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