test-hub.sh

#!/bin/bash
# Test GraphLens Telemetry Hub

set -e

cd "$(dirname "$0")/../.."

# Source environment
source .env

# Start hub in background
echo "Starting hub..."
node tools/observability-hub/index.js > /tmp/hub-test.log 2>&1 &
HUB_PID=$!

# Wait for hub to start
sleep 2

# Test health endpoint
echo "Testing /health..."
curl -s http://localhost:3000/health | jq .

# Generate HMAC signature for test payload
echo ""
echo "Testing /telemetry with HMAC auth..."
node -e "
const { generateSignature } = require('./backend/services/hmac-auth.cjs');
const payload = {
  timestamp: new Date().toISOString(),
  machine_id: 'test-machine',
  agent_id: 'marketing',
  quality_score: 85,
  execution_ms: 120,
  overall_pass: true,
  bottleneck_type: 'structure'
};
const signature = generateSignature(payload, process.env.GRAPHLENS_AUTH_SECRET);
console.log('Payload:', JSON.stringify(payload));
console.log('Signature:', signature);

// Make POST request
const http = require('http');
const postData = JSON.stringify(payload);
const options = {
  hostname: 'localhost',
  port: 3000,
  path: '/telemetry',
  method: 'POST',
  headers: {
    'Content-Type': 'application/json',
    'Content-Length': Buffer.byteLength(postData),
    'X-GraphLens-Signature': signature
  }
};

const req = http.request(options, (res) => {
  let data = '';
  res.on('data', (chunk) => { data += chunk; });
  res.on('end', () => {
    console.log('Response:', data);
  });
});

req.on('error', (e) => {
  console.error('Error:', e.message);
});

req.write(postData);
req.end();
"

sleep 1

# Test query endpoint
echo ""
echo "Testing /telemetry/query..."
curl -s 'http://localhost:3000/telemetry/query?hours=1&limit=10' | jq '.[] | {timestamp, agent_id, quality_score}'

# Test stats endpoint
echo ""
echo "Testing /telemetry/stats..."
curl -s 'http://localhost:3000/telemetry/stats?hours=1' | jq .

# Cleanup
echo ""
echo "Stopping hub..."
kill $HUB_PID
wait $HUB_PID 2>/dev/null || true

echo ""
echo "Hub log:"
cat /tmp/hub-test.log

echo ""
echo "✅ Hub test complete"