fix: ensure result.timestamp present for Go server schema validation

Go CSAPI server validates that observation results contain all fields
defined in the datastream schema. Publishers were popping 'timestamp'
from the result (SensorHub auto-fills from phenomenonTime), but Go
server requires it explicitly. Now re-adds timestamp from phenomenonTime
when missing. Also adds Go workaround to BuoyCAM and NIMS publishers.

Author: Sam-Bolling

publishers/aviation_wx/aviation_wx_publisher.py

@@ -288,8 +288,10 @@ def _post_observation(self, ds_id: str, obs: dict):
             for key, val in list(r.items()):
                 if val == "NaN":
                     r[key] = 0.0
-            # Coerce numeric timestamp to string
-            if "timestamp" in r and not isinstance(r["timestamp"], str):
+            # Go server requires timestamp in result (schema validation)
+            if "timestamp" not in r:
+                r["timestamp"] = obs.get("phenomenonTime", "")
+            elif not isinstance(r["timestamp"], str):
                 r["timestamp"] = str(r["timestamp"])
 
         url = f"{self._base_url}/datastreams/{ds_id}/observations"

publishers/coops/coops_publisher.py

@@ -310,8 +310,10 @@ def _post_observation(self, ds_id: str, obs: dict):
             for key, val in list(r.items()):
                 if val == "NaN":
                     r[key] = 0.0
-            # Coerce numeric timestamp to string
-            if "timestamp" in r and not isinstance(r["timestamp"], str):
+            # Go server requires timestamp in result (schema validation)
+            if "timestamp" not in r:
+                r["timestamp"] = obs.get("phenomenonTime", "")
+            elif not isinstance(r["timestamp"], str):
                 r["timestamp"] = str(r["timestamp"])
 
         url = f"{self._base_url}/datastreams/{ds_id}/observations"

publishers/iss/iss_publisher.py

@@ -255,10 +255,13 @@ def publish_obs(self, obs: dict) -> bool:
             import ssl
             url = f"{self._base_url}/datastreams/{self._ds_id}/observations"
 
-            # Go server: coerce numeric timestamp to string
-            if self._is_go_server:
-                r = obs.get("result", {})
-                if "timestamp" in r and not isinstance(r["timestamp"], str):
+# Go server workarounds
+        if self._is_go_server:
+            r = obs.get("result", {})
+            # Go server requires timestamp in result (schema validation)
+            if "timestamp" not in r:
+                r["timestamp"] = obs.get("phenomenonTime", "")
+            elif not isinstance(r["timestamp"], str):
                     r["timestamp"] = str(r["timestamp"])
 
             body = json.dumps(obs).encode()

publishers/ndbc/ndbc_buoycam_publisher.py

@@ -212,6 +212,15 @@ def connect_with_retry(self, max_attempts=10, base_delay=5.0, max_delay=120.0):
 
     def _post_observation(self, ds_id: str, obs: dict):
         """POST an observation to the server."""
+        # Go server workarounds
+        if self._is_go_server:
+            r = obs.get("result", {})
+            # Go server requires timestamp in result (schema validation)
+            if "timestamp" not in r:
+                r["timestamp"] = obs.get("phenomenonTime", "")
+            elif not isinstance(r["timestamp"], str):
+                r["timestamp"] = str(r["timestamp"])
+
         url = f"{self._base_url}/datastreams/{ds_id}/observations"
         body = json.dumps(obs).encode()
 

publishers/ndbc/ndbc_publisher.py

@@ -255,8 +255,10 @@ def _post_observation(self, ds_id: str, obs: dict):
             for key, val in list(r.items()):
                 if val == "NaN":
                     r[key] = 0.0
-            # Coerce numeric timestamp to string
-            if "timestamp" in r and not isinstance(r["timestamp"], str):
+            # Go server requires timestamp in result (schema validation)
+            if "timestamp" not in r:
+                r["timestamp"] = obs.get("phenomenonTime", "")
+            elif not isinstance(r["timestamp"], str):
                 r["timestamp"] = str(r["timestamp"])
 
         url = f"{self._base_url}/datastreams/{ds_id}/observations"

publishers/nws/nws_publisher.py

@@ -226,8 +226,10 @@ def _post_observation(self, ds_id: str, obs: dict):
             for key, val in list(r.items()):
                 if val == "NaN":
                     r[key] = 0.0
-            # Coerce numeric timestamp to string
-            if "timestamp" in r and not isinstance(r["timestamp"], str):
+            # Go server requires timestamp in result (schema validation)
+            if "timestamp" not in r:
+                r["timestamp"] = obs.get("phenomenonTime", "")
+            elif not isinstance(r["timestamp"], str):
                 r["timestamp"] = str(r["timestamp"])
 
         url = f"{self._base_url}/datastreams/{ds_id}/observations"

publishers/usgs_nims/usgs_nims_publisher.py

@@ -235,6 +235,15 @@ def connect_with_retry(self, max_attempts=10, base_delay=5.0, max_delay=120.0):
 
     def _post_observation(self, ds_id: str, obs: dict):
         """POST an observation to the server."""
+        # Go server workarounds
+        if self._is_go_server:
+            r = obs.get("result", {})
+            # Go server requires timestamp in result (schema validation)
+            if "timestamp" not in r:
+                r["timestamp"] = obs.get("phenomenonTime", "")
+            elif not isinstance(r["timestamp"], str):
+                r["timestamp"] = str(r["timestamp"])
+
         url = f"{self._base_url}/datastreams/{ds_id}/observations"
         body = json.dumps(obs).encode()
 

publishers/usgs_water/usgs_water_publisher.py

@@ -250,8 +250,10 @@ def _post_observation(self, ds_id: str, obs: dict):
         # Go server workarounds
         if self._is_go_server:
             r = obs.get("result", {})
-            # Coerce numeric timestamp to string
-            if "timestamp" in r and not isinstance(r["timestamp"], str):
+            # Go server requires timestamp in result (schema validation)
+            if "timestamp" not in r:
+                r["timestamp"] = obs.get("phenomenonTime", "")
+            elif not isinstance(r["timestamp"], str):
                 r["timestamp"] = str(r["timestamp"])
 
         url = f"{self._base_url}/datastreams/{ds_id}/observations"