feat: add defensive queue to _sendEventStream to prevent event loss

src/Rokt-Kit.js

@@ -39,6 +39,7 @@ var constructor = function () {
     self.placementEventMappingLookup = {};
     self.placementEventAttributeMappingLookup = {};
     self.eventQueue = [];
+    self.eventStreamQueue = [];
     self.integrationName = null;
 
     function getEventAttributeValue(event, eventAttributeKey) {
@@ -521,7 +522,12 @@ var constructor = function () {
 
     function _sendEventStream(event) {
         if (window.Rokt && typeof window.Rokt.__event_stream__ === 'function') {
+            while (self.eventStreamQueue.length) {
+                window.Rokt.__event_stream__(self.eventStreamQueue.shift());
+            }
             window.Rokt.__event_stream__(event);
+        } else {
+            self.eventStreamQueue.push(event);
         }
     }
 

test/src/tests.js

@@ -4317,6 +4317,7 @@
 
     describe('#_sendEventStream', () => {
         beforeEach(() => {
+            window.mParticle.forwarder.eventStreamQueue = [];
             window.Rokt = new MockRoktForwarder();
             window.Rokt.createLauncher = async function () {
                 return Promise.resolve({
@@ -4364,6 +4365,7 @@
         afterEach(() => {
             delete window.Rokt.__event_stream__;
             window.mParticle.forwarder.eventQueue = [];
+            window.mParticle.forwarder.eventStreamQueue = [];
             window.mParticle.forwarder.isInitialized = false;
             window.mParticle.Rokt.attachKitCalled = false;
         });
@@ -4396,7 +4398,7 @@
             receivedEvents[0].should.deepEqual(testEvent);
         });
 
-        it('should not throw when window.Rokt.__event_stream__ is not defined', async () => {
+        it('should queue event when window.Rokt.__event_stream__ is not defined', async () => {
             await window.mParticle.forwarder.init(
                 { accountId: '123456' },
                 reportService.cb,
@@ -4407,16 +4409,21 @@
 
             await waitForCondition(() => window.mParticle.Rokt.attachKitCalled);
 
+            var testEvent = {
+                EventName: 'Test Event',
+                EventCategory: EventType.Other,
+                EventDataType: MessageType.PageEvent,
+            };
+
             (function () {
-                window.mParticle.forwarder.process({
-                    EventName: 'Test Event',
-                    EventCategory: EventType.Other,
-                    EventDataType: MessageType.PageEvent,
-                });
+                window.mParticle.forwarder.process(testEvent);
             }).should.not.throw();
+
+            window.mParticle.forwarder.eventStreamQueue.length.should.equal(1);
+            window.mParticle.forwarder.eventStreamQueue[0].should.deepEqual(testEvent);
         });
 
-        it('should not throw when window.Rokt is undefined', async () => {
+        it('should queue event when window.Rokt is undefined', async () => {
             await window.mParticle.forwarder.init(
                 { accountId: '123456' },
                 reportService.cb,
@@ -4430,14 +4437,19 @@
             var savedRokt = window.Rokt;
             window.Rokt = undefined;
 
+            var testEvent = {
+                EventName: 'Test Event',
+                EventCategory: EventType.Other,
+                EventDataType: MessageType.PageEvent,
+            };
+
             (function () {
-                window.mParticle.forwarder.process({
-                    EventName: 'Test Event',
-                    EventCategory: EventType.Other,
-                    EventDataType: MessageType.PageEvent,
-                });
+                window.mParticle.forwarder.process(testEvent);
             }).should.not.throw();
 
+            window.mParticle.forwarder.eventStreamQueue.length.should.equal(1);
+            window.mParticle.forwarder.eventStreamQueue[0].should.deepEqual(testEvent);
+
             window.Rokt = savedRokt;
         });
 
@@ -4579,6 +4591,49 @@
                 'foo-mapped-flag': true,
             });
         });
+
+        it('should flush queued events in FIFO order when __event_stream__ becomes available', async () => {
+            await window.mParticle.forwarder.init(
+                { accountId: '123456' },
+                reportService.cb,
+                true,
+                null,
+                {}
+            );
+
+            await waitForCondition(() => window.mParticle.Rokt.attachKitCalled);
+
+            window.mParticle.forwarder.process({
+                EventName: 'Event A',
+                EventCategory: EventType.Other,
+                EventDataType: MessageType.PageEvent,
+            });
+            window.mParticle.forwarder.process({
+                EventName: 'Event B',
+                EventCategory: EventType.Other,
+                EventDataType: MessageType.PageEvent,
+            });
+
+            window.mParticle.forwarder.eventStreamQueue.length.should.equal(2);
+
+            var receivedEvents = [];
+            window.Rokt.__event_stream__ = function (event) {
+                receivedEvents.push(event);
+            };
+
+            window.mParticle.forwarder.process({
+                EventName: 'Event C',
+                EventCategory: EventType.Other,
+                EventDataType: MessageType.PageEvent,
+            });
+
+            receivedEvents.length.should.equal(3);
+            receivedEvents[0].EventName.should.equal('Event A');
+            receivedEvents[1].EventName.should.equal('Event B');
+            receivedEvents[2].EventName.should.equal('Event C');
+            window.mParticle.forwarder.eventStreamQueue.length.should.equal(0);
+        });
+
     });
 
     describe('#parseSettingsString', () => {