[FSSDK-10711] Make use of VUID as an opt-in

.devcontainer/devcontainer.json

@@ -10,7 +10,6 @@
 				"dbaeumer.vscode-eslint",
 				"eamodio.gitlens",
 				"esbenp.prettier-vscode",
-				"Gruntfuggly.todo-tree",
 				"github.vscode-github-actions",
 				"Orta.vscode-jest",
 				"ms-vscode.test-adapter-converter"

.vscode/settings.json

@@ -1,6 +1,7 @@
 {
-    "jest.rootPath": "/workspaces/javascript-sdk/packages/optimizely-sdk",
+    "jest.rootPath": "/workspaces/javascript-sdk",
     "jest.jestCommandLine": "./node_modules/.bin/jest",
-    "jest.autoRevealOutput": "on-exec-error",
-    "editor.tabSize": 2
-}
+    "jest.outputConfig": "test-results-based",
+    "editor.tabSize": 2,
+    "jest.runMode": "deferred"
+}

jest.config.js

@@ -2,7 +2,7 @@ module.exports = {
   "transform": {
     "^.+\\.(ts|tsx|js|jsx)$": "ts-jest",
   },
-  "testRegex": "(/tests/.*|(\\.|/)(test|spec))\\.tsx?$",
+  "testRegex": "(/tests/.*|(\\.|/)(test|spec|tests))\\.tsx?$",
   moduleNameMapper: {
     // Force module uuid to resolve with the CJS entry point, because Jest does not support package.json.exports. See https://github.com/uuidjs/uuid/issues/451
     "uuid": require.resolve('uuid'),

lib/core/notification_center/notification_registry.tests.ts

@@ -1,5 +1,5 @@
 /**
- * Copyright 2023, Optimizely
+ * Copyright 2023-2024, Optimizely
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -14,9 +14,7 @@
  * limitations under the License.
  */
 
-import { describe, it } from 'mocha';
 import { expect } from 'chai';
-
 import { NotificationRegistry } from './notification_registry';
 
 describe('Notification Registry', () => {

lib/core/odp/odp_manager.ts

@@ -14,13 +14,12 @@
  * limitations under the License.
  */
 
-import { LOG_MESSAGES } from './../../utils/enums/index';
-import { getLogger, LogHandler, LogLevel } from '../../modules/logging';
+import { LogHandler, LogLevel } from '../../modules/logging';
 import { ERROR_MESSAGES, ODP_USER_KEY } from '../../utils/enums';
 
 import { VuidManager } from '../../plugins/vuid_manager';
 
-import { OdpConfig, OdpIntegrationConfig, odpIntegrationsAreEqual } from './odp_config';
+import { OdpIntegrationConfig, odpIntegrationsAreEqual } from './odp_config';
 import { IOdpEventManager } from './odp_event_manager';
 import { IOdpSegmentManager } from './odp_segment_manager';
 import { OptimizelySegmentOption } from './optimizely_segment_option';
@@ -47,11 +46,12 @@ export interface IOdpManager {
 
   sendEvent({ type, action, identifiers, data }: OdpEvent): void;
 
-  isVuidEnabled(): boolean;
-
-  getVuid(): string | undefined;
+  registerVuid(vuid: string): void;
 }
 
+/**
+ * Possible statuses for the OdpManager
+ */
 export enum Status {
   Running,
   Stopped,
@@ -72,32 +72,40 @@ export abstract class OdpManager implements IOdpManager {
    */
   private configPromise: ResolvablePromise<void>;
 
-  status: Status = Status.Stopped;
+  /**
+   * The current status of the ODP Manager
+   */
+  private status: Status = Status.Stopped;
 
   /**
    * ODP Segment Manager which provides an interface to the remote ODP server (GraphQL API) for audience segments mapping.
    * It fetches all qualified segments for the given user context and manages the segments cache for all user contexts.
+   * @private
+   * @readonly
    */
-  private segmentManager: IOdpSegmentManager;
+  private readonly segmentManager: IOdpSegmentManager;
 
   /**
    * ODP Event Manager which provides an interface to the remote ODP server (REST API) for events.
    * It will queue all pending events (persistent) and send them (in batches of up to 10 events) to the ODP server when possible.
+   * @protected
+   * @readonly
    */
-  private eventManager: IOdpEventManager;
+  protected readonly eventManager: IOdpEventManager;
 
   /**
    * Handler for recording execution logs
    * @protected
+   * @readonly
    */
-  protected logger: LogHandler;
+  protected readonly logger: LogHandler;
 
   /**
    * ODP configuration settings for identifying the target API and segments
+   * @protected
    */
-  odpIntegrationConfig?: OdpIntegrationConfig;
+  protected odpIntegrationConfig?: OdpIntegrationConfig;
 
-  // TODO: Consider accepting logger as a parameter and initializing it in constructor instead
   constructor({
     odpIntegrationConfig,
     segmentManager,
@@ -112,33 +120,38 @@ export abstract class OdpManager implements IOdpManager {
     this.segmentManager = segmentManager;
     this.eventManager = eventManager;
     this.logger = logger;
-
     this.configPromise = resolvablePromise();
 
     const readinessDependencies: PromiseLike<unknown>[] = [this.configPromise];
 
-    if (this.isVuidEnabled()) {
-      readinessDependencies.push(this.initializeVuid());
-    }
-
     this.initPromise = Promise.all(readinessDependencies);
 
     this.onReady().then(() => {
       this.ready = true;
-      if (this.isVuidEnabled() && this.status === Status.Running) {
-        this.registerVuid();
-      }
     });
 
     if (odpIntegrationConfig) {
       this.updateSettings(odpIntegrationConfig);
     }
   }
 
-  public getStatus(): Status {
+  /**
+   * Register a VUID with the ODP Manager in client side context
+   * @param {string} vuid - Unique identifier of an anonymous vistor
+   */
+  abstract registerVuid(vuid: string): void;
+
+  /**
+   * @returns {Status} The current status of the ODP Manager
+   */
+  getStatus(): Status {
     return this.status;
   }
 
+  /**
+   * Starts the ODP Manager
+   * @returns {Promise<void>} A promise that resolves when starting has completed
+   */
   async start(): Promise<void> {
     if (this.status === Status.Running) {
       return;
@@ -159,6 +172,10 @@ export abstract class OdpManager implements IOdpManager {
     return Promise.resolve();
   }
 
+  /**
+   * Stops the ODP Manager
+   * @returns A promise that resolves when stopping has completed
+   */
   async stop(): Promise<void> {
     if (this.status === Status.Stopped) {
       return;
@@ -230,7 +247,7 @@ export abstract class OdpManager implements IOdpManager {
   /**
    * Identifies a user via the ODP Event Manager
    * @param {string}  userId    (Optional) Custom unique identifier of a target user.
-   * @param {string}  vuid      (Optional) Secondary unique identifier of a target user, primarily used by client SDKs.
+   * @param {string}  vuid      (Optional) Secondary unique identifier of a target user, used by client SDKs.
    * @returns
    */
   identifyUser(userId?: string, vuid?: string): void {
@@ -283,41 +300,4 @@ export abstract class OdpManager implements IOdpManager {
 
     this.eventManager.sendEvent(new OdpEvent(mType, action, identifiers, data));
   }
-
-  /**
-   * Identifies if the VUID feature is enabled
-   */
-  abstract isVuidEnabled(): boolean;
-
-  /**
-   * Returns VUID value if it exists
-   */
-  abstract getVuid(): string | undefined;
-
-  protected initializeVuid(): Promise<void> {
-    return Promise.resolve();
-  }
-
-  private registerVuid() {
-    if (!this.odpIntegrationConfig) {
-      this.logger.log(LogLevel.ERROR, ERROR_MESSAGES.ODP_CONFIG_NOT_AVAILABLE);
-      return;
-    }
-
-    if (!this.odpIntegrationConfig.integrated) {
-      this.logger.log(LogLevel.INFO, ERROR_MESSAGES.ODP_NOT_INTEGRATED);
-      return;
-    }
-
-    const vuid = this.getVuid();
-    if (!vuid) {
-      return;
-    }
-
-    try {
-      this.eventManager.registerVuid(vuid);
-    } catch (e) {
-      this.logger.log(LogLevel.ERROR, ERROR_MESSAGES.ODP_VUID_REGISTRATION_FAILED);
-    }
-  }
 }

lib/index.browser.tests.js

@@ -654,38 +654,6 @@ describe('javascript-sdk (Browser)', function() {
         sinon.assert.calledWith(logger.log, optimizelyFactory.enums.LOG_LEVEL.INFO, LOG_MESSAGES.ODP_DISABLED);
       });
 
-      it('should include the VUID instantation promise of Browser ODP Manager in the Optimizely client onReady promise dependency array', () => {
-        const client = optimizelyFactory.createInstance({
-          datafile: testData.getTestProjectConfigWithFeatures(),
-          errorHandler: fakeErrorHandler,
-          eventDispatcher: fakeEventDispatcher,
-          eventBatchSize: null,
-          logger,
-          odpManager: BrowserOdpManager.createInstance({
-            logger,
-          }),
-        });
-
-        client
-          .onReady()
-          .then(() => {
-            assert.isDefined(client.odpManager.initPromise);
-            client.odpManager.initPromise
-              .then(() => {
-                assert.isTrue(true);
-              })
-              .catch(() => {
-                assert.isTrue(false);
-              });
-            assert.isDefined(client.odpManager.getVuid());
-          })
-          .catch(() => {
-            assert.isTrue(false);
-          });
-
-        sinon.assert.neverCalledWith(logger.log, optimizelyFactory.enums.LOG_LEVEL.ERROR);
-      });
-
       it('should accept a valid custom cache size', () => {
         const client = optimizelyFactory.createInstance({
           datafile: testData.getTestProjectConfigWithFeatures(),

lib/index.browser.ts

@@ -26,13 +26,15 @@ import * as loggerPlugin from './plugins/logger';
 import eventProcessorConfigValidator from './utils/event_processor_config_validator';
 import { createNotificationCenter } from './core/notification_center';
 import { default as eventProcessor } from './plugins/event_processor';
-import { OptimizelyDecideOption, Client, Config, OptimizelyOptions } from './shared_types';
+import { OptimizelyDecideOption, Client, Config, OptimizelyOptions, VuidManagerOptions } from './shared_types';
 import { createHttpPollingDatafileManager } from './plugins/datafile_manager/browser_http_polling_datafile_manager';
 import { BrowserOdpManager } from './plugins/odp_manager/index.browser';
 import Optimizely from './optimizely';
 import { IUserAgentParser } from './core/odp/user_agent_parser';
 import { getUserAgentParser } from './plugins/odp/user_agent_parser/index.browser';
 import * as commonExports from './common_exports';
+import { VuidManager } from './plugins/vuid_manager';
+import BrowserAsyncStorageCache from './plugins/key_value_cache/browserAsyncStorageCache';
 
 const logger = getLogger();
 logHelper.setLogHandler(loggerPlugin.createLogger());
@@ -51,7 +53,7 @@ let hasRetriedEvents = false;
  * @return {Client|null} the Optimizely client object
  *                           null on error
  */
-const createInstance = function(config: Config): Client | null {
+const createInstance = function (config: Config): Client | null {
   try {
     // TODO warn about setting per instance errorHandler / logger / logLevel
     let isValidInstance = false;
@@ -133,6 +135,11 @@ const createInstance = function(config: Config): Client | null {
 
     const { clientEngine, clientVersion } = config;
 
+    const cache = new BrowserAsyncStorageCache();
+    const vuidManagerOptions: VuidManagerOptions = {
+      enableVuid: config.vuidManagerOptions?.enableVuid || false,
+    }
+
     const optimizelyOptions: OptimizelyOptions = {
       clientEngine: enums.JAVASCRIPT_CLIENT_ENGINE,
       ...config,
@@ -146,6 +153,7 @@ const createInstance = function(config: Config): Client | null {
       isValidInstance,
       odpManager: odpExplicitlyOff ? undefined
         : BrowserOdpManager.createInstance({ logger, odpOptions: config.odpOptions, clientEngine, clientVersion }),
+      vuidManager: new VuidManager(cache, vuidManagerOptions, logger),
     };
 
     const optimizely = new Optimizely(optimizelyOptions);
@@ -174,7 +182,7 @@ const createInstance = function(config: Config): Client | null {
   }
 };
 
-const __internalResetRetryState = function(): void {
+const __internalResetRetryState = function (): void {
   hasRetriedEvents = false;
 };
 

lib/index.react_native.ts

@@ -24,11 +24,12 @@ import defaultEventDispatcher from './plugins/event_dispatcher/index.browser';
 import eventProcessorConfigValidator from './utils/event_processor_config_validator';
 import { createNotificationCenter } from './core/notification_center';
 import { createEventProcessor } from './plugins/event_processor/index.react_native';
-import { OptimizelyDecideOption, Client, Config } from './shared_types';
+import { OptimizelyDecideOption, Client, Config, VuidManagerOptions } from './shared_types';
 import { createHttpPollingDatafileManager } from './plugins/datafile_manager/react_native_http_polling_datafile_manager';
 import { BrowserOdpManager } from './plugins/odp_manager/index.browser';
 import * as commonExports from './common_exports';
-
+import { VuidManager } from './plugins/vuid_manager';
+import ReactNativeAsyncStorageCache from './plugins/key_value_cache/reactNativeAsyncStorageCache';
 import 'fast-text-encoding';
 import 'react-native-get-random-values';
 
@@ -46,7 +47,7 @@ const DEFAULT_EVENT_MAX_QUEUE_SIZE = 10000;
  * @return {Client|null} the Optimizely client object
  *                           null on error
  */
-const createInstance = function(config: Config): Client | null {
+const createInstance = function (config: Config): Client | null {
   try {
     // TODO warn about setting per instance errorHandler / logger / logLevel
     let isValidInstance = false;
@@ -108,6 +109,11 @@ const createInstance = function(config: Config): Client | null {
 
     const { clientEngine, clientVersion } = config;
 
+    const cache = new ReactNativeAsyncStorageCache();
+    const vuidManagerOptions: VuidManagerOptions = {
+      enableVuid: config.vuidManagerOptions?.enableVuid || false,
+    }
+
     const optimizelyOptions = {
       clientEngine: enums.REACT_NATIVE_JS_CLIENT_ENGINE,
       ...config,
@@ -126,7 +132,8 @@ const createInstance = function(config: Config): Client | null {
       notificationCenter,
       isValidInstance: isValidInstance,
       odpManager: odpExplicitlyOff ? undefined
-        :BrowserOdpManager.createInstance({ logger, odpOptions: config.odpOptions, clientEngine, clientVersion }),
+        : BrowserOdpManager.createInstance({ logger, odpOptions: config.odpOptions, clientEngine, clientVersion }),
+      vuidManager: new VuidManager(cache, vuidManagerOptions, logger),
     };
 
     // If client engine is react, convert it to react native.