Add trapper to telemetry

Author: jhh

build.gradle

@@ -12,7 +12,7 @@ buildscript {
 
 configure(subprojects) {
     group = 'org.strykeforce.thirdcoast'
-    version = '19.0.1'
+    version = '19.1.0'
 
     apply plugin: 'java-library'
     apply plugin: 'idea'
@@ -39,6 +39,8 @@ configure(subprojects) {
         module {
             downloadJavadoc = true
             downloadSources = true
+            sourceDirs += files('build/generated/source/kaptKotlin/main')
+            generatedSourceDirs += files('build/generated/source/kaptKotlin/main')
         }
     }
 

telemetry/build.gradle

@@ -15,6 +15,7 @@ buildscript {
 }
 
 apply plugin: "kotlin"
+apply plugin: "kotlin-kapt"
 apply plugin: 'org.jetbrains.dokka'
 
 sourceCompatibility = 11
@@ -28,8 +29,10 @@ dependencies {
     compile "org.jetbrains.kotlin:kotlin-stdlib-jdk8:$kotlin_version"
 
     // telemetry
-    implementation 'org.eclipse.jetty:jetty-server:9.4.12.v20180830'
-    implementation 'com.squareup.moshi:moshi:1.5.0'
+    implementation "org.eclipse.jetty:jetty-server:9.4.12.v20180830"
+    implementation "com.squareup.moshi:moshi:1.8.0"
+    kapt "com.squareup.moshi:moshi-kotlin-codegen:1.8.0"
+    implementation "com.squareup.okhttp3:okhttp:3.12.0"
     implementation project(':swerve')
 
     // Logging

telemetry/src/main/kotlin/org/strykeforce/thirdcoast/trapper/Action.kt

@@ -0,0 +1,17 @@
+package org.strykeforce.thirdcoast.trapper
+
+import com.squareup.moshi.JsonClass
+import java.time.LocalDateTime
+
+internal fun actionDefaultName() = "Action ${LocalDateTime.now()}"
+
+@JsonClass(generateAdapter = true)
+data class Action(
+    val activity: Activity? = null,
+    val name: String = actionDefaultName(),
+    val meta: MutableMap<String, Any> = mutableMapOf(),
+    val measures: List<String> = emptyList(),
+    val data: MutableList<Double> = mutableListOf(),
+    val traceMeasures: List<String> = emptyList(),
+    val traceData: MutableList<List<Double>> = mutableListOf()
+)

telemetry/src/main/kotlin/org/strykeforce/thirdcoast/trapper/Activity.kt

@@ -0,0 +1,22 @@
+package org.strykeforce.thirdcoast.trapper
+
+import com.squareup.moshi.JsonClass
+import java.time.LocalDateTime
+import java.util.*
+
+@JsonClass(generateAdapter = true)
+data class Activity(
+    val id: UUID = UUID.randomUUID(),
+    val name: String = "Activity ${LocalDateTime.now()}",
+    val meta: MutableMap<String, Any> = mutableMapOf(),
+    val measures: List<String> = emptyList(),
+    val data: MutableList<Double> = mutableListOf()
+) {
+
+    fun newAction(
+        name: String = actionDefaultName(),
+        measures: List<String> = emptyList(),
+        traceMeasures: List<String> = emptyList()
+    ): Action =
+        Action(this, name, measures = measures, traceMeasures = traceMeasures)
+}

telemetry/src/main/kotlin/org/strykeforce/thirdcoast/trapper/Session.kt

@@ -0,0 +1,77 @@
+package org.strykeforce.thirdcoast.trapper
+
+import com.squareup.moshi.FromJson
+import com.squareup.moshi.Moshi
+import com.squareup.moshi.ToJson
+import okhttp3.*
+import okio.BufferedSink
+import java.util.*
+
+val JSON = MediaType.get("application/json; charset=utf-8")
+
+object Session {
+    val client = OkHttpClient()
+
+    var baseUrl = "http://example.com:5000"
+        set(value) {
+            field = value
+            activityEndpoint = HttpUrl.get("$value/activities")
+            actionEndpoint = HttpUrl.get("$value/actions")
+        }
+    var activityEndpoint: HttpUrl = HttpUrl.get("$baseUrl/activities")
+    var actionEndpoint: HttpUrl = HttpUrl.get("$baseUrl/actions")
+
+
+    fun post(url: HttpUrl, json: String) {
+        val body = RequestBody.create(JSON, json)
+        val request = Request.Builder().url(url).post(body).build()
+
+        client.newCall(request).execute().use { println("response: ${it.body()?.string()}") }
+    }
+
+    fun post(url: HttpUrl, body: RequestBody) {
+        val request = Request.Builder().url(url).post(body).build()
+        client.newCall(request).execute().use { println("response: ${it.body()?.string()}") }
+    }
+
+}
+
+private val moshi = Moshi.Builder().add(UUIDAdapter()).add(ActivityAdapter()).build()
+private val activityJsonAdapter = ActivityJsonAdapter(moshi)
+
+/** Post an Activity to the web server specified in URL. */
+fun Activity.post() {
+    val body = object : RequestBody() {
+        override fun contentType() = JSON
+        override fun writeTo(sink: BufferedSink) = activityJsonAdapter.toJson(sink, this@post)
+    }
+    Session.post(Session.activityEndpoint, body)
+}
+
+private val actionJsonAdapter = ActionJsonAdapter(moshi).serializeNulls()
+
+/** Post an Action to the web server specified in URL. The parent activity must be posted first or this will fail. */
+fun Action.post() {
+    val body = object : RequestBody() {
+        override fun contentType() = JSON
+        override fun writeTo(sink: BufferedSink) = actionJsonAdapter.toJson(sink, this@post)
+    }
+    Session.post(Session.actionEndpoint, body)
+}
+
+internal class UUIDAdapter {
+
+    @ToJson
+    fun toJson(uuid: UUID): String = uuid.toString()
+
+    @FromJson
+    fun fromJson(uuid: String) = UUID.fromString(uuid)
+}
+
+internal class ActivityAdapter {
+    @ToJson
+    fun toJson(activity: Activity): UUID = activity.id
+
+    @FromJson
+    fun fromJson(uuid: UUID) = Activity(id = uuid, name = "UNKNOWN")
+}