Fix grpc send and receive sizes.

Author: LINCKODE

legacy/app/archive-query-service/main.go

@@ -44,7 +44,7 @@ func run() error {
 			StatusDataCacheTtl    time.Duration `conf:"default:1s"`  // nolint:revive
 			EmptyTicksTtl         time.Duration `conf:"default:24h"` // nolint:revive
 			MaxRecvSizeInMb       int           `conf:"default:1"`
-			MaxSendSizeInMb       int           `conf:"default:10"`
+			MaxSendSizeInMb       int           `conf:"default:2"`
 		}
 		ElasticSearch struct {
 			Address                               []string      `conf:"default:https://localhost:9200"`

legacy/rpc/rpc_server.go

@@ -717,11 +717,13 @@ func (s *Server) Start(cfg StartConfig, interceptors ...grpc.UnaryServerIntercep
 			mux := runtime.NewServeMux(runtime.WithMarshalerOption(runtime.MIMEWildcard, &runtime.JSONPb{
 				MarshalOptions: protojson.MarshalOptions{EmitDefaultValues: true, EmitUnpopulated: true},
 			}))
+			// Configuration for the http gateway grpc client (http request -> http gateway (grpc client) -> grpc server)
+			// The send and recv values are reversed on purpose as the client's send is the server's receive and vice versa.
 			opts := []grpc.DialOption{
 				grpc.WithTransportCredentials(insecure.NewCredentials()),
 				grpc.WithDefaultCallOptions(
-					grpc.MaxCallRecvMsgSize(cfg.MaxRecvMsgSize),
-					grpc.MaxCallSendMsgSize(cfg.MaxSendMsgSize),
+					grpc.MaxCallRecvMsgSize(cfg.MaxSendMsgSize),
+					grpc.MaxCallSendMsgSize(cfg.MaxRecvMsgSize),
 				),
 			}
 			if err := protobuf.RegisterTransactionsServiceHandlerFromEndpoint(

v2/cmd/archive-query-service/main.go

@@ -48,7 +48,7 @@ func run() error {
 			CacheEnabled          bool          `conf:"default:false"`
 			CacheTTLFile          string        `conf:"default:cache_ttl.json"`
 			MaxRecvSizeInMb       int           `conf:"default:1"`
-			MaxSendSizeInMb       int           `conf:"default:10"`
+			MaxSendSizeInMb       int           `conf:"default:2"`
 		}
 		Pagination struct {
 			MaxPageSize     uint32 `conf:"default:1000"`

v2/grpc/server.go

@@ -46,11 +46,13 @@ func (s *ArchiveQueryService) Start(cfg StartConfig, errCh chan error, intercept
 			mux := runtime.NewServeMux(runtime.WithMarshalerOption(runtime.MIMEWildcard, &runtime.JSONPb{
 				MarshalOptions: protojson.MarshalOptions{EmitDefaultValues: true, EmitUnpopulated: true},
 			}))
+			// Configuration for the http gateway grpc client (http request -> http gateway (grpc client) -> grpc server)
+			// The send and recv values are reversed on purpose as the client's send is the server's receive and vice versa.
 			opts := []grpc.DialOption{
 				grpc.WithTransportCredentials(insecure.NewCredentials()),
 				grpc.WithDefaultCallOptions(
-					grpc.MaxCallRecvMsgSize(cfg.MaxRecvMsgSize),
-					grpc.MaxCallSendMsgSize(cfg.MaxSendMsgSize),
+					grpc.MaxCallRecvMsgSize(cfg.MaxSendMsgSize),
+					grpc.MaxCallSendMsgSize(cfg.MaxRecvMsgSize),
 				),
 			}