OTT-806 :: Adpod Support (CTV)

analytics/pubmatic/logger.go

@@ -12,7 +12,6 @@ import (
 	"github.com/prebid/openrtb/v19/openrtb3"
 	"github.com/prebid/prebid-server/analytics"
 	"github.com/prebid/prebid-server/hooks/hookexecution"
-	"github.com/prebid/prebid-server/modules/pubmatic/openwrap"
 	"github.com/prebid/prebid-server/modules/pubmatic/openwrap/customdimensions"
 	"github.com/prebid/prebid-server/modules/pubmatic/openwrap/models"
 	"github.com/prebid/prebid-server/modules/pubmatic/openwrap/utils"
@@ -86,20 +85,16 @@ func GetLogAuctionObjectAsURL(ao analytics.AuctionObject, rCtx *models.RequestCt
 
 	// parent bidder could in one of the above and we need them by prebid's bidderCode and not seat(could be alias)
 	slots := make([]SlotRecord, 0)
-	for _, imp := range ao.RequestWrapper.Imp {
-		impCtx, ok := rCtx.ImpBidCtx[imp.ID]
-		if !ok {
-			continue
-		}
+	for impId, impCtx := range rCtx.ImpBidCtx {
 		reward := 0
 		if impCtx.IsRewardInventory != nil {
 			reward = int(*impCtx.IsRewardInventory)
 		}
 
 		// to keep existing response intact
 		partnerData := make([]PartnerRecord, 0)
-		if ipr[imp.ID] != nil {
-			partnerData = ipr[imp.ID]
+		if ipr[impId] != nil {
+			partnerData = ipr[impId]
 		}
 
 		slots = append(slots, SlotRecord{
@@ -109,7 +104,7 @@ func GetLogAuctionObjectAsURL(ao analytics.AuctionObject, rCtx *models.RequestCt
 			Adunit:            impCtx.AdUnitName,
 			PartnerData:       partnerData,
 			RewardedInventory: int(reward),
-			// AdPodSlot:         getAdPodSlot(imp, responseMap.AdPodBidsExt),
+			AdPodSlot:         getAdPodSlot(impCtx.AdpodConfig),
 		})
 	}
 
@@ -191,6 +186,23 @@ func GetRequestCtx(hookExecutionOutcome []hookexecution.StageOutcome) *models.Re
 	return nil
 }
 
+func getAdPodSlot(adPodConfig *models.AdPod) *AdPodSlot {
+	if adPodConfig == nil {
+		return nil
+	}
+
+	adPodSlot := AdPodSlot{
+		MinAds:                      adPodConfig.MinAds,
+		MaxAds:                      adPodConfig.MaxAds,
+		MinDuration:                 adPodConfig.MinDuration,
+		MaxDuration:                 adPodConfig.MaxDuration,
+		AdvertiserExclusionPercent:  *adPodConfig.AdvertiserExclusionPercent,
+		IABCategoryExclusionPercent: *adPodConfig.IABCategoryExclusionPercent,
+	}
+
+	return &adPodSlot
+}
+
 func convertNonBidToBidWrapper(nonBid *openrtb_ext.NonBid) (bid bidWrapper) {
 	bid.Bid = &openrtb2.Bid{
 		Price:   nonBid.Ext.Prebid.Bid.Price,
@@ -228,7 +240,7 @@ func convertNonBidToBidWrapper(nonBid *openrtb_ext.NonBid) (bid bidWrapper) {
 	}
 	// the 'nbr' field will be lost due to json.Marshal hence do not set it inside bid.Ext
 	// set the 'nbr' code at bid level, while forming partner-records we give high priority to bid.nbr over bid.ext.nbr
-	bid.Nbr = openwrap.GetNonBidStatusCodePtr(openrtb3.NonBidStatusCode(nonBid.StatusCode))
+	bid.Nbr = models.GetNonBidStatusCodePtr(openrtb3.NonBidStatusCode(nonBid.StatusCode))
 	return bid
 }
 
@@ -301,7 +313,12 @@ func getPartnerRecordsByImp(ao analytics.AuctionObject, rCtx *models.RequestCtx)
 		}
 
 		for _, bid := range bids {
-			impCtx, ok := rCtx.ImpBidCtx[bid.ImpID]
+			var sequence int
+			impId := bid.ImpID
+			if rCtx.IsCTVRequest {
+				impId, sequence = models.GetImpressionID(impId)
+			}
+			impCtx, ok := rCtx.ImpBidCtx[impId]
 			if !ok {
 				continue
 			}
@@ -355,7 +372,7 @@ func getPartnerRecordsByImp(ao analytics.AuctionObject, rCtx *models.RequestCtx)
 			kgpv = tracker.Tracker.PartnerInfo.KGPV
 			kgpsv = tracker.Tracker.LoggerData.KGPSV
 			if kgpv == "" || kgpsv == "" {
-				kgpv, kgpsv = models.GetKGPSV(*bid.Bid, bidderMeta, adFormat, impCtx.TagID, impCtx.Div, rCtx.Source)
+				kgpv, kgpsv = models.GetKGPSV(*bid.Bid, &bidExt, bidderMeta, adFormat, impCtx.TagID, impCtx.Div, rCtx.Source)
 			}
 
 			price := bid.Price
@@ -368,7 +385,7 @@ func getPartnerRecordsByImp(ao analytics.AuctionObject, rCtx *models.RequestCtx)
 			}
 
 			if seat == models.BidderPubMatic {
-				pmMkt[bid.ImpID] = pubmaticMarketplaceMeta{
+				pmMkt[impId] = pubmaticMarketplaceMeta{
 					PubmaticKGP:   kgp,
 					PubmaticKGPV:  kgpv,
 					PubmaticKGPSV: kgpsv,
@@ -427,7 +444,7 @@ func getPartnerRecordsByImp(ao analytics.AuctionObject, rCtx *models.RequestCtx)
 			}
 
 			// WinningBids contains map of imp.id against bid.id+::+uuid
-			if b, ok := rCtx.WinningBids[bid.ImpID]; ok && b.ID == bidIDForLookup {
+			if rCtx.WinningBids.IsWinningBid(impId, bidIDForLookup) {
 				pr.WinningBidStaus = 1
 			}
 
@@ -466,7 +483,19 @@ func getPartnerRecordsByImp(ao analytics.AuctionObject, rCtx *models.RequestCtx)
 				}
 			}
 
-			ipr[bid.ImpID] = append(ipr[bid.ImpID], pr)
+			// Adpod parameters
+			if impCtx.AdpodConfig != nil {
+				pr.AdPodSequenceNumber = &sequence
+
+				if len(bid.Cat) > 0 {
+					pr.Cat = append(pr.Cat, bid.Cat...)
+				}
+
+				aprc := int(impCtx.BidIDToAPRC[bidIDForLookup])
+				pr.NoBidReason = &aprc
+			}
+
+			ipr[impId] = append(ipr[impId], pr)
 		}
 	}