daily.py

"""Daily asynchronous workflow for capturing market scores."""

from __future__ import annotations

import asyncio
import logging
from typing import List, Tuple

from data_fetcher import RawFinancialData, fetch_raw
from db import get_connection, get_portfolio, insert_daily_analysis
from evaluator import evaluate

LOGGER = logging.getLogger(__name__)


async def run_daily() -> None:
    """Fetch scores for the current portfolio and persist them."""

    async with await get_connection() as conn:
        portfolio = await get_portfolio(conn)
        analyses: List[Tuple[str, float, str, float]] = []
        for position in portfolio:
            raw: RawFinancialData | None = fetch_raw(position["ticker"])
            if raw is None:
                LOGGER.warning("Skipping %s due to missing market data", position["ticker"])
                continue
            score, decision = evaluate(raw)
            price = float(raw.get("price") or 0)
            analyses.append((position["ticker"], score, decision, price))
        await insert_daily_analysis(conn, analyses)


if __name__ == "__main__":
    logging.basicConfig(level=logging.INFO)
    asyncio.run(run_daily())