flowchart TD
    subgraph Compile-Time Phases
        A[Raw OpenAPI Specs] -->|Phase 1: Ingestion| B[OpenAPI Parser]
        B -->|OpenAPI schemas| C[AI Clustering Engine]
        C -->|Local Ollama/Instructor| D[(Workflow Mappings JSON)]
    end
    subgraph Runtime Execution
        E[MCP Clients] -->|MCP Protocol| F[FastMCP Server]
        D -->|Deterministic Routes| F
        F -->|Select Executor| G[BaseExecutor Interface]
        G -->|Hot-Swapped| H[HTTPX Executor]
        G -->|Hot-Swapped| I[Dell OM SDK / Redfish API]
    end

dell_mcp_proxy/
├── data/
│   ├── raw_specs/              # Downloaded raw Dell OpenAPI YAML/JSON specs
│   └── output/                 # Generated workflow_mapping.json mapping file
├── src/
│   ├── __init__.py
│   ├── core/                   # Shared Pydantic models, configurations, and exceptions
│   │   ├── __init__.py
│   │   ├── config.py
│   │   └── exceptions.py
│   ├── parser/                 # Phase 1: OpenAPI spec parsing and schema extraction
│   │   ├── __init__.py
│   │   └── openapi_parser.py
│   ├── ai_clustering/          # Phase 2: Offline clustering via Instructor/Ollama LLM
│   │   ├── __init__.py
│   │   └── workflow_generator.py
│   └── proxy/                  # Phase 3: FastMCP Server & Deterministic Routing
│       ├── __init__.py
│       ├── server.py           # FastMCP initialization & tool registrations
│       └── executors/          # Target execution engines
│           ├── __init__.py
│           ├── base.py         # BaseExecutor Abstract Base Class
│           └── httpx_executor.py # HTTPX executor implementation
├── tests/
│   ├── __init__.py
│   └── conftest.py
├── .env.example                # Local environment template variables
├── .flake8                     # Flake8 style config
├── pyproject.toml              # Project dependencies, packaging, and tool overrides
└── README.md                   # System documentation

curl -LsSf https://astral.sh/uv/install.sh | sh

# Sync environment and lock dependencies
uv sync

cp .env.example .env

source .venv/bin/activate

fastmcp list src/proxy/server.py

fastmcp dev src/proxy/server.py

# Code Formatting (Black)
uv run black --check .

# Code Linting (Flake8)
uv run flake8 .

# Strict Type Checking (Mypy)
uv run mypy .

# Run Tests
uv run pytest

from abc import ABC, abstractmethod
from typing import Any, Dict

class BaseExecutor(ABC):
    @abstractmethod
    async def execute_workflow(
        self, workflow_name: str, params: Dict[str, Any]
    ) -> Dict[str, Any]:
        """
        Asynchronously execute a clustered workflow.
        """
        pass