up

Author: raju-opti

lib/event_processor/batch_event_processor.react_native.spec.ts

@@ -33,9 +33,12 @@ import { ReactNativeNetInfoEventProcessor } from './batch_event_processor.react_
 import { getMockLogger } from '../tests/mock/mock_logger';
 import { getMockRepeater } from '../tests/mock/mock_repeater';
 import { getMockAsyncCache } from '../tests/mock/mock_cache';
-import { createImpressionEvent } from '../tests/mock/create_event';
+
 import { EventWithId } from './batch_event_processor';
-import { formatEvents, ProcessableEvent } from '.';
+import { EventDispatcher } from './eventDispatcher';
+import { formatEvents } from './v1/buildEventV1';
+import { createImpressionEvent } from '../tests/mock/create_event';
+import { ProcessableEvent } from './eventProcessor';
 
 const getMockDispatcher = () => {
   return {

lib/event_processor/event_processor_factory.browser copy.ts

@@ -26,11 +26,12 @@ vi.mock('./forwarding_event_processor', () => {
   return { getForwardingEventProcessor };
 });
 
-vi.mock('./event_processor_factory', () => {
+vi.mock('./event_processor_factory', async (importOriginal) => {
   const getBatchEventProcessor = vi.fn().mockImplementation(() => {
     return {};
   });
-  return { getBatchEventProcessor, EVENT_STORE_PREFIX: 'test_prefix', FAILED_EVENT_RETRY_INTERVAL: 1000 };
+  const original: any = await importOriginal();
+  return { ...original, getBatchEventProcessor };
 });
 
 vi.mock('../utils/cache/local_storage_cache.browser', () => {

lib/event_processor/event_processor_factory.browser.spec copy.ts

@@ -25,11 +25,12 @@ vi.mock('./forwarding_event_processor', () => {
   return { getForwardingEventProcessor };
 });
 
-vi.mock('./event_processor_factory', () => {
+vi.mock('./event_processor_factory', async (importOriginal) => {
   const getBatchEventProcessor = vi.fn().mockImplementation(() => {
     return {};
   });
-  return { getBatchEventProcessor, EVENT_STORE_PREFIX: 'test_prefix', FAILED_EVENT_RETRY_INTERVAL: 1000 };
+  const original: any = await importOriginal();
+  return { ...original, getBatchEventProcessor };
 });
 
 vi.mock('../utils/cache/async_storage_cache.react_native', () => {

lib/event_processor/event_processor_factory.browser.spec.ts

@@ -16,10 +16,9 @@
 import { expect, describe, it, vi } from 'vitest';
 
 import { getForwardingEventProcessor } from './forwarding_event_processor';
-import { EventDispatcher, formatEvents, makeBatchedEventV1 } from '.';
-
+import { EventDispatcher } from './eventDispatcher';
+import { formatEvents, makeBatchedEventV1 } from './v1/buildEventV1';
 import { createImpressionEvent } from '../tests/mock/create_event';
-import exp from 'constants';
 import { ServiceState } from '../service';
 
 const getMockEventDispatcher = (): EventDispatcher => {

lib/event_processor/event_processor_factory.react_native.spec.ts

@@ -31,7 +31,7 @@ import { getUserAgentParser } from './plugins/odp/user_agent_parser/index.browse
 import * as commonExports from './common_exports';
 import { PollingConfigManagerConfig } from './project_config/config_manager_factory';
 import { createPollingProjectConfigManager } from './project_config/config_manager_factory.browser';
-import { createForwardingEventProcessor } from './event_processor/event_processor_factory.browser';
+import { createBatchEventProcessor, createForwardingEventProcessor } from './event_processor/event_processor_factory.browser';
 
 const logger = getLogger();
 logHelper.setLogHandler(loggerPlugin.createLogger());
@@ -196,6 +196,7 @@ export {
   getUserAgentParser,
   createPollingProjectConfigManager,
   createForwardingEventProcessor,
+  createBatchEventProcessor,
 };
 
 export * from './common_exports';
@@ -215,6 +216,7 @@ export default {
   getUserAgentParser,
   createPollingProjectConfigManager,
   createForwardingEventProcessor,
+  createBatchEventProcessor,
 };
 
 export * from './export_types';

lib/event_processor/forwarding_event_processor.spec.ts

@@ -26,7 +26,8 @@ import { OptimizelyDecideOption, Client, Config } from './shared_types';
 import { NodeOdpManager } from './plugins/odp_manager/index.node';
 import * as commonExports from './common_exports';
 import { createPollingProjectConfigManager } from './project_config/config_manager_factory.node';
-import { createForwardingEventProcessor } from './event_processor/event_processor_factory.node';
+import { createForwardingEventProcessor, createBatchEventProcessor } from './event_processor/event_processor_factory.node';
+import { create } from 'domain';
 
 const logger = getLogger();
 setLogLevel(LogLevel.ERROR);
@@ -143,6 +144,7 @@ export {
   OptimizelyDecideOption,
   createPollingProjectConfigManager,
   createForwardingEventProcessor,
+  createBatchEventProcessor,
 };
 
 export * from './common_exports';
@@ -159,6 +161,7 @@ export default {
   OptimizelyDecideOption,
   createPollingProjectConfigManager,
   createForwardingEventProcessor,
+  createBatchEventProcessor,
 };
 
 export * from './export_types';

lib/index.browser.ts

@@ -26,7 +26,7 @@ import { OptimizelyDecideOption, Client, Config } from './shared_types';
 import { BrowserOdpManager } from './plugins/odp_manager/index.browser';
 import * as commonExports from './common_exports';
 import { createPollingProjectConfigManager } from './project_config/config_manager_factory.react_native';
-import { createForwardingEventProcessor } from './event_processor/event_processor_factory.react_native';
+import { createBatchEventProcessor, createForwardingEventProcessor } from './event_processor/event_processor_factory.react_native';
 
 import 'fast-text-encoding';
 import 'react-native-get-random-values';
@@ -146,6 +146,7 @@ export {
   OptimizelyDecideOption,
   createPollingProjectConfigManager,
   createForwardingEventProcessor,
+  createBatchEventProcessor,
 };
 
 export * from './common_exports';
@@ -162,6 +163,7 @@ export default {
   OptimizelyDecideOption,
   createPollingProjectConfigManager,
   createForwardingEventProcessor,
+  createBatchEventProcessor,
 };
 
 export * from './export_types';

lib/index.node.ts

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