Logan CusanoandClaude Opus 5.5
aa5b71d853
Backend (c2-core):
- app/internal/cameras/: provider interface, licence model, per-provider
catalog cache; one adapter per source in design-canvas/camera-sources.md.
Implemented: 511NY (legacy shape + tolerant XML inventory parser, 511x
endpoints UNVERIFIED), Caltrans, DelDOT, Ontario 511, DriveBC, Calgary,
TfL, NSW, Fintraffic. Stubs: NYC DOT, Westchester DPW, TRANSCOM, CTroads,
511NJ, Austin, TxDOT, MD CHART, WSDOT, Tallinn, Tarktee, Warendorf,
TrafficLand, Windy, EarthCam.
- Every provider defaults OFF (config/camera_providers). Gated licences
(agreement required / unverified / non-commercial / paid) need an explicit
acknowledgement stored with who/when and written to audit_log; the audit
write is a precondition. Stubs and prohibited sources cannot be enabled.
Ack is bound to the licence status it was given for.
- GET /cameras (signed-in), GET/PUT /admin/camera-providers (admin only).
- /traffic/511 follows the ny511 provider switch and returns the DAA credit
+ NYSDOT as-is disclaimer; 511NY event descriptions no longer truncated
("may not alter the substance of a report").
Frontend:
- LiveView becomes the ops wall: Region > Incident > Camera drill-down,
worst-first rail (MapView), KPIs, transcript ticker, scrubber incident
bands, auto-tour, deep links (#inc=&cam=&tour), Esc steps up.
- Incident panel: nearest cameras (path-weighted), fused situational context
(ADS-B, AIS, 511NY events, NEXRAD tile sample), units, call spine.
- MapView keeps every layer; adds Camera Viewsheds (approx.) overlay and a
nearest-camera layer for the selected incident.
- CameraFeed hygiene: hidden-tab/off-screen gating, 2 concurrent HLS cap,
last good frame + stale badge, frozen-frame signature, HLS stall watchdog,
provider attribution rendered on the imagery.
- Camera/event popups show source credit, update time and the disclaimer.
- Admin > Camera providers tab with licence status, health, gated confirm.
- Camera detection is not built (blocked on #199/#200); seam only.
Co-Authored-By: Claude Opus 5.5 <noreply@anthropic.com>
48 lines
2.1 KiB
Python
48 lines
2.1 KiB
Python
import asyncio
|
|
from typing import Optional
|
|
|
|
from fastapi import APIRouter, HTTPException, Query
|
|
|
|
from app.internal import ny511
|
|
from app.internal.cameras import registry
|
|
|
|
router = APIRouter(prefix="/traffic", tags=["traffic"])
|
|
|
|
# Per-layer cap per response. A statewide view is ~3k cameras; past this the
|
|
# map is unreadable anyway, and the client is told the list was cut.
|
|
MAX_ITEMS = 1500
|
|
|
|
|
|
def _feed_status(feed: "ny511._Feed") -> dict:
|
|
return {"fetched_at": feed.fetched_at, "error": feed.error}
|
|
|
|
|
|
@router.get("/511")
|
|
async def get_511(
|
|
south: float = Query(..., ge=-90, le=90),
|
|
west: float = Query(..., ge=-180, le=180),
|
|
north: float = Query(..., ge=-90, le=90),
|
|
east: float = Query(..., ge=-180, le=180),
|
|
layers: Optional[str] = Query("cameras,events", description="comma list: cameras, events"),
|
|
):
|
|
if south > north or west > east:
|
|
raise HTTPException(400, "bbox must satisfy south<=north and west<=east")
|
|
wanted = {s.strip() for s in (layers or "").split(",") if s.strip()}
|
|
# 511NY data (events included) is covered by the same NYSDOT DAA as its
|
|
# cameras, so the whole feed follows the ny511 camera provider's switch,
|
|
# which defaults OFF and needs a licence acknowledgement (server-26#198).
|
|
if not await registry.is_serving("ny511"):
|
|
off = {"fetched_at": None, "error": None, "total_in_bbox": 0, "truncated": False, "disabled": True}
|
|
return {**{n: [] for n in ("cameras", "events") if n in wanted},
|
|
**{f"{n}_status": off for n in ("cameras", "events") if n in wanted}}
|
|
feeds = {name: getattr(ny511, name) for name in ("cameras", "events") if name in wanted}
|
|
await asyncio.gather(*(f.get() for f in feeds.values()))
|
|
|
|
out: dict = {}
|
|
for name, feed in feeds.items():
|
|
hits = ny511.in_bbox(feed.items, south, west, north, east)
|
|
out[name] = hits[:MAX_ITEMS]
|
|
out[f"{name}_status"] = {**_feed_status(feed), "total_in_bbox": len(hits), "truncated": len(hits) > MAX_ITEMS}
|
|
out["credit"] = registry.credit("ny511") # DAA: source credit + as-is disclaimer travel with the data
|
|
return out
|