Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 0156b224 authored by Moez Bhatti's avatar Moez Bhatti
Browse files
parent e6e55e91
Loading
Loading
Loading
Loading
+3 −1
Original line number Original line Diff line number Diff line
@@ -39,6 +39,7 @@ import util.extensions.asFlowable
import util.extensions.insertOrUpdate
import util.extensions.insertOrUpdate
import util.extensions.map
import util.extensions.map
import util.extensions.mapWhile
import util.extensions.mapWhile
import util.tryOrNull
import javax.inject.Inject
import javax.inject.Inject
import javax.inject.Singleton
import javax.inject.Singleton


@@ -138,13 +139,14 @@ class SyncRepositoryImpl @Inject constructor(
    }
    }


    override fun syncMessage(uri: Uri): Flowable<Message> {
    override fun syncMessage(uri: Uri): Flowable<Message> {
        val id = ContentUris.parseId(uri)
        val type = when {
        val type = when {
            uri.toString().contains("mms") -> "mms"
            uri.toString().contains("mms") -> "mms"
            uri.toString().contains("sms") -> "sms"
            uri.toString().contains("sms") -> "sms"
            else -> return Flowable.empty()
            else -> return Flowable.empty()
        }
        }


        val id = tryOrNull { ContentUris.parseId(uri) }

        // Check if the message already exists, so we can reuse the id
        // Check if the message already exists, so we can reuse the id
        val existingId = Realm.getDefaultInstance().use { realm ->
        val existingId = Realm.getDefaultInstance().use { realm ->
            realm.refresh()
            realm.refresh()