| import * as grpc from '@grpc/grpc-js'; |
| import * as flatbuffers from 'flatbuffers'; |
| import {GreeterClient} from './greeter_grpc'; |
| import {HelloReply} from './models/hello-reply'; |
| import {HelloRequest} from './models/hello-request'; |
| |
| async function main(PORT: Number, name: string) { |
| const client = new GreeterClient( |
| `localhost:${PORT}`, |
| grpc.credentials.createInsecure(), |
| ); |
| const builder = new flatbuffers.Builder(); |
| const offset = builder.createString(name); |
| const root = HelloRequest.createHelloRequest(builder, offset); |
| builder.finish(root); |
| const buffer = HelloRequest.getRootAsHelloRequest( |
| new flatbuffers.ByteBuffer(builder.asUint8Array()), |
| ); |
| |
| client.SayHello(buffer, (err, response) => { |
| console.log(response.message()); |
| }); |
| |
| const data = client.SayManyHellos(buffer, null); |
| |
| data.on('data', (data) => { |
| console.log(data.message()); |
| }); |
| } |
| |
| const args = process.argv.slice(2); |
| const PORT = Number(args[0]); |
| const name: string = args[1] ?? 'flatbuffers'; |
| |
| if (PORT) { |
| main(PORT, name); |
| } else { |
| throw new Error('Requires a valid port number.'); |
| } |