File size: 1,297 Bytes
311871d | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 | """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
|