diff --git a/app/src/main/java/com/vitorpamplona/amethyst/service/NostrDiscoveryDataSource.kt b/app/src/main/java/com/vitorpamplona/amethyst/service/NostrDiscoveryDataSource.kt index 17741ee60..270bf599b 100644 --- a/app/src/main/java/com/vitorpamplona/amethyst/service/NostrDiscoveryDataSource.kt +++ b/app/src/main/java/com/vitorpamplona/amethyst/service/NostrDiscoveryDataSource.kt @@ -17,7 +17,6 @@ object NostrDiscoveryDataSource : NostrDataSource("DiscoveryFeed") { lateinit var account: Account val latestEOSEs = EOSEAccount() - val dataSource = "Discovery" fun createLiveStreamFilter(): TypedFilter { val follows = account.selectedUsersFollowList(account.defaultDiscoveryFollowList) @@ -32,7 +31,7 @@ object NostrDiscoveryDataSource : NostrDataSource("DiscoveryFeed") { authors = followKeys, kinds = listOf(LiveActivitiesChatMessageEvent.kind, LiveActivitiesEvent.kind), limit = 300, - since = latestEOSEs.users[account.userProfile()]?.followList?.get(dataSource)?.relayList + since = latestEOSEs.users[account.userProfile()]?.followList?.get(account.defaultDiscoveryFollowList)?.relayList ) ) } @@ -50,7 +49,7 @@ object NostrDiscoveryDataSource : NostrDataSource("DiscoveryFeed") { authors = followKeys, kinds = listOf(ChannelCreateEvent.kind, ChannelMetadataEvent.kind, ChannelMessageEvent.kind), limit = 300, - since = latestEOSEs.users[account.userProfile()]?.followList?.get(dataSource)?.relayList + since = latestEOSEs.users[account.userProfile()]?.followList?.get(account.defaultDiscoveryFollowList)?.relayList ) ) } @@ -68,7 +67,7 @@ object NostrDiscoveryDataSource : NostrDataSource("DiscoveryFeed") { authors = followKeys, kinds = listOf(CommunityDefinitionEvent.kind, CommunityPostApprovalEvent.kind), limit = 300, - since = latestEOSEs.users[account.userProfile()]?.followList?.get(dataSource)?.relayList + since = latestEOSEs.users[account.userProfile()]?.followList?.get(account.defaultDiscoveryFollowList)?.relayList ) ) } @@ -88,7 +87,7 @@ object NostrDiscoveryDataSource : NostrDataSource("DiscoveryFeed") { }.flatten() ), limit = 300, - since = latestEOSEs.users[account.userProfile()]?.followList?.get(dataSource)?.relayList + since = latestEOSEs.users[account.userProfile()]?.followList?.get(account.defaultDiscoveryFollowList)?.relayList ) ) } @@ -108,7 +107,7 @@ object NostrDiscoveryDataSource : NostrDataSource("DiscoveryFeed") { }.flatten() ), limit = 300, - since = latestEOSEs.users[account.userProfile()]?.followList?.get(dataSource)?.relayList + since = latestEOSEs.users[account.userProfile()]?.followList?.get(account.defaultDiscoveryFollowList)?.relayList ) ) } @@ -128,12 +127,14 @@ object NostrDiscoveryDataSource : NostrDataSource("DiscoveryFeed") { }.flatten() ), limit = 300, - since = latestEOSEs.users[account.userProfile()]?.followList?.get(dataSource)?.relayList + since = latestEOSEs.users[account.userProfile()]?.followList?.get(account.defaultDiscoveryFollowList)?.relayList ) ) } - val discoveryFeedChannel = requestNewChannel() + val discoveryFeedChannel = requestNewChannel() { time, relayUrl -> + latestEOSEs.addOrUpdate(account.userProfile(), account.defaultDiscoveryFollowList, relayUrl, time) + } override fun updateChannelFilters() { discoveryFeedChannel.typedFilters = listOfNotNull(