"""Orchestrator for the complete data acquisition pipeline."""

from __future__ import annotations

import asyncio

from src.utils import ensure_dirs, setup_logging
from src.api.polymarket import fetch_all_data as fetch_polymarket
from src.api.fred import fetch_all_fred_data
from src.api.yahoo import fetch_all_yahoo_data


def run_all() -> None:
    """Run complete data acquisition pipeline."""
    ensure_dirs()
    logger = setup_logging("data_acquisition")
    logger.info("Starting data acquisition pipeline")

    # Polymarket (async)
    logger.info("--- Phase 1/3: Polymarket ---")
    asyncio.run(fetch_polymarket())

    # FRED
    logger.info("--- Phase 2/3: FRED ---")
    fetch_all_fred_data()

    # Yahoo Finance
    logger.info("--- Phase 3/3: Yahoo Finance ---")
    fetch_all_yahoo_data()

    logger.info("Data acquisition complete")


if __name__ == "__main__":
    run_all()