const { GrpcReflection } = require('grpc-js-reflection-client'); const grpc = require('@grpc/grpc-js'); /**  * List services  */ try { (async () => { const c = new GrpcReflection( '0.0.0.0:50051', grpc.ChannelCredentials.createInsecure(), // { // "grpc.max_connection_age_ms": 10*1000, // 'grpc.keepalive_time_ms': 10 * 1000, // // Keepalive ping timeout after 5 seconds, default is 20 seconds. // 'grpc.keepalive_timeout_ms': 5 * 1000, // // Allow keepalive pings when there are no gRPC calls. // 'grpc.keepalive_permit_without_calls': 1, // "grpc.initial_reconnect_backoff_ms": 1000, // } ); console.log(await c.listServices()); })(); }catch(e){ console.log(e); }

const { GrpcReflection } = require('grpc-js-reflection-client'); const grpc = require('@grpc/grpc-js'); function getChannelCredentials() { return grpc.ChannelCredentials.createSsl(); } try { (async()=> { const client = new GrpcReflection( 'grpcb.in:9001', getChannelCredentials(), ); console.log(await client.listServices()); })(); }catch(e){ console.log(e) }

const { GrpcReflection } = require('grpc-js-reflection-client'); const grpc = require('@grpc/grpc-js'); function getChannelCredentials() { return grpc.ChannelCredentials.createSsl(); } try { (async()=> { const client = new GrpcReflection( 'grpcb.in:9001', getChannelCredentials(), ); const methods = await client.listMethods('grpc.gateway.examples.examplepb.ABitOfEverythingService'); console.log(methods.map(method => method.name)); })(); }catch(e){ console.log(e) }

cat <<EOF > server.js const grpc = require('@grpc/grpc-js'); const { ReflectionService } = require('@grpc/reflection'); const protoLoader = require('@grpc/proto-loader'); const def_options = { keepCase: true, longs: String, enums: String, defaults: true, oneofs: true }; const packageDefinition = protoLoader.loadSync( __dirname + 'addressbook.proto', // https://raw.githubusercontent.com/gawsoftpl/grpc-js-reflection-api-client/main/tests/protos/addressbook.proto def_options ); const addressbook = grpc.loadPackageDefinition(packageDefinition) // This wraps the instance of gRPC server with the Server Reflection service and returns it. const server = new grpc.Server(); const reflection = new ReflectionService(packageDefinition); reflection.addToServer(server); server.addService( //@ts-ignore addressbook.addressbook.AddressesService.service, { Add: (_, callback) => { callback(null, { success: true, id: "123" }); } } ) server.bindAsync("127.0.0.1:3000", grpc.ServerCredentials.createInsecure(),() => { server.start(); console.log("Server started on port 3000"); }); EOF

cat <<EOF > client.js const { GrpcReflection } = require('grpc-js-reflection-client'); const grpc = require('@grpc/grpc-js'); /**  * Get proto descriptor from reflection grpc api and get in @grpc/grpc-js format  *  * */ const host = "127.0.0.1:3000" try { (async()=>{ // Connect with grpc server reflection const client = new GrpcReflection(host, grpc.ChannelCredentials.createInsecure()); // Get services without proto file for specific symbol or file name const descriptor = await client.getDescriptorByFileName('addressbook.proto'); // Create package services const packageObject = descriptor.getPackageObject({ keepCase: true, enums: String, longs: String }); // Send request over grpc const proto = new packageObject.addressbook.AddressesService( host, grpc.ChannelCredentials.createInsecure(), ); proto.Add({ name: "abc", email: "test@example.com" },(err,data)=>{ if(err) { console.log(err); }else{ console.log(data); } }); })(); }catch(e){ console.log(e); } EOF

const { serviceHelper } = require('grpc-js-reflection-client'); const grpc = require('@grpc/grpc-js'); (async()=>{ const proto = await serviceHelper({ host: "localhost:50053", servicePath: "addressbook.AddressesService", credentials: grpc.ChannelCredentials.createInsecure(), proto_filename: 'addressbook.proto', protoLoaderOptions: { keepCase: true } }) proto.Add({ name: "abc", email: "test@example.com" }, (err, response) => { console.log(response) }); })();