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

return true if at least one relay replied with success

Browse Source
This commit is contained in:
greenart7c3
2024-07-19 13:29:09 -03:00
parent 5cf8b5aa12
commit 3f3367258f
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
ammolite/src/main/java/com/vitorpamplona/ammolite/relays/Client.kt
View File

@@ -142,12 +142,13 @@ object Client : RelayPool.Listener {
onDone: (() -> Unit)? = null, onDone: (() -> Unit)? = null,
additionalListener: Listener? = null, additionalListener: Listener? = null,
timeoutInSeconds: Long = 15, timeoutInSeconds: Long = 15,
) { ): Boolean {
checkNotInMainThread() checkNotInMainThread()
val size = if (relay != null) 1 else relayList?.size ?: RelayPool.availableRelays() val size = if (relay != null) 1 else relayList?.size ?: RelayPool.availableRelays()
val latch = CountDownLatch(size) val latch = CountDownLatch(size)
val relayErrors = mutableMapOf<String, String>() val relayErrors = mutableMapOf<String, String>()
var result = false
Log.d("sendAndWaitForResponse", "Waiting for $size responses") Log.d("sendAndWaitForResponse", "Waiting for $size responses")
@@ -182,6 +183,9 @@ object Client : RelayPool.Listener {
relay: Relay, relay: Relay,
) { ) {
if (eventId == signedEvent.id()) { if (eventId == signedEvent.id()) {
if (success) {
result = true
}
latch.countDown() latch.countDown()
Log.d("sendAndWaitForResponse", "onSendResponse Received response for $eventId from relay ${relay.url} count: ${latch.count} message $message success $success") Log.d("sendAndWaitForResponse", "onSendResponse Received response for $eventId from relay ${relay.url} count: ${latch.count} message $message success $success")
} }
@@ -203,6 +207,7 @@ object Client : RelayPool.Listener {
Log.d("sendAndWaitForResponse", "countdown finished") Log.d("sendAndWaitForResponse", "countdown finished")
unsubscribe(subscription) unsubscribe(subscription)
additionalListener?.let { unsubscribe(it) } additionalListener?.let { unsubscribe(it) }
return result
} }
fun sendFilterOnlyIfDisconnected( fun sendFilterOnlyIfDisconnected(