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,37 @@ 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('anonymous provider with named client should run init events', (done) => {
+      const defaultProvider = new MockProvider({ failOnInit: false, initialStatus: ProviderStatus.NOT_READY, name: 'defauwlt' });
+      const unboundName = 'some-other-unbound-name';
+
+      // get a client using the default because it has not other mapping
+      const unBoundClient = OpenFeature.getClient(unboundName);
+      unBoundClient.addHandler(ProviderEvents.Ready, () => {
+        done();
+      });
+
+      // set the default provider
+      OpenFeature.setProvider(defaultProvider);
+    });
+
     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

@@ -104,21 +104,28 @@ export abstract class OpenFeatureCommonAPI<P extends CommonProvider = CommonProv
       return this;
     }
 
-    const clientEmitter = this.getAndCacheEventEmitterForClient(clientName);
+    // get the named emitter, or if this is the default provider, get all event emitters not associated with a provider
+    const emitters = clientName ? [this._clientEvents.get(clientName)] : this.getUnboundEmitters();
 
     if (typeof provider.initialize === 'function') {
       provider
         .initialize?.(this._context)
         ?.then(() => {
-          clientEmitter.emit(ProviderEvents.Ready, { clientName });
+          emitters.forEach((emitter) => {
+            emitter?.emit(ProviderEvents.Ready, { clientName });
+          });
           this._events?.emit(ProviderEvents.Ready, { clientName });
         })
         ?.catch((error) => {
-          clientEmitter.emit(ProviderEvents.Error, { clientName, message: error.message });
+          emitters.forEach((emitter) => {
+            emitter?.emit(ProviderEvents.Error, { clientName, message: error.message });
+          });
           this._events?.emit(ProviderEvents.Error, { clientName, message: error.message });
         });
     } else {
-      clientEmitter.emit(ProviderEvents.Ready, { clientName });
+      emitters.forEach((emitter) => {
+        emitter?.emit(ProviderEvents.Ready, { clientName });
+      });
       this._events?.emit(ProviderEvents.Ready, { clientName });
     }
 
@@ -128,7 +135,7 @@ export abstract class OpenFeatureCommonAPI<P extends CommonProvider = CommonProv
       this._defaultProvider = provider;
     }
 
-    this.transferListeners(oldProvider, provider, clientName, clientEmitter);
+    this.transferListeners(oldProvider, provider, clientName, emitters);
 
     // Do not close a provider that is bound to any client
     if (![...this._clientProviders.values(), this._defaultProvider].includes(oldProvider)) {
@@ -167,11 +174,18 @@ export abstract class OpenFeatureCommonAPI<P extends CommonProvider = CommonProv
     return newEmitter;
   }
 
+  private getUnboundEmitters(): OpenFeatureEventEmitter[] {
+    const namedProviders = [...this._clientProviders.keys()];
+    const eventEmitterNames = [...this._clientEvents.keys()].filter(key => key) 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
+    emitters: (OpenFeatureEventEmitter | undefined)[]
   ) {
     this._clientEventHandlers
       .get(clientName)
@@ -182,7 +196,9 @@ export abstract class OpenFeatureCommonAPI<P extends CommonProvider = CommonProv
       (eventType) => {
         const handler = async (details?: EventDetails) => {
           // on each event type, fire the associated handlers
-          clientEmitter.emit(eventType, { ...details, clientName });
+          emitters.forEach(emitter => {
+            emitter?.emit(eventType, { ...details, clientName });
+          });
           this._events.emit(eventType, { ...details, clientName });
         };