highperfocused/amethyst
1
0
Fork 0
mirror of https://github.com/vitorpamplona/amethyst.git synced 2025-09-27 18:36:37 +02:00
Code Issues Packages Projects Releases Wiki Activity

Forces relay status updates when connecting and disconnecting

Browse Source
This commit is contained in:
Vitor Pamplona
2025-09-04 21:02:20 -04:00
parent 103ef01be4
commit b0e27d0748
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/RelayPool.kt
View File

@@ -94,24 +94,31 @@ class RelayPool(
relay.connectAndSyncFiltersIfDisconnected() relay.connectAndSyncFiltersIfDisconnected()
} }
} }
updateStatus()
} }
fun connect() = fun connect() {
relays.forEach { url, relay -> relays.forEach { url, relay ->
relay.connect() relay.connect()
} }
updateStatus()
}
fun connectIfDisconnected() = fun connectIfDisconnected() {
relays.forEach { url, relay -> relays.forEach { url, relay ->
relay.connectAndSyncFiltersIfDisconnected() relay.connectAndSyncFiltersIfDisconnected()
} }
updateStatus()
}
fun connectIfDisconnected(relay: NormalizedRelayUrl) = relays.get(relay)?.connectAndSyncFiltersIfDisconnected() fun connectIfDisconnected(relay: NormalizedRelayUrl) = relays.get(relay)?.connectAndSyncFiltersIfDisconnected()
fun disconnect() = fun disconnect() {
relays.forEach { url, relay -> relays.forEach { url, relay ->
relay.disconnect() relay.disconnect()
} }
updateStatus()
}
fun sendRequest( fun sendRequest(
relay: NormalizedRelayUrl, relay: NormalizedRelayUrl,