fix(core): append correct OTLP paths for HTTP exporters

Author: sebastien-prudhomme

packages/core/src/telemetry/sdk.test.ts

@@ -110,13 +110,13 @@ describe('Telemetry SDK', () => {
     await initializeTelemetry(mockConfig);
 
     expect(OTLPTraceExporterHttp).toHaveBeenCalledWith({
-      url: 'http://localhost:4318/',
+      url: 'http://localhost:4318/v1/traces',
     });
     expect(OTLPLogExporterHttp).toHaveBeenCalledWith({
-      url: 'http://localhost:4318/',
+      url: 'http://localhost:4318/v1/logs',
     });
     expect(OTLPMetricExporterHttp).toHaveBeenCalledWith({
-      url: 'http://localhost:4318/',
+      url: 'http://localhost:4318/v1/metrics',
     });
     expect(NodeSDK.prototype.start).toHaveBeenCalled();
   });
@@ -138,7 +138,7 @@ describe('Telemetry SDK', () => {
     );
     await initializeTelemetry(mockConfig);
     expect(OTLPTraceExporterHttp).toHaveBeenCalledWith(
-      expect.objectContaining({ url: 'https://my-collector.com/' }),
+      expect.objectContaining({ url: 'https://my-collector.com/v1/traces' }),
     );
   });
 

packages/core/src/telemetry/sdk.ts

@@ -240,15 +240,17 @@ export async function initializeTelemetry(
     });
   } else if (useOtlp) {
     if (otlpProtocol === 'http') {
+      // Trim trailing slashes
+      const baseUrl = parsedEndpoint.replace(/\/+$/, '');
       spanExporter = new OTLPTraceExporterHttp({
-        url: parsedEndpoint,
+        url: `${baseUrl}/v1/traces`,
       });
       logExporter = new OTLPLogExporterHttp({
-        url: parsedEndpoint,
+        url: `${baseUrl}/v1/logs`,
       });
       metricReader = new PeriodicExportingMetricReader({
         exporter: new OTLPMetricExporterHttp({
-          url: parsedEndpoint,
+          url: `${baseUrl}/v1/metrics`,
         }),
         exportIntervalMillis: 10000,
       });