fixes

data/src/main/java/com/moez/QKSMS/repository/ScheduledMessageRepositoryImpl.kt

@@ -1,24 +1,10 @@
-/*
- * Copyright (C) 2017 Moez Bhatti <moez.bhatti@gmail.com>
- *
- * This file is part of QKSMS.
- *
- * QKSMS is free software: you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation, either version 3 of the License, or
- * (at your option) any later version.
- *
- * QKSMS is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License
- * along with QKSMS.  If not, see <http://www.gnu.org/licenses/>.
- */
 package dev.octoshrimpy.quik.repository
 
 import dev.octoshrimpy.quik.model.ScheduledMessage
+import io.reactivex.Completable
+import io.reactivex.android.schedulers.AndroidSchedulers
+import io.reactivex.disposables.CompositeDisposable
+import io.reactivex.schedulers.Schedulers
 import io.realm.Realm
 import io.realm.RealmList
 import io.realm.RealmResults
@@ -26,6 +12,8 @@ import javax.inject.Inject
 
 class ScheduledMessageRepositoryImpl @Inject constructor() : ScheduledMessageRepository {
 
+    private val disposables = CompositeDisposable()
+
     override fun saveScheduledMessage(
         date: Long,
         subId: Int,
@@ -40,7 +28,7 @@ class ScheduledMessageRepositoryImpl @Inject constructor() : ScheduledMessageRep
             val attachmentsRealmList = RealmList(*attachments.toTypedArray())
 
             val message = ScheduledMessage(id, date, subId, recipientsRealmList, sendAsGroup, body,
-                    attachmentsRealmList)
+                attachmentsRealmList)
 
             realm.executeTransaction { realm.insertOrUpdate(message) }
         }
@@ -48,29 +36,41 @@ class ScheduledMessageRepositoryImpl @Inject constructor() : ScheduledMessageRep
 
     override fun getScheduledMessages(): RealmResults<ScheduledMessage> {
         return Realm.getDefaultInstance()
-                .where(ScheduledMessage::class.java)
-                .sort("date")
-                .findAll()
+            .where(ScheduledMessage::class.java)
+            .sort("date")
+            .findAll()
     }
 
     override fun getScheduledMessage(id: Long): ScheduledMessage? {
         return Realm.getDefaultInstance()
-                .apply { refresh() }
-                .where(ScheduledMessage::class.java)
-                .equalTo("id", id)
-                .findFirst()
+            .apply { refresh() }
+            .where(ScheduledMessage::class.java)
+            .equalTo("id", id)
+            .findFirst()
     }
 
     override fun deleteScheduledMessage(id: Long) {
-        Realm.getDefaultInstance()
-                .apply { refresh() }
-                .use { realm ->
-                    val message = realm.where(ScheduledMessage::class.java)
-                            .equalTo("id", id)
-                            .findFirst()
+        val subscription = Completable.fromAction {
+            Realm.getDefaultInstance().use { realm ->
+                val message = realm.where(ScheduledMessage::class.java)
+                    .equalTo("id", id)
+                    .findFirst()
 
-                    realm.executeTransaction { message?.deleteFromRealm() }
-                }
+                realm.executeTransaction { message?.deleteFromRealm() }
+            }
+        }.subscribeOn(Schedulers.io()) // Perform the operation in a background thread
+            .observeOn(AndroidSchedulers.mainThread()) // Switch back to the main thread if needed
+            .subscribe({
+                // Handle completion, e.g., log success or update UI
+            }, {
+                // Handle error, e.g., log or show error message
+            })
+
+        disposables.add(subscription)
     }
 
-}
+    // Ensure to clear disposables when the repository is no longer needed
+    fun clearDisposables() {
+        disposables.clear()
+    }
+}