Webhooks

// Handle sms.delivered webhook
async function handleSMSDelivered(data) {
  const order = await Order.findByPhone(data.to);
  
  await order.update({ status: 'notification_sent' });
  
  await sendEmail(order.customerEmail, {
    subject: 'SMS Delivered',
    body: `Your order update was delivered to ${data.to}`
  });
}

// Handle otp.verified webhook
async function handleOTPVerified(data) {
  const session = await Session.create({
    userId: data.metadata.userId,
    verifiedAt: data.verifiedAt,
    ipAddress: data.metadata.ipAddress
  });
  
  await AuditLog.create({
    action: 'otp_verified',
    userId: data.metadata.userId,
    details: {
      attempts: data.attemptsUsed,
      phone: data.phone
    }
  });
  
  return session;
}

// Handle multiple webhook types
class CampaignAnalytics {
  constructor() {
    this.metrics = {
      sent: 0,
      delivered: 0,
      failed: 0,
      conversions: 0
    };
  }
  
  async handleWebhook(payload) {
    const { event, data } = payload;
    
    switch(event) {
      case 'sms.sent':
        this.metrics.sent++;
        await this.updateRedis('campaign:sent', 1);
        break;
        
      case 'sms.delivered':
        this.metrics.delivered++;
        await this.updateDeliveryRate(data.campaignId);
        break;
        
      case 'sms.failed':
        this.metrics.failed++;
        await this.alertOnHighFailure(data);
        break;
    }
    
    await this.updateDashboard();
  }
}