API: globe-incidents Endpoint fuer Lage-Auswahl im Globe
Dieser Commit ist enthalten in:
@@ -229,6 +229,19 @@ async def globe_ingest(
|
|||||||
await db.commit()
|
await db.commit()
|
||||||
return {"ok": True, "inserted": inserted, "total_sent": len(events)}
|
return {"ok": True, "inserted": inserted, "total_sent": len(events)}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
@router.get("/globe-incidents", dependencies=[Depends(verify_api_key)])
|
||||||
|
async def get_globe_incidents(db=Depends(db_dependency)):
|
||||||
|
"""Liste aller oeffentlichen aktiven Lagen fuer Globe-Auswahl."""
|
||||||
|
cursor = await db.execute(
|
||||||
|
"""SELECT id, title, type, status, updated_at
|
||||||
|
FROM incidents
|
||||||
|
WHERE status IN ('active','archived') AND visibility = 'public'
|
||||||
|
ORDER BY updated_at DESC LIMIT 30"""
|
||||||
|
)
|
||||||
|
return [dict(r) for r in await cursor.fetchall()]
|
||||||
|
|
||||||
@router.get("/globe-feed", dependencies=[Depends(verify_api_key)])
|
@router.get("/globe-feed", dependencies=[Depends(verify_api_key)])
|
||||||
async def get_globe_feed(
|
async def get_globe_feed(
|
||||||
incident_id: int = None,
|
incident_id: int = None,
|
||||||
|
|||||||
In neuem Issue referenzieren
Einen Benutzer sperren