fix: named client events

* fixed issues where named client wouldnt get events from a default provider

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

Author: toddbaert

packages/client/test/events.spec.ts

@@ -1,6 +1,7 @@
 import {
   EventDetails,
   JsonValue,
+  NOOP_PROVIDER,
   OpenFeature,
   OpenFeatureEventEmitter,
   Provider,
@@ -76,6 +77,10 @@ describe('Events', () => {
     clientId = uuid();
   });
 
+  beforeEach(() => {
+    OpenFeature.setProvider(NOOP_PROVIDER);
+  });
+
   describe('Requirement 5.1.1', () => {
     describe('provider implements events', () => {
       it('The provider defines a mechanism for signalling the occurrence of an event`PROVIDER_READY`', (done) => {
@@ -192,6 +197,24 @@ describe('Events', () => {
       OpenFeature.setProvider(clientId, provider);
     });
 
+    it('anonymous provider with named client should run', (done) => {
+      const defaultProvider = new MockProvider({ failOnInit: false, initialStatus: ProviderStatus.NOT_READY, name: 'defauwlt' });
+      const unboundName = 'some-new-unbound-name';
+
+
+      // get a client using the default because it has not other mapping
+      const unBoundClient = OpenFeature.getClient(unboundName);
+      unBoundClient.addHandler(ProviderEvents.ConfigurationChanged, () => {
+        done();
+      });
+
+      // set the default provider
+      OpenFeature.setProvider(defaultProvider);
+
+      // fire events
+      defaultProvider.events?.emit(ProviderEvents.ConfigurationChanged);
+    });
+
     it('un-bound client event handlers still run after new provider set', (done) => {
       const defaultProvider = new MockProvider({ name: 'default' });
       const namedProvider = new MockProvider();

packages/shared/src/open-feature.ts

@@ -128,7 +128,7 @@ export abstract class OpenFeatureCommonAPI<P extends CommonProvider = CommonProv
       this._defaultProvider = provider;
     }
 
-    this.transferListeners(oldProvider, provider, clientName, clientEmitter);
+    this.transferListeners(oldProvider, provider, clientName);
 
     // Do not close a provider that is bound to any client
     if (![...this._clientProviders.values(), this._defaultProvider].includes(oldProvider)) {
@@ -167,22 +167,32 @@ export abstract class OpenFeatureCommonAPI<P extends CommonProvider = CommonProv
     return newEmitter;
   }
 
+  private getUnboundEmitters(): OpenFeatureEventEmitter[] {
+    const namedProviders = [...this._clientProviders.keys()];
+    const eventEmitterNames = [...this._clientEvents.keys()].filter(k => !!k) as string[];
+    const unboundEmitterNames = eventEmitterNames.filter(name => !namedProviders.includes(name));
+    return unboundEmitterNames.map(name => this._clientEvents.get(name)!);
+  }
+
   private transferListeners(
     oldProvider: P,
     newProvider: P,
-    clientName: string | undefined,
-    clientEmitter: OpenFeatureEventEmitter
+    clientName: string | undefined
   ) {
     this._clientEventHandlers
       .get(clientName)
       ?.forEach((eventHandler) => oldProvider.events?.removeHandler(...eventHandler));
 
+    const emittersToTransfer = !!clientName ? [this._clientEvents.get(clientName)!] : this.getUnboundEmitters();
+
     // iterate over the event types
     const newClientHandlers = Object.values<ProviderEvents>(ProviderEvents).map<[ProviderEvents, EventHandler]>(
       (eventType) => {
         const handler = async (details?: EventDetails) => {
           // on each event type, fire the associated handlers
-          clientEmitter.emit(eventType, { ...details, clientName });
+          emittersToTransfer.forEach(emitter => {
+            emitter.emit(eventType, { ...details, clientName });
+          });
           this._events.emit(eventType, { ...details, clientName });
         };