···

       
4
       
4
       
 
       
import fs from "node:fs";

     

       
5
       
5
       
 
       
import WebSocket from "ws";

     

       
6
       
6
       
 
       


     

       
7
       
7
       
-
       
const subscribe = () => {

     

       
7
       
7
       
+
       
const subscribe = async () => {

     

       
8
       
8
       
 
       
  let cursor = 0;

     

       
9
       
9
       
 
       
  let intervalID: NodeJS.Timeout;

     

       
10
       
10
       
 
       
  const cursorFile = fs.readFileSync("cursor.txt", "utf8");