prebid · aleksatr · Nov 16, 2020 · Oct 27, 2020 · Oct 27, 2020 · Oct 29, 2020
diff --git a/...xamples/gpt/audigentSegments_example.html → ...Examples/gpt/haloRtdProvider_example.html b/...xamples/gpt/audigentSegments_example.html → ...Examples/gpt/haloRtdProvider_example.html
@@ -1,6 +1,7 @@
 <html>
 <head>
     <script>
+
         (function(window, document) {
             if (!window.__cmp) {
                 window.__cmp = (function() {
@@ -90,11 +91,9 @@
                 },
                 bids: [
                     {
-                        bidder: 'rubicon',
+                        bidder: 'appnexus',
                         params: {
-                            accountId: '1001',
-                            siteId: '113932',
-                            zoneId: '535510'
+                            placementId: 13144370
                         }
                     }
                 ]
@@ -108,11 +107,25 @@
 
     <script>
         var googletag = googletag || {};
+        var testAuctionDelay = 1000;
         googletag.cmd = googletag.cmd || [];
         googletag.cmd.push(function() {
             googletag.pubads().disableInitialLoad();
         });
 
+        var bidSegmentMappers = {
+            appnexus: function(bid, segments) {
+                if (!bid.params) {
+                    bid.params = {}
+                }
+                if (!bid.params.user) {
+                    bid.params.user = {}
+                }
+
+                bid.params.user.segments = segments;
+            }
+        }
+
         pbjs.que.push(function() {
             pbjs.setConfig({
                 debug: true,
@@ -232,17 +245,33 @@
                     auctionDelay: 1000
                 },
                 realTimeData: {
-                    auctionDelay: 1000,
-                    dataProviders: [{name: "audigent", waitForIt: true}]
+                    auctionDelay: testAuctionDelay, // lower in real scenario to meet publisher spec
+                    dataProviders: [
+                        {
+                            name: "audigent",
+                            waitForIt: true,
+                            params: {
+                                mapSegments: {
+                                    appnexus: true
+                                },
+                                segmentCache: false,
+                                requestParams: {
+                                    publisherId: 0
+                                }
+                            }
+
+                        }
+                    ]
                 }
             });
             pbjs.addAdUnits(adUnits);
+
             pbjs.requestBids({bidsBackHandler: sendAdserverRequest});
         });
 
         function sendAdserverRequest() {
             document.getElementById('tdid').innerHTML = adUnits[0].bids[0].userId['tdid'];
-            document.getElementById('audigent_segments').innerHTML = JSON.stringify(adUnits[0].bids[0].audigent_segments);
+            document.getElementById('audigent_segments').innerHTML = JSON.stringify(adUnits[0].bids[0].params.user.segments);
 
             if (pbjs.adserverRequestSent) return;
             pbjs.adserverRequestSent = true;
@@ -294,7 +323,7 @@ <h2>Audigent Segments Prebid</h2>
 <div id='tdid'>
 </div>
 
-Audigent Segments:
+Audigent Segments (Appnexus):
 <div id='audigent_segments'>
 </div>
 </body>

diff --git a/modules/.submodules.json b/modules/.submodules.json
@@ -26,7 +26,7 @@
   ],
   "rtdModule": [
     "browsiRtdProvider",
-    "audigentRtdProvider",
+    "haloRtdProvider",
     "jwplayerRtdProvider",
     "reconciliationRtdProvider"
   ]

diff --git a/modules/audigentRtdProvider.md b/modules/audigentRtdProvider.md
diff --git a/modules/audigentRtdProvider.js → modules/haloRtdProvider.js b/modules/audigentRtdProvider.js → modules/haloRtdProvider.js
@@ -11,27 +11,77 @@ import {submodule} from '../src/hook.js';
 import {ajax} from '../src/ajax.js';
 import { getStorageManager } from '../src/storageManager.js';
 
-const storage = getStorageManager();
+export const storage = getStorageManager();
 
 /** @type {string} */
 const MODULE_NAME = 'realTimeData';
-const SUBMODULE_NAME = 'audigent';
-const HALOID_LOCAL_NAME = 'auHaloId';
-const SEG_LOCAL_NAME = '__adgntseg';
+const SUBMODULE_NAME = 'halo';
+const ERR_MSG = 'AUDIGENT_ERR';
+
+export const HALOID_LOCAL_NAME = 'auHaloId';
+export const SEG_LOCAL_NAME = '__adgntseg';
+
+const set = (obj, path, val) => {
+  const keys = path.split('.');
+  const lastKey = keys.pop();
+  const lastObj = keys.reduce((obj, key) => obj[key] = obj[key] || {}, obj);
+  lastObj[lastKey] = lastObj[lastKey] || val;
+};
+
+/** bid adapter format segment augmentation functions */
+const segmentMappers = {
+  appnexus: function(bid, segments) {
+    set(bid, 'params.user.segments', []);
+    let appnexusSegments = [];
+    segments.forEach(segment => {
+      if (typeof segment.value != 'undefined' && segment.value != null) {
+        let appnexusSegment = {'id': segment.id, 'value': segment.value};
+        appnexusSegments.push(appnexusSegment);
+      }
+    })
+    bid.params.user.segments = bid.params.user.segments.concat(appnexusSegments);
+  },
+  generic: function(bid, segments) {
+    bid.segments = segments;
+  }
+}
 
 /**
  * decorate adUnits with segment data
  * @param {adUnit[]} adUnits
  * @param {Object} data
  */
-function addSegmentData(adUnits, data) {
+export function addSegmentData(adUnits, segmentData, config) {
   adUnits.forEach(adUnit => {
     if (adUnit.hasOwnProperty('bids')) {
       adUnit.bids.forEach(bid => {
-        bid.audigent_segments = data;
-      })
+        try {
+          set(bid, 'fpd.user.data', []);
+          if (Array.isArray(bid.fpd.user.data)) {
+            bid.fpd.user.data.forEach(fpdData => {
+              if (fpdData.name) { config.params.mapSegments[fpdData.name] = true; }
+              let segments = segmentData[fpdData.id] || segmentData[fpdData.name] || [];
+              fpdData.segment = (fpdData.segment || []).concat(segments);
+            });
+          }
+        } catch (err) {
+          utils.logError(ERR_MSG);
+        }
+
+        try {
+          if (config.params.mapSegments && config.params.mapSegments[bid.bidder] && segmentData[bid.bidder]) {
+            if (typeof config.params.mapSegments[bid.bidder] == 'function') {
+              config.params.mapSegments[bid.bidder](bid, segmentData[bid.bidder]);
+            } else if (segmentMappers[bid.bidder]) {
+              segmentMappers[bid.bidder](bid, segmentData[bid.bidder]);
+            }
+          }
+        } catch (err) {
+          utils.logError(ERR_MSG);
+        }
+      });
     }
-  })
+  });
 
   return adUnits;
 }
@@ -43,16 +93,20 @@ function addSegmentData(adUnits, data) {
  * @param {Object} config
  * @param {Object} userConsent
  */
-function getSegments(reqBidsConfigObj, onDone, config, userConsent) {
+export function getSegments(reqBidsConfigObj, onDone, config, userConsent) {
   const adUnits = reqBidsConfigObj.adUnits || getGlobal().adUnits;
 
-  let jsonData = storage.getDataFromLocalStorage(SEG_LOCAL_NAME);
-  if (jsonData) {
-    let data = JSON.parse(jsonData);
-    if (data.audigent_segments) {
-      addSegmentData(adUnits, data.audigent_segments);
-      onDone();
-      return;
+  if (config.params.segmentCache) {
+    let jsonData = storage.getDataFromLocalStorage(SEG_LOCAL_NAME);
+
+    if (jsonData) {
+      let data = JSON.parse(jsonData);
+
+      if (data.audigent_segments) {
+        addSegmentData(adUnits, data.audigent_segments, config);
+        onDone();
+        return;
+      }
     }
   }
 
@@ -88,20 +142,20 @@ function getSegments(reqBidsConfigObj, onDone, config, userConsent) {
  * @param {Object} userConsent
  * @param {Object} userIds
  */
-function getSegmentsAsync(adUnits, onDone, config, userConsent, userIds) {
-  let reqParams = {}
+export function getSegmentsAsync(adUnits, onDone, config, userConsent, userIds) {
+  let reqParams = {};
   if (typeof config == 'object' && config != null && Object.keys(config).length > 0) {
-    reqParams = config.params
+    reqParams = config.params.requestParams;
   }
 
-  const url = `https://seg.halo.ad.gt/api/v1/rtb_segments`;
+  const url = `http://127.0.0.1:5000/api/v1/rtb_segments`;
   ajax(url, {
     success: function (response, req) {
       if (req.status === 200) {
         try {
           const data = JSON.parse(response);
           if (data && data.audigent_segments) {
-            addSegmentData(adUnits, data.audigent_segments);
+            addSegmentData(adUnits, data.audigent_segments, config);
             onDone();
             storage.setDataInLocalStorage(SEG_LOCAL_NAME, JSON.stringify(data));
           } else {
@@ -128,18 +182,19 @@ function getSegmentsAsync(adUnits, onDone, config, userConsent, userIds) {
 
 /**
  * module init
- * @param {Object} config
+ * @param {Object} provider
+ * @param {Objkect} userConsent
  * @return {boolean}
  */
-export function init(config) {
+function init(provider, userConsent) {
   return true;
 }
 
 /** @type {RtdSubmodule} */
-export const audigentSubmodule = {
+export const haloSubmodule = {
   name: SUBMODULE_NAME,
   getBidRequestData: getSegments,
   init: init
 };
 
-submodule(MODULE_NAME, audigentSubmodule);
+submodule(MODULE_NAME, haloSubmodule);