-
Notifications
You must be signed in to change notification settings - Fork 104
Expand file tree
/
Copy pathindex.ts
More file actions
75 lines (65 loc) · 2.36 KB
/
index.ts
File metadata and controls
75 lines (65 loc) · 2.36 KB
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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
import "./polyfill";
import "./tracer";
import { initServer } from "./server";
import { env } from "./shared/utils/env";
import { logger } from "./shared/utils/logger";
import { initWorker } from "./worker";
import { CancelRecycledNoncesQueue } from "./worker/queues/cancel-recycled-nonces-queue";
import { MineTransactionQueue } from "./worker/queues/mine-transaction-queue";
import { NonceResyncQueue } from "./worker/queues/nonce-resync-queue";
import { ProcessEventsLogQueue } from "./worker/queues/process-event-logs-queue";
import { ProcessTransactionReceiptsQueue } from "./worker/queues/process-transaction-receipts-queue";
import { PruneTransactionsQueue } from "./worker/queues/prune-transactions-queue";
import { SendTransactionQueue } from "./worker/queues/send-transaction-queue";
import { SendWebhookQueue } from "./worker/queues/send-webhook-queue";
const main = async () => {
if (env.ENGINE_MODE === "server_only") {
initServer();
} else if (env.ENGINE_MODE === "worker_only") {
initWorker();
} else {
initServer();
initWorker();
}
};
main();
// Adding handlers for `uncaughtException` & `unhandledRejection`
// Needs to be root level of your application to ensure it
// catches any unhandledRejections or uncaughtException that occur throughout
// entire codebase
process.on("uncaughtException", (err) => {
logger({
message: "Uncaught Exception",
service: "server",
level: "error",
error: err,
});
});
process.on("unhandledRejection", (err) => {
logger({
message: "Unhandled Rejection",
service: "server",
level: "error",
error: err,
});
});
process.on("SIGINT", () => gracefulShutdown("SIGINT"));
process.on("SIGTERM", () => gracefulShutdown("SIGTERM"));
const gracefulShutdown = async (signal: NodeJS.Signals) => {
logger({
level: "info",
service: "server",
message: `Received ${signal}, closing server...`,
});
// Gracefully close workers to minimize stalled jobs.
// Source: https://docs.bullmq.io/guide/going-to-production#gracefully-shut-down-workers
await SendWebhookQueue.q.close();
await ProcessEventsLogQueue.q.close();
await ProcessTransactionReceiptsQueue.q.close();
await SendTransactionQueue.q.close();
await MineTransactionQueue.q.close();
await CancelRecycledNoncesQueue.q.close();
await PruneTransactionsQueue.q.close();
await NonceResyncQueue.q.close();
process.exit(0);
};