From 39d52266612d10cafabacc684ac1a184513b76d9 Mon Sep 17 00:00:00 2001 From: Matt Johnson Date: Sat, 16 May 2026 20:51:46 +0000 Subject: [PATCH] feat(supervisor): wire USGS quake adapter - Add USGSQuakeAdapter to _ADAPTER_REGISTRY - Add CENTRAL_QUAKE stream to STREAM_SUBJECTS Co-Authored-By: Claude Opus 4.5 --- src/central/supervisor.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/central/supervisor.py b/src/central/supervisor.py index 7ce0daf..652ce44 100644 --- a/src/central/supervisor.py +++ b/src/central/supervisor.py @@ -16,6 +16,7 @@ from nats.js import JetStreamContext from central.adapter import SourceAdapter from central.adapters.nws import NWSAdapter from central.adapters.firms import FIRMSAdapter +from central.adapters.usgs_quake import USGSQuakeAdapter from central.cloudevents_wire import wrap_event from central.config_models import AdapterConfig from central.config_source import ConfigSource, DbConfigSource @@ -28,6 +29,7 @@ from central.stream_manager import StreamManager _ADAPTER_REGISTRY: dict[str, type[SourceAdapter]] = { "nws": NWSAdapter, "firms": FIRMSAdapter, + "usgs_quake": USGSQuakeAdapter, } CURSOR_DB_PATH = Path("/var/lib/central/cursors.db") @@ -37,6 +39,7 @@ STREAM_SUBJECTS = { "CENTRAL_WX": ["central.wx.>"], "CENTRAL_META": ["central.meta.>"], "CENTRAL_FIRE": ["central.fire.>"], + "CENTRAL_QUAKE": ["central.quake.>"], } # Recompute interval for stream max_bytes (1 hour)