From 66c2752096325245d4bdffff6add3652a0172951 Mon Sep 17 00:00:00 2001 From: James Magahern Date: Tue, 19 Mar 2024 00:55:43 -0700 Subject: [PATCH] ChatRepository: Bump up sync limit a bit --- .../kordophonedroid/ui/messagelist/MessageListViewModel.kt | 2 +- .../net/buzzert/kordophone/backend/server/ChatRepository.kt | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/app/src/main/java/net/buzzert/kordophonedroid/ui/messagelist/MessageListViewModel.kt b/app/src/main/java/net/buzzert/kordophonedroid/ui/messagelist/MessageListViewModel.kt index 69d3de7..9ee845f 100644 --- a/app/src/main/java/net/buzzert/kordophonedroid/ui/messagelist/MessageListViewModel.kt +++ b/app/src/main/java/net/buzzert/kordophonedroid/ui/messagelist/MessageListViewModel.kt @@ -92,6 +92,6 @@ class MessageListViewModel @Inject constructor( } fun synchronize() = viewModelScope.launch { - repository.synchronizeConversation(conversation!!) + repository.synchronizeConversation(conversation!!, limit = 100) } } \ No newline at end of file diff --git a/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt b/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt index 50b7e5d..141822f 100644 --- a/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt +++ b/backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt @@ -173,10 +173,10 @@ class ChatRepository( _errorEncounteredChannel.emit(Error.ConnectionError(e)) } - suspend fun synchronizeConversation(conversation: Conversation) = try { + suspend fun synchronizeConversation(conversation: Conversation, limit: Int = 15) = try { // TODO: Should only fetch messages after the last GUID we know about. // But keep in mind that outgoing message GUIDs are fake... - val messages = fetchMessages(conversation, limit = 15) + val messages = fetchMessages(conversation, limit = limit) database.writeMessages(messages, conversation) } catch (e: java.lang.Exception) { _errorEncounteredChannel.emit(Error.ConnectionError(e))