commit 776673903553d1050d7257e67fe1ea0f27698a32 · pronouns.diy/pronouns-bsky

+6 -8
src/main.ts
···

       25
       25
        
           }, 60000);

     

       26
       26
        
         });

     

       27
       27
        
       

     

       28
       28
       -
         ws.on("close", function close() {

     

       28
       28
       +
         ws.on("close", () => {

     

       29
       29
        
           clearInterval(intervalID);

     

       30
       30
        
         });

     

       31
       31
        
       

     

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

     

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

     

       34
       34
        
           cursor = event.time_us;

     

       35
       35
       -
           if (event.type.includes("com")) {

     

       36
       36
       -
             if (event.commit?.record?.subject.uri.includes(DID)) {

     

       37
       37
       -
               await label(

     

       38
       38
       -
                 event.did,

     

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

     

       40
       40
       -
               );

     

       41
       41
       -
             }

     

       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()!);

     

       42
       40
        
           }

     

       43
       41
        
         });

     

       44
       42
        
       };