matt/central
1
0
Fork 0
mirror of https://github.com/zvx-echo6/central.git synced 2026-05-21 18:14:44 +02:00
Code Issues Projects Releases Packages Wiki Activity

feat(supervisor): wire USGS quake adapter

Browse source 
- Add USGSQuakeAdapter to _ADAPTER_REGISTRY
- Add CENTRAL_QUAKE stream to STREAM_SUBJECTS

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Matt Johnson 2026-05-16 20:51:46 +00:00
commit 39d5226661
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/central/supervisor.py
View file

@ -16,6 +16,7 @@ from nats.js import JetStreamContext
from central.adapter import SourceAdapter from central.adapter import SourceAdapter
from central.adapters.nws import NWSAdapter from central.adapters.nws import NWSAdapter
from central.adapters.firms import FIRMSAdapter from central.adapters.firms import FIRMSAdapter
from central.adapters.usgs_quake import USGSQuakeAdapter
from central.cloudevents_wire import wrap_event from central.cloudevents_wire import wrap_event
from central.config_models import AdapterConfig from central.config_models import AdapterConfig
from central.config_source import ConfigSource, DbConfigSource from central.config_source import ConfigSource, DbConfigSource
@ -28,6 +29,7 @@ from central.stream_manager import StreamManager
_ADAPTER_REGISTRY: dict[str, type[SourceAdapter]] = { _ADAPTER_REGISTRY: dict[str, type[SourceAdapter]] = {
"nws": NWSAdapter, "nws": NWSAdapter,
"firms": FIRMSAdapter, "firms": FIRMSAdapter,
"usgs_quake": USGSQuakeAdapter,
} }
CURSOR_DB_PATH = Path("/var/lib/central/cursors.db") CURSOR_DB_PATH = Path("/var/lib/central/cursors.db")
@ -37,6 +39,7 @@ STREAM_SUBJECTS = {
"CENTRAL_WX": ["central.wx.>"], "CENTRAL_WX": ["central.wx.>"],
"CENTRAL_META": ["central.meta.>"], "CENTRAL_META": ["central.meta.>"],
"CENTRAL_FIRE": ["central.fire.>"], "CENTRAL_FIRE": ["central.fire.>"],
"CENTRAL_QUAKE": ["central.quake.>"],
} }
# Recompute interval for stream max_bytes (1 hour) # Recompute interval for stream max_bytes (1 hour)