elasticsearch - done

Author: Grzegorz Pustulka

stac_fastapi/opensearch/stac_fastapi/opensearch/database_logic.py

@@ -112,9 +112,12 @@ class DatabaseLogic(BaseDatabaseLogic):
 
     async_settings: AsyncSearchSettings = attr.ib(factory=AsyncSearchSettings)
     sync_settings: SyncSearchSettings = attr.ib(factory=SyncSearchSettings)
-    async_index_inserter: AsyncIndexInserter = attr.ib(init=False)
+
     async_index_selector: IndexSelectionStrategy = attr.ib(init=False)
     sync_index_selector: IndexSelectionStrategy = attr.ib(init=False)
+    async_index_inserter: AsyncIndexInserter = attr.ib(init=False)
+    sync_index_inserter: SyncIndexInserter = attr.ib(init=False)
+
     client = attr.ib(init=False)
     sync_client = attr.ib(init=False)
 

stac_fastapi/sfeos_helpers/stac_fastapi/sfeos_helpers/database/datetime.py

@@ -40,9 +40,9 @@ def return_date(
     if isinstance(interval, str):
         if "/" in interval:
             parts = interval.split("/")
-            result["gte"] = parts[0] if parts[0] != ".." else datetime_type.min
+            result["gte"] = parts[0] if parts[0] != ".." else datetime_type.min.isoformat() + "Z"
             result["lte"] = (
-                parts[1] if len(parts) > 1 and parts[1] != ".." else datetime_type.max
+                parts[1] if len(parts) > 1 and parts[1] != ".." else datetime_type.max.isoformat() + "Z"
             )
         else:
             converted_time = interval if interval != ".." else None

stac_fastapi/sfeos_helpers/stac_fastapi/sfeos_helpers/database/index.py

@@ -6,6 +6,7 @@
 from datetime import datetime
 from functools import lru_cache
 from typing import Any, List, Optional
+from dateutil.parser import parse
 
 from stac_fastapi.sfeos_helpers.mappings import (
     _ES_INDEX_NAME_UNSUPPORTED_CHARS_TABLE,
@@ -83,7 +84,7 @@ def filter_indexes_by_datetime(
 
     def parse_datetime(dt_str: str) -> datetime:
         """Parse datetime string, handling both with and without 'Z' suffix."""
-        return datetime.fromisoformat(dt_str.rstrip('Z'))
+        return parse(dt_str).replace(tzinfo=None)
 
     def extract_date_range_from_index(index_name: str) -> tuple:
         """Extract start and end dates from index name."""