feat/otel tracing exporter

Author: piotr-szewczyk

packages/opentelemetry-node/package.json

@@ -25,7 +25,8 @@
     },
     "dependencies": {
         "@opentelemetry/api": "^1.4.1",
-        "@opentelemetry/exporter-metrics-otlp-proto": "^0.38.0",
+        "@opentelemetry/exporter-metrics-otlp-http": "^0.38.0",
+        "@opentelemetry/exporter-trace-otlp-http": "^0.39.1",
         "@traceo-sdk/node-core": "0.32.2",
         "os": "^0.1.2",
         "stacktrace-parser-node": "^1.1.3"

packages/opentelemetry-node/src/exporters/index.ts

@@ -1 +1,2 @@
-export { TraceoOTLPMetricExporter } from "./otel-metrics-exporter";
+export { TraceoMetricExporter } from "./metrics-exporter";
+export { TraceoTracingExporter } from "./tracing-exporter";

…e/src/exporters/otel-metrics-exporter.ts …y-node/src/exporters/metrics-exporter.tspackages/opentelemetry-node/src/exporters/otel-metrics-exporter.ts renamed to packages/opentelemetry-node/src/exporters/metrics-exporter.ts packages/opentelemetry-node/src/exporters/otel-metrics-exporter.ts renamed to packages/opentelemetry-node/src/exporters/metrics-exporter.ts

@@ -1,4 +1,4 @@
-import { OTLPMetricExporter } from "@opentelemetry/exporter-metrics-otlp-proto";
+import { OTLPMetricExporter } from "@opentelemetry/exporter-metrics-otlp-http";
 import {
     CAPTURE_ENDPOINT,
     MetricData,
@@ -9,11 +9,11 @@ import {
     ExportResult,
     ExportResultCode,
     ResourceMetrics,
-    INodeClient
+    INodeClient,
+    utils
 } from "@traceo-sdk/node-core";
-import { getGlobalTraceo } from "@traceo-sdk/node-core/dist/utils";
 
-export class TraceoOTLPMetricExporter extends OTLPMetricExporter {
+export class TraceoMetricExporter extends OTLPMetricExporter {
     private client: INodeClient;
 
     constructor(config?: OTLPExporterNodeConfigBase) {
@@ -22,7 +22,7 @@ export class TraceoOTLPMetricExporter extends OTLPMetricExporter {
             temporalityPreference: AggregationTemporality.DELTA
         });
 
-        this.client = getGlobalTraceo();
+        this.client = utils.getGlobalTraceo();
     }
 
     public export(metrics: ResourceMetrics, resultCallback: (result: ExportResult) => void): void {
@@ -40,14 +40,17 @@ export class TraceoOTLPMetricExporter extends OTLPMetricExporter {
             body: flatMetrics,
             url: CAPTURE_ENDPOINT.METRICS,
             method: "POST",
+            callback: () => {
+                resultCallback({ code: ExportResultCode.SUCCESS });
+            },
             onError: (error: Error) => {
                 console.error(
-                    `Traceo Error. Something went wrong while sending new Metrics to Traceo. Please report this issue.`
+                    `Traceo Error. Something went wrong while sending new metrics to Traceo. Please report this issue.`
                 );
                 console.error(`Caused by: ${error.message}`);
+
+                resultCallback({ code: ExportResultCode.FAILED });
             }
         });
-
-        resultCallback({ code: ExportResultCode.SUCCESS });
     }
 };

packages/opentelemetry-node/src/exporters/tracing-exporter.ts

@@ -0,0 +1,47 @@
+import { OTLPTraceExporter } from "@opentelemetry/exporter-trace-otlp-http";
+import {
+    INodeClient,
+    utils,
+    transport,
+    CAPTURE_ENDPOINT,
+    ExportResultCode,
+    ReadableSpan,
+    ExportResult,
+    OTLPExporterNodeConfigBase
+} from "@traceo-sdk/node-core";
+
+export class TraceoTracingExporter extends OTLPTraceExporter {
+    private client: INodeClient;
+
+    constructor(config: OTLPExporterNodeConfigBase) {
+        super(config);
+
+        this.client = utils.getGlobalTraceo();
+    }
+
+    public export(items: ReadableSpan[], resultCallback: (result: ExportResult) => void): void {
+        const isOffline = this.client.options.offline;
+
+        if (isOffline) {
+            return;
+        }
+
+        transport.request({
+            body: items,
+            url: CAPTURE_ENDPOINT.TRACING,
+            method: "POST",
+            callback: () => {
+                resultCallback({ code: ExportResultCode.SUCCESS });
+            },
+            onError: (error: Error) => {
+                console.error(
+                    `Traceo Error. Something went wrong while sending new Traces to Traceo. Please report this issue.`
+                );
+                console.error(`Caused by: ${error.message}`);
+
+                resultCallback({ code: ExportResultCode.FAILED });
+            }
+        });
+
+    }
+}