From 8055060af3733d69110a0ae0aeea10471f637f0d Mon Sep 17 00:00:00 2001
From: Julien Calixte <julien.calixte@theodo.com>
Date: Tue, 5 May 2026 12:48:15 +0200
Subject: [PATCH] fix: increase create debounce time

---
 jetstream.ts | 22 ++++++++++++++--------
 1 file changed, 14 insertions(+), 8 deletions(-)

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