adjust rpc resolver

Signed-off-by: lea konvalinka <lea.konvalinka@dynatrace.com>

Author: leakonvalinka

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/FlagdProvider.java

@@ -194,7 +194,7 @@ EvaluationContext getEnrichedContext() {
 
     @SuppressWarnings("checkstyle:fallthrough")
     private void onProviderEvent(FlagdProviderEvent flagdProviderEvent) {
-        log.info("FlagdProviderEvent event {} ", flagdProviderEvent.getEvent());
+        log.debug("FlagdProviderEvent event {} ", flagdProviderEvent.getEvent());
         synchronized (syncResources) {
             /*
              * We only use Error and Ready as previous states.
@@ -240,7 +240,6 @@ private void onProviderEvent(FlagdProviderEvent flagdProviderEvent) {
 
     private void onError() {
         this.emitProviderError(ProviderEventDetails.builder().errorCode(ErrorCode.PROVIDER_FATAL).build());
-        shutdown();
     }
 
     private void onConfigurationChanged(FlagdProviderEvent flagdProviderEvent) {

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java

@@ -143,7 +143,6 @@ private void observeSyncStream() {
                     if (fatalStatusCodes.contains(metaEx.getStatus().getCode().name())) {
                         //throw new FatalError("Failed to connect for metadata request, not retrying for error " + metaEx.getStatus());
                         enqueueFatal("Fatal: Failed to connect for metadata request, not retrying for error " + metaEx.getStatus().getCode());
-                        return;
                     }
                     // retry for other status codes
                     String message = metaEx.getMessage();

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/rpc/RpcResolver.java

@@ -68,6 +68,7 @@ public final class RpcResolver implements Resolver {
     private final Consumer<FlagdProviderEvent> onProviderEvent;
     private final ServiceStub stub;
     private final ServiceBlockingStub blockingStub;
+    private final List<String> fatalStatusCodes;
 
     /**
      * Resolves flag values using
@@ -89,6 +90,7 @@ public RpcResolver(
         this.stub = ServiceGrpc.newStub(this.connector.getChannel()).withWaitForReady();
         this.blockingStub =
                 ServiceGrpc.newBlockingStub(this.connector.getChannel()).withWaitForReady();
+        this.fatalStatusCodes = options.getFatalStatusCodes();
     }
 
     // testing only
@@ -107,6 +109,7 @@ protected RpcResolver(
         this.onProviderEvent = onProviderEvent;
         this.stub = mockStub;
         this.blockingStub = mockBlockingStub;
+        this.fatalStatusCodes = options.getFatalStatusCodes();
     }
 
     /**
@@ -353,7 +356,12 @@ private void observeEventStream() throws InterruptedException {
                     log.debug(
                             "Exception in event stream connection, streamException {}, will reconnect",
                             streamException);
-                    this.handleErrorOrComplete();
+                    if (streamException instanceof StatusRuntimeException && fatalStatusCodes.contains(
+                            ((StatusRuntimeException) streamException).getStatus().getCode().name())) {
+                        this.handleFatalError();
+                    } else {
+                        this.handleErrorOrComplete();
+                    }
                     break;
                 }
 
@@ -412,9 +420,15 @@ private void handleProviderReadyEvent() {
      * Handles provider error events by clearing the cache (if enabled) and notifying listeners of the error.
      */
     private void handleErrorOrComplete() {
-        log.debug("Emitting provider error event");
+        log.debug("Emitting provider stale event");
 
         // complete is an error, logically...even if the server went down gracefully we need to reconnect.
+        onProviderEvent.accept(new FlagdProviderEvent(ProviderEvent.PROVIDER_STALE));
+    }
+
+    private void handleFatalError() {
+        log.debug("Emitting provider error event");
+
         onProviderEvent.accept(new FlagdProviderEvent(ProviderEvent.PROVIDER_ERROR));
     }
 }