21 lines
635 B
Python
21 lines
635 B
Python
from fastapi import APIRouter, BackgroundTasks, Header, status
|
|
|
|
from app.config import get_settings
|
|
from app.ingest.pipeline import process_file
|
|
from app.webhook.auth import verify_secret
|
|
from app.webhook.models import NextcloudEvent
|
|
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
@router.post("/webhook", status_code=status.HTTP_202_ACCEPTED)
|
|
async def webhook(
|
|
event: NextcloudEvent,
|
|
background: BackgroundTasks,
|
|
x_webhook_secret: str | None = Header(default=None),
|
|
):
|
|
verify_secret(x_webhook_secret, get_settings().webhook_secret)
|
|
background.add_task(process_file, event.file_path, event.event_type)
|
|
return {"status": "accepted"}
|