Integrations

// When new order is placed
app.post('/webhooks/new-order', async (req, res) => {
  const { customer_phone, order_id } = req.body;
  
  // Make confirmation call
  await fetch('https://api.call24x7.ai/outbound_call', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${process.env.CALL24X7_API_KEY}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      to_phone_number: customer_phone,
      agent_id: 'order-confirmation-agent',
      input_parameters: JSON.stringify({ order_id }),
      webhook_url: 'https://your-app.com/webhooks/call-complete'
    })
  });
  
  res.status(200).json({ success: true });
});

// When high-priority ticket is created
app.post('/webhooks/new-ticket', async (req, res) => {
  const { ticket_id, customer_phone, priority } = req.body;
  
  if (priority === 'high') {
    // Call customer immediately
    await call24x7.makeCall({
      to_phone_number: customer_phone,
      agent_id: 'support-agent',
      input_parameters: JSON.stringify({ ticket_id }),
      webhook_url: 'https://your-app.com/webhooks/call-complete'
    });
  }
  
  res.status(200).json({ received: true });
});

// Sync appointments with calendar
app.post('/webhooks/appointment-created', async (req, res) => {
  const { appointment_date, customer_phone, customer_name } = req.body;
  
  // Make reminder call
  await call24x7.makeCall({
    to_phone_number: customer_phone,
    agent_id: 'appointment-reminder-agent',
    input_parameters: JSON.stringify({
      appointment_date,
      customer_name
    })
  });
  
  res.status(200).json({ success: true });
});

// Cron job to make daily reminder calls
cron.schedule('0 9 * * *', async () => {
  const appointments = await getTodayAppointments();
  
  for (const appointment of appointments) {
    await call24x7.makeCall({
      to_phone_number: appointment.phone,
      agent_id: 'reminder-agent',
      input_parameters: JSON.stringify({
        appointment_time: appointment.time
      })
    });
  }
});

app.post('/webhooks/call-complete', async (req, res) => {
  const callData = req.body;
  
  // Update multiple systems
  await Promise.all([
    updateCRM(callData),
    updateAnalytics(callData),
    sendNotification(callData),
    logCall(callData)
  ]);
  
  res.status(200).json({ received: true });
});

async function makeCallWithRetry(params, maxRetries = 3) {
  for (let i = 0; i < maxRetries; i++) {
    try {
      const response = await call24x7.makeCall(params);
      return response;
    } catch (error) {
      if (i === maxRetries - 1) throw error;
      await sleep(1000 * (i + 1)); // Exponential backoff
    }
  }
}