fixup: adding gherkin tests for evaluations, and fxing found issues

Signed-off-by: Simon Schrottner <[email protected]>

Author: aepfli

providers/openfeature-provider-flagd/src/openfeature/contrib/provider/flagd/resolvers/in_process.py

@@ -84,8 +84,6 @@ def resolve_float_details(
         evaluation_context: typing.Optional[EvaluationContext] = None,
     ) -> FlagResolutionDetails[float]:
         result = self._resolve(key, default_value, evaluation_context)
-        if not isinstance(result.value, float):
-            result.value = float(result.value)
         return result
 
     def resolve_integer_details(
@@ -95,8 +93,6 @@ def resolve_integer_details(
         evaluation_context: typing.Optional[EvaluationContext] = None,
     ) -> FlagResolutionDetails[int]:
         result = self._resolve(key, default_value, evaluation_context)
-        if not isinstance(result.value, int):
-            result.value = int(result.value)
         return result
 
     def resolve_object_details(

providers/openfeature-provider-flagd/src/openfeature/contrib/provider/flagd/resolvers/process/connector/grpc_watcher.py

@@ -30,7 +30,14 @@ def __init__(
     ):
         self.flag_store = flag_store
         channel_factory = grpc.secure_channel if config.tls else grpc.insecure_channel
-        self.channel = channel_factory(f"{config.host}:{config.port}")
+        self.channel = channel_factory(
+            f"{config.host}:{config.port}",
+            options=(
+                ("grpc.max_reconnect_backoff_ms", 1000),
+                ("grpc.initial_reconnect_backoff_ms", 1000),
+                ("grpc.keepalive_time_ms", 1000),
+            ),
+        )
         self.stub = sync_pb2_grpc.FlagSyncServiceStub(self.channel)
         self.timeout = config.timeout
         self.retry_backoff_seconds = config.retry_backoff_seconds
@@ -62,11 +69,10 @@ def shutdown(self) -> None:
         self.active = False
 
     def sync_flags(self) -> None:
-        request = sync_pb2.SyncFlagsRequest(selector=self.selector)  # type:ignore[attr-defined]
-
         retry_delay = self.retry_backoff_seconds
         while self.active:
             try:
+                request = sync_pb2.SyncFlagsRequest(selector=self.selector)  # type:ignore[attr-defined]
                 logger.debug("Setting up gRPC sync flags connection")
                 for flag_rsp in self.stub.SyncFlags(request):
                     flag_str = flag_rsp.flag_configuration
@@ -107,4 +113,4 @@ def sync_flags(self) -> None:
             )
             logger.info(f"gRPC sync disconnected, reconnecting in {retry_delay}s")
             time.sleep(retry_delay)
-            retry_delay = min(2 * retry_delay, self.MAX_BACK_OFF)
+            retry_delay = min(2, self.MAX_BACK_OFF)

providers/openfeature-provider-flagd/src/openfeature/contrib/provider/flagd/resolvers/process/flags.py

@@ -72,6 +72,10 @@ def from_dict(cls, key: str, data: dict) -> "Flag":
             data["default_variant"] = data["defaultVariant"]
             del data["defaultVariant"]
 
+        if "source" in data:
+            del data["source"]
+        if "selector" in data:
+            del data["selector"]
         try:
             flag = cls(key=key, **data)
             return flag

providers/openfeature-provider-flagd/test-harness

@@ -5,29 +5,22 @@
 from tests.e2e.flagd_container import FlagdContainer
 from tests.e2e.steps import *  # noqa: F403
 
-from openfeature import api
-from openfeature.contrib.provider.flagd import FlagdProvider
-
 JsonPrimitive = typing.Union[str, bool, float, int]
 
 
-@pytest.fixture(autouse=True, scope="package")
-def setup(request, port, image, resolver_type):
+@pytest.fixture(autouse=True, scope="module")
+def setup(request, port, image):
     container: DockerContainer = FlagdContainer(
         image=image,
         port=port,
     )
     # Setup code
     c = container.start()
-    api.set_provider(
-        FlagdProvider(
-            resolver_type=resolver_type,
-            port=int(container.get_exposed_port(port)),
-        )
-    )
 
     def fin():
         c.stop()
 
     # Teardown code
     request.addfinalizer(fin)
+
+    return c.get_exposed_port(port)