karol/quik
0
0
Fork 0
forked from upstream-mirrors/quik
Code Pull Requests Actions Releases 10 Activity

change to start dial of last non-me recipient in a conversation in compose, qkreply and main-activity-swipe call actions

Browse Source
This commit is contained in:
gavine99
2025-03-13 09:39:02 +11:00
parent 28001d4e99
commit 74a639cf40
5 changed files with 65 additions and 37 deletions
Download Patch File Download Diff File Expand all files Collapse all files
data/src/main/java/com/moez/QKSMS/repository/MessageRepositoryImpl.kt
+24 -16
View File
@@ -63,6 +63,7 @@ import dev.octoshrimpy.quik.util.Preferences
import dev.octoshrimpy.quik.util.tryOrNull
import io.realm.Case
import io.realm.Realm
import io.realm.RealmQuery
import io.realm.RealmResults
import io.realm.Sort
import timber.log.Timber
@@ -73,7 +74,7 @@ import kotlin.collections.ArrayList
import kotlin.math.sqrt
@Singleton
class MessageRepositoryImpl @Inject constructor(
open class MessageRepositoryImpl @Inject constructor(
private val activeConversationManager: ActiveConversationManager,
private val context: Context,
private val messageIds: KeyManager,
@@ -82,23 +83,30 @@ class MessageRepositoryImpl @Inject constructor(
private val syncRepository: SyncRepository
) : MessageRepository {
override fun getMessages(threadId: Long, query: String): RealmResults<Message> {
private fun getMessagesBase(threadId: Long, query: String): RealmQuery<Message> {
return Realm.getDefaultInstance()
.where(Message::class.java)
.equalTo("threadId", threadId)
.let {
when (query.isEmpty()) {
true -> it
false -> it
.beginGroup()
.contains("body", query, Case.INSENSITIVE)
.or()
.contains("parts.text", query, Case.INSENSITIVE)
.endGroup()
}
.where(Message::class.java)
.equalTo("threadId", threadId)
.let {
when (query.isEmpty()) {
true -> it
false -> it
.beginGroup()
.contains("body", query, Case.INSENSITIVE)
.or()
.contains("parts.text", query, Case.INSENSITIVE)
.endGroup()
}
.sort("date")
.findAllAsync()
}
.sort("date")
}
override fun getMessages(threadId: Long, query: String): RealmResults<Message> {
return getMessagesBase(threadId, query).findAllAsync()
}
override fun getMessagesSync(threadId: Long, query: String): RealmResults<Message> {
return getMessagesBase(threadId, query).findAll()
}
override fun getMessage(id: Long): Message? {