Update metrics/opentelemetry-metrics/src/main/scala/sttp/tapir/server…

…/metrics/opentelemetry/OpenTelemetryMetrics.scala
varshith257 · Nov 16, 2024 · 21d174f · 21d174f
1 parent 966631c
commit 21d174f
Showing 1 changed file with 12 additions and 8 deletions.
diff --git a/...metrics/src/main/scala/sttp/tapir/server/metrics/opentelemetry/OpenTelemetryMetrics.scala b/...metrics/src/main/scala/sttp/tapir/server/metrics/opentelemetry/OpenTelemetryMetrics.scala
@@ -50,16 +50,20 @@ object OpenTelemetryMetrics {
       "path" -> { case (ep, _) => ep.showPathTemplate(showQueryParam = None) }
     ),
     forResponse = List(
-      "http.response.status_code" -> {
-        case Right(r) => r.code.code.toString
-        // Default to 500 for exceptions
-        case Left(_) => "500"
+    "http.response.status_code" -> { response: Either[Throwable, ServerResponse[_]] =>
+        response match {
+            case Right(r) => r.code.code.toString
+            // Default to 500 for exceptions
+            case Left(_) => "500"
+          }
       },
-      "error.type" -> {
-        case Left(ex)                   => Some(ex.getClass.getName) // Exception class name for pre-response errors
-        case Right(_)                   => None // No error.type for successful responses
+    "error.type" -> { response: Either[Throwable, ServerResponse[_]] =>
+       response match {
+            case Left(ex)                   => Some(ex.getClass.getName) // Exception class name for pre-response errors
+            case Right(_)                   => None // No error.type for successful responses
+        }
       }
-    ).collect { case (k, Some(v)) => k -> v }
+    ).collect {  case (k, v) if v(response) != None => k -> v(response).get }
   )
 
   def apply[F[_]](meter: Meter): OpenTelemetryMetrics[F] = apply(meter, Nil)