app.post('/webhook', (req, res) => {
  const event = req.body;

  if (event.event === 'message.received') {
    const message = event.message;

    console.log(`New email from ${message.from}: ${message.subject}`);

    // Extract reply text (without quoted history)
    const replyText = message.reply_body;

    // Process CTA links (e.g., verification links)
    if (message.cta_links.length > 0) {
      console.log('Found verification link:', message.cta_links[0]);
    }

    // Download attachments
    for (const attachment of message.attachments) {
      downloadAttachment(attachment.url);
    }
  }

  res.status(200).send('OK');
});

app.post('/webhook', (req, res) => {
  const event = req.body;

  if (event.event === 'message.bounced') {
    const bounce = event.bounce;

    console.log(`Bounce from ${bounce.recipient}: ${bounce.reason}`);

    if (bounce.type === 'permanent') {
      // Remove from contact list
      removeFromContactList(bounce.recipient);

      // Alert operator
      sendAlert(`Permanent bounce: ${bounce.recipient}`);
    } else if (bounce.type === 'temporary') {
      // Retry later
      scheduleRetry(event.message_id, bounce.recipient);
    }
  }

  res.status(200).send('OK');
});

app.post('/webhook', (req, res) => {
  const event = req.body;

  if (event.event === 'message.complaint') {
    const complaint = event.complaint;

    console.log(`Complaint from ${complaint.recipient}: ${complaint.feedback_type}`);

    // Immediately unsubscribe recipient
    unsubscribe(complaint.recipient);

    // Alert operator if complaint rate is high
    const complaintRate = calculateComplaintRate();

    if (complaintRate > 0.001) { // 0.1% threshold
      sendAlert(`High complaint rate: ${complaintRate * 100}%`);
    }
  }

  res.status(200).send('OK');
});

app.post('/webhook', (req, res) => {
  const event = req.body;

  if (event.event === 'account.upgraded') {
    const upgrade = event.upgrade;

    console.log(`Account upgraded: ${upgrade.from_tier} → ${upgrade.to_tier}`);

    // Enable sending capability for all agents
    if (upgrade.new_limits.max_sends_per_day > 0) {
      enableSendingForAllAgents(event.account_id);
    }

    // Enable webhooks
    if (upgrade.new_limits.webhooks_enabled) {
      createWebhooks(event.account_id);
    }

    // Notify operator
    sendEmail({
      to: 'operator@yourcompany.com',
      subject: 'Account upgraded',
      body: `Your daimon.email account has been upgraded to ${upgrade.to_tier}.`
    });
  }

  res.status(200).send('OK');
});

app.post('/webhook', (req, res) => {
  const event = req.body;

  if (event.event === 'webhook.unhealthy') {
    const webhook = event.webhook;

    console.log(`Webhook unhealthy: ${webhook.url}`);
    console.log(`Failure count: ${webhook.failure_count}`);
    console.log(`Last error: ${webhook.last_error}`);

    // Alert operator
    sendAlert({
      title: 'Webhook unhealthy',
      body: `${webhook.url} has failed ${webhook.failure_count} times. Last error: ${webhook.last_error}`
    });

    // Attempt to fix (e.g., restart webhook server)
    restartWebhookServer();

    // Re-enable webhook after fix
    setTimeout(async () => {
      await client.webhooks.enable(webhook.id);
      console.log('Webhook re-enabled');
    }, 60000); // Wait 1 minute before re-enabling
  }

  res.status(200).send('OK');
});

curl -X POST https://api.daimon.email/v1/webhooks \
  -H "Authorization: Bearer dm_live_account123..." \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://your-platform.com/webhook/daimon",
    "events": ["message.received"],
    "inbox_id": "inbox_abc123"
  }'

curl -X POST https://api.daimon.email/v1/webhooks \
  -H "Authorization: Bearer dm_live_account123..." \
  -H "Content-Type: application/json" \
  -d '{
    "url": "https://your-platform.com/webhook/daimon",
    "events": ["message.received", "message.bounced"]
  }'

curl -X POST https://api.daimon.email/v1/webhooks/wh_abc123/test \
  -H "Authorization: Bearer dm_live_account123..."