Fix: Filters onCannotConnect to the relays that sent a req

2026-03-18 17:34:50 -04:00
parent f25be5e7bd
commit e57023cad9
1 changed files with 9 additions and 5 deletions
@@ -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),
+                )
+            }
        }
    }