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

Only avoids sending a message for the request state if it is a new open request

Browse Source
This commit is contained in:
Vitor Pamplona
2025-10-21 20:17:04 -04:00
parent 551bd344e0
commit 031e604923
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -230,13 +230,17 @@ class PoolRequests {
sync: (NormalizedRelayUrl, Command) -> Unit, sync: (NormalizedRelayUrl, Command) -> Unit,
) { ) {
relaysToUpdate.forEach { relay -> relaysToUpdate.forEach { relay ->
sendToRelayIfChanged(subId, relay) { cmd ->
if (cmd is ReqCmd) {
val currentState = relayState.get(subId)?.currentState(relay) val currentState = relayState.get(subId)?.currentState(relay)
if (currentState == ReqSubStatus.SENT || currentState == ReqSubStatus.QUERYING_PAST) { if (currentState == ReqSubStatus.SENT || currentState == ReqSubStatus.QUERYING_PAST) {
// sending multiple REQs triggers multiple EOSEs back and we then don't know which // sending multiple REQs triggers multiple EOSEs back and we then don't know which
// one is which. // one is which.
} else { } else {
sendToRelayIfChanged(subId, relay) { cmd -> sync(relay, cmd)
}
} else {
sync(relay, cmd) sync(relay, cmd)
} }
} }