amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat(microservices): support ncc when using grpc

Browse Source
This commit is contained in:
zmj
2021-11-17 15:22:12 +08:00
parent ac70acedad
commit 3d9539268c
2 changed files with 17 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
packages/microservices/client/client-grpc.ts
View File

@@ -31,7 +31,14 @@ export class ClientGrpcProxy extends ClientProxy implements ClientGrpc {
require('@grpc/grpc-js'),
);
grpcProtoLoaderPackage = loadPackage(protoLoader, ClientGrpcProxy.name);
grpcProtoLoaderPackage = loadPackage(
protoLoader,
ClientGrpcProxy.name,
() =>
protoLoader === GRPC_DEFAULT_PROTO_LOADER
? require('@grpc/proto-loader')
: require(protoLoader),
);
this.grpcClients = this.createClients();
}
@@ -278,7 +285,7 @@ export class ClientGrpcProxy extends ClientProxy implements ClientGrpc {
const packageDefinition =
this.getOptionsProp(this.options, 'packageDefinition') ||
grpcProtoLoaderPackage.loadSync(file, loader);
const packageObject =
grpcPackage.loadPackageDefinition(packageDefinition);
return packageObject;

9
packages/microservices/server/server-grpc.ts
View File

@@ -48,7 +48,14 @@ export class ServerGrpc extends Server implements CustomTransportStrategy {
grpcPackage = this.loadPackage('@grpc/grpc-js', ServerGrpc.name, () =>
require('@grpc/grpc-js'),
);
grpcProtoLoaderPackage = this.loadPackage(protoLoader, ServerGrpc.name);
grpcProtoLoaderPackage = this.loadPackage(
protoLoader,
ServerGrpc.name,
() =>
protoLoader === GRPC_DEFAULT_PROTO_LOADER
? require('@grpc/proto-loader')
: require(protoLoader),
);
}
public async listen(