julien/remanso-jetstream
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

logs: add log for upserts

Browse Source
This commit is contained in:
Julien Calixte
2026-02-14 22:37:07 +01:00
parent a7a90ea075
commit d950d5cb48
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
jetstream.ts
View File

@@ -21,7 +21,7 @@ jetstream.onCreate("space.remanso.note", (event) => {
jetstream.onUpdate("space.remanso.note", (event) => { jetstream.onUpdate("space.remanso.note", (event) => {
const { did, commit: { rkey, record } } = 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">
console.log(`[jetstream] update ${did}/${rkey}: ${note.title}`); console.log(`[jetstream] update ${did}/${rkey}: ${note.title}, published at ${note.publishedAt}`);
upsertNote({ upsertNote({
did, did,

1
src/data/db.ts
View File

@@ -59,6 +59,7 @@ export const deleteNote = ({ did, rkey }: { did: string; rkey: string }) => {
export const upsertNote = (note: Note) => { export const upsertNote = (note: Note) => {
const now = new Date().toISOString() const now = new Date().toISOString()
db.query( db.query(
` `
INSERT INTO note ( INSERT INTO note (