Add createEventProcessor factory function

Author: Matt Carroll

packages/optimizely-sdk/lib/core/event_processor/index.ts

@@ -0,0 +1,11 @@
+import { LogTierV1EventProcessor, LocalStoragePendingEventsDispatcher } from '@optimizely/js-sdk-event-processor';
+
+export function createEventProcessor(
+  ...args: ConstructorParameters<typeof LogTierV1EventProcessor>
+): LogTierV1EventProcessor {
+  return new LogTierV1EventProcessor(...args);
+}
+
+export { EventProcessor, LocalStoragePendingEventsDispatcher } from '@optimizely/js-sdk-event-processor';
+
+export default { createEventProcessor, LocalStoragePendingEventsDispatcher };

packages/optimizely-sdk/lib/index.browser.tests.js

@@ -16,7 +16,7 @@
 import { assert } from 'chai';
 import sinon from 'sinon';
 import * as logging from '@optimizely/js-sdk-logging';
-import * as eventProcessor from '@optimizely/js-sdk-event-processor';
+import eventProcessor from './core/event_processor';
 
 import Optimizely from './optimizely';
 import testData from './tests/test_data';
@@ -391,11 +391,11 @@ describe('javascript-sdk', function() {
       describe('event processor configuration', function() {
         var eventProcessorSpy;
         beforeEach(function() {
-          eventProcessorSpy = sinon.spy(eventProcessor, 'LogTierV1EventProcessor');
+          eventProcessorSpy = sinon.spy(eventProcessor, 'createEventProcessor');
         });
 
         afterEach(function() {
-          eventProcessor.LogTierV1EventProcessor.restore();
+          eventProcessor.createEventProcessor.restore();
         });
 
         it('should use default event flush interval when none is provided', function() {

packages/optimizely-sdk/lib/index.node.tests.js

@@ -15,7 +15,7 @@
  */
 import { assert } from 'chai';
 import sinon from 'sinon';
-import * as eventProcessor from '@optimizely/js-sdk-event-processor';
+import eventProcessor from './core/event_processor';
 
 import * as enums from './utils/enums';
 import Optimizely from './optimizely';
@@ -96,11 +96,11 @@ describe('optimizelyFactory', function() {
       describe('event processor configuration', function() {
         var eventProcessorSpy;
         beforeEach(function() {
-          eventProcessorSpy = sinon.stub(eventProcessor, 'LogTierV1EventProcessor').callThrough();
+          eventProcessorSpy = sinon.stub(eventProcessor, 'createEventProcessor').callThrough();
         });
 
         afterEach(function() {
-          eventProcessor.LogTierV1EventProcessor.restore();
+          eventProcessor.createEventProcessor.restore();
         });
 
         it('should ignore invalid event flush interval and use default instead', function() {

packages/optimizely-sdk/lib/index.react_native.tests.js

@@ -16,7 +16,7 @@
 import { assert } from 'chai';
 import sinon from 'sinon';
 import * as logging from '@optimizely/js-sdk-logging';
-import * as eventProcessor from '@optimizely/js-sdk-event-processor';
+import eventProcessor from './core/event_processor';
 
 import Optimizely from './optimizely';
 import testData from './tests/test_data';
@@ -184,11 +184,11 @@ describe('javascript-sdk/react-native', function() {
       describe('event processor configuration', function() {
         var eventProcessorSpy;
         beforeEach(function() {
-          eventProcessorSpy = sinon.spy(eventProcessor, 'LogTierV1EventProcessor');
+          eventProcessorSpy = sinon.spy(eventProcessor, 'createEventProcessor');
         });
 
         afterEach(function() {
-          eventProcessor.LogTierV1EventProcessor.restore();
+          eventProcessor.createEventProcessor.restore();
         });
 
         it('should use default event flush interval when none is provided', function() {

packages/optimizely-sdk/lib/optimizely/index.tests.js

@@ -16,7 +16,7 @@
 import { assert } from 'chai';
 import sinon from 'sinon';
 import { sprintf } from '@optimizely/js-sdk-utils';
-import * as eventProcessor from '@optimizely/js-sdk-event-processor';
+import eventProcessor from '../core/event_processor';
 import * as logging from '@optimizely/js-sdk-logging';
 
 import Optimizely from './';
@@ -7730,11 +7730,11 @@ describe('lib/optimizely', function() {
           start: sinon.stub(),
           stop: sinon.stub(),
         };
-        sinon.stub(eventProcessor, 'LogTierV1EventProcessor').returns(mockEventProcessor);
+        sinon.stub(eventProcessor, 'createEventProcessor').returns(mockEventProcessor);
       });
 
       afterEach(function() {
-        eventProcessor.LogTierV1EventProcessor.restore();
+        eventProcessor.createEventProcessor.restore();
       });
 
       describe('when the event processor stop method returns a promise that fulfills', function() {
@@ -7813,13 +7813,13 @@ describe('lib/optimizely', function() {
     beforeEach(function() {
       sinon.stub(errorHandler, 'handleError');
       sinon.stub(createdLogger, 'log');
-      sinon.spy(eventProcessor, 'LogTierV1EventProcessor');
+      sinon.spy(eventProcessor, 'createEventProcessor');
     });
 
     afterEach(function() {
       errorHandler.handleError.restore();
       createdLogger.log.restore();
-      eventProcessor.LogTierV1EventProcessor.restore();
+      eventProcessor.createEventProcessor.restore();
     });
 
     it('should instantiate the eventProcessor with the provided event flush interval and event batch size', function() {
@@ -7836,7 +7836,7 @@ describe('lib/optimizely', function() {
       });
 
       sinon.assert.calledWithExactly(
-        eventProcessor.LogTierV1EventProcessor,
+        eventProcessor.createEventProcessor,
         sinon.match({
           dispatcher: eventDispatcher,
           flushInterval: 20000,

packages/optimizely-sdk/lib/optimizely/index.ts

@@ -33,7 +33,7 @@ import { getImpressionEvent, getConversionEvent } from '../core/event_builder';
 import { buildImpressionEvent, buildConversionEvent } from '../core/event_builder/event_helpers';
 import fns from '../utils/fns'
 import { validate } from '../utils/attributes_validator';
-import { EventProcessor, LogTierV1EventProcessor } from '@optimizely/js-sdk-event-processor';
+import { EventProcessor, default as eventProcessor } from '../core/event_processor';
 import * as enums from '../utils/enums';
 import * as eventTagsValidator from '../utils/event_tags_validator';
 import * as projectConfig from '../core/project_config';
@@ -170,7 +170,7 @@ export default class Optimizely {
       notificationCenter: this.notificationCenter,
     }
 
-    this.eventProcessor = new LogTierV1EventProcessor(eventProcessorConfig);
+    this.eventProcessor = eventProcessor.createEventProcessor(eventProcessorConfig);
 
     const eventProcessorStartedPromise = this.eventProcessor.start();