Telemetry Metrics

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

@@ -81,6 +81,9 @@ open class Analytics protected constructor(
 
     init {
         require(configuration.isValid()) { "invalid configuration" }
+        Telemetry.increment(Telemetry.INVOKE,
+            mapOf("message" to "configured", "apihost" to configuration.apiHost, "cdnhost" to configuration.cdnHost,
+                "flush" to "at:${configuration.flushAt} int:${configuration.flushInterval} pol:${configuration.flushPolicies.count()}"))
         build()
     }
 
@@ -96,6 +99,10 @@ open class Analytics protected constructor(
                 Analytics.segmentLog(
                     "Caught Exception in Analytics Scope: ${t}"
                 )
+                Telemetry.error(Telemetry.INVOKE_ERROR,
+                    mapOf("error" to t.toString(), "message" to "Exception in Analytics Scope"),
+                    t.stackTraceToString()
+                )
             }
             override val analyticsScope = CoroutineScope(SupervisorJob() + exceptionHandler)
             override val analyticsDispatcher: CloseableCoroutineDispatcher =

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

@@ -35,6 +35,10 @@ class HTTPClient(
         } catch (e: MalformedURLException) {
             val error = IOException("Attempted to use malformed url: $url", e)
             Analytics.reportInternalError(error)
+            Telemetry.error(Telemetry.INVOKE_ERROR,
+                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

@@ -13,6 +13,8 @@ import kotlinx.serialization.DeserializationStrategy
 import kotlinx.serialization.Serializable
 import kotlinx.serialization.json.Json
 import kotlinx.serialization.json.JsonObject
+import kotlinx.serialization.json.double
+import kotlinx.serialization.json.jsonPrimitive
 import kotlinx.serialization.serializer
 import java.io.BufferedReader
 
@@ -22,6 +24,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,
@@ -97,6 +100,13 @@ suspend fun Analytics.checkSettings() {
                 update(settingsObj)
             }
 
+            settingsObj?.metrics?.get("sampleRate")?.jsonPrimitive?.double.also {
+                if (it != null) {
+                    Telemetry.sampleRate = it
+                    Telemetry.start()
+                }
+            }
+
             // we're good to go back to a running state.
             store.dispatch(System.ToggleRunningAction(running = true), System::class)
         }
@@ -118,5 +128,9 @@ internal fun Analytics.fetchSettings(
         "${ex.message}: failed to fetch settings",
         kind = LogKind.ERROR
     )
+    Telemetry.error(Telemetry.INVOKE_ERROR,
+        mapOf("error" to ex.toString(), "writekey" to writeKey, "message" to "Error retrieving settings"),
+        ex.stackTraceToString()
+    )
     null
 }