···

       
13
       
 
       
        "dotenv": "^16.4.5"

     

       
14
       
 
       
      },

     

       
15
       
 
       
      "devDependencies": {

     

       
16
       
-
       
        "@atcute/bluesky": "^1.0.6",

     

       
17
       
 
       
        "@types/node": "^22.7.5",

     

       
18
       
 
       
        "typescript": "^5.5.3"

     

       
19
       
 
       
      }

     

···

       
13
       
 
       
        "dotenv": "^16.4.5"

     

       
14
       
 
       
      },

     

       
15
       
 
       
      "devDependencies": {

     

       
0
       
 
       

     

       
16
       
 
       
        "@types/node": "^22.7.5",

     

       
17
       
 
       
        "typescript": "^5.5.3"

     

       
18
       
 
       
      }

     

···

       
6
       
 
       
    "start": "npx tsx src/main.ts"

     

       
7
       
 
       
  },

     

       
8
       
 
       
  "devDependencies": {

     

       
9
       
-
       
    "@atcute/bluesky": "^1.0.6",

     

       
10
       
 
       
    "@types/node": "^22.7.5",

     

       
11
       
 
       
    "typescript": "^5.5.3"

     

       
12
       
 
       
  },

     

···

       
6
       
 
       
    "start": "npx tsx src/main.ts"

     

       
7
       
 
       
  },

     

       
8
       
 
       
  "devDependencies": {

     

       
0
       
 
       

     

       
9
       
 
       
    "@types/node": "^22.7.5",

     

       
10
       
 
       
    "typescript": "^5.5.3"

     

       
11
       
 
       
  },

     

···

       
1
       
 
       
import "dotenv/config";

     

       
2
       
 
       


     

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

     

       
4
       
-
       
export const SIGNING_KEY = process.env.SIGNING_KEY ?? "";

     

       
5
       
 
       
export const PORT = Number(process.env.PORT ?? 4001);

     

       
6
       
 
       
export const URL = process.env.URL ?? "wss://jetstream.atproto.tools/subscribe";

     

       
7
       
-
       
export const LABEL_LIMIT = 4;

     

       
8
       
 
       
export const DELETE = "3kwsqucto3j2a";

     

       
9
       
 
       
export const POSTS: Record<string, string> = {

     

       
10
       
 
       
  "3kwss4ldkwd2j": "they",

     

···

       
1
       
 
       
import "dotenv/config";

     

       
2
       
 
       


     

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

     

       
4
       
+
       
export const SIGN_KEY = process.env.SIGNING_KEY ?? "";

     

       
5
       
 
       
export const PORT = Number(process.env.PORT ?? 4001);

     

       
6
       
 
       
export const URL = process.env.URL ?? "wss://jetstream.atproto.tools/subscribe";

     

       
7
       
+
       
export const MAXLABELS = 4;

     

       
8
       
 
       
export const DELETE = "3kwsqucto3j2a";

     

       
9
       
 
       
export const POSTS: Record<string, string> = {

     

       
10
       
 
       
  "3kwss4ldkwd2j": "they",

     

···

       
1
       
 
       
import { ComAtprotoLabelDefs } from "@atcute/client/lexicons";

     

       
2
       
-
       
import {

     

       
3
       
-
       
  DID,

     

       
4
       
-
       
  PORT,

     

       
5
       
-
       
  LABEL_LIMIT,

     

       
6
       
-
       
  POSTS,

     

       
7
       
-
       
  SIGNING_KEY,

     

       
8
       
-
       
  DELETE,

     

       
9
       
-
       
} from "./constants.js";

     

       
10
       
 
       
import { LabelerServer } from "@skyware/labeler";

     

       
11
       
 
       


     

       
12
       
-
       
const server = new LabelerServer({ did: DID, signingKey: SIGNING_KEY });

     

       
13
       
-
       


     

       
14
       
 
       
server.start(PORT, (error, address) => {

     

       
15
       
 
       
  if (error) console.error(error);

     

       
16
       
 
       
  else console.log(`Labeler server listening on ${address}`);

     
···

       
31
       
 
       
    if (rkey.includes(DELETE)) {

     

       
32
       
 
       
      server.createLabels({ uri: did }, { negate: [...labels] });

     

       
33
       
 
       
      console.log(`${new Date().toISOString()} Deleted labels: ${did}`);

     

       
34
       
-
       
    } else if (labels.size < LABEL_LIMIT && POSTS[rkey]) {

     

       
35
       
 
       
      server.createLabel({ uri: did, val: POSTS[rkey] });

     

       
36
       
 
       
      console.log(`${new Date().toISOString()} Labeled ${did}: ${POSTS[rkey]}`);

     

       
37
       
 
       
    }

     

···

       
1
       
 
       
import { ComAtprotoLabelDefs } from "@atcute/client/lexicons";

     

       
2
       
+
       
import { DID, PORT, MAXLABELS, POSTS, SIGN_KEY, DELETE } from "./constants.js";

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
3
       
 
       
import { LabelerServer } from "@skyware/labeler";

     

       
4
       
 
       


     

       
5
       
+
       
const server = new LabelerServer({ did: DID, signingKey: SIGN_KEY });

     

       
0
       
 
       

     

       
6
       
 
       
server.start(PORT, (error, address) => {

     

       
7
       
 
       
  if (error) console.error(error);

     

       
8
       
 
       
  else console.log(`Labeler server listening on ${address}`);

     
···

       
23
       
 
       
    if (rkey.includes(DELETE)) {

     

       
24
       
 
       
      server.createLabels({ uri: did }, { negate: [...labels] });

     

       
25
       
 
       
      console.log(`${new Date().toISOString()} Deleted labels: ${did}`);

     

       
26
       
+
       
    } else if (labels.size < MAXLABELS && POSTS[rkey]) {

     

       
27
       
 
       
      server.createLabel({ uri: did, val: POSTS[rkey] });

     

       
28
       
 
       
      console.log(`${new Date().toISOString()} Labeled ${did}: ${POSTS[rkey]}`);

     

       
29
       
 
       
    }

     

···

       
2
       
 
       
import { DID, URL } from "./constants.js";

     

       
3
       
 
       
import fs from "node:fs";

     

       
4
       
 
       
import { Jetstream } from "@skyware/jetstream";

     

       
5
       
-
       
import { AppBskyFeedLike } from "@atcute/client/lexicons";

     

       
6
       
 
       


     

       
7
       
 
       
let intervalID: NodeJS.Timeout;

     

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

     

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

     

       
10
       
 
       


     

       
11
       
 
       
const jetstream = new Jetstream({

     

       
12
       
 
       
  endpoint: URL,

     
···

       
16
       
 
       


     

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

     

       
18
       
 
       
  intervalID = setInterval(() => {

     

       
19
       
-
       
    if (jetstream.cursor) {

     

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

     

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

     

       
22
       
-
       
      });

     

       
23
       
-
       
    }

     

       
24
       
 
       
  }, 60000);

     

       
25
       
 
       
});

     

       
26
       
 
       


     

       
27
       
 
       
jetstream.on("error", (err) => console.error(err));

     

       
28
       
-
       


     

       
29
       
 
       
jetstream.on("close", () => clearInterval(intervalID));

     

       
30
       
 
       


     

       
31
       
 
       
jetstream.onCreate("app.bsky.feed.like", (event) => {

     

       
32
       
-
       
  const record = event.commit.record as AppBskyFeedLike.Record;

     

       
33
       
-
       
  if (record.subject?.uri?.includes(`${DID}/app.bsky.feed.post`))

     

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

     

       
35
       
 
       
});

     

       
36
       
 
       


     

       
37
       
 
       
jetstream.start();

     

···

       
2
       
 
       
import { DID, URL } from "./constants.js";

     

       
3
       
 
       
import fs from "node:fs";

     

       
4
       
 
       
import { Jetstream } from "@skyware/jetstream";

     

       
0
       
 
       

     

       
5
       
 
       


     

       
6
       
 
       
let intervalID: NodeJS.Timeout;

     

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

     

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

     

       
9
       
 
       


     

       
10
       
 
       
const jetstream = new Jetstream({

     

       
11
       
 
       
  endpoint: URL,

     
···

       
15
       
 
       


     

       
16
       
 
       
jetstream.on("open", () => {

     

       
17
       
 
       
  intervalID = setInterval(() => {

     

       
18
       
+
       
    if (!jetstream.cursor) return;

     

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

     

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

     

       
21
       
+
       
    });

     

       
0
       
 
       

     

       
22
       
 
       
  }, 60000);

     

       
23
       
 
       
});

     

       
24
       
 
       


     

       
25
       
 
       
jetstream.on("error", (err) => console.error(err));

     

       
0
       
 
       

     

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

     

       
27
       
 
       


     

       
28
       
 
       
jetstream.onCreate("app.bsky.feed.like", (event) => {

     

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

     

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

     

       
0
       
 
       

     

       
31
       
 
       
});

     

       
32
       
 
       


     

       
33
       
 
       
jetstream.start();