chore: misc updated to ffm and otel

Author: sureshg

backend/jvm/src/main/kotlin/dev/suresh/lang/FFM.kt

@@ -23,7 +23,7 @@ object FFM {
   }
 
   private fun KLogger.strlen(str: String) {
-    val strlenAddr = SYMBOL_LOOKUP.findOrNull("strlen")
+    val strlenAddr = SYMBOL_LOOKUP.findOrThrow("strlen")
     val strlenDescriptor = FunctionDescriptor.of(ValueLayout.JAVA_INT, AddressLayout.ADDRESS)
     val strlen = LINKER.downcallHandle(strlenAddr, strlenDescriptor)
     Arena.ofConfined().use { arena ->
@@ -35,15 +35,15 @@ object FFM {
 
   private fun KLogger.currTime() {
     // Print the current time.
-    val timeAddr = SYMBOL_LOOKUP.findOrNull("time")
+    val timeAddr = SYMBOL_LOOKUP.findOrThrow("time")
     val timeDesc = FunctionDescriptor.of(ValueLayout.JAVA_LONG)
     val time = LINKER.downcallHandle(timeAddr, timeDesc)
     val timeResult = time.invokeExact() as Long
     info { "time() = $timeResult epochSecond" }
   }
 
   private fun KLogger.gmtime() {
-    val gmtAddr = SYMBOL_LOOKUP.findOrNull("gmtime")
+    val gmtAddr = SYMBOL_LOOKUP.findOrThrow("gmtime")
     val gmtDesc =
         FunctionDescriptor.of(
             AddressLayout.ADDRESS.withTargetLayout(TM.LAYOUT), AddressLayout.ADDRESS)
@@ -58,7 +58,7 @@ object FFM {
   }
 
   private fun KLogger.getPid() {
-    val getpidAddr = SYMBOL_LOOKUP.findOrNull("getpid")
+    val getpidAddr = SYMBOL_LOOKUP.findOrThrow("getpid")
     val getpidDesc = FunctionDescriptor.of(ValueLayout.JAVA_INT)
     val getpid = LINKER.downcallHandle(getpidAddr, getpidDesc)
     val pid = getpid.invokeExact() as Int

backend/jvm/src/main/kotlin/dev/suresh/plugins/OTel.kt

@@ -1,35 +1,44 @@
 package dev.suresh.plugins
 
+import BuildConfig
+import io.ktor.http.HttpMethod
 import io.ktor.server.application.*
-import io.opentelemetry.api.OpenTelemetry
+import io.ktor.server.request.httpMethod
+import io.opentelemetry.api.trace.SpanKind
+import io.opentelemetry.instrumentation.ktor.v3_0.*
+import io.opentelemetry.sdk.OpenTelemetrySdk
 import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk
 import io.opentelemetry.semconv.ServiceAttributes
+import kotlin.time.Clock
 
 fun Application.configureOTel() {
-  // install(OTelExtnPlugin) { enabled = true }
-  //
-  //  install(KtorServerTracing) {
-  //    setOpenTelemetry(GlobalOpenTelemetry.get())
-  //    attributeExtractor {
-  //      onStart { attributes.put("start-time", Clock.System.now().toEpochMilliseconds()) }
-  //      onEnd { attributes.put("end-time", Clock.System.now().toEpochMilliseconds()) }
-  //    }
-  //  }
-}
+  install(KtorServerTelemetry) {
+    setOpenTelemetry(getOpenTelemetry(BuildConfig.name))
 
-/**
- * [Manual
- * instrumentation](https://opentelemetry.io/docs/languages/java/instrumentation/#acquiring-a-tracer-in-java-agent)
- */
-fun getOpenTelemetry(serviceName: String): OpenTelemetry {
-  return AutoConfiguredOpenTelemetrySdk.builder()
-      .addResourceCustomizer { oldResource, _ ->
-        oldResource
-            .toBuilder()
-            .putAll(oldResource.attributes)
-            .put(ServiceAttributes.SERVICE_NAME, serviceName)
-            .build()
+    spanKindExtractor {
+      if (httpMethod == HttpMethod.Post) {
+        SpanKind.PRODUCER
+      } else {
+        SpanKind.CLIENT
       }
-      .build()
-      .openTelemetrySdk
+    }
+
+    attributesExtractor {
+      onStart { attributes.put("start-time", Clock.System.now().toEpochMilliseconds()) }
+      onEnd { attributes.put("end-time", Clock.System.now().toEpochMilliseconds()) }
+    }
+  }
+  // install(OTelExtnPlugin) { enabled = true }
 }
+
+/** See [Configure the SDK](https://opentelemetry.io/docs/languages/java/configuration/) */
+fun getOpenTelemetry(serviceName: String): OpenTelemetrySdk =
+    AutoConfiguredOpenTelemetrySdk.builder()
+        .addResourceCustomizer { res, _ ->
+          res.toBuilder()
+              .putAll(res.attributes)
+              .put(ServiceAttributes.SERVICE_NAME, serviceName)
+              .build()
+        }
+        .build()
+        .openTelemetrySdk

backend/jvm/src/main/kotlin/dev/suresh/plugins/custom/Plugins.kt

@@ -2,7 +2,7 @@ package dev.suresh.plugins.custom
 
 import dev.suresh.plugins.isApi
 import io.ktor.server.application.*
-import io.ktor.util.AttributeKey
+import io.ktor.util.*
 import io.opentelemetry.api.trace.Span
 
 /**