this repo has no description
remove cursor check
-6
-6
src/main.ts
-6
src/main.ts
···
9
9
const agent = await getAgent();
10
10
11
11
let cursorFirehose = 0;
12
-
let oldCursor = 0;
13
12
let cursorFile = fs.readFileSync("cursor.txt", "utf8");
14
13
15
14
const firehose = new Firehose({ cursor: cursorFile ?? "" });
···
21
20
22
21
firehose.on("open", () => {
23
22
setInterval(() => {
24
-
if (oldCursor && oldCursor == cursorFirehose) {
25
-
firehose.close();
26
-
subscribe();
27
-
}
28
-
oldCursor = cursorFirehose;
29
23
const timestamp = new Date().toISOString();
30
24
console.log(`${timestamp} cursor: ${cursorFirehose}`);
31
25
fs.writeFile("cursor.txt", cursorFirehose.toString(), (err) => {