Handle IOExceptions went fetching remote settings

Author: mrober

firebase-sessions/src/main/kotlin/com/google/firebase/sessions/settings/RemoteSettings.kt

@@ -35,11 +35,11 @@ import org.json.JSONException
 import org.json.JSONObject
 
 internal class RemoteSettings(
-  val context: Context,
-  val blockingDispatcher: CoroutineContext,
-  val backgroundDispatcher: CoroutineContext,
-  val firebaseInstallationsApi: FirebaseInstallationsApi,
-  val appInfo: ApplicationInfo,
+  context: Context,
+  private val blockingDispatcher: CoroutineContext,
+  private val backgroundDispatcher: CoroutineContext,
+  private val firebaseInstallationsApi: FirebaseInstallationsApi,
+  private val appInfo: ApplicationInfo,
   private val configsFetcher: CrashlyticsSettingsFetcher = RemoteSettingsFetcher(appInfo),
   dataStoreName: String = SESSION_CONFIGS_NAME
 ) : SettingsProvider {
@@ -80,7 +80,7 @@ internal class RemoteSettings(
     scope.launch { settingsCache.removeConfigs() }
   }
 
-  suspend private fun fetchConfigs() {
+  private suspend fun fetchConfigs() {
     // Check if a fetch is in progress. If yes, return
     if (fetchInProgress.get()) {
       return
@@ -94,7 +94,7 @@ internal class RemoteSettings(
     fetchInProgress.set(true)
 
     // Get the installations ID before making a remote config fetch
-    var installationId = firebaseInstallationsApi.id.await()
+    val installationId = firebaseInstallationsApi.id.await()
     if (installationId == null) {
       fetchInProgress.set(false)
       return
@@ -141,7 +141,6 @@ internal class RemoteSettings(
           }
         }
 
-        val scope = CoroutineScope(backgroundDispatcher)
         sessionsEnabled?.let { settingsCache.updateSettingsEnabled(sessionsEnabled) }
 
         sessionTimeoutSeconds?.let {
@@ -156,9 +155,9 @@ internal class RemoteSettings(
         settingsCache.updateSessionCacheUpdatedTime(System.currentTimeMillis())
         fetchInProgress.set(false)
       },
-      onFailure = {
+      onFailure = { msg ->
         // Network request failed here.
-        Log.e(TAG, "Error failing to fetch the remote configs")
+        Log.e(TAG, "Error failing to fetch the remote configs: $msg")
         fetchInProgress.set(false)
       }
     )

firebase-sessions/src/main/kotlin/com/google/firebase/sessions/settings/RemoteSettingsFetcher.kt

@@ -19,6 +19,7 @@ package com.google.firebase.sessions.settings
 import android.net.Uri
 import com.google.firebase.sessions.ApplicationInfo
 import java.io.BufferedReader
+import java.io.IOException
 import java.io.InputStreamReader
 import java.net.URL
 import javax.net.ssl.HttpsURLConnection
@@ -27,43 +28,48 @@ import org.json.JSONObject
 internal interface CrashlyticsSettingsFetcher {
   suspend fun doConfigFetch(
     headerOptions: Map<String, String>,
-    onSuccess: suspend ((JSONObject)) -> Unit,
-    onFailure: suspend () -> Unit
+    onSuccess: suspend (JSONObject) -> Unit,
+    onFailure: suspend (msg: String) -> Unit
   )
 }
 
-internal class RemoteSettingsFetcher(val appInfo: ApplicationInfo) : CrashlyticsSettingsFetcher {
+internal class RemoteSettingsFetcher(private val appInfo: ApplicationInfo) :
+  CrashlyticsSettingsFetcher {
   override suspend fun doConfigFetch(
     headerOptions: Map<String, String>,
-    onSuccess: suspend ((JSONObject)) -> Unit,
-    onFailure: suspend () -> Unit
+    onSuccess: suspend (JSONObject) -> Unit,
+    onFailure: suspend (String) -> Unit
   ) {
     val connection = settingsUrl().openConnection() as HttpsURLConnection
     connection.requestMethod = "GET"
     connection.setRequestProperty("Accept", "application/json")
     headerOptions.forEach { connection.setRequestProperty(it.key, it.value) }
 
-    val responseCode = connection.responseCode
-    if (responseCode == HttpsURLConnection.HTTP_OK) {
-      val inputStream = connection.inputStream
-      val bufferedReader = BufferedReader(InputStreamReader(inputStream))
-      val response = StringBuilder()
-      var inputLine: String?
-      while (bufferedReader.readLine().also { inputLine = it } != null) {
-        response.append(inputLine)
-      }
-      bufferedReader.close()
-      inputStream.close()
+    try {
+      val responseCode = connection.responseCode
+      if (responseCode == HttpsURLConnection.HTTP_OK) {
+        val inputStream = connection.inputStream
+        val bufferedReader = BufferedReader(InputStreamReader(inputStream))
+        val response = StringBuilder()
+        var inputLine: String?
+        while (bufferedReader.readLine().also { inputLine = it } != null) {
+          response.append(inputLine)
+        }
+        bufferedReader.close()
+        inputStream.close()
 
-      val responseJson = JSONObject(response.toString())
-      onSuccess(responseJson)
-    } else {
-      onFailure()
+        val responseJson = JSONObject(response.toString())
+        onSuccess(responseJson)
+      } else {
+        onFailure("Bad response code: $responseCode")
+      }
+    } catch (ex: IOException) {
+      onFailure(ex.message ?: ex.toString())
     }
   }
 
-  fun settingsUrl(): URL {
-    var uri =
+  private fun settingsUrl(): URL {
+    val uri =
       Uri.Builder()
         .scheme("https")
         .authority(FIREBASE_SESSIONS_BASE_URL_STRING)

firebase-sessions/src/test/kotlin/com/google/firebase/sessions/testing/FakeRemoteConfigFetcher.kt

@@ -24,7 +24,7 @@ internal class FakeRemoteConfigFetcher(var responseJSONObject: JSONObject = JSON
   override suspend fun doConfigFetch(
     headerOptions: Map<String, String>,
     onSuccess: suspend (JSONObject) -> Unit,
-    onFailure: suspend () -> Unit
+    onFailure: suspend (String) -> Unit
   ) {
     onSuccess(responseJSONObject)
   }