From 2b2499849fb0116287099c56f1aa64d6492b769d Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Fri, 3 May 2024 13:52:11 -0500
Subject: [PATCH] pipeline: fix reqmeister crash, probably

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

diff --git a/src/pipeline.ts b/src/pipeline.ts
index f28b886..3eb8913 100644
--- a/src/pipeline.ts
+++ b/src/pipeline.ts
@@ -186,7 +186,7 @@ async function fetchRelatedEvents(event: DittoEvent) {
   if (!event.author) {
     const signal = AbortSignal.timeout(3000);
     Storages.reqmeister.query([{ kinds: [0], authors: [event.pubkey] }], { signal })
-      .then((events) => events.forEach((event) => handleEvent(event, signal)))
+      .then((events) => Promise.allSettled(events.map((event) => handleEvent(event, signal))))
       .catch(() => {});
   }
 
@@ -196,7 +196,7 @@ async function fetchRelatedEvents(event: DittoEvent) {
       if (!count) {
         const signal = AbortSignal.timeout(3000);
         Storages.reqmeister.query([{ ids: [id] }], { signal })
-          .then((events) => events.forEach((event) => handleEvent(event, signal)))
+          .then((events) => Promise.allSettled(events.map((event) => handleEvent(event, signal))))
           .catch(() => {});
       }
     }