feat(python): added async client

flipt-python/flipt/__init__.py

@@ -1,5 +1,7 @@
+from .async_client import AsyncFliptClient
 from .sync_client import FliptClient
 
 __all__ = [
     'FliptClient',
+    'AsyncFliptClient',
 ]

flipt-python/flipt/async_client.py

@@ -0,0 +1,19 @@
+import httpx
+
+from .authentication import AuthenticationStrategy
+from .evaluation import AsyncEvaluation
+
+
+class AsyncFliptClient:
+    def __init__(
+        self,
+        url: str = "http://localhost:8080",
+        timeout: int = 60,
+        authentication: AuthenticationStrategy | None = None,
+    ):
+        self.httpx_client = httpx.AsyncClient(timeout=timeout)
+
+        self.evaluation = AsyncEvaluation(url, authentication, self.httpx_client)
+
+    async def close(self) -> None:
+        await self.httpx_client.aclose()

flipt-python/flipt/evaluation/__init__.py

@@ -1,3 +1,4 @@
+from .async_evaluation_client import AsyncEvaluation
 from .models import (
     BatchEvaluationRequest,
     BatchEvaluationResponse,
@@ -14,6 +15,7 @@
 
 __all__ = [
     'Evaluation',
+    'AsyncEvaluation',
     'EvaluationResponseType',
     'EvaluationReason',
     'ErrorEvaluationReason',

flipt-python/flipt/evaluation/async_evaluation_client.py

@@ -0,0 +1,74 @@
+from http import HTTPStatus
+
+import httpx
+
+from ..authentication import AuthenticationStrategy
+from ..exceptions import FliptApiError
+from .models import (
+    BatchEvaluationRequest,
+    BatchEvaluationResponse,
+    BooleanEvaluationResponse,
+    EvaluationRequest,
+    VariantEvaluationResponse,
+)
+
+
+class AsyncEvaluation:
+    def __init__(
+        self,
+        url: str,
+        authentication: AuthenticationStrategy | None = None,
+        httpx_client: httpx.AsyncClient | None = None,
+    ):
+        self.url = url
+        self.headers: dict[str, str] = {}
+
+        self._client = httpx_client or httpx.AsyncClient()
+
+        if authentication:
+            authentication.authenticate(self.headers)
+
+    async def close(self) -> None:
+        await self._client.aclose()
+
+    async def variant(self, request: EvaluationRequest) -> VariantEvaluationResponse:
+        response = await self._client.post(
+            f"{self.url}/evaluate/v1/variant",
+            headers=self.headers,
+            json=request.model_dump(),
+        )
+
+        if response.status_code != 200:
+            body = response.json()
+            message = body.get("message", HTTPStatus(response.status_code).description)
+            raise FliptApiError(message, response.status_code)
+
+        return VariantEvaluationResponse.model_validate_json(response.text)
+
+    async def boolean(self, request: EvaluationRequest) -> BooleanEvaluationResponse:
+        response = await self._client.post(
+            f"{self.url}/evaluate/v1/boolean",
+            headers=self.headers,
+            json=request.model_dump(),
+        )
+
+        if response.status_code != 200:
+            body = response.json()
+            message = body.get("message", HTTPStatus(response.status_code).description)
+            raise FliptApiError(message, response.status_code)
+
+        return BooleanEvaluationResponse.model_validate_json(response.text)
+
+    async def batch(self, request: BatchEvaluationRequest) -> BatchEvaluationResponse:
+        response = await self._client.post(
+            f"{self.url}/evaluate/v1/batch",
+            headers=self.headers,
+            json=request.model_dump(),
+        )
+
+        if response.status_code != 200:
+            body = response.json()
+            message = body.get("message", HTTPStatus(response.status_code).description)
+            raise FliptApiError(message, response.status_code)
+
+        return BatchEvaluationResponse.model_validate_json(response.text)