Add Native-Specific Metrics to Prebid Server

endpoints/openrtb2/amp_auction.go

@@ -91,6 +91,10 @@ func (deps *endpointDeps) AmpAuction(w http.ResponseWriter, r *http.Request, _ h
 	labels := pbsmetrics.Labels{
 		Source:        pbsmetrics.DemandUnknown,
 		RType:         pbsmetrics.ReqTypeAMP,
+		IsImpBanner:   false,
+		IsImpVideo:    false,
+		IsImpAudio:    false,
+		IsImpNative:   false,
 		PubID:         "",
 		Browser:       pbsmetrics.BrowserOther,
 		CookieFlag:    pbsmetrics.CookieFlagUnknown,

endpoints/openrtb2/auction.go

@@ -89,6 +89,10 @@ func (deps *endpointDeps) Auction(w http.ResponseWriter, r *http.Request, _ http
 	labels := pbsmetrics.Labels{
 		Source:        pbsmetrics.DemandUnknown,
 		RType:         pbsmetrics.ReqTypeORTB2Web,
+		IsImpBanner:   false,
+		IsImpVideo:    false,
+		IsImpAudio:    false,
+		IsImpNative:   false,
 		PubID:         "",
 		Browser:       pbsmetrics.BrowserOther,
 		CookieFlag:    pbsmetrics.CookieFlagUnknown,

endpoints/openrtb2/video_auction.go

@@ -74,6 +74,10 @@ func (deps *endpointDeps) VideoAuctionEndpoint(w http.ResponseWriter, r *http.Re
 	labels := pbsmetrics.Labels{
 		Source:        pbsmetrics.DemandUnknown,
 		RType:         pbsmetrics.ReqTypeVideo,
+		IsImpBanner:   false,
+		IsImpVideo:    false,
+		IsImpAudio:    false,
+		IsImpNative:   false,
 		PubID:         "",
 		Browser:       pbsmetrics.BrowserOther,
 		CookieFlag:    pbsmetrics.CookieFlagUnknown,

exchange/exchange.go

@@ -85,6 +85,21 @@ func (e *exchange) HoldAuction(ctx context.Context, bidRequest *openrtb.BidReque
 		}
 	}
 
+	for _, impInRequest := range bidRequest.Imp {
+		if impInRequest.Banner != nil {
+			labels.IsImpBanner = true
+		}
+		if impInRequest.Video != nil {
+			labels.IsImpVideo = true
+		}
+		if impInRequest.Audio != nil {
+			labels.IsImpAudio = true
+		}
+		if impInRequest.Native != nil {
+			labels.IsImpNative = true
+		}
+	}
+
 	// Slice of BidRequests, each a copy of the original cleaned to only contain bidder data for the named bidder
 	blabels := make(map[openrtb_ext.BidderName]*pbsmetrics.AdapterLabels)
 	cleanRequests, aliases, errs := cleanOpenRTBRequests(ctx, bidRequest, usersyncs, blabels, labels, e.gDPR, e.UsersyncIfAmbiguous)

pbsmetrics/config/metrics_test.go

@@ -46,6 +46,10 @@ func TestMultiMetricsEngine(t *testing.T) {
 	labels := pbsmetrics.Labels{
 		Source:        pbsmetrics.DemandWeb,
 		RType:         pbsmetrics.ReqTypeORTB2Web,
+		IsImpBanner:   true,
+		IsImpVideo:    false,
+		IsImpAudio:    false,
+		IsImpNative:   false,
 		PubID:         "test1",
 		Browser:       pbsmetrics.BrowserSafari,
 		CookieFlag:    pbsmetrics.CookieFlagYes,
@@ -54,6 +58,10 @@ func TestMultiMetricsEngine(t *testing.T) {
 	apnLabels := pbsmetrics.AdapterLabels{
 		Source:      pbsmetrics.DemandWeb,
 		RType:       pbsmetrics.ReqTypeORTB2Web,
+		IsImpBanner: true,
+		IsImpVideo:  false,
+		IsImpAudio:  false,
+		IsImpNative: false,
 		Adapter:     openrtb_ext.BidderAppnexus,
 		PubID:       "test1",
 		Browser:     pbsmetrics.BrowserSafari,
@@ -63,6 +71,10 @@ func TestMultiMetricsEngine(t *testing.T) {
 	pubLabels := pbsmetrics.AdapterLabels{
 		Source:      pbsmetrics.DemandWeb,
 		RType:       pbsmetrics.ReqTypeORTB2Web,
+		IsImpBanner: true,
+		IsImpVideo:  false,
+		IsImpAudio:  false,
+		IsImpNative: false,
 		Adapter:     openrtb_ext.BidderPubmatic,
 		PubID:       "test1",
 		Browser:     pbsmetrics.BrowserSafari,
@@ -79,6 +91,7 @@ func TestMultiMetricsEngine(t *testing.T) {
 		metricsEngine.RecordAdapterBidReceived(pubLabels, openrtb_ext.BidTypeBanner, true)
 		metricsEngine.RecordAdapterTime(pubLabels, time.Millisecond*20)
 	}
+	//Make the metrics engine, instantiated here with goEngine, fill its RequestStatuses[RequestType][pbsmetrics.RequestStatusXX] with the new boolean values added to pbsmetrics.Labels
 	VerifyMetrics(t, "RequestStatuses.OpenRTB2.OK", goEngine.RequestStatuses[pbsmetrics.ReqTypeORTB2Web][pbsmetrics.RequestStatusOK].Count(), 5)
 	VerifyMetrics(t, "RequestStatuses.Legacy.OK", goEngine.RequestStatuses[pbsmetrics.ReqTypeLegacy][pbsmetrics.RequestStatusOK].Count(), 0)
 	VerifyMetrics(t, "RequestStatuses.AMP.OK", goEngine.RequestStatuses[pbsmetrics.ReqTypeAMP][pbsmetrics.RequestStatusOK].Count(), 0)
@@ -87,6 +100,12 @@ func TestMultiMetricsEngine(t *testing.T) {
 	VerifyMetrics(t, "RequestStatuses.Video.BadInput", goEngine.RequestStatuses[pbsmetrics.ReqTypeVideo][pbsmetrics.RequestStatusBadInput].Count(), 0)
 	VerifyMetrics(t, "RequestStatuses.OpenRTB2.Error", goEngine.RequestStatuses[pbsmetrics.ReqTypeORTB2Web][pbsmetrics.RequestStatusErr].Count(), 0)
 	VerifyMetrics(t, "RequestStatuses.OpenRTB2.BadInput", goEngine.RequestStatuses[pbsmetrics.ReqTypeORTB2Web][pbsmetrics.RequestStatusBadInput].Count(), 0)
+
+	VerifyMetrics(t, "ImpTypeBanner", goEngine.ImpTypeBanner.Count(), 3)
+	VerifyMetrics(t, "ImpTypeVideo", goEngine.ImpTypeVideo.Count(), 0)
+	VerifyMetrics(t, "ImpTypeAudio", goEngine.ImpTypeAudio.Count(), 0)
+	VerifyMetrics(t, "ImpTypeNative", goEngine.ImpTypeNative.Count(), 0)
+
 	VerifyMetrics(t, "Request", goEngine.RequestStatuses[pbsmetrics.ReqTypeORTB2Web][pbsmetrics.RequestStatusOK].Count(), 5)
 	VerifyMetrics(t, "ImpMeter", goEngine.ImpMeter.Count(), 10)
 	VerifyMetrics(t, "NoCookieMeter", goEngine.NoCookieMeter.Count(), 0)

pbsmetrics/go_metrics.go

@@ -37,6 +37,12 @@ type Metrics struct {
 	userSyncSet           map[openrtb_ext.BidderName]metrics.Meter
 	userSyncGDPRPrevent   map[openrtb_ext.BidderName]metrics.Meter
 
+	// Media types found in the "imp" JSON object
+	ImpTypeBanner metrics.Meter
+	ImpTypeVideo  metrics.Meter
+	ImpTypeAudio  metrics.Meter
+	ImpTypeNative metrics.Meter
+
 	AdapterMetrics map[openrtb_ext.BidderName]*AdapterMetrics
 	// Don't export accountMetrics because we need helper functions here to insure its properly populated dynamically
 	accountMetrics        map[string]*accountMetrics
@@ -107,6 +113,11 @@ func NewBlankMetrics(registry metrics.Registry, exchanges []openrtb_ext.BidderNa
 		userSyncSet:                make(map[openrtb_ext.BidderName]metrics.Meter),
 		userSyncGDPRPrevent:        make(map[openrtb_ext.BidderName]metrics.Meter),
 
+		ImpTypeBanner: blankMeter,
+		ImpTypeVideo:  blankMeter,
+		ImpTypeAudio:  blankMeter,
+		ImpTypeNative: blankMeter,
+
 		AdapterMetrics: make(map[openrtb_ext.BidderName]*AdapterMetrics, len(exchanges)),
 		accountMetrics: make(map[string]*accountMetrics),
 
@@ -137,6 +148,13 @@ func NewMetrics(registry metrics.Registry, exchanges []openrtb_ext.BidderName) *
 	newMetrics.ConnectionAcceptErrorMeter = metrics.GetOrRegisterMeter("connection_accept_errors", registry)
 	newMetrics.ConnectionCloseErrorMeter = metrics.GetOrRegisterMeter("connection_close_errors", registry)
 	newMetrics.ImpMeter = metrics.GetOrRegisterMeter("imps_requested", registry)
+
+	// Find out how to GetOrRegisterMeter
+	newMetrics.ImpTypeBanner = metrics.GetOrRegisterMeter("imp_banner", registry)
+	newMetrics.ImpTypeVideo = metrics.GetOrRegisterMeter("imp_video", registry)
+	newMetrics.ImpTypeAudio = metrics.GetOrRegisterMeter("imp_audio", registry)
+	newMetrics.ImpTypeNative = metrics.GetOrRegisterMeter("imp_native", registry)
+
 	newMetrics.SafariRequestMeter = metrics.GetOrRegisterMeter("safari_requests", registry)
 	newMetrics.NoCookieMeter = metrics.GetOrRegisterMeter("no_cookie_requests", registry)
 	newMetrics.AppRequestMeter = metrics.GetOrRegisterMeter("app_requests", registry)

pbsmetrics/metrics.go

@@ -10,6 +10,10 @@ import (
 type Labels struct {
 	Source        DemandSource
 	RType         RequestType
+	IsImpBanner   bool
+	IsImpVideo    bool
+	IsImpAudio    bool
+	IsImpNative   bool
 	PubID         string // exchange specific ID, so we cannot compile in values
 	Browser       Browser
 	CookieFlag    CookieFlag
@@ -20,6 +24,10 @@ type Labels struct {
 type AdapterLabels struct {
 	Source        DemandSource
 	RType         RequestType
+	IsImpBanner   bool
+	IsImpVideo    bool
+	IsImpAudio    bool
+	IsImpNative   bool
 	Adapter       openrtb_ext.BidderName
 	PubID         string // exchange specific ID, so we cannot compile in values
 	Browser       Browser
@@ -33,6 +41,9 @@ type AdapterLabels struct {
 // DemandSource : Demand source enumeration
 type DemandSource string
 
+// ImpMediaType : Media type described in the "imp" JSON object
+type ImpMediaType string
+
 // RequestType : Request type enumeration
 type RequestType string
 
@@ -78,6 +89,14 @@ const (
 	ReqTypeVideo    RequestType = "video"
 )
 
+// The media types described in the "imp json objects
+const (
+	ImpTypeBanner ImpMediaType = "banner"
+	ImpTypeVideo  ImpMediaType = "video"
+	ImpTypeAudio  ImpMediaType = "audio"
+	ImpTypeNative ImpMediaType = "native"
+)
+
 func RequestTypes() []RequestType {
 	return []RequestType{
 		ReqTypeLegacy,