CHANGELOG.md

@@ -5,6 +5,40 @@ All notable changes to Terra-View will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.13.3] - 2026-06-05
+
+Calibration sync from SFM events.  Closes the manual data-entry loop on calibration dates — Terra-View now pulls `device.calibration_date` from each seismograph's most recent event sidecar once a day and updates `RosterUnit.last_calibrated` when the device reports something fresher than what's stored.  Manual edits still win when they're newer than the latest event; a fresh event arriving later supersedes the manual edit.  Adds a "Sync now" button under Settings → Advanced → Calibration Defaults for on-demand runs, and a `docs/ROADMAP.md` to track in-flight + deferred work.
+
+### Added
+
+- **Calibration sync service** (`backend/services/calibration_sync.py`).  Per-unit: fetches `/db/events?serial={id}&limit=1` then `/db/events/{event_id}/sidecar` via the SFM proxy, reads `device.calibration_date`, and writes it to `RosterUnit.last_calibrated` with `next_calibration_due` recomputed from `UserPreferences.calibration_interval_days`.  Every change is logged in `UnitHistory` with `source='sfm_event'` and `notes="Synced from event {id}"` so the unit detail history timeline reflects auto-sync activity alongside manual edits.
+- **Conflict rule: events-as-truth, manual wins when newer.**  Three outcomes per unit:
+  - `already_in_sync` — stored date already matches the event's calibration date.
+  - `skipped_manual_newer` — the latest `UnitHistory` change for `last_calibrated` happened *after* the event's timestamp, so the manual edit is preserved.  Only a future event can supersede it.
+  - `updated` — the event is newer (or no manual edit exists), so the stored date is replaced.
+- **Daily background job at 03:15 local** via the `schedule` library + a worker thread (modeled on `backup_scheduler.py`).  Started in `main.py`'s startup hook, stopped on shutdown.  Does not run on boot — first sync after a server start fires at the next 03:15.
+- **`POST /api/calibration/sync`** — runs a full sync immediately and returns a summary `{checked, updated, skipped_manual_newer, already_in_sync, no_event, no_sidecar, no_cal_in_sidecar, errors, results: [...]}`.  Powers the Settings button.
+- **`GET /api/calibration/sync/status`** — returns scheduler state + the last run's summary including per-unit `{unit_id, action, old, new, event_id}` rows.  Useful for diagnostics: `curl localhost:8001/api/calibration/sync/status | jq`.
+- **Settings UI: "Sync from SFM events" section** under the Calibration Defaults card (Advanced tab).  Click "Sync now" → result line shows counts: `Checked N · Updated N · Already in sync N · Manual kept N · No event N`.
+- **`docs/ROADMAP.md`** — first-pass roadmap pulling deferred items from `CLAUDE.md`'s focus block, in-code TODOs (`photos.py` GPS migration → `MonitoringLocation`, `device_controller.py` SFM Phase 2 stubs, `modem_dashboard.py` ModemManager backend, `dashboard.html` geocoding), and the README's long-standing "Future Enhancements" wishlist.  Grouped into In Flight / Near-Term / Medium-Term / Wishlist; intended as a living document.
+
+### Fixed
+
+- **Prod startup crash: `ModuleNotFoundError: No module named 'schedule'`**.  The `schedule` library wasn't pinned in `requirements.txt` even though `backend/services/backup_scheduler.py` has been using it since v0.4.x — the dev image happened to have it from an earlier manual `pip install`, but a clean prod rebuild dropped it.  Added `schedule==1.2.2` so the new calibration scheduler (and the existing backup scheduler) survive a clean rebuild.
+
+### Upgrade Notes
+
+No DB migration required — `UnitHistory.source` and `RosterUnit.last_calibrated`/`next_calibration_due` already exist.  Rebuild only:
+
+```bash
+cd /home/serversdown/terra-view
+docker compose build terra-view && docker compose up -d terra-view
+```
+
+After rebuild, Settings → Advanced → "Sync from SFM events" → "Sync now" to backfill in one shot; otherwise wait for the 03:15 job.
+
+---
+
 ## [0.13.2] - 2026-05-30
 
 PWA-cache fix for mobile operators.  v0.13.0 added the inline PDF preview, `.TXT` download, and Review form to `event-modal.js`, but mobile devices using Terra-View as a PWA never saw any of it — the service worker had `CACHE_VERSION = 'v1'` (unchanged since v0.12.x), so the activate handler never evicted the stale cache and mobile users kept getting served the pre-v0.13.0 modal forever.

README.md

@@ -1,4 +1,4 @@
-# Terra-View v0.13.2
+# Terra-View v0.13.3
 Backend API and HTMX-powered web interface for managing a mixed fleet of seismographs and field modems. Track deployments, monitor health in real time, merge roster intent with incoming telemetry, and control your fleet through a unified database and dashboard.
 
 ## Features

backend/main.py

@@ -30,7 +30,7 @@ Base.metadata.create_all(bind=engine)
 ENVIRONMENT = os.getenv("ENVIRONMENT", "production")
 
 # Initialize FastAPI app
-VERSION = "0.13.2"
+VERSION = "0.13.3"
 if ENVIRONMENT == "development":
     _build = os.getenv("BUILD_NUMBER", "0")
     if _build and _build != "0":
@@ -144,9 +144,14 @@ app.include_router(fleet_calendar.router)
 from backend.routers import deployments
 app.include_router(deployments.router)
 
+# Calibration sync router (SFM-driven cal date updates)
+from backend.routers import calibration
+app.include_router(calibration.router)
+
 # Start scheduler service and device status monitor on application startup
 from backend.services.scheduler import start_scheduler, stop_scheduler
 from backend.services.device_status_monitor import start_device_status_monitor, stop_device_status_monitor
+from backend.services.calibration_sync import get_calibration_sync_scheduler
 
 @app.on_event("startup")
 async def startup_event():
@@ -159,6 +164,10 @@ async def startup_event():
     await start_device_status_monitor()
     logger.info("Device status monitor started")
 
+    logger.info("Starting calibration sync scheduler...")
+    get_calibration_sync_scheduler().start()
+    logger.info("Calibration sync scheduler started")
+
 @app.on_event("shutdown")
 def shutdown_event():
     """Clean up services on app shutdown"""
@@ -170,6 +179,10 @@ def shutdown_event():
     stop_scheduler()
     logger.info("Scheduler service stopped")
 
+    logger.info("Stopping calibration sync scheduler...")
+    get_calibration_sync_scheduler().stop()
+    logger.info("Calibration sync scheduler stopped")
+
 
 # Legacy routes from the original backend
 from backend import routes as legacy_routes

backend/routers/activity.py

@@ -9,6 +9,7 @@ import logging
 import httpx
 from backend.database import get_db
 from backend.models import UnitHistory, Emitter, RosterUnit
+from backend.services.unit_location import get_active_location
 
 log = logging.getLogger(__name__)
 
@@ -140,6 +141,7 @@ def get_recent_callins(hours: int = 6, limit: int = None, db: Session = Depends(
                 days = int(hours_ago / 24)
                 time_ago = f"{days}d ago"
 
+        loc = get_active_location(db, emitter.id) if roster_unit else None
         call_in = {
             "unit_id": emitter.id,
             "last_seen": emitter.last_seen.isoformat(),
@@ -148,7 +150,7 @@ def get_recent_callins(hours: int = 6, limit: int = None, db: Session = Depends(
             "device_type": roster_unit.device_type if roster_unit else "seismograph",
             "deployed": roster_unit.deployed if roster_unit else False,
             "note": roster_unit.note if roster_unit and roster_unit.note else "",
-            "location": roster_unit.address if roster_unit and roster_unit.address else (roster_unit.location if roster_unit else "")
+            "location": (loc or {}).get("address") or (loc or {}).get("name") or ""
         }
         call_ins.append(call_in)
 

backend/routers/calibration.py

@@ -0,0 +1,31 @@
+"""
+Calibration Sync Router
+
+Endpoints for triggering and inspecting the SFM-driven calibration sync.
+The scheduled job runs daily; this router is what the "Sync now" button in
+Settings calls, plus a status endpoint for diagnostics.
+"""
+
+from fastapi import APIRouter
+from typing import Dict, Any
+
+from backend.services.calibration_sync import (
+    sync_all_calibrations,
+    get_calibration_sync_scheduler,
+)
+
+router = APIRouter(prefix="/api/calibration", tags=["calibration"])
+
+
+@router.post("/sync")
+async def trigger_calibration_sync() -> Dict[str, Any]:
+    """Run a full calibration sync now and return the summary."""
+    summary = await sync_all_calibrations()
+    get_calibration_sync_scheduler().last_run = summary
+    return summary
+
+
+@router.get("/sync/status")
+def calibration_sync_status() -> Dict[str, Any]:
+    """Return scheduler status and the most recent run's summary."""
+    return get_calibration_sync_scheduler().status()

backend/routers/fleet_calendar.py

@@ -750,15 +750,17 @@ async def get_unit_quick_info(unit_id: str, db: Session = Depends(get_db)):
     # Last seen from emitter
     emitter = db.query(Emitter).filter(Emitter.unit_type == unit_id).first()
 
+    from backend.services.unit_location import get_active_location
+    loc = get_active_location(db, u.id)
     return {
         "id": u.id,
         "unit_type": u.unit_type,
         "deployed": u.deployed,
         "out_for_calibration": u.out_for_calibration or False,
         "note": u.note or "",
-        "project_id": u.project_id or "",
+        "project_id": (loc or {}).get("project_id") or u.project_id or "",
-        "address": u.address or u.location or "",
+        "address": (loc or {}).get("address") or "",
-        "coordinates": u.coordinates or "",
+        "coordinates": (loc or {}).get("coordinates") or "",
         "deployed_with_modem_id": u.deployed_with_modem_id or "",
         "last_calibrated": u.last_calibrated.isoformat() if u.last_calibrated else None,
         "next_calibration_due": u.next_calibration_due.isoformat() if u.next_calibration_due else (expiry.isoformat() if expiry else None),

backend/routers/modem_dashboard.py

@@ -14,6 +14,7 @@ import logging
 
 from backend.database import get_db
 from backend.models import RosterUnit
+from backend.services.unit_location import get_active_location
 from backend.templates_config import templates
 
 logger = logging.getLogger(__name__)
@@ -85,8 +86,7 @@ async def get_modem_units(
             (RosterUnit.id.ilike(search_term)) |
             (RosterUnit.ip_address.ilike(search_term)) |
             (RosterUnit.hardware_model.ilike(search_term)) |
-            (RosterUnit.phone_number.ilike(search_term)) |
+            (RosterUnit.phone_number.ilike(search_term))
-            (RosterUnit.location.ilike(search_term))
         )
 
     modems = query.order_by(
@@ -128,6 +128,8 @@ async def get_modem_units(
         if filter_status and status != filter_status:
             continue
 
+        # Inherit location from the paired device's active assignment.
+        loc = get_active_location(db, modem.id) if paired else None
         modem_list.append({
             "id": modem.id,
             "ip_address": modem.ip_address,
@@ -135,8 +137,8 @@ async def get_modem_units(
             "hardware_model": modem.hardware_model,
             "deployed": modem.deployed,
             "retired": modem.retired,
-            "location": modem.location,
+            "location": (loc or {}).get("address") or (loc or {}).get("name") or "",
-            "project_id": modem.project_id,
+            "project_id": (loc or {}).get("project_id") or modem.project_id,
             "paired_device": paired,
             "status": status
         })
@@ -165,14 +167,15 @@ async def get_paired_device(modem_id: str, db: Session = Depends(get_db)):
     ).first()
 
     if device:
+        loc = get_active_location(db, device.id)
         return {
             "paired": True,
             "device": {
                 "id": device.id,
                 "device_type": device.device_type,
                 "deployed": device.deployed,
-                "project_id": device.project_id,
+                "project_id": (loc or {}).get("project_id") or device.project_id,
-                "location": device.location or device.address
+                "location": (loc or {}).get("address") or (loc or {}).get("name") or ""
             }
         }
 
@@ -314,8 +317,6 @@ async def get_pairable_devices(
         query = query.filter(
             (RosterUnit.id.ilike(search_term)) |
             (RosterUnit.project_id.ilike(search_term)) |
-            (RosterUnit.location.ilike(search_term)) |
-            (RosterUnit.address.ilike(search_term)) |
             (RosterUnit.note.ilike(search_term))
         )
 
@@ -338,12 +339,13 @@ async def get_pairable_devices(
         if hide_paired and is_paired_to_other:
             continue
 
+        loc = get_active_location(db, device.id)
         device_list.append({
             "id": device.id,
             "device_type": device.device_type,
             "deployed": device.deployed,
-            "project_id": device.project_id,
+            "project_id": (loc or {}).get("project_id") or device.project_id,
-            "location": device.location or device.address,
+            "location": (loc or {}).get("address") or (loc or {}).get("name") or "",
             "note": device.note,
             "paired_modem_id": device.deployed_with_modem_id,
             "is_paired_to_this": is_paired_to_this,

backend/routers/project_locations.py

@@ -1483,11 +1483,13 @@ async def get_available_units(
     ).distinct().all()
     assigned_unit_ids = [uid[0] for uid in assigned_unit_ids]
 
+    # These units have no active assignment by definition, so there's no
+    # current location to show — leave the field empty.
     available_units = [
         {
             "id": unit.id,
             "device_type": unit.device_type,
-            "location": unit.address or unit.location,
+            "location": "",
             "model": unit.slm_model if unit.device_type == "slm" else unit.unit_type,
             "deployed": bool(unit.deployed),
         }

backend/routers/roster_edit.py

@@ -12,6 +12,7 @@ from backend.database import get_db
 from backend.models import RosterUnit, IgnoredUnit, Emitter, UnitHistory, UserPreferences, DeploymentRecord
 import uuid
 from backend.services.slmm_sync import sync_slm_to_slmm
+from backend.services.unit_location import get_active_location
 
 router = APIRouter(prefix="/api/roster", tags=["roster-edit"])
 logger = logging.getLogger(__name__)
@@ -182,9 +183,6 @@ async def add_roster_unit(
     out_for_calibration: str = Form(None),
     note: str = Form(""),
     project_id: str = Form(None),
-    location: str = Form(None),
-    address: str = Form(None),
-    coordinates: str = Form(None),
     # Seismograph-specific fields
     last_calibrated: str = Form(None),
     next_calibration_due: str = Form(None),
@@ -249,9 +247,6 @@ async def add_roster_unit(
         out_for_calibration=out_for_calibration_bool,
         note=note,
         project_id=project_id,
-        location=location,
-        address=address,
-        coordinates=coordinates,
         last_updated=datetime.utcnow(),
         # Seismograph-specific fields
         last_calibrated=last_cal_date,
@@ -273,19 +268,15 @@ async def add_roster_unit(
         slm_measurement_range=slm_measurement_range if slm_measurement_range else None,
     )
 
-    # Auto-fill data from modem if pairing and fields are empty
+    # Auto-fill data from modem if pairing and fields are empty.
+    # Location/address/coordinates now come from MonitoringLocation via the
+    # active UnitAssignment, so there's nothing to copy from the modem row.
     if deployed_with_modem_id:
         modem = db.query(RosterUnit).filter(
             RosterUnit.id == deployed_with_modem_id,
             RosterUnit.device_type == "modem"
         ).first()
         if modem:
-            if not unit.location and modem.location:
-                unit.location = modem.location
-            if not unit.address and modem.address:
-                unit.address = modem.address
-            if not unit.coordinates and modem.coordinates:
-                unit.coordinates = modem.coordinates
             if not unit.project_id and modem.project_id:
                 unit.project_id = modem.project_id
             if not unit.note and modem.note:
@@ -493,6 +484,8 @@ def get_roster_unit(unit_id: str, db: Session = Depends(get_db)):
     if not unit:
         raise HTTPException(status_code=404, detail="Unit not found")
 
+    active_loc = get_active_location(db, unit_id)
+
     return {
         "id": unit.id,
         "device_type": unit.device_type or "seismograph",
@@ -504,9 +497,11 @@ def get_roster_unit(unit_id: str, db: Session = Depends(get_db)):
         "allocated_to_project_id": getattr(unit, 'allocated_to_project_id', None) or "",
         "note": unit.note or "",
         "project_id": unit.project_id or "",
-        "location": unit.location or "",
+        "active_location": active_loc,
-        "address": unit.address or "",
+        # Convenience fields so the unit-detail page can read the same shape
-        "coordinates": unit.coordinates or "",
+        # whether or not there's an active assignment.
+        "address":     (active_loc or {}).get("address") or "",
+        "coordinates": (active_loc or {}).get("coordinates") or "",
         "last_calibrated": unit.last_calibrated.isoformat() if unit.last_calibrated else "",
         "next_calibration_due": unit.next_calibration_due.isoformat() if unit.next_calibration_due else "",
         "deployed_with_modem_id": unit.deployed_with_modem_id or "",
@@ -538,9 +533,6 @@ async def edit_roster_unit(
     allocated_to_project_id: str = Form(None),
     note: str = Form(""),
     project_id: str = Form(None),
-    location: str = Form(None),
-    address: str = Form(None),
-    coordinates: str = Form(None),
     # Seismograph-specific fields
     last_calibrated: str = Form(None),
     next_calibration_due: str = Form(None),
@@ -565,8 +557,6 @@ async def edit_roster_unit(
     cascade_deployed: str = Form(None),
     cascade_retired: str = Form(None),
     cascade_project: str = Form(None),
-    cascade_location: str = Form(None),
-    cascade_coordinates: str = Form(None),
     cascade_note: str = Form(None),
     db: Session = Depends(get_db)
 ):
@@ -620,9 +610,6 @@ async def edit_roster_unit(
     unit.allocated_to_project_id = allocated_to_project_id if allocated_bool else None
     unit.note = note
     unit.project_id = project_id
-    unit.location = location
-    unit.address = address
-    unit.coordinates = coordinates
     unit.last_updated = datetime.utcnow()
 
     # Seismograph-specific fields
@@ -630,20 +617,15 @@ async def edit_roster_unit(
     unit.next_calibration_due = next_cal_date
     unit.deployed_with_modem_id = deployed_with_modem_id if deployed_with_modem_id else None
 
-    # Auto-fill data from modem if pairing and fields are empty
+    # Auto-fill data from modem if pairing and fields are empty.
+    # Location/address/coordinates live on MonitoringLocation now, nothing
+    # to copy across roster rows.
     if deployed_with_modem_id:
         modem = db.query(RosterUnit).filter(
             RosterUnit.id == deployed_with_modem_id,
             RosterUnit.device_type == "modem"
         ).first()
         if modem:
-            # Only fill if the device field is empty
-            if not unit.location and modem.location:
-                unit.location = modem.location
-            if not unit.address and modem.address:
-                unit.address = modem.address
-            if not unit.coordinates and modem.coordinates:
-                unit.coordinates = modem.coordinates
             if not unit.project_id and modem.project_id:
                 unit.project_id = modem.project_id
             if not unit.note and modem.note:
@@ -769,26 +751,6 @@ async def edit_roster_unit(
                     record_history(db, paired_unit.id, "project_change", "project_id",
                                    old_paired_project or "", project_id or "", f"cascade from {unit_id}")
 
-            # Cascade address/location
-            if cascade_location in ['true', 'True', '1', 'yes']:
-                old_paired_address = paired_unit.address
-                old_paired_location = paired_unit.location
-                paired_unit.address = address
-                paired_unit.location = location
-                paired_unit.last_updated = datetime.utcnow()
-                if old_paired_address != address:
-                    record_history(db, paired_unit.id, "address_change", "address",
-                                   old_paired_address or "", address or "", f"cascade from {unit_id}")
-
-            # Cascade coordinates
-            if cascade_coordinates in ['true', 'True', '1', 'yes']:
-                old_paired_coords = paired_unit.coordinates
-                paired_unit.coordinates = coordinates
-                paired_unit.last_updated = datetime.utcnow()
-                if old_paired_coords != coordinates:
-                    record_history(db, paired_unit.id, "coordinates_change", "coordinates",
-                                   old_paired_coords or "", coordinates or "", f"cascade from {unit_id}")
-
             # Cascade note
             if cascade_note in ['true', 'True', '1', 'yes']:
                 old_paired_note = paired_unit.note
@@ -1011,9 +973,8 @@ async def import_csv(
     - retired: Boolean
     - note: Notes about the unit
     - project_id: Project identifier
-    - location: Location description
+    (Location / address / coordinates are not roster fields anymore — they
-    - address: Street address
+    live on the MonitoringLocation a unit is assigned to.)
-    - coordinates: GPS coordinates (lat;lon or lat,lon)
 
     Seismograph-specific:
     - last_calibrated: Date (YYYY-MM-DD)
@@ -1126,9 +1087,6 @@ async def import_csv(
                 existing_unit.retired = _parse_bool(row.get('retired', '')) if row.get('retired') else existing_unit.retired
                 existing_unit.note = _get_csv_value(row, 'note', existing_unit.note)
                 existing_unit.project_id = _get_csv_value(row, 'project_id', existing_unit.project_id)
-                existing_unit.location = _get_csv_value(row, 'location', existing_unit.location)
-                existing_unit.address = _get_csv_value(row, 'address', existing_unit.address)
-                existing_unit.coordinates = _get_csv_value(row, 'coordinates', existing_unit.coordinates)
                 existing_unit.last_updated = datetime.utcnow()
 
                 # Seismograph-specific fields
@@ -1194,9 +1152,6 @@ async def import_csv(
                     retired=_parse_bool(row.get('retired', '')),
                     note=_get_csv_value(row, 'note', ''),
                     project_id=_get_csv_value(row, 'project_id'),
-                    location=_get_csv_value(row, 'location'),
-                    address=_get_csv_value(row, 'address'),
-                    coordinates=_get_csv_value(row, 'coordinates'),
                     last_updated=datetime.utcnow(),
                     # Seismograph fields - auto-calc next_calibration_due from last_calibrated
                     last_calibrated=last_cal,

backend/routers/settings.py

@@ -12,6 +12,7 @@ from pathlib import Path
 from backend.database import get_db
 from backend.models import RosterUnit, Emitter, IgnoredUnit, UserPreferences
 from backend.services.database_backup import DatabaseBackupService
+from backend.services.unit_location import bulk_active_locations
 
 router = APIRouter(prefix="/api/settings", tags=["settings"])
 
@@ -21,11 +22,14 @@ def export_roster_csv(db: Session = Depends(get_db)):
     """Export all roster units to CSV"""
     units = db.query(RosterUnit).all()
 
-    # Create CSV in memory
+    # Create CSV in memory.  Location lives on MonitoringLocation now, so
+    # we don't export legacy address/coordinates/location columns here —
+    # round-trip CSV editing would otherwise look like it edits unit
+    # location, when it can't.
     output = io.StringIO()
     fieldnames = [
         'unit_id', 'unit_type', 'device_type', 'deployed', 'retired',
-        'note', 'project_id', 'location', 'address', 'coordinates',
+        'note', 'project_id',
         'last_calibrated', 'next_calibration_due', 'deployed_with_modem_id',
         'ip_address', 'phone_number', 'hardware_model'
     ]
@@ -42,9 +46,6 @@ def export_roster_csv(db: Session = Depends(get_db)):
             'retired': 'true' if unit.retired else 'false',
             'note': unit.note or '',
             'project_id': unit.project_id or '',
-            'location': unit.location or '',
-            'address': unit.address or '',
-            'coordinates': unit.coordinates or '',
             'last_calibrated': unit.last_calibrated.strftime('%Y-%m-%d') if unit.last_calibrated else '',
             'next_calibration_due': unit.next_calibration_due.strftime('%Y-%m-%d') if unit.next_calibration_due else '',
             'deployed_with_modem_id': unit.deployed_with_modem_id or '',
@@ -82,6 +83,7 @@ def get_table_stats(db: Session = Depends(get_db)):
 def get_all_roster_units(db: Session = Depends(get_db)):
     """Get all roster units for management table"""
     units = db.query(RosterUnit).order_by(RosterUnit.id).all()
+    active_locs = bulk_active_locations(db, units)
 
     return [{
         "id": unit.id,
@@ -90,10 +92,10 @@ def get_all_roster_units(db: Session = Depends(get_db)):
         "deployed": unit.deployed,
         "retired": unit.retired,
         "note": unit.note or "",
-        "project_id": unit.project_id or "",
+        "project_id": (active_locs.get(unit.id) or {}).get("project_id") or unit.project_id or "",
-        "location": unit.location or "",
+        "address":     (active_locs.get(unit.id) or {}).get("address") or "",
-        "address": unit.address or "",
+        "coordinates": (active_locs.get(unit.id) or {}).get("coordinates") or "",
-        "coordinates": unit.coordinates or "",
+        "location_name": (active_locs.get(unit.id) or {}).get("name") or "",
         "last_calibrated": unit.last_calibrated.isoformat() if unit.last_calibrated else None,
         "next_calibration_due": unit.next_calibration_due.isoformat() if unit.next_calibration_due else None,
         "deployed_with_modem_id": unit.deployed_with_modem_id or "",

backend/routers/slm_ui.py

@@ -14,6 +14,7 @@ import os
 
 from backend.database import get_db
 from backend.models import RosterUnit
+from backend.services.unit_location import get_active_location
 from backend.templates_config import templates
 
 logger = logging.getLogger(__name__)
@@ -58,13 +59,14 @@ async def get_slm_summary(unit_id: str, db: Session = Depends(get_db)):
     except Exception as e:
         logger.warning(f"Failed to get SLM status for {unit_id}: {e}")
 
+    loc = get_active_location(db, unit_id)
     return {
         "unit_id": unit_id,
         "device_type": "slm",
         "deployed": unit.deployed,
         "model": unit.slm_model or "NL-43",
-        "location": unit.address or unit.location,
+        "location": (loc or {}).get("address") or (loc or {}).get("name") or "",
-        "coordinates": unit.coordinates,
+        "coordinates": (loc or {}).get("coordinates") or "",
         "note": unit.note,
         "status": status_data,
         "last_check": unit.slm_last_check.isoformat() if unit.slm_last_check else None,

backend/routers/units.py

@@ -5,6 +5,7 @@ from typing import Dict, Any, Optional
 
 from backend.database import get_db
 from backend.services.snapshot import emit_status_snapshot
+from backend.services.unit_location import get_active_location
 from backend.models import RosterUnit
 
 router = APIRouter(prefix="/api", tags=["units"])
@@ -13,7 +14,8 @@ router = APIRouter(prefix="/api", tags=["units"])
 @router.get("/unit/{unit_id}")
 def get_unit_detail(unit_id: str, db: Session = Depends(get_db)):
     """
-    Returns detailed data for a single unit.
+    Returns detailed data for a single unit, including its active deployment
+    location (or None if benched / unassigned).
     """
     snapshot = emit_status_snapshot()
 
@@ -21,17 +23,7 @@ def get_unit_detail(unit_id: str, db: Session = Depends(get_db)):
         raise HTTPException(status_code=404, detail=f"Unit {unit_id} not found")
 
     unit_data = snapshot["units"][unit_id]
-
+    active_loc = get_active_location(db, unit_id)
-    # Mock coordinates for now (will be replaced with real data)
-    mock_coords = {
-        "BE1234": {"lat": 37.7749, "lon": -122.4194, "location": "San Francisco, CA"},
-        "BE5678": {"lat": 34.0522, "lon": -118.2437, "location": "Los Angeles, CA"},
-        "BE9012": {"lat": 40.7128, "lon": -74.0060, "location": "New York, NY"},
-        "BE3456": {"lat": 41.8781, "lon": -87.6298, "location": "Chicago, IL"},
-        "BE7890": {"lat": 29.7604, "lon": -95.3698, "location": "Houston, TX"},
-    }
-
-    coords = mock_coords.get(unit_id, {"lat": 39.8283, "lon": -98.5795, "location": "Unknown"})
 
     return {
         "id": unit_id,
@@ -41,7 +33,7 @@ def get_unit_detail(unit_id: str, db: Session = Depends(get_db)):
         "last_file": unit_data.get("fname", ""),
         "deployed": unit_data["deployed"],
         "note": unit_data.get("note", ""),
-        "coordinates": coords
+        "active_location": active_loc,
     }
 
 
@@ -49,12 +41,16 @@ def get_unit_detail(unit_id: str, db: Session = Depends(get_db)):
 def get_unit_by_id(unit_id: str, db: Session = Depends(get_db)):
     """
     Get unit data directly from the roster (for settings/configuration).
+    Address/coordinates come from the active MonitoringLocation, not the
+    roster row.
     """
     unit = db.query(RosterUnit).filter_by(id=unit_id).first()
 
     if not unit:
         raise HTTPException(status_code=404, detail=f"Unit {unit_id} not found")
 
+    active_loc = get_active_location(db, unit_id)
+
     return {
         "id": unit.id,
         "unit_type": unit.unit_type,
@@ -62,9 +58,9 @@ def get_unit_by_id(unit_id: str, db: Session = Depends(get_db)):
         "deployed": unit.deployed,
         "retired": unit.retired,
         "note": unit.note,
-        "location": unit.location,
+        "active_location": active_loc,
-        "address": unit.address,
+        "address":     (active_loc or {}).get("address") or "",
-        "coordinates": unit.coordinates,
+        "coordinates": (active_loc or {}).get("coordinates") or "",
         "slm_host": unit.slm_host,
         "slm_tcp_port": unit.slm_tcp_port,
         "slm_ftp_port": unit.slm_ftp_port,

backend/services/calibration_sync.py

@@ -0,0 +1,295 @@
+"""
+Calibration Sync Service
+
+Pulls device-reported calibration dates from SFM event sidecars and updates
+RosterUnit.last_calibrated when the device has a newer record than what
+Terra-View has stored.
+
+Conflict rule: events-as-truth, but don't go backwards.
+  - If the newest event's calibration_date == unit.last_calibrated → no-op.
+  - If the last UnitHistory change for last_calibrated is newer than the
+    newest event's timestamp → skip (a manual edit was made after this
+    event landed; manual wins until a fresher event arrives).
+  - Otherwise → write the event's calibration_date, recompute
+    next_calibration_due, and log a UnitHistory row with source='sfm_event'.
+"""
+
+import asyncio
+import logging
+import os
+import threading
+import time
+from datetime import datetime, date, timedelta
+from typing import Optional, Dict, Any, List
+
+import httpx
+import schedule
+from sqlalchemy.orm import Session
+
+from backend.database import SessionLocal
+from backend.models import RosterUnit, UnitHistory, UserPreferences
+
+logger = logging.getLogger(__name__)
+
+SFM_BASE_URL = os.getenv("SFM_BASE_URL", "http://localhost:8200")
+
+
+def _get_cal_interval(db: Session) -> int:
+    prefs = db.query(UserPreferences).first()
+    if prefs and prefs.calibration_interval_days:
+        return prefs.calibration_interval_days
+    return 365
+
+
+def _parse_event_ts(value: Any) -> Optional[datetime]:
+    if not value:
+        return None
+    if isinstance(value, datetime):
+        return value.replace(tzinfo=None) if value.tzinfo else value
+    try:
+        s = str(value).replace("Z", "")
+        if "+" in s:
+            s = s.split("+", 1)[0]
+        return datetime.fromisoformat(s)
+    except (ValueError, TypeError):
+        logger.warning(f"Could not parse event timestamp: {value!r}")
+        return None
+
+
+def _parse_cal_date(value: Any) -> Optional[date]:
+    if not value:
+        return None
+    if isinstance(value, date) and not isinstance(value, datetime):
+        return value
+    if isinstance(value, datetime):
+        return value.date()
+    try:
+        return datetime.fromisoformat(str(value)).date()
+    except (ValueError, TypeError):
+        try:
+            return datetime.strptime(str(value), "%Y-%m-%d").date()
+        except (ValueError, TypeError):
+            logger.warning(f"Could not parse calibration_date: {value!r}")
+            return None
+
+
+async def _get_latest_event(client: httpx.AsyncClient, serial: str) -> Optional[Dict[str, Any]]:
+    try:
+        resp = await client.get(
+            f"{SFM_BASE_URL}/db/events",
+            params={"serial": serial, "limit": 1},
+        )
+        resp.raise_for_status()
+        data = resp.json()
+        events = data.get("events", [])
+        return events[0] if events else None
+    except (httpx.HTTPError, ValueError) as e:
+        logger.warning(f"Failed to fetch latest event for {serial}: {e}")
+        return None
+
+
+async def _get_event_sidecar(client: httpx.AsyncClient, event_id: str) -> Optional[Dict[str, Any]]:
+    try:
+        resp = await client.get(f"{SFM_BASE_URL}/db/events/{event_id}/sidecar")
+        resp.raise_for_status()
+        return resp.json()
+    except (httpx.HTTPError, ValueError) as e:
+        logger.warning(f"Failed to fetch sidecar for event {event_id}: {e}")
+        return None
+
+
+async def sync_unit_calibration(
+    db: Session,
+    unit: RosterUnit,
+    client: httpx.AsyncClient,
+) -> Dict[str, Any]:
+    """Sync calibration for one seismograph unit. Returns a result dict."""
+    result: Dict[str, Any] = {
+        "unit_id": unit.id,
+        "action": "checked",
+        "old": unit.last_calibrated.isoformat() if unit.last_calibrated else None,
+        "new": None,
+        "event_id": None,
+    }
+
+    event = await _get_latest_event(client, unit.id)
+    if not event:
+        result["action"] = "no_event"
+        return result
+
+    sidecar = await _get_event_sidecar(client, event["id"])
+    if not sidecar:
+        result["action"] = "no_sidecar"
+        return result
+
+    device = sidecar.get("device") or {}
+    event_cal = _parse_cal_date(device.get("calibration_date"))
+    if not event_cal:
+        result["action"] = "no_cal_in_sidecar"
+        return result
+
+    result["event_id"] = event["id"]
+    result["new"] = event_cal.isoformat()
+
+    if unit.last_calibrated == event_cal:
+        result["action"] = "already_in_sync"
+        return result
+
+    event_ts = _parse_event_ts(event.get("timestamp"))
+    last_change = (
+        db.query(UnitHistory)
+        .filter(
+            UnitHistory.unit_id == unit.id,
+            UnitHistory.field_name == "last_calibrated",
+        )
+        .order_by(UnitHistory.changed_at.desc())
+        .first()
+    )
+
+    if last_change and event_ts and last_change.changed_at > event_ts:
+        result["action"] = "skipped_manual_newer"
+        return result
+
+    old_cal = unit.last_calibrated
+    unit.last_calibrated = event_cal
+    unit.next_calibration_due = event_cal + timedelta(days=_get_cal_interval(db))
+
+    db.add(UnitHistory(
+        unit_id=unit.id,
+        change_type="calibration_status_change",
+        field_name="last_calibrated",
+        old_value=old_cal.strftime("%Y-%m-%d") if old_cal else None,
+        new_value=event_cal.strftime("%Y-%m-%d"),
+        source="sfm_event",
+        notes=f"Synced from event {event['id']}",
+    ))
+
+    result["action"] = "updated"
+    return result
+
+
+async def sync_all_calibrations(db: Optional[Session] = None) -> Dict[str, Any]:
+    """Sync calibration for every non-retired seismograph.
+
+    If `db` is provided the caller owns the session and commit.  Otherwise
+    a session is opened, committed, and closed locally — this is what the
+    scheduled job uses.
+    """
+    owns_session = db is None
+    if owns_session:
+        db = SessionLocal()
+
+    summary: Dict[str, Any] = {
+        "started_at": datetime.utcnow().isoformat(),
+        "checked": 0,
+        "updated": 0,
+        "skipped_manual_newer": 0,
+        "already_in_sync": 0,
+        "no_event": 0,
+        "no_sidecar": 0,
+        "no_cal_in_sidecar": 0,
+        "errors": 0,
+        "results": [],
+    }
+
+    try:
+        units = (
+            db.query(RosterUnit)
+            .filter(
+                RosterUnit.retired == False,
+                RosterUnit.device_type == "seismograph",
+            )
+            .all()
+        )
+
+        async with httpx.AsyncClient(timeout=15.0) as client:
+            for unit in units:
+                summary["checked"] += 1
+                try:
+                    r = await sync_unit_calibration(db, unit, client)
+                except Exception as e:
+                    logger.exception(f"Error syncing calibration for {unit.id}")
+                    summary["errors"] += 1
+                    summary["results"].append({"unit_id": unit.id, "action": "error", "error": str(e)})
+                    continue
+
+                summary["results"].append(r)
+                action = r["action"]
+                if action in summary:
+                    summary[action] += 1
+
+        if owns_session:
+            db.commit()
+
+    finally:
+        if owns_session:
+            db.close()
+
+    summary["finished_at"] = datetime.utcnow().isoformat()
+    logger.info(
+        f"Calibration sync done: checked={summary['checked']} "
+        f"updated={summary['updated']} skipped_manual={summary['skipped_manual_newer']} "
+        f"in_sync={summary['already_in_sync']} errors={summary['errors']}"
+    )
+    return summary
+
+
+# ---------------------------------------------------------------------------
+# Background scheduler — runs once daily.  Modeled on backup_scheduler.
+# ---------------------------------------------------------------------------
+
+class CalibrationSyncScheduler:
+    """Runs sync_all_calibrations() once per day at a fixed local time."""
+
+    def __init__(self, run_at: str = "03:15"):
+        self.run_at = run_at
+        self.is_running = False
+        self.thread: Optional[threading.Thread] = None
+        self.last_run: Optional[Dict[str, Any]] = None
+
+    def _job_wrapper(self):
+        """Run the async sync in a fresh event loop (we're on a worker thread)."""
+        try:
+            self.last_run = asyncio.run(sync_all_calibrations())
+        except Exception as e:
+            logger.exception(f"Calibration sync job failed: {e}")
+            self.last_run = {"error": str(e), "finished_at": datetime.utcnow().isoformat()}
+
+    def start(self):
+        if self.is_running:
+            return
+        logger.info(f"Starting calibration sync scheduler (daily at {self.run_at})")
+        schedule.every().day.at(self.run_at).do(self._job_wrapper)
+        self.is_running = True
+        self.thread = threading.Thread(target=self._loop, daemon=True)
+        self.thread.start()
+
+    def _loop(self):
+        while self.is_running:
+            schedule.run_pending()
+            time.sleep(60)
+
+    def stop(self):
+        if not self.is_running:
+            return
+        logger.info("Stopping calibration sync scheduler")
+        self.is_running = False
+        if self.thread:
+            self.thread.join(timeout=5)
+
+    def status(self) -> Dict[str, Any]:
+        return {
+            "running": self.is_running,
+            "run_at": self.run_at,
+            "last_run": self.last_run,
+        }
+
+
+_scheduler: Optional[CalibrationSyncScheduler] = None
+
+
+def get_calibration_sync_scheduler() -> CalibrationSyncScheduler:
+    global _scheduler
+    if _scheduler is None:
+        _scheduler = CalibrationSyncScheduler()
+    return _scheduler

backend/services/snapshot.py

@@ -10,6 +10,7 @@ from sqlalchemy.orm import Session
 
 from backend.database import get_db_session
 from backend.models import Emitter, RosterUnit, IgnoredUnit
+from backend.services.unit_location import bulk_active_locations
 
 log = logging.getLogger(__name__)
 
@@ -137,6 +138,10 @@ def emit_status_snapshot():
         emitters = {e.id: e for e in db.query(Emitter).all()}
         ignored = {i.id for i in db.query(IgnoredUnit).all()}
 
+        # Active-assignment location lookup for all roster units (direct only;
+        # modems inherit from their paired device below in the derive loop).
+        active_locs = bulk_active_locations(db, list(roster.values()))
+
         # SFM event-forwards are now the primary "last seen" signal for
         # seismographs.  Watcher heartbeats stay as a backup — if SFM is down
         # or hasn't seen a serial, we fall back to Emitter.last_seen.
@@ -225,10 +230,13 @@ def emit_status_snapshot():
                 "ip_address": r.ip_address,
                 "phone_number": r.phone_number,
                     "hardware_model": r.hardware_model,
-                    # Location for mapping
+                    # Location for mapping — sourced from active UnitAssignment
-                    "location": r.location or "",
+                    # → MonitoringLocation.  Empty for benched / unassigned.
-                    "address": r.address or "",
+                    "address":       (active_locs.get(unit_id) or {}).get("address") or "",
-                    "coordinates": r.coordinates or "",
+                    "coordinates":   (active_locs.get(unit_id) or {}).get("coordinates") or "",
+                    "location_name": (active_locs.get(unit_id) or {}).get("name") or "",
+                    "project_id":    (active_locs.get(unit_id) or {}).get("project_id") or "",
+                    "location_id":   (active_locs.get(unit_id) or {}).get("location_id") or "",
                 }
 
         # --- Add unexpected emitter-only units ---
@@ -267,10 +275,12 @@ def emit_status_snapshot():
                     "ip_address": None,
                     "phone_number": None,
                     "hardware_model": None,
-                    # Location fields
+                    # Location fields — unknown units have no assignment
-                    "location": "",
                     "address": "",
                     "coordinates": "",
+                    "location_name": "",
+                    "project_id": "",
+                    "location_id": "",
                 }
 
         # --- Derive modem status from paired devices ---
@@ -301,6 +311,11 @@ def emit_status_snapshot():
                         unit_data["last"] = paired_unit.get("last")
                         unit_data["last_seen_source"] = paired_unit.get("last_seen_source", "none")
                         unit_data["derived_from"] = paired_unit_id
+                        # Inherit deployment location too — modems don't carry
+                        # their own UnitAssignment.
+                        for k in ("address", "coordinates", "location_name", "project_id", "location_id"):
+                            if not unit_data.get(k):
+                                unit_data[k] = paired_unit.get(k, "")
 
         # Separate buckets for UI
         active_units = {

backend/services/unit_location.py

@@ -0,0 +1,125 @@
+"""
+Active-assignment location resolution for roster units.
+
+`RosterUnit.location`, `.address`, `.coordinates` are legacy per-unit fields.
+The current source of truth for "where is this unit deployed right now" is the
+active `UnitAssignment` (assigned_until IS NULL) pointing at a
+`MonitoringLocation`, which carries the canonical address/coordinates/name.
+
+Modems don't get their own `UnitAssignment` — they're paired with a
+seismograph or SLM via `deployed_with_unit_id`.  A deployed modem inherits the
+location of its paired device's active assignment.
+
+Returned dict shape (or None if no active assignment resolvable):
+    {
+        "location_id":   "uuid",
+        "project_id":    "uuid",
+        "name":          "NRL-001",
+        "address":       "123 Main St" | None,
+        "coordinates":   "34.0522,-118.2437" | None,
+        "via_paired_unit_id": "BE1234" | None,   # set only for modems
+    }
+"""
+
+from typing import Optional
+
+from sqlalchemy.orm import Session
+
+from backend.models import MonitoringLocation, RosterUnit, UnitAssignment
+
+
+def _serialize(loc: MonitoringLocation, via_paired_unit_id: Optional[str] = None) -> dict:
+    return {
+        "location_id": loc.id,
+        "project_id":  loc.project_id,
+        "name":        loc.name,
+        "address":     loc.address or None,
+        "coordinates": loc.coordinates or None,
+        "via_paired_unit_id": via_paired_unit_id,
+    }
+
+
+def _active_location_for_unit_id(db: Session, unit_id: str) -> Optional[MonitoringLocation]:
+    """Return the MonitoringLocation tied to this unit's active assignment, if any."""
+    row = (
+        db.query(MonitoringLocation)
+        .join(UnitAssignment, UnitAssignment.location_id == MonitoringLocation.id)
+        .filter(
+            UnitAssignment.unit_id == unit_id,
+            UnitAssignment.assigned_until == None,  # noqa: E711
+        )
+        .order_by(UnitAssignment.assigned_at.desc())
+        .first()
+    )
+    return row
+
+
+def get_active_location(db: Session, unit_id: str) -> Optional[dict]:
+    """
+    Resolve the active deployment location for a unit.
+
+    Seismographs / SLMs: their own active UnitAssignment.
+    Modems: follow `deployed_with_unit_id` to the paired device's active
+            assignment (modems don't carry their own assignment).
+    """
+    unit = db.query(RosterUnit).filter_by(id=unit_id).first()
+    if unit is None:
+        return None
+
+    if (unit.device_type or "seismograph") == "modem":
+        paired_id = unit.deployed_with_unit_id
+        if not paired_id:
+            return None
+        loc = _active_location_for_unit_id(db, paired_id)
+        return _serialize(loc, via_paired_unit_id=paired_id) if loc else None
+
+    loc = _active_location_for_unit_id(db, unit_id)
+    return _serialize(loc) if loc else None
+
+
+def bulk_active_locations(db: Session, units: list[RosterUnit]) -> dict[str, dict]:
+    """
+    Resolve active locations for many units in two queries.  Use this from
+    snapshot-style loops to avoid N+1 lookups.
+
+    Returns {unit_id: <serialized location dict>} — only populated for units
+    that resolve to an active assignment.  Modems are resolved by walking
+    `deployed_with_unit_id` to the paired device's entry in the same map.
+    """
+    if not units:
+        return {}
+
+    direct_unit_ids = [
+        u.id for u in units
+        if (u.device_type or "seismograph") != "modem"
+    ]
+
+    direct: dict[str, MonitoringLocation] = {}
+    if direct_unit_ids:
+        rows = (
+            db.query(UnitAssignment.unit_id, MonitoringLocation)
+            .join(MonitoringLocation, MonitoringLocation.id == UnitAssignment.location_id)
+            .filter(
+                UnitAssignment.unit_id.in_(direct_unit_ids),
+                UnitAssignment.assigned_until == None,  # noqa: E711
+            )
+            .order_by(UnitAssignment.assigned_at.desc())
+            .all()
+        )
+        # First row wins per unit_id (most recent assigned_at).
+        for unit_id, loc in rows:
+            direct.setdefault(unit_id, loc)
+
+    out: dict[str, dict] = {
+        uid: _serialize(loc) for uid, loc in direct.items()
+    }
+
+    # Modems inherit from paired device.
+    for u in units:
+        if (u.device_type or "seismograph") != "modem":
+            continue
+        paired_id = u.deployed_with_unit_id
+        if paired_id and paired_id in direct:
+            out[u.id] = _serialize(direct[paired_id], via_paired_unit_id=paired_id)
+
+    return out

docs/ROADMAP.md

@@ -0,0 +1,67 @@
+# Terra-View Roadmap
+
+Living document — captures known deferred work, in-flight initiatives, and longer-term ideas.
+Bump items up/down or strike them through as priorities shift. Source of truth for "what's next"
+should be this file plus the `## Current Development Focus` block in `CLAUDE.md`.
+
+Last updated: 2026-06-05 (Terra-View v0.13.3)
+
+---
+
+## In Flight
+
+Work that's started or has obvious next steps in the code.
+
+- **SFM Integration Phase 2 — device control** — expose `/device/*` (start, stop, erase, push-config)
+  through the Terra-View proxy. Blocked on SFM growing an auth layer; placeholder TODOs already in
+  `backend/services/device_controller.py` (lines 73, 109, 207, 282, 582).
+- **Calibration sync from SFM events** — done in v0.13.x. Daily 03:15 job + Settings "Sync now" button.
+  Future: surface "last sync" timestamp on unit detail; per-unit "sync this one" action.
+- **Synology NAS deployment** — doc lives at `docs/SYNOLOGY_DEPLOYMENT.md`. Need to actually deploy
+  + write up what tripped us up vs. the doc's expectations.
+
+## Near-Term
+
+Concrete things scoped but not started.
+
+- **Migrate GPS coord parse in `photos.py`** — currently writes to dead `RosterUnit.coordinates`
+  field. Should write to the active `MonitoringLocation` instead (matches the location-as-truth
+  refactor done elsewhere). Helper: `backend/services/unit_location.py`.
+- **Phase 3 — drag-to-resize deployment bars** on the fleet-wide deployment-history Gantt
+  (`/tools/deployment-history`). Phase 2 (the calendar + Gantt tabs) shipped in v0.12.0.
+- **Phase 5c — swap-detection daily job** — placeholder card already in `templates/tools.html:162`.
+  Auto-detects unit swaps in the field (BE12345 → BE67890 at the same project+location) from
+  operator-typed metadata. Pairs with a notification inbox.
+- **Geocoding for address strings** — TODO in `templates/dashboard.html:913`. Lets locations without
+  explicit coordinates still appear on maps.
+- **ModemManager backend** — `backend/routers/modem_dashboard.py:279` has a TODO for querying a real
+  modem backend. Currently the modem dashboard is mostly read-only metadata.
+
+## Medium-Term
+
+Bigger features, sketched but not designed in detail.
+
+- **Alerting** — email/SMS for missing units, calibration-expiring-soon, sync failures.
+  README's "Future Enhancements" has had this for a while; would pair well with the existing
+  `UserPreferences` thresholds.
+- **Multi-user auth** — currently single-tenant, no login. Probably the prerequisite for any
+  cloud-hosted multi-customer deployment.
+- **Notification inbox** — central place for swap-detection alerts, sync errors, calibration
+  warnings, FT-flag review queue, etc.
+- **Audit log UI** — `UnitHistory` already records everything; expose a filterable view.
+
+## Long-Term / Wishlist
+
+Speculative. Promote up the list once there's a concrete need.
+
+- PostgreSQL backend for larger deployments (SQLite is fine for now)
+- Advanced filtering / saved searches on roster + events
+- Export roster in additional formats (XLSX, GeoJSON)
+- Public-facing project status pages (read-only, share-link gated)
+- SLM module parity with seismographs — modal-based event/measurement detail similar to SFM modal
+- Weather station / accelerometer / GPS tracker modules (new device-type modules following the
+  SLMM pattern — see `CLAUDE.md` → "Adding a New Device Type Module")
+
+## Done / Reference
+
+For shipped items, see `CHANGELOG.md`. For architecture decisions, see `CLAUDE.md`.

requirements.txt

@@ -9,3 +9,4 @@ Pillow==10.1.0
 httpx==0.25.2
 openpyxl==3.1.2
 rapidfuzz==3.10.1
+schedule==1.2.2

templates/dashboard.html

@@ -150,46 +150,55 @@ setInterval(_refreshPendingDeployBanner, 30000);
                     </svg>
                 </div>
             </div>
-            <div class="space-y-3 card-content" id="fleet-summary-content">
+            <div class="space-y-4 card-content" id="fleet-summary-content">
-                <div class="flex justify-between items-center">
+                <!-- Seismographs -->
-                    <span class="text-gray-600 dark:text-gray-400">Total Units</span>
+                <div>
-                    <span id="total-units" class="text-3xl md:text-2xl font-bold text-gray-900 dark:text-white">--</span>
+                    <div class="flex justify-between items-center mb-1.5">
-                </div>
-                <div class="flex justify-between items-center">
-                    <span class="text-gray-600 dark:text-gray-400">Deployed</span>
-                    <span id="deployed-units" class="text-3xl md:text-2xl font-bold text-blue-600 dark:text-blue-400">--</span>
-                </div>
-                <div class="flex justify-between items-center">
-                    <span class="text-gray-600 dark:text-gray-400">Benched</span>
-                    <span id="benched-units" class="text-3xl md:text-2xl font-bold text-gray-600 dark:text-gray-400">--</span>
-                </div>
-                <div class="flex justify-between items-center">
-                    <span class="text-orange-600 dark:text-orange-400">Allocated</span>
-                    <span id="allocated-units" class="text-3xl md:text-2xl font-bold text-orange-500 dark:text-orange-400">--</span>
-                </div>
-                <div class="border-t border-gray-200 dark:border-gray-700 pt-3 mt-3">
-                    <p class="text-xs text-gray-500 dark:text-gray-500 mb-2 italic">By Device Type:</p>
-                    <div class="flex justify-between items-center mb-1">
                         <div class="flex items-center">
                             <svg class="w-4 h-4 mr-1.5 text-blue-500" fill="none" stroke="currentColor" viewBox="0 0 24 24">
                                 <path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M9 19v-6a2 2 0 00-2-2H5a2 2 0 00-2 2v6a2 2 0 002 2h2a2 2 0 002-2zm0 0V9a2 2 0 012-2h2a2 2 0 012 2v10m-6 0a2 2 0 002 2h2a2 2 0 002-2m0 0V5a2 2 0 012-2h2a2 2 0 012 2v14a2 2 0 01-2 2h-2a2 2 0 01-2-2z"></path>
                             </svg>
-                            <a href="/seismographs" class="text-sm text-gray-600 dark:text-gray-400 hover:text-blue-600 dark:hover:text-blue-400">Seismographs</a>
+                            <a href="/seismographs" class="text-sm font-semibold text-gray-800 dark:text-gray-200 hover:text-blue-600 dark:hover:text-blue-400">Seismographs</a>
                         </div>
-                        <span id="seismo-count" class="font-semibold text-blue-600 dark:text-blue-400">--</span>
+                        <span id="seismo-count" class="text-lg font-bold text-blue-600 dark:text-blue-400">--</span>
                     </div>
-                    <div class="flex justify-between items-center mb-2">
+                    <div class="pl-6 flex flex-col gap-0.5 text-sm">
+                        <div class="flex justify-between">
+                            <span class="text-gray-500 dark:text-gray-400">Deployed</span>
+                            <span id="seismo-deployed" class="font-medium text-gray-800 dark:text-gray-200">--</span>
+                        </div>
+                        <div class="flex justify-between">
+                            <span class="text-gray-500 dark:text-gray-400">Benched</span>
+                            <span id="seismo-benched" class="font-medium text-gray-800 dark:text-gray-200">--</span>
+                        </div>
+                    </div>
+                </div>
+
+                <!-- Sound Level Meters -->
+                <div>
+                    <div class="flex justify-between items-center mb-1.5">
                         <div class="flex items-center">
                             <svg class="w-4 h-4 mr-1.5 text-purple-500" fill="none" stroke="currentColor" viewBox="0 0 24 24">
                                 <path stroke-linecap="round" stroke-linejoin="round" stroke-width="2" d="M15.536 8.464a5 5 0 010 7.072m2.828-9.9a9 9 0 010 12.728M5.586 15H4a1 1 0 01-1-1v-4a1 1 0 011-1h1.586l4.707-4.707C10.923 3.663 12 4.109 12 5v14c0 .891-1.077 1.337-1.707.707L5.586 15z"></path>
                             </svg>
-                            <a href="/sound-level-meters" class="text-sm text-gray-600 dark:text-gray-400 hover:text-purple-600 dark:hover:text-purple-400">Sound Level Meters</a>
+                            <a href="/sound-level-meters" class="text-sm font-semibold text-gray-800 dark:text-gray-200 hover:text-purple-600 dark:hover:text-purple-400">Sound Level Meters</a>
+                        </div>
+                        <span id="slm-count" class="text-lg font-bold text-purple-600 dark:text-purple-400">--</span>
+                    </div>
+                    <div class="pl-6 flex flex-col gap-0.5 text-sm">
+                        <div class="flex justify-between">
+                            <span class="text-gray-500 dark:text-gray-400">Deployed</span>
+                            <span id="slm-deployed" class="font-medium text-gray-800 dark:text-gray-200">--</span>
+                        </div>
+                        <div class="flex justify-between">
+                            <span class="text-gray-500 dark:text-gray-400">Benched</span>
+                            <span id="slm-benched" class="font-medium text-gray-800 dark:text-gray-200">--</span>
                         </div>
-                        <span id="slm-count" class="font-semibold text-purple-600 dark:text-purple-400">--</span>
                     </div>
                 </div>
+
                 <div class="border-t border-gray-200 dark:border-gray-700 pt-3 mt-3">
-                    <p class="text-xs text-gray-500 dark:text-gray-500 mb-2 italic">Deployed Status:</p>
+                    <p class="text-xs text-gray-500 dark:text-gray-500 mb-2 italic">Call-in Status:</p>
                     <div class="flex justify-between items-center mb-2" title="Units reporting normally (last seen < 12 hours)">
                         <div class="flex items-center">
                             <span class="w-3 h-3 rounded-full bg-green-500 mr-2 flex items-center justify-center">
@@ -628,9 +637,14 @@ function updateFleetMapFiltered(allUnits) {
     fleetMarkers.forEach(marker => fleetMap.removeLayer(marker));
     fleetMarkers = [];
 
-    // Get deployed units with coordinates that pass the filter
+    // Get deployed units with coordinates that pass the filter.
+    // Modems are not plotted — they inherit the paired device's location,
+    // which would just stack a duplicate marker on the same pin.
     const deployedUnits = Object.entries(allUnits || {})
-        .filter(([_, u]) => u.deployed && u.coordinates && unitPassesFilter(u));
+        .filter(([_, u]) => u.deployed
+            && u.coordinates
+            && (u.device_type || 'seismograph') !== 'modem'
+            && unitPassesFilter(u));
 
     if (deployedUnits.length === 0) {
         return;
@@ -672,10 +686,12 @@ function updateFleetMapFiltered(allUnits) {
             // Popup with device type
             const deviceLabel = getDeviceTypeLabel(deviceType);
 
+            const locName = unit.location_name || '';
             marker.bindPopup(`
                 <div class="p-2">
                     <h3 class="font-bold text-lg">${id}</h3>
                     <p class="text-sm text-gray-600">${deviceLabel}</p>
+                    ${locName ? `<p class="text-sm text-gray-700">📍 ${locName}</p>` : ''}
                     <p class="text-sm">Status: <span style="color: ${markerColor}">${unit.status}</span></p>
                     ${unit.note ? `<p class="text-sm text-gray-600">${unit.note}</p>` : ''}
                     <a href="/unit/${id}" class="text-blue-600 hover:underline text-sm">View Details</a>
@@ -783,32 +799,51 @@ function updateDashboard(event) {
             timeZoneName: 'short'
         });
 
-        // ===== Fleet summary numbers (always unfiltered) =====
+        // ===== Fleet Summary: per-device-type counts (always unfiltered) =====
-        document.getElementById('total-units').textContent = data.summary?.total ?? 0;
+        // Deployed = unit has an active UnitAssignment (location_id set by
-        document.getElementById('deployed-units').textContent = data.summary?.active ?? 0;
+        // the snapshot helper).  Benched = no active assignment.
-        document.getElementById('benched-units').textContent = data.summary?.benched ?? 0;
+        // Retired, out-for-calibration, and roster-unknown units (emitters
-        document.getElementById('allocated-units').textContent = data.summary?.allocated ?? 0;
+        // not in the roster) are excluded from totals.
-        document.getElementById('status-ok').textContent = data.summary?.ok ?? 0;
+        const counts = {
-        document.getElementById('status-pending').textContent = data.summary?.pending ?? 0;
+            seismograph:        { total: 0, deployed: 0, benched: 0 },
-        document.getElementById('status-missing').textContent = data.summary?.missing ?? 0;
+            sound_level_meter:  { total: 0, deployed: 0, benched: 0 },
+        };
+        let monitoredOk = 0, monitoredPending = 0, monitoredMissing = 0;
+        const unknownIds = new Set(Object.keys(data.unknown || {}));
 
-        // ===== Device type counts (always unfiltered) =====
+        Object.entries(data.units || {}).forEach(([uid, unit]) => {
-        let seismoCount = 0;
+            if (unit.retired || unit.out_for_calibration) return;
-        let slmCount = 0;
+            if (unknownIds.has(uid)) return;
-        let modemCount = 0;
+            const dt = unit.device_type || 'seismograph';
-        Object.values(data.units || {}).forEach(unit => {
+            const bucket = counts[dt];
-            if (unit.retired) return; // Don't count retired units
+            if (!bucket) return;          // skip modems and anything else
-            const deviceType = unit.device_type || 'seismograph';
+
-            if (deviceType === 'seismograph') {
+            bucket.total++;
-                seismoCount++;
+            if (unit.location_id) {
-            } else if (deviceType === 'sound_level_meter') {
+                bucket.deployed++;
-                slmCount++;
+            } else {
-            } else if (deviceType === 'modem') {
+                bucket.benched++;
-                modemCount++;
+            }
+
+            // Status tally only for seismographs + SLMs that are actually
+            // deployed (assigned).  Mirrors the per-device buckets so the
+            // sum matches.
+            if (unit.location_id) {
+                if (unit.status === 'OK')      monitoredOk++;
+                else if (unit.status === 'Pending') monitoredPending++;
+                else if (unit.status === 'Missing') monitoredMissing++;
             }
         });
-        document.getElementById('seismo-count').textContent = seismoCount;
+
-        document.getElementById('slm-count').textContent = slmCount;
+        document.getElementById('seismo-count').textContent     = counts.seismograph.total;
+        document.getElementById('seismo-deployed').textContent  = counts.seismograph.deployed;
+        document.getElementById('seismo-benched').textContent   = counts.seismograph.benched;
+        document.getElementById('slm-count').textContent        = counts.sound_level_meter.total;
+        document.getElementById('slm-deployed').textContent     = counts.sound_level_meter.deployed;
+        document.getElementById('slm-benched').textContent      = counts.sound_level_meter.benched;
+        document.getElementById('status-ok').textContent        = monitoredOk;
+        document.getElementById('status-pending').textContent   = monitoredPending;
+        document.getElementById('status-missing').textContent   = monitoredMissing;
 
         // ===== Apply filters and render map + alerts =====
         renderFilteredDashboard(data);

templates/settings.html

@@ -472,6 +472,20 @@
             <button onclick="saveCalibrationDefaults()" class="mt-6 px-6 py-3 bg-seismo-orange hover:bg-orange-600 text-white rounded-lg transition-colors">
                 Save Defaults
             </button>
+
+            <div class="mt-8 pt-6 border-t border-gray-200 dark:border-gray-700">
+                <h3 class="text-lg font-semibold text-gray-900 dark:text-white mb-2">Sync from SFM events</h3>
+                <p class="text-sm text-gray-500 dark:text-gray-400 mb-3">
+                    Reads <code>calibration_date</code> from each seismograph's most recent event sidecar and updates
+                    <em>Last Calibrated</em> when the device reports a newer date than what's stored.
+                    Manual edits made after the latest event are preserved. Runs automatically once a day.
+                </p>
+                <button onclick="runCalibrationSync()" id="cal-sync-btn"
+                        class="px-6 py-3 bg-blue-600 hover:bg-blue-700 text-white rounded-lg transition-colors">
+                    Sync now
+                </button>
+                <div id="cal-sync-result" class="mt-3 text-sm text-gray-700 dark:text-gray-300"></div>
+            </div>
         </div>
     </div>
 </div>
@@ -890,6 +904,41 @@ async function saveCalibrationDefaults() {
     }
 }
 
+async function runCalibrationSync() {
+    const btn = document.getElementById('cal-sync-btn');
+    const out = document.getElementById('cal-sync-result');
+    btn.disabled = true;
+    const originalLabel = btn.textContent;
+    btn.textContent = 'Syncing…';
+    out.textContent = '';
+    out.className = 'mt-3 text-sm text-gray-700 dark:text-gray-300';
+
+    try {
+        const response = await fetch('/api/calibration/sync', { method: 'POST' });
+        const data = await response.json();
+        if (!response.ok) {
+            out.className = 'mt-3 text-sm text-red-600 dark:text-red-400';
+            out.textContent = 'Error: ' + (data.detail || response.statusText);
+            return;
+        }
+        const parts = [
+            `Checked ${data.checked}`,
+            `Updated ${data.updated}`,
+            `Already in sync ${data.already_in_sync}`,
+            `Manual kept ${data.skipped_manual_newer}`,
+            `No event ${data.no_event}`,
+        ];
+        if (data.errors) parts.push(`Errors ${data.errors}`);
+        out.textContent = parts.join(' · ');
+    } catch (error) {
+        out.className = 'mt-3 text-sm text-red-600 dark:text-red-400';
+        out.textContent = 'Error: ' + error.message;
+    } finally {
+        btn.disabled = false;
+        btn.textContent = originalLabel;
+    }
+}
+
 // ========== DATA TAB - IMPORT/EXPORT ==========
 
 // Merge Mode Import

templates/unit_detail.html

@@ -129,6 +129,15 @@
                         <span id="viewProjectNoLink" class="text-gray-900 dark:text-white font-medium">Not assigned</span>
                     </p>
                 </div>
+                <div>
+                    <label class="text-sm font-medium text-gray-500 dark:text-gray-400">Deployment Location</label>
+                    <p id="viewLocationContainer" class="mt-1">
+                        <a id="viewLocationLink" href="#" class="text-seismo-orange hover:text-orange-600 font-medium hover:underline hidden">
+                            <span id="viewLocationText">--</span>
+                        </a>
+                        <span id="viewLocationNoLink" class="text-gray-500 dark:text-gray-400 italic">Not deployed</span>
+                    </p>
+                </div>
                 <div>
                     <label class="text-sm font-medium text-gray-500 dark:text-gray-400">Address</label>
                     <p id="viewAddress" class="mt-1 text-gray-900 dark:text-white font-medium">--</p>
@@ -639,18 +648,12 @@
                     {% include "partials/project_picker.html" with context %}
                 </div>
 
-                <!-- Address -->
+                <!-- Address / coordinates are managed on the project's
-                <div>
+                     MonitoringLocation, not the unit itself.  Edit them on
-                    <label class="block text-sm font-medium text-gray-700 dark:text-gray-300 mb-2">Address</label>
+                     the project page. -->
-                    <input type="text" name="address" id="address" placeholder="123 Main St, City, State"
+                <div class="md:col-span-2 rounded-lg bg-gray-50 dark:bg-slate-700/50 border border-gray-200 dark:border-gray-700 p-3 text-sm text-gray-600 dark:text-gray-400">
-                        class="w-full px-4 py-2 rounded-lg border border-gray-300 dark:border-gray-600 bg-white dark:bg-slate-700 text-gray-900 dark:text-white focus:ring-2 focus:ring-seismo-orange">
+                    Address &amp; coordinates are set on the deployment location.
-                </div>
+                    Open the project to edit them.
-
-                <!-- Coordinates -->
-                <div class="md:col-span-2">
-                    <label class="block text-sm font-medium text-gray-700 dark:text-gray-300 mb-2">Coordinates</label>
-                    <input type="text" name="coordinates" id="coordinates" placeholder="34.0522,-118.2437"
-                        class="w-full px-4 py-2 rounded-lg border border-gray-300 dark:border-gray-600 bg-white dark:bg-slate-700 text-gray-900 dark:text-white focus:ring-2 focus:ring-seismo-orange font-mono">
                 </div>
             </div>
 
@@ -848,16 +851,6 @@
                             class="w-4 h-4 text-seismo-orange focus:ring-seismo-orange rounded">
                         <span class="text-sm text-gray-700 dark:text-gray-300">Project</span>
                     </label>
-                    <label class="flex items-center gap-2 cursor-pointer">
-                        <input type="checkbox" name="cascade_location" id="detailCascadeLocation" value="true"
-                            class="w-4 h-4 text-seismo-orange focus:ring-seismo-orange rounded">
-                        <span class="text-sm text-gray-700 dark:text-gray-300">Address</span>
-                    </label>
-                    <label class="flex items-center gap-2 cursor-pointer">
-                        <input type="checkbox" name="cascade_coordinates" id="detailCascadeCoordinates" value="true"
-                            class="w-4 h-4 text-seismo-orange focus:ring-seismo-orange rounded">
-                        <span class="text-sm text-gray-700 dark:text-gray-300">Coordinates</span>
-                    </label>
                     <label class="flex items-center gap-2 cursor-pointer">
                         <input type="checkbox" name="cascade_note" id="detailCascadeNote" value="true"
                             class="w-4 h-4 text-seismo-orange focus:ring-seismo-orange rounded">
@@ -1168,8 +1161,28 @@ function populateViewMode() {
         if (projectLink) projectLink.classList.add('hidden');
     }
 
-    document.getElementById('viewAddress').textContent = currentUnit.address || '--';
+    // Deployment Location — comes from the active UnitAssignment →
-    document.getElementById('viewCoordinates').textContent = currentUnit.coordinates || '--';
+    // MonitoringLocation.  Show project link if present, otherwise
+    // "Not deployed" placeholder.
+    const locLink   = document.getElementById('viewLocationLink');
+    const locText   = document.getElementById('viewLocationText');
+    const locNoLink = document.getElementById('viewLocationNoLink');
+    const activeLoc = currentUnit.active_location;
+    if (activeLoc && activeLoc.location_id) {
+        if (locText) locText.textContent = activeLoc.name || activeLoc.address || 'Active location';
+        if (locLink) {
+            locLink.href = `/projects/${activeLoc.project_id}`;
+            locLink.classList.remove('hidden');
+        }
+        if (locNoLink) locNoLink.classList.add('hidden');
+    } else {
+        if (locLink) locLink.classList.add('hidden');
+        if (locNoLink) locNoLink.classList.remove('hidden');
+    }
+
+    // Address / coordinates also come from the active assignment.
+    document.getElementById('viewAddress').textContent = (activeLoc && activeLoc.address) || '--';
+    document.getElementById('viewCoordinates').textContent = (activeLoc && activeLoc.coordinates) || '--';
 
     // Seismograph fields
     document.getElementById('viewLastCalibrated').textContent = currentUnit.last_calibrated || '--';
@@ -1327,8 +1340,6 @@ function populateEditForm() {
         if (projectPickerClear) projectPickerClear.classList.add('hidden');
     }
 
-    document.getElementById('address').value = currentUnit.address || '';
-    document.getElementById('coordinates').value = currentUnit.coordinates || '';
     document.getElementById('deployed').checked = currentUnit.deployed;
     document.getElementById('outForCalibration').checked = currentUnit.out_for_calibration || false;
     document.getElementById('retired').value = currentUnit.retired ? 'true' : '';
@@ -1609,8 +1620,13 @@ function initUnitMap() {
     // Update marker (can be called multiple times)
     updateMapMarker(lat, lon);
 
-    // Update location text
+    // Update location text — prefer the assignment's location name, fall
+    // back to address, then coordinates.
     const locationParts = [];
+    const loc = currentUnit.active_location;
+    if (loc && loc.name) {
+        locationParts.push(loc.name);
+    }
     if (currentUnit.address) {
         locationParts.push(currentUnit.address);
     }
@@ -1724,13 +1740,12 @@ async function uploadPhoto(file) {
 
         const result = await response.json();
 
-        // Show success message with metadata info
+        // Show success message with metadata info.  Location is on the
+        // assignment's MonitoringLocation now, so we just surface what GPS
+        // came in — the backend no longer mutates the unit row.
         let message = 'Photo uploaded successfully!';
         if (result.metadata && result.metadata.coordinates) {
             message += ` GPS location detected: ${result.metadata.coordinates}`;
-            if (result.coordinates_updated) {
-                message += ' (Unit coordinates updated automatically)';
-            }
         } else {
             message += ' No GPS data found in photo.';
         }
@@ -1738,11 +1753,8 @@ async function uploadPhoto(file) {
         statusDiv.className = 'mt-4 p-4 rounded-lg bg-green-100 dark:bg-green-900 text-green-800 dark:text-green-200';
         statusDiv.textContent = message;
 
-        // Reload photos and unit data
+        // Reload photos
         await loadPhotos();
-        if (result.coordinates_updated) {
-            await loadUnitData();
-        }
 
         // Hide status after 5 seconds
         setTimeout(() => {