import logging
from apscheduler.schedulers.background import BackgroundScheduler
from app import database as db
from app import yodeck as yd
from app.zabbix import sync_to_zabbix
from app.config import YODECK_POLL_INTERVAL_MINUTES

log = logging.getLogger(__name__)


def poll_yodeck():
    log.info("Polling Yodeck API …")
    try:
        players = yd.get_all_screens()
        for p in players:
            db.upsert_player(p)
        current_ids = [p['id'] for p in players]
        removed = db.delete_players_not_in(current_ids)
        msg = f"Fetched {len(players)} players from Yodeck API"
        if removed:
            msg += f", removed {removed} deleted player(s)"
        db.add_log('yodeck_fetch', msg, {'count': len(players), 'removed': removed})
        log.info(msg)
        # Sync host list to Zabbix after a successful fetch
        sync_to_zabbix(players, db.add_log)
    except Exception as exc:
        msg = f"Yodeck poll failed: {exc}"
        db.add_log('error', msg)
        log.error(msg)


def start_scheduler():
    scheduler = BackgroundScheduler(daemon=True)
    scheduler.add_job(
        poll_yodeck,
        'interval',
        minutes=YODECK_POLL_INTERVAL_MINUTES,
        id='yodeck_poll',
    )
    scheduler.start()
    log.info("Scheduler started — Yodeck poll every %d minutes", YODECK_POLL_INTERVAL_MINUTES)
    # Run an initial poll immediately so the DB is populated at startup
    poll_yodeck()
    return scheduler