From a33ad47c7e36ad26e0e496824da9d735cd73e39b Mon Sep 17 00:00:00 2001
From: Julien Calixte <julien.calixte@theodo.com>
Date: Tue, 5 May 2026 12:52:27 +0200
Subject: [PATCH] chore(jetstream): log bulk-create record count on flush

---
 jetstream.ts | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/jetstream.ts b/jetstream.ts
index 8958564..56df8be 100644
--- a/jetstream.ts
+++ b/jetstream.ts
@@ -72,6 +72,9 @@ const flushBulkCreate = async (did: string): Promise<void> => {
   if (!buffer) return;
   bulkBuffers.delete(did);
   const webhooks = getWebhooksByDidAndVerb(did, "bulk-create");
+  log(
+    `[jetstream] bulk-create ${did}: ${buffer.records.length} record(s)`,
+  );
   await dispatchAll(
     webhooks,
     { event: "bulk-create", did, records: buffer.records },