fix bulk sync

Author: jonhealy1

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py

@@ -275,6 +275,7 @@ def delete_item(self, item_id: str, collection_id: str):
             )
 
     def create_collection(self, collection: stac_types.Collection):
+        """Database logic for creating one collection."""
         if self.client.exists(index=COLLECTIONS_INDEX, id=collection["id"]):
             raise ConflictError(f"Collection {collection['id']} already exists")
 
@@ -285,20 +286,22 @@ def create_collection(self, collection: stac_types.Collection):
         )
 
     def prep_update_collection(self, collection_id: str):
+        """Database logic for updating a collection."""
         try:
             _ = self.client.get(index=COLLECTIONS_INDEX, id=collection_id)
         except elasticsearch.exceptions.NotFoundError:
             raise NotFoundError(f"Collection {collection_id} not found")
 
     def delete_collection(self, collection_id: str):
+        """Database logic for deleting one collection."""
         try:
             _ = self.client.get(index=COLLECTIONS_INDEX, id=collection_id)
         except elasticsearch.exceptions.NotFoundError:
             raise NotFoundError(f"Collection {collection_id} not found")
         self.client.delete(index=COLLECTIONS_INDEX, id=collection_id)
 
-     def bulk_sync(self, processed_items):
-        """Database logic for bulk insertion."""
+    def bulk_sync(self, processed_items):
+        """Database logic for bulk item insertion."""
         actions = [
             {
                 "_index": ITEMS_INDEX,

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/transactions.py

@@ -49,7 +49,7 @@ def create_item(self, item: stac_types.Item, **kwargs) -> stac_types.Item:
                 bulk_client.preprocess_item(item, base_url) for item in item["features"]
             ]
             return_msg = f"Successfully added {len(processed_items)} items."
-            bulk_client.bulk_sync(processed_items)
+            self.database.bulk_sync(processed_items)
 
             return return_msg
         else: