feat: add a server for querying notes

jetstream.ts

@@ -0,0 +1,40 @@
+import { Jetstream } from "@skyware/jetstream";
+import { upsertNote } 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
+
+  upsertNote({
+    did,
+    rkey,
+    ...record
+  } as any)
+});
+
+jetstream.onUpdate("space.litenote.note", (event) => {
+	console.log("update", event);
+  const {did, commit: {rkey, record}} = event
+
+  upsertNote({
+    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();