From decb3ac61825a179e9528574a07069acdf314f68 Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Sun, 23 Feb 2025 11:56:29 -0600
Subject: [PATCH] =?UTF-8?q?Fix=20streaming=20API=20hydration=20(=20=CD=A1?=
 =?UTF-8?q?=C2=B0=20=CD=9C=CA=96=20=CD=A1=C2=B0)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 packages/ditto/controllers/api/streaming.ts | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/packages/ditto/controllers/api/streaming.ts b/packages/ditto/controllers/api/streaming.ts
index 01a829df..93816cda 100644
--- a/packages/ditto/controllers/api/streaming.ts
+++ b/packages/ditto/controllers/api/streaming.ts
@@ -99,8 +99,9 @@ const streamingController: AppController = async (c) => {
     filter: NostrFilter & { limit: 0 },
     render: (event: NostrEvent) => Promise<StreamingEvent | undefined>,
   ) {
+    const { signal } = controller;
     try {
-      for await (const msg of relay.req([filter], { signal: controller.signal })) {
+      for await (const msg of relay.req([filter], { signal })) {
         if (msg[0] === 'EVENT') {
           const event = msg[2];
 
@@ -111,7 +112,7 @@ const streamingController: AppController = async (c) => {
             }
           }
 
-          await hydrateEvents({ ...c.var, events: [event] });
+          await hydrateEvents({ ...c.var, events: [event], signal });
 
           const result = await render(event);