Merge pull request #8465 from aaronschweig/feature/grpc-package-defin…

…ition feat(microservices): adds packageDefinition option to ClientGrpc
nestjs · Nov 8, 2021 · d47fc51 · d47fc51
2 parents fdcf5b2 + 3b74293
commit d47fc51
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/packages/microservices/client/client-grpc.ts b/packages/microservices/client/client-grpc.ts
@@ -34,6 +34,7 @@ export class ClientGrpcProxy extends ClientProxy implements ClientGrpc {
     grpcPackage = loadPackage('@grpc/grpc-js', ClientGrpcProxy.name, () =>
       require('@grpc/grpc-js'),
     );
+
     grpcProtoLoaderPackage = loadPackage(protoLoader, ClientGrpcProxy.name);
     this.grpcClients = this.createClients();
   }
@@ -286,7 +287,10 @@ export class ClientGrpcProxy extends ClientProxy implements ClientGrpc {
       const file = this.getOptionsProp(this.options, 'protoPath');
       const loader = this.getOptionsProp(this.options, 'loader');
 
-      const packageDefinition = grpcProtoLoaderPackage.loadSync(file, loader);
+      const packageDefinition =
+        this.getOptionsProp(this.options, 'packageDefinition') ||
+        grpcProtoLoaderPackage.loadSync(file, loader);
+
       const packageObject =
         grpcPackage.loadPackageDefinition(packageDefinition);
       return packageObject;

diff --git a/packages/microservices/interfaces/microservice-configuration.interface.ts b/packages/microservices/interfaces/microservice-configuration.interface.ts
@@ -33,7 +33,9 @@ export interface CustomStrategy {
 export interface GrpcOptions {
   transport?: Transport.GRPC;
   options: {
-    interceptors?: Array<(options: any, nextCall: (options: any) => any) => any>;
+    interceptors?: Array<
+      (options: any, nextCall: (options: any) => any) => any
+    >;
     url?: string;
     maxSendMessageLength?: number;
     maxReceiveMessageLength?: number;
@@ -52,6 +54,7 @@ export interface GrpcOptions {
     protoPath: string | string[];
     package: string | string[];
     protoLoader?: string;
+    packageDefinition?: any;
     loader?: {
       keepCase?: boolean;
       alternateCommentMode?: boolean;