"""Starter adapter: Venue B (simulated FIX/WebSocket/REST feed)."""
from __future__ import annotations

from datetime import datetime
from mercurymesh.contracts import MarketSignal


class VenueBAdapter:
    name = "venue-b"

    def extract_signal(self) -> MarketSignal:
        now = datetime.utcnow()
        signal = MarketSignal(
            venue_id=self.name,
            symbol="XYZ",
            timestamp=now,
            features={
                "liquidity_proxy": 0.75,
                "order_flow_intensity": 0.65,
                "volatility_proxy": 0.2,
            },
        )
        return signal