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

Exposes active filters per relay on the Nostr Client for debugging purposes

Browse Source
This commit is contained in:
Vitor Pamplona
2025-09-02 18:28:41 -04:00
parent 116bd1ae29
commit 7a807e94af
3 changed files with 28 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/NostrClient.kt
View File

@@ -21,6 +21,7 @@
package com.vitorpamplona.quartz.nip01Core.relay.client package com.vitorpamplona.quartz.nip01Core.relay.client
import com.vitorpamplona.quartz.nip01Core.core.Event import com.vitorpamplona.quartz.nip01Core.core.Event
import com.vitorpamplona.quartz.nip01Core.core.HexKey
import com.vitorpamplona.quartz.nip01Core.relay.client.listeners.IRelayClientListener import com.vitorpamplona.quartz.nip01Core.relay.client.listeners.IRelayClientListener
import com.vitorpamplona.quartz.nip01Core.relay.client.listeners.RelayState import com.vitorpamplona.quartz.nip01Core.relay.client.listeners.RelayState
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.PoolEventOutboxRepository import com.vitorpamplona.quartz.nip01Core.relay.client.pool.PoolEventOutboxRepository
@@ -395,6 +396,12 @@ class NostrClient(
listeners = listeners.minus(listener) listeners = listeners.minus(listener)
} }
fun activeRequests(url: NormalizedRelayUrl): Map<String, List<Filter>> = activeRequests.activeFiltersFor(url)
fun activeCounts(url: NormalizedRelayUrl): Map<String, List<Filter>> = activeCounts.activeFiltersFor(url)
fun activeOutboxCache(url: NormalizedRelayUrl): Set<HexKey> = eventOutbox.activeOutboxCacheFor(url)
fun getSubscriptionFiltersOrNull(subId: String): Map<NormalizedRelayUrl, List<Filter>>? = activeRequests.getSubscriptionFiltersOrNull(subId) fun getSubscriptionFiltersOrNull(subId: String): Map<NormalizedRelayUrl, List<Filter>>? = activeRequests.getSubscriptionFiltersOrNull(subId)
fun relayStatusFlow() = relayPool.statusFlow fun relayStatusFlow() = relayPool.statusFlow

10
quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolEventOutboxRepository.kt
View File

@@ -40,6 +40,16 @@ class PoolEventOutboxRepository {
} }
} }
fun activeOutboxCacheFor(url: NormalizedRelayUrl): Set<HexKey> {
val myEvents = mutableSetOf<HexKey>()
eventOutbox.forEach { eventId, outboxCache ->
if (url in outboxCache.relays) {
myEvents.add(eventId)
}
}
return myEvents
}
fun markAsSending( fun markAsSending(
event: Event, event: Event,
relays: Set<NormalizedRelayUrl>, relays: Set<NormalizedRelayUrl>,

11
quartz/src/androidMain/kotlin/com/vitorpamplona/quartz/nip01Core/relay/client/pool/PoolSubscriptionRepository.kt
View File

@@ -40,6 +40,17 @@ class PoolSubscriptionRepository {
} }
} }
fun activeFiltersFor(url: NormalizedRelayUrl): Map<String, List<Filter>> {
val myRelays = mutableMapOf<String, List<Filter>>()
subscriptions.forEach { sub, perRelayFilters ->
val filters = perRelayFilters.get(url)
if (filters != null) {
myRelays.put(sub, filters)
}
}
return myRelays
}
fun addOrUpdate( fun addOrUpdate(
subscriptionId: String, subscriptionId: String,
filters: Map<NormalizedRelayUrl, List<Filter>>, filters: Map<NormalizedRelayUrl, List<Filter>>,