Gateway ARQ API

curl -X GET http://localhost:8000/health

fetch('http://localhost:8000/health')
  .then(res => res.json())
  .then(data => console.log(data));

const axios = require('axios');

axios.get('http://localhost:8000/health')
  .then(response => console.log(response.data));

curl -X GET http://localhost:8000/version

fetch('http://localhost:8000/version')
  .then(res => res.json())
  .then(data => console.log(`Version: ${data.version}`));

curl -X GET http://localhost:8000/metrics

const axios = require('axios');

async function getMetrics() {
  const { data } = await axios.get('http://localhost:8000/metrics');
  console.log(`Active calls: ${data.calls.webcom_active}`);
  console.log(`Cost today: €${data.costs.today}`);
}

getMetrics();

curl -X GET http://localhost:8000/api/webcom/lines

fetch('http://localhost:8000/api/webcom/lines')
  .then(res => res.json())
  .then(data => {
    console.log(`Total lines: ${data.count}`);
    data.lines.forEach(line => {
      console.log(`${line.number}: ${line.lineType}`);
    });
  });

const axios = require('axios');

axios.get('http://localhost:8000/api/webcom/lines')
  .then(response => {
    console.log(`Total lines: ${response.data.count}`);
    console.log('Lines:', response.data.lines);
  });

curl -X GET "http://localhost:8000/api/webcom/calls?limit=10"

fetch('http://localhost:8000/api/webcom/calls?limit=10')
  .then(res => res.json())
  .then(data => {
    console.log(`Active calls: ${data.count}`);
    data.calls.forEach(call => {
      console.log(`${call.id}: ${call.state} - ${call.caller} → ${call.called}`);
    });
  });

const axios = require('axios');

async function getCalls() {
  const { data } = await axios.get('http://localhost:8000/api/webcom/calls', {
    params: { limit: 10 }
  });

  console.log(`Found ${data.count} calls`);
  return data.calls;
}

getCalls();

curl -X GET http://localhost:8000/api/webcom/calls/691880b00a5a19c9db354ac8

const callId = '691880b00a5a19c9db354ac8';

fetch(`http://localhost:8000/api/webcom/calls/${callId}`)
  .then(res => res.json())
  .then(call => {
    if (call.error) {
      console.error('Call not found');
    } else {
      console.log(`Call ${call.id}: ${call.state}`);
      console.log(`Duration: ${call.duration}s, Cost: €${call.cost}`);
    }
  });

const axios = require('axios');

async function getCall(callId) {
  try {
    const { data } = await axios.get(
      `http://localhost:8000/api/webcom/calls/${callId}`
    );
    return data;
  } catch (error) {
    console.error('Error fetching call:', error.message);
  }
}

getCall('691880b00a5a19c9db354ac8');

curl -X GET http://localhost:8000/api/webcom/rebates

curl -X GET "http://localhost:8000/api/webcom/rebates?month=2025-10"

fetch('http://localhost:8000/api/webcom/rebates?month=2025-11')
  .then(res => res.json())
  .then(data => {
    console.log(`Rebates for ${data.month}`);

    let totalCost = 0;
    data.rebates.forEach(rebate => {
      console.log(`${rebate.operator} (${rebate.type}): €${rebate.cost}`);
      totalCost += rebate.cost;
    });

    console.log(`Total: €${totalCost.toFixed(2)}`);
  });

const axios = require('axios');

async function getRebates(month = null) {
  const params = month ? { month } : {};

  const { data } = await axios.get(
    'http://localhost:8000/api/webcom/rebates',
    { params }
  );

  console.log(`Rebates for ${data.month}: ${data.count} entries`);
  return data.rebates;
}

// Get current month
getRebates();

// Get specific month
getRebates('2025-10');

curl -H "X-API-Key: sk_live_arq_2024_production_key_change_me" \
  http://localhost:8000/

curl -H "X-API-Key: sk_live_arq_2024_production_key_change_me" \
  http://localhost:8000/api/webtv/viewers

const response = await fetch('http://localhost:8000/api/webtv/viewers', {
  headers: { 'X-API-Key': 'sk_live_arq_2024_production_key_change_me' }
});
const data = await response.json();
console.log(`Current viewers: ${data.viewers}`);

import requests

headers = {'X-API-Key': 'sk_live_arq_2024_production_key_change_me'}
response = requests.get('http://localhost:8000/api/webtv/viewers', headers=headers)
data = response.json()
print(f"Current viewers: {data['viewers']}")

curl -H "X-API-Key: sk_live_arq_2024_production_key_change_me" \
  http://localhost:8000/api/webtv/stats

const response = await fetch('http://localhost:8000/api/webtv/stats', {
  headers: { 'X-API-Key': 'sk_live_arq_2024_production_key_change_me' }
});
const data = await response.json();

// Create Chart.js graph
const chart = new Chart(ctx, {
  type: 'line',
  data: {
    labels: Array.from({length: 24}, (_, i) => `${i}:00`),
    datasets: [{
      label: 'Today',
      data: data.today.hourly,
      borderColor: 'rgb(59, 130, 246)'
    }]
  }
});

const ws = new WebSocket('ws://localhost:8000/ws');

ws.onopen = () => {
  console.log('Connected to Gateway ARQ');
};

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);
  console.log('Event received:', data);

  if (data.id && data.state) {
    console.log(`Call ${data.id}: ${data.state}`);
  }
};

ws.onerror = (error) => {
  console.error('WebSocket error:', error);
};

ws.onclose = () => {
  console.log('Disconnected');
};

const WebSocket = require('ws');

const ws = new WebSocket('ws://localhost:8000/ws');

ws.on('open', () => {
  console.log('Connected to Gateway ARQ');
});

ws.on('message', (data) => {
  const event = JSON.parse(data);

  if (event.id && event.state) {
    console.log(`Call ${event.id}: ${event.state}`);
    console.log(`  Caller: ${event.caller}`);
    console.log(`  Cost: €${event.cost}`);
  }
});

ws.on('error', (error) => {
  console.error('Error:', error);
});

const ws = new WebSocket('ws://localhost:8000/ws?api_key=sk_live_arq_2024_production_key_change_me');

ws.onmessage = (event) => {
  const data = JSON.parse(event.data);

  // Filter Asterisk events
  if (data.type === 'asterisk_event') {
    console.log(`[Asterisk] ${data.event} on ${data.server}`);
    console.log(`  Channel: ${data.channel}`);
    console.log(`  CallerID: ${data.calleridnum} (${data.calleridname})`);
    console.log(`  State: ${data.state}`);
  }
};

const WebSocket = require('ws');

const ws = new WebSocket('ws://localhost:8000/ws?api_key=sk_live_arq_2024_production_key_change_me');

ws.on('message', (data) => {
  const event = JSON.parse(data);

  if (event.type === 'asterisk_event') {
    if (event.event === 'Newchannel') {
      console.log(`📞 New call on ${event.server}: ${event.calleridnum}`);
    } else if (event.event === 'Hangup') {
      console.log(`📴 Call ended: ${event.channel}`);
    }
  }
});