highperfocused/amethyst
1
0
Fork 0
mirror of https://github.com/vitorpamplona/amethyst.git synced 2025-11-10 22:06:43 +01:00
Code Issues Packages Projects Releases Wiki Activity

Avoid sending close to subs that are already closed.

Browse Source
This commit is contained in:
Vitor Pamplona
2025-10-02 17:48:06 -04:00
parent c6107dd784
commit 90b682a38f
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
quartz/src/commonMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/NostrClient.kt
View File

@@ -231,7 +231,10 @@ class NostrClient(
if (newFilters.isNullOrEmpty()) { if (newFilters.isNullOrEmpty()) {
// some relays are not in this sub anymore. Stop their subscriptions // some relays are not in this sub anymore. Stop their subscriptions
if (!oldFilters.isNullOrEmpty()) {
// only update if the old filters are not already closed.
relayPool.close(relay, subId) relayPool.close(relay, subId)
}
} else if (oldFilters.isNullOrEmpty()) { } else if (oldFilters.isNullOrEmpty()) {
// new relays were added. Start a new sub in them // new relays were added. Start a new sub in them
relayPool.sendRequest(relay, subId, newFilters) relayPool.sendRequest(relay, subId, newFilters)
@@ -267,7 +270,10 @@ class NostrClient(
if (newFilters.isNullOrEmpty()) { if (newFilters.isNullOrEmpty()) {
// some relays are not in this sub anymore. Stop their subscriptions // some relays are not in this sub anymore. Stop their subscriptions
if (!oldFilters.isNullOrEmpty()) {
// only update if the old filters are not already closed.
relayPool.close(relay, subId) relayPool.close(relay, subId)
}
} else if (oldFilters.isNullOrEmpty()) { } else if (oldFilters.isNullOrEmpty()) {
// new relays were added. Start a new sub in them // new relays were added. Start a new sub in them
relayPool.sendCount(relay, subId, newFilters) relayPool.sendCount(relay, subId, newFilters)