azuro_executor.py

"""
Azuro executor: place bets for entries that have _azuro_outcome set.
Uses azuro_relayer.place_bet; stake = unit_dollars * unit_map[colour].
"""
from __future__ import annotations

import logging
from typing import Any

import azuro_relayer

logger = logging.getLogger(__name__)


def execute_small_for_entries(
    entries: list[dict],
    colours: list[str],
    unit_dollars: float,
    unit_map: dict[str, float],
    dry_run: bool = False,
) -> tuple[bool, str | None]:
    """
    For each entry with _azuro_outcome, place one ordinar bet.
    colours[i] = "GREEN"|"YELLOW"|"RED" for entries[i].
    stake = unit_dollars * unit_map[colour]; default unit_map e.g. {"GREEN": 3.0, "YELLOW": 2.0, "RED": 0.5}.
    Returns (placed: bool, order_id: str | None). order_id is the last placed order ID if any.
    """
    if not entries or not colours:
        return (False, None)
    placed = False
    order_id: str | None = None
    for i, entry in enumerate(entries):
        outcome = entry.get("_azuro_outcome")
        if not outcome:
            continue
        colour = colours[i] if i < len(colours) else "GREEN"
        coef = unit_map.get(colour) if isinstance(unit_map, dict) else 1.0
        if coef is None or coef <= 0:
            coef = 1.0
        stake = unit_dollars * float(coef)
        try:
            condition_id = getattr(outcome, "market_id", None) or (outcome.get("market_id") if isinstance(outcome, dict) else None)
            outcome_id = getattr(outcome, "outcome_id", None) or (outcome.get("outcome_id") if isinstance(outcome, dict) else None)
            odds_decimal = getattr(outcome, "odds", None) or (outcome.get("odds") if isinstance(outcome, dict) else None)
            if not condition_id or outcome_id is None or odds_decimal is None:
                logger.warning("Executor: entry missing market_id/outcome_id/odds")
                continue
            result = azuro_relayer.place_bet(
                condition_id=str(condition_id),
                outcome_id=int(outcome_id),
                odds_decimal=float(odds_decimal),
                amount_usd=stake,
                dry_run=dry_run,
            )
            if result is not None:
                placed = True
                order_id = result.get("order_id")
                if dry_run:
                    logger.info("Executor: dry run would place %s USDT on %s / %s", stake, condition_id, outcome_id)
                else:
                    logger.info("Executor: placed %s USDT on %s / %s -> %s", stake, condition_id, outcome_id, result.get("order_id"))
            else:
                logger.warning("Executor: place_bet returned None for entry %s", i)
        except Exception as e:
            logger.exception("Executor: error placing bet for entry %s: %s", i, e)
    return (placed, order_id)