blob: d08011fae1e9913eb677ca3249584a934bb1d115 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
|
from sqlalchemy import select
from sqlalchemy.ext.asyncio import AsyncSession
from app.models import Subscription, Event, Delivery, Device
async def poll_builds_once(db: AsyncSession) -> None:
# Placeholder.
# Replace with sr.ht fetch logic.
# Strategy:
# 1. query distinct build subscriptions
# 2. fetch latest builds per source_id
# 3. create Event rows for unseen terminal states
# 4. create Delivery rows for enabled devices subscribed to matching event_type
subscribed = await db.execute(
select(Subscription).where(Subscription.source_type == "build", Subscription.is_enabled.is_(True))
)
subscriptions = subscribed.scalars().all()
# no-op until sr.ht integration is wired
_ = subscriptions
|
