feat: worker generates maps for all indicators, serves spatial JSON

- Switch worker to new render_indicator_map/render_status_map signatures
- Generate map PNG for every indicator (not just ones with SpatialData)
- Serialize spatial data to JSON after each indicator for frontend use
- Add GET /api/jobs/{job_id}/spatial/{indicator_id} endpoint in main.py

Generated with [Claude Code](https://claude.ai/code)
via [Happy](https://happy.engineering)

Co-Authored-By: Claude <noreply@anthropic.com>
Co-Authored-By: Happy <yesreply@happy.engineering>

app/main.py

@@ -103,6 +103,18 @@ def create_app(db_path: str = "aperture.db", run_worker: bool = False) -> FastAP
             media_type="image/png",
         )
 
+    @app.get("/api/jobs/{job_id}/spatial/{indicator_id}")
+    async def get_indicator_spatial(job_id: str, indicator_id: str, email: str = Depends(get_current_user)):
+        await _verify_job_access(job_id, email)
+        spatial_path = _HERE.parent / "results" / job_id / f"{indicator_id}_spatial.json"
+        if not spatial_path.exists():
+            raise HTTPException(status_code=404, detail="Spatial data not available for this indicator")
+        import json as _json
+        with open(spatial_path) as f:
+            data = _json.load(f)
+        from fastapi.responses import JSONResponse
+        return JSONResponse(content=data)
+
     # ── Static files + SPA root ───────────────────────────────────────
     if _FRONTEND_DIR.exists():
         app.mount("/static", StaticFiles(directory=str(_FRONTEND_DIR)), name="static")

app/worker.py

@@ -1,5 +1,6 @@
 from __future__ import annotations
 import asyncio
+import json
 import logging
 import os
 import traceback
@@ -9,12 +10,38 @@ from app.models import JobStatus
 from app.outputs.report import generate_pdf_report
 from app.outputs.package import create_data_package
 from app.outputs.charts import render_timeseries_chart
-from app.outputs.maps import render_indicator_map
+from app.outputs.maps import render_indicator_map, render_status_map
 from app.core.email import send_completion_email
 
 logger = logging.getLogger(__name__)
 
 
+def _save_spatial_json(spatial, status_value: str, path: str) -> None:
+    """Serialize spatial data to JSON for the frontend."""
+    if spatial is None:
+        obj = {"map_type": "status", "status": status_value}
+    elif spatial.map_type == "grid":
+        obj = {
+            "map_type": "grid",
+            "status": status_value,
+            "data": spatial.data.tolist(),
+            "lats": spatial.lats.tolist(),
+            "lons": spatial.lons.tolist(),
+            "label": spatial.label,
+            "colormap": spatial.colormap,
+        }
+    else:
+        obj = {
+            "map_type": spatial.map_type,
+            "status": status_value,
+            "geojson": spatial.geojson,
+            "label": spatial.label,
+            "colormap": spatial.colormap,
+        }
+    with open(path, "w") as f:
+        json.dump(obj, f)
+
+
 async def process_job(job_id: str, db: Database, registry: IndicatorRegistry) -> None:
     job = await db.get_job(job_id)
     if job is None:
@@ -57,22 +84,27 @@ async def process_job(job_id: str, db: Database, registry: IndicatorRegistry) ->
             )
             output_files.append(chart_path)
 
-            # Generate map PNG if spatial data is available
+            # Generate map PNG for every indicator
             spatial = spatial_cache.get(result.indicator_id)
+            map_path = os.path.join(results_dir, f"{result.indicator_id}_map.png")
             if spatial is not None:
-                map_path = os.path.join(results_dir, f"{result.indicator_id}_map.png")
                 render_indicator_map(
-                    data=spatial.data,
-                    lons=spatial.lons,
-                    lats=spatial.lats,
+                    spatial=spatial,
                     aoi=job.request.aoi,
-                    indicator_name=result.indicator_id.replace("_", " ").title(),
                     status=result.status,
                     output_path=map_path,
-                    colormap=spatial.colormap,
-                    label=spatial.label,
                 )
-                output_files.append(map_path)
+            else:
+                render_status_map(
+                    aoi=job.request.aoi,
+                    status=result.status,
+                    output_path=map_path,
+                )
+            output_files.append(map_path)
+
+            # Save spatial data as JSON for frontend
+            spatial_json_path = os.path.join(results_dir, f"{result.indicator_id}_spatial.json")
+            _save_spatial_json(spatial, result.status.value, spatial_json_path)
 
         # Generate PDF report
         report_path = os.path.join(results_dir, "report.pdf")