Merge pull request #68 from negatic/master

Test Stage and Various Fixes

Author: HosseinNejatiJavaremi

.env.test

@@ -17,7 +17,7 @@ FASTAPI__SWAGGER_UI_PARAMS={}
 
 # Redis Configuration (RedisConfig)
 REDIS__MASTER_HOST=localhost:6379
-REDIS__IMAGE=redis:7-alpine
+REDIS__IMAGE=redis:8.2.0
 REDIS__DATABASE=0
 REDIS__PASSWORD=test_password
 
@@ -31,20 +31,27 @@ POSTGRES_SQLALCHEMY__PASSWORD=test_password
 
 # Keycloak Configuration (KeycloakConfig)
 KEYCLOAK__SERVER_URL=http://localhost:8080
-KEYCLOAK__IMAGE=quay.io/keycloak/keycloak:23.0
+KEYCLOAK__IMAGE=quay.io/keycloak/keycloak:26.3
 KEYCLOAK__ADMIN_USERNAME=admin
 KEYCLOAK__ADMIN_PASSWORD=admin
 KEYCLOAK__REALM_NAME=master
+KEYCLOAK__CLIENT_ID=admin-cli
+KEYCLOAK__IS_ADMIN_MODE_ENABLED=true
+KEYCLOAK__ADMIN_USERNAME=admin
+KEYCLOAK__ADMIN_PASSWORD=admin
+KEYCLOAK__ADMIN_REALM_NAME=master
+KEYCLOAK__VERIFY_SSL=false
+KEYCLOAK__TIMEOUT=30
 
 # Elasticsearch Configuration (ElasticsearchConfig)
 ELASTIC__HOSTS=["http://localhost:9200"]
-ELASTIC__IMAGE=repo.smartech.ir/elasticsearch/elasticsearch:9.1.0
+ELASTIC__IMAGE=docker.elastic.co/elasticsearch/elasticsearch:9.1.0
 ELASTIC__PORT=9200
 ELASTIC__HTTP_USER_NAME=elastic
 ELASTIC__HTTP_PASSWORD=test_password
 
 # Kafka Configuration (KafkaConfig)
-KAFKA__IMAGE=confluentinc/cp-kafka:7.4.0
+KAFKA__IMAGE=confluentinc/cp-kafka:7.4.10
 KAFKA__BROKERS_LIST=["localhost:9092"]
 
 # MinIO Configuration (MinioConfig)

.github/workflows/tests.yml

@@ -0,0 +1,41 @@
+name: Behave Tests
+
+on:
+  push:
+    branches: [ master ]
+  pull_request:
+    branches: [ '*' ]
+
+jobs:
+  behave-tests:
+    runs-on: ubuntu-latest
+    strategy:
+      matrix:
+        python-version: ["3.13"]
+
+    steps:
+    - uses: actions/checkout@v4
+
+    - name: Set up Python ${{ matrix.python-version }}
+      uses: actions/setup-python@v4
+      with:
+        python-version: ${{ matrix.python-version }}
+
+    - name: Install Poetry
+      uses: snok/install-poetry@v1
+      with:
+        virtualenvs-create: true
+        virtualenvs-in-project: true
+
+    - name: Cache Poetry virtualenv
+      uses: actions/cache@v3
+      id: cache
+      with:
+        path: .venv
+        key: venv-${{ runner.os }}-${{ matrix.python-version }}-${{ hashFiles('pyproject.toml') }}
+
+    - name: Install dependencies
+      run: make install-dev
+
+    - name: Run Behave tests
+      run: make behave

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

features/environment.py

@@ -27,12 +27,12 @@ class TestConfig(BaseConfig):
     )
 
     # Test container images
-    REDIS__IMAGE: str = "redis:7-alpine"
+    REDIS__IMAGE: str = "redis:8.2.0"
     POSTGRES__IMAGE: str = "postgres:17"
-    ELASTIC__IMAGE: str = "elasticsearch:9.1.0"
-    KAFKA__IMAGE: str = "confluentinc/cp-kafka:7.4.0"
-    MINIO__IMAGE: str = "minio/minio:latest"
-    KEYCLOAK__IMAGE: str = "quay.io/keycloak/keycloak:23.0"
+    ELASTIC__IMAGE: str = "docker.elastic.co/elasticsearch/elasticsearch:9.1.0"
+    KAFKA__IMAGE: str = "confluentinc/cp-kafka:7.4.10"
+    MINIO__IMAGE: str = "quay.io/minio/minio:latest"
+    KEYCLOAK__IMAGE: str = "quay.io/keycloak/keycloak:26.3"
 
     def __init__(self, **kwargs):
         super().__init__(**kwargs)

features/exception_utils.feature

@@ -18,7 +18,7 @@ Feature: Exception Utilities
   Scenario: Handle a gRPC exception
     Given a gRPC exception "BaseError"
     When gRPC exception is handled
-    Then the response should have gRPC status "UNKNOWN"
+    Then the response should have gRPC status "INTERNAL"
 
   Scenario: Generate FastAPI exception responses
     Given a list of FastAPI errors ["InvalidPhoneNumberError", "NotFoundError"]