-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.js
34 lines (30 loc) · 923 Bytes
/
server.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
const grpc = require("grpc");
const protoLoader = require("@grpc/proto-loader");
const packageDef = protoLoader.loadSync("todo.proto", {});
const grpcObject = grpc.loadPackageDefinition(packageDef);
const todoPackage = grpcObject.todoPackage;
const server = new grpc.Server();
server.bind("0.0.0.0:40000", grpc.ServerCredentials.createInsecure());
server.addService(todoPackage.Todo.service,
{
"createTodo": createTodo,
"readTodos": readTodos,
"readTodosStream": readTodosStream
});
server.start();
const todos = [];
function createTodo(call, callback) {
const todoItem = {
"id": todos.length + 1,
"text": call.request.text
};
todos.push(todoItem);
callback(null, todoItem);
}
function readTodos(call, callback) {
callback(null, { "items": todos });
}
function readTodosStream(call, callback) {
todos.forEach(t => call.write(t));
call.end();
}