Coroutine + Realm = FUCK

Author: potados99

common/src/main/java/org/wbpbp/preshoes/interactor/UseCase.kt

@@ -19,10 +19,8 @@
 
 package org.wbpbp.preshoes.interactor
 
-import kotlinx.coroutines.GlobalScope
-import kotlinx.coroutines.MainScope
-import kotlinx.coroutines.async
-import kotlinx.coroutines.launch
+import android.os.Handler
+import android.os.Looper
 import org.wbpbp.preshoes.functional.Result
 import timber.log.Timber
 
@@ -31,18 +29,21 @@ import timber.log.Timber
  * Any use case in this application should implement this.
  */
 abstract class UseCase<in Params, out Type> {
-    abstract suspend fun run(params: Params): Result<Type>
+    abstract fun run(params: Params): Result<Type>
 
     /**
-     * Execute [run] in Global Scope co-routine and launch onResult on Main conversation.
+     * Use thread instead of coroutine because it ruins Realm.
      */
     operator fun invoke(params: Params, onResult: (Result<Type>) -> Unit = {}) {
-        Timber.i("Use case '${this::class.java.name}' running")
-
-        val job = GlobalScope.async { run(params) }
-
-        MainScope().launch {
-            onResult(job.await())
-        }
+        Thread {
+            try {
+                Timber.v("UseCase ${this::class.java.name} running on ${Thread.currentThread().name}")
+                val result = run(params)
+                Handler(Looper.getMainLooper()).post { onResult(result) }
+            } catch (e: Exception) {
+                Timber.w("Exception inside another thread.")
+                Timber.w(e)
+            }
+        }.start()
     }
 }

data/src/main/java/org/wbpbp/preshoes/storage/ReportRepositoryImpl.kt

@@ -94,8 +94,6 @@ class ReportRepositoryImpl(
             rightPressure = features.samplesInSingleWalkCycleRight
         )
 
-        Timber.i(requestModel.toString())
-
         val response = api.requestReportCommentary(requestModel).execute()
 
         if (!response.isSuccessful) {

domain/src/main/java/org/wbpbp/preshoes/usecase/ConnectDevices.kt

@@ -27,7 +27,7 @@ class ConnectDevices(
     private val service: SensorDeviceService
 ) : UseCase<Pair<String, String>, Boolean>() {
 
-    override suspend fun run(params: Pair<String, String>)=
+    override fun run(params: Pair<String, String>)=
         Result.of {
             val leftResult = service.connectLeftSensorDevice(params.first)
             val rightResult = service.connectRightSensorDevice(params.second)

domain/src/main/java/org/wbpbp/preshoes/usecase/CreateReport.kt

@@ -27,7 +27,7 @@ class CreateReport(
     private val service: ReportService
 ) : UseCase<Unit, Int?>() {
 
-    override suspend fun run(params: Unit) = Result.of {
+    override fun run(params: Unit) = Result.of {
         service.finishRecordingAndCreateReport()
     }
 }

domain/src/main/java/org/wbpbp/preshoes/usecase/DeleteReport.kt

@@ -27,7 +27,7 @@ class DeleteReport(
     private val repo: ReportRepository
 ) : UseCase<Int, Unit>() {
 
-    override suspend fun run(params: Int) = Result.of {
+    override fun run(params: Int) = Result.of {
         repo.deleteReportById(params)
     }
 }

domain/src/main/java/org/wbpbp/preshoes/usecase/FinishStandingRecording.kt

@@ -27,7 +27,7 @@ class FinishStandingRecording(
     private val service: ReportService
 ) : UseCase<Unit, Unit>() {
 
-    override suspend fun run(params: Unit) = Result.of {
+    override fun run(params: Unit) = Result.of {
         service.finishRecordingStandingPressureDistribution()
     }
 }

domain/src/main/java/org/wbpbp/preshoes/usecase/FinishWalkingRecording.kt

@@ -27,7 +27,7 @@ class FinishWalkingRecording(
     private val service: ReportService
 ) : UseCase<Unit, Unit>() {
 
-    override suspend fun run(params: Unit) = Result.of {
+    override fun run(params: Unit) = Result.of {
         service.finishRecordingWalkingPressureDistribution()
     }
 }

domain/src/main/java/org/wbpbp/preshoes/usecase/GetReports.kt

@@ -29,7 +29,7 @@ class GetReports(
     private val repo: ReportRepository
 ) : UseCase<Unit, RealmResults<Report>>() {
 
-    override suspend fun run(params: Unit) = Result.of {
+    override fun run(params: Unit) = Result.of {
         repo.getAllReports()
     }
 }

domain/src/main/java/org/wbpbp/preshoes/usecase/GetUser.kt

@@ -28,7 +28,7 @@ class GetUser(
     private val repo: UserRepository
 ) : UseCase<Unit, User?>() {
 
-    override suspend fun run(params: Unit) = Result.of {
+    override fun run(params: Unit) = Result.of {
         repo.getUser()
     }
 }

domain/src/main/java/org/wbpbp/preshoes/usecase/HaltRecording.kt

@@ -27,7 +27,7 @@ class HaltRecording(
     private val service: ReportService
 ) : UseCase<Unit, Unit>() {
 
-    override suspend fun run(params: Unit) = Result.of {
+    override fun run(params: Unit) = Result.of {
         service.haltRecording()
     }
 }