Do not change the network override from within the repository

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

@@ -1044,6 +1044,7 @@ class HomeActivity : AppCompatActivity(), SearchView.OnQueryTextListener, DIAwar
                     Toast.makeText(this, R.string.refresh_in_progress, Toast.LENGTH_SHORT).show()
                     // TODO: Use Dispatchers.IO
                     CoroutineScope(Dispatchers.Main).launch {
+                        repository.offlineOverride = false
                         val updatedRemote = repository.updateRemote()
                         if (updatedRemote) {
                             // TODO: Send toast messages from the repository

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

@@ -43,7 +43,7 @@ class LoadingWorker(val context: Context, params: WorkerParameters) : Worker(con
 override fun doWork(): Result {
     val settings = Settings()
     val periodicRefresh = settings.getBoolean("periodic_refresh", false)
-    if (periodicRefresh) {
+    if (periodicRefresh && repository.isNetworkAvailable()) {
 
         CoroutineScope(Dispatchers.IO).launch {
             val notificationManager =

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

@@ -278,84 +278,89 @@ class ArticleFragment : Fragment(), DIAware {
         binding.progressBar.visibility = View.VISIBLE
         val parser = MercuryApi()
 
-        parser.parseUrl(url).enqueue(
+        if (repository.isNetworkAvailable()) {
-            object : Callback<ParsedContent> {
+            parser.parseUrl(url).enqueue(
-                override fun onResponse(
+                object : Callback<ParsedContent> {
-                    call: Call<ParsedContent>,
+                    override fun onResponse(
-                    response: Response<ParsedContent>
+                        call: Call<ParsedContent>,
-                ) {
+                        response: Response<ParsedContent>
-                    // TODO: clean all the following after finding the mercury content issue
+                    ) {
-                    try {
+                        // TODO: clean all the following after finding the mercury content issue
-                        if (response.body() != null && response.body()!!.content != null && !response.body()!!.content.isNullOrEmpty()) {
+                        try {
-                            try {
+                            if (response.body() != null && response.body()!!.content != null && !response.body()!!.content.isNullOrEmpty()) {
-                                binding.titleView.text = response.body()!!.title
-                                if (typeface != null) {
-                                    binding.titleView.typeface = typeface
-                                }
                                 try {
-                                    // Note: Mercury may return relative urls... If it does the url val will not be changed.
+                                    binding.titleView.text = response.body()!!.title
-                                    URL(response.body()!!.url)
+                                    if (typeface != null) {
-                                    url = response.body()!!.url
+                                        binding.titleView.typeface = typeface
-                                } catch (e: MalformedURLException) {
-                                    // Mercury returned a relative url. We do nothing.
-                                }
-                            } catch (e: Exception) {
-                            }
-
-                            try {
-                                contentText = response.body()!!.content.orEmpty()
-                                htmlToWebview()
-                            } catch (e: Exception) {
-                            }
-
-                            try {
-                                if (response.body()!!.lead_image_url != null && !response.body()!!.lead_image_url.isNullOrEmpty() && context != null) {
-                                    binding.imageView.visibility = View.VISIBLE
-                                    try {
-                                        Glide
-                                            .with(requireContext())
-                                            .asBitmap()
-                                            .loadMaybeBasicAuth(config, response.body()!!.lead_image_url.orEmpty())
-                                            .apply(RequestOptions.fitCenterTransform())
-                                            .into(binding.imageView)
-                                    } catch (e: Exception) {
                                     }
-                                } else {
+                                    try {
-                                    binding.imageView.visibility = View.GONE
+                                        // Note: Mercury may return relative urls... If it does the url val will not be changed.
+                                        URL(response.body()!!.url)
+                                        url = response.body()!!.url
+                                    } catch (e: MalformedURLException) {
+                                        // Mercury returned a relative url. We do nothing.
+                                    }
+                                } catch (e: Exception) {
                                 }
-                            } catch (e: Exception) {
-                                if (context != null) {
-                                }
-                            }
 
-                            try {
+                                try {
-                                binding.nestedScrollView.scrollTo(0, 0)
+                                    contentText = response.body()!!.content.orEmpty()
+                                    htmlToWebview()
+                                } catch (e: Exception) {
+                                }
 
-                                binding.progressBar.visibility = View.GONE
+                                try {
-                            } catch (e: Exception) {
+                                    if (response.body()!!.lead_image_url != null && !response.body()!!.lead_image_url.isNullOrEmpty() && context != null) {
-                                if (context != null) {
+                                        binding.imageView.visibility = View.VISIBLE
+                                        try {
+                                            Glide
+                                                .with(requireContext())
+                                                .asBitmap()
+                                                .loadMaybeBasicAuth(
+                                                    config,
+                                                    response.body()!!.lead_image_url.orEmpty()
+                                                )
+                                                .apply(RequestOptions.fitCenterTransform())
+                                                .into(binding.imageView)
+                                        } catch (e: Exception) {
+                                        }
+                                    } else {
+                                        binding.imageView.visibility = View.GONE
+                                    }
+                                } catch (e: Exception) {
+                                    if (context != null) {
+                                    }
+                                }
+
+                                try {
+                                    binding.nestedScrollView.scrollTo(0, 0)
+
+                                    binding.progressBar.visibility = View.GONE
+                                } catch (e: Exception) {
+                                    if (context != null) {
+                                    }
+                                }
+                            } else {
+                                try {
+                                    openInBrowserAfterFailing(customTabsIntent)
+                                } catch (e: Exception) {
+                                    if (context != null) {
+                                    }
                                 }
                             }
-                        } else {
+                        } catch (e: Exception) {
-                            try {
+                            if (context != null) {
-                                openInBrowserAfterFailing(customTabsIntent)
-                            } catch (e: Exception) {
-                                if (context != null) {
-                                }
                             }
                         }
-                    } catch (e: Exception) {
-                        if (context != null) {
-                        }
                     }
-                }
 
-                override fun onFailure(
+                    override fun onFailure(
-                    call: Call<ParsedContent>,
+                        call: Call<ParsedContent>,
-                    t: Throwable
+                        t: Throwable
-                ) = openInBrowserAfterFailing(customTabsIntent)
+                    ) = openInBrowserAfterFailing(customTabsIntent)
-            }
+                }
-        )
+            )
+        }
     }
 
     private fun htmlToWebview() {

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

@@ -63,7 +63,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun getNewerItems(): ArrayList<SelfossModel.Item> {
         // TODO: Use the updatedSince parameter
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             val fetchedItems = api.getItems(
                 displayedItems.type,
                 settings.getString("prefer_api_items_number", "200").toInt(),
@@ -84,7 +84,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
     }
 
     suspend fun getOlderItems(): ArrayList<SelfossModel.Item> {
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             val offset = items.size
             val fetchedItems = api.getItems(
                 displayedItems.type,
@@ -106,7 +106,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
     }
 
     suspend fun allItems(itemType: ItemType): List<SelfossModel.Item>? {
-        return if (isConnectionAvailable.value && !offlineOverride) {
+        return if (isNetworkAvailable()) {
             api.getItems(
                 itemType.type,
                 200,
@@ -137,7 +137,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun reloadBadges(): Boolean {
         var success = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             val response = api.stats()
             if (response != null) {
                 badgeUnread = response.unread
@@ -153,7 +153,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun getTags(): List<SelfossModel.Tag>? {
         // TODO: Store in DB
-        return if (isConnectionAvailable.value && !offlineOverride) {
+        return if (isNetworkAvailable()) {
             api.tags()
         } else {
             // TODO: Compute from database
@@ -163,7 +163,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun getSpouts(): Map<String, SelfossModel.Spout>? {
         // TODO: Store in DB
-        return if (isConnectionAvailable.value && !offlineOverride) {
+        return if (isNetworkAvailable()) {
             api.spouts()
         } else {
             // TODO: Compute from database
@@ -173,7 +173,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun getSources(): ArrayList<SelfossModel.Source>? {
         // TODO: Store in DB
-        return if (isConnectionAvailable.value && !offlineOverride) {
+        return if (isNetworkAvailable()) {
             api.sources()
         } else {
             // TODO: Compute from database
@@ -192,7 +192,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun markAsReadById(id: Int): Boolean {
         var success = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             success = api.markAsRead(id.toString())?.isSuccess == true
         }
         return success
@@ -209,7 +209,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun unmarkAsReadById(id: Int): Boolean {
         var success = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             success = api.unmarkAsRead(id.toString())?.isSuccess == true
         }
         return success
@@ -226,7 +226,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun starrById(id: Int): Boolean {
         var success = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             success = api.starr(id.toString())?.isSuccess == true
         }
         return success
@@ -243,7 +243,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun unstarrById(id: Int): Boolean {
         var success = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             success = api.unstarr(id.toString())?.isSuccess == true
         }
         return success
@@ -252,7 +252,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun markAllAsRead(items: ArrayList<SelfossModel.Item>): Boolean {
         var success = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             success = api.markAllAsRead(items.map { it.id.toString() })?.isSuccess == true
         }
 
@@ -304,7 +304,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
         filter: String
     ): Boolean {
         var response = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             response = api.createSourceForVersion(
                 title,
                 url,
@@ -321,7 +321,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
     suspend fun deleteSource(id: Int): Boolean {
         // TODO: Store in DB
         var success = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             val response = api.deleteSource(id)
             if (response != null) {
                 success = response.isSuccess
@@ -333,7 +333,6 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun updateRemote(): Boolean {
         var response = false
-        offlineOverride = false
         if (isConnectionAvailable.value) {
             response = api.update()?.isSuccess == true
         }
@@ -342,7 +341,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
 
     suspend fun login(): Boolean {
         var result = false
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             try {
                 val response = api.login()
                 result = response?.isSuccess == true
@@ -369,7 +368,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
     private suspend fun updateApiVersion() {
         apiMajorVersion = settings.getInt("apiVersionMajor", 0)
 
-        if (isConnectionAvailable.value && !offlineOverride) {
+        if (isNetworkAvailable()) {
             val fetchedVersion = api.version()
             if (fetchedVersion != null) {
                 apiMajorVersion = fetchedVersion.getApiMajorVersion()
@@ -378,5 +377,7 @@ class Repository(private val api: SelfossApi, private val apiDetails: ApiDetails
         }
     }
 
+    fun isNetworkAvailable() = isConnectionAvailable.value && !offlineOverride
+
     // TODO: Handle offline actions
 }