Downmerge Release 08th August 2024

modules/pubmatic/openwrap/applovinmax.go

@@ -215,11 +215,15 @@ func setIfKeysExists(source []byte, target []byte, keys ...string) []byte {
 
 func updateRequestWrapper(signalExt json.RawMessage, maxRequest *openrtb2.BidRequest) {
 	clientConfigFlag, err := jsonparser.GetInt(signalExt, "wrapper", "clientconfig")
-	if err != nil || clientConfigFlag != 1 {
-		return
+	if err != nil {
+		clientConfigFlag = 0
+	}
+
+	if len(maxRequest.Ext) == 0 {
+		maxRequest.Ext = []byte(`{}`)
 	}
 
-	if maxReqExt, err := jsonparser.Set(maxRequest.Ext, []byte(`1`), "prebid", "bidderparams", "pubmatic", "wrapper", "clientconfig"); err == nil {
+	if maxReqExt, err := jsonparser.Set(maxRequest.Ext, []byte(strconv.FormatInt(clientConfigFlag, 10)), "prebid", "bidderparams", "pubmatic", "wrapper", "clientconfig"); err == nil {
 		maxRequest.Ext = maxReqExt
 	}
 }

modules/pubmatic/openwrap/metrics/config/multimetrics.go

@@ -320,6 +320,13 @@ func (me *MultiMetricsEngine) RecordReqImpsWithContentCount(publisher, contentTy
 	}
 }
 
+// RecordPrebidAuctionBidResponse across all engines
+func (me *MultiMetricsEngine) RecordPrebidAuctionBidResponse(publisher string, partnerName string, bidderCode string, adapterCode string) {
+	for _, thisME := range *me {
+		thisME.RecordPrebidAuctionBidResponse(publisher, partnerName, bidderCode, adapterCode)
+	}
+}
+
 // RecordPBSAuctionRequestsStats across all engines
 func (me *MultiMetricsEngine) RecordPBSAuctionRequestsStats() {
 	for _, thisME := range *me {

modules/pubmatic/openwrap/metrics/metrics.go

@@ -28,6 +28,7 @@ type MetricsEngine interface {
 
 	// not-captured in openwrap module, dont provide enough insights
 	RecordPBSAuctionRequestsStats()
+	RecordPrebidAuctionBidResponse(publisher string, partnerName string, bidderCode string, adapterCode string)
 	RecordInvalidCreativeStats(publisher, partner string)
 
 	// not implemented in openwrap module yet

modules/pubmatic/openwrap/metrics/prometheus/prometheus.go

@@ -71,6 +71,7 @@ type Metrics struct {
 	ampVideoResponses     *prometheus.CounterVec
 	analyticsThrottle     *prometheus.CounterVec
 	signalStatus          *prometheus.CounterVec
+	pbsAuctionResponse    *prometheus.CounterVec
 
 	// VAST Unwrap
 	requests       *prometheus.CounterVec
@@ -112,6 +113,8 @@ const (
 	signalTypeLabel    = "signal_status"
 	successLabel       = "success"
 	adpodImpCountLabel = "adpod_imp_count"
+	bidderCodeLabel    = "bidder_code"
+	adapterCodeLabel   = "adapter_code"
 )
 
 var standardTimeBuckets = []float64{0.1, 0.3, 0.75, 1}
@@ -163,6 +166,12 @@ func newMetrics(cfg *config.PrometheusMetrics, promRegistry *prometheus.Registry
 		[]string{pubIDLabel, partnerLabel, adFormatLabel},
 	)
 
+	metrics.pbsAuctionResponse = newCounter(cfg, promRegistry,
+		"pbs_auction_response",
+		"Count of errors while injecting trackers at publisher, partner level.",
+		[]string{pubIDLabel, partnerLabel, bidderCodeLabel, adapterCodeLabel},
+	)
+
 	metrics.pubPartnerResponseTimeSecs = newHistogramVec(cfg, promRegistry,
 		"partner_response_time",
 		"Time taken by each partner to respond in seconds labeled by publisher.",
@@ -401,6 +410,15 @@ func (m *Metrics) RecordOpenWrapServerPanicStats(hostName, method string) {
 	}).Inc()
 }
 
+func (m *Metrics) RecordPrebidAuctionBidResponse(publisher string, partnerName string, bidderCode string, adapterCode string) {
+	m.pbsAuctionResponse.With(prometheus.Labels{
+		pubIDLabel:       publisher,
+		partnerLabel:     partnerName,
+		bidderCodeLabel:  bidderCode,
+		adapterCodeLabel: adapterCode,
+	}).Inc()
+}
+
 func (m *Metrics) RecordPublisherPartnerNoCookieStats(publisherID, partner string) {
 	m.pubPartnerNoCookie.With(prometheus.Labels{
 		pubIDLabel:   publisherID,

modules/pubmatic/openwrap/metrics/stats/tcp_stats.go

@@ -350,3 +350,5 @@ func (st *StatsTCP) RecordAdruleEnabled(pubId, profId string)
 func (st *StatsTCP) RecordAdruleValidationFailure(pubId, profId string)                       {}
 func (st *StatsTCP) RecordSignalDataStatus(pubid, profileid, signalType string)               {}
 func (st *StatsTCP) RecordPrebidCacheRequestTime(success bool, length time.Duration)          {}
+func (st *StatsTCP) RecordPrebidAuctionBidResponse(publisher string, partnerName string, bidderCode string, adapterCode string) {
+}