graph TB
    subgraph Dashboard["🖥️ OmniFix Dashboard (Dark Glassmorphism UI)"]
        UI[Real-time Agent Graph] --> WS[WebSocket Events]
        UI --> PIPELINE[Pipeline Visualizer]
        UI --> LOGS[Live Log Stream]
    end

    subgraph API["⚡ FastAPI Gateway"]
        REST[REST Endpoints] --> EXECUTE[/api/workflows/execute]
        WS_EP[WebSocket /ws/events] --> BUS[Event Bus]
    end

    subgraph MCP["🔌 FastMCP Server"]
        TOOL1[execute_workflow tool]
        TOOL2[validate_output tool]
        TOOL3[log_execution tool]
        RES1[workflow://state resource]
        PROMPT1[decompose_task prompt]
        PROMPT2[error_recovery prompt]
    end

    subgraph GRAPH["🕸️ LangGraph StateGraph"]
        PLANNER[🧠 PlannerAgent] -->|steps| EXECUTOR[⚙️ ExecutorAgent]
        EXECUTOR -->|output| VALIDATOR[✅ ValidatorAgent]
        EXECUTOR -->|error| RECOVERY[🔧 RecoveryAgent]
        VALIDATOR -->|retry| EXECUTOR
        RECOVERY -->|healed| EXECUTOR
    end

    subgraph SPECIALISTS["🤖 Specialist Agent Pool"]
        DE[📝 DataEntryAgent<br/>Playwright + Forms]
        DP[📄 DocProcessorAgent<br/>EasyOCR + LLM]
        DM[🎯 DecisionAgent<br/>Rules + ML + HITL]
        CA[📨 CommunicationAgent<br/>Slack + Gmail + Notion]
    end

    subgraph INFRA["🏗️ Infrastructure"]
        REDIS[(Redis<br/>Workflow State)]
        POSTGRES[(PostgreSQL<br/>History + Analytics)]
    end

    Dashboard -->|HTTP/WS| API
    API --> MCP
    MCP --> GRAPH
    GRAPH --> SPECIALISTS
    GRAPH --> INFRA

📧 Gmail Monitor → 🔍 OCR Extract → ✅ PO Validate → 💻 Accounting Entry
                                                              ↓
📑 Report Generate ← 🗃️ Archive Drive ← 💬 Slack Approval ← 📊 Notion Budget

# Tools
await client.call_tool("execute_workflow", {"workflow_name": "invoice_processing", "input_data": {...}})
await client.call_tool("validate_output",  {"workflow_id": "abc-123", "expected_schema": {...}})
await client.call_tool("log_execution",    {"workflow_id": "abc-123", "step": "OCR", "status": "success"})

# Resources
state = await client.read_resource("workflow://state/abc-123")
history = await client.read_resource("workflow://execution_history")

# Prompts
plan_prompt = await client.get_prompt("decompose_task", {"task_description": "process invoices"})

# Just open in browser — works 100% offline!
start dashboard/index.html

git clone https://github.com/Soumo04/OmniFix-Autonomous-SRE-Remediation-Agent-.git
cd OmniFix-Autonomous-SRE-Remediation-Agent-

# Copy env (mock LLM works out of the box)
cp .env.example .env

# Launch everything
docker-compose up -d

# Open dashboard
start http://localhost:8000

pip install -r requirements.txt

# Start API server
python -m src.api.main

# (Optional) Start MCP server  
python -m src.mcp_server.autoflow_mcp_server

# Open dashboard
start dashboard/index.html

# Install dev deps
pip install -r requirements.txt pytest pytest-asyncio

# Run all tests
pytest tests/ -v --tb=short

# Run with coverage
pytest tests/ --cov=src --cov-report=html

OmniFix/
├── src/
│   ├── core/           # Config, logging, Redis/DB clients
│   ├── mcp_server/     # FastMCP server (tools/resources/prompts)
│   ├── orchestration/  # LangGraph StateGraph + routing
│   ├── agents/         # Base + 4 core + 4 specialist agents
│   └── api/            # FastAPI + WebSocket event bus
├── dashboard/
│   ├── index.html      # Single-page glassmorphism dashboard
│   ├── css/            # Dark design system
│   └── js/             # D3 graph + real-time events
├── tests/              # Async pytest suite
├── docker-compose.yml  # One-command stack launch
└── Dockerfile          # Multi-stage build (api + mcp)