Removing all the default since logic

This commit is contained in:
Vitor Pamplona
2025-07-08 15:22:31 -04:00
parent 0be9447bee
commit dbb9ee5379
58 changed files with 68 additions and 261 deletions
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip23LongContent.LongTextNoteEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterLongFormAllCommunities(
@@ -73,14 +72,12 @@ fun filterLongFormByAllCommunities(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterLongFormAllCommunities(
relay = it.key,
communities = it.value.communities,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -28,7 +28,6 @@ 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.nip23LongContent.LongTextNoteEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -58,8 +57,6 @@ fun filterLongFormByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -68,7 +65,7 @@ fun filterLongFormByAuthors(
filterLongFormAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -80,8 +77,6 @@ fun filterLongFormByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -90,7 +85,7 @@ fun filterLongFormByAuthors(
filterLongFormAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip23LongContent.LongTextNoteEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterLongFormByCommunity(
@@ -75,15 +74,13 @@ fun filterLongFormByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterLongFormByCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -23,7 +23,6 @@ package com.vitorpamplona.amethyst.ui.screen.loggedIn.discover.nip23LongForm.sub
import com.vitorpamplona.amethyst.model.topNavFeeds.allFollows.AllFollowsByOutboxTopNavPerRelayFilterSet
import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatMap
fun filterLongFormByFollows(
@@ -32,10 +31,8 @@ fun filterLongFormByFollows(
): List<RelayBasedFilter> {
if (followsSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return followsSet.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
val relay = it.key
listOfNotNull(
@@ -27,7 +27,6 @@ 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.nip23LongContent.LongTextNoteEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterLongFormByGeohash(
@@ -59,8 +58,6 @@ fun filterLongFormByGeohash(
): List<RelayBasedFilter> {
if (geoSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return geoSet.set
.mapNotNull {
if (it.value.geotags.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterLongFormByGeohash(
filterLiveActivitiesByGeohash(
relay = it.key,
geotags = it.value.geotags,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip01Core.tags.hashtags.hashtagAlts
import com.vitorpamplona.quartz.nip23LongContent.LongTextNoteEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterLongFormByHashtag(
@@ -59,8 +58,6 @@ fun filterLongFormByHashtag(
): List<RelayBasedFilter> {
if (hashSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashSet.set
.mapNotNull { relayHashSet ->
if (relayHashSet.value.hashtags.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterLongFormByHashtag(
filterLongFormByHashtag(
relay = relayHashSet.key,
hashtags = relayHashSet.value.hashtags,
since = since?.get(relayHashSet.key)?.time ?: defaultSince,
since = since?.get(relayHashSet.key)?.time,
)
}
}.flatten()
@@ -25,7 +25,6 @@ import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip23LongContent.LongTextNoteEvent
import com.vitorpamplona.quartz.utils.TimeUtils
fun filterLongFormGlobal(
relays: GlobalTopNavPerRelayFilterSet,
@@ -33,10 +32,8 @@ fun filterLongFormGlobal(
): List<RelayBasedFilter> {
if (relays.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return relays.set.map {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
RelayBasedFilter(
relay = it.key,
filter =
@@ -29,7 +29,6 @@ import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelCreateEvent
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelMetadataEvent
import com.vitorpamplona.quartz.nip28PublicChat.message.ChannelMessageEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterPublicChatsAllCommunities(
@@ -79,15 +78,12 @@ fun filterPublicChatsByAllCommunities(
since: SincePerRelayMap?,
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterPublicChatsAllCommunities(
relay = it.key,
communities = it.value.communities,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -30,7 +30,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelCreateEvent
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelMetadataEvent
import com.vitorpamplona.quartz.nip28PublicChat.message.ChannelMessageEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -65,8 +64,6 @@ fun filterPublicChatsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -75,7 +72,7 @@ fun filterPublicChatsByAuthors(
filterPublicChatsAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -87,8 +84,6 @@ fun filterPublicChatsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -97,7 +92,7 @@ fun filterPublicChatsByAuthors(
filterPublicChatsAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -29,7 +29,6 @@ import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelCreateEvent
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelMetadataEvent
import com.vitorpamplona.quartz.nip28PublicChat.message.ChannelMessageEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterPublicChatsByCommunity(
@@ -82,15 +81,13 @@ fun filterPublicChatsByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterPublicChatsByCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -23,7 +23,6 @@ package com.vitorpamplona.amethyst.ui.screen.loggedIn.discover.nip28Chats.subass
import com.vitorpamplona.amethyst.model.topNavFeeds.allFollows.AllFollowsByOutboxTopNavPerRelayFilterSet
import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatMap
fun filterPublicChatsByFollows(
@@ -32,10 +31,8 @@ fun filterPublicChatsByFollows(
): List<RelayBasedFilter> {
if (followsSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return followsSet.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
val relay = it.key
listOfNotNull(
@@ -28,7 +28,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelCreateEvent
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelMetadataEvent
import com.vitorpamplona.quartz.nip28PublicChat.message.ChannelMessageEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterPublicChatsByGeohash(
@@ -65,8 +64,6 @@ fun filterPublicChatsByGeohash(
): List<RelayBasedFilter> {
if (geoSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return geoSet.set
.mapNotNull {
if (it.value.geotags.isEmpty()) {
@@ -75,7 +72,7 @@ fun filterPublicChatsByGeohash(
filterPublicChatsByGeohash(
relay = it.key,
geotags = it.value.geotags,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -29,7 +29,6 @@ import com.vitorpamplona.quartz.nip01Core.tags.hashtags.hashtagAlts
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelCreateEvent
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelMetadataEvent
import com.vitorpamplona.quartz.nip28PublicChat.message.ChannelMessageEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterPublicChatsByHashtag(
@@ -66,8 +65,6 @@ fun filterPublicChatsByHashtag(
): List<RelayBasedFilter> {
if (hashSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashSet.set
.mapNotNull { relayHashSet ->
if (relayHashSet.value.hashtags.isEmpty()) {
@@ -76,7 +73,7 @@ fun filterPublicChatsByHashtag(
filterPublicChatsByHashtag(
relay = relayHashSet.key,
hashtags = relayHashSet.value.hashtags,
since = since?.get(relayHashSet.key)?.time ?: defaultSince,
since = since?.get(relayHashSet.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelCreateEvent
import com.vitorpamplona.quartz.nip28PublicChat.admin.ChannelMetadataEvent
import com.vitorpamplona.quartz.nip28PublicChat.message.ChannelMessageEvent
import com.vitorpamplona.quartz.utils.TimeUtils
fun filterPublicChatsGlobal(
relays: GlobalTopNavPerRelayFilterSet,
@@ -35,10 +34,8 @@ fun filterPublicChatsGlobal(
): List<RelayBasedFilter> {
if (relays.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return relays.set.map {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
RelayBasedFilter(
relay = it.key,
filter =
@@ -28,7 +28,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip51Lists.FollowListEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterFollowSetsAllCommunities(
@@ -74,14 +73,12 @@ fun filterFollowSetsByAllCommunities(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterContentDVMsAllCommunities(
relay = it.key,
communities = it.value.communities,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -28,7 +28,6 @@ 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.nip51Lists.FollowListEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -58,8 +57,6 @@ fun filterFollowSetsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -68,7 +65,7 @@ fun filterFollowSetsByAuthors(
filterFollowSetsAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -80,8 +77,6 @@ fun filterFollowSetsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -90,7 +85,7 @@ fun filterFollowSetsByAuthors(
filterFollowSetsAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip51Lists.FollowListEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterFollowSetsByCommunity(
@@ -75,15 +74,13 @@ fun filterFollowSetsByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterFollowSetsByCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -23,7 +23,6 @@ package com.vitorpamplona.amethyst.ui.screen.loggedIn.discover.nip51FollowSets.s
import com.vitorpamplona.amethyst.model.topNavFeeds.allFollows.AllFollowsByOutboxTopNavPerRelayFilterSet
import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatMap
fun filterFollowSetsByFollows(
@@ -32,10 +31,8 @@ fun filterFollowSetsByFollows(
): List<RelayBasedFilter> {
if (followsSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return followsSet.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
val relay = it.key
listOfNotNull(
@@ -26,7 +26,6 @@ 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.nip51Lists.FollowListEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterFollowSetsByGeohash(
@@ -58,8 +57,6 @@ fun filterFollowSetsByGeohash(
): List<RelayBasedFilter> {
if (geoSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return geoSet.set
.mapNotNull {
if (it.value.geotags.isEmpty()) {
@@ -68,7 +65,7 @@ fun filterFollowSetsByGeohash(
filterFollowSetsByGeohash(
relay = it.key,
geotags = it.value.geotags,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip01Core.tags.hashtags.hashtagAlts
import com.vitorpamplona.quartz.nip51Lists.FollowListEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterFollowSetsByHashtag(
@@ -59,8 +58,6 @@ fun filterFollowSetsByHashtag(
): List<RelayBasedFilter> {
if (hashSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashSet.set
.mapNotNull { relayHashSet ->
if (relayHashSet.value.hashtags.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterFollowSetsByHashtag(
filterFollowSetsByHashtag(
relay = relayHashSet.key,
hashtags = relayHashSet.value.hashtags,
since = since?.get(relayHashSet.key)?.time ?: defaultSince,
since = since?.get(relayHashSet.key)?.time,
)
}
}.flatten()
@@ -25,7 +25,6 @@ import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip51Lists.FollowListEvent
import com.vitorpamplona.quartz.utils.TimeUtils
fun filterFollowSetsGlobal(
relays: GlobalTopNavPerRelayFilterSet,
@@ -33,10 +32,8 @@ fun filterFollowSetsGlobal(
): List<RelayBasedFilter> {
if (relays.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return relays.set.map {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
RelayBasedFilter(
relay = it.key,
filter =
@@ -29,7 +29,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip53LiveActivities.chat.LiveActivitiesChatMessageEvent
import com.vitorpamplona.quartz.nip53LiveActivities.streaming.LiveActivitiesEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterLiveActivitiesAllCommunities(
@@ -75,14 +74,12 @@ fun filterLiveActivitiesByAllCommunities(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterContentDVMsAllCommunities(
relay = it.key,
communities = it.value.communities,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -29,7 +29,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip53LiveActivities.chat.LiveActivitiesChatMessageEvent
import com.vitorpamplona.quartz.nip53LiveActivities.streaming.LiveActivitiesEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -70,8 +69,6 @@ fun filterLiveActivitiesByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -80,7 +77,7 @@ fun filterLiveActivitiesByAuthors(
filterLiveActivitiesAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -92,8 +89,6 @@ fun filterLiveActivitiesByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -102,7 +97,7 @@ fun filterLiveActivitiesByAuthors(
filterLiveActivitiesAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -28,7 +28,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip53LiveActivities.chat.LiveActivitiesChatMessageEvent
import com.vitorpamplona.quartz.nip53LiveActivities.streaming.LiveActivitiesEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterLiveActivitiesByCommunity(
@@ -76,15 +75,13 @@ fun filterLiveActivitiesByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterLiveActivitiesByCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -23,7 +23,6 @@ package com.vitorpamplona.amethyst.ui.screen.loggedIn.discover.nip53LiveActiviti
import com.vitorpamplona.amethyst.model.topNavFeeds.allFollows.AllFollowsByOutboxTopNavPerRelayFilterSet
import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatMap
fun filterLiveActivitiesByFollows(
@@ -32,10 +31,8 @@ fun filterLiveActivitiesByFollows(
): List<RelayBasedFilter> {
if (followsSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return followsSet.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
val relay = it.key
listOfNotNull(
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip53LiveActivities.chat.LiveActivitiesChatMessageEvent
import com.vitorpamplona.quartz.nip53LiveActivities.streaming.LiveActivitiesEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterLiveActivitiesByGeohash(
@@ -59,8 +58,6 @@ fun filterLiveActivitiesByGeohash(
): List<RelayBasedFilter> {
if (geoSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return geoSet.set
.mapNotNull {
if (it.value.geotags.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterLiveActivitiesByGeohash(
filterLiveActivitiesByGeohash(
relay = it.key,
geotags = it.value.geotags,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -28,7 +28,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip01Core.tags.hashtags.hashtagAlts
import com.vitorpamplona.quartz.nip53LiveActivities.chat.LiveActivitiesChatMessageEvent
import com.vitorpamplona.quartz.nip53LiveActivities.streaming.LiveActivitiesEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterLiveActivitiesByHashtag(
@@ -60,8 +59,6 @@ fun filterLiveActivitiesByHashtag(
): List<RelayBasedFilter> {
if (hashSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashSet.set
.mapNotNull { relayHashSet ->
if (relayHashSet.value.hashtags.isEmpty()) {
@@ -70,7 +67,7 @@ fun filterLiveActivitiesByHashtag(
filterLiveActivitiesByHashtag(
relay = relayHashSet.key,
hashtags = relayHashSet.value.hashtags,
since = since?.get(relayHashSet.key)?.time ?: defaultSince,
since = since?.get(relayHashSet.key)?.time,
)
}
}.flatten()
@@ -26,7 +26,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip53LiveActivities.chat.LiveActivitiesChatMessageEvent
import com.vitorpamplona.quartz.nip53LiveActivities.streaming.LiveActivitiesEvent
import com.vitorpamplona.quartz.utils.TimeUtils
fun filterLiveActivitiesGlobal(
relays: GlobalTopNavPerRelayFilterSet,
@@ -34,10 +33,8 @@ fun filterLiveActivitiesGlobal(
): List<RelayBasedFilter> {
if (relays.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return relays.set.map {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
RelayBasedFilter(
relay = it.key,
filter =
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterCommunitiesAllCommunities(
@@ -69,14 +68,12 @@ fun filterCommunitiesByAllCommunities(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterCommunitiesAllCommunities(
relay = it.key,
communities = it.value.communities,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -29,7 +29,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip72ModCommunities.definition.CommunityDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -59,8 +58,6 @@ fun filterCommunitiesByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterCommunitiesByAuthors(
filterCommunitiesAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -81,8 +78,6 @@ fun filterCommunitiesByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -91,7 +86,7 @@ fun filterCommunitiesByAuthors(
filterCommunitiesAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -26,7 +26,6 @@ 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.nip72ModCommunities.definition.CommunityDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterClassifiedsByCommunity(
@@ -58,15 +57,13 @@ fun filterCommunitiesByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterClassifiedsByCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -23,7 +23,6 @@ package com.vitorpamplona.amethyst.ui.screen.loggedIn.discover.nip72Communities.
import com.vitorpamplona.amethyst.model.topNavFeeds.allFollows.AllFollowsByOutboxTopNavPerRelayFilterSet
import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatMap
fun filterCommunitiesByFollows(
@@ -32,10 +31,8 @@ fun filterCommunitiesByFollows(
): List<RelayBasedFilter> {
if (followsSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return followsSet.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
val relay = it.key
listOfNotNull(
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip72ModCommunities.definition.CommunityDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterCommunitiesByGeohash(
@@ -59,8 +58,6 @@ fun filterCommunitiesByGeohash(
): List<RelayBasedFilter> {
if (geoSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return geoSet.set
.mapNotNull {
if (it.value.geotags.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterCommunitiesByGeohash(
filterCommunitiesByGeohash(
relay = it.key,
geotags = it.value.geotags,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -28,7 +28,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip01Core.tags.hashtags.hashtagAlts
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip72ModCommunities.definition.CommunityDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterCommunitiesByHashtag(
@@ -60,8 +59,6 @@ fun filterCommunitiesByHashtag(
): List<RelayBasedFilter> {
if (hashSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashSet.set
.mapNotNull { relayHashSet ->
if (relayHashSet.value.hashtags.isEmpty()) {
@@ -70,7 +67,7 @@ fun filterCommunitiesByHashtag(
filterCommunitiesByHashtag(
relay = relayHashSet.key,
hashtags = relayHashSet.value.hashtags,
since = since?.get(relayHashSet.key)?.time ?: defaultSince,
since = since?.get(relayHashSet.key)?.time,
)
}
}.flatten()
@@ -26,7 +26,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip72ModCommunities.definition.CommunityDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
fun filterCommunitiesGlobal(
relays: GlobalTopNavPerRelayFilterSet,
@@ -34,10 +33,8 @@ fun filterCommunitiesGlobal(
): List<RelayBasedFilter> {
if (relays.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return relays.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
listOf(
RelayBasedFilter(
relay = it.key,
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip89AppHandlers.definition.AppDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterContentDVMsAllCommunities(
@@ -73,14 +72,12 @@ fun filterContentDVMsByAllCommunities(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterContentDVMsAllCommunities(
relay = it.key,
communities = it.value.communities,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -28,7 +28,6 @@ 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.nip89AppHandlers.definition.AppDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -59,8 +58,6 @@ fun filterContentDVMsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterContentDVMsByAuthors(
filterContentDVMsAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -81,8 +78,6 @@ fun filterContentDVMsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -91,7 +86,7 @@ fun filterContentDVMsByAuthors(
filterContentDVMsAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip89AppHandlers.definition.AppDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterContentDVMsByCommunity(
@@ -75,15 +74,13 @@ fun filterContentDVMsByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterContentDVMsByCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -23,7 +23,6 @@ package com.vitorpamplona.amethyst.ui.screen.loggedIn.discover.nip90DVMs.subasse
import com.vitorpamplona.amethyst.model.topNavFeeds.allFollows.AllFollowsByOutboxTopNavPerRelayFilterSet
import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatMap
fun filterContentDVMsByFollows(
@@ -32,10 +31,8 @@ fun filterContentDVMsByFollows(
): List<RelayBasedFilter> {
if (followsSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return followsSet.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
val relay = it.key
listOfNotNull(
@@ -26,7 +26,6 @@ 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.nip89AppHandlers.definition.AppDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterContentDVMsByGeohash(
@@ -58,8 +57,6 @@ fun filterContentDVMsByGeohash(
): List<RelayBasedFilter> {
if (geoSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return geoSet.set
.mapNotNull {
if (it.value.geotags.isEmpty()) {
@@ -68,7 +65,7 @@ fun filterContentDVMsByGeohash(
filterContentDVMsByGeohash(
relay = it.key,
geotags = it.value.geotags,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip01Core.tags.hashtags.hashtagAlts
import com.vitorpamplona.quartz.nip89AppHandlers.definition.AppDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterContentDVMsByHashtag(
@@ -59,8 +58,6 @@ fun filterContentDVMsByHashtag(
): List<RelayBasedFilter> {
if (hashSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashSet.set
.mapNotNull { relayHashSet ->
if (relayHashSet.value.hashtags.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterContentDVMsByHashtag(
filterContentDVMsByHashtag(
relay = relayHashSet.key,
hashtags = relayHashSet.value.hashtags,
since = since?.get(relayHashSet.key)?.time ?: defaultSince,
since = since?.get(relayHashSet.key)?.time,
)
}
}.flatten()
@@ -25,7 +25,6 @@ import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip89AppHandlers.definition.AppDefinitionEvent
import com.vitorpamplona.quartz.utils.TimeUtils
fun filterContentDVMsGlobal(
relays: GlobalTopNavPerRelayFilterSet,
@@ -33,10 +32,8 @@ fun filterContentDVMsGlobal(
): List<RelayBasedFilter> {
if (relays.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return relays.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
listOf(
RelayBasedFilter(
relay = it.key,
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterClassifiedsAllCommunities(
@@ -73,14 +72,12 @@ fun filterClassifiedsByAllCommunities(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterClassifiedsAllCommunities(
relay = it.key,
communities = it.value.communities,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -28,7 +28,6 @@ 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.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -58,8 +57,6 @@ fun filterClassifiedsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -68,7 +65,7 @@ fun filterClassifiedsByAuthors(
filterClassifiedsAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -80,8 +77,6 @@ fun filterClassifiedsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -90,7 +85,7 @@ fun filterClassifiedsByAuthors(
filterClassifiedsAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterClassifiedsByCommunity(
@@ -75,15 +74,13 @@ fun filterClassifiedsByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterClassifiedsByCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -23,7 +23,6 @@ package com.vitorpamplona.amethyst.ui.screen.loggedIn.discover.nip99Classifieds.
import com.vitorpamplona.amethyst.model.topNavFeeds.allFollows.AllFollowsByOutboxTopNavPerRelayFilterSet
import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterClassifiedsByFollows(
@@ -32,10 +31,8 @@ fun filterClassifiedsByFollows(
): List<RelayBasedFilter> {
if (followsSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return followsSet.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
val relay = it.key
listOfNotNull(
@@ -26,7 +26,6 @@ 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.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterClassifiedsByGeohash(
@@ -58,8 +57,6 @@ fun filterClassifiedsByGeohash(
): List<RelayBasedFilter> {
if (geoSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return geoSet.set
.mapNotNull {
if (it.value.geotags.isEmpty()) {
@@ -68,7 +65,7 @@ fun filterClassifiedsByGeohash(
filterClassifiedsByGeohash(
relay = it.key,
geotags = it.value.geotags,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -27,7 +27,6 @@ import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip01Core.relay.normalizer.NormalizedRelayUrl
import com.vitorpamplona.quartz.nip01Core.tags.hashtags.hashtagAlts
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
fun filterClassifiedsByHashtag(
@@ -59,8 +58,6 @@ fun filterClassifiedsByHashtag(
): List<RelayBasedFilter> {
if (hashSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashSet.set
.mapNotNull { relayHashSet ->
if (relayHashSet.value.hashtags.isEmpty()) {
@@ -69,7 +66,7 @@ fun filterClassifiedsByHashtag(
filterClassifiedsByHashtag(
relay = relayHashSet.key,
hashtags = relayHashSet.value.hashtags,
since = since?.get(relayHashSet.key)?.time ?: defaultSince,
since = since?.get(relayHashSet.key)?.time,
)
}
}.flatten()
@@ -25,7 +25,6 @@ import com.vitorpamplona.amethyst.service.relays.SincePerRelayMap
import com.vitorpamplona.quartz.nip01Core.relay.client.pool.RelayBasedFilter
import com.vitorpamplona.quartz.nip01Core.relay.filters.Filter
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
fun filterClassifiedsGlobal(
relays: GlobalTopNavPerRelayFilterSet,
@@ -33,10 +32,8 @@ fun filterClassifiedsGlobal(
): List<RelayBasedFilter> {
if (relays.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return relays.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
listOf(
RelayBasedFilter(
relay = it.key,
@@ -35,7 +35,6 @@ import com.vitorpamplona.quartz.nip23LongContent.LongTextNoteEvent
import com.vitorpamplona.quartz.nip54Wiki.WikiNoteEvent
import com.vitorpamplona.quartz.nip84Highlights.HighlightEvent
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
import kotlin.collections.sorted
@@ -80,8 +79,6 @@ fun filterHomePostsByGeohashes(
): List<RelayBasedFilter> {
if (geoSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return geoSet.set
.mapNotNull {
if (it.value.geotags.isEmpty()) {
@@ -90,12 +87,12 @@ fun filterHomePostsByGeohashes(
filterHomePostsByGeohashes(
relay = it.key,
geotags = it.value.geotags,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
) +
filterHomePostsByScopes(
relay = it.key,
scopesToLoad = it.value.geotagScopes,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -39,7 +39,6 @@ import com.vitorpamplona.quartz.nip53LiveActivities.streaming.LiveActivitiesEven
import com.vitorpamplona.quartz.nip54Wiki.WikiNoteEvent
import com.vitorpamplona.quartz.nip84Highlights.HighlightEvent
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
val HomePostsByGlobalKinds =
listOf(
@@ -70,10 +69,8 @@ fun filterHomePostsByGlobal(
): List<RelayBasedFilter> {
if (relays.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return relays.set.flatMap {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
val relayUrl = it.key
listOf(
RelayBasedFilter(
@@ -37,7 +37,6 @@ import com.vitorpamplona.quartz.nip23LongContent.LongTextNoteEvent
import com.vitorpamplona.quartz.nip54Wiki.WikiNoteEvent
import com.vitorpamplona.quartz.nip84Highlights.HighlightEvent
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -84,14 +83,12 @@ fun filterHomePostsByHashtags(
): List<RelayBasedFilter> {
if (hashtagSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashtagSet.set
.mapNotNull {
if (it.value.hashtags.isEmpty()) {
null
} else {
val since = since?.get(it.key)?.time ?: defaultSince
val since = since?.get(it.key)?.time
return filterHomePostsByHashtags(
relay = it.key,
@@ -42,7 +42,6 @@ import com.vitorpamplona.quartz.nip53LiveActivities.streaming.LiveActivitiesEven
import com.vitorpamplona.quartz.nip54Wiki.WikiNoteEvent
import com.vitorpamplona.quartz.nip84Highlights.HighlightEvent
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.mapNotNull
val HomePostsKinds =
@@ -105,8 +104,6 @@ fun filterHomePostsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -115,7 +112,7 @@ fun filterHomePostsByAuthors(
filterHomePostsByAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -127,8 +124,6 @@ fun filterHomePostsByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -137,7 +132,7 @@ fun filterHomePostsByAuthors(
filterHomePostsByAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -26,7 +26,6 @@ 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.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterHomePostsFromAllCommunities(
@@ -72,14 +71,12 @@ fun filterHomePostsByAllCommunities(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterHomePostsFromAllCommunities(
relay = it.key,
communities = it.value.communities,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -33,7 +33,6 @@ import com.vitorpamplona.quartz.nip54Wiki.WikiNoteEvent
import com.vitorpamplona.quartz.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.nip84Highlights.HighlightEvent
import com.vitorpamplona.quartz.nip99Classifieds.ClassifiedsEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -106,15 +105,13 @@ fun filterHomePostsByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterHomePostsFromCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}
@@ -29,7 +29,6 @@ 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.nip01Core.tags.hashtags.hashtagAlts
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterPictureAndVideoHashtag(
@@ -73,8 +72,6 @@ fun filterPictureAndVideoByHashtag(
): List<RelayBasedFilter> {
if (hashSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return hashSet.set
.mapNotNull { relayHashSet ->
if (relayHashSet.value.hashtags.isEmpty()) {
@@ -83,7 +80,7 @@ fun filterPictureAndVideoByHashtag(
filterPictureAndVideoHashtag(
relay = relayHashSet.key,
hashtags = relayHashSet.value.hashtags,
since = since?.get(relayHashSet.key)?.time ?: defaultSince,
since = since?.get(relayHashSet.key)?.time,
)
}
}.flatten()
@@ -30,7 +30,6 @@ 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.TimeUtils
import kotlin.collections.flatten
import kotlin.collections.mapNotNull
@@ -71,8 +70,6 @@ fun filterPictureAndVideoByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -81,7 +78,7 @@ fun filterPictureAndVideoByAuthors(
filterPictureAndVideoAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -93,8 +90,6 @@ fun filterPictureAndVideoByAuthors(
): List<RelayBasedFilter> {
if (authorSet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return authorSet.set
.mapNotNull {
if (it.value.authors.isEmpty()) {
@@ -103,7 +98,7 @@ fun filterPictureAndVideoByAuthors(
filterPictureAndVideoAuthors(
relay = it.key,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}
}.flatten()
@@ -31,7 +31,6 @@ 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.nip72ModCommunities.approval.CommunityPostApprovalEvent
import com.vitorpamplona.quartz.utils.TimeUtils
import kotlin.collections.flatten
fun filterPictureAndVideoCommunity(
@@ -111,15 +110,13 @@ fun filterPictureAndVideoByCommunity(
): List<RelayBasedFilter> {
if (communitySet.set.isEmpty()) return emptyList()
val defaultSince = TimeUtils.oneWeekAgo()
return communitySet.set
.mapNotNull {
filterPictureAndVideoCommunity(
relay = it.key,
community = it.value.community,
authors = it.value.authors,
since = since?.get(it.key)?.time ?: defaultSince,
since = since?.get(it.key)?.time,
)
}.flatten()
}