···

       
29
       
29
       
 
       
    clearInterval(intervalID);

     

       
30
       
30
       
 
       
  });

     

       
31
       
31
       
 
       


     

       
32
       
32
       
-
       
  ws.on("message", async (data) => {

     

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

     

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

     

       
34
       
34
       
 
       
    cursor = event.time_us;

     

       
35
       
35
       
 
       
    if (

     

       
36
       
36
       
 
       
      event.type.includes("com") &&

     

       
37
       
37
       
 
       
      event.commit?.record?.subject.uri.includes(DID)

     

       
38
       
38
       
 
       
    ) {

     

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

     

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

     

       
40
       
40
       
 
       
    }

     

       
41
       
41
       
 
       
  });

     

       
42
       
42
       
 
       
};