From 55ee8eaf74ac0034f498ea88a54a734bbaa543f1 Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Thu, 12 Sep 2024 11:09:54 -0500
Subject: [PATCH] Fix stat inflation

---
 src/pipeline.ts | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/src/pipeline.ts b/src/pipeline.ts
index 88e5f29..4153cd4 100644
--- a/src/pipeline.ts
+++ b/src/pipeline.ts
@@ -119,8 +119,10 @@ async function storeEvent(event: DittoEvent, signal?: AbortSignal): Promise<unde
   const store = await Storages.db();
   const kysely = await Storages.kysely();
 
-  await updateStats({ event, store, kysely }).catch(debug);
-  await store.event(event, { signal });
+  await kysely.transaction().execute(async (kysely) => {
+    await updateStats({ event, store, kysely });
+    await store.event(event, { signal });
+  });
 }
 
 /** Parse kind 0 metadata and track indexes in the database. */