Elasticsearch to lower index name

Author: strawgate

key-value/key-value-aio/src/key_value/aio/stores/elasticsearch/store.py

@@ -207,7 +207,7 @@ def __init__(
         LessCapableJsonSerializer.install_default_serializer(client=self._client)
         LessCapableNdjsonSerializer.install_serializer(client=self._client)
 
-        self._index_prefix = index_prefix
+        self._index_prefix = index_prefix.lower()
         self._native_storage = native_storage
         self._is_serverless = False
 
@@ -237,7 +237,7 @@ async def _setup_collection(self, *, collection: str) -> None:
         _ = await self._client.options(ignore_status=404).indices.create(index=index_name, mappings=DEFAULT_MAPPING, settings={})
 
     def _get_index_name(self, collection: str) -> str:
-        return self._index_prefix + "-" + self._collection_sanitization.sanitize(value=collection)
+        return self._index_prefix + "-" + self._collection_sanitization.sanitize(value=collection).lower()
 
     def _get_document_id(self, key: str) -> str:
         return self._key_sanitization.sanitize(value=key)

key-value/key-value-sync/src/key_value/sync/code_gen/stores/elasticsearch/store.py

@@ -176,7 +176,7 @@ def __init__(
         LessCapableJsonSerializer.install_default_serializer(client=self._client)
         LessCapableNdjsonSerializer.install_serializer(client=self._client)
 
-        self._index_prefix = index_prefix
+        self._index_prefix = index_prefix.lower()
         self._native_storage = native_storage
         self._is_serverless = False
 
@@ -206,7 +206,7 @@ def _setup_collection(self, *, collection: str) -> None:
         _ = self._client.options(ignore_status=404).indices.create(index=index_name, mappings=DEFAULT_MAPPING, settings={})
 
     def _get_index_name(self, collection: str) -> str:
-        return self._index_prefix + "-" + self._collection_sanitization.sanitize(value=collection)
+        return self._index_prefix + "-" + self._collection_sanitization.sanitize(value=collection).lower()
 
     def _get_document_id(self, key: str) -> str:
         return self._key_sanitization.sanitize(value=key)