flowchart TD
    UI["LogiLink Mission Control Cockpit"]
    
    subgraph Orchestration["Agent-to-Agent Coordination Layer"]
        COORD["Coordinator Orchestrator<br/><i>(smolagents + Ollama LLM)</i>"]
    end

    subgraph Specialists["Specialist Agent Swarm (Google A2A Protocol)"]
        direction LR
        SHIP["Shipment Agent<br/><b>Port :8101</b><br/><i>Telemetry & Anomaly Diagnosis</i>"]
        KNOW["Knowledge Agent<br/><b>Port :8102</b><br/><i>SOP Retrieval & Vector Search</i>"]
        INV["Inventory Agent<br/><b>Port :8103</b><br/><i>Safety Stock & DC Allocation</i>"]
        ESC["Escalation Agent<br/><b>Port :8104</b><br/><i>IoT Telematics & Carrier Claims</i>"]
    end

    subgraph Tooling["Model Context Protocol (FastMCP)"]
        MCP["Logistics FastMCP Server<br/><i>(Tool Execution Engine)</i>"]
    end

    subgraph Storage["Persistent Logistics Data Layer"]
        direction LR
        D_SHIP[("Shipment Status &<br/>Carrier Scans")]
        D_SOP[("Markdown SOP<br/>Catalog")]
        D_INV[("Regional Warehouses &<br/>Safety Stock")]
        D_IOT[("IoT Sensor Telemetry &<br/>Carrier Contracts")]
    end

    UI -->|REST / Run Scenario| COORD
    COORD -->|A2A JSON-RPC :8101| SHIP
    COORD -->|A2A JSON-RPC :8102| KNOW
    COORD -->|A2A JSON-RPC :8103| INV
    COORD -->|A2A JSON-RPC :8104| ESC

    SHIP -->|FastMCP Tool Calls| MCP
    KNOW -->|FastMCP Tool Calls| MCP
    INV -->|FastMCP Tool Calls| MCP
    ESC -->|FastMCP Tool Calls| MCP

    MCP --> D_SHIP
    MCP --> D_SOP
    MCP --> D_INV
    MCP --> D_IOT

    COORD -.->|Live SSE Stream / Real-time Status| UI

    classDef ui fill:#1e293b,stroke:#38bdf8,stroke-width:2px,color:#f8fafc;
    classDef coord fill:#0f172a,stroke:#818cf8,stroke-width:2px,color:#f8fafc;
    classDef specialist fill:#1e293b,stroke:#34d399,stroke-width:1.5px,color:#f8fafc;
    classDef mcp fill:#1e293b,stroke:#f59e0b,stroke-width:2px,color:#f8fafc;
    classDef data fill:#0f172a,stroke:#94a3b8,stroke-width:1px,color:#cbd5e1;

    class UI ui;
    class COORD coord;
    class SHIP,KNOW,INV,ESC specialist;
    class MCP mcp;
    class D_SHIP,D_SOP,D_INV,D_IOT data;

sequenceDiagram
    autonumber
    actor Operator as Logistics Operator / UI
    participant Coord as Coordinator Agent
    participant Ship as Shipment Agent (:8101)
    participant Know as Knowledge Agent (:8102)
    participant Inv as Inventory Agent (:8103)
    participant Esc as Escalation Agent (:8104)
    participant MCP as Logistics FastMCP Server

    Operator->>Coord: Trigger Incident Investigation (e.g. SHP-7701)
    
    rect rgb(30, 41, 59)
    Note over Coord,Ship: Phase 1: Anomaly Diagnosis
    Coord->>Ship: A2A Request: Diagnose Status & Timeline
    Ship->>MCP: Call get_shipment_status & get_carrier_events
    MCP-->>Ship: Telemetry Data (Status: CRITICAL_ALERT)
    Ship->>MCP: Call analyse_shipment_events
    MCP-->>Ship: Deterministic Issue: TEMPERATURE_EXCURSION
    Ship-->>Coord: A2A Response: Diagnosed Issue & Evidence
    end

    rect rgb(30, 41, 59)
    Note over Coord,Know: Phase 2: SOP Compliance Matching
    Coord->>Know: A2A Request: Retrieve Remediation Protocol
    Know->>MCP: Call search_sop(TEMPERATURE_EXCURSION)
    MCP-->>Know: SOP Markdown: cold_chain_excursion
    Know-->>Coord: A2A Response: Matched Actions & Guidelines
    end

    rect rgb(30, 41, 59)
    Note over Coord,Inv: Phase 3: Warehouse Buffer Allocation
    Coord->>Inv: A2A Request: Check Buffer & Reserve Replacement
    Inv->>MCP: Call query_warehouse_inventory(SKU-PHARM-770)
    MCP-->>Inv: Stock Levels (Berlin DC: 14 units available)
    Inv->>MCP: Call reserve_replacement_stock(quantity=1)
    MCP-->>Inv: Reservation Confirmed (RES-EEBF8425)
    Inv-->>Coord: A2A Response: Buffer Reserved & DC Details
    end

    rect rgb(30, 41, 59)
    Note over Coord,Esc: Phase 4: SLA Claim & Carrier Ticket
    Coord->>Esc: A2A Request: Inspect IoT & Escalate Claim
    Esc->>MCP: Call get_iot_telemetry(SHP-7701)
    MCP-->>Esc: Sensor Log (14.2°C Excursion >30min in Bay 4)
    Esc->>MCP: Call generate_carrier_ticket(SLA breach, Priority: HIGH)
    MCP-->>Esc: Ticket Created (ESC-516629, Penalty Clause active)
    Esc-->>Coord: A2A Response: Ticket Details & Carrier Desk
    end

    Coord->>Operator: Synthesized Operational Resolution (Markdown)

# Clone the repository
git clone https://github.com/CagriCatik/LogiLink.git
cd LogiLink

# Create virtual environment & install Python dependencies
uv venv .venv
uv pip install --python .venv -e ".[dev]"

cd frontend
npm install
npm run build
cd ..

# Start the Visual Cockpit on http://localhost:8006
python main.py

python main.py --mode=chat --model="gpt-oss:120b-cloud"

python scratch/test_all_scenarios_e2e.py

python scratch/verify_all_scenarios_ui.py

pytest