Add a safe executor which does not crash when an exception occurs (for Telephony)

Signed-off-by: Kyle Corry <[email protected]>

Author: kylecorry31

core/src/main/java/com/kylecorry/andromeda/core/coroutines/SafeExecutor.kt

@@ -0,0 +1,31 @@
+package com.kylecorry.andromeda.core.coroutines
+
+import android.util.Log
+import java.util.concurrent.Executor
+import java.util.concurrent.Executors
+
+class SafeExecutor(
+    private val delegate: Executor,
+    private val onError: (Throwable) -> Unit = defaultThrowableHandler
+) : Executor {
+    override fun execute(command: Runnable) {
+        delegate.execute {
+            try {
+                command.run()
+            } catch (e: Throwable) {
+                onError(e)
+            }
+        }
+    }
+
+    companion object {
+
+        private val defaultThrowableHandler: (Throwable) -> Unit = {
+            Log.e("SafeExecutor", "Exception caught in executor: ${it.message}", it)
+        }
+
+        fun newSingleThreadExecutor(onError: (Throwable) -> Unit = defaultThrowableHandler): SafeExecutor {
+            return SafeExecutor(Executors.newSingleThreadExecutor(), onError)
+        }
+    }
+}

gradle/libs.versions.toml

@@ -1,18 +1,18 @@
 [versions]
 androidLibraryVersion = "8.7.3"
 androidXDocumentFileVersion = "1.0.1"
-androidXExifinterfaceVersion = "1.3.7"
+androidXExifinterfaceVersion = "1.4.0"
 appCompatVersion = "1.7.0"
 cameraCamera2Version = "1.4.1"
-constraintlayoutVersion = "2.2.0"
+constraintlayoutVersion = "2.2.1"
 coreKtxVersion = "1.15.0"
 flexboxVersion = "3.0.0"
 tensorflowLiteSupportVersion = "0.4.4"
 coroutinesVersion = "1.8.0"
-datastorePreferencesVersion = "1.1.1"
-desugarVersion = "2.1.4"
+datastorePreferencesVersion = "1.1.3"
+desugarVersion = "2.1.5"
 espressoCoreVersion = "3.6.1"
-gsonVersion = "2.10.1"
+gsonVersion = "2.12.1"
 junit = "1.2.1"
 junitJupiterApiVersion = "5.11.3"
 junitPlatformRunnerVersion = "1.11.3"
@@ -26,7 +26,7 @@ markwonVersion = "4.6.2"
 mockitoKotlinVersion = "5.1.0"
 preferenceKtxVersion = "1.2.1"
 printVersion = "1.0.0"
-recyclerviewVersion = "1.3.2"
+recyclerviewVersion = "1.4.0"
 solVersion = "10.2.0"
 workRuntimeKtxVersion = "2.10.0"
 zxingVersion = "3.5.2"

signal/src/main/java/com/kylecorry/andromeda/signal/CellSignalSensor.kt

@@ -5,10 +5,17 @@ import android.content.Context
 import android.os.Build
 import android.os.Handler
 import android.os.Looper
-import android.os.SystemClock
-import android.telephony.*
+import android.telephony.CellInfo
+import android.telephony.CellInfoCdma
+import android.telephony.CellInfoGsm
+import android.telephony.CellInfoLte
+import android.telephony.CellInfoNr
+import android.telephony.CellInfoTdscdma
+import android.telephony.CellInfoWcdma
+import android.telephony.TelephonyManager
 import androidx.core.content.getSystemService
 import androidx.core.math.MathUtils
+import com.kylecorry.andromeda.core.coroutines.SafeExecutor
 import com.kylecorry.andromeda.core.sensors.AbstractSensor
 import com.kylecorry.andromeda.core.sensors.Quality
 import com.kylecorry.andromeda.core.time.AndroidTime
@@ -17,7 +24,6 @@ import com.kylecorry.andromeda.core.tryOrNothing
 import com.kylecorry.andromeda.permissions.Permissions
 import java.time.Duration
 import java.time.Instant
-import java.util.concurrent.Executors
 
 class CellSignalSensor(
     private val context: Context,
@@ -59,7 +65,13 @@ class CellSignalSensor(
                 return@tryOrNothing
             }
             telephony?.requestCellInfoUpdate(
-                Executors.newSingleThreadExecutor(),
+                SafeExecutor.newSingleThreadExecutor {
+                    tryOrNothing {
+                        Handler(Looper.getMainLooper()).post {
+                            updateCellInfo(emptyList())
+                        }
+                    }
+                },
                 @SuppressLint("NewApi")
                 object : TelephonyManager.CellInfoCallback() {
                     override fun onCellInfo(cellInfo: MutableList<CellInfo>) {