remmove base_url from elasticsearch

Author: jonhealy1

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/core.py

@@ -53,7 +53,7 @@ async def all_collections(self, **kwargs) -> Collections:
         """Read all collections from the database."""
         base_url = str(kwargs["request"].base_url)
         collection_list = await self.database.get_all_collections()
-        collection_list =  [
+        collection_list = [
             self.collection_serializer.db_to_stac(c, base_url=base_url)
             for c in collection_list
         ]
@@ -91,7 +91,6 @@ async def item_collection(
     ) -> ItemCollection:
         """Read an item collection from the database."""
         request: Request = kwargs["request"]
-        base_url = str(request.base_url)
 
         items, maybe_count, next_token = await self.database.execute_search(
             search=self.database.apply_collections_filter(
@@ -100,7 +99,6 @@ async def item_collection(
             limit=limit,
             token=token,
             sort=None,
-            base_url=base_url,
         )
 
         context_obj = None
@@ -273,12 +271,10 @@ async def post_search(
             limit=limit,
             token=search_request.token,  # type: ignore
             sort=sort,
-            base_url=base_url,
         )
 
         items = [
-            self.item_serializer.db_to_stac(item, base_url=base_url)
-            for item in items
+            self.item_serializer.db_to_stac(item, base_url=base_url) for item in items
         ]
 
         # if self.extension_is_enabled("FieldsExtension"):

stac_fastapi/elasticsearch/stac_fastapi/elasticsearch/database_logic.py

@@ -71,9 +71,7 @@ async def get_all_collections(self) -> List[Collection]:
         # https://github.com/stac-utils/stac-fastapi-elasticsearch/issues/65
         # collections should be paginated, but at least return more than the default 10 for now
         collections = await self.client.search(index=COLLECTIONS_INDEX, size=1000)
-        return [
-            c["_source"] for c in collections["hits"]["hits"]
-        ]
+        return [c["_source"] for c in collections["hits"]["hits"]]
 
     async def get_one_item(self, collection_id: str, item_id: str) -> Dict:
         """Database logic to retrieve a single item."""
@@ -192,7 +190,6 @@ async def execute_search(
         limit: int,
         token: Optional[str],
         sort: Optional[Dict[str, Dict[str, str]]],
-        base_url: str,
     ) -> Tuple[List[Item], Optional[int], Optional[str]]:
         """Database logic to execute search with limit."""
         search_after = None
@@ -218,9 +215,7 @@ async def execute_search(
         es_response = await search_task
 
         hits = es_response["hits"]["hits"]
-        items = [
-            hit["_source"] for hit in hits
-        ]
+        items = [hit["_source"] for hit in hits]
 
         next_token = None
         if hits and (sort_array := hits[-1].get("sort")):