From c4391ccd99cfd79bea6040a93e21cf118857543f Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Sun, 22 Sep 2024 11:49:37 -0500
Subject: [PATCH] pipeline: fix events not being pushed through streaming API
 Fixes https://gitlab.com/soapbox-pub/ditto/-/issues/206

---
 src/pipeline.ts | 19 +++++++++++--------
 1 file changed, 11 insertions(+), 8 deletions(-)

diff --git a/src/pipeline.ts b/src/pipeline.ts
index e94ed21e..d89c6cef 100644
--- a/src/pipeline.ts
+++ b/src/pipeline.ts
@@ -62,14 +62,17 @@ async function handleEvent(event: DittoEvent, signal: AbortSignal): Promise<void
 
   const kysely = await Storages.kysely();
 
-  await storeEvent(purifyEvent(event), signal);
-  await Promise.all([
-    handleZaps(kysely, event),
-    parseMetadata(event, signal),
-    setLanguage(event),
-    generateSetEvents(event),
-    streamOut(event),
-  ]);
+  try {
+    await storeEvent(purifyEvent(event), signal);
+    await Promise.all([
+      handleZaps(kysely, event),
+      parseMetadata(event, signal),
+      setLanguage(event),
+    ]);
+  } finally {
+    await generateSetEvents(event);
+    await streamOut(event);
+  }
 }
 
 async function policyFilter(event: NostrEvent): Promise<void> {