Add multiplatform connectivity check

androidApp/src/main/java/bou/amine/apps/readerforselfossv2/android/MyApp.kt

@@ -13,6 +13,7 @@ import bou.amine.apps.readerforselfossv2.DI.networkModule
 import bou.amine.apps.readerforselfossv2.android.utils.Config
 import bou.amine.apps.readerforselfossv2.android.utils.glide.loadMaybeBasicAuth
 import bou.amine.apps.readerforselfossv2.repository.Repository
+import bou.amine.apps.readerforselfossv2.utils.NetworkStatus
 import com.bumptech.glide.Glide
 import com.bumptech.glide.request.RequestOptions
 import com.ftinc.scoop.Scoop
@@ -25,7 +26,7 @@ class MyApp : MultiDexApplication(), DIAware {
 
     override val di by DI.lazy {
         import(networkModule)
-        bind<Repository>() with singleton { Repository(instance(), instance()) }
+        bind<Repository>() with singleton { Repository(instance(), instance(), NetworkStatus(applicationContext)) }
     }
 
     private lateinit var config: Config

shared/build.gradle.kts

@@ -36,6 +36,9 @@ kotlin {
 
                 //Logging
                 implementation("io.github.aakira:napier:2.6.1")
+
+                // Network information
+                implementation("com.github.ln-12:multiplatform-connectivity-status:1.1.0")
             }
         }
         val commonTest by getting {

shared/src/androidMain/kotlin/bou/amine/apps/readerforselfossv2/utils/NetworkStatus.kt

@@ -0,0 +1,17 @@
+package bou.amine.apps.readerforselfossv2.utils
+
+import android.content.Context
+import com.github.`ln-12`.library.ConnectivityStatus
+
+actual class NetworkStatus(context: Context) {
+    private val connectivityStatus = ConnectivityStatus(context)
+    actual val current = connectivityStatus.isNetworkConnected
+
+    actual fun start() {
+        connectivityStatus.start()
+    }
+
+    actual fun stop() {
+        connectivityStatus.stop()
+    }
+}

shared/src/commonMain/kotlin/bou/amine/apps/readerforselfossv2/repository/RepositoryImpl.kt

@@ -5,16 +5,18 @@ import bou.amine.apps.readerforselfossv2.rest.SelfossModel
 import bou.amine.apps.readerforselfossv2.service.ApiDetailsService
 import bou.amine.apps.readerforselfossv2.utils.DateUtils
 import bou.amine.apps.readerforselfossv2.utils.ItemType
+import bou.amine.apps.readerforselfossv2.utils.NetworkStatus
 import com.russhwolf.settings.Settings
 import io.github.aakira.napier.Napier
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.launch
 
-class Repository(private val api: SelfossApi, private val apiDetails: ApiDetailsService) {
+class Repository(private val api: SelfossApi, private val apiDetails: ApiDetailsService, networkStatus: NetworkStatus) {
     val settings = Settings()
 
     var items = ArrayList<SelfossModel.Item>()
+    private val isConnectionAvailable = networkStatus.current
 
     var baseUrl = apiDetails.getBaseUrl()
     lateinit var dateUtils: DateUtils
@@ -36,6 +38,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
     set(value) {field = if (value < 0) { 0 } else { value } }
 
     init {
+        networkStatus.start()
         // TODO: Dispatchers.IO not available in KMM, an alternative solution should be found
         CoroutineScope(Dispatchers.Main).launch {
             updateApiVersion()

shared/src/commonMain/kotlin/bou/amine/apps/readerforselfossv2/utils/NetworkStatus.kt

@@ -0,0 +1,9 @@
+package bou.amine.apps.readerforselfossv2.utils
+
+import kotlinx.coroutines.flow.MutableStateFlow
+
+expect class NetworkStatus {
+    val current: MutableStateFlow<Boolean>
+    fun start()
+    fun stop()
+}

shared/src/iosMain/kotlin/bou/amine/apps/readerforselfossv2/utils/NetworkStatus.kt

@@ -0,0 +1,27 @@
+package bou.amine.apps.readerforselfossv2.utils
+
+import com.github.`ln-12`.library.ConnectivityStatus
+import kotlinx.coroutines.MainScope
+import kotlinx.coroutines.flow.MutableStateFlow
+import kotlinx.coroutines.launch
+
+actual class NetworkStatus {
+    private val connectivityStatus: ConnectivityStatus = ConnectivityStatus()
+    actual val current: MutableStateFlow<Boolean> = connectivityStatus.isNetworkConnected
+
+    actual fun start() {
+        connectivityStatus.start()
+    }
+
+    actual fun stop() {
+        connectivityStatus.stop()
+    }
+
+    fun getStatus(success: (Boolean) -> Unit) {
+        MainScope().launch {
+            connectivityStatus.isNetworkConnected.collect { status ->
+                success(status)
+            }
+        }
+    }
+}