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

fix: increase create debounce time

Browse Source
This commit is contained in:
Julien Calixte
2026-05-05 12:48:15 +02:00
parent 5cb581123d
commit 8055060af3
1 changed files with 14 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
jetstream.ts
View File

@@ -59,7 +59,7 @@ const fireWebhooks = async (
await dispatchAll(webhooks, payload, `${verb} ${did}`); await dispatchAll(webhooks, payload, `${verb} ${did}`);
}; };
const BULK_CREATE_DEBOUNCE_MS = 400; const BULK_CREATE_DEBOUNCE_MS = 3000;
type BulkBuffer = { type BulkBuffer = {
records: Record<string, unknown>[]; records: Record<string, unknown>[];
@@ -98,10 +98,7 @@ const queueBulkCreate = (
} }
bulkBuffers.set(did, { bulkBuffers.set(did, {
records: [record], records: [record],
timer: setTimeout( timer: setTimeout(() => flushBulkCreate(did), BULK_CREATE_DEBOUNCE_MS),
() => flushBulkCreate(did),
BULK_CREATE_DEBOUNCE_MS,
),
}); });
}; };
@@ -116,7 +113,10 @@ const jetstream = new Jetstream({
jetstream.onCreate("space.remanso.note", async (event) => { jetstream.onCreate("space.remanso.note", async (event) => {
try { try {
const { did, commit: { rkey, record } } = event; const {
did,
commit: { rkey, record },
} = event;
log(`[jetstream] creating ${did}/${rkey}...`); 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">;
upsertNote({ did, rkey, ...note }); upsertNote({ did, rkey, ...note });
@@ -130,7 +130,10 @@ jetstream.onCreate("space.remanso.note", async (event) => {
jetstream.onUpdate("space.remanso.note", async (event) => { jetstream.onUpdate("space.remanso.note", async (event) => {
try { try {
const { did, commit: { rkey, record } } = event; const {
did,
commit: { rkey, record },
} = event;
log(`[jetstream] updating ${did}/${rkey}...`); 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">;
upsertNote({ did, rkey, ...note }); upsertNote({ did, rkey, ...note });
@@ -145,7 +148,10 @@ jetstream.onUpdate("space.remanso.note", async (event) => {
jetstream.onDelete("space.remanso.note", async (event) => { jetstream.onDelete("space.remanso.note", async (event) => {
try { try {
const { did, commit: { rkey } } = event; const {
did,
commit: { rkey },
} = event;
log(`[jetstream] deleting ${did}/${rkey}...`); log(`[jetstream] deleting ${did}/${rkey}...`);
deleteNote({ did, rkey }); deleteNote({ did, rkey });
log(`[jetstream] delete ${did}/${rkey}`); log(`[jetstream] delete ${did}/${rkey}`);