Replace a moving feature with PUT /collections/{cid}/items/{fid}

PUT on a feature replaces its temporal geometry and properties from the posted
Feature: the feature is deleted (the foreign-key cascade removes its temporal
geometries, properties and values) and re-inserted under the same id in one
transaction, reusing the create path and the extent trigger. do_PUT routes the
items path to the new handler before the collection PUT.

Author: estebanzimanyi

resource/moving_feature/Replace.py

@@ -0,0 +1,46 @@
+# PUT /collections/{collectionId}/items/{mFeatureId}
+# Replace a moving feature: its temporal geometry and properties are replaced by
+# the posted Feature. The feature is deleted (the FK cascade removes its temporal
+# geometries / properties / values) and re-inserted under the same id, in one
+# transaction, so the replace reuses the create path and the extent trigger.
+import json
+
+from utils import send_json_response
+from resource.moving_features.Create import insert_feature
+
+
+def put_single_moving_feature(self, collection_id, feature_id, connection, cursor):
+    try:
+        content_length = int(self.headers.get("Content-Length", 0))
+        body = json.loads(self.rfile.read(content_length).decode("utf-8")) if content_length else {}
+
+        cursor.execute("SELECT id FROM collections WHERE id = %s", (collection_id,))
+        if cursor.fetchone() is None:
+            self.handle_error(404, f"Collection '{collection_id}' not found")
+            return
+
+        cursor.execute(
+            "SELECT id FROM moving_features WHERE id = %s AND collection_id = %s",
+            (feature_id, collection_id),
+        )
+        if cursor.fetchone() is None:
+            self.handle_error(404, f"Feature '{feature_id}' not found in collection '{collection_id}'")
+            return
+
+        # Full replace: drop the feature (cascades to its temporal geometries,
+        # properties and values) and re-insert it under the path id.
+        cursor.execute(
+            "DELETE FROM moving_features WHERE id = %s AND collection_id = %s",
+            (feature_id, collection_id),
+        )
+        body["id"] = feature_id
+        if body.get("type") is None:
+            body["type"] = "Feature"
+        insert_feature(self, body, collection_id, connection, cursor)
+        connection.commit()
+
+        send_json_response(self, 200, {"message": "replaced", "id": feature_id})
+
+    except Exception as e:
+        connection.rollback()
+        self.handle_error(400, f"Replace failed: {str(e)}")

server.py

@@ -15,6 +15,7 @@
 from resource.moving_features.Retrieve import get_collection_items
 from resource.moving_feature.Retrieve import get_movement_single_moving_feature
 from resource.moving_feature.Delete import delete_single_moving_feature
+from resource.moving_feature.Replace import put_single_moving_feature
 from resource.temporal_geom_seq.Retrieve import get_tgsequence
 from resource.temporal_geom_seq.Create import post_tgsequence
 from resource.bulk.Create import post_bulk
@@ -242,8 +243,12 @@ def do_DELETE(self):
 
 
     def do_PUT(self):
+        # PUT /collections/{collectionId}/items/{mFeatureId} — replace a feature
+        if self.path.startswith('/collections/') and '/items/' in self.path and len(self.path.split('/')) == 5:
+            parts = self.path.split('/')
+            self.put_single_moving_feature(parts[2], parts[4], connection, cursor)
         #===================================================PUT collection========================================
-        if self.path.startswith('/collections/'):
+        elif self.path.startswith('/collections/'):
             collection_id = self.path.split('/')[-1]
             self.put_collection(collection_id, connection, cursor)
 
@@ -370,6 +375,9 @@ def get_movement_single_moving_feature(self, collectionId, mFeatureId, connectio
     def delete_single_moving_feature(self, collectionId, mFeature_id, connection, cursor):
         delete_single_moving_feature(self, collectionId, mFeature_id, connection, cursor)
 
+    def put_single_moving_feature(self, collectionId, mFeature_id, connection, cursor):
+        put_single_moving_feature(self, collectionId, mFeature_id, connection, cursor)
+
 
 ## Resource Temporal Geometry Sequence
     #Get