fix(flagd): widen metadata TypedDict and cover EventStream selector

- types.py: metadata is now variadic tuple[tuple[str, str], ...] to allow >1 entry and satisfy mypy.\n- tests: import FLAGD_SELECTOR_HEADER from the resolver instead of hardcoding, and add coverage for the EventStream listen() path (both with and without selector).

Signed-off-by: Todd Baert <todd.baert@dynatrace.com>

Author: toddbaert

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

@@ -4,4 +4,4 @@
 class GrpcMultiCallableArgs(typing.TypedDict, total=False):
     timeout: float | None
     wait_for_ready: bool | None
-    metadata: tuple[tuple[str, str]] | None
+    metadata: tuple[tuple[str, str], ...] | None

providers/openfeature-provider-flagd/tests/test_grpc_resolver.py

@@ -2,7 +2,10 @@
 
 from openfeature.contrib.provider.flagd.config import Config
 from openfeature.contrib.provider.flagd.flag_type import FlagType
-from openfeature.contrib.provider.flagd.resolvers.grpc import GrpcResolver
+from openfeature.contrib.provider.flagd.resolvers.grpc import (
+    FLAGD_SELECTOR_HEADER,
+    GrpcResolver,
+)
 from openfeature.schemas.protobuf.flagd.evaluation.v2 import evaluation_pb2
 
 
@@ -30,7 +33,7 @@ def test_unary_call_includes_selector_metadata_when_configured():
     resolver._resolve("flag", FlagType.BOOLEAN, False, None)
 
     kwargs = mock_stub.ResolveBoolean.call_args.kwargs
-    assert kwargs.get("metadata") == (("flagd-selector", "test-selector"),)
+    assert kwargs.get("metadata") == ((FLAGD_SELECTOR_HEADER, "test-selector"),)
 
 
 def test_unary_call_omits_metadata_when_no_selector():
@@ -45,3 +48,35 @@ def test_unary_call_omits_metadata_when_no_selector():
 
     kwargs = mock_stub.ResolveBoolean.call_args.kwargs
     assert "metadata" not in kwargs
+
+
+def test_event_stream_includes_selector_metadata_when_configured():
+    resolver = _make_resolver("test-selector")
+    mock_stub = MagicMock()
+    mock_stub.EventStream = Mock(side_effect=Exception("break loop"))
+    resolver.stub = mock_stub
+    resolver.active = True
+
+    try:
+        resolver.listen()
+    except Exception:
+        pass
+
+    kwargs = mock_stub.EventStream.call_args.kwargs
+    assert kwargs.get("metadata") == ((FLAGD_SELECTOR_HEADER, "test-selector"),)
+
+
+def test_event_stream_omits_metadata_when_no_selector():
+    resolver = _make_resolver(None)
+    mock_stub = MagicMock()
+    mock_stub.EventStream = Mock(side_effect=Exception("break loop"))
+    resolver.stub = mock_stub
+    resolver.active = True
+
+    try:
+        resolver.listen()
+    except Exception:
+        pass
+
+    kwargs = mock_stub.EventStream.call_args.kwargs
+    assert "metadata" not in kwargs