Try wrapping slow queries in transaction

src/controllers/api/timelines.ts

@@ -1,3 +1,4 @@
+import { db } from '@/db.ts';
 import { z } from '@/deps.ts';
 import { type DittoFilter } from '@/filter.ts';
 import * as mixer from '@/mixer.ts';
@@ -40,8 +41,10 @@ async function renderStatuses(c: AppContext, filters: DittoFilter<1>[]) {
     return c.json([]);
   }
 
-  const statuses = await Promise.all(events.map((event) => renderStatus(event, c.get('pubkey'))));
+  return db.transaction().execute(async () => {
-  return paginated(c, events, statuses);
+    const statuses = await Promise.all(events.map((event) => renderStatus(event, c.get('pubkey'))));
+    return paginated(c, events, statuses);
+  })
 }
 
 export { hashtagTimelineController, homeTimelineController, publicTimelineController };

src/pipeline.ts

@@ -1,3 +1,4 @@
+import { db } from '@/db.ts';
 import { Conf } from '@/config.ts';
 import * as eventsDB from '@/db/events.ts';
 import { addRelays } from '@/db/relays.ts';
@@ -21,17 +22,20 @@ import type { EventData } from '@/types.ts';
  */
 async function handleEvent(event: Event): Promise<void> {
   if (encounterEvent(event)) return;
-  const data = await getEventData(event);
 
-  await Promise.all([
+  await db.transaction().execute(async () => {
-    storeEvent(event, data),
+    const data = await getEventData(event);
-    processDeletions(event),
+
-    trackRelays(event),
+    await Promise.all([
-    trackHashtags(event),
+      storeEvent(event, data),
-    processMedia(event, data),
+      processDeletions(event),
-    streamOut(event, data),
+      trackRelays(event),
-    broadcast(event, data),
+      trackHashtags(event),
-  ]);
+      processMedia(event, data),
+      streamOut(event, data),
+      broadcast(event, data),
+    ]);
+  })
 }
 
 /** Tracks encountered events to skip duplicates, improving idempotency and performance. */