Pronouns labels on Bluesky
pronouns.diy
1import { label } from "./label.js";
2import { DID } from "./constants.js";
3import fs from "node:fs";
4import { Jetstream } from "@skyware/jetstream";
5import { AppBskyFeedLike } from "@atcute/client/lexicons";
6
7let cursor = 0;
8let intervalID: NodeJS.Timeout;
9const cursorFile = fs.readFileSync("cursor.txt", "utf8");
10if (cursorFile) console.log(`Initiate firehose at cursor ${cursorFile}`);
11
12const jetstream = new Jetstream({
13 wantedCollections: ["app.bsky.feed.like"],
14 cursor: cursorFile ?? 0,
15});
16
17jetstream.on("open", () => {
18 intervalID = setInterval(() => {
19 console.log(`${new Date().toISOString()}: ${cursor}`);
20 fs.writeFile("cursor.txt", cursor.toString(), (err) => {
21 if (err) console.log(err);
22 });
23 }, 60000);
24});
25
26jetstream.on("error", (err) => console.error(err));
27
28jetstream.on("close", () => clearInterval(intervalID));
29
30jetstream.onCreate("app.bsky.feed.like", (event) => {
31 cursor = event.time_us;
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
37jetstream.start();