use getOptionsProp method on grcp max_send_message_length & max_receive_message_length implementation

Author: hschiavone

packages/microservices/constants.ts

@@ -27,3 +27,5 @@ export const RQM_DEFAULT_IS_GLOBAL_PREFETCH_COUNT = false;
 export const RQM_DEFAULT_QUEUE_OPTIONS = {};
 
 export const GRPC_DEFAULT_PROTO_LOADER = '@grpc/proto-loader';
+export const GRPC_DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH = 4 * 1024 * 1024;
+export const GRPC_DEFAULT_MAX_SEND_MESSAGE_LENGTH = 4 * 1024 * 1024;

packages/microservices/server/server-grpc.ts

@@ -1,6 +1,12 @@
 import { fromEvent } from 'rxjs';
 import { takeUntil } from 'rxjs/operators';
-import { CANCEL_EVENT, GRPC_DEFAULT_PROTO_LOADER, GRPC_DEFAULT_URL } from '../constants';
+import {
+  CANCEL_EVENT,
+  GRPC_DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH,
+  GRPC_DEFAULT_MAX_SEND_MESSAGE_LENGTH,
+  GRPC_DEFAULT_PROTO_LOADER,
+  GRPC_DEFAULT_URL
+} from '../constants';
 import { InvalidGrpcPackageException } from '../exceptions/errors/invalid-grpc-package.exception';
 import { InvalidProtoDefinitionException } from '../exceptions/errors/invalid-proto-definition.exception';
 import { CustomTransportStrategy } from '../interfaces';
@@ -15,20 +21,13 @@ let grpcProtoLoaderPackage: any = {};
 
 export class ServerGrpc extends Server implements CustomTransportStrategy {
   private readonly url: string;
-  private readonly maxSendMessageLength: number;
-  private readonly maxReceiveMessageLength: number;
   private grpcClient: any;
 
   constructor(private readonly options: MicroserviceOptions['options']) {
     super();
     this.url =
       this.getOptionsProp<GrpcOptions>(options, 'url') || GRPC_DEFAULT_URL;
 
-    this.maxSendMessageLength =
-      this.getOptionsProp<GrpcOptions>(options, 'maxSendMessageLength') || GRPC_DEFAULT_URL;
-    this.maxReceiveMessageLength =
-      this.getOptionsProp<GrpcOptions>(options, 'maxReceiveMessageLength') || GRPC_DEFAULT_URL;
-
     const protoLoader =
       this.getOptionsProp<GrpcOptions>(options, 'protoLoader') || GRPC_DEFAULT_PROTO_LOADER;
 
@@ -145,8 +144,8 @@ export class ServerGrpc extends Server implements CustomTransportStrategy {
 
   public createClient(): any {
     const server = new grpcPackage.Server({
-      ...this.maxSendMessageLength ? { 'grpc.max_send_message_length': this.maxSendMessageLength } : {},
-      ...this.maxReceiveMessageLength ? { 'grpc.max_receive_message_length': this.maxReceiveMessageLength } : {}
+      'grpc.max_send_message_length': this.getOptionsProp<GrpcOptions>(this.options, 'maxSendMessageLength', GRPC_DEFAULT_MAX_SEND_MESSAGE_LENGTH),
+      'grpc.max_receive_message_length': this.getOptionsProp<GrpcOptions>(this.options, 'maxReceiveMessageLength', GRPC_DEFAULT_MAX_RECEIVE_MESSAGE_LENGTH)
   });
     const credentials = this.getOptionsProp<GrpcOptions>(
       this.options,