mirror of
https://github.com/Kong/insomnia
synced 2024-11-12 17:26:32 +00:00
3234c05c6e
* Enable noImplicitAny. * extracts PreviewMode * Update packages/insomnia/src/network/certificate-url-parse.ts * Add missing type. * un-any-ifies some of the modal onDone callbacks easy enough. * few more onDone, but the async ones this time * Get rid of jsonlint any. * adds noImplicitAny support for insomnia-smoke-test * fixes playwright type error * avoid full @ts-ignore in playwright Co-authored-by: Dimitri Mitropoulos <dimitrimitropoulos@gmail.com>
47 lines
1.5 KiB
TypeScript
47 lines
1.5 KiB
TypeScript
// inspiration: https://github.com/grpc/grpc/blob/e963544eef6a76f9f86d43418ee2ac57aebba6f6/examples/node/dynamic_codegen/greeter_server.js
|
|
import * as grpc from '@grpc/grpc-js';
|
|
import { HandleCall } from '@grpc/grpc-js/build/src/server-call';
|
|
import * as protoLoader from '@grpc/proto-loader';
|
|
import path from 'path';
|
|
|
|
const PROTO_PATH = path.resolve('../../packages/insomnia/src/network/grpc/__fixtures__/library/hello.proto');
|
|
const packageDefinition = protoLoader.loadSync(
|
|
PROTO_PATH,
|
|
{
|
|
keepCase: true,
|
|
longs: String,
|
|
enums: String,
|
|
defaults: true,
|
|
oneofs: true,
|
|
});
|
|
|
|
const helloProto = grpc.loadPackageDefinition(packageDefinition).hello;
|
|
|
|
/**
|
|
* Implements the SayHello RPC method.
|
|
*/
|
|
// eslint-disable-next-line @typescript-eslint/no-explicit-any
|
|
const sayHello: HandleCall<any, any> = (call: any, callback: any) => {
|
|
callback(null, { reply: call.request.greeting });
|
|
};
|
|
|
|
/**
|
|
* Starts an RPC server that receives requests for the Greeter service at the given port
|
|
*/
|
|
export const startGRPCServer = (port: number) => {
|
|
return new Promise<void>((resolve, reject) => {
|
|
const server = new grpc.Server();
|
|
// @ts-expect-error generated from proto file
|
|
server.addService(helloProto.HelloService.service, { sayHello });
|
|
server.bindAsync(`localhost:${port}`, grpc.ServerCredentials.createInsecure(), error => {
|
|
if (error) {
|
|
return reject(error);
|
|
}
|
|
|
|
console.log(`Listening at grpc://localhost:${port}`);
|
|
server.start();
|
|
resolve();
|
|
});
|
|
});
|
|
};
|