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

new map of set api

Browse Source
This commit is contained in:
Vitor Pamplona
2025-07-07 13:48:39 -04:00
parent cf48516602
commit eb5d113298
1 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
amethyst/src/main/java/com/vitorpamplona/amethyst/service/relayClient/reqCommand/event/loaders/FilterMissingEvents.kt
View File

@@ -22,12 +22,12 @@ package com.vitorpamplona.amethyst.service.relayClient.reqCommand.event.loaders
import com.vitorpamplona.amethyst.model.AddressableNote
import com.vitorpamplona.amethyst.model.LocalCache
import com.vitorpamplona.amethyst.model.LocalCache.relayHints
import com.vitorpamplona.amethyst.service.relayClient.reqCommand.event.EventFinderQueryState
import com.vitorpamplona.quartz.nip01Core.core.HexKey
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.utils.MapOfSetBuilder
import com.vitorpamplona.quartz.utils.mapOfSet
fun filterMissingEvents(keys: List<EventFinderQueryState>): List<RelayBasedFilter>? {
val missingEvents = mutableSetOf<String>()
@@ -51,15 +51,16 @@ fun filterMissingEvents(keys: List<EventFinderQueryState>): List<RelayBasedFilte
fun filterMissingEvents(missingEventIds: Set<HexKey>): List<RelayBasedFilter> {
if (missingEventIds.isEmpty()) return emptyList()
val relayHints = MapOfSetBuilder<NormalizedRelayUrl, HexKey>()
missingEventIds.forEach { eventId ->
LocalCache.relayHints.hintsForEvent(eventId).forEach { relayUrl ->
relayHints.add(relayUrl, eventId)
val relayHints =
mapOfSet {
missingEventIds.forEach { eventId ->
LocalCache.relayHints.hintsForEvent(eventId).forEach { relayUrl ->
add(relayUrl, eventId)
}
}
}
}
return relayHints.build().map {
return relayHints.map {
RelayBasedFilter(
relay = it.key,
filter = Filter(ids = it.value.sorted()),