flowchart TD
    %% ── Stage 1: Metric Collection ──────────────────────────────
    START([⏰ Schedule Trigger<br/>Every 15-30 min]) --> FETCH

    subgraph STAGE1["<b>Stage 1 — Gather Metrics</b>"]
        FETCH[Fetch from Prometheus]
        FETCH --> CPU[CPU Usage<br/><i>per host</i>]
        FETCH --> RAM[Memory Available<br/><i>per host</i>]
        FETCH --> DISK[Disk Usage<br/><i>per host</i>]
        FETCH --> IO[I/O Pressure<br/><i>per host</i>]
        FETCH --> SVC_FAIL[Failed Services<br/><i>all hosts</i>]
        FETCH --> SVC_INACTIVE[Inactive Critical<br/>Services]
        FETCH --> PROCS_CPU[Top CPU<br/>Processes]
        FETCH --> PROCS_MEM[Top Memory<br/>Processes]

        CPU & RAM & DISK & IO & SVC_FAIL & SVC_INACTIVE & PROCS_CPU & PROCS_MEM --> MERGE[Merge All Metrics]
        MERGE --> PROCESS[Process Metrics<br/><i>JS: threshold checks,<br/>alert cache dedup</i>]
    end

    PROCESS --> CACHE_CHECK{Issues found<br/>& not cached?}
    CACHE_CHECK -- No --> DONE_CLEAN([✅ No Issues])
    CACHE_CHECK -- Yes --> LOKI_Q

    subgraph LOKI["Loki Log Enrichment"]
        LOKI_Q[Build Loki Query<br/><i>failed/inactive services</i>] --> LOKI_FETCH[Fetch Logs from Loki]
        LOKI_FETCH --> LOKI_FMT[Format Loki Context<br/><i>last 20 entries per stream,<br/>truncate at 3000 chars</i>]
    end

    %% ── Stage 2: AI Decision Engine ─────────────────────────────
    LOKI_FMT --> AI

    subgraph STAGE2["<b>Stage 2 — AI Decision Engine</b>"]
        AI[Claude Analysis<br/><i>metrics + logs + prompt</i>]
        AI --> PARSE[Parse JSON Response<br/><i>with malformed JSON fallback</i>]
        PARSE --> ROUTE{Response type?}
    end

    ROUTE -- "actions: []<br/>manual_issues: []" --> DONE_OK([✅ No Action Needed])
    ROUTE -- "manual_issues only" --> MANUAL[📋 Post Manual Issues<br/>to Discord]
    MANUAL --> LOOP_CHECK
    ROUTE -- "actions present" --> SUMMARY_CHECK

    SUMMARY_CHECK{Multiple<br/>actions?} -- Yes --> SUMMARY[📊 Post Summary<br/>to Discord]
    SUMMARY_CHECK -- No --> SPLIT
    SUMMARY --> SPLIT

    SPLIT[Split Actions<br/><i>one item per action</i>] --> LOOP_START

    %% ── Stage 3: Discord Approval ───────────────────────────────
    subgraph STAGE3["<b>Stage 3 — Discord Approval Gate</b>"]
        LOOP_START[Next Action] --> PREP[Prepare Discord Message<br/><i>risk level → emoji, color,<br/>timeout, default action</i>]
        PREP --> POST_MSG[Post to Discord<br/><i>via Bot API</i>]
        POST_MSG --> ADD_REACT[Add ✅ and ❌<br/>Reactions]
        ADD_REACT --> WAIT_POLL[⏳ Wait 20s]
        WAIT_POLL --> CHECK_APPROVE[Check ✅ Reactions]
        WAIT_POLL --> CHECK_REJECT[Check ❌ Reactions]
        CHECK_APPROVE & CHECK_REJECT --> EVALUATE[Evaluate Approval<br/><i>filter bot reactions,<br/>check timeout</i>]
        EVALUATE --> DECISION{Decision?}
        DECISION -- Pending --> WAIT_POLL
        DECISION -- Rejected --> REJECTED[❌ Post Rejection<br/>to Discord]
    end

    DECISION -- Approved --> LAUNCH

    %% ── Stage 4: Automation Execution ───────────────────────────
    subgraph STAGE4["<b>Stage 4 — Automation Execution</b>"]
        LAUNCH[Build Platform Config<br/><i>AWX or Semaphore<br/>URLs, body, auth</i>]
        LAUNCH --> FIRE[Launch Job<br/><i>POST to API</i>]
        FIRE --> EXTRACT_ID[Extract Job ID]
        EXTRACT_ID --> JOB_WAIT[⏳ Wait 20s]
        JOB_WAIT --> JOB_POLL[Poll Job Status<br/><i>GET job endpoint</i>]
        JOB_POLL --> JOB_CHECK[Check Job Status<br/><i>JS: poll counter,<br/>max wait enforcement</i>]
        JOB_CHECK --> JOB_DONE{Status?}
        JOB_DONE -- Running --> JOB_WAIT
        JOB_DONE -- Timed out --> JOB_FAIL[⚠️ Job Timeout]
    end

    JOB_DONE -- "Complete<br/>(success or failed)" --> VERIFY

    %% ── Stage 5: Verification ───────────────────────────────────
    subgraph STAGE5["<b>Stage 5 — Verification & Closing</b>"]
        VERIFY[Format Job Output<br/><i>extract stdout,<br/>query Loki for<br/>post-remediation logs</i>]
        VERIFY --> LOKI_POST[Fetch Post-Remediation<br/>Logs from Loki<br/><i>last 5 minutes</i>]
        LOKI_POST --> AI_VERIFY[Claude Verifies Result<br/><i>job output + fresh logs</i>]
        AI_VERIFY --> DISCORD_RESULT[📋 Post Result<br/>to Discord<br/><i>structured feedback</i>]
    end

    %% ── Loop Back ───────────────────────────────────────────────
    DISCORD_RESULT --> LOOP_CHECK{More actions<br/>in queue?}
    REJECTED --> LOOP_CHECK
    JOB_FAIL --> LOOP_CHECK
    LOOP_CHECK -- Yes --> LOOP_START
    LOOP_CHECK -- No --> DONE_FINAL([✅ Workflow Complete])

    %% ── Styling ─────────────────────────────────────────────────
    classDef stage1 fill:#e8f4f8,stroke:#2196F3,stroke-width:2px
    classDef stage2 fill:#fef3e2,stroke:#FF9800,stroke-width:2px
    classDef stage3 fill:#f3e5f5,stroke:#9C27B0,stroke-width:2px
    classDef stage4 fill:#e8f5e9,stroke:#4CAF50,stroke-width:2px
    classDef stage5 fill:#fff3e0,stroke:#FF5722,stroke-width:2px
    classDef terminal fill:#f5f5f5,stroke:#607D8B,stroke-width:2px,stroke-dasharray: 5 5

    class STAGE1 stage1
    class STAGE2 stage2
    class STAGE3 stage3
    class STAGE4 stage4
    class STAGE5 stage5
    class DONE_CLEAN,DONE_OK,DONE_FINAL,START terminal