feat: index_exists method for elastic adapter

Author: s.kazemi

archipy/adapters/elasticsearch/adapters.py

@@ -258,6 +258,23 @@ def exists(
         """
         return self.client.exists(index=index, id=doc_id, **kwargs)
 
+    @override
+    def index_exists(
+        self,
+        index: ElasticsearchIndexType,
+        **kwargs: object,
+    ) -> ElasticsearchResponseType:
+        """Check if an index exists in Elasticsearch.
+
+        Args:
+            index (ElasticsearchIndexType): The index name.
+            kwargs: Additional keyword arguments passed to the Elasticsearch client.
+
+        Returns:
+            ElasticsearchResponseType: True if the index exists, False otherwise.
+        """
+        return self.client.indices.exists(index=index, **kwargs)
+
 
 class AsyncElasticsearchAdapter(AsyncElasticsearchPort):
     """Concrete implementation of the AsyncElasticsearchPort interface using elasticsearch-py library.
@@ -495,3 +512,20 @@ async def exists(
             ElasticsearchResponseType: True if the document exists, False otherwise.
         """
         return await self.client.exists(index=index, id=doc_id, **kwargs)
+
+    @override
+    async def index_exists(
+        self,
+        index: ElasticsearchIndexType,
+        **kwargs: object,
+    ) -> ElasticsearchResponseType:
+        """Check if an index exists in Elasticsearch.
+
+        Args:
+            index (ElasticsearchIndexType): The index name.
+            kwargs: Additional keyword arguments passed to the Elasticsearch client.
+
+        Returns:
+            ElasticsearchResponseType: True if the index exists, False otherwise.
+        """
+        return await self.client.indices.exists(index=index, **kwargs)

archipy/adapters/elasticsearch/ports.py

@@ -228,6 +228,26 @@ def exists(
         """
         raise NotImplementedError
 
+    @abstractmethod
+    def index_exists(
+        self,
+        index: ElasticsearchIndexType,
+        **kwargs: object,
+    ) -> ElasticsearchResponseType:
+        """Check if an index exists in Elasticsearch.
+
+        Args:
+            index (ElasticsearchIndexType): The index name.
+            **kwargs (object): Additional keyword arguments passed to the Elasticsearch client.
+
+        Returns:
+            ElasticsearchResponseType: True if the index exists, False otherwise.
+
+        Raises:
+            NotImplementedError: If not implemented by the subclass.
+        """
+        raise NotImplementedError
+
 
 class AsyncElasticsearchPort:
     """Async interface for Elasticsearch operations providing a standardized access pattern.
@@ -447,3 +467,23 @@ async def exists(
             NotImplementedError: If not implemented by the subclass.
         """
         raise NotImplementedError
+
+    @abstractmethod
+    async def index_exists(
+        self,
+        index: ElasticsearchIndexType,
+        **kwargs: object,
+    ) -> ElasticsearchResponseType:
+        """Check if an index exists in Elasticsearch.
+
+        Args:
+            index (ElasticsearchIndexType): The index name.
+            **kwargs (object): Additional keyword arguments passed to the Elasticsearch client.
+
+        Returns:
+            ElasticsearchResponseType: True if the index exists, False otherwise.
+
+        Raises:
+            NotImplementedError: If not implemented by the subclass.
+        """
+        raise NotImplementedError