···

       
25
       
 
       
  "ae/aer": "ae",

     

       
26
       
 
       
  "prince/princes/princeself": "prince",

     

       
27
       
 
       
  "ze/hir": "ze",

     

       
0
       
 
       

     

       
0
       
 
       

     

       
28
       
 
       
};

     

       
29
       
 
       


     

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

     
···

       
78
       
 
       
    "prince/princes/princeself",

     

       
79
       
 
       
  "at://did:plc:wkoofae5uytcm7bjncmev6n6/app.bsky.feed.post/3kwvcc736wg2n":

     

       
80
       
 
       
    "ze/hir",

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
81
       
 
       
};

     

       
82
       
 
       


     

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

     

···

       
25
       
 
       
  "ae/aer": "ae",

     

       
26
       
 
       
  "prince/princes/princeself": "prince",

     

       
27
       
 
       
  "ze/hir": "ze",

     

       
28
       
+
       
  "dey/deren": "dey",

     

       
29
       
+
       
  none: "none",

     

       
30
       
 
       
};

     

       
31
       
 
       


     

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

     
···

       
80
       
 
       
    "prince/princes/princeself",

     

       
81
       
 
       
  "at://did:plc:wkoofae5uytcm7bjncmev6n6/app.bsky.feed.post/3kwvcc736wg2n":

     

       
82
       
 
       
    "ze/hir",

     

       
83
       
+
       
  "at://did:plc:wkoofae5uytcm7bjncmev6n6/app.bsky.feed.post/3kwwwvsvcnz2h":

     

       
84
       
+
       
    "dey/deren",

     

       
85
       
+
       
  "at://did:plc:wkoofae5uytcm7bjncmev6n6/app.bsky.feed.post/3kwxljuxooh2r":

     

       
86
       
+
       
    "none",

     

       
87
       
 
       
};

     

       
88
       
 
       


     

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

     

···

       
11
       
 
       
    .withProxy("atproto_labeler", DID)

     

       
12
       
 
       
    .api.tools.ozone.moderation.getRepo({ did: did })

     

       
13
       
 
       
    .catch((err) => {

     

       
14
       
-
       
      console.log({

     

       
15
       
-
       
        error: err,

     

       
16
       
-
       
      });

     

       
17
       
 
       
    });

     

       
18
       
 
       


     

       
19
       
 
       
  if (!repo) return;

     
···

       
38
       
 
       
        subjectBlobCids: [],

     

       
39
       
 
       
      })

     

       
40
       
 
       
      .catch((err) => {

     

       
41
       
-
       
        console.log({

     

       
42
       
-
       
          error: err,

     

       
43
       
-
       
        });

     

       
44
       
 
       
      })

     

       
45
       
 
       
      .then(() => console.log(`Deleted labels for ${did}`));

     

       
46
       
 
       
    return;

     
···

       
66
       
 
       
        subjectBlobCids: [],

     

       
67
       
 
       
      })

     

       
68
       
 
       
      .catch((err) => {

     

       
69
       
-
       
        console.log({

     

       
70
       
-
       
          error: err,

     

       
71
       
-
       
        });

     

       
72
       
 
       
      })

     

       
73
       
 
       
      .then(() => console.log(`Labeled ${did} with ${post}`));

     

       
74
       
 
       
  }

     

···

       
11
       
 
       
    .withProxy("atproto_labeler", DID)

     

       
12
       
 
       
    .api.tools.ozone.moderation.getRepo({ did: did })

     

       
13
       
 
       
    .catch((err) => {

     

       
14
       
+
       
      console.log(err);

     

       
0
       
 
       

     

       
0
       
 
       

     

       
15
       
 
       
    });

     

       
16
       
 
       


     

       
17
       
 
       
  if (!repo) return;

     
···

       
36
       
 
       
        subjectBlobCids: [],

     

       
37
       
 
       
      })

     

       
38
       
 
       
      .catch((err) => {

     

       
39
       
+
       
        console.log(err);

     

       
0
       
 
       

     

       
0
       
 
       

     

       
40
       
 
       
      })

     

       
41
       
 
       
      .then(() => console.log(`Deleted labels for ${did}`));

     

       
42
       
 
       
    return;

     
···

       
62
       
 
       
        subjectBlobCids: [],

     

       
63
       
 
       
      })

     

       
64
       
 
       
      .catch((err) => {

     

       
65
       
+
       
        console.log(err);

     

       
0
       
 
       

     

       
0
       
 
       

     

       
66
       
 
       
      })

     

       
67
       
 
       
      .then(() => console.log(`Labeled ${did} with ${post}`));

     

       
68
       
 
       
  }

     

···

       
3
       
 
       
import { getAgent } from "./agent.js";

     

       
4
       
 
       
import { label } from "./label.js";

     

       
5
       
 
       
import { DID } from "./constants.js";

     

       
6
       
-
       
import "dotenv/config";

     

       
7
       
 
       


     

       
8
       
 
       
const subscribe = async () => {

     

       
9
       
 
       
  const agent = await getAgent();

     

       
10
       
-
       
  let cursorSave = 0;

     

       
11
       
 
       


     

       
12
       
-
       
  // TODO: save cursor to a file

     

       
13
       
-
       
  const firehose = new Firehose({ cursor: process.env.CURSOR ?? "" });

     

       
14
       
 
       


     

       
15
       
-
       
  firehose.on("error", ({ cursor }) => {

     

       
16
       
-
       
    console.log(`Firehose errored on cursor: ${cursor}`);

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
17
       
 
       
  });

     

       
18
       
 
       


     

       
19
       
 
       
  firehose.on("open", () => {

     

       
20
       
 
       
    setInterval(() => {

     

       
21
       
-
       
      console.log(`cursor: ${cursorSave}`);

     

       
0
       
 
       

     

       
0
       
 
       

     

       
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)) {

     

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

     

···

       
3
       
 
       
import { getAgent } from "./agent.js";

     

       
4
       
 
       
import { label } from "./label.js";

     

       
5
       
 
       
import { DID } from "./constants.js";

     

       
6
       
+
       
import fs from "node:fs";

     

       
7
       
 
       


     

       
8
       
 
       
const subscribe = async () => {

     

       
9
       
 
       
  const agent = await getAgent();

     

       
0
       
 
       

     

       
10
       
 
       


     

       
11
       
+
       
  let cursorFirehose = 0;

     

       
12
       
+
       
  let cursorFile = fs.readFileSync("cursor.txt", "utf8");

     

       
13
       
 
       


     

       
14
       
+
       
  const firehose = new Firehose({ cursor: cursorFile ?? "" });

     

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

     

       
16
       
+
       


     

       
17
       
+
       
  firehose.on("error", ({ cursor, error }) => {

     

       
18
       
+
       
    console.log(`Firehose errored on cursor: ${cursor}`, error);

     

       
19
       
 
       
  });

     

       
20
       
 
       


     

       
21
       
 
       
  firehose.on("open", () => {

     

       
22
       
 
       
    setInterval(() => {

     

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

     

       
24
       
+
       
        if (err) console.error(err);

     

       
25
       
+
       
      });

     

       
26
       
 
       
    }, 60000);

     

       
27
       
 
       
  });

     

       
28
       
 
       


     

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

     

       
30
       
+
       
    cursorFirehose = commit.seq;

     

       
31
       
 
       
    commit.ops.forEach(async (op) => {

     

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

     

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