Alert

{
  "event": {
    "type": "alert",
    "data": {
      "alert": {
        "id": "string",
        "currentValue": 0,
        "threshold": 0,
        "status": "triggered | resolved",
        "timeWindow": "string",
        "type": "cost | latency | error_rate"
      },
      "message": "string",
      "timestamp": "string"
    }
  }
}

if (event.type === "alert") {
  const alertData = event.data;

  try {
    if (alertData.alert.status === "triggered") {
      await handleTriggeredAlert(alertData);
    } else if (alertData.alert.status === "resolved") {
      await handleResolvedAlert(alertData);
    }

    return NextResponse.json({
      message: "Alert processed",
      alertId: alertData.alert.id,
      status: alertData.alert.status,
    });
  } catch (error) {
    console.error("Alert processing error:", error);
    return NextResponse.json(
      { message: "Error processing alert" },
      { status: 500 }
    );
  }
}

async function handleTriggeredAlert(alertData: any) {
  const { alert, message, timestamp } = alertData;

  switch (alert.type) {
    case "cost":
      console.log(`Cost alert: ${alert.currentValue} exceeded threshold ${alert.threshold}`);
      break;
    case "latency":
      console.log(`Latency alert: ${alert.currentValue}ms exceeded threshold ${alert.threshold}ms`);
      break;
    case "error_rate":
      console.log(`Error rate alert: ${alert.currentValue}% exceeded threshold ${alert.threshold}%`);
      break;
  }
}

async function handleResolvedAlert(alertData: any) {
  const { alert, message, timestamp } = alertData;
  console.log(`Alert ${alert.id} resolved at ${timestamp}`);
}

async function sendSlackNotification(alert: any, message: string) {
  const slackWebhookUrl = process.env.SLACK_WEBHOOK_URL;
  if (!slackWebhookUrl) return;

  await fetch(slackWebhookUrl, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({
      text: `AgentMark Alert: ${alert.type.toUpperCase()}`,
      blocks: [
        {
          type: "section",
          text: { type: "mrkdwn", text: message },
        },
        {
          type: "section",
          fields: [
            { type: "mrkdwn", text: `*Status:*\n${alert.status}` },
            { type: "mrkdwn", text: `*Current:*\n${alert.currentValue}` },
            { type: "mrkdwn", text: `*Threshold:*\n${alert.threshold}` },
            { type: "mrkdwn", text: `*Window:*\n${alert.timeWindow}` },
          ],
        },
      ],
    }),
  });
}

async function sendEmailAlert(alert: any, message: string) {
  // Use your preferred email service (Resend, SendGrid, AWS SES, etc.)
  const emailConfig = {
    from: process.env.ALERT_EMAIL_FROM,
    to: process.env.ALERT_EMAIL_TO,
    subject: `AgentMark Alert: ${alert.type} - ${alert.status}`,
    html: `
      <h2>AgentMark Alert</h2>
      <p>${message}</p>
      <table>
        <tr><td><strong>Alert ID:</strong></td><td>${alert.id}</td></tr>
        <tr><td><strong>Type:</strong></td><td>${alert.type}</td></tr>
        <tr><td><strong>Status:</strong></td><td>${alert.status}</td></tr>
        <tr><td><strong>Current Value:</strong></td><td>${alert.currentValue}</td></tr>
        <tr><td><strong>Threshold:</strong></td><td>${alert.threshold}</td></tr>
      </table>
    `,
  };

  // await sendEmail(emailConfig);
}