Add CoroutineExceptionHandler and try/catch blocks over critical area… (#146)

* Add CoroutineExceptionHandler and try/catch blocks over critical areas. Also moved AndroidLogger setup to earlier time to handle early crashes.

* Move try/catch to timeline.add() instead of build.

Author: didiergarcia

android/src/main/java/com/segment/analytics/kotlin/android/AndroidAnalytics.kt

@@ -50,6 +50,7 @@ public fun Analytics(
     context: Context,
     configs: Configuration.() -> Unit
 ): Analytics {
+    Analytics.setLogger(AndroidLogger())
     require(writeKey.isNotBlank()) { "writeKey cannot be blank " }
     val conf = Configuration(
         writeKey = writeKey,
@@ -66,7 +67,6 @@ public fun Analytics(
 private fun Analytics.startup() {
     add(AndroidContextPlugin())
     add(AndroidLifecyclePlugin())
-    Analytics.setLogger(AndroidLogger())
 }
 
 /**

core/src/main/java/com/segment/analytics/kotlin/core/Analytics.kt

@@ -8,9 +8,7 @@ import com.segment.analytics.kotlin.core.platform.plugins.ContextPlugin
 import com.segment.analytics.kotlin.core.platform.plugins.SegmentDestination
 import com.segment.analytics.kotlin.core.platform.plugins.StartupQueue
 import com.segment.analytics.kotlin.core.platform.plugins.UserInfoPlugin
-import com.segment.analytics.kotlin.core.platform.plugins.logger.ConsoleLogger
-import com.segment.analytics.kotlin.core.platform.plugins.logger.Logger
-import com.segment.analytics.kotlin.core.platform.plugins.logger.log
+import com.segment.analytics.kotlin.core.platform.plugins.logger.*
 import kotlinx.coroutines.*
 import kotlinx.serialization.DeserializationStrategy
 import kotlinx.serialization.SerializationStrategy
@@ -87,7 +85,12 @@ open class Analytics protected constructor(
     constructor(configuration: Configuration) : this(configuration,
         object : CoroutineConfiguration {
             override val store = Store()
-            override val analyticsScope = CoroutineScope(SupervisorJob())
+            val exceptionHandler = CoroutineExceptionHandler { _, t ->
+                Analytics.segmentLog(
+                    "Caught Exception in Analytics Scope: ${t}"
+                )
+            }
+            override val analyticsScope = CoroutineScope(SupervisorJob() + exceptionHandler)
             override val analyticsDispatcher : CloseableCoroutineDispatcher =
                 Executors.newCachedThreadPool().asCoroutineDispatcher()
             override val networkIODispatcher : CloseableCoroutineDispatcher =

core/src/main/java/com/segment/analytics/kotlin/core/platform/Mediator.kt

@@ -51,7 +51,11 @@ internal class Mediator(internal var plugins: CopyOnWriteArrayList<Plugin> = Cop
 
     fun applyClosure(closure: (Plugin) -> Unit) {
         plugins.forEach {
-            closure(it)
+            try {
+                closure(it)
+            } catch (t: Throwable) {
+                Analytics.segmentLog("Caught Exception applying closure to plugin: $it: $t")
+            }
         }
     }
 

core/src/main/java/com/segment/analytics/kotlin/core/platform/Timeline.kt

@@ -3,6 +3,7 @@ package com.segment.analytics.kotlin.core.platform
 import com.segment.analytics.kotlin.core.Analytics
 import com.segment.analytics.kotlin.core.BaseEvent
 import com.segment.analytics.kotlin.core.System
+import com.segment.analytics.kotlin.core.platform.plugins.logger.segmentLog
 import kotlinx.coroutines.launch
 import java.util.concurrent.CopyOnWriteArrayList
 import kotlin.reflect.KClass
@@ -60,7 +61,11 @@ internal class Timeline {
 
     // Register a new plugin
     fun add(plugin: Plugin) {
-        plugin.setup(analytics)
+        try {
+            plugin.setup(analytics)
+        } catch (t: Throwable) {
+            Analytics.segmentLog("Caught Exception while setting up plugin $plugin: $t")
+        }
         plugins[plugin.type]?.add(plugin)
         with(analytics) {
             analyticsScope.launch(analyticsDispatcher) {

core/src/test/kotlin/com/segment/analytics/kotlin/core/PluginTests.kt

@@ -12,6 +12,7 @@ import kotlinx.serialization.json.put
 import org.junit.jupiter.api.Assertions
 import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.TestInstance
+import org.junit.jupiter.api.assertDoesNotThrow
 import java.util.*
 
 @TestInstance(TestInstance.Lifecycle.PER_CLASS)
@@ -59,4 +60,22 @@ class PluginTests {
         Assertions.assertEquals(trackEvent, result)
         verify(exactly = 1) { plugin.execute(trackEvent) }
     }
+
+    @Test
+    fun `throwing exception in setup() is handled in timeline`() {
+        val plugin = object : Plugin {
+            override val type: Plugin.Type = Plugin.Type.Before
+            override lateinit var analytics: Analytics
+            override fun setup(analytics: Analytics) {
+                super.setup(analytics)
+                throw Exception("Boom!")
+            }
+        }
+        val spy = spyk(plugin)
+        assertDoesNotThrow {
+            timeline.add(spy)
+        }
+        verify(exactly = 1) { spy.setup(mockAnalytics) }
+        Assertions.assertTrue(spy.analytics === mockAnalytics)
+    }
 }