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 - log(`[jetstream] create ${did}/${rkey}: ${note.title}`); - - upsertNote({ - did, - rkey, - ...note, - }); + const note = record as unknown as Omit; + 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 - log(`[jetstream] update ${did}/${rkey}: ${note.title}, published at ${note.publishedAt}`); - - upsertNote({ - did, - rkey, - ...note, - }); + const note = record as unknown as Omit; + 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; };