krz/hutch-notify

 1from fastapi import APIRouter, Depends
 2from sqlalchemy.ext.asyncio import AsyncSession
 3from app.db import get_db
 4from app.schemas import SubscriptionUpsertIn
 5from app.crud import replace_subscriptions
 6from app.security import require_api_key
 7
 8router = APIRouter(prefix="/v1/subscriptions", tags=["subscriptions"], dependencies=[Depends(require_api_key)])
 9
10
11@router.post("/upsert")
12async def upsert_subscriptions(payload: SubscriptionUpsertIn, db: AsyncSession = Depends(get_db)) -> dict:
13    await replace_subscriptions(db, payload)
14    return {"status": "ok"}