···

       
8
       
 
       
  let cursor = 0;

     

       
9
       
 
       
  let intervalID: NodeJS.Timeout;

     

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

     

       
11
       
-
       


     

       
12
       
 
       
  const relay = cursorFile ? RELAY.concat("&cursor=", cursorFile) : RELAY;

     

       
0
       
 
       

     

       
13
       
 
       
  if (cursorFile) console.log(`Initiate firehose at cursor ${cursorFile}`);

     

       
14
       
-
       
  const ws = new WebSocket(relay);

     

       
15
       
 
       


     

       
16
       
 
       
  ws.on("error", (err) => console.error(err));

     

       
17
       
 
       


     

       
18
       
 
       
  ws.on("open", () => {

     

       
19
       
 
       
    intervalID = setInterval(() => {

     

       
20
       
 
       
      console.log(`${new Date().toISOString()}: ${cursor}`);

     

       
21
       
-
       
      fs.writeFile("cursor.txt", cursor.toString(), (err) => console.log(err));

     

       
0
       
 
       

     

       
0
       
 
       

     

       
22
       
 
       
    }, 60000);

     

       
23
       
 
       
  });

     

       
24
       
 
       


     

       
25
       
-
       
  ws.on("close", () => {

     

       
26
       
-
       
    clearInterval(intervalID);

     

       
27
       
-
       
  });

     

       
28
       
 
       


     

       
29
       
 
       
  ws.on("message", (data) => {

     

       
30
       
 
       
    const event: EventStream = JSON.parse(data.toString());

     

       
31
       
 
       
    cursor = event.time_us;

     

       
32
       
 
       
    if (

     

       
33
       
-
       
      event.commit?.record?.subject?.uri?.includes(DID + "/app.bsky.feed.post")

     

       
34
       
 
       
    ) {

     

       
35
       
 
       
      label(event.did, event.commit.record.subject.uri.split("/").pop()!);

     

       
36
       
 
       
    }

     

···

       
8
       
 
       
  let cursor = 0;

     

       
9
       
 
       
  let intervalID: NodeJS.Timeout;

     

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

     

       
0
       
 
       

     

       
11
       
 
       
  const relay = cursorFile ? RELAY.concat("&cursor=", cursorFile) : RELAY;

     

       
12
       
+
       
  const ws = new WebSocket(relay);

     

       
13
       
 
       
  if (cursorFile) console.log(`Initiate firehose at cursor ${cursorFile}`);

     

       
0
       
 
       

     

       
14
       
 
       


     

       
15
       
 
       
  ws.on("error", (err) => console.error(err));

     

       
16
       
 
       


     

       
17
       
 
       
  ws.on("open", () => {

     

       
18
       
 
       
    intervalID = setInterval(() => {

     

       
19
       
 
       
      console.log(`${new Date().toISOString()}: ${cursor}`);

     

       
20
       
+
       
      fs.writeFile("cursor.txt", cursor.toString(), (err) => {

     

       
21
       
+
       
        if (err) console.log(err);

     

       
22
       
+
       
      });

     

       
23
       
 
       
    }, 60000);

     

       
24
       
 
       
  });

     

       
25
       
 
       


     

       
26
       
+
       
  ws.on("close", () => clearInterval(intervalID));

     

       
0
       
 
       

     

       
0
       
 
       

     

       
27
       
 
       


     

       
28
       
 
       
  ws.on("message", (data) => {

     

       
29
       
 
       
    const event: EventStream = JSON.parse(data.toString());

     

       
30
       
 
       
    cursor = event.time_us;

     

       
31
       
 
       
    if (

     

       
32
       
+
       
      event.commit?.record?.subject?.uri?.includes(`${DID}/app.bsky.feed.post`)

     

       
33
       
 
       
    ) {

     

       
34
       
 
       
      label(event.did, event.commit.record.subject.uri.split("/").pop()!);

     

       
35
       
 
       
    }