Open Telemetry Connector

import express, { Express, Request, Response } from 'express';
 
const PORT: number = parseInt(process.env.PORT || '8080');
const app: Express = express();
 
// Add middleware for both JSON and protobuf
app.use(express.json());
app.use(express.raw({ type: 'application/x-protobuf', limit: '10mb' }));
 
function getRandomNumber(min: number, max: number) {
  return Math.floor(Math.random() * (max - min + 1) + min);
}
 
// OpenTelemetry Collector compatible endpoints
app.post('/v1/traces', (req: Request, res: Response) => {
  try {
    console.log('Received traces data');
    console.log('Content-Type:', req.headers['content-type']);
    console.log('Data length:', req.body.length);
    
    // For protobuf data, you'd need to decode it
    // This is a simplified response for now
    res.status(200).send();
  } catch (error) {
    console.error('Error processing traces:', error);
    res.status(500).send();
  }
});
 
app.post('/v1/metrics', (req: Request, res: Response) => {
  try {
    console.log('Received metrics data');
    console.log('Content-Type:', req.headers['content-type']);
    console.log('Data length:', req.body.length);
    
    res.status(200).send();
  } catch (error) {
    console.error('Error processing metrics:', error);
    res.status(500).send();
  }
});
 
app.post('/v1/logs', (req: Request, res: Response) => {
  try {
    console.log('Received logs data');
    console.log('Content-Type:', req.headers['content-type']);
    console.log('Data length:', req.body.length);
    
    res.status(200).send();
  } catch (error) {
    console.error('Error processing logs:', error);
    res.status(500).send();
  }
});
 
// Keep your original webhook endpoint for JSON data
app.post('/webhook/otel', (req: Request, res: Response) => {
  try {
    const webhookData = req.body;
    
    // Log the incoming webhook data
    console.log('Received webhook event:', JSON.stringify(webhookData, null, 2));
    
    // Process OpenTelemetry compatible events
    if (webhookData.resourceSpans) {
      // Handle trace data
      console.log('Processing trace spans...');
      webhookData.resourceSpans.forEach((resourceSpan: any) => {
        resourceSpan.scopeSpans?.forEach((scopeSpan: any) => {
          scopeSpan.spans?.forEach((span: any) => {
            console.log(`Span: ${span.name}, TraceID: ${span.traceId}, SpanID: ${span.spanId}`);
          });
        });
      });
    }
    
    if (webhookData.resourceMetrics) {
      // Handle metrics data
      console.log('Processing metrics...');
      webhookData.resourceMetrics.forEach((resourceMetric: any) => {
        resourceMetric.scopeMetrics?.forEach((scopeMetric: any) => {
          scopeMetric.metrics?.forEach((metric: any) => {
            console.log(`Metric: ${metric.name}, Type: ${metric.unit}`);
          });
        });
      });
    }
    
    if (webhookData.resourceLogs) {
      // Handle log data
      console.log('Processing logs...');
      webhookData.resourceLogs.forEach((resourceLog: any) => {
        resourceLog.scopeLogs?.forEach((scopeLog: any) => {
          scopeLog.logRecords?.forEach((logRecord: any) => {
            console.log(`Log: ${logRecord.body?.stringValue}, Severity: ${logRecord.severityText}`);
          });
        });
      });
    }
    
    // Send success response
    res.status(200).json({ 
      status: 'success', 
      message: 'Webhook event processed',
      timestamp: new Date().toISOString()
    });
    
  } catch (error) {
    console.error('Error processing webhook:', error);
    res.status(500).json({ 
      status: 'error', 
      message: 'Failed to process webhook event' 
    });
  }
});
 
app.listen(PORT, () => {
  console.log(`Listening for requests on http://localhost:${PORT}`);
});