Allow rubicon adapter to register individual responses from fastlane

src/adapters/rubicon.js

@@ -63,11 +63,11 @@ var RubiconAdapter = function RubiconAdapter() {
  /**
  * Create an error bid
  * @param {String} placement - the adunit path
- * @param {Object} response - the (error) response from fastlane
+ * @param {Object} slot - the (error) response from fastlane
  * @return {Bid} a bid, for prebid
  */
- function _errorBid(response, ads) {
- var bidResponse = bidfactory.createBid(2, response.bid);
+ function _errorBid(slot, ads) {
+ var bidResponse = bidfactory.createBid(2, slot.bid);
  bidResponse.bidderCode = RUBICON_BIDDER_CODE;
 
  // use the raw ads as the 'error'
@@ -107,70 +107,68 @@ var RubiconAdapter = function RubiconAdapter() {
  }
 
  /**
- * Create (successful) bids for a unit,
+ * Create (successful) bids for a slot,
  * based on the given response
- * @param {String} placement placement code/unit path
- * @param {Object} response the response from rubicon
- * @return {Bid} a bid objectj
+ * @param {Object} slot the slot from rubicon
+ * @param {Object} ads the raw responses
  */
- function _makeBids(response, ads) {
+ function _makeBids(slot, ads) {
 
- // if there are multiple ads, sort by CPM
- ads = ads.sort(_adCpmSort);
-
- var bidResponses = [];
-
- ads.forEach(function(ad) {
-
- var bidResponse,
- size = ad.dimensions;
-
- if (!size) {
- // this really shouldn't happen
- utils.logError('no dimensions given', RUBICON_BIDDER_CODE, ad);
- bidResponse = _errorBid(response, ads);
- } else {
- bidResponse = bidfactory.createBid(1, response.bid);
+ if (!ads || ads.length === 0) {
 
- bidResponse.bidderCode = RUBICON_BIDDER_CODE;
- bidResponse.cpm = ad.cpm;
+ bidmanager.addBidResponse(
+ slot.getElementId(),
+ _errorBid(slot, ads)
+ );
 
- // the element id is what the iframe will use to render
- // itself using the rubicontag.renderCreative API
- bidResponse.ad = _creative(response.getElementId(), size);
- bidResponse.width = size[0];
- bidResponse.height = size[1];
+ } else {
 
- // DealId
- if (ad.deal) {
- bidResponse.dealId = ad.deal;
- }
- }
+ // if there are multiple ads, sort by CPM
+ ads = ads.sort(_adCpmSort);
 
- bidResponses.push(bidResponse);
+ ads.forEach(function (ad) {
+ _makeBid(slot, ad);
+ });
 
- });
+ }
 
- return bidResponses;
  }
 
  /**
- * Add success/error bids based
- * on the response from rubicon
- * @param {Object} response -- AJAX response from fastlane
+ * Create (successful) bid for a slot size,
+ * based on the given response
+ * @param {Object} slot the slot from rubicon
+ * @param {Object} ad a raw response
  */
- function _addBids(response, ads) {
- // get the bid for the placement code
- var bids;
- if (!ads || ads.length === 0) {
- bids = [ _errorBid(response, ads) ];
+ function _makeBid(slot, ad) {
+
+ var bidResponse,
+ size = ad.dimensions;
+
+ if (!size) {
+ // this really shouldn't happen
+ utils.logError('no dimensions given', RUBICON_BIDDER_CODE, ad);
+ bidResponse = _errorBid(slot, ad);
  } else {
- bids = _makeBids(response, ads);
+ bidResponse = bidfactory.createBid(1, slot.bid);
+
+ bidResponse.bidderCode = RUBICON_BIDDER_CODE;
+ bidResponse.cpm = ad.cpm;
+
+ // the element id is what the iframe will use to render
+ // itself using the rubicontag.renderCreative API
+ bidResponse.ad = _creative(slot.getElementId(), size);
+ bidResponse.width = size[0];
+ bidResponse.height = size[1];
+
+ // DealId
+ if (ad.deal) {
+ bidResponse.dealId = ad.deal;
+ }
  }
 
- bids.forEach(function(bid) {
- bidmanager.addBidResponse(response.getElementId(), bid);
- });
+ bidmanager.addBidResponse(slot.getElementId(), bidResponse);
+
  }
 
  /**
@@ -286,10 +284,32 @@ var RubiconAdapter = function RubiconAdapter() {
  utils.logMessage('Rubicon Project bidding complete: ' + ((new Date).getTime() - _bidStart));
 
  utils._each(slots, function (slot) {
- _addBids(slot, slot.getRawResponses());
+ _makeBids(slot, slot.getRawResponses());
  });
  }
 
+
+ var _cb;
+ var _eventAvailable;
+ /**
+ * Used to attach (and switch out) callback for listening to rubicon bid events
+ * Rubicon
+ * @param {Function} cb Callback to register with event handler
+ * @return {Boolean} whether we can handle the event or not
+ */
+ function _handleBidEvent(cb) {
+ _cb = cb;
+ if(_eventAvailable) {
+ return true;
+ }
+ if (_eventAvailable === false) {
+ return false;
+ }
+ return _eventAvailable = window.rubicontag.addEventListener('FL_TIER_MAPPED', params => {
+ _cb(params);
+ })
+ }
+
  /**
  * Request the specified bids from
  * Rubicon
@@ -325,9 +345,23 @@ var RubiconAdapter = function RubiconAdapter() {
  slots: slots,
  timeout: bidderRequest.timeout - (Date.now() - bidderRequest.auctionStart - TIMEOUT_BUFFER)
  };
- var callback = function () {
- _bidsReady(slots);
- };
+ var callback = function noop() {};
+
+ if(!_handleBidEvent(params => {
+
+ var slot = slots.find(slot => slot.getElementId() === params.elementId);
+ var ad = slot.getRawResponseBySizeId(params.sizeId);
+ var time = ((new Date).getTime() - _bidStart);
+
+ utils.logMessage(`Rubicon Project bid back for "${params.elementId}" size ${params.sizeId} at: ${time}`);
+
+ _makeBid(slot, ad);
+
+ })) {
+ callback = () => {
+ _bidsReady(slots);
+ }
+ }
 
  window.rubicontag.setIntegration('$$PREBID_GLOBAL$$');
  window.rubicontag.run(callback, parameters);