// npm install @opentelemetry/api @opentelemetry/sdk-node
// npm install @opentelemetry/auto-instrumentations-node

// tracing.js — load before everything else
import { NodeSDK } from '@opentelemetry/sdk-node';
import { OTLPTraceExporter } from '@opentelemetry/exporter-trace-otlp-http';
import { getNodeAutoInstrumentations } from '@opentelemetry/auto-instrumentations-node';

const sdk = new NodeSDK({
  traceExporter: new OTLPTraceExporter({
    url: 'http://otel-collector:4318/v1/traces',
  }),
  instrumentations: [
    getNodeAutoInstrumentations({
      '@opentelemetry/instrumentation-http': { enabled: true },
      '@opentelemetry/instrumentation-express': { enabled: true },
      '@opentelemetry/instrumentation-pg': { enabled: true },
      '@opentelemetry/instrumentation-redis': { enabled: true },
    }),
  ],
  resource: Resource.default().merge(
    new Resource({
      [SemanticResourceAttributes.SERVICE_NAME]: 'payment-service',
      [SemanticResourceAttributes.SERVICE_VERSION]: '2.1.0',
    })
  ),
});

sdk.start();

// Manual span
const { trace } = require('@opentelemetry/api');
const tracer = trace.getTracer('payment-service');

async function chargeCard(card, amount) {
  return tracer.startActiveSpan('charge_card', async (span) => {
    try {
      span.setAttribute('payment.amount', amount);
      span.setAttribute('payment.currency', 'ILS');
      span.setAttribute('card.last4', card.last4);

      const result = await stripe.charges.create({ amount, currency: 'ils' });

      span.setAttribute('stripe.charge_id', result.id);
      span.setStatus({ code: SpanStatusCode.OK });
      return result;
    } catch (error) {
      span.recordException(error);
      span.setStatus({ code: SpanStatusCode.ERROR, message: error.message });
      throw error;
    } finally {
      span.end();
    }
  });
}
Distributed Tracing — Jaeger, OpenTelemetry

Distributed Tracing — Jaeger, OpenTelemetry

Distributed Tracing — Jaeger, OpenTelemetry
