it happened!

This commit is contained in:
Julien Calixte
2026-02-08 01:50:11 +01:00
parent f0456ca39d
commit d9d794ba1d

54
main.ts
View File

@@ -2,39 +2,37 @@ import { Jetstream } from "@skyware/jetstream";
const jetstream = new Jetstream({ const jetstream = new Jetstream({
wantedCollections: [ wantedCollections: [
"site.standard.graph.subscription",
"site.standard.publication",
"site.standard.document",
"space.litenote.note", "space.litenote.note",
], ],
}); });
// Handle standard posts
jetstream.onCreate("site.standard.graph.subscription", (event) => {
// Check if it references litenote content
const { did, commit } = event
console.log(did, commit);
});
jetstream.onCreate("site.standard.publication", (event) => {
// Check if it references litenote content
const { did, commit } = event
console.log(did, commit);
});
// Handle standard posts
jetstream.onCreate("site.standard.document", (event) => {
// Check if it references litenote content
const { did, commit } = event
console.log(did, commit);
});
// Handle your custom posts
jetstream.onCreate("space.litenote.note", (event) => { jetstream.onCreate("space.litenote.note", (event) => {
// Process litenote-specific data
const { did, commit } = event const { did, commit } = event
console.log(did, commit); console.log("create", did, commit);
}); });
jetstream.start(); jetstream.onUpdate("space.litenote.note", (event) => {
const { did, commit } = event
console.log("update", did, commit);
});
jetstream.on("close", () => {
console.log("Connection closed, PartySocket will reconnect automatically");
});
console.log("launching jetstream")
jetstream.start();
// Keep the process alive and provide a health check
Bun.serve({
port: 3000,
routes: {
"/health": () => new Response("ok"),
},
fetch() {
return new Response("Not Found", { status: 404 });
},
});