fixup: revert enum change

Signed-off-by: Todd Baert <[email protected]>

Author: toddbaert

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/InProcessResolver.java

@@ -88,10 +88,10 @@ public void init() throws Exception {
 
                             log.debug("post onConnectionEvent.accept ProviderEvent.PROVIDER_CONFIGURATION_CHANGED");
                             break;
-                        case TRANSIENT_ERROR:
+                        case STALE:
                             onConnectionEvent.accept(ProviderEvent.PROVIDER_ERROR, null, null);
                             break;
-                        case FATAL_ERROR:
+                        case ERROR:
                             onConnectionEvent.accept(
                                     ProviderEvent.PROVIDER_ERROR,
                                     ProviderEventDetails.builder()

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/FlagStore.java

@@ -132,19 +132,19 @@ private void streamerListener(final QueueSource connector) throws InterruptedExc
                     } catch (Throwable e) {
                         // catch all exceptions and avoid stream listener interruptions
                         log.warn("Invalid flag sync payload from connector", e);
-                        if (!stateBlockingQueue.offer(new StorageStateChange(StorageState.TRANSIENT_ERROR))) {
+                        if (!stateBlockingQueue.offer(new StorageStateChange(StorageState.STALE))) {
                             log.warn("Failed to convey TRANSIENT_ERROR status, queue is full");
                         }
                     }
                     break;
                 case ERROR:
-                    if (!stateBlockingQueue.offer(new StorageStateChange(StorageState.TRANSIENT_ERROR))) {
+                    if (!stateBlockingQueue.offer(new StorageStateChange(StorageState.STALE))) {
                         log.warn("Failed to convey TRANSIENT_ERROR status, queue is full");
                     }
                     break;
                 case SHUTDOWN:
                     shutdown();
-                    if (!stateBlockingQueue.offer(new StorageStateChange(StorageState.FATAL_ERROR))) {
+                    if (!stateBlockingQueue.offer(new StorageStateChange(StorageState.ERROR))) {
                         log.warn("Failed to convey FATAL_ERROR status, queue is full");
                     }
                     break;

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/StorageState.java

@@ -5,7 +5,7 @@ public enum StorageState {
     /** Storage is upto date and working as expected. */
     OK,
     /** Storage has gone stale (most recent sync failed). May get to OK status with next sync. */
-    TRANSIENT_ERROR,
+    STALE,
     /** Storage is in an unrecoverable error stage. */
-    FATAL_ERROR,
+    ERROR,
 }

providers/flagd/src/test/java/dev/openfeature/contrib/providers/flagd/resolver/process/InProcessResolverTest.java

@@ -116,7 +116,7 @@ void eventHandling() throws Throwable {
                     boolean isDisconnected =
                             event == ProviderEvent.PROVIDER_ERROR || event == ProviderEvent.PROVIDER_STALE;
                     receiver.offer(new StorageStateChange(
-                            isDisconnected ? StorageState.FATAL_ERROR : StorageState.OK,
+                            isDisconnected ? StorageState.ERROR : StorageState.OK,
                             details != null ? details.getFlagsChanged() : Collections.emptyList(),
                             metadata));
                 });
@@ -135,7 +135,7 @@ void eventHandling() throws Throwable {
                 TimeUnit.MILLISECONDS)) {
             Assertions.fail("failed to send the event");
         }
-        if (!sender.offer(new StorageStateChange(StorageState.FATAL_ERROR), 100, TimeUnit.MILLISECONDS)) {
+        if (!sender.offer(new StorageStateChange(StorageState.ERROR), 100, TimeUnit.MILLISECONDS)) {
             Assertions.fail("failed to send the event");
         }
 

providers/flagd/src/test/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/FlagStoreTest.java

@@ -46,7 +46,7 @@ void connectorHandling() throws Exception {
         });
 
         assertTimeoutPreemptively(Duration.ofMillis(maxDelay), () -> {
-            assertEquals(StorageState.TRANSIENT_ERROR, states.take().getStorageState());
+            assertEquals(StorageState.STALE, states.take().getStorageState());
         });
 
         // OK again for next payload
@@ -64,14 +64,14 @@ void connectorHandling() throws Exception {
         });
 
         assertTimeoutPreemptively(Duration.ofMillis(maxDelay), () -> {
-            assertEquals(StorageState.TRANSIENT_ERROR, states.take().getStorageState());
+            assertEquals(StorageState.STALE, states.take().getStorageState());
         });
 
         // Shutdown handling
         store.shutdown();
 
         assertTimeoutPreemptively(Duration.ofMillis(maxDelay), () -> {
-            assertEquals(StorageState.TRANSIENT_ERROR, states.take().getStorageState());
+            assertEquals(StorageState.STALE, states.take().getStorageState());
         });
     }