blob: 62444f1ebc379f79234f5d573bb392d8359d97a1 [file] [log] [blame]
James Kuszmaul8e62b022022-03-22 09:33:25 -07001import * as grpc from '@grpc/grpc-js';
2import * as flatbuffers from 'flatbuffers';
3import { HelloReply } from './models/hello-reply';
4import { HelloRequest } from './models/hello-request';
5import { GreeterClient } from './greeter_grpc';
6
7async function main(PORT: Number, name: string) {
8 const client = new GreeterClient(`localhost:${PORT}`, grpc.credentials.createInsecure());
9 const builder = new flatbuffers.Builder();
10 const offset = builder.createString(name);
11 const root = HelloRequest.createHelloRequest(builder, offset);
12 builder.finish(root);
13 const buffer = HelloRequest.getRootAsHelloRequest(new flatbuffers.ByteBuffer(builder.asUint8Array()));
14
15 client.SayHello(buffer, (err, response) => {
16 console.log(response.message());
17 });
18
19 const data = client.SayManyHellos(buffer, null);
20
21 data.on('data', (data) => {
22 console.log(data.message());
23 });
24}
25
26const args = process.argv.slice(2)
27const PORT = Number(args[0]);
28const name: string = args[1] ?? "flatbuffers";
29
30if (PORT) {
31 main(PORT, name);
32} else {
33 throw new Error("Requires a valid port number.")
34}