up

Author: raju-opti

lib/event_processor/event_processor_factory.browser.spec.ts

@@ -45,7 +45,8 @@ vi.mock('../utils/cache/cache', () => {
 import defaultEventDispatcher from './default_dispatcher.browser';
 import { LocalStorageCache } from '../utils/cache/local_storage_cache.browser';
 import { SyncPrefixCache } from '../utils/cache/cache';
-import { createForwardingEventProcessor, createBatchEventProcessor, EVENT_STORE_PREFIX, FAILED_EVENT_RETRY_INTERVAL } from './event_processor_factory.browser';
+import { createForwardingEventProcessor, createBatchEventProcessor } from './event_processor_factory.browser';
+import { EVENT_STORE_PREFIX, FAILED_EVENT_RETRY_INTERVAL } from './event_processor_factory';
 import sendBeaconEventDispatcher from '../plugins/event_dispatcher/send_beacon_dispatcher';
 import { getForwardingEventProcessor } from './forwarding_event_processor';
 import browserDefaultEventDispatcher from './default_dispatcher.browser';

lib/event_processor/event_processor_factory.browser.ts

@@ -23,9 +23,7 @@ import defaultEventDispatcher from './default_dispatcher.browser';
 import sendBeaconEventDispatcher from '../plugins/event_dispatcher/send_beacon_dispatcher';
 import { LocalStorageCache } from '../utils/cache/local_storage_cache.browser';
 import { SyncPrefixCache } from '../utils/cache/cache';
-
-export const FAILED_EVENT_RETRY_INTERVAL = 20 * 1000; 
-export const EVENT_STORE_PREFIX = 'optly_event:';
+import { EVENT_STORE_PREFIX, FAILED_EVENT_RETRY_INTERVAL } from './event_processor_factory';
 
 export const createForwardingEventProcessor = (
   eventDispatcher: EventDispatcher = defaultEventDispatcher,

lib/event_processor/event_processor_factory.react_native.ts

@@ -17,9 +17,65 @@ import { getForwardingEventProcessor } from './forwarding_event_processor';
 import { EventDispatcher } from './eventDispatcher';
 import { EventProcessor } from './eventProcessor';
 import defaultEventDispatcher from './default_dispatcher.browser';
+import { BatchEventProcessorOptions, getBatchEventProcessor } from './event_processor_factory';
+import { EVENT_STORE_PREFIX, FAILED_EVENT_RETRY_INTERVAL } from './event_processor_factory';
+import { AsyncPrefixCache, Cache, SyncPrefixCache } from '../utils/cache/cache';
+import { EventWithId } from './batch_event_processor';
 
 export const createForwardingEventProcessor = (
   eventDispatcher: EventDispatcher = defaultEventDispatcher,
 ): EventProcessor => {
   return getForwardingEventProcessor(eventDispatcher);
 };
+
+const identity = <T>(v: T): T => v;
+
+const getDefaultEventStore = () => {
+  const AsyncStorageCache = require('../utils/cache/async_storage_cache.react_native').AsyncStorageCache;
+
+  const asyncStorageCache = new AsyncStorageCache();
+
+  const eventStore = new AsyncPrefixCache<EventWithId, EventWithId>(
+    asyncStorageCache, 
+    EVENT_STORE_PREFIX,
+    identity,
+    identity,
+  );
+
+  return eventStore;
+}
+
+const getPrefixEventStore = (cache: Cache<string>): Cache<EventWithId> => {
+  if (cache.operation === 'async') {
+    return new AsyncPrefixCache<string, EventWithId>(
+      cache, 
+      EVENT_STORE_PREFIX,
+      JSON.parse,
+      JSON.stringify,
+    );
+  } else {
+    return new SyncPrefixCache<string, EventWithId>(
+      cache, 
+      EVENT_STORE_PREFIX,
+      JSON.parse,
+      JSON.stringify,
+    );
+  }
+};
+
+export const createBatchEventProcessor = (
+  options: BatchEventProcessorOptions
+): EventProcessor => {
+  const eventStore = options.eventStore ? getPrefixEventStore(options.eventStore) : getDefaultEventStore();
+  
+  return getBatchEventProcessor({
+    eventDispatcher: options.eventDispatcher || defaultEventDispatcher,
+    flushInterval: options.flushInterval,
+    batchSize: options.batchSize,
+    retryOptions: {
+      maxRetries: 5,
+    },
+    failedEventRetryInterval: FAILED_EVENT_RETRY_INTERVAL,
+    eventStore,
+  });
+};

lib/event_processor/event_processor_factory.ts

@@ -11,6 +11,8 @@ export const DEFAULT_EVENT_FLUSH_INTERVAL = 1000;
 export const DEFAULT_EVENT_MAX_QUEUE_SIZE = 10000;
 export const DEFAULT_MIN_BACKOFF = 1000;
 export const DEFAULT_MAX_BACKOFF = 32000;
+export const FAILED_EVENT_RETRY_INTERVAL = 20 * 1000; 
+export const EVENT_STORE_PREFIX = 'optly_event:';
 
 export type BatchEventProcessorOptions = {
   eventDispatcher?: EventDispatcher;