typescript-grpc

a minimalistic annotation-based typescript library to help build grpc servers and clients.

Usage

$ yarn add typescript-grpc protobufjs grpc @grpc/proto-loader --save

See src/example.ts

import debug from 'debug';
import { Type, Field, Message } from 'protobufjs';
import { load } from '@grpc/proto-loader';
import { Server, ServiceDefinition, ServerCredentials } from 'grpc';
 
import { Service, Method, generateProto, wrapServiceMethods } from 'typescript-grpc';
 
const log = debug('typescript-grpc:example');
 
@Type.d()
class Movie extends Message<Movie> {
  @Field.d(1, 'string')
  name: string;
 
  @Field.d(2, 'int32')
  year: number;
 
  @Field.d(3, 'float')
  rating: number;
 
  @Field.d(4, 'string', 'repeated')
  cast: string[];
}
 
@Type.d()
class MoviesResult extends Message<MoviesResult> {
  @Field.d(1, Movie, 'repeated')
  result: Movie[];
}
 
@Type.d()
class EmptyRequest extends Message<EmptyRequest> {}
 
@Service()
class ExampleService {
  @Method({
    requestType: 'EmptyRequest',
    requestStream: false,
    responseType: 'MoviesResult',
    responseStream: false,
  })
  async getMovies(req: EmptyRequest): Promise<MoviesResult> {
    log('get movies called');
    return new MoviesResult({ result: [] });
  }
}
 
async function main(): Promise<void> {
  const service = new ExampleService();
  log(service);
 
  const protoPath = await generateProto('example');
 
  const packageDefinition = await load(protoPath, {
    keepCase: true,
  });
 
  const server = new Server({
    'grpc.max_send_message_length': -1,
    'grpc.max_receive_message_length': -1,
  });
 
  server.addService(packageDefinition[service.constructor.name] as ServiceDefinition<any>, wrapServiceMethods(service));
  server.bind('0.0.0.0:50051', ServerCredentials.createInsecure());
  server.start();
 
  log(`server started`);
}
 
main();
 

Features

• Modern service method handlers via Promise and rxjs streams (TODO)
• Auto proto generation using annotations