mirror of
https://github.com/Sea-Haven-Industries/open-swe.git
synced 2026-09-30 12:43:16 +00:00
28 lines
981 B
Python
28 lines
981 B
Python
|
"""Health and run-completion routes."""
|
||
|
|
|
||
|
|
from fastapi import APIRouter, HTTPException, Request
|
||
|
|
|
||
|
|
from ..completion import handle_run_completion, verify_run_complete_token
|
||
|
|
|
||
|
|
router = APIRouter()
|
||
|
|
|
||
|
|
|
||
|
|
@router.get("/health")
|
||
|
|
async def health_check() -> dict[str, str]:
|
||
|
|
"""Health check endpoint."""
|
||
|
|
return {"status": "healthy"}
|
||
|
|
|
||
|
|
|
||
|
|
@router.post("/webhooks/run-complete")
|
||
|
|
async def run_complete_webhook(request: Request) -> dict[str, str]:
|
||
|
|
"""Platform run-completion webhook: post a failure reply for runs that died."""
|
||
|
|
if not verify_run_complete_token(request.query_params.get("token")):
|
||
|
|
raise HTTPException(status_code=401, detail="Invalid run-complete token")
|
||
|
|
try:
|
||
|
|
payload = await request.json()
|
||
|
|
except Exception: # noqa: BLE001
|
||
|
|
return {"status": "error", "message": "Invalid JSON"}
|
||
|
|
if not isinstance(payload, dict):
|
||
|
|
return {"status": "ignored", "reason": "payload not an object"}
|
||
|
|
return await handle_run_completion(payload)
|