@router.post("/webhooks/trigger") async def trigger_webhook(payload: WebhookPayload): async with httpx.AsyncClient() as client: response = await client.post( payload.url, json=payload.data, timeout=30.0 ) return {"status": response.status_code} @router.get("/webhooks/health") async def webhook_health(): return {"status": "ok"}