t1c.dev
+10
-6
index.ts
+10
-6
index.ts
···
18
18
jetstream.start();
19
19
20
20
jetstream.onCreate("app.bsky.feed.post", async (event) => {
21
-
if (event.commit.record.text.includes("BlueSky")) {
22
-
console.log("Labeling: ", JSON.stringify(event.commit))
23
-
await server.createLabel({
24
-
uri: event.did,
25
-
val: "blue-sky",
26
-
});
21
+
try {
22
+
if (event.commit.record.text.includes("BlueSky")) {
23
+
console.log("Labeling: ", JSON.stringify(event.commit))
24
+
await server.createLabel({
25
+
uri: event.did,
26
+
val: "blue-sky",
27
+
});
28
+
}
29
+
} catch (e) {
30
+
console.error(`Error occured on record ${event.commit.cid}: `, (e as Error).toString())
27
31
}
28
32
});