SuperintelA Personal Quantitative Trading Platform — Ports, Adapters & a 22-Model Ensemble

1def get_price_data_repository(
2    db_client=None,
3) -> PriceDataRepositoryPort:
4    """
5    Domain code calls this and receives a PriceDataRepositoryPort.
6    It never sees Postgres, Redis, or any infrastructure symbol.
7    """
8    impl = os.getenv("PRICE_DATA_REPO_IMPL", "postgres")
9
10    match impl:
11        case "postgres":
12            return PostgresPriceDataRepository(
13                db_client or get_db_client()
14            )
15        case "memory":
16            return InMemoryPriceDataRepository()
17        case "mock":
18            return MockPriceDataRepository()
19        case _:
20            raise ValueError(f"Unknown adapter: {impl}")
21
22
23# DDD compliance test — validates the contract holds
24def test_adapter_swap_produces_same_contract():
25    for impl in ["postgres", "memory", "mock"]:
26        os.environ["PRICE_DATA_REPO_IMPL"] = impl
27        repo = get_price_data_repository()
28        assert isinstance(repo, PriceDataRepositoryPort)
29        assert hasattr(repo, "get_prices")
30        assert hasattr(repo, "write_prices")

1class CompositeBrokerAdapter(BrokerPort):
2    """
3    Routes orders by asset_type.
4    Upstream code only sees BrokerPort — no IBKR/Binance imports.
5    """
6    def __init__(
7        self,
8        ibkr: IBKRAdapter,
9        binance: BinanceAdapter,
10    ):
11        self._ibkr    = ibkr
12        self._binance = binance
13
14    async def submit_order(
15        self, order: PairOrder
16    ) -> OrderResult:
17        match order.asset_type:
18            case AssetType.EQUITY:
19                return await self._ibkr.submit_order(order)
20            case AssetType.CRYPTO:
21                return await self._binance.submit_order(order)
22            case _:
23                raise UnsupportedAssetTypeError(
24                    order.asset_type
25                )
26
27    async def get_positions(self) -> list[Position]:
28        equity = await self._ibkr.get_positions()
29        crypto = await self._binance.get_positions()
30        return equity + crypto