From e57023cad905e1f875a0e3d5c01f6972ea6afd69 Mon Sep 17 00:00:00 2001
From: Vitor Pamplona <vitor@vitorpamplona.com>
Date: Wed, 18 Mar 2026 17:34:50 -0400
Subject: [PATCH] Fix: Filters onCannotConnect to the relays that sent a req

---
 .../nip01Core/relay/client/pool/PoolRequests.kt    | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt b/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt
index c0e41864e..e877ca750 100644
--- a/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt
+++ b/quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolRequests.kt
@@ -265,11 +265,15 @@ class PoolRequests {
         errorMessage: String,
     ) {
         relayState.forEach { subId, state ->
-            desiredSubListeners.get(subId)?.onCannotConnect(
-                message = errorMessage,
-                relay = url,
-                forFilters = state.lastKnownFilterStates(url),
-            )
+            // These are all my subs.. need to figure out which relays have them
+            val subs = desiredSubs.get(subId)
+            if (subs != null && url in subs.keys) {
+                desiredSubListeners.get(subId)?.onCannotConnect(
+                    relay = url,
+                    message = errorMessage,
+                    forFilters = state.lastKnownFilterStates(url),
+                )
+            }
         }
     }