create collection

Author: jonhealy1

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py

@@ -273,3 +273,13 @@ def delete_item(self, item_id: str, collection_id: str):
                 f"Item {item_id} in collection {collection_id} not found"
             )
 
+    def create_collection(self, collection: stac_types.Collection):
+        if self.client.exists(index=COLLECTIONS_INDEX, id=collection["id"]):
+            raise ConflictError(f"Collection {collection['id']} already exists")
+
+        self.client.index(
+            index=COLLECTIONS_INDEX,
+            id=collection["id"],
+            document=collection,
+        )
+

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/transactions.py

@@ -91,15 +91,8 @@ def create_collection(
             collection_id=collection["id"], base_url=base_url
         ).create_links()
         collection["links"] = collection_links
+        self.database.create_collection(collection=collection)
 
-        if self.client.exists(index=COLLECTIONS_INDEX, id=collection["id"]):
-            raise ConflictError(f"Collection {collection['id']} already exists")
-
-        self.client.index(
-            index=COLLECTIONS_INDEX,
-            id=collection["id"],
-            document=collection,
-        )
         return CollectionSerializer.db_to_stac(collection, base_url)
 
     @overrides