feat: Implement Rokt Local Launcher SDKE-321 (#45)

Author: guillermot

src/Rokt-Kit.js

@@ -330,35 +330,40 @@ var constructor = function () {
             launcherOptions || {}
         );
 
-        window.Rokt.createLauncher(options)
-            .then(function (launcher) {
-                // Assign the launcher to a global variable for later access
-                window.Rokt.currentLauncher = launcher;
-                // Locally cache the launcher and filters
-                self.launcher = launcher;
+        if (isPartnerInLocalLauncherTestGroup()) {
+            var localLauncher = window.Rokt.createLocalLauncher(options);
+            initRoktLauncher(localLauncher);
+        } else {
+            window.Rokt.createLauncher(options)
+                .then(initRoktLauncher)
+                .catch(function (err) {
+                    console.error('Error creating Rokt launcher:', err);
+                });
+        }
+    }
 
-                var roktFilters = window.mParticle.Rokt.filters;
+    function initRoktLauncher(launcher) {
+        // Assign the launcher to a global variable for later access
+        window.Rokt.currentLauncher = launcher;
+        // Locally cache the launcher and filters
+        self.launcher = launcher;
 
-                if (!roktFilters) {
-                    console.warn('Rokt Kit: No filters have been set.');
-                } else {
-                    self.filters = roktFilters;
-                    if (!roktFilters.filteredUser) {
-                        console.warn(
-                            'Rokt Kit: No filtered user has been set.'
-                        );
-                    }
-                }
+        var roktFilters = window.mParticle.Rokt.filters;
 
-                // Kit must be initialized before attaching to the Rokt manager
-                self.isInitialized = true;
-                // Attaches the kit to the Rokt manager
-                window.mParticle.Rokt.attachKit(self);
-                processEventQueue();
-            })
-            .catch(function (err) {
-                console.error('Error creating Rokt launcher:', err);
-            });
+        if (!roktFilters) {
+            console.warn('Rokt Kit: No filters have been set.');
+        } else {
+            self.filters = roktFilters;
+            if (!roktFilters.filteredUser) {
+                console.warn('Rokt Kit: No filtered user has been set.');
+            }
+        }
+
+        // Kit must be initialized before attaching to the Rokt manager
+        self.isInitialized = true;
+        // Attaches the kit to the Rokt manager
+        window.mParticle.Rokt.attachKit(self);
+        processEventQueue();
     }
 
     // mParticle Kit Callback Methods
@@ -426,6 +431,13 @@ var constructor = function () {
     function isKitReady() {
         return !!(self.isInitialized && self.launcher);
     }
+
+    function isPartnerInLocalLauncherTestGroup() {
+        return (
+            window.mParticle.config &&
+            window.mParticle.config.isLocalLauncherEnabled
+        );
+    }
 };
 
 function generateIntegrationName(customIntegrationName) {

test/src/tests.js

@@ -98,6 +98,7 @@ describe('Rokt Forwarder', () => {
         this.sandbox = null;
         this.integrationName = null;
         this.createLauncherCalled = false;
+        this.createLocalLauncherCalled = false;
 
         this.createLauncher = function (options) {
             self.accountId = options.accountId;
@@ -115,6 +116,26 @@ describe('Rokt Forwarder', () => {
             });
         };
 
+        this.createLocalLauncher = function (options) {
+            self.accountId = options.accountId;
+            self.integrationName = options.integrationName;
+            self.noFunctional = options.noFunctional;
+            self.noTargeting = options.noTargeting;
+            self.createLocalLauncherCalled = true;
+            self.isInitialized = true;
+            self.sandbox = options.sandbox;
+
+            return {
+                selectPlacements: function () {},
+                hashAttributes: function () {
+                    throw new Error('hashAttributes not implemented');
+                },
+                use: function () {
+                    throw new Error('use not implemented');
+                },
+            };
+        };
+
         this.currentLauncher = function () {};
     };
 
@@ -544,6 +565,37 @@ describe('Rokt Forwarder', () => {
                     },
                 },
             };
+            window.mParticle.config = undefined;
+        });
+
+        it('should create a remote launcher if the partner is not in the local launcher test group', async () => {
+            await window.mParticle.forwarder.init(
+                { accountId: '123456' },
+                reportService.cb,
+                true,
+                null,
+                {}
+            );
+
+            window.mParticle.Rokt.createLauncherCalled.should.equal(true);
+            window.mParticle.Rokt.createLocalLauncherCalled.should.equal(false);
+        });
+
+        it('should create a local launcher if the partner is in the local launcher test group', async () => {
+            window.mParticle.config = {
+                isLocalLauncherEnabled: true,
+            };
+
+            await window.mParticle.forwarder.init(
+                { accountId: '123456' },
+                reportService.cb,
+                true,
+                null,
+                {}
+            );
+
+            window.mParticle.Rokt.createLauncherCalled.should.equal(false);
+            window.mParticle.Rokt.createLocalLauncherCalled.should.equal(true);
         });
 
         it('should call attachKit', async () => {