Model AIS feed as observation-only source

Author: Sam-Bolling

docs/research/finland-publisher-expansion/Finland_Source_Endpoint_Probe_2026-05-29.md

@@ -63,4 +63,4 @@ Selected Phase 4 demo window:
 
 Implementation choice: publish one bounded feed-adapter system and one `digitrafficMarineAisPosition` datastream. Runtime observations lift MMSI, vessel metadata, lat/lon, SOG, COG, heading, navigation status, ship type, destination, source update time, and compact source payload JSON. AIS sentinel values are normalized before publishing: SOG >= 102.2, COG >= 360, and heading >= 511 become `"NaN"`.
 
-Live smoke on 2026-05-30: bootstrapped procedure `04ig`, system `06702`, datastream `07hg2`, root deployment `06i02`, and feed deployment `06ig2` on the public SensorHub. The first retained full cycle used millisecond offsets from source snapshot time so the server stores all vessels from the same Digitraffic snapshot; public proxy verification returned 62 AIS observations, including the 60-record 2026-05-30T07:02:25Z cycle.
+Live smoke on 2026-05-30: bootstrapped procedure `04ig`, system `06702`, datastream `07hg2`, and root grouping deployment `06i02` on the public SensorHub. A legacy platform-linked feed deployment `06ig2` was removed after visual review because AIS is a feed adapter/query window, not a physical emplacement; Explorer should visualize the vessel observations rather than a static deployment symbol at the bbox center. The first retained full cycle used millisecond offsets from source snapshot time so the server stores all vessels from the same Digitraffic snapshot; public proxy verification returned 62 AIS observations, including the 60-record 2026-05-30T07:02:25Z cycle.

publishers/digitraffic_marine_ais/README.md

@@ -2,7 +2,7 @@
 
 Publishes live vessel positions from Fintraffic Digitraffic Marine AIS for a bounded Gulf of Finland demo window.
 
-The publisher uses a single CSAPI feed-adapter system and one datastream. Each publish cycle filters the public AIS latest-location feed to the configured bbox, caps the cycle to `max_vessels_per_cycle`, enriches records with vessel metadata where available, and emits one observation per vessel.
+The publisher uses a single CSAPI feed-adapter system and one datastream. It intentionally does not model the feed adapter as a physical deployment marker; the map experience comes from vessel observations, not a static sensor symbol at the query-window center. Each publish cycle filters the public AIS latest-location feed to the configured bbox, caps the cycle to `max_vessels_per_cycle`, enriches records with vessel metadata where available, and emits one observation per vessel.
 
 ```powershell
 py publishers\digitraffic_marine_ais\bootstrap_digitraffic_marine_ais.py --dry-run

publishers/digitraffic_marine_ais/bootstrap_digitraffic_marine_ais.py

@@ -18,7 +18,7 @@
 PROC_UID = "urn:os4csapi:procedure:digitraffic-marine-ais:v1"
 SYSTEM_UID = "urn:os4csapi:system:digitraffic-marine-ais-feed:v1"
 DEPLOY_ROOT_UID = "urn:os4csapi:deployment:digitraffic-marine-ais-demo:v1"
-DEPLOY_FEED_UID = "urn:os4csapi:deployment:digitraffic-marine-ais-feed:v1"
+LEGACY_DEPLOY_FEED_UID = "urn:os4csapi:deployment:digitraffic-marine-ais-feed:v1"
 DS_OUTPUT_NAME = "digitrafficMarineAisPosition"
 
 DIGITRAFFIC_MARINE_HOME = "https://www.digitraffic.fi/en/marine-traffic/"
@@ -88,13 +88,8 @@ def _deploy_root(config: dict) -> dict:
     return {"type": "Feature", "geometry": {"type": "Point", "coordinates": [lon, lat]}, "properties": {"uid": DEPLOY_ROOT_UID, "featureType": "sosa:Deployment", "name": "Digitraffic Marine AIS Demo", "description": "Top-level grouping for the Finnish Digitraffic Marine AIS feed-adapter demo.", "validTime": [VALID_TIME_START, ".."]}}
 
 
-def _deploy_feed(config: dict, system_server_id: str, base_url: str) -> dict:
-    lon, lat = _bbox_center(config)
-    return {"type": "Feature", "geometry": {"type": "Point", "coordinates": [lon, lat]}, "properties": {"uid": DEPLOY_FEED_UID, "featureType": "sosa:Deployment", "name": "Digitraffic Marine AIS Feed", "description": f"Deployment linking the Digitraffic Marine AIS feed adapter to the configured Gulf of Finland query window ({_bbox_label(config)}).", "validTime": [VALID_TIME_START, ".."], "platform@link": {"href": f"{base_url.rstrip('/')}/systems/{system_server_id}", "uid": SYSTEM_UID, "title": "Digitraffic Marine AIS Feed - Gulf of Finland"}}}
-
-
 def clean_all(base_url: str, auth: str, *, dry_run: bool, stats: dict):
-    clean_resource(base_url, auth, "deployments", DEPLOY_FEED_UID, dry_run=dry_run, stats=stats, cascade=True)
+    clean_resource(base_url, auth, "deployments", LEGACY_DEPLOY_FEED_UID, dry_run=dry_run, stats=stats, cascade=True)
     clean_resource(base_url, auth, "deployments", DEPLOY_ROOT_UID, dry_run=dry_run, stats=stats, cascade=True)
     clean_resource(base_url, auth, "systems", SYSTEM_UID, dry_run=dry_run, stats=stats, cascade=True)
     clean_resource(base_url, auth, "procedures", PROC_UID, dry_run=dry_run, stats=stats)
@@ -111,9 +106,7 @@ def bootstrap(*, clean: bool = False, clean_only: bool = False, dry_run: bool =
     print("  -- System + Datastream --"); system_id = ensure_system(base_url, auth, SYSTEM_UID, _system_stub(config), _system_sml(config), dry_run=dry_run, stats=stats, force_sml=force_sml)
     if system_id:
         ensure_datastream(base_url, auth, system_id, DS_OUTPUT_NAME, _datastream_schema(), dry_run=dry_run, stats=stats)
-    print("  -- Deployments --"); ensure_deployment(base_url, auth, DEPLOY_ROOT_UID, _deploy_root(config), dry_run=dry_run, stats=stats)
-    if system_id:
-        ensure_deployment(base_url, auth, DEPLOY_FEED_UID, _deploy_feed(config, system_id, base_url), dry_run=dry_run, stats=stats)
+    print("  -- Deployments --"); clean_resource(base_url, auth, "deployments", LEGACY_DEPLOY_FEED_UID, dry_run=dry_run, stats=stats, cascade=False); ensure_deployment(base_url, auth, DEPLOY_ROOT_UID, _deploy_root(config), dry_run=dry_run, stats=stats)
     print_summary(stats, dry_run)