logs: better error handling

jetstream.ts

@@ -9,33 +9,34 @@ const jetstream = new Jetstream({
 
 jetstream.onCreate("space.remanso.note", (event) => {
   const { did, commit: { rkey, record } } = event;
-  const note = record as unknown as Omit<Note, "did" | "rkey">
+  const note = record as unknown as Omit<Note, "did" | "rkey">;
-  log(`[jetstream] create ${did}/${rkey}: ${note.title}`);
+  try {
-
+    upsertNote({ did, rkey, ...note });
-  upsertNote({
+    log(`[jetstream] create ${did}/${rkey}: ${note.title}`);
-    did,
+  } catch (error) {
-    rkey,
+    log(`[jetstream] error on create ${did}/${rkey}:`, error);
-    ...note,
+  }
-  });
 });
 
 jetstream.onUpdate("space.remanso.note", (event) => {
   const { did, commit: { rkey, record } } = event;
-  const note = record as unknown as Omit<Note, "did" | "rkey">
+  const note = record as unknown as Omit<Note, "did" | "rkey">;
-  log(`[jetstream] update ${did}/${rkey}: ${note.title}, published at ${note.publishedAt}`);
+  try {
-  
+    upsertNote({ did, rkey, ...note });
-  upsertNote({
+    log(`[jetstream] update ${did}/${rkey}: ${note.title}`);
-    did,
+  } catch (error) {
-    rkey,
+    log(`[jetstream] error on update ${did}/${rkey}:`, error);
-    ...note,
+  }
-  });
 });
 
 jetstream.onDelete("space.remanso.note", (event) => {
   const { did, commit: { rkey } } = event;
-  log(`[jetstream] delete ${did}/${rkey}`);
+  try {
-
+    deleteNote({ did, rkey });
-  deleteNote({ did, rkey });
+    log(`[jetstream] delete ${did}/${rkey}`);
+  } catch (error) {
+    log(`[jetstream] error on delete ${did}/${rkey}:`, error);
+  }
 });
 
 jetstream.on("close", () => {

src/data/note.ts

@@ -2,6 +2,6 @@ export type Note = {
   did: string;
   rkey: string;
   title: string;
-  publishedAt: Date;
+  publishedAt: string;
-  createdAt: Date;
+  createdAt: string;
 };