From 5c31be6aa91ff89624267112f24bbc3887ea236b Mon Sep 17 00:00:00 2001
From: Julien Calixte <julienc@bam.tech>
Date: Sun, 15 Feb 2026 12:35:44 +0100
Subject: [PATCH] logs: better error handling

---
 jetstream.ts     | 39 ++++++++++++++++++++-------------------
 src/data/note.ts |  4 ++--
 2 files changed, 22 insertions(+), 21 deletions(-)

diff --git a/jetstream.ts b/jetstream.ts
index a898661..99083f0 100644
--- a/jetstream.ts
+++ b/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">
-  log(`[jetstream] create ${did}/${rkey}: ${note.title}`);
-
-  upsertNote({
-    did,
-    rkey,
-    ...note,
-  });
+  const note = record as unknown as Omit<Note, "did" | "rkey">;
+  try {
+    upsertNote({ did, rkey, ...note });
+    log(`[jetstream] create ${did}/${rkey}: ${note.title}`);
+  } catch (error) {
+    log(`[jetstream] error on create ${did}/${rkey}:`, error);
+  }
 });
 
 jetstream.onUpdate("space.remanso.note", (event) => {
   const { did, commit: { rkey, record } } = event;
-  const note = record as unknown as Omit<Note, "did" | "rkey">
-  log(`[jetstream] update ${did}/${rkey}: ${note.title}, published at ${note.publishedAt}`);
-  
-  upsertNote({
-    did,
-    rkey,
-    ...note,
-  });
+  const note = record as unknown as Omit<Note, "did" | "rkey">;
+  try {
+    upsertNote({ did, rkey, ...note });
+    log(`[jetstream] update ${did}/${rkey}: ${note.title}`);
+  } catch (error) {
+    log(`[jetstream] error on update ${did}/${rkey}:`, error);
+  }
 });
 
 jetstream.onDelete("space.remanso.note", (event) => {
   const { did, commit: { rkey } } = event;
-  log(`[jetstream] delete ${did}/${rkey}`);
-
-  deleteNote({ did, rkey });
+  try {
+    deleteNote({ did, rkey });
+    log(`[jetstream] delete ${did}/${rkey}`);
+  } catch (error) {
+    log(`[jetstream] error on delete ${did}/${rkey}:`, error);
+  }
 });
 
 jetstream.on("close", () => {
diff --git a/src/data/note.ts b/src/data/note.ts
index c65cddb..96ea80f 100644
--- a/src/data/note.ts
+++ b/src/data/note.ts
@@ -2,6 +2,6 @@ export type Note = {
   did: string;
   rkey: string;
   title: string;
-  publishedAt: Date;
-  createdAt: Date;
+  publishedAt: string;
+  createdAt: string;
 };