Telemetry Metrics

.gitignore

@@ -14,3 +14,4 @@
 .cxx
 local.properties
 .idea
+/core/bin

android/src/androidTest/java/com/segment/analytics/ExampleInstrumentedTest.kt

@@ -2,6 +2,7 @@ package com.segment.analytics
 
 import androidx.test.platform.app.InstrumentationRegistry
 import androidx.test.ext.junit.runners.AndroidJUnit4
+import com.segment.analytics.kotlin.core.Telemetry
 
 import org.junit.Test
 import org.junit.runner.RunWith
@@ -15,6 +16,10 @@ import org.junit.Assert.*
  */
 @RunWith(AndroidJUnit4::class)
 class ExampleInstrumentedTest {
+    init {
+        Telemetry.enable = false
+    }
+
     @Test
     fun useAppContext() {
         // Context of the app under test.

android/src/test/java/com/segment/analytics/kotlin/android/AndroidAnalyticsKtTest.kt

@@ -1,11 +1,16 @@
 package com.segment.analytics.kotlin.android
 
+import com.segment.analytics.kotlin.core.Telemetry
 import org.junit.jupiter.api.Assertions.*
 
 import org.junit.jupiter.api.Test
 import org.junit.jupiter.api.assertThrows
 
 internal class AndroidAnalyticsKtTest {
+    init {
+        Telemetry.enable = false
+    }
+
     @Test
     fun `jvm initializer in android platform should failed`() {
         val exception =  assertThrows<Exception> {

android/src/test/java/com/segment/analytics/kotlin/android/AndroidContextCollectorTests.kt

@@ -31,6 +31,10 @@ class AndroidContextCollectorTests {
     private val testDispatcher = UnconfinedTestDispatcher()
     private val testScope = TestScope(testDispatcher)
 
+    init {
+        Telemetry.enable = false
+    }
+
     @Before
     fun setUp() {
         appContext = spyk(InstrumentationRegistry.getInstrumentation().targetContext)

android/src/test/java/com/segment/analytics/kotlin/android/AndroidLifecyclePluginTests.kt

@@ -41,6 +41,7 @@ class AndroidLifecyclePluginTests {
     private val testScope = TestScope(testDispatcher)
 
     init {
+        Telemetry.enable = false
         val packageInfo = PackageInfo()
         packageInfo.versionCode = 100
         packageInfo.versionName = "1.0.0"

android/src/test/java/com/segment/analytics/kotlin/android/EventsFileTests.kt

@@ -7,6 +7,7 @@ import com.segment.analytics.kotlin.core.emptyJsonObject
 import com.segment.analytics.kotlin.core.utilities.EncodeDefaultsJson
 import com.segment.analytics.kotlin.core.utilities.EventsFileManager
 import com.segment.analytics.kotlin.core.utilities.SegmentInstant
+import com.segment.analytics.kotlin.core.Telemetry
 import io.mockk.every
 import io.mockk.mockkObject
 import kotlinx.coroutines.test.runTest
@@ -32,6 +33,7 @@ class EventsFileTests {
     private val directory = File("/tmp/analytics-android-test/")
 
     init {
+        Telemetry.enable = false
         mockkObject(SegmentInstant)
         every { SegmentInstant.now() } returns Date(0).toInstant().toString()
     }

android/src/test/java/com/segment/analytics/kotlin/android/StorageTests.kt

@@ -9,6 +9,7 @@ import com.segment.analytics.kotlin.core.Configuration
 import com.segment.analytics.kotlin.core.Settings
 import com.segment.analytics.kotlin.core.Storage
 import com.segment.analytics.kotlin.core.System
+import com.segment.analytics.kotlin.core.Telemetry
 import com.segment.analytics.kotlin.core.TrackEvent
 import com.segment.analytics.kotlin.core.UserInfo
 import com.segment.analytics.kotlin.core.emptyJsonObject
@@ -43,6 +44,10 @@ class StorageTests {
         private lateinit var androidStorage: AndroidStorage
         private var mockContext: Context = mockContext()
 
+        init {
+            Telemetry.enable = false
+        }
+
         @BeforeEach
         fun setup() = runTest  {
             clearPersistentStorage()

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

@@ -93,8 +93,10 @@ open class Analytics protected constructor(
         object : CoroutineConfiguration {
             override val store = Store()
             val exceptionHandler = CoroutineExceptionHandler { _, t ->
-                Analytics.segmentLog(
-                    "Caught Exception in Analytics Scope: ${t}"
+                reportErrorWithMetrics(null, t,
+                    "Caught Exception in Analytics Scope", Telemetry.INVOKE_ERROR_METRIC,
+                    mapOf("error" to t.toString(), "message" to "Exception in Analytics Scope"),
+                    t.stackTraceToString()
                 )
             }
             override val analyticsScope = CoroutineScope(SupervisorJob() + exceptionHandler)
@@ -114,6 +116,10 @@ open class Analytics protected constructor(
         add(ContextPlugin())
         add(UserInfoPlugin())
 
+        Telemetry.increment(Telemetry.INVOKE_METRIC,
+            mapOf("message" to "configured", "apihost" to configuration.apiHost, "cdnhost" to configuration.cdnHost,
+                "flush" to "at:${configuration.flushAt} int:${configuration.flushInterval} pol:${configuration.flushPolicies.count()}"))
+
         // Setup store
         analyticsScope.launch(analyticsDispatcher) {
             store.also {
@@ -129,6 +135,8 @@ open class Analytics protected constructor(
                 add(SegmentDestination())
             }
 
+            Telemetry.subscribe(store)
+
             checkSettings()
         }
     }

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

@@ -10,6 +10,14 @@ fun Analytics.reportInternalError(error: Throwable) {
     Analytics.reportInternalError(error)
 }
 
+fun reportErrorWithMetrics(analytics: Analytics?, error: Throwable, message: String, metric:String, tags: Map<String, String>, log: String) {
+    analytics?.configuration?.errorHandler?.invoke(error)
+    var fullMessage = message
+    error.message?.let { fullMessage += ": $it"}
+    Analytics.segmentLog(fullMessage)
+    Telemetry.error(metric, tags, log)
+}
+
 fun Analytics.Companion.reportInternalError(error: Throwable) {
     error.message?.let {
         Analytics.segmentLog(it)

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

@@ -34,7 +34,11 @@ class HTTPClient(
             URL(url)
         } catch (e: MalformedURLException) {
             val error = IOException("Attempted to use malformed url: $url", e)
-            Analytics.reportInternalError(error)
+            reportErrorWithMetrics(null, e,
+                "Attempted to use malformed url: $url", Telemetry.INVOKE_ERROR_METRIC,
+                mapOf("error" to e.toString(), "writekey" to writeKey, "message" to "Malformed url"),
+                e.stackTraceToString()
+            )
             throw error
         }
         val connection = requestedURL.openConnection() as HttpURLConnection
@@ -105,7 +109,7 @@ internal fun HttpURLConnection.createPostConnection(): Connection {
                         inputStream?.close()
                     }
                     throw HTTPException(
-                        responseCode, connection.responseMessage, responseBody
+                        responseCode, connection.responseMessage, responseBody, connection.headerFields
                     )
                 }
             } finally {
@@ -119,7 +123,8 @@ internal fun HttpURLConnection.createPostConnection(): Connection {
 internal class HTTPException(
     val responseCode: Int,
     val responseMessage: String,
-    val responseBody: String?
+    val responseBody: String?,
+    val responseHeaders: MutableMap<String, MutableList<String>>
 ) :
     IOException("HTTP $responseCode: $responseMessage. Response: ${responseBody ?: "No response"}") {
     fun is4xx(): Boolean {

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

@@ -22,6 +22,7 @@ data class Settings(
     var plan: JsonObject = emptyJsonObject,
     var edgeFunction: JsonObject = emptyJsonObject,
     var middlewareSettings: JsonObject = emptyJsonObject,
+    var metrics: JsonObject = emptyJsonObject,
 ) {
     inline fun <reified T : Any> destinationSettings(
         name: String,
@@ -113,10 +114,10 @@ internal fun Analytics.fetchSettings(
     log("Fetched Settings: $settingsString")
     LenientJson.decodeFromString(settingsString)
 } catch (ex: Exception) {
-    reportInternalError(ex)
-    Analytics.segmentLog(
-        "${ex.message}: failed to fetch settings",
-        kind = LogKind.ERROR
+    reportErrorWithMetrics(this, ex, "Failed to fetch settings",
+        Telemetry.INVOKE_ERROR_METRIC,
+        mapOf("error" to ex.toString(), "writekey" to writeKey, "message" to "Error retrieving settings"),
+        ex.stackTraceToString()
     )
     null
 }