100-exchange-integration

🔗 INTEGRACIÓN CON EXCHANGES — TRADING TERMINAL

PRINCIPIO: ADAPTADOR UNIVERSAL

El sistema NUNCA debe depender directamente de la API de un exchange específico. Todos los exchanges se acceden a través de un adaptador que implementa la misma interfaz. Esto permite cambiar de Binance a MT5 sin tocar el resto del código.

🏗️ INTERFAZ BASE DEL EXCHANGE

# adapters/base_exchange.py

from abc import ABC, abstractmethod
from decimal import Decimal
from typing import AsyncIterator
from dataclasses import dataclass
from datetime import datetime

@dataclass
class OrderResult:
    order_id: str
    symbol: str
    side: str
    order_type: str
    quantity: Decimal
    fill_price: Decimal
    status: str
    timestamp: datetime
    exchange: str

@dataclass
class Ticker:
    symbol: str
    price: Decimal
    bid: Decimal
    ask: Decimal
    volume_24h: Decimal
    change_24h_pct: Decimal
    timestamp: datetime

@dataclass
class Balance:
    asset: str
    free: Decimal
    locked: Decimal

    @property
    def total(self) -> Decimal:
        return self.free + self.locked

class BaseExchangeAdapter(ABC):
    """
    Interfaz que TODOS los exchanges deben implementar.

    Si agregas un exchange nuevo, implementa esta clase.
    No modifiques el código que llama a esta interfaz.
    """

    @abstractmethod
    async def get_ticker(self, symbol: str) -> Ticker:
        """Obtener precio actual y datos de mercado."""
        ...

    @abstractmethod
    async def get_balances(self) -> list[Balance]:
        """Obtener todos los balances de la cuenta."""
        ...

    @abstractmethod
    async def place_order(
        self,
        symbol: str,
        side: str,          # "BUY" o "SELL"
        order_type: str,    # "MARKET" o "LIMIT"
        quantity: Decimal,
        price: Decimal | None = None
    ) -> OrderResult:
        """Enviar orden al exchange."""
        ...

    @abstractmethod
    async def cancel_order(self, symbol: str, order_id: str) -> bool:
        """Cancelar orden pendiente."""
        ...

    @abstractmethod
    async def get_order_status(self, symbol: str, order_id: str) -> OrderResult:
        """Consultar estado de una orden."""
        ...

    @abstractmethod
    async def stream_prices(self, symbol: str) -> AsyncIterator[Ticker]:
        """Stream de precios en tiempo real."""
        ...