[FSSDK-11003] disposable odp manager

Author: junaed-optimizely

lib/odp/event_manager/odp_event_manager.spec.ts

@@ -207,6 +207,39 @@ describe('DefaultOdpEventManager', () => {
     }
   });
 
+  it('should flush the queue immediately if disposable, regardless of the batchSize', async () => {
+    const apiManager = getMockApiManager();
+    const repeater = getMockRepeater()
+    apiManager.sendEvents.mockResolvedValue({ statusCode: 200 });
+    // spy on the flush method
+    const odpEventManager = new DefaultOdpEventManager({
+      repeater, 
+      apiManager: apiManager,
+      batchSize: 10,
+      retryConfig: {
+        maxRetries: 3,
+        backoffProvider: vi.fn(),
+      },
+    });
+
+    odpEventManager.updateConfig({
+      integrated: true,
+      odpConfig: config,
+    });
+    odpEventManager.makeDisposable();
+    odpEventManager.start();
+
+    await expect(odpEventManager.onRunning()).resolves.not.toThrow(); 
+
+    const event = makeEvent(0);
+    odpEventManager.sendEvent(event);
+    await exhaustMicrotasks();
+
+    expect(apiManager.sendEvents).toHaveBeenCalledTimes(1);
+    expect(apiManager.sendEvents).toHaveBeenNthCalledWith(1, config, [event]);
+    expect(repeater.reset).toHaveBeenCalledTimes(1);
+  })
+
   it('drops events and logs if the state is not running', async () => {
     const apiManager = getMockApiManager();
     apiManager.sendEvents.mockResolvedValue({ statusCode: 200 });

lib/odp/event_manager/odp_event_manager.ts

@@ -105,6 +105,11 @@ export class DefaultOdpEventManager extends BaseService implements OdpEventManag
     if (!this.isNew) {
       return;
     }
+    // Override for disposable event manager 
+    if(this.disposable) {
+      this.retryConfig.maxRetries = 5;
+      this.batchSize = 1
+    }
 
     super.start();
     if (this.odpIntegrationConfig) {

lib/odp/odp_manager.ts

@@ -90,6 +90,10 @@ export class DefaultOdpManager extends BaseService implements OdpManager {
     if (!this.isNew()) {
       return;
     }
+    
+    if(this.disposable) {
+      this.eventManager.makeDisposable();
+    }
 
     this.state = ServiceState.Starting;
 

lib/optimizely/index.ts

@@ -141,10 +141,20 @@ export default class Optimizely implements Client {
     this.errorHandler = config.errorHandler;
     this.isOptimizelyConfigValid = config.isValidInstance;
     this.logger = config.logger;
+    this.projectConfigManager = config.projectConfigManager;
+    this.notificationCenter = config.notificationCenter;
     this.odpManager = config.odpManager;
     this.vuidManager = config.vuidManager;
+    this.eventProcessor = config.eventProcessor;
+
+    if(config.disposable) {
+      this.projectConfigManager.makeDisposable();
+      this.eventProcessor?.makeDisposable();
+      this.odpManager?.makeDisposable();
+    }
 
     let decideOptionsArray = config.defaultDecideOptions ?? [];
+
     if (!Array.isArray(decideOptionsArray)) {
       this.logger.log(LOG_LEVEL.DEBUG, INVALID_DEFAULT_DECIDE_OPTIONS, MODULE_NAME);
       decideOptionsArray = [];
@@ -160,7 +170,6 @@ export default class Optimizely implements Client {
       }
     });
     this.defaultDecideOptions = defaultDecideOptions;
-    this.projectConfigManager = config.projectConfigManager;
 
     this.disposeOnUpdate = this.projectConfigManager.onUpdate((configObj: projectConfig.ProjectConfig) => {
       this.logger.log(
@@ -176,10 +185,6 @@ export default class Optimizely implements Client {
       this.updateOdpSettings();
     });
 
-    if(config.disposable) {
-      this.projectConfigManager.makeDisposable();
-    }
-    
     this.projectConfigManager.start();
     const projectConfigManagerRunningPromise = this.projectConfigManager.onRunning();
 
@@ -201,10 +206,6 @@ export default class Optimizely implements Client {
       UNSTABLE_conditionEvaluators: config.UNSTABLE_conditionEvaluators,
     });
 
-    this.notificationCenter = config.notificationCenter;
-
-    this.eventProcessor = config.eventProcessor;
-
     this.eventProcessor?.start();
     const eventProcessorRunningPromise = this.eventProcessor ? this.eventProcessor.onRunning() :
       Promise.resolve(undefined);
@@ -213,6 +214,8 @@ export default class Optimizely implements Client {
       this.notificationCenter.sendNotifications(NOTIFICATION_TYPES.LOG_EVENT, event);
     });
 
+    this.odpManager?.start();
+
     this.readyPromise = Promise.all([
       projectConfigManagerRunningPromise,
       eventProcessorRunningPromise,