this repo has no description
Better shutdown, fix cursor bug
+10
-11
+10
-11
src/main.ts
+10
-11
src/main.ts
···
40
40
cursorUpdateInterval = setInterval(() => {
41
41
if (jetstream.cursor) {
42
42
logger.info(`Cursor updated to: ${jetstream.cursor} (${epochUsToDateTime(jetstream.cursor)})`);
43
-
fs.writeFile('cursor.txt', cursor.toString(), (err) => {
43
+
fs.writeFile('cursor.txt', jetstream.cursor.toString(), (err) => {
44
44
if (err) logger.error(err);
45
45
});
46
46
}
···
78
78
jetstream.start();
79
79
80
80
function shutdown() {
81
-
setTimeout(() => {
82
-
logger.error('Forcing shutdown...');
81
+
try {
82
+
logger.info('Shutting down gracefully...');
83
+
fs.writeFileSync('cursor.txt', jetstream.cursor!.toString(), 'utf8');
84
+
jetstream.close();
85
+
labelerServer.stop();
86
+
metricsServer.close();
87
+
} catch (error) {
88
+
logger.error(`Error shutting down gracefully: ${error}`);
83
89
process.exit(1);
84
-
}, 60000);
85
-
86
-
logger.info('Shutting down gracefully...');
87
-
jetstream.close();
88
-
labelerServer.stop();
89
-
metricsServer.close();
90
-
clearInterval(cursorUpdateInterval);
91
-
fs.writeFileSync('cursor.txt', cursor.toString(), 'utf8');
90
+
}
92
91
}
93
92
94
93
process.on('SIGINT', shutdown);