New Adapter: Concert

adapters/concert/concert.go

@@ -0,0 +1,164 @@
+package concert
+
+import (
+	"encoding/json"
+	"fmt"
+	"github.com/prebid/openrtb/v20/openrtb2"
+	"github.com/prebid/prebid-server/v2/adapters"
+	"github.com/prebid/prebid-server/v2/config"
+	"github.com/prebid/prebid-server/v2/errortypes"
+	"github.com/prebid/prebid-server/v2/openrtb_ext"
+	"net/http"
+)
+
+type adapter struct {
+	endpoint string
+}
+
+const adapterVersion = "1.0.0"
+
+// Builder builds a new instance of the Concert adapter for the given bidder with the given config.
+func Builder(bidderName openrtb_ext.BidderName, config config.Adapter, server config.Server) (adapters.Bidder, error) {
+	bidder := &adapter{
+		endpoint: config.Endpoint,
+	}
+	return bidder, nil
+}
+
+func (a *adapter) MakeRequests(request *openrtb2.BidRequest, requestInfo *adapters.ExtraRequestInfo) ([]*adapters.RequestData, []error) {
+	bidderImpExt, err := getBidderExt(request.Imp[0])
+	if err != nil {
+		return nil, []error{fmt.Errorf("get bidder ext: %v", err)}
+	}
+
+	requestJSON, err := json.Marshal(request)
+	if err != nil {
+		return nil, []error{err}
+	}
+
+	var requestMap map[string]interface{}
+	err = json.Unmarshal(requestJSON, &requestMap)
+	if err != nil {
+		return nil, []error{err}
+	}
+
+	if requestMap["ext"] == nil {
+		requestMap["ext"] = make(map[string]interface{})
+	}
+	requestMap["ext"].(map[string]interface{})["adapterVersion"] = adapterVersion
+	requestMap["ext"].(map[string]interface{})["partnerId"] = bidderImpExt.PartnerId
+
+	requestJSON, err = json.Marshal(requestMap)
+	if err != nil {
+		return nil, []error{err}
+	}
+
+	requestData := &adapters.RequestData{
+		Method: "POST",
+		Uri:    a.endpoint,
+		Body:   requestJSON,
+		Headers: http.Header{
+			"Content-Type":  []string{"application/json"},
+			"Authorization": []string{"concert-prebid-server"},
+		},
+	}
+
+	return []*adapters.RequestData{requestData}, nil
+}
+
+func (a *adapter) MakeBids(request *openrtb2.BidRequest, requestData *adapters.RequestData, responseData *adapters.ResponseData) (*adapters.BidderResponse, []error) {
+	if responseData.StatusCode == http.StatusNoContent {
+		return nil, nil
+	}
+
+	if responseData.StatusCode == http.StatusBadRequest {
+		err := &errortypes.BadInput{
+			Message: "Unexpected status code: 400. Bad request from publisher. Run with request.debug = 1 for more info.",
+		}
+		return nil, []error{err}
+	}
+
+	if responseData.StatusCode != http.StatusOK {
+		err := &errortypes.BadServerResponse{
+			Message: fmt.Sprintf("Unexpected status code: %d. Run with request.debug = 1 for more info.", responseData.StatusCode),
+		}
+		return nil, []error{err}
+	}
+
+	var response openrtb2.BidResponse
+	if err := json.Unmarshal(responseData.Body, &response); err != nil {
+		return nil, []error{err}
+	}
+
+	bidResponse := adapters.NewBidderResponseWithBidsCapacity(len(request.Imp))
+	bidResponse.Currency = response.Cur
+	var errors []error
+	for _, seatBid := range response.SeatBid {
+		for i, bid := range seatBid.Bid {
+			imp, _ := getImpByID(bid.ImpID, request.Imp)
+			bidType, err := getMediaTypeForBid(bid, imp)
+			if err != nil {
+				errors = append(errors, err)
+				continue
+			}
+			bidResponse.Bids = append(bidResponse.Bids, &adapters.TypedBid{
+				Bid:     &seatBid.Bid[i],
+				BidType: bidType,
+			})
+		}
+	}
+
+	if len(errors) > 0 {
+		return nil, errors
+	}
+
+	if len(bidResponse.Bids) == 0 {
+		return nil, []error{fmt.Errorf("no bids returned")}
+	}
+
+	return bidResponse, nil
+}
+
+func getImpByID(impID string, imps []openrtb2.Imp) (*openrtb2.Imp, error) {
+	for _, imp := range imps {
+		if imp.ID == impID {
+			return &imp, nil
+		}
+	}
+	return nil, fmt.Errorf("no matching imp found for id %s", impID)
+}
+
+func getMediaTypeForBid(bid openrtb2.Bid, imp *openrtb2.Imp) (openrtb_ext.BidType, error) {
+	if bid.Ext != nil {
+		var bidExt openrtb_ext.ExtBid
+		err := json.Unmarshal(bid.Ext, &bidExt)
+		if err == nil && bidExt.Prebid != nil {
+			return openrtb_ext.ParseBidType(string(bidExt.Prebid.Type))
+		}
+	}
+
+	if imp != nil {
+		if imp.Video != nil {
+			return openrtb_ext.BidTypeVideo, nil
+		} else if imp.Banner != nil {
+			return openrtb_ext.BidTypeBanner, nil
+		} else if imp.Audio != nil {
+			return openrtb_ext.BidTypeAudio, nil
+		}
+	}
+
+	return "", &errortypes.BadServerResponse{
+		Message: fmt.Sprintf("Failed to parse impression \"%s\" mediatype", bid.ImpID),
+	}
+}
+
+func getBidderExt(imp openrtb2.Imp) (bidderImpExt openrtb_ext.ImpExtConcert, err error) {
+	var impExt adapters.ExtImpBidder
+	if err = json.Unmarshal(imp.Ext, &impExt); err != nil {
+		return bidderImpExt, fmt.Errorf("imp ext: %v", err)
+	}
+	if err = json.Unmarshal(impExt.Bidder, &bidderImpExt); err != nil {
+		return bidderImpExt, fmt.Errorf("bidder ext: %v", err)
+	}
+	return bidderImpExt, nil
+}

adapters/concert/concert_test.go

@@ -0,0 +1,20 @@
+package concert
+
+import (
+	"testing"
+
+	"github.com/prebid/prebid-server/v2/adapters/adapterstest"
+	"github.com/prebid/prebid-server/v2/config"
+	"github.com/prebid/prebid-server/v2/openrtb_ext"
+)
+
+func TestJsonSamples(t *testing.T) {
+	bidder, buildErr := Builder(openrtb_ext.BidderConcert, config.Adapter{
+		Endpoint: "https://bids.concert.io/bids/openrtb"}, config.Server{ExternalUrl: "http://hosturl.com", GvlID: 1, DataCenter: "2"})
+
+	if buildErr != nil {
+		t.Fatalf("Builder returned unexpected error %v", buildErr)
+	}
+
+	adapterstest.RunJSONBidderTest(t, "concerttest", bidder)
+}

adapters/concert/concerttest/exemplary/audio.json

@@ -0,0 +1,116 @@
+{
+    "mockBidRequest": {
+      "id": "test-request-id",
+      "imp": [
+        {
+          "id": "test-imp-id",
+          "audio": {
+            "mimes": ["audio/mp3"],
+            "minduration": 5,
+            "maxduration": 30,
+            "protocols": [1, 2]
+          },
+          "ext": {
+            "bidder": {
+              "partnerId": "partner_name",
+              "placementId": 1234567,
+              "site": "site_name",
+              "slot": "slot_name"
+            }
+          }
+        }
+      ],
+      "site": {
+        "page": "http://www.example.com"
+      },
+      "device": {
+        "ua": "test-user-agent",
+        "ip": "123.123.123.123"
+      },
+      "user": {
+        "buyeruid": "some-buyer-uid"
+      },
+      "ext": {
+        "adapterVersion": "1.0.0",
+        "partnerId": "partner_name"
+      }
+    },
+    "httpCalls": [
+      {
+        "expectedRequest": {
+          "uri": "https://bids.concert.io/bids/openrtb",
+          "body": {
+            "id": "test-request-id",
+            "imp": [
+              {
+                "id": "test-imp-id",
+                "audio": {
+                  "mimes": ["audio/mp3"],
+                  "minduration": 5,
+                  "maxduration": 30,
+                  "protocols": [1, 2]
+                },
+                "ext": {
+                  "bidder": {
+                    "partnerId": "partner_name",
+                    "placementId": 1234567,
+                    "site": "site_name",
+                    "slot": "slot_name"
+                  }
+                }
+              }
+            ],
+            "device": {
+              "ip": "123.123.123.123",
+              "ua": "test-user-agent"
+            },
+            "site": {
+              "page": "http://www.example.com"
+            },
+            "user": {
+              "buyeruid": "some-buyer-uid"
+            },
+            "ext": {
+              "adapterVersion": "1.0.0",
+              "partnerId": "partner_name"
+            }
+          }
+        },
+        "mockResponse": {
+          "status": 200,
+          "body": {
+            "id": "test-response-id",
+            "seatbid": [
+              {
+                "bid": [
+                  {
+                    "id": "test-bid-id",
+                    "impid": "test-imp-id",
+                    "price": 1.23,
+                    "adm": "<VAST version=\"3.0\"><Ad><Wrapper>...</Wrapper></Ad></VAST>",
+                    "crid": "test-creative-id"
+                  }
+                ]
+              }
+            ]
+          }
+        }
+      }
+    ],
+    "expectedBidResponses": [
+      {
+        "bids": [
+          {
+            "bid": {
+              "id": "test-bid-id",
+              "impid": "test-imp-id",
+              "price": 1.23,
+              "adm": "<VAST version=\"3.0\"><Ad><Wrapper>...</Wrapper></Ad></VAST>",
+              "crid": "test-creative-id"
+            },
+            "type": "audio"
+          }
+        ]
+      }
+    ]
+  }