Unit 5: FastAPI REST API & SSE Streaming

[guglxni]

Scope

All HTTP endpoints, SSE streaming for live investigation, middleware

Package

• chronos/api/ — Routes, middleware
• chronos/main.py — FastAPI app entrypoint

Deliverables

• chronos/main.py — FastAPI app with lifespan
• chronos/api/routes/webhooks.py — OM + OL webhook receivers
• chronos/api/routes/incidents.py — Incident CRUD (list, detail, ack, resolve)
• chronos/api/routes/investigations.py — Manual trigger + SSE stream
• chronos/api/routes/stats.py — Dashboard statistics
• chronos/api/middleware.py — Error handling + logging
• Health check endpoint

API Spec

POST /api/v1/webhooks/openmetadata
POST /api/v1/webhooks/openlineage
GET  /api/v1/incidents
GET  /api/v1/incidents/{id}
POST /api/v1/incidents/{id}/acknowledge
POST /api/v1/incidents/{id}/resolve
GET  /api/v1/investigations/{id}/stream (SSE)
POST /api/v1/investigate
GET  /api/v1/stats
GET  /api/v1/health

Dependencies

Units 3 + 4

Timeline

Days 6-7