buzzert/Kordophone
Private
Public Access
1
0
Fork 0
Code Packages Activity

ChatRepository: Bump up sync limit a bit

Browse Source
This commit is contained in:
James Magahern
2024-03-19 00:55:43 -07:00
parent 09294e7da9
commit 66c2752096
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/src/main/java/net/buzzert/kordophonedroid/ui/messagelist/MessageListViewModel.kt
View File

@@ -92,6 +92,6 @@ class MessageListViewModel @Inject constructor(
} }
fun synchronize() = viewModelScope.launch { fun synchronize() = viewModelScope.launch {
repository.synchronizeConversation(conversation!!) repository.synchronizeConversation(conversation!!, limit = 100)
} }
} }

4
backend/src/main/java/net/buzzert/kordophone/backend/server/ChatRepository.kt
View File

@@ -173,10 +173,10 @@ class ChatRepository(
_errorEncounteredChannel.emit(Error.ConnectionError(e)) _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. // TODO: Should only fetch messages after the last GUID we know about.
// But keep in mind that outgoing message GUIDs are fake... // 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) database.writeMessages(messages, conversation)
} catch (e: java.lang.Exception) { } catch (e: java.lang.Exception) {
_errorEncounteredChannel.emit(Error.ConnectionError(e)) _errorEncounteredChannel.emit(Error.ConnectionError(e))