Removes unused since param for missing events in thread assemblers

This commit is contained in:
Vitor Pamplona
2025-05-14 14:50:52 -04:00
parent 6f7f8e296b
commit b7ac32d768
2 changed files with 4 additions and 8 deletions
@@ -25,13 +25,9 @@ import com.vitorpamplona.amethyst.model.ThreadAssembler
import com.vitorpamplona.amethyst.service.relayClient.reqCommand.event.loaders.filterMissingAddressables
import com.vitorpamplona.amethyst.service.relayClient.reqCommand.event.loaders.filterMissingEvents
import com.vitorpamplona.ammolite.relays.TypedFilter
import com.vitorpamplona.ammolite.relays.filters.EOSETime
import com.vitorpamplona.quartz.nip01Core.tags.addressables.Address
fun filterMissingEventsForThread(
threadInfo: ThreadAssembler.ThreadInfo,
since: Map<String, EOSETime>?,
): List<TypedFilter> {
fun filterMissingEventsForThread(threadInfo: ThreadAssembler.ThreadInfo): List<TypedFilter> {
val missingEvents = mutableSetOf<String>()
val missingAddresses = mutableSetOf<Address>()
@@ -53,8 +49,8 @@ fun filterMissingEventsForThread(
}
}
val missingEventsFilter = filterMissingEvents(missingEvents, since) ?: emptyList()
val missingAddressFilter = filterMissingAddressables(missingAddresses, since) ?: emptyList()
val missingEventsFilter = filterMissingEvents(missingEvents) ?: emptyList()
val missingAddressFilter = filterMissingAddressables(missingAddresses) ?: emptyList()
return missingEventsFilter + missingAddressFilter
}
@@ -45,7 +45,7 @@ class ThreadEventLoaderSubAssembler(
since: Map<String, EOSETime>?,
): List<TypedFilter>? {
val branches = ThreadAssembler().findThreadFor(key.eventId) ?: return null
return filterMissingEventsForThread(branches, since)
return filterMissingEventsForThread(branches)
}
override fun id(key: ThreadQueryState) = key.eventId