for wenxi

Author: prayansh

build.gradle

@@ -27,8 +27,6 @@ allprojects {
     repositories {
         google()
         mavenCentral()
-        maven { url "https://kotlin.bintray.com/kotlinx" }
-        maven { url 'https://dl.bintray.com/kotlin/kotlin-eap' }
     }
     tasks.withType(org.jetbrains.kotlin.gradle.tasks.KotlinCompile).all {
         kotlinOptions {

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

@@ -6,8 +6,13 @@ import com.segment.analytics.kotlin.core.platform.Timeline
 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 kotlinx.coroutines.*
-import com.segment.analytics.kotlin.core.platform.plugins.logger.*
+import com.segment.analytics.kotlin.core.platform.plugins.logger.SegmentLog
+import com.segment.analytics.kotlin.core.platform.plugins.logger.log
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.asCoroutineDispatcher
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.runBlocking
 import kotlinx.serialization.DeserializationStrategy
 import kotlinx.serialization.SerializationStrategy
 import kotlinx.serialization.json.Json
@@ -76,7 +81,7 @@ open class Analytics protected constructor(
     constructor(configuration: Configuration): this(configuration, object : CoroutineConfiguration{
         override val store = Store()
         override val analyticsScope = CoroutineScope(SupervisorJob())
-        override val analyticsDispatcher = Executors.newCachedThreadPool().asCoroutineDispatcher()
+        override val analyticsDispatcher = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
         override val networkIODispatcher = Executors.newSingleThreadExecutor().asCoroutineDispatcher()
         override val fileIODispatcher = Executors.newFixedThreadPool(2).asCoroutineDispatcher()
     })
@@ -378,7 +383,7 @@ open class Analytics protected constructor(
     fun process(event: BaseEvent) {
         event.applyBaseData()
 
-        log("applying base attributes on ${Thread.currentThread().name}")
+//        log("applying base attributes on ${Thread.currentThread().name}")
         analyticsScope.launch(analyticsDispatcher) {
             event.applyBaseEventData(store)
             log("processing event on ${Thread.currentThread().name}")

samples/kotlin-android-app-destinations/src/main/java/com/segment/analytics/kotlin/destinations/MainApplication.kt

@@ -1,14 +1,10 @@
 package com.segment.analytics.kotlin.destinations
 
 import android.app.Application
-import com.segment.analytics.kotlin.destinations.plugins.*
+import com.segment.analytics.destinations.plugins.EdgeFunction
 import com.segment.analytics.kotlin.android.Analytics
 import com.segment.analytics.kotlin.core.Analytics
-import com.segment.analytics.kotlin.core.platform.plugins.logger.*
-import com.segment.analytics.kotlin.destinations.amplitude.AmplitudeSession
-import com.segment.analytics.kotlin.destinations.appsflyer.AppsFlyerDestination
-import com.segment.analytics.kotlin.destinations.firebase.FirebaseDestination
-import com.segment.analytics.kotlin.destinations.mixpanel.MixpanelDestination
+import com.segment.analytics.kotlin.destinations.plugins.WebhookPlugin
 import java.util.concurrent.Executors
 
 class MainApplication : Application() {
@@ -19,16 +15,14 @@ class MainApplication : Application() {
     override fun onCreate() {
         super.onCreate()
 
-        analytics = Analytics(BuildConfig.SEGMENT_WRITE_KEY, applicationContext) {
+        analytics = Analytics("8lScBxzFnESRxYxeNZyniANYovjrHBtP", applicationContext) {
             this.collectDeviceId = true
             this.trackApplicationLifecycleEvents = true
             this.trackDeepLinks = true
             this.flushAt = 1
             this.flushInterval = 0
         }
 
-        analytics.add(MixpanelDestination(applicationContext))
-
         // A random webhook url to view your events
         analytics.add(
             WebhookPlugin(
@@ -37,37 +31,7 @@ class MainApplication : Application() {
             )
         )
 
-        // Try out amplitude session
-        analytics.add(AmplitudeSession())
-
-        // Try out Firebase Destination
-        analytics.add(FirebaseDestination(applicationContext))
-
-        // Try out Intercom destination
-        analytics.add(IntercomDestination(this))
-
-        val appsflyerDestination = AppsFlyerDestination(applicationContext, true)
-        analytics.add(appsflyerDestination)
-
-        appsflyerDestination.conversionListener =
-            object : AppsFlyerDestination.ExternalAppsFlyerConversionListener {
-                override fun onConversionDataSuccess(map: Map<String, Any>) {
-                    // Process Deferred Deep Linking here
-                    for (attrName in map.keys) {
-                        analytics.log("Appsflyer: attribute: " + attrName + " = " + map[attrName])
-                    }
-                }
-
-                override fun onConversionDataFail(s: String?) {}
-                override fun onAppOpenAttribution(map: Map<String, String>) {
-                    // Process Direct Deep Linking here
-                    for (attrName in map.keys) {
-                        analytics.log("Appsflyer: attribute: " + attrName + " = " + map[attrName])
-                    }
-                }
-
-                override fun onAttributionFailure(s: String?) {}
-            }
+        analytics.add(EdgeFunction())
 
     }
 }