this repo has no description
Add logging helper
+10
-6
+10
-6
src/main.ts
+10
-6
src/main.ts
···
9
9
let cursor = 0;
10
10
let cursorUpdateInterval: NodeJS.Timeout;
11
11
12
+
function epochUsToDateTime(cursor: number): string {
13
+
return new Date(cursor / 1000).toISOString();
14
+
}
15
+
12
16
try {
13
17
logger.info('Trying to read cursor from cursor.txt...');
14
18
cursor = Number(fs.readFileSync('cursor.txt', 'utf8'));
15
-
logger.info(`Cursor found: ${cursor} (${new Date(cursor / 1000).toISOString()})`);
19
+
logger.info(`Cursor found: ${cursor} (${epochUsToDateTime(cursor)})`);
16
20
} catch (error) {
17
21
if (error instanceof Error && 'code' in error && error.code === 'ENOENT') {
18
-
logger.info(
19
-
`Cursor not found in cursor.txt, setting cursor to: ${cursor} (${new Date(cursor / 1000).toISOString()})`,
20
-
);
22
+
logger.info(`Cursor not found in cursor.txt, setting cursor to: ${cursor} (${epochUsToDateTime(cursor)})`);
21
23
fs.writeFileSync('cursor.txt', cursor.toString(), 'utf8');
22
24
} else {
23
25
logger.error(error);
···
32
34
});
33
35
34
36
jetstream.on('open', () => {
35
-
logger.info(`Connected to Jetstream at ${FIREHOSE_URL} with cursor ${jetstream.cursor}`);
37
+
logger.info(
38
+
`Connected to Jetstream at ${FIREHOSE_URL} with cursor ${jetstream.cursor} (${epochUsToDateTime(jetstream.cursor!)})`,
39
+
);
36
40
cursorUpdateInterval = setInterval(() => {
37
41
if (jetstream.cursor) {
38
-
logger.info(`Cursor updated to: ${jetstream.cursor} (${new Date(jetstream.cursor / 1000).toISOString()})`);
42
+
logger.info(`Cursor updated to: ${jetstream.cursor} (${epochUsToDateTime(jetstream.cursor)})`);
39
43
fs.writeFile('cursor.txt', cursor.toString(), (err) => {
40
44
if (err) logger.error(err);
41
45
});