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

adding logs again...

Browse Source
This commit is contained in:
Julien Calixte
2026-02-16 22:21:17 +01:00
parent 37b95d9196
commit 1a7841b728
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
jetstream.ts
View File

@@ -9,6 +9,7 @@ const jetstream = new Jetstream({
jetstream.onCreate("space.remanso.note", (event) => { jetstream.onCreate("space.remanso.note", (event) => {
const { did, commit: { rkey, record } } = event; const { did, commit: { rkey, record } } = event;
log(`[jetstream] creating ${did}/${rkey}...`);
const note = record as unknown as Omit<Note, "did" | "rkey">; const note = record as unknown as Omit<Note, "did" | "rkey">;
try { try {
upsertNote({ did, rkey, ...note }); upsertNote({ did, rkey, ...note });
@@ -20,6 +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;
log(`[jetstream] updating ${did}/${rkey}...`);
const note = record as unknown as Omit<Note, "did" | "rkey">; const note = record as unknown as Omit<Note, "did" | "rkey">;
try { try {
upsertNote({ did, rkey, ...note }); upsertNote({ did, rkey, ...note });
@@ -32,6 +34,7 @@ jetstream.onUpdate("space.remanso.note", (event) => {
jetstream.onDelete("space.remanso.note", (event) => { jetstream.onDelete("space.remanso.note", (event) => {
const { did, commit: { rkey } } = event; const { did, commit: { rkey } } = event;
log(`[jetstream] deleting ${did}/${rkey}...`);
try { try {
deleteNote({ did, rkey }); deleteNote({ did, rkey });
log(`[jetstream] delete ${did}/${rkey}`); log(`[jetstream] delete ${did}/${rkey}`);