Update opensearch collection patch.

Author: rhysrevans3

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py

@@ -988,12 +988,9 @@ async def json_patch_item(
             )
 
         except exceptions.BadRequestError as exc:
-            detail = (
-                exc.info["error"]["caused_by"]["to_string"]
-                if "to_string" in exc.info["error"]["caused_by"]
-                else exc.info["error"]["caused_by"]
-            )
-            raise HTTPException(status_code=400, detail=detail) from exc
+            raise HTTPException(
+                status_code=400, detail=exc.info["error"]["caused_by"]
+            ) from exc
 
         item = await self.get_one_item(collection_id, item_id)
 
@@ -1228,12 +1225,9 @@ async def json_patch_collection(
             )
 
         except exceptions.BadRequestError as exc:
-            detail = (
-                exc.info["error"]["caused_by"]["to_string"]
-                if "to_string" in exc.info["error"]["caused_by"]
-                else exc.info["error"]["caused_by"]
-            )
-            raise HTTPException(status_code=400, detail=detail) from exc
+            raise HTTPException(
+                status_code=400, detail=exc.info["error"]["caused_by"]
+            ) from exc
 
         collection = await self.find_collection(collection_id)
 

stac_fastapi/opensearch/stac_fastapi/opensearch/database_logic.py

@@ -1021,7 +1021,7 @@ async def json_patch_item(
 
         except exceptions.RequestError as exc:
             raise HTTPException(
-                status_code=400, detail=exc.info["error"]["caused_by"]["to_string"]
+                status_code=400, detail=exc.info["error"]["caused_by"]
             ) from exc
 
         item = await self.get_one_item(collection_id, item_id)
@@ -1237,8 +1237,8 @@ async def json_patch_collection(
 
         for operation in operations:
             if (
-                operation["op"] in ["add", "replace"]
-                and operation["path"] == "collection"
+                operation.op in ["add", "replace"]
+                and operation.path == "collection"
                 and collection_id != operation["value"]
             ):
                 new_collection_id = operation["value"]
@@ -1252,13 +1252,14 @@ async def json_patch_collection(
             await self.client.update(
                 index=COLLECTIONS_INDEX,
                 id=collection_id,
-                script=script,
+                body={"script": script},
                 refresh=True,
             )
 
         except exceptions.BadRequestError as exc:
+
             raise HTTPException(
-                status_code=400, detail=exc.info["error"]["caused_by"]["to_string"]
+                status_code=400, detail=exc.info["error"]["caused_by"]
             ) from exc
 
         collection = await self.find_collection(collection_id)