grpc-kit

grpc-kit

Use grpc more simply on Node.js.

quick start

install

$ npm install grpc @grpc/proto-loader grpc-kit

proto

syntax="proto3";

package greeter;

service Greeter {
  rpc Hello (RequestGreet) returns (ResponseGreet) {}
  rpc Goodbye (RequestGreet) returns (ResponseGreet) {}
}

message RequestGreet {
  string name = 1;
}

message ResponseGreet {
  string message = 1;
}

Server

const {createServer} = require("grpc-kit");
const server = createServer();

server.use({
  protoPath: "/path/to/greeter.proto",
  packageName: "greeter",
  serviceName: "Greeter",
  routes: {
    hello: (call, callback) => {
      callback(null, { message: `Hello, ${call.request.name}` });
    },
    goodbye: async (call) => {
      return { message: `Goodbye, ${call.request.name}` };
    }
  }
});
server.listen("0.0.0.0:50051");

Client

const {createClient} = require("grpc-kit");
const client = createClient({
  protoPath: "/path/to/greeter.proto",
  packageName: "greeter",
  serviceName: "Greeter"
}, "0.0.0.0:50051");

client.hello({ name: "Jack" }, (err, { message }) => {
  if(err) throw err;
  console.log(message);
});

client.goodbye({ name: "John" }, (err, { message }) => {
  if(err) throw err;
  console.log(message);
});

api

createServer(): GrpcServer

Create GrpcServer instance. GrpcServer is a wrapper class of grpc.Server providing simplified api to register services.

GrpcServer.use({protoPath,packageName,serviceName,routes}): GrpcServer

Register a service to provide from a server.

arg name	type	required/optional	description
protoPath	String	Required	path to .proto file
packageName	String	Required	name of package
serviceName	String	Required	name of service
routes	{ [methodName]:(call, callback) => void | (call) => Promise }	Required	routing map consists of a set of pair of method name and handler. Both of sync function and async function are available as a handler

GrpcServer.listen(address_port, credentials): GrpcServer

Start server. Alias to grpc.Server.bind() and grpc.Server.start().

arg name	type	required/optional	description
address_port	String	Required	address and port of server to listen
credentials	grpc.ServerCredentials	Optional	grpc server credentials. Default to insecure credentials generated by grpc.ServerCredentials.createInsecure()

GrpcServer.close(force, callback): GrpcServer

Close server. Alias to grpc.Server.tryShutdown() and grpc.Server.forceShutdown.

arg name	type	required/optional	description
force	Boolean	Optional	flag if force shutdown or not. Default to false
callback	()=>{}	Optional	call when shutdown completed. available only when force is false

createClient({protoPath,packageName,serviceName},address_port,credentials): grpc.Client

Create grpc.Client instance.

arg name	type	required/optional	description
protoPath	String	Required	path to .proto file
packageName	String	Required	name of package
serviceName	String	Required	name of service
address_port	String	Required	address and port of server to listen
credentials	grpc.ChannelCredentials	Optional	grpc channel credentials. Default to insecure credentials generated by grpc.credentials.createInsecure()