41 lines
803 B
TypeScript
41 lines
803 B
TypeScript
import { Jetstream } from "@skyware/jetstream";
|
|
import { createNote, updateNote } from "./src/data/db"
|
|
|
|
const jetstream = new Jetstream({
|
|
wantedCollections: ["space.litenote.note"],
|
|
});
|
|
|
|
jetstream.onCreate("space.litenote.note", (event) => {
|
|
console.log("create", event);
|
|
const {did, commit: {rkey, record}} = event
|
|
|
|
createNote({
|
|
did,
|
|
rkey,
|
|
...record
|
|
} as any)
|
|
});
|
|
|
|
jetstream.onUpdate("space.litenote.note", (event) => {
|
|
console.log("update", event);
|
|
const {did, commit: {rkey, record}} = event
|
|
|
|
updateNote({
|
|
did,
|
|
rkey,
|
|
...record
|
|
} as any)
|
|
});
|
|
|
|
jetstream.on("close", () => {
|
|
console.log("Connection closed");
|
|
});
|
|
|
|
jetstream.on("error", (error) => {
|
|
console.log("Connection closed with error", error);
|
|
});
|
|
|
|
console.log("launching jetstream");
|
|
|
|
jetstream.start();
|