-
Notifications
You must be signed in to change notification settings - Fork 3
/
server.js
33 lines (29 loc) · 876 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
if (!process.env.NODE_DEBUG) {
console.debug = () => {};
}
const startInvoker = require("./lib/invoker");
const userFunctionUri = process.env.FUNCTION_URI;
if (typeof userFunctionUri === "undefined" || userFunctionUri.trim() === "") {
throw "FUNCTION_URI envvar not set or empty. Aborting.";
}
console.time("riff-invoker");
const port = process.env.GRPC_PORT || "8081";
const shutdownSignal = new Promise((resolve) => {
process.once("SIGTERM", resolve);
process.once("SIGINT", resolve);
});
(async () => {
try {
const { shutdownPromise } = await startInvoker(
userFunctionUri,
{ port },
shutdownSignal
);
await shutdownPromise;
console.timeEnd("riff-invoker");
process.exit(0);
} catch (err) {
console.timeEnd("riff-invoker");
process.exit(1);
}
})();