ucfunnelAnalyticsAdapter

modules/ucfunnelAnalyticsAdapter.js

@@ -0,0 +1,198 @@
+import {ajax} from '../src/ajax';
+import adapter from '../src/AnalyticsAdapter';
+import CONSTANTS from '../src/constants.json';
+import adapterManager from '../src/adapterManager';
+import {logError, logInfo, deepClone} from '../src/utils';
+
+const analyticsType = 'endpoint';
+
+export const ANALYTICS_VERSION = '1.0.0';
+
+const ANALYTICS_SERVER = 'https://hbwa.aralego.com';
+
+const {
+  EVENTS: {
+    AUCTION_END,
+    BID_WON,
+    BID_TIMEOUT
+  }
+} = CONSTANTS;
+
+export const BIDDER_STATUS = {
+  BID: 'bid',
+  NO_BID: 'noBid',
+  BID_WON: 'bidWon',
+  TIMEOUT: 'timeout'
+};
+
+const analyticsOptions = {};
+
+export const parseBidderCode = function (bid) {
+  let bidderCode = bid.bidderCode || bid.bidder;
+  return bidderCode.toLowerCase();
+};
+
+export const parseAdUnitCode = function (bidResponse) {
+  return bidResponse.adUnitCode.toLowerCase();
+};
+
+export const ucfunnelAnalyticsAdapter = Object.assign(adapter({ANALYTICS_SERVER, analyticsType}), {
+
+  cachedAuctions: {},
+
+  initConfig(config) {
+    /**
+     * Required option: pbuid
+     * Required option: adid
+     * @type {boolean}
+     */
+    analyticsOptions.options = deepClone(config.options);
+    if (typeof config.options.pbuid !== 'string' || config.options.pbuid.length < 1) {
+      logError('"options.pbuid" is required.');
+      return false;
+    }
+    if (typeof config.options.adid !== 'string' || config.options.adid.length < 1) {
+      logError('"options.adid" is required.');
+      return false;
+    }
+    analyticsOptions.sampled = true;
+    if (typeof config.options.sampling === 'number') {
+      analyticsOptions.sampled = Math.random() < parseFloat(config.options.sampling);
+    }
+
+    analyticsOptions.pbuid = config.options.pbuid
+    analyticsOptions.adid = config.options.adid
+    analyticsOptions.server = ANALYTICS_SERVER;
+    return true;
+  },
+  sendEventMessage(endPoint, data) {
+    logInfo(`AJAX: ${endPoint}: ` + JSON.stringify(data));
+
+    ajax(`${analyticsOptions.server}/${endPoint}`, null, JSON.stringify(data), {
+      contentType: 'application/json',
+      withCredentials: true
+    });
+  },
+  createCommonMessage(auctionId) {
+    return {
+      version: ANALYTICS_VERSION,
+      auctionId: auctionId,
+      referrer: window.location.href,
+      sampling: analyticsOptions.options.sampling,
+      prebid: '$prebid.version$',
+      adid: analyticsOptions.adid,
+      pbuid: analyticsOptions.pbuid,
+      adUnits: {},
+    };
+  },
+  serializeBidResponse(bid, status) {
+    const result = {
+      prebidWon: (status === BIDDER_STATUS.BID_WON),
+      isTimeout: (status === BIDDER_STATUS.TIMEOUT),
+      status: status,
+    };
+    if (status === BIDDER_STATUS.BID || status === BIDDER_STATUS.BID_WON) {
+      Object.assign(result, {
+        time: bid.timeToRespond,
+        cpm: bid.cpm,
+        currency: bid.currency,
+      });
+    }
+    return result;
+  },
+  addBidResponseToMessage(message, bid, status) {
+    const adUnitCode = parseAdUnitCode(bid);
+    message.adUnits[adUnitCode] = message.adUnits[adUnitCode] || {};
+    const bidder = parseBidderCode(bid);
+    const bidResponse = this.serializeBidResponse(bid, status);
+    message.adUnits[adUnitCode][bidder] = bidResponse;
+  },
+  createBidMessage(auctionEndArgs, winningBids, timeoutBids) {
+    const {auctionId, timestamp, auctionEnd, adUnitCodes, bidsReceived, noBids} = auctionEndArgs;
+    const message = this.createCommonMessage(auctionId);
+
+    message.auctionElapsed = (auctionEnd - timestamp);
+
+    adUnitCodes.forEach((adUnitCode) => {
+      message.adUnits[adUnitCode] = {};
+    });
+
+    // In this situation, the bid exists in both noBids and bids arrays.
+    noBids.forEach(bid => this.addBidResponseToMessage(message, bid, BIDDER_STATUS.NO_BID));
+
+    // This array may contain some timeout bids (responses come back after auction timeout)
+    bidsReceived.forEach(bid => this.addBidResponseToMessage(message, bid, BIDDER_STATUS.BID));
+
+    // We handle timeout after bids since it's possible that a bid has a response, but the response comes back
+    // after auction end. In this case, the bid exists in both bidsReceived and timeoutBids arrays.
+    timeoutBids.forEach(bid => this.addBidResponseToMessage(message, bid, BIDDER_STATUS.TIMEOUT));
+
+    // mark the winning bids with prebidWon = true
+    winningBids.forEach(bid => {
+      const adUnitCode = parseAdUnitCode(bid);
+      const bidder = parseBidderCode(bid);
+      message.adUnits[adUnitCode][bidder].prebidWon = true;
+    });
+    return message;
+  },
+  createImpressionMessage(bid) {
+    const message = this.createCommonMessage(bid.auctionId);
+    this.addBidResponseToMessage(message, bid, BIDDER_STATUS.BID_WON);
+    return message;
+  },
+  getCachedAuction(auctionId) {
+    this.cachedAuctions[auctionId] = this.cachedAuctions[auctionId] || {
+      timeoutBids: [],
+    };
+    return this.cachedAuctions[auctionId];
+  },
+  handleAuctionEnd(auctionEndArgs) {
+    const cachedAuction = this.getCachedAuction(auctionEndArgs.auctionId);
+    const highestCpmBids = pbjs.getHighestCpmBids();
+    this.sendEventMessage('bid',
+      this.createBidMessage(auctionEndArgs, highestCpmBids, cachedAuction.timeoutBids)
+    );
+  },
+  handleBidTimeout(timeoutBids) {
+    timeoutBids.forEach((bid) => {
+      const cachedAuction = this.getCachedAuction(bid.auctionId);
+      cachedAuction.timeoutBids.push(bid);
+    });
+  },
+  handleBidWon(bidWonArgs) {
+    this.sendEventMessage('imp', this.createImpressionMessage(bidWonArgs));
+  },
+  track({eventType, args}) {
+    if (analyticsOptions.sampled) {
+      switch (eventType) {
+        case BID_WON:
+          this.handleBidWon(args);
+          break;
+        case BID_TIMEOUT:
+          this.handleBidTimeout(args);
+          break;
+        case AUCTION_END:
+          this.handleAuctionEnd(args);
+          break;
+      }
+    }
+  },
+  getAnalyticsOptions() {
+    return analyticsOptions;
+  },
+});
+
+// save the base class function
+ucfunnelAnalyticsAdapter.originEnableAnalytics = ucfunnelAnalyticsAdapter.enableAnalytics;
+
+// override enableAnalytics so we can get access to the config passed in from the page
+ucfunnelAnalyticsAdapter.enableAnalytics = function (config) {
+  if (this.initConfig(config)) {
+    ucfunnelAnalyticsAdapter.originEnableAnalytics(config); // call the base class function
+  }
+};
+
+adapterManager.registerAnalyticsAdapter({
+  adapter: ucfunnelAnalyticsAdapter,
+  code: 'ucfunnelAnalytics'
+});

modules/ucfunnelAnalyticsAdapter.md

@@ -0,0 +1,23 @@
+# Overview
+
+```
+Module Name: ucfunnel Analytics Adapter
+Module Type: Analytics Adapter
+Maintainer: [email protected]
+```
+
+# Description
+
+Analytics adapter for ucfunnel
+
+# Test Parameters
+
+```
+{
+  provider: 'ucfunnelAnalytics',
+  options: {
+    pbuid: "PBUID_FROM_UCFUNNEL"
+    adid: "BIDDING_ADID_FROM_UCFUNNEL"
+  }
+}
+```

modules/ucfunnelBidAdapter.js

@@ -64,7 +64,7 @@ export const spec = {
     let bid = {
       requestId: bidRequest.bidId,
       cpm: ad.cpm || 0,
-      creativeId: ad.ad_id,
+      creativeId: ad.ad_id || bidRequest.params.adid,
       dealId: ad.deal || null,
       currency: 'USD',
       netRevenue: true,
@@ -108,10 +108,11 @@ export const spec = {
         break;
       case BANNER:
       default:
+        var size = parseSizes(bidRequest);
         Object.assign(bid, {
-          width: ad.width,
-          height: ad.height,
-          ad: ad.adm
+          width: ad.width || size[0],
+          height: ad.height || size[1],
+          ad: ad.adm || ''
         });
     }