factory test

Author: raju-opti

lib/event_processor/event_processor_factory.browser.spec.ts

@@ -24,9 +24,15 @@ vi.mock('./forwarding_event_processor', () => {
   return { getForwardingEventProcessor };
 });
 
-import { createForwardingEventProcessor } from './event_processor_factory.browser';
+vi.mock('./event_processor_factory', () => {
+  const getBatchEventProcessor = vi.fn().mockReturnValue({});
+  return { getBatchEventProcessor };
+});
+
+import { createForwardingEventProcessor, createBatchEventProcessor } from './event_processor_factory.browser';
 import { getForwardingEventProcessor } from './forwarding_event_processor';
 import browserDefaultEventDispatcher from './default_dispatcher.browser';
+import { getBatchEventProcessor } from './event_processor_factory';
 
 describe('createForwardingEventProcessor', () => {
   const mockGetForwardingEventProcessor = vi.mocked(getForwardingEventProcessor);
@@ -53,3 +59,27 @@ describe('createForwardingEventProcessor', () => {
     expect(mockGetForwardingEventProcessor).toHaveBeenNthCalledWith(1, browserDefaultEventDispatcher);
   });
 });
+
+
+describe('createBatchEventProcessor', () => {
+  const mockGetBatchEventProcessor = vi.mocked(getBatchEventProcessor);
+
+  beforeEach(() => {
+    mockGetBatchEventProcessor.mockClear();
+  });
+
+  it('uses localStorageCache and SyncPrefixCache to create eventStore', () => {
+    const options = {
+      eventDispatcher: {
+        dispatchEvent: vi.fn(),
+      },
+      flushInterval: 1000,
+      batchSize: 10,
+    };
+
+    const processor = createBatchEventProcessor(options);
+    expect(Object.is(processor, mockGetBatchEventProcessor.mock.results[0].value)).toBe(true);
+    const eventStore = mockGetBatchEventProcessor.mock.calls[0][0].eventStore;
+    expect
+  });
+});

lib/event_processor/event_processor_factory.browser.ts

@@ -17,12 +17,12 @@
 import { getForwardingEventProcessor } from './forwarding_event_processor';
 import { EventDispatcher } from './eventDispatcher';
 import { EventProcessor } from './eventProcessor';
-import { BatchEventProcessor, BatchEventProcessorConfig, EventWithId } from './batch_event_processor';
-import { getBatchEventProcessor, QueueingEventProcessorOptions } from './event_processor_factory';
+import { EventWithId } from './batch_event_processor';
+import { getBatchEventProcessor, BatchEventProcessorOptions } from './event_processor_factory';
 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';
+import { SyncPrefixCache, AsyncPrefixCache, Cache } from '../utils/cache/cache';
 
 export const FAILED_EVENT_RETRY_INTERVAL = 20 * 1000; 
 export const EVENT_STORE_PREFIX = 'fs_optly_pending_events';
@@ -33,14 +33,16 @@ export const createForwardingEventProcessor = (
   return getForwardingEventProcessor(eventDispatcher);
 };
 
-export const createQueueingEventProcessor = (
-  options: QueueingEventProcessorOptions
+const identity = <T>(v: T): T => v;
+
+export const createBatchEventProcessor = (
+  options: BatchEventProcessorOptions
 ): EventProcessor => {
-  const localStorageCache = new LocalStorageCache<string>();
-  const eventStore = new SyncPrefixCache<string, EventWithId>(
+  const localStorageCache = new LocalStorageCache<EventWithId>();
+  const eventStore = new SyncPrefixCache<EventWithId, EventWithId>(
     localStorageCache, EVENT_STORE_PREFIX,
-    JSON.parse,
-    JSON.stringify
+    identity,
+    identity,
   );
 
   return getBatchEventProcessor({

lib/event_processor/event_processor_factory.ts

@@ -12,14 +12,15 @@ export const DEFAULT_EVENT_MAX_QUEUE_SIZE = 10000;
 export const DEFAULT_MIN_BACKOFF = 1000;
 export const DEFAULT_MAX_BACKOFF = 32000;
 
-export type QueueingEventProcessorOptions = {
+export type BatchEventProcessorOptions = {
   eventDispatcher?: EventDispatcher;
   closingEventDispatcher?: EventDispatcher;
   flushInterval?: number;
   batchSize?: number;
+  eventStore?: Cache<string>;
 };
 
-export type QueueingEventProcessorFactoryOptions = Omit<QueueingEventProcessorOptions, 'eventDispatcher'> & {
+export type BatchEventProcessorFactoryOptions = Omit<BatchEventProcessorOptions, 'eventDispatcher' | 'eventStore'> & {
   eventDispatcher: EventDispatcher;
   failedEventRetryInterval?: number;
   eventStore?: Cache<EventWithId>;
@@ -31,7 +32,7 @@ export type QueueingEventProcessorFactoryOptions = Omit<QueueingEventProcessorOp
 }
 
 export const getBatchEventProcessor = (
-    options: QueueingEventProcessorFactoryOptions,
+    options: BatchEventProcessorFactoryOptions,
     EventProcessorConstructor: typeof BatchEventProcessor = BatchEventProcessor
   ): EventProcessor => {
   const { eventDispatcher, closingEventDispatcher, retryOptions, eventStore } = options;

vitest.config.mts

@@ -20,7 +20,7 @@ export default defineConfig({
   test: {
     onConsoleLog: () => true,
     environment: 'happy-dom',
-    include: ['**/event_processor_factory.spec.ts'],
+    include: ['**/event_processor_factory.browser.spec.ts'],
     typecheck: {
       tsconfig: 'tsconfig.spec.json',
     },