OFREP web provider

Signed-off-by: Thomas Poignant <thomas.poignant@gofeatureflag.org>

Author: thomaspoignant

libs/providers/ofrep-web/jest.config.ts

@@ -2,9 +2,15 @@
 export default {
   displayName: 'providers-ofrep-web',
   preset: '../../../jest.preset.js',
+  globals: {
+    'ts-jest': {
+      tsconfig: '<rootDir>/tsconfig.spec.json',
+    },
+  },
   transform: {
-    '^.+\\.[tj]s$': ['ts-jest', { tsconfig: '<rootDir>/tsconfig.spec.json' }],
+    '^.+\\.[tj]s$': 'ts-jest',
   },
+  testEnvironment: 'jsdom',
   moduleFileExtensions: ['ts', 'js', 'html'],
-  coverageDirectory: '../../../coverage/libs/providers/ofrep-web',
+  setupFiles: ['./jest.polyfills.js'],
 };

libs/providers/ofrep-web/jest.polyfills.js

@@ -0,0 +1,32 @@
+// jest.polyfills.js
+/**
+ * @note The block below contains polyfills for Node.js globals
+ * required for Jest to function when running JSDOM tests.
+ * These HAVE to be require's and HAVE to be in this exact
+ * order, since "undici" depends on the "TextEncoder" global API.
+ *
+ * Consider migrating to a more modern test runner if
+ * you don't want to deal with this.
+ */
+
+const { TextDecoder, TextEncoder } = require('node:util');
+
+// eslint-disable-next-line no-undef
+Object.defineProperties(globalThis, {
+  TextDecoder: { value: TextDecoder },
+  TextEncoder: { value: TextEncoder },
+})
+
+const { Blob, File } = require('node:buffer');
+const { fetch, Headers, FormData, Request, Response } = require('undici');
+
+// eslint-disable-next-line no-undef
+Object.defineProperties(globalThis, {
+  fetch: { value: fetch, writable: true },
+  Blob: { value: Blob },
+  File: { value: File },
+  Headers: { value: Headers },
+  FormData: { value: FormData },
+  Request: { value: Request },
+  Response: { value: Response },
+})

libs/providers/ofrep-web/src/lib/error/fetch-error.ts

@@ -0,0 +1,4 @@
+export enum EvaluationStatus {
+  SUCCESS_NO_CHANGES = 'SUCCESS_NO_CHANGES',
+  SUCCESS_WITH_CHANGES = 'SUCCESS_WITH_CHANGES',
+}

libs/providers/ofrep-web/src/lib/model/evaluate-response.ts

@@ -0,0 +1,6 @@
+import { FetchAPI } from '@openfeature/ofrep-core';
+export interface OfrepWebProviderOptions {
+  baseUrl: string;
+  pollInterval?: number; // in milliseconds
+  disablePolling?: boolean;
+}

libs/providers/ofrep-web/src/lib/model/evaluation-status.ts

@@ -1,89 +1,74 @@
 import { OfrepWebProvider } from './ofrep-web-provider';
-import { OpenFeature } from '@openfeature/web-sdk';
 import TestLogger from './test-logger';
-import fetchMock from 'fetch-mock-jest';
-import { ChangePropagationStrategy } from './model/options';
+// eslint-disable-next-line @nx/enforce-module-boundaries
+import { server } from '../../../../shared/ofrep-core/src/test/mock-service-worker';
+import { ClientProviderEvents, ClientProviderStatus, OpenFeature } from '@openfeature/web-sdk';
 
 describe('OFREPWebProvider', () => {
-  beforeEach(async () => {
-    fetchMock.mockClear();
-    fetchMock.reset();
-  });
+  beforeAll(() => server.listen());
+  afterEach(() => server.resetHandlers());
+  afterAll(() => server.close());
+
+  const defaultContext = {
+    targetingKey: '21640825-95e7-4335-b149-bd6881cf7875',
+    errors: {
+      // 403: true,
+    },
+  };
+
   it('xxx', async () => {
-    const provider = new OfrepWebProvider('http://localhost:1031/ofrep/', [], {
-      logger: new TestLogger(),
-      changePropagationStrategy: ChangePropagationStrategy.POLLING,
-      pollingOptions: {
-        interval: 500,
-      },
+    const providerName = expect.getState().currentTestName || 'test-provider';
+    const provider = new OfrepWebProvider({ baseUrl: 'https://localhost:8080', pollInterval: 100 }, new TestLogger());
+
+    await OpenFeature.setContext(defaultContext);
+    await OpenFeature.setProviderAndWait(providerName, provider);
+    const client = OpenFeature.getClient(providerName);
+
+    client.addHandler(ClientProviderEvents.Ready, (xxx) => {
+      console.log(`ready: ${JSON.stringify(xxx)}`);
     });
 
-    const evaluateEndpoint = 'http://localhost:1031/ofrep/v1/evaluate';
-    const flagChangesEndpoint = 'http://localhost:1031/ofrep/v1/flag/changes';
-    const fetchResult = [
-      {
-        key: 'flag1',
-        metadata: {
-          additionalProp1: 'xxx',
-        },
-        reason: 'TARGETING_MATCH',
-        value: 'toto',
-        variant: 'Variant1',
-        ETag: '9f9fc0b4',
-      },
-      {
-        key: 'flag2',
-        metadata: {
-          additionalProp1: 'xxx',
-        },
-        reason: 'SPLIT',
-        value: 'titi',
-        variant: 'Variant150',
-        ETag: '6c23a4',
-      },
-      {
-        key: 'flag3',
-        metadata: {
-          additionalProp1: 'xxx',
-        },
-        reason: 'SPLIT',
-        value: 'titi',
-        variant: 'Variant150',
-        ETag: '6c23a4',
-      },
-    ];
+    client.addHandler(ClientProviderEvents.Error, (xxx) => {
+      console.log(`error: ${JSON.stringify(xxx)}`);
+    });
 
-    const fetchFlagChanges = [
-      {
-        key: 'flag1',
-        ETag: '9f9fc0b1',
-      },
-      {
-        key: 'flag2',
-        ETag: '6c23a5',
-      },
-      {
-        key: 'flag3',
-        errorCode: 'FLAG_NOT_FOUND',
-        errorDetails: 'Flag not found',
+    client.addHandler(ClientProviderEvents.Stale, (xxx) => {
+      console.log(`stale: ${JSON.stringify(xxx)}`);
+    });
+
+    client.addHandler(ClientProviderEvents.Reconciling, (xxx) => {
+      console.log(`Reconciling: ${JSON.stringify(xxx)}`);
+    });
+
+    client.addHandler(ClientProviderEvents.ContextChanged, (xxx) => {
+      console.log(`ContextChanged: ${JSON.stringify(xxx)}`);
+    });
+
+    client.addHandler(ClientProviderEvents.ConfigurationChanged, (xxx) => {
+      console.log(`ConfigurationChanged: ${JSON.stringify(xxx)}`);
+    });
+
+    console.log(client.getBooleanDetails('bool-flag', true));
+
+    console.log('status:', client.providerStatus);
+
+    await OpenFeature.setContext({
+      ...defaultContext,
+      errors: {
+        403: true,
       },
-    ];
-
-    fetchMock.post(evaluateEndpoint, (url, options) => {
-      const t = JSON.parse(options.body as string).flags as string[];
-      if (t.length === 0) {
-        return fetchResult;
-      }
-      return fetchResult.filter((f) => t.includes(f.key));
     });
-    fetchMock.post(flagChangesEndpoint, fetchFlagChanges, { overwriteRoutes: true });
-    await OpenFeature.setContext({ targetingKey: 'user1' });
-    await OpenFeature.setProviderAndWait(provider);
-    const cli = OpenFeature.getClient();
-    console.log(cli.getStringDetails('flag1', 'default'));
-    console.log(cli.getStringDetails('flag3', 'default'));
+
+    console.log('status:', client.providerStatus);
+
+    console.log(client.getBooleanDetails('bool-flag', false));
 
     await new Promise((resolve) => setTimeout(resolve, 1000));
-    console.log(cli.getStringDetails('flag3', 'default'));
+    await OpenFeature.setContext({
+      ...defaultContext,
+      email: 'john.doe@goff.org',
+    });
+    await OpenFeature.close();
+    await new Promise((resolve) => setTimeout(resolve, 3000));
   });
 });