fixup: naming

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

Author: aepfli

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

@@ -125,7 +125,7 @@ def setup_resolver(self) -> AbstractResolver:
         ):
             return InProcessResolver(
                 self.config,
-                self.on_provider_ready,
+                self.emit_provider_ready_with_context,
                 self.emit_provider_error,
                 self.emit_provider_stale,
                 self.emit_provider_configuration_changed,
@@ -196,7 +196,7 @@ def resolve_object_details(
             key, default_value, evaluation_context
         )
 
-    def on_provider_ready(self, details: ProviderEventDetails, metadata: dict) -> None:
-        self.enriched_context = metadata
+    def emit_provider_ready_with_context(self, details: ProviderEventDetails, context: dict) -> None:
+        self.enriched_context = context
         self.emit_provider_ready(details)
         pass

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

@@ -137,7 +137,7 @@ def monitor(self) -> None:
 
     def _state_change_callback(self, new_state: ChannelConnectivity) -> None:
         logger.debug(f"gRPC state change: {new_state}")
-        if new_state == ChannelConnectivity.READY:
+        if new_state == ChannelConnectivity.READY or new_state == ChannelConnectivity.IDLE:
             if not self.thread or not self.thread.is_alive():
                 self.thread = threading.Thread(
                     target=self.listen,

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

@@ -107,7 +107,7 @@ def monitor(self) -> None:
 
     def _state_change_callback(self, new_state: grpc.ChannelConnectivity) -> None:
         logger.debug(f"gRPC state change: {new_state}")
-        if new_state == grpc.ChannelConnectivity.READY:
+        if new_state == grpc.ChannelConnectivity.READY or new_state == grpc.ChannelConnectivity.IDLE:
             if not self.thread or not self.thread.is_alive():
                 self.thread = threading.Thread(
                     target=self.listen,