From b0e27d07489bec0d04e74fece03c4c67630aae63 Mon Sep 17 00:00:00 2001 From: Vitor Pamplona Date: Thu, 4 Sep 2025 21:02:20 -0400 Subject: [PATCH] Forces relay status updates when connecting and disconnecting --- .../quartz/nip01Core/relay/client/pool/RelayPool.kt | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/RelayPool.kt b/quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/RelayPool.kt index 6e7fd5c9e..4eb6daa85 100644 --- a/quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/RelayPool.kt +++ b/quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/RelayPool.kt @@ -94,24 +94,31 @@ class RelayPool( relay.connectAndSyncFiltersIfDisconnected() } } + updateStatus() } - fun connect() = + fun connect() { relays.forEach { url, relay -> relay.connect() } + updateStatus() + } - fun connectIfDisconnected() = + fun connectIfDisconnected() { relays.forEach { url, relay -> relay.connectAndSyncFiltersIfDisconnected() } + updateStatus() + } fun connectIfDisconnected(relay: NormalizedRelayUrl) = relays.get(relay)?.connectAndSyncFiltersIfDisconnected() - fun disconnect() = + fun disconnect() { relays.forEach { url, relay -> relay.disconnect() } + updateStatus() + } fun sendRequest( relay: NormalizedRelayUrl,