fix(seismic): handle EMSC 204, widen Azores radius, bootstrap feeds on deploy

EMSC returns empty 204 for zero results — treat as no events instead of JSON
error. Use archipelago-scale radius (400km min) and 30-day lookback. Queue
news + seismic Celery syncs from runserver.sh after migrate.

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: hc-sousa

src/runserver.sh

@@ -3,5 +3,6 @@ set -euo pipefail
 
 python manage.py collectstatic --no-input
 python manage.py migrate --no-input
+python manage.py bootstrap_feed_syncs
 python manage.py ensure_superuser
 gunicorn src.wsgi --bind="0.0.0.0:${WEB_CONTAINER_PORT:-8000}" --workers="${GUNICORN_WORKERS:-3}" --timeout 120

src/seismic/services.py

@@ -18,8 +18,10 @@
 logger = logging.getLogger(__name__)
 
 FDSN_EVENT_URL = 'https://www.seismicportal.eu/fdsnws/event/1/query'
-DEFAULT_MIN_MAGNITUDE = 2.5
-DEFAULT_LOOKBACK_DAYS = 7
+DEFAULT_MIN_MAGNITUDE = 2.0
+DEFAULT_LOOKBACK_DAYS = 30
+# Island.radius_km is transit-local (~50); seismic covers the whole archipelago.
+SEISMIC_MIN_RADIUS_KM = 400
 KM_PER_DEGREE_LAT = 111.0
 REQUEST_TIMEOUT_SECONDS = 30
 
@@ -85,7 +87,8 @@ def _parse_feature(feature: dict[str, Any]) -> dict[str, Any] | None:
 
 def build_fdsn_params(island: Island) -> dict[str, str]:
     start = timezone.now() - timedelta(days=DEFAULT_LOOKBACK_DAYS)
-    max_radius_deg = _km_to_degrees(float(island.radius_km))
+    radius_km = max(float(island.radius_km), float(SEISMIC_MIN_RADIUS_KM))
+    max_radius_deg = _km_to_degrees(radius_km)
     return {
         'format': 'json',
         'starttime': start.strftime('%Y-%m-%dT%H:%M:%S'),
@@ -103,6 +106,8 @@ def fetch_events_for_island(island: Island) -> list[dict[str, Any]]:
     params = build_fdsn_params(island)
     response = requests.get(FDSN_EVENT_URL, params=params, timeout=REQUEST_TIMEOUT_SECONDS)
     response.raise_for_status()
+    if response.status_code == 204 or not response.content.strip():
+        return []
     payload = response.json()
     features = payload.get('features') or []
     if not isinstance(features, list):

src/seismic/tests/test_services.py

@@ -59,6 +59,8 @@ def test_parse_feature_maps_fields(self):
     @patch('seismic.services.requests.get')
     def test_sync_events_upserts_without_duplicates(self, mock_get):
         mock_response = MagicMock()
+        mock_response.status_code = 200
+        mock_response.content = b'{"features": []}'
         mock_response.raise_for_status = MagicMock()
         mock_response.json.return_value = SAMPLE_FEATURES
         mock_get.return_value = mock_response
@@ -76,10 +78,24 @@ def test_sync_events_upserts_without_duplicates(self, mock_get):
     @patch('seismic.services.requests.get')
     def test_sync_empty_features(self, mock_get):
         mock_response = MagicMock()
+        mock_response.status_code = 200
+        mock_response.content = b'{"features": []}'
         mock_response.raise_for_status = MagicMock()
         mock_response.json.return_value = {'features': []}
         mock_get.return_value = mock_response
 
         counts = sync_events_for_island(self.island)
         self.assertEqual(counts['created'], 0)
         self.assertEqual(SeismicEvent.objects.count(), 0)
+
+    @patch('seismic.services.requests.get')
+    def test_sync_emsc_nodata_204(self, mock_get):
+        mock_response = MagicMock()
+        mock_response.status_code = 204
+        mock_response.content = b''
+        mock_response.raise_for_status = MagicMock()
+        mock_get.return_value = mock_response
+
+        counts = sync_events_for_island(self.island)
+        self.assertEqual(counts['created'], 0)
+        self.assertEqual(SeismicEvent.objects.count(), 0)

src/shared/management/commands/bootstrap_feed_syncs.py

@@ -0,0 +1,39 @@
+"""Queue one-shot feed sync Celery jobs after deploy."""
+
+from __future__ import annotations
+
+import logging
+
+from django.core.management.base import BaseCommand
+
+logger = logging.getLogger(__name__)
+
+FEED_TASKS: tuple[tuple[str, str], ...] = (
+    ('news', 'news.poll_sources'),
+    ('seismic', 'seismic.sync_events'),
+)
+
+
+class Command(BaseCommand):
+    help = 'Queue initial news and seismic feed sync tasks (runs after migrate on deploy).'
+
+    def handle(self, *args: object, **options: object) -> None:
+        queued: list[str] = []
+        for label, task_name in FEED_TASKS:
+            try:
+                if label == 'news':
+                    from news.tasks import poll_sources_task
+
+                    poll_sources_task.delay()
+                elif label == 'seismic':
+                    from seismic.tasks import sync_events_task
+
+                    sync_events_task.delay()
+                queued.append(task_name)
+            except Exception:
+                logger.exception('bootstrap_feed_syncs failed to queue %s', task_name)
+
+        if queued:
+            self.stdout.write(f'Queued feed sync tasks: {", ".join(queued)}')
+        else:
+            self.stdout.write('No feed sync tasks were queued (check Celery broker).')