"""Cleanup job: deletes unconfirmed subscriptions older than the expiry window."""

from datetime import datetime, timezone, timedelta

from config import CONFIRMATION_EXPIRY_HOURS, SUPABASE_SERVICE_ROLE_KEY, SUPABASE_URL
from services.observability import setup_logger

logger = setup_logger(__name__)


def _get_service_client():
    """Lazy-import Supabase service client to avoid circular imports at module level."""
    from supabase import create_client
    return create_client(SUPABASE_URL, SUPABASE_SERVICE_ROLE_KEY)


async def cleanup_stale_subscriptions() -> int:
    """Delete pending subscriptions where created_at < now() - expiry window.

    Returns count of deleted subscriptions.
    """
    client = _get_service_client()
    cutoff = (datetime.now(timezone.utc) - timedelta(hours=CONFIRMATION_EXPIRY_HOURS)).isoformat()

    try:
        result = (
            client.table("alert_subscriptions")
            .delete()
            .eq("status", "pending")
            .lt("created_at", cutoff)
            .execute()
        )
        count = len(result.data) if result.data else 0
        logger.info(f"[cleanup] deleted {count} stale pending subscriptions")
        return count
    except Exception as exc:
        logger.error(f"[cleanup] failed: {exc}")
        return 0