add otel compatible telemetry signal

Signed-off-by: christian.lutnik <[email protected]>

Author: chrfwow

android/src/main/java/dev/openfeature/sdk/EvaluationEvent.kt

@@ -0,0 +1,27 @@
+package dev.openfeature.sdk
+
+/**
+ * OpenTelemetry compatible telemetry signal for flag evaluations. Can be created by calling [createEvaluationEvent].
+ *
+ * See
+ * [TELEMETRY_KEY],
+ * [TELEMETRY_ERROR_CODE],
+ * [TELEMETRY_VARIANT],
+ * [TELEMETRY_CONTEXT_ID],
+ * [TELEMETRY_ERROR_MSG],
+ * [TELEMETRY_REASON],
+ * [TELEMETRY_PROVIDER],
+ * [TELEMETRY_FLAG_SET_ID],
+ * [TELEMETRY_VERSION],
+ * [TELEMETRY_FLAG_META_CONTEXT_ID],
+ * [TELEMETRY_FLAG_META_FLAG_SET_ID],
+ * [TELEMETRY_FLAG_META_VERSION],
+ * [TELEMETRY_BODY] and
+ * [FLAG_EVALUATION_EVENT_NAME]
+ * for attribute and body keys.
+ */
+data class EvaluationEvent(
+    val name: String,
+    val attributes: Map<String, Any?>,
+    val body: Map<String, Any?>,
+)

android/src/main/java/dev/openfeature/sdk/Telemetry.kt

@@ -0,0 +1,62 @@
+package dev.openfeature.sdk
+
+import dev.openfeature.sdk.exceptions.ErrorCode
+
+const val TELEMETRY_KEY = "feature_flag.key"
+const val TELEMETRY_ERROR_CODE = "error.type"
+const val TELEMETRY_VARIANT = "feature_flag.variant"
+const val TELEMETRY_CONTEXT_ID = "feature_flag.context.id"
+const val TELEMETRY_ERROR_MSG = "feature_flag.evaluation.error.message"
+const val TELEMETRY_REASON = "feature_flag.evaluation.reason"
+const val TELEMETRY_PROVIDER = "feature_flag.provider_name"
+const val TELEMETRY_FLAG_SET_ID = "feature_flag.set.id"
+const val TELEMETRY_VERSION = "feature_flag.version"
+
+// Well-known flag metadata attributes for telemetry events.
+// Specification: https://openfeature.dev/specification/appendix-d#flag-metadata
+const val TELEMETRY_FLAG_META_CONTEXT_ID = "contextId"
+const val TELEMETRY_FLAG_META_FLAG_SET_ID = "flagSetId"
+const val TELEMETRY_FLAG_META_VERSION = "version"
+
+// OpenTelemetry event body.
+// Specification: https://opentelemetry.io/docs/specs/semconv/feature-flags/feature-flags-logs/
+const val TELEMETRY_BODY = "value"
+
+const val FLAG_EVALUATION_EVENT_NAME = "feature_flag.evaluation"
+
+/**
+ * Creates an [EvaluationEvent] from a flag evaluation. To be used inside a finally hook to provide an OpenTelemetry
+ * compatible telemetry signal.
+ */
+fun <T> createEvaluationEvent(
+    hookContext: HookContext<T>,
+    providerEvaluation: ProviderEvaluation<T>
+): EvaluationEvent {
+    val attributes = mutableMapOf<String, Any?>()
+    val body = mutableMapOf<String, Any?>()
+    attributes[TELEMETRY_KEY] = hookContext.flagKey
+    attributes[TELEMETRY_PROVIDER] = hookContext.providerMetadata.name ?: ""
+    attributes[TELEMETRY_REASON] = providerEvaluation.reason?.lowercase() ?: Reason.UNKNOWN.name.lowercase()
+    attributes[TELEMETRY_CONTEXT_ID] =
+        providerEvaluation.metadata.getString(TELEMETRY_FLAG_META_CONTEXT_ID) ?: hookContext.ctx?.getTargetingKey()
+    providerEvaluation.metadata.getString(TELEMETRY_FLAG_META_FLAG_SET_ID)?.let { attributes[TELEMETRY_FLAG_SET_ID] = it }
+    providerEvaluation.metadata.getString(TELEMETRY_FLAG_META_VERSION)?.let { attributes[TELEMETRY_VERSION] = it }
+
+    val variant = providerEvaluation.variant
+    if (variant == null) {
+        body[TELEMETRY_BODY] = providerEvaluation.value
+    } else {
+        attributes[TELEMETRY_VARIANT] = variant
+    }
+
+    if (providerEvaluation.reason == Reason.ERROR.name) {
+        attributes[TELEMETRY_ERROR_CODE] = providerEvaluation.errorCode ?: ErrorCode.GENERAL
+        providerEvaluation.errorMessage?.let { attributes[TELEMETRY_ERROR_MSG] = it }
+    }
+
+    return EvaluationEvent(
+        FLAG_EVALUATION_EVENT_NAME,
+        attributes,
+        body
+    )
+}