init changes

Author: prayansh

samples/kotlin-android-app-destinations/build.gradle

@@ -58,6 +58,8 @@ dependencies {
     implementation 'com.segment.analytics.kotlin.destinations:appsflyer:1.5.1'
     implementation 'com.segment.analytics.kotlin.destinations:firebase:1.5.2'
     implementation 'com.segment.analytics.kotlin.destinations:mixpanel:1.5.2'
+
+    implementation 'com.eclipsesource.j2v8:j2v8:6.2.0@aar'
 }
 
 // Partner Dependencies

samples/kotlin-android-app-destinations/src/androidTest/java/com/segment/analytics/destinations/plugins/Benchmark.kt

@@ -0,0 +1,89 @@
+package com.segment.analytics.destinations.plugins
+
+import androidx.test.ext.junit.runners.AndroidJUnit4
+import com.segment.analytics.kotlin.core.BaseEvent
+import com.segment.analytics.kotlin.core.TrackEvent
+import kotlinx.serialization.json.buildJsonObject
+import kotlinx.serialization.json.put
+import kotlin.system.measureTimeMillis
+import com.eclipsesource.v8.V8
+import org.junit.Assert.assertNotNull
+import org.junit.Assert.assertNull
+import org.junit.Test
+import org.junit.runner.RunWith
+
+
+@RunWith(AndroidJUnit4::class)
+class Benchmark {
+    val e1 = TrackEvent(
+        event = "App Opened",
+        properties = buildJsonObject { put("new", true); put("click", true) })
+    val e2 = TrackEvent(
+        event = "Screen Opened",
+        properties = buildJsonObject { put("new", false); put("click", false) })
+    val e3 = TrackEvent(
+        event = "App Closed",
+        properties = buildJsonObject { put("new", false); put("click", true) })
+
+    @Test
+    fun usingExpressions() {
+        val plugin = DestinationFiltersDropPlugin().apply {
+            matchers.add(MatcherExpressionImpl())
+        }
+        val matcherTime = measureTimeMillis {
+            assertNotNull(plugin.execute(e1))
+            assertNull(plugin.execute(e2))
+            assertNotNull(plugin.execute(e3))
+        }
+        println(matcherTime)
+    }
+
+    @Test
+    fun usingJsRuntime() {
+        val plugin = DestinationFiltersDropPlugin().apply {
+            matchers.add(MatcherJSImpl())
+        }
+        val matcherTime = measureTimeMillis {
+            assertNotNull(plugin.execute(e1))
+            assertNull(plugin.execute(e2))
+            assertNotNull(plugin.execute(e3))
+        }
+        println(matcherTime)
+    }
+}
+
+/*
+    {
+      "ir": "["!",["or",["=","event",{"value":"App Opened"}],["=","event",{"value":"App Closed"}]]]",
+      "type": "fql",
+      "config": {
+        "expr": "!(event = \"CP VOD - Start video\" or event = \"CP VOD - Track video\")"
+      }
+    }
+     */
+class MatcherExpressionImpl : Matcher {
+    override fun match(payload: BaseEvent): Boolean {
+        payload as TrackEvent
+        return Not(
+            Or(
+                Equals(Path("event"), "App Opened"),
+                Equals(Path("event"), "App Closed")
+            )
+        ).evaluate(payload)
+    }
+}
+
+class MatcherJSImpl : Matcher {
+
+    val runtime = V8.createV8Runtime()
+    override fun match(payload: BaseEvent): Boolean {
+        payload as TrackEvent
+        val result = runtime.executeBooleanScript(
+            """
+              !("${payload.event}" === "App Opened" || "${payload.event}" === "App Closed")
+              """.trimIndent()
+        )
+//        runtime.close()
+        return result
+    }
+}

samples/kotlin-android-app-destinations/src/androidTest/java/com/segment/analytics/next/ExampleInstrumentedTest.kt

@@ -0,0 +1,95 @@
+package com.segment.analytics.destinations.plugins
+
+import com.segment.analytics.kotlin.core.Analytics
+import com.segment.analytics.kotlin.core.BaseEvent
+import com.segment.analytics.kotlin.core.platform.Plugin
+
+/*
+{
+  "matchers": [
+    {
+      "ir": "[\"!\",[\"or\",[\"=\",\"event\",{\"value\":\"CP VOD - Start video\"}],[\"=\",\"event\",{\"value\":\"CP VOD - Track video\"}]]]",
+      "type": "fql",
+      "config": {
+        "expr": "!(event = \"CP VOD - Start video\" or event = \"CP VOD - Track video\")"
+      }
+    }
+  ],
+  "scope": "destinations",
+  "target_type": "workspace::project::destination::config",
+  "transformers": [
+    [
+      {
+        "type": "drop"
+      }
+    ]
+  ],
+  "destinationName": "Amazon Kinesis"
+}
+ */
+
+class DestinationFiltersDropPlugin : Plugin {
+    override val type: Plugin.Type = Plugin.Type.Enrichment
+    override lateinit var analytics: Analytics
+
+    val matchers = mutableListOf<Matcher>()
+
+    // Implement only drop event
+    override fun execute(event: BaseEvent): BaseEvent? {
+        for (matcher in matchers) {
+            if (matcher.match(event)) {
+                return null
+            }
+        }
+        return super.execute(event)
+    }
+}
+
+interface Matcher {
+    /*
+    {
+      "ir": "["!",["or",["=","event",{"value":"CP VOD - Start video"}],["=","event",{"value":"CP VOD - Track video"}]]]",
+      "type": "fql",
+      "config": {
+        "expr": "!(event = \"CP VOD - Start video\" or event = \"CP VOD - Track video\")"
+      }
+    }
+     */
+    fun match(payload: BaseEvent): Boolean
+}
+
+interface Expression {
+    fun evaluate(event: BaseEvent): Boolean
+}
+
+class Not(private val e: Expression) : Expression {
+    override fun evaluate(event: BaseEvent): Boolean {
+        return !e.evaluate(event)
+    }
+}
+
+class Or(private val e1: Expression, private val e2: Expression) : Expression {
+    override fun evaluate(event: BaseEvent): Boolean {
+        return e1.evaluate(event) || e2.evaluate(event)
+    }
+}
+
+class And(private val e1: Expression, private val e2: Expression) : Expression {
+    override fun evaluate(event: BaseEvent): Boolean {
+        return e1.evaluate(event) && e2.evaluate(event)
+    }
+}
+
+class Equals(private val t1: Any, private val t2: Any): Expression {
+    override fun evaluate(event: BaseEvent): Boolean {
+        return t1 == t2
+    }
+}
+
+class Path(private val path: String): Expression {
+    override fun evaluate(event: BaseEvent): Boolean {
+        return
+    }
+}
+
+// Not(Or(Equals(payload.event, "CP VOD - Start video"), Equals(payload.event, "CP VOD - Track video")))