anyproto/anytype-kotlin
1
0
Fork 0
mirror of https://github.com/anyproto/anytype-kotlin.git synced 2025-06-07 21:37:02 +09:00
Code Activity

DROID-3699 Chats | Enhancement | Unsubscribe from chats on back navigation (#2473)

Browse source
This commit is contained in:
Evgenii Kozlov 2025-05-27 22:43:24 +02:00 • committed by konstantiniiv
parent 363560b459
commit eddd5b98f3
3 changed files with 17 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

17
domain/src/main/java/com/anytypeio/anytype/domain/chats/ChatContainer.kt
View file

@ -105,6 +105,16 @@ class ChatContainer @Inject constructor(
}
}
suspend fun stop(chat: Id) {
runCatching {
repo.unsubscribeChat(chat)
}.onFailure {
logger.logWarning("DROID-2966 Error while unsubscribing from chat")
}.onSuccess {
logger.logInfo("DROID-2966 Successfully unsubscribed from chat")
}
}
fun watch(chat: Id): Flow<ChatStreamState> = flow {
val response = repo.subscribeLastChatMessages(
command = Command.ChatCommand.SubscribeLastMessages(
@ -119,7 +129,7 @@ class ChatContainer @Inject constructor(
var intent: Intent = Intent.None
val initial = buildList<Chat.Message> {
val initial = buildList {
if (initialState.hasUnReadMessages && !initialState.oldestMessageOrderId.isNullOrEmpty()) {
// Starting from the unread-messages window.
val aroundUnread = loadAroundMessageOrder(
@ -210,7 +220,6 @@ class ChatContainer @Inject constructor(
logger.logException(e, "DROID-2966 Error while loading reply context")
state.messages
}
val target = messages.find { it.order == oldestReadOrderId }
ChatStreamState(
messages = messages,
intent = Intent.ScrollToBottom,
@ -296,7 +305,7 @@ class ChatContainer @Inject constructor(
)
)
}.onFailure {
logger.logException(it, "DROID-2966 Error while reading mentions")
logger.logWarning("DROID-2966 Error while reading mentions: ${it.message}")
}.onSuccess {
logger.logInfo("DROID-2966 Read mentions with success")
}
@ -336,7 +345,7 @@ class ChatContainer @Inject constructor(
)
)
}.onFailure {
logger.logException(it, "DROID-2966 Error while reading messages")
logger.logWarning("DROID-2966 Error while reading messages: ${it.message}")
}.onSuccess {
logger.logInfo("DROID-2966 Read messages with success")
}

2
domain/src/main/java/com/anytypeio/anytype/domain/chats/ChatPreviewContainer.kt
View file

@ -48,7 +48,7 @@ interface ChatPreviewContainer {
job = scope.launch(dispatchers.io) {
previews.value = emptyList()
val initial = runCatching { repo.subscribeToMessagePreviews(SUBSCRIPTION_ID) }
.onFailure { logger.logException(it, "DROID-2966 Error while getting initial previews") }
.onFailure { logger.logWarning("DROID-2966 Error while getting initial previews: ${it.message}") }
.getOrDefault(emptyList())
events
.subscribe(SUBSCRIPTION_ID)

3
feature-chats/src/main/java/com/anytypeio/anytype/feature_chats/presentation/ChatViewModel.kt
View file

@ -914,6 +914,9 @@ class ChatViewModel @Inject constructor(
fun onBackButtonPressed(isSpaceRoot: Boolean) {
viewModelScope.launch {
withContext(dispatchers.io) {
chatContainer.stop(chat = vmParams.ctx)
}
if (isSpaceRoot) {
Timber.d("Root space screen. Releasing resources...")
proceedWithClearingSpaceBeforeExitingToVault()