Skip to content

RTD Module: Populate userIdAsEids in handleRTD function #256

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
mosherBT wants to merge 2 commits into from
Closed

RTD Module: Populate userIdAsEids in handleRTD function #256

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a956803
Populate userIdAsEids in handleRTD function
mosherBT Dec 17, 2025
c8b9a96
optableResolved
mosherBT Dec 17, 2025
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
49 changes: 49 additions & 0 deletions lib/core/prebid/rtd.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,7 @@ interface ReqBidsConfigObj {
[bidderName: string]: ORTB2;
};
};
adUnits?: any[];
}

type MergeStrategy = (existingEids: EID[], newEids: EID[], key?: (eid: EID) => string) => EID[];
Expand Down Expand Up @@ -248,6 +249,7 @@ function mergeStrategy(config: RTDConfig, eidSource: string): MergeStrategy {
function merge(config: RTDConfig, targetORTB2: ORTB2, sourceORTB2: ORTB2): number {
/* eslint-disable no-param-reassign */
targetORTB2.user = targetORTB2.user ?? {};
targetORTB2.user.eids = targetORTB2.user.eids ?? [];
targetORTB2.user.ext = targetORTB2.user.ext ?? {};
targetORTB2.user.ext.eids = targetORTB2.user.ext.eids ?? [];
/* eslint-enable no-param-reassign */
Expand All @@ -269,6 +271,9 @@ function merge(config: RTDConfig, targetORTB2: ORTB2, sourceORTB2: ORTB2): numbe
const mergeFn = mergeStrategy(config, eidSource);
// eslint-disable-next-line no-param-reassign
targetORTB2.user!.ext!.eids = mergeFn(targetORTB2.user!.ext!.eids!, eids);
// Also populate user.eids for ORTB 2.6 compatibility
// eslint-disable-next-line no-param-reassign
targetORTB2.user!.eids = mergeFn(targetORTB2.user!.eids!, eids);
});
return skipped;
}
Expand Down Expand Up @@ -346,6 +351,50 @@ function handleRtd(

config.log("info", `Processed ${processedEids} EIDs, skipped ${skippedEids} EIDs`);
config.log("info", `Merged ${globalEidsCount} global EIDs and ${bidderEidsCount} bidder-specific EID sets`);

// Populate userIdAsEids on each bid in adUnits
const adUnitsToProcess = reqBidsConfigObj.adUnits || [];
if (adUnitsToProcess.length > 0) {
const globalEids = reqBidsConfigObj.ortb2Fragments.global.user?.eids || [];
let totalBidsProcessed = 0;

adUnitsToProcess.forEach((adUnit) => {
if (adUnit.bids && Array.isArray(adUnit.bids)) {
adUnit.bids.forEach((bid: any) => {
// Get bidder-specific EIDs if they exist
const bidderEids = reqBidsConfigObj.ortb2Fragments.bidder[bid.bidder]?.user?.eids || [];

// Initialize userIdAsEids if it doesn't exist
// eslint-disable-next-line no-param-reassign
bid.userIdAsEids = bid.userIdAsEids || [];

// Merge global and bidder-specific EIDs, deduplicating by source and inserter
const combinedEids = [...globalEids, ...bidderEids];

combinedEids.forEach((eid) => {
// Check if duplicate exists (by source and inserter)
const isDuplicate = bid.userIdAsEids.some(
(e: any) => e.source === eid.source && e.inserter === (eid as any).inserter
);
if (!isDuplicate) {
// eslint-disable-next-line no-param-reassign
bid.userIdAsEids.push(eid);
}
});

totalBidsProcessed += 1;

config.log("info", `Populated userIdAsEids for ${bid.bidder} with ${bid.userIdAsEids.length} EIDs`);
});
}
});

config.log(
"info",
`Populated userIdAsEids on ${totalBidsProcessed} bids across ${adUnitsToProcess.length} ad units`
);
}

config.log("info", "Successfully completed handleRtd function");
}

Expand Down