Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
19 changes: 19 additions & 0 deletions src/Rokt-Kit.js
Original file line number Diff line number Diff line change
Expand Up @@ -242,6 +242,24 @@ var constructor = function () {
return self.launcher.selectPlacements(selectPlacementsOptions);
}

/**
* Enables optional Integration Launcher extensions before selecting placements
* @param {string} extensionName - Name of the extension to enable
* @returns {Promise<*>} A Promise resolving to the extension API if available
*/
function use(extensionName) {
if (!isKitReady()) {
console.error('Rokt Kit: Not initialized');
return Promise.reject(new Error('Rokt Kit: Not initialized'));
}
if (!extensionName || typeof extensionName !== 'string') {
return Promise.reject(
new Error('Rokt Kit: Invalid extension name')
);
}
return self.launcher.use(extensionName);
}

/**
* Sets extension data for Rokt Web SDK
* @param {Object} partnerExtensionData - The extension data object containing:
Expand Down Expand Up @@ -375,6 +393,7 @@ var constructor = function () {
// Called by the mParticle Rokt Manager
this.selectPlacements = selectPlacements;
this.hashAttributes = hashAttributes;
this.use = use;

// Kit Callback Methods
this.init = initForwarder;
Expand Down
139 changes: 139 additions & 0 deletions test/src/tests.js
Original file line number Diff line number Diff line change
Expand Up @@ -1391,6 +1391,145 @@ describe('Rokt Forwarder', () => {
});
});

describe('#use', () => {
beforeEach(() => {
window.Rokt = new MockRoktForwarder();
window.mParticle.Rokt = window.Rokt;
window.mParticle.Rokt.attachKitCalled = false;
window.mParticle.Rokt.attachKit = async (kit) => {
window.mParticle.Rokt.attachKitCalled = true;
window.mParticle.Rokt.kit = kit;
Promise.resolve();
};
});

it('should call launcher.use with the provided extension name when fully initialized', async () => {
window.mParticle.forwarder.isInitialized = true;
window.mParticle.forwarder.launcher = {
use: function (name) {
window.Rokt.useCalled = true;
window.Rokt.useName = name;
return Promise.resolve({});
},
};

await window.mParticle.forwarder.use('ThankYouPageJourney');

window.Rokt.useCalled.should.equal(true);
window.Rokt.useName.should.equal('ThankYouPageJourney');
});

it('should reject when called before initialization', async () => {
window.mParticle.forwarder.isInitialized = false;

try {
await window.mParticle.forwarder.use('ThankYouPageJourney');
} catch (error) {
error.message.should.equal('Rokt Kit: Not initialized');
}
});

it('should log an error when called before initialization', async () => {
const originalConsoleError = window.console.error;
let errorLogged = false;
let errorMessage = null;
window.console.error = function (message) {
errorLogged = true;
errorMessage = message;
};

window.mParticle.forwarder.isInitialized = false;
window.mParticle.forwarder.launcher = null;

try {
await window.mParticle.forwarder.use('ThankYouPageJourney');
throw new Error('Expected promise to reject');
} catch (error) {
error.message.should.equal('Rokt Kit: Not initialized');
} finally {
window.console.error = originalConsoleError;
}

errorLogged.should.equal(true);
errorMessage.should.equal('Rokt Kit: Not initialized');
});

it('should reject when extension name is invalid', async () => {
window.mParticle.forwarder.isInitialized = true;
window.mParticle.forwarder.launcher = {
use: function () {
return Promise.resolve({});
},
};

try {
await window.mParticle.forwarder.use(123);
} catch (error) {
error.message.should.equal('Rokt Kit: Invalid extension name');
}
});

it('should log an error when kit is initialized but launcher is missing', async () => {
const originalConsoleError = window.console.error;
let errorLogged = false;
let errorMessage = null;
window.console.error = function (message) {
errorLogged = true;
errorMessage = message;
};

window.mParticle.forwarder.isInitialized = true;
window.mParticle.forwarder.launcher = null;

try {
await window.mParticle.forwarder.use('ThankYouPageJourney');
throw new Error('Expected promise to reject');
} catch (error) {
error.message.should.equal('Rokt Kit: Not initialized');
} finally {
window.console.error = originalConsoleError;
}
errorLogged.should.equal(true);
errorMessage.should.equal('Rokt Kit: Not initialized');
});

it('should call launcher.use after init (test mode) and attach', async () => {
window.mParticle.Rokt.attachKitCalled = false;
window.mParticle.Rokt.attachKit = async (kit) => {
window.mParticle.Rokt.attachKitCalled = true;
window.mParticle.Rokt.kit = kit;
Promise.resolve();
};

window.Rokt.createLauncher = async function () {
return Promise.resolve({
use: function (name) {
window.Rokt.useCalled = true;
window.Rokt.useName = name;
return Promise.resolve({});
},
});
};

await window.mParticle.forwarder.init(
{
accountId: '123456',
},
reportService.cb,
true,
null,
{}
);

await waitForCondition(() => window.mParticle.Rokt.attachKitCalled);

await window.mParticle.forwarder.use('ThankYouPageJourney');

window.Rokt.useCalled.should.equal(true);
window.Rokt.useName.should.equal('ThankYouPageJourney');
});
});

describe('#setUserAttribute', () => {
it('should set the user attribute', async () => {
window.mParticle.forwarder.setUserAttribute(
Expand Down
Loading