feat(realtime): add tracing filter (#64)

realtime/src/app/index.ts

@@ -11,6 +11,7 @@ for (const subModule in allFunctions) {
     allFunctions[subModule][fn] = wrapAsyncToRunInSpan({
       namespace: `app.${subModule.toLowerCase()}`,
       fn: allFunctions[subModule][fn],
+      root: true,
     })
   }
 }

realtime/src/config/process.ts

@@ -1,3 +1,4 @@
 export const tracingConfig = {
   otelServiceName: process.env.OTEL_SERVICE_NAME || "galoy-price-dev",
+  enableFilter: process.env.TRACING_ENABLE_FILTER === "true",
 }

realtime/src/domain/primitives/errors.ts

@@ -1,5 +1,7 @@
-import { DomainError } from "@domain/errors"
+import { DomainError, ErrorLevel } from "@domain/errors"
 
 class PrimitivesError extends DomainError {}
 
-export class InvalidCurrencyError extends PrimitivesError {}
+export class InvalidCurrencyError extends PrimitivesError {
+  level = ErrorLevel.Warn
+}

realtime/src/services/tracing.ts

@@ -64,6 +64,17 @@ class SpanProcessorWrapper extends SimpleSpanProcessor {
     }
     super.onStart(span, parentContext)
   }
+
+  onEnd(span: SdkSpan) {
+    if (tracingConfig.enableFilter) {
+      const errorLevel = span.attributes["error.level"]
+      if (!errorLevel || errorLevel === ErrorLevel.Info) {
+        return // Ignore the span if it has no error or if error is info level
+      }
+    }
+
+    super.onEnd(span)
+  }
 }
 
 provider.addSpanProcessor(new SpanProcessorWrapper(new OTLPTraceExporter()))