···

       
19
       
 
       
  "shey/sheir/sher": "shey",

     

       
20
       
 
       
  "voi/void": "voi",

     

       
21
       
 
       
  "mew/mews": "mew",

     

       
0
       
 
       

     

       
22
       
 
       
};

     

       
23
       
 
       


     

       
24
       
 
       
export const URIs: Record<string, string> = {

     
···

       
60
       
 
       
    "voi/void",

     

       
61
       
 
       
  "at://did:plc:wkoofae5uytcm7bjncmev6n6/app.bsky.feed.post/3kwueewr2p22j":

     

       
62
       
 
       
    "mew/mews",

     

       
0
       
 
       

     

       
0
       
 
       

     

       
63
       
 
       
};

     

       
64
       
 
       


     

       
65
       
 
       
export const DID = process.env.DID ?? "";

     

···

       
19
       
 
       
  "shey/sheir/sher": "shey",

     

       
20
       
 
       
  "voi/void": "voi",

     

       
21
       
 
       
  "mew/mews": "mew",

     

       
22
       
+
       
  "paw/paws": "paw",

     

       
23
       
 
       
};

     

       
24
       
 
       


     

       
25
       
 
       
export const URIs: Record<string, string> = {

     
···

       
61
       
 
       
    "voi/void",

     

       
62
       
 
       
  "at://did:plc:wkoofae5uytcm7bjncmev6n6/app.bsky.feed.post/3kwueewr2p22j":

     

       
63
       
 
       
    "mew/mews",

     

       
64
       
+
       
  "at://did:plc:wkoofae5uytcm7bjncmev6n6/app.bsky.feed.post/3kwukwwz4nt2j":

     

       
65
       
+
       
    "paw/paws",

     

       
66
       
 
       
};

     

       
67
       
 
       


     

       
68
       
 
       
export const DID = process.env.DID ?? "";

     

···

       
22
       
 
       
    }, 60000);

     

       
23
       
 
       
  });

     

       
24
       
 
       


     

       
25
       
-
       
  firehose.on("commit", (commit) => {

     

       
26
       
 
       
    cursorSave = commit.seq;

     

       
27
       
-
       
    for (const op of commit.ops) {

     

       
28
       
-
       
      if (op.action === "delete") continue;

     

       
29
       
-
       
      if (AppBskyFeedLike.isRecord(op.record)) {

     

       
30
       
 
       
        if ((op.record.subject.uri ?? "").includes(DID)) {

     

       
31
       
 
       
          if ((op.record.subject.uri ?? "").includes("app.bsky.feed.post")) {

     

       
32
       
-
       
            label(agent, commit.repo, op.record.subject.uri).catch((err) =>

     

       
33
       
-
       
              console.error(err),

     

       
34
       
 
       
            );

     

       
35
       
 
       
          }

     

       
36
       
 
       
        }

     

       
37
       
 
       
      }

     

       
38
       
-
       
    }

     

       
39
       
 
       
  });

     

       
40
       
 
       


     

       
41
       
 
       
  firehose.start();

     

···

       
22
       
 
       
    }, 60000);

     

       
23
       
 
       
  });

     

       
24
       
 
       


     

       
25
       
+
       
  firehose.on("commit", async (commit) => {

     

       
26
       
 
       
    cursorSave = commit.seq;

     

       
27
       
+
       
    commit.ops.forEach(async (op) => {

     

       
28
       
+
       
      if (op.action !== "delete" && AppBskyFeedLike.isRecord(op.record)) {

     

       
0
       
 
       

     

       
29
       
 
       
        if ((op.record.subject.uri ?? "").includes(DID)) {

     

       
30
       
 
       
          if ((op.record.subject.uri ?? "").includes("app.bsky.feed.post")) {

     

       
31
       
+
       
            await label(agent, commit.repo, op.record.subject.uri).catch(

     

       
32
       
+
       
              (err) => console.error(err),

     

       
33
       
 
       
            );

     

       
34
       
 
       
          }

     

       
35
       
 
       
        }

     

       
36
       
 
       
      }

     

       
37
       
+
       
    });

     

       
38
       
 
       
  });

     

       
39
       
 
       


     

       
40
       
 
       
  firehose.start();