feat(thing): expose phenomenonTime on Thing for STAC and DCAT-AP temporal extent

api/app/models/thing.py

@@ -14,6 +14,7 @@
 
 from app.db.sqlalchemy_db import SCHEMA_NAME, Base
 from sqlalchemy.dialects.postgresql.json import JSON
+from sqlalchemy.dialects.postgresql.ranges import TSTZRANGE
 from sqlalchemy.orm import relationship
 from sqlalchemy.sql.schema import Column, ForeignKey
 from sqlalchemy.sql.sqltypes import Integer, String, Text
@@ -36,6 +37,7 @@ class Thing(Base):
     name = Column(String(255), nullable=False)
     description = Column(Text, nullable=False)
     properties = Column(JSON)
+    phenomenon_time = Column("phenomenonTime", TSTZRANGE)
     commit_id = Column(Integer, ForeignKey(f"{SCHEMA_NAME}.Commit.id"))
     location = relationship(
         "Location", secondary=Thing_Location, back_populates="thing"

api/app/sta2rest/sta2rest.py

@@ -128,6 +128,7 @@ class STA2REST:
             "name",
             "description",
             "properties",
+            "phenomenon_time",
         ],
         "ThingTravelTime": [
             "id",
@@ -138,6 +139,7 @@ class STA2REST:
             "name",
             "description",
             "properties",
+            "phenomenon_time",
             "system_time_validity",
         ],
         "HistoricalLocation": [

database/istsos_schema.sql

@@ -72,6 +72,21 @@ CREATE OR REPLACE FUNCTION "Datastreams@iot.navigationLink"(sensorthings."Thing"
     SELECT '/Things(' || $1.id || ')/Datastreams';
 $$ LANGUAGE SQL;
 
+CREATE OR REPLACE FUNCTION "phenomenonTime"(sensorthings."Thing") RETURNS tstzrange AS $$
+BEGIN
+    RETURN (
+        SELECT tstzrange(
+            min(lower(d."phenomenonTime")),
+            max(upper(d."phenomenonTime")),
+            '[]'
+        )
+        FROM sensorthings."Datastream" d
+        WHERE d."thing_id" = $1.id
+          AND d."phenomenonTime" IS NOT NULL
+    );
+END;
+$$ LANGUAGE plpgsql STABLE;
+
 CREATE TABLE IF NOT EXISTS sensorthings."Thing_Location" (
     "thing_id" BIGINT NOT NULL REFERENCES sensorthings."Thing"(id) ON DELETE CASCADE,
     "location_id" BIGINT NOT NULL REFERENCES sensorthings."Location"(id) ON DELETE CASCADE,