#!/bin/bash
# Alertmanager Webhook Receiver
# Receives alerts and triggers appropriate workflows
#
# This script is designed to be called by a simple webhook server
# or can be integrated into the dashboard.
#
# Usage:
#   echo '{"alerts": [...]}' | ./webhook-receiver.sh

set -euo pipefail

SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
CLAUDE_DIR="${SCRIPT_DIR}/.."
LOG_DIR="${CLAUDE_DIR}/logs/webhooks"

mkdir -p "${LOG_DIR}"

# Read JSON from stdin
PAYLOAD=$(cat)
TIMESTAMP=$(date +%Y-%m-%d_%H-%M-%S)
LOG_FILE="${LOG_DIR}/alert_${TIMESTAMP}.json"

# Log the payload
echo "${PAYLOAD}" > "${LOG_FILE}"

# Parse alerts and trigger workflows
echo "${PAYLOAD}" | jq -c '.alerts[]' 2>/dev/null | while read -r alert; do
    ALERTNAME=$(echo "${alert}" | jq -r '.labels.alertname // "unknown"')
    STATUS=$(echo "${alert}" | jq -r '.status // "firing"')
    NAMESPACE=$(echo "${alert}" | jq -r '.labels.namespace // "default"')
    POD=$(echo "${alert}" | jq -r '.labels.pod // ""')

    echo "Processing alert: ${ALERTNAME} (${STATUS})"

    # Only process firing alerts
    if [[ "${STATUS}" != "firing" ]]; then
        echo "  Skipping resolved alert"
        continue
    fi

    # Map alerts to workflows
    case "${ALERTNAME}" in
        KubePodCrashLooping|KubePodNotReady)
            echo "  Triggering pod-crashloop workflow"
            "${SCRIPT_DIR}/scheduler.sh" pod-crashloop-remediation \
                --namespace "${NAMESPACE}" --pod "${POD}" &
            ;;
        KubeNodeNotReady|KubeNodeUnreachable)
            echo "  Triggering node-issue workflow"
            "${SCRIPT_DIR}/scheduler.sh" node-issue-response &
            ;;
        KubeMemoryOvercommit|KubeCPUOvercommit)
            echo "  Triggering resource-pressure workflow"
            "${SCRIPT_DIR}/scheduler.sh" resource-pressure-response &
            ;;
        TargetDown|PrometheusTargetMissing)
            echo "  Triggering target-down workflow"
            "${SCRIPT_DIR}/scheduler.sh" target-down-investigation &
            ;;
        *)
            echo "  No workflow mapped for ${ALERTNAME}"
            ;;
    esac
done

echo "Webhook processing complete"