factory test

Author: raju-opti

lib/odp/event_manager/odp_event_manager.ts

@@ -204,8 +204,7 @@ export class DefaultOdpEventManager extends BaseService implements OdpEventManag
 
     if (this.queue.length === this.batchSize) {
       this.flush();
-    } else if (!this.repeater.isRunning() && this.batchSize > 1) {
-      // no need to repeatedly flush if batchSize is 1
+    } else if (!this.repeater.isRunning()) {
       this.repeater.start();
     }
   }

lib/odp/odp_manager_factory.browser.ts

@@ -0,0 +1,26 @@
+import { BrowserRequestHandler } from '../utils/http_request_handler/browser_request_handler';
+import { pixelApiRequestGenerator } from './event_manager/odp_event_api_manager';
+import { OdpManager } from './odp_manager';
+import { getOdpManager, OdpManagerOptions } from './odp_manager_factory';
+
+export const BROWSER_DEFAULT_API_TIMEOUT = 10_000;
+
+export const createOdpManager = (options: OdpManagerOptions): OdpManager => {
+  let defaultRequestHandler = new BrowserRequestHandler({ timeout: BROWSER_DEFAULT_API_TIMEOUT });
+
+  const segmentRequestHandler = options.segmentsApiTimeout !== undefined  ?
+    new BrowserRequestHandler({ timeout: options.segmentsApiTimeout }) :
+    defaultRequestHandler;
+
+  const eventRequestHandler = options.eventApiTimeout !== undefined ?
+    new BrowserRequestHandler({ timeout: options.eventApiTimeout }) :
+    defaultRequestHandler;
+
+  return getOdpManager({
+    ...options,
+    eventBatchSize: 1,
+    segmentRequestHandler,
+    eventRequestHandler,
+    eventRequestGenerator: pixelApiRequestGenerator,
+  });
+};

lib/odp/odp_manager_factory.node.ts

@@ -0,0 +1,29 @@
+import { NodeRequestHandler } from '../utils/http_request_handler/node_request_handler';
+import { eventApiRequestGenerator } from './event_manager/odp_event_api_manager';
+import { OdpManager } from './odp_manager';
+import { getOdpManager, OdpManagerOptions } from './odp_manager_factory';
+
+export const NODE_DEFAULT_API_TIMEOUT = 10_000;
+export const NODE_DEFAULT_BATCH_SIZE = 10;
+export const NODE_DEFAULT_FLUSH_INTERVAL = 1000;
+
+export const createOdpManager = (options: OdpManagerOptions): OdpManager => {
+  let defaultRequestHandler = new NodeRequestHandler({ timeout: NODE_DEFAULT_API_TIMEOUT });
+
+  const segmentRequestHandler = options.segmentsApiTimeout !== undefined  ?
+    new NodeRequestHandler({ timeout: options.segmentsApiTimeout }) :
+    defaultRequestHandler;
+
+  const eventRequestHandler = options.eventApiTimeout !== undefined ?
+    new NodeRequestHandler({ timeout: options.eventApiTimeout }) :
+    defaultRequestHandler;
+
+  return getOdpManager({
+    ...options,
+    segmentRequestHandler,
+    eventRequestHandler,
+    eventBatchSize: options.eventBatchSize || NODE_DEFAULT_BATCH_SIZE,
+    eventFlushInterval: options.eventFlushInterval || NODE_DEFAULT_FLUSH_INTERVAL,
+    eventRequestGenerator: eventApiRequestGenerator,
+  });
+};

lib/odp/odp_manager_factory.react_native.ts

@@ -0,0 +1,29 @@
+import { BrowserRequestHandler } from '../utils/http_request_handler/browser_request_handler';
+import { eventApiRequestGenerator } from './event_manager/odp_event_api_manager';
+import { OdpManager } from './odp_manager';
+import { getOdpManager, OdpManagerOptions } from './odp_manager_factory';
+
+export const RN_DEFAULT_API_TIMEOUT = 10_000;
+export const RN_DEFAULT_BATCH_SIZE = 10;
+export const RN_DEFAULT_FLUSH_INTERVAL = 1000;
+
+export const createOdpManager = (options: OdpManagerOptions): OdpManager => {
+  let defaultRequestHandler = new BrowserRequestHandler({ timeout: RN_DEFAULT_API_TIMEOUT });
+
+  const segmentRequestHandler = options.segmentsApiTimeout !== undefined  ?
+    new BrowserRequestHandler({ timeout: options.segmentsApiTimeout }) :
+    defaultRequestHandler;
+
+  const eventRequestHandler = options.eventApiTimeout !== undefined ?
+    new BrowserRequestHandler({ timeout: options.eventApiTimeout }) :
+    defaultRequestHandler;
+
+  return getOdpManager({
+    ...options,
+    segmentRequestHandler,
+    eventRequestHandler,
+    eventBatchSize: options.eventBatchSize || RN_DEFAULT_BATCH_SIZE,
+    eventFlushInterval: options.eventFlushInterval || RN_DEFAULT_FLUSH_INTERVAL,
+    eventRequestGenerator: eventApiRequestGenerator,
+  });
+};