chore(jetstream): log bulk-create record count on flush

2026-05-05 12:52:27 +02:00
parent 8055060af3
commit a33ad47c7e
1 changed files with 3 additions and 0 deletions
--- 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 },