Unified search: show error when there's no connection

Signed-off-by: Álvaro Brey Vilas <alvaro.brey@nextcloud.com>

src/main/java/com/owncloud/android/ui/unifiedsearch/UnifiedSearchViewModel.kt

@@ -29,6 +29,7 @@ import androidx.lifecycle.MutableLiveData
 import com.nextcloud.client.account.CurrentAccountProvider
 import com.nextcloud.client.core.AsyncRunner
 import com.nextcloud.client.network.ClientFactory
+import com.nextcloud.client.network.ConnectivityService
 import com.owncloud.android.R
 import com.owncloud.android.datamodel.FileDataStorageManager
 import com.owncloud.android.datamodel.OCFile
@@ -64,10 +65,11 @@ class UnifiedSearchViewModel(application: Application) : AndroidViewModel(applic
         }
     }
 
-    lateinit var currentAccountProvider: CurrentAccountProvider
-    lateinit var runner: AsyncRunner
-    lateinit var clientFactory: ClientFactory
-    lateinit var resources: Resources
+    private lateinit var currentAccountProvider: CurrentAccountProvider
+    private lateinit var runner: AsyncRunner
+    private lateinit var clientFactory: ClientFactory
+    private lateinit var resources: Resources
+    private lateinit var connectivityService: ConnectivityService
 
     private val context: Context
         get() = getApplication<Application>().applicationContext
@@ -90,11 +92,13 @@ class UnifiedSearchViewModel(application: Application) : AndroidViewModel(applic
         runner: AsyncRunner,
         clientFactory: ClientFactory,
         resources: Resources,
+        connectivityService: ConnectivityService
     ) : this(application) {
         this.currentAccountProvider = currentAccountProvider
         this.runner = runner
         this.clientFactory = clientFactory
         this.resources = resources
+        this.connectivityService = connectivityService
 
         repository = UnifiedSearchRemoteRepository(
             clientFactory,
@@ -115,31 +119,47 @@ class UnifiedSearchViewModel(application: Application) : AndroidViewModel(applic
      * Clears data and queries all available providers
      */
     override fun initialQuery() {
-        results = mutableMapOf()
-        searchResults.value = mutableListOf()
-        val queryTerm = query.value.orEmpty()
+        doWithConnectivityCheck {
+            results = mutableMapOf()
+            searchResults.value = mutableListOf()
+            val queryTerm = query.value.orEmpty()
 
-        if (isLoading.value != true && queryTerm.isNotBlank()) {
-            isLoading.value = true
-            repository.queryAll(queryTerm, this::onSearchResult, this::onError, this::onSearchFinished)
+            if (isLoading.value != true && queryTerm.isNotBlank()) {
+                isLoading.value = true
+                repository.queryAll(queryTerm, this::onSearchResult, this::onError, this::onSearchFinished)
+            }
         }
     }
 
     override fun loadMore(provider: ProviderID) {
-        val queryTerm = query.value.orEmpty()
+        doWithConnectivityCheck {
+            val queryTerm = query.value.orEmpty()
 
-        if (isLoading.value != true && queryTerm.isNotBlank()) {
-            results[provider]?.nextCursor()?.let { cursor ->
-                isLoading.value = true
-                repository.queryProvider(
-                    queryTerm,
-                    provider,
-                    cursor,
-                    this::onSearchResult,
-                    this::onError,
-                    this::onSearchFinished
-                )
+            if (isLoading.value != true && queryTerm.isNotBlank()) {
+                results[provider]?.nextCursor()?.let { cursor ->
+                    isLoading.value = true
+                    repository.queryProvider(
+                        queryTerm,
+                        provider,
+                        cursor,
+                        this::onSearchResult,
+                        this::onError,
+                        this::onSearchFinished
+                    )
+                }
+            }
+        }
+    }
+
+    private fun doWithConnectivityCheck(block: () -> Unit) {
+        when (connectivityService.connectivity.isConnected) {
+            false -> {
+                error.value = resources.getString(R.string.offline_mode)
+                if (isLoading.value == true) {
+                    isLoading.value = false
+                }
             }
+            else -> block()
         }
     }
 
@@ -213,7 +233,7 @@ class UnifiedSearchViewModel(application: Application) : AndroidViewModel(applic
             }
     }
 
-    fun onSearchFinished(success: Boolean) {
+    private fun onSearchFinished(success: Boolean) {
         Log_OC.d(TAG, "onSearchFinished: success: $success")
         isLoading.value = false
         if (!success) {