highperfocused/amethyst
1
0
Fork 0
mirror of https://github.com/vitorpamplona/amethyst.git synced 2025-11-10 13:17:34 +01:00
Code Issues Packages Projects Releases Wiki Activity

Only listens to notification changes when the UI is visible

Browse Source
This commit is contained in:
Vitor Pamplona
2025-10-20 19:41:27 -04:00
parent 63bd0b6cae
commit 37625987c1
1 changed files with 38 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
amethyst/src/main/java/com/vitorpamplona/amethyst/ui/screen/loggedIn/AccountViewModel.kt
View File

@@ -187,12 +187,22 @@ class AccountViewModel(
}.map { it?.list?.firstOrNull()?.createdAt() }, }.map { it?.list?.firstOrNull()?.createdAt() },
) { lastRead, newestItemCreatedAt -> ) { lastRead, newestItemCreatedAt ->
emit(newestItemCreatedAt != null && newestItemCreatedAt > lastRead) emit(newestItemCreatedAt != null && newestItemCreatedAt > lastRead)
}.onStart {
val lastRead = account.loadLastReadFlow("Notification").value
val cards = feedStates.notifications.feedContent.value
if (cards is CardFeedState.Loaded) {
val newestItemCreatedAt =
cards.feed.value.list
.firstOrNull()
?.createdAt()
emit(newestItemCreatedAt != null && newestItemCreatedAt > lastRead)
}
} }
val notificationHasNewItemsFlow = val notificationHasNewItemsFlow =
notificationHasNewItems notificationHasNewItems
.flowOn(Dispatchers.Default) .flowOn(Dispatchers.Default)
.stateIn(viewModelScope, SharingStarted.Eagerly, false) .stateIn(viewModelScope, SharingStarted.WhileSubscribed(30000), false)
@OptIn(ExperimentalCoroutinesApi::class) @OptIn(ExperimentalCoroutinesApi::class)
val messagesHasNewItems = val messagesHasNewItems =
@@ -221,12 +231,27 @@ class AccountViewModel(
} else { } else {
MutableStateFlow(false) MutableStateFlow(false)
} }
}.onStart {
val feed = feedStates.dmKnown.feedContent.value
if (feed is FeedState.Loaded) {
val newItems =
feed.feed.value.list.any { chat ->
(chat.event as? ChatroomKeyable)?.let { event ->
val room = event.chatroomKey(account.signer.pubKey)
val lastReadAt =
account.settings.lastReadPerRoute.value["Room/${room.hashCode()}"]
?.value ?: 0L
(chat.event?.createdAt ?: 0) > lastReadAt
} == true
}
emit(newItems)
}
} }
val messagesHasNewItemsFlow = val messagesHasNewItemsFlow =
messagesHasNewItems messagesHasNewItems
.flowOn(Dispatchers.Default) .flowOn(Dispatchers.Default)
.stateIn(viewModelScope, SharingStarted.Eagerly, false) .stateIn(viewModelScope, SharingStarted.WhileSubscribed(30000), false)
@OptIn(ExperimentalCoroutinesApi::class) @OptIn(ExperimentalCoroutinesApi::class)
val homeHasNewItems = val homeHasNewItems =
@@ -244,12 +269,22 @@ class AccountViewModel(
}, },
) { lastRead, newestItemCreatedAt -> ) { lastRead, newestItemCreatedAt ->
emit(newestItemCreatedAt != null && newestItemCreatedAt > lastRead) emit(newestItemCreatedAt != null && newestItemCreatedAt > lastRead)
}.onStart {
val lastRead = account.loadLastReadFlow("HomeFollows").value
val feed = feedStates.homeNewThreads.feedContent.value
if (feed is FeedState.Loaded) {
val newestItemCreatedAt =
feed.feed.value.list
.firstOrNull { it.event != null && it.event !is GenericRepostEvent && it.event !is RepostEvent }
?.createdAt()
emit(newestItemCreatedAt != null && newestItemCreatedAt > lastRead)
}
} }
val homeHasNewItemsFlow = val homeHasNewItemsFlow =
homeHasNewItems homeHasNewItems
.flowOn(Dispatchers.Default) .flowOn(Dispatchers.Default)
.stateIn(viewModelScope, SharingStarted.Eagerly, false) .stateIn(viewModelScope, SharingStarted.WhileSubscribed(30000), false)
val hasNewItems = val hasNewItems =
mapOf( mapOf(