feat(contract-tests): add flag change listener support for Node server SDK

Implement contract test support for flag change listeners in the Node server
SDK test service:

- Add 'flag-change-listeners' capability to the service
- Handle registerFlagChangeListener, registerFlagValueChangeListener, and
  unregisterListener commands
- Use SDK 'update' and 'update:${key}' events for config and value changes
- Post listener callbacks to the test harness via HTTP
- Unregister listeners on client close

Author: aaron-zeisler

packages/sdk/server-node/contract-tests/src/index.ts

@@ -42,6 +42,7 @@ app.get('/', (req: Request, res: Response) => {
       'client-prereq-events',
       'event-gzip',
       'optional-event-gzip',
+      'flag-change-listeners',
     ],
   });
 });

packages/sdk/server-node/contract-tests/src/sdkClientEntity.ts

@@ -140,6 +140,21 @@ interface CommandParams {
     newEndpoint: string;
     oldEndpoint: string;
   };
+  registerFlagChangeListener?: {
+    listenerId: string;
+    flagKey: string;
+    callbackUri: string;
+  };
+  registerFlagValueChangeListener?: {
+    listenerId: string;
+    flagKey: string;
+    context: LDContext;
+    defaultValue: LDFlagValue;
+    callbackUri: string;
+  };
+  unregisterListener?: {
+    listenerId: string;
+  };
 }
 
 export function makeSdkConfig(options: SdkConfigOptions, tag: string): LDOptions {
@@ -316,9 +331,15 @@ export interface SdkClientEntity {
   doCommand: (params: CommandParams) => Promise<any>;
 }
 
+interface ListenerEntry {
+  eventName: string;
+  handler: (...args: any[]) => void;
+}
+
 export async function newSdkClientEntity(options: any): Promise<SdkClientEntity> {
   const c: any = {};
   const log = Log(options.tag);
+  const listeners = new Map<string, ListenerEntry>();
 
   log.info(`Creating client with configuration: ${JSON.stringify(options.configuration)}`);
   const timeout =
@@ -341,6 +362,10 @@ export async function newSdkClientEntity(options: any): Promise<SdkClientEntity>
   }
 
   c.close = () => {
+    listeners.forEach((entry) => {
+      client.off(entry.eventName, entry.handler);
+    });
+    listeners.clear();
     client.close();
     log.info('Test ended');
   };
@@ -514,6 +539,65 @@ export async function newSdkClientEntity(options: any): Promise<SdkClientEntity>
         }
       }
 
+      case 'registerFlagChangeListener': {
+        const p = params.registerFlagChangeListener!;
+        const eventName = p.flagKey ? `update:${p.flagKey}` : 'update';
+
+        const handler = (eventParams: { key: string }) => {
+          got
+            .post(p.callbackUri, {
+              json: {
+                listenerId: p.listenerId,
+                flagKey: eventParams.key,
+              },
+            })
+            .catch(() => {});
+        };
+
+        listeners.set(p.listenerId, { eventName, handler });
+        client.on(eventName, handler);
+        return undefined;
+      }
+
+      case 'registerFlagValueChangeListener': {
+        const p = params.registerFlagValueChangeListener!;
+        const eventName = `update:${p.flagKey}`;
+
+        let oldValue = await client.variation(p.flagKey, p.context, p.defaultValue);
+
+        const handler = async () => {
+          const newValue = await client.variation(p.flagKey, p.context, p.defaultValue);
+          if (JSON.stringify(newValue) !== JSON.stringify(oldValue)) {
+            const previousValue = oldValue;
+            oldValue = newValue;
+            got
+              .post(p.callbackUri, {
+                json: {
+                  listenerId: p.listenerId,
+                  flagKey: p.flagKey,
+                  oldValue: previousValue,
+                  newValue,
+                },
+              })
+              .catch(() => {});
+          }
+        };
+
+        listeners.set(p.listenerId, { eventName, handler });
+        client.on(eventName, handler);
+        return undefined;
+      }
+
+      case 'unregisterListener': {
+        const p = params.unregisterListener!;
+        const entry = listeners.get(p.listenerId);
+        if (entry) {
+          client.off(entry.eventName, entry.handler);
+          listeners.delete(p.listenerId);
+        }
+        return undefined;
+      }
+
       default:
         throw badCommandError;
     }