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

Implement deletion of non-existent conversations

Browse Source
This commit is contained in:
James Magahern
2023-08-17 01:53:37 -07:00
parent 84e3a27c62
commit 19a6960ab2
3 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/src/main/java/net/buzzert/kordophonedroid/ui/conversationlist/ConversationListViewModel.kt
View File

@@ -26,7 +26,7 @@ class ConversationListViewModel @Inject constructor(
init { init {
// TODO: Is this the best place to put these? // TODO: Is this the best place to put these?
// TODO: Need error handling (exceptions thrown below) // TODO: Need error handling (exceptions thrown below)
viewModelScope.launch { viewModelScope.launch {
repository.synchronize() repository.synchronize()
} }

9
backend/src/main/java/net/buzzert/kordophone/backend/db/CachedChatDatabase.kt
View File

@@ -85,6 +85,15 @@ class CachedChatDatabase (private val realmConfig: RealmConfiguration) {
} }
} }
fun deleteConversations(conversations: List<ModelConversation>) = realm.writeBlocking {
conversations.forEach { inConversation ->
val conversation = getConversationByGuid(inConversation.guid)
findLatest(conversation)?.let {
delete(it)
}
}
}
fun fetchConversations(): List<ModelConversation> { fun fetchConversations(): List<ModelConversation> {
val items = realm.query(Conversation::class).find() val items = realm.query(Conversation::class).find()
return items.map { it.toConversation() } return items.map { it.toConversation() }

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

@@ -121,10 +121,11 @@ class ChatRepository(
Log.d(REPO_LOG, "Synchronizing conversations") Log.d(REPO_LOG, "Synchronizing conversations")
// Sync conversations // Sync conversations
val conversations = fetchConversations() val serverConversations = fetchConversations()
database.writeConversations(conversations) val deletedConversations = conversations.minus(serverConversations)
// TODO: Delete non-existent conversations. database.deleteConversations(deletedConversations)
database.writeConversations(serverConversations)
// Sync top N number of conversations' message content // Sync top N number of conversations' message content
Log.d(REPO_LOG, "Synchronizing messages") Log.d(REPO_LOG, "Synchronizing messages")