nice-grpc-client-middleware-deadline

import { createChannel, createClientFactory, createClient, ClientError, status } from 'nice-grpc'; import { createDeadlineClientMiddleware } from 'nice-grpc-client-middleware-deadline'; import { ProtoGrpcType } from './greeter'; // Assuming you have compiled protobufs import { GreeterClient, GreeterDefinition } from './greeter/Greeter'; // Adjust based on your proto compilation interface HelloRequest { name: string; } interface HelloResponse { message: string; } // Mock Service Definition (replace with your compiled proto definition) const GreeterServiceDefinition: GreeterDefinition = { // @ts-ignore - In a real scenario, this would come from compiled protos name: 'Greeter', // @ts-ignore methods: { SayHello: { path: '/Greeter/SayHello', requestStream: false, responseStream: false, requestType: { type: 'HelloRequest' }, responseType: { type: 'HelloResponse' }, }, }, }; async function main() { const channel = createChannel('localhost:50051'); const clientFactory = createClientFactory() .use(createDeadlineClientMiddleware()); const client: GreeterClient = clientFactory.create(GreeterServiceDefinition, channel); console.log('Client created with deadline middleware.'); try { // Example 1: Call with a specific deadline (500 ms from now) const response1 = await client.sayHello({ name: 'Alice', }, { deadline: Date.now() + 500, // Call will timeout if server doesn't respond in 500ms }); console.log(`Response from SayHello (Alice): ${response1.message}`); } catch (error) { if (error instanceof ClientError && error.code === status.DEADLINE_EXCEEDED) { console.error('Call for Alice exceeded deadline!'); } else { console.error('Error calling SayHello for Alice:', error); } } try { // Example 2: Call without an explicit deadline (will use any factory-wide default or gRPC's default) const response2 = await client.sayHello({ name: 'Bob', }); console.log(`Response from SayHello (Bob): ${response2.message}`); } catch (error) { console.error('Error calling SayHello for Bob:', error); } // To demonstrate a factory-wide default deadline: const clientFactoryWithDefaultDeadline = createClientFactory() .use(createDeadlineClientMiddleware()) .use(async (call, options) => call.next(call, { ...options, deadline: Date.now() + 2000 })); // 2-second default const clientWithDefault: GreeterClient = clientFactoryWithDefaultDeadline.create(GreeterServiceDefinition, channel); try { console.log('\nAttempting call with 2-second default deadline...'); const response3 = await clientWithDefault.sayHello({ name: 'Charlie' }); console.log(`Response from SayHello (Charlie): ${response3.message}`); } catch (error) { if (error instanceof ClientError && error.code === status.DEADLINE_EXCEEDED) { console.error('Call for Charlie exceeded default deadline!'); } else { console.error('Error calling SayHello for Charlie:', error); } } channel.close(); } main().catch(console.error);