diff --git a/packages/api-gateway/src/Bootstrap/Container.ts b/packages/api-gateway/src/Bootstrap/Container.ts index 106c308ee..6e3634951 100644 --- a/packages/api-gateway/src/Bootstrap/Container.ts +++ b/packages/api-gateway/src/Bootstrap/Container.ts @@ -160,6 +160,11 @@ export class ContainerConfigLoader { const grpcAgentKeepAliveTimeout = env.get('GRPC_AGENT_KEEP_ALIVE_TIMEOUT', true) ? +env.get('GRPC_AGENT_KEEP_ALIVE_TIMEOUT', true) : 8_000 + + const grpcMaxMessageSize = env.get('GRPC_MAX_MESSAGE_SIZE', true) + ? +env.get('GRPC_MAX_MESSAGE_SIZE', true) + : 1024 * 1024 * 50 + container.bind(TYPES.ApiGateway_GRPCSessionsClient).toConstantValue( new SessionsClient( container.get(TYPES.ApiGateway_AUTH_SERVER_GRPC_URL), @@ -169,6 +174,8 @@ export class ContainerConfigLoader { 'grpc.keepalive_timeout_ms': grpcAgentKeepAliveTimeout, 'grpc.default_compression_algorithm': grpc.compressionAlgorithms.gzip, 'grpc.default_compression_level': 2, + 'grpc.max_receive_message_length': grpcMaxMessageSize, + 'grpc.max_send_message_length': grpcMaxMessageSize, }, ), ) @@ -181,6 +188,8 @@ export class ContainerConfigLoader { 'grpc.keepalive_timeout_ms': grpcAgentKeepAliveTimeout, 'grpc.default_compression_algorithm': grpc.compressionAlgorithms.gzip, 'grpc.default_compression_level': 2, + 'grpc.max_receive_message_length': grpcMaxMessageSize, + 'grpc.max_send_message_length': grpcMaxMessageSize, }, ), ) diff --git a/packages/auth/bin/server.ts b/packages/auth/bin/server.ts index fee79533a..89506b2bb 100644 --- a/packages/auth/bin/server.ts +++ b/packages/auth/bin/server.ts @@ -81,10 +81,16 @@ void container.load().then((container) => { ? +env.get('GRPC_KEEP_ALIVE_TIMEOUT', true) : 10_000 + const grpcMaxMessageSize = env.get('GRPC_MAX_MESSAGE_SIZE', true) + ? +env.get('GRPC_MAX_MESSAGE_SIZE', true) + : 1024 * 1024 * 50 + const grpcServer = new grpc.Server({ 'grpc.keepalive_time_ms': grpcKeepAliveTimeout * 2, 'grpc.keepalive_timeout_ms': grpcKeepAliveTimeout, 'grpc.default_compression_algorithm': grpc.compressionAlgorithms.gzip, + 'grpc.max_receive_message_length': grpcMaxMessageSize, + 'grpc.max_send_message_length': grpcMaxMessageSize, }) const gRPCPort = env.get('GRPC_PORT', true) ? +env.get('GRPC_PORT', true) : 50051 diff --git a/packages/syncing-server/bin/server.ts b/packages/syncing-server/bin/server.ts index 4770a6d3d..6602eba34 100644 --- a/packages/syncing-server/bin/server.ts +++ b/packages/syncing-server/bin/server.ts @@ -89,10 +89,16 @@ void container.load().then((container) => { ? +env.get('GRPC_KEEP_ALIVE_TIMEOUT', true) : 10_000 + const grpcMaxMessageSize = env.get('GRPC_MAX_MESSAGE_SIZE', true) + ? +env.get('GRPC_MAX_MESSAGE_SIZE', true) + : 1024 * 1024 * 50 + const grpcServer = new grpc.Server({ 'grpc.keepalive_time_ms': grpcKeepAliveTimeout * 2, 'grpc.keepalive_timeout_ms': grpcKeepAliveTimeout, 'grpc.default_compression_algorithm': grpc.compressionAlgorithms.gzip, + 'grpc.max_receive_message_length': grpcMaxMessageSize, + 'grpc.max_send_message_length': grpcMaxMessageSize, }) const gRPCPort = env.get('GRPC_PORT', true) ? +env.get('GRPC_PORT', true) : 50051