Test Webhook Endpoints Before Going Live

const response = await fetch('https://blackbox.dasha.ai/api/v1/webhooks/test', {
  method: 'POST',
  headers: {
    'Authorization': 'Bearer YOUR_API_KEY',
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    webHook: {
      url: 'https://your-server.com/webhook',
      headers: { 'Authorization': 'Bearer your-secret' }
    },
    webhookType: 'CompletedWebHookPayload',
    callAdditionalData: { userId: 'test-123' }
  })
});

const result = await response.json();
console.log('Success:', result.success);
console.log('HTTP Status:', result.httpStatus);
console.log('Time:', result.timeTaken, 'ms');

{
  "success": true,
  "httpStatus": 200,
  "responseData": { "received": true },
  "timeTaken": 245
}

# Install ngrok
brew install ngrok  # macOS
# or download from ngrok.com

# Authenticate
ngrok config add-authtoken YOUR_TOKEN

# Start tunnel
ngrok http 3000
# Output: https://abc123.ngrok.io -> localhost:3000

const express = require('express');

const app = express();
app.use(express.json());

app.post('/webhook', (req, res) => {
  console.log('Webhook received:', req.body.type);

  // Handle by type
  switch (req.body.type) {
    case 'StartWebHookPayload':
      console.log('Call started:', req.body.callId);
      break;
    case 'CompletedWebHookPayload':
      console.log('Call completed:', req.body.callId);
      break;
    case 'FailedWebHookPayload':
      console.error('Call failed:', req.body.errorMessage);
      break;
  }

  res.status(200).json({ received: true });
});

app.listen(3000, () => console.log('Server on port 3000'));

# Terminal 1: Start server
node webhook-server.js

# Terminal 2: Start ngrok
ngrok http 3000

# Terminal 3: Test
curl -X POST https://blackbox.dasha.ai/api/v1/webhooks/test \
  -H "Authorization: Bearer YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "webHook": { "url": "https://abc123.ngrok.io/webhook" },
    "webhookType": "CompletedWebHookPayload"
  }'

await fetch('https://blackbox.dasha.ai/api/v1/webhooks/test', {
  method: 'POST',
  headers: {
    'Authorization': 'Bearer YOUR_API_KEY',
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    webHook: { url: 'https://your-server.com/webhook' },
    webhookType: 'StartWebHookPayload',
    agentAdditionalData: { companyName: 'Acme Corp' },
    callAdditionalData: { customerId: 'cust_123' }
  })
});

await fetch('https://blackbox.dasha.ai/api/v1/webhooks/test', {
  method: 'POST',
  headers: {
    'Authorization': 'Bearer YOUR_API_KEY',
    'Content-Type': 'application/json'
  },
  body: JSON.stringify({
    webHook: { url: 'https://your-server.com/webhook' },
    webhookType: 'ToolWebHookPayload',
    toolName: 'check_availability',
    toolArguments: { date: '2025-01-20', time: '14:00' }
  })
});

let attemptCount = 0;

app.post('/webhook', (req, res) => {
  attemptCount++;
  console.log(`Attempt ${attemptCount}`);

  // Fail first 2 attempts
  if (attemptCount <= 2) {
    return res.status(500).json({ error: 'Temporary error' });
  }

  res.status(200).json({ received: true });
});

const processed = new Set();

app.post('/webhook', (req, res) => {
  const id = `${req.body.callId}_${req.body.timestamp}`;

  if (processed.has(id)) {
    console.log('Duplicate webhook, skipping');
    return res.status(200).json({ duplicate: true });
  }

  processed.add(id);
  processWebhook(req.body);

  res.status(200).json({ received: true });
});

app.post('/webhook', (req, res) => {
  // Respond immediately
  res.status(200).json({ received: true });

  // Process asynchronously
  setImmediate(() => {
    processWebhook(req.body);
  });
});