use atcute for jetstream

bun.lock

···
     "": {
       "name": "bluesky",
       "dependencies": {
+        "@atcute/bluesky": "^3.2.2",
+        "@atcute/jetstream": "^1.1.0",
+        "@atcute/lexicons": "^1.1.1",
         "@skyware/bot": "^0.4.0",
-        "@skyware/jetstream": "^0.2.5",
         "@skyware/labeler": "^0.2.0",
       },
       "devDependencies": {
···
     "@atcute/client": ["@atcute/client@4.0.3", "", { "dependencies": { "@atcute/identity": "^1.0.2", "@atcute/lexicons": "^1.0.3" } }, "sha512-RIOZWFVLca/HiPAAUDqQPOdOreCxTbL5cb+WUf5yqQOKIu5yEAP3eksinmlLmgIrlr5qVOE7brazUUzaskFCfw=="],
 
     "@atcute/identity": ["@atcute/identity@1.1.0", "", { "dependencies": { "@atcute/lexicons": "^1.1.1", "@badrap/valita": "^0.4.5" } }, "sha512-6vRvRqJatDB+JUQsb+UswYmtBGQnSZcqC3a2y6H5DB/v5KcIh+6nFFtc17G0+3W9rxdk7k9M4KkgkdKf/YDNoQ=="],
+
+    "@atcute/jetstream": ["@atcute/jetstream@1.1.0", "", { "dependencies": { "@atcute/lexicons": "^1.1.1", "@badrap/valita": "^0.4.6", "@mary-ext/event-iterator": "^1.0.0", "@mary-ext/simple-event-emitter": "^1.0.0", "partysocket": "^1.1.5", "type-fest": "^4.41.0", "yocto-queue": "^1.2.1" } }, "sha512-XrSeEHLt2FnVNm3KBDQYY7+rWM0IQKBjLQUjdoCj4mnkMCdm3/dC09qs5ubQQGrHieUWeKHHEko/D6EB891hPg=="],
 
     "@atcute/lexicons": ["@atcute/lexicons@1.1.1", "", { "dependencies": { "esm-env": "^1.2.2" } }, "sha512-k6qy5p3j9fJJ6ekaMPfEfp3ni4TW/XNuH9ZmsuwC0fi0tOjp+Fa8ZQakHwnqOzFt/cVBfGcmYE/lKNAbeTjgUg=="],
 
···
     "@libsql/linux-x64-musl": ["@libsql/linux-x64-musl@0.4.7", "", { "os": "linux", "cpu": "x64" }, "sha512-nI6tpS1t6WzGAt1Kx1n1HsvtBbZ+jHn0m7ogNNT6pQHZQj7AFFTIMeDQw/i/Nt5H38np1GVRNsFe99eSIMs9XA=="],
 
     "@libsql/win32-x64-msvc": ["@libsql/win32-x64-msvc@0.4.7", "", { "os": "win32", "cpu": "x64" }, "sha512-7pJzOWzPm6oJUxml+PCDRzYQ4A1hTMHAciTAHfFK4fkbDZX33nWPVG7Y3vqdKtslcwAzwmrNDc6sXy2nwWnbiw=="],
+
+    "@mary-ext/event-iterator": ["@mary-ext/event-iterator@1.0.0", "", { "dependencies": { "yocto-queue": "^1.2.1" } }, "sha512-l6gCPsWJ8aRCe/s7/oCmero70kDHgIK5m4uJvYgwEYTqVxoBOIXbKr5tnkLqUHEg6mNduB4IWvms3h70Hp9ADQ=="],
+
+    "@mary-ext/simple-event-emitter": ["@mary-ext/simple-event-emitter@1.0.0", "", {}, "sha512-meA/zJZKIN1RVBNEYIbjufkUrW7/tRjHH60FjolpG1ixJKo76TB208qefQLNdOVDA7uIG0CGEDuhmMirtHKLAg=="],
 
     "@neon-rs/load": ["@neon-rs/load@0.0.4", "", {}, "sha512-kTPhdZyTQxB+2wpiRcFWrDcejc4JI6tkPuS7UZCG4l6Zvc5kU/gGQ/ozvHTh1XR5tS+UlfAfGuPajjzQjCiHCw=="],
 
···
     "tiny-emitter": ["tiny-emitter@2.1.0", "", {}, "sha512-NB6Dk1A9xgQPMoGqC5CVXn123gWyte215ONT5Pp5a0yt4nlEoO1ZWeCwpncaekPHXO60i47ihFnZPiRPjRMq4Q=="],
 
     "toad-cache": ["toad-cache@3.7.0", "", {}, "sha512-/m8M+2BJUpoJdgAHoG+baCwBT+tf2VraSfkBgl0Y00qIWt41DJ8R5B8nsEw0I58YwF5IZH6z24/2TobDKnqSWw=="],
+
+    "type-fest": ["type-fest@4.41.0", "", {}, "sha512-TeTSQ6H5YHvpqVwBRcnLDCBnDOHWYu7IvGbHT6N8AOymcr9PJGjc1GTtiWZTYg0NCgYwvnYWEkVChQAr9bjfwA=="],
 
     "typescript": ["typescript@5.9.2", "", { "bin": { "tsc": "bin/tsc", "tsserver": "bin/tsserver" } }, "sha512-CWBzXQrc/qOkhidw1OzBTQuYRbfyxDXJMVJ1XNwUHGROVmuaeiEm3OslpZ1RV96d7SKKjZKrSJu3+t/xlw3R9A=="],
 

index.ts

···
+import { AppBskyFeedPost } from "@atcute/bluesky";
+import { JetstreamSubscription } from "@atcute/jetstream";
+import { is } from "@atcute/lexicons";
 import { LabelerServer } from "@skyware/labeler";
-import { Jetstream } from "@skyware/jetstream";
 
 const server = new LabelerServer({
-    did: process.env.LABELER_DID,
-    signingKey: process.env.SIGNING_KEY
+	did: process.env.LABELER_DID,
+	signingKey: process.env.SIGNING_KEY,
 });
 
 server.start(14831, (error) => {
-    if (error) {
-        console.error("Failed to start server:", error);
-    } else {
-        console.log("Labeler server running on port 14831");
-    }
+	if (error) {
+		console.error("Failed to start server:", error);
+	} else {
+		console.log("Labeler server running on port 14831");
+	}
 });
 
-const jetstream = new Jetstream();
-jetstream.start();
-
-jetstream.onCreate("app.bsky.feed.post", async (event) => {
-  try {
-    if (event.commit.record.text.includes("BlueSky")) {
-      console.log("Labeling: ", JSON.stringify(event.commit))
-      await server.createLabel({
-          uri: event.did,
-          val: "blue-sky",
-      });
-    }
-  } catch (e) {
-    console.error(`Error occured on record ${event.commit.cid}: `, (e as Error).toString())
-  }
+const subscription = new JetstreamSubscription({
+	url: "wss://jetstream2.us-east.bsky.network",
+	wantedCollections: ["app.bsky.feed.post"],
 });
+
+for await (const event of subscription) {
+	if (event.kind === "commit") {
+		const commit = event.commit;
+
+		if (commit.collection !== "app.bsky.feed.post") {
+			continue;
+		}
+
+		if (commit.operation === "create") {
+			const record = commit.record;
+			if (!is(AppBskyFeedPost.mainSchema, record)) {
+				continue;
+			}
+
+			try {
+				if (record.text.includes("BlueSky")) {
+					console.log("Labeling: ", JSON.stringify(event.commit));
+					await server.createLabel({
+						uri: event.did,
+						val: "blue-sky",
+					});
+				}
+			} catch (e) {
+				console.error(
+					`Error occured on record ${commit.cid}: `,
+					(e as Error).toString(),
+				);
+			}
+		}
+	}
+}

package.json

···
     "typescript": "^5"
   },
   "dependencies": {
+    "@atcute/bluesky": "^3.2.2",
+    "@atcute/jetstream": "^1.1.0",
+    "@atcute/lexicons": "^1.1.1",
     "@skyware/bot": "^0.4.0",
-    "@skyware/jetstream": "^0.2.5",
     "@skyware/labeler": "^0.2.0"
   }
 }