test: Test observeEvents

Signed-off-by: Fabrizio Demaria <[email protected]>

Author: fabriziodemaria

android/src/main/java/dev/openfeature/sdk/async/Extensions.kt

@@ -12,7 +12,6 @@ import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.cancel
 import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.distinctUntilChanged
 import kotlinx.coroutines.flow.flatMapLatest
 import kotlinx.coroutines.flow.onStart
 import kotlinx.coroutines.flow.take

android/src/test/java/dev/openfeature/sdk/DeveloperExperienceTests.kt

@@ -1,15 +1,18 @@
 package dev.openfeature.sdk
 
+import dev.openfeature.sdk.async.observeEvents
 import dev.openfeature.sdk.async.setProviderAndWait
 import dev.openfeature.sdk.exceptions.ErrorCode
 import dev.openfeature.sdk.helpers.AlwaysBrokenProvider
+import dev.openfeature.sdk.helpers.DoSomethingProvider
 import dev.openfeature.sdk.helpers.GenericSpyHookMock
 import dev.openfeature.sdk.helpers.SlowProvider
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.ExperimentalCoroutinesApi
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.test.StandardTestDispatcher
 import kotlinx.coroutines.test.UnconfinedTestDispatcher
+import kotlinx.coroutines.test.advanceUntilIdle
 import kotlinx.coroutines.test.runTest
 import org.junit.Assert
 import org.junit.Test
@@ -86,4 +89,24 @@ class DeveloperExperienceTests {
         val booleanValue = OpenFeatureAPI.getClient().getBooleanValue("test", false)
         Assert.assertFalse(booleanValue)
     }
+
+    @Test
+    fun testObserveEvents() = runTest {
+        val dispatcher = StandardTestDispatcher(testScheduler)
+        var eventCount = 0
+        CoroutineScope(dispatcher).launch {
+            OpenFeatureAPI.observeEvents().collect {
+                eventCount++
+            }
+        }
+        CoroutineScope(dispatcher).launch {
+            OpenFeatureAPI.setProviderAndWait(
+                DoSomethingProvider(dispatcher = dispatcher),
+                dispatcher,
+                ImmutableContext()
+            )
+        }
+        advanceUntilIdle()
+        Assert.assertEquals(eventCount, 1)
+    }
 }

android/src/test/java/dev/openfeature/sdk/helpers/DoSomethingProvider.kt

@@ -6,16 +6,25 @@ import dev.openfeature.sdk.Hook
 import dev.openfeature.sdk.ProviderEvaluation
 import dev.openfeature.sdk.ProviderMetadata
 import dev.openfeature.sdk.Value
+import dev.openfeature.sdk.events.EventHandler
 import dev.openfeature.sdk.events.OpenFeatureEvents
+import kotlinx.coroutines.CoroutineDispatcher
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.flowOf
+import kotlinx.coroutines.launch
 
 class DoSomethingProvider(
     override val hooks: List<Hook<*>> = listOf(),
-    override val metadata: ProviderMetadata = DoSomethingProviderMetadata()
+    override val metadata: ProviderMetadata = DoSomethingProviderMetadata(),
+    private var dispatcher: CoroutineDispatcher = Dispatchers.IO
 ) : FeatureProvider {
+    private var eventHandler = EventHandler(dispatcher)
+
     override fun initialize(initialContext: EvaluationContext?) {
-        // no-op
+        CoroutineScope(dispatcher).launch {
+            eventHandler.publish(OpenFeatureEvents.ProviderReady)
+        }
     }
 
     override fun shutdown() {
@@ -69,7 +78,7 @@ class DoSomethingProvider(
         return ProviderEvaluation(Value.Null)
     }
 
-    override fun observe(): Flow<OpenFeatureEvents> = flowOf()
+    override fun observe(): Flow<OpenFeatureEvents> = eventHandler.observe()
 
     override fun getProviderStatus(): OpenFeatureEvents = OpenFeatureEvents.ProviderReady
 

android/src/test/java/dev/openfeature/sdk/helpers/SlowProvider.kt

@@ -13,7 +13,6 @@ import kotlinx.coroutines.CoroutineDispatcher
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.delay
 import kotlinx.coroutines.flow.Flow
-import kotlinx.coroutines.flow.flowOf
 import kotlinx.coroutines.launch
 
 class SlowProvider(override val hooks: List<Hook<*>> = listOf(), private var dispatcher: CoroutineDispatcher) : FeatureProvider {
@@ -84,7 +83,7 @@ class SlowProvider(override val hooks: List<Hook<*>> = listOf(), private var dis
         return ProviderEvaluation(Value.Null)
     }
 
-    override fun observe(): Flow<OpenFeatureEvents> = flowOf()
+    override fun observe(): Flow<OpenFeatureEvents> = eventHandler.observe()
 
     override fun getProviderStatus(): OpenFeatureEvents = if (ready) {
         OpenFeatureEvents.ProviderReady