highperfocused/amethyst
1
0
Fork 0
mirror of https://github.com/vitorpamplona/amethyst.git synced 2025-10-10 15:42:53 +02:00
Code Issues Packages Projects Releases Wiki Activity

Migrates to a more obvious open/close subscription model for NostrClient

Browse Source
This commit is contained in:
Vitor Pamplona
2025-08-11 10:34:10 -04:00
parent d5b9d5e80b
commit d0f3dde08b
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
quartz/src/main/java/com/vitorpamplona/quartz/nip01Core/relay/client/NostrClient.kt
View File

@@ -206,7 +206,7 @@ class NostrClient(
return false return false
} }
fun sendRequest( fun openReqSubscription(
subId: String = newSubId(), subId: String = newSubId(),
filters: Map<NormalizedRelayUrl, List<Filter>>, filters: Map<NormalizedRelayUrl, List<Filter>>,
) { ) {
@@ -239,7 +239,7 @@ class NostrClient(
} }
} }
fun sendCount( fun openCountSubscription(
subId: String = newSubId(), subId: String = newSubId(),
filters: Map<NormalizedRelayUrl, List<Filter>>, filters: Map<NormalizedRelayUrl, List<Filter>>,
) { ) {

2
quartz/src/main/java/com/vitorpamplona/quartz/nip01Core/relay/client/accessories/NostrClientSingleDownloadExt.kt
View File

@@ -56,7 +56,7 @@ fun NostrClient.downloadFirstEvent(
subscribe(listener) subscribe(listener)
sendRequest(subscriptionId, filters) openReqSubscription(subscriptionId, filters)
GlobalScope.launch(Dispatchers.IO) { GlobalScope.launch(Dispatchers.IO) {
delay(30000) delay(30000)

4
quartz/src/main/java/com/vitorpamplona/quartz/nip01Core/relay/client/subscriptions/SubscriptionController.kt
View File

@@ -126,14 +126,14 @@ class SubscriptionController(
// was active and is not active anymore, just close. // was active and is not active anymore, just close.
client.close(subId) client.close(subId)
} else { } else {
client.sendRequest(subId, updatedFilters) client.openReqSubscription(subId, updatedFilters)
} }
} else { } else {
if (updatedFilters == null) { if (updatedFilters == null) {
// was not active and is still not active, does nothing // was not active and is still not active, does nothing
} else { } else {
// was not active and becomes active, sends the entire filter. // was not active and becomes active, sends the entire filter.
client.sendRequest(subId, updatedFilters) client.openReqSubscription(subId, updatedFilters)
} }
} }
} }