New Adapter: Connatix

adapters/connatix/connatix.go

@@ -0,0 +1,257 @@
+package connatix
+
+import (
+	"encoding/json"
+	"fmt"
+	"net/http"
+	"net/url"
+	"strings"
+
+	"github.com/buger/jsonparser"
+	"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"
+)
+
+const (
+	maxImpsPerReq = 1
+)
+
+// Builder builds a new instance of the Connatix adapter for the given bidder with the given config.
+func Builder(bidderName openrtb_ext.BidderName, config config.Adapter, server config.Server) (adapters.Bidder, error) {
+	uri, err := url.Parse(config.Endpoint)
+	if err != nil {
+		return nil, err
+	}
+
+	bidder := &adapter{
+		uri: *uri,
+	}
+	return bidder, nil
+}
+
+func (a *adapter) MakeRequests(request *openrtb2.BidRequest, reqInfo *adapters.ExtraRequestInfo) ([]*adapters.RequestData, []error) {
+	if request.Site == nil && request.App == nil {
+		return nil, []error{&errortypes.BadInput{
+			Message: "Either site or app object is required",
+		}}
+	}
+
+	if request.Device != nil && request.Device.IP == "" {
+		return nil, []error{&errortypes.BadInput{
+			Message: "Device IP is required",
+		}}
+	}
+
+	// connatix adapter expects imp.displaymanagerver to be populated in openrtb2 request
+	// but some SDKs will put it in imp.ext.prebid instead
+	displayManagerVer := buildDisplayManageVer(request)
+
+	var errs []error
+
+	validImps := []openrtb2.Imp{}
+	for i := 0; i < len(request.Imp); i++ {
+		impExtIncoming, err := validateAndBuildImpExt(&request.Imp[i])
+		if err != nil {
+			errs = append(errs, err)
+			continue
+		}
+
+		if err := buildRequestImp(&request.Imp[i], impExtIncoming, displayManagerVer, reqInfo); err != nil {
+			errs = append(errs, err)
+			continue
+		}
+
+		validImps = append(validImps, request.Imp[i])
+	}
+	request.Imp = validImps
+
+	// If all the requests were malformed, don't bother making a server call with no impressions.
+	if len(request.Imp) == 0 {
+		return nil, errs
+	}
+
+	// Divide imps to several requests
+	requests, errors := splitRequests(request.Imp, request, a.uri.String())
+	return requests, append(errs, errors...)
+}
+
+func (a *adapter) MakeBids(internalRequest *openrtb2.BidRequest, externalRequest *adapters.RequestData, response *adapters.ResponseData) (*adapters.BidderResponse, []error) {
+	if adapters.IsResponseStatusCodeNoContent(response) {
+		return nil, nil
+	}
+
+	if err := adapters.CheckResponseStatusCodeForErrors(response); err != nil {
+		return nil, []error{err}
+	}
+
+	var connatixResponse openrtb2.BidResponse
+	if err := json.Unmarshal(response.Body, &connatixResponse); err != nil {
+		return nil, []error{err}
+	}
+
+	var errs []error
+	bidderResponse := adapters.NewBidderResponseWithBidsCapacity(1)
+	for _, sb := range connatixResponse.SeatBid {
+		for i := range sb.Bid {
+			bid := sb.Bid[i]
+			var bidExt bidExt
+			var bidType openrtb_ext.BidType
+
+			if err := json.Unmarshal(bid.Ext, &bidExt); err != nil {
+				bidType = openrtb_ext.BidTypeBanner
+			} else {
+				bidType = getBidType(bidExt)
+			}
+
+			bidderResponse.Bids = append(bidderResponse.Bids, &adapters.TypedBid{
+				Bid:     &bid,
+				BidType: bidType,
+			})
+		}
+	}
+
+	bidderResponse.Currency = "USD"
+
+	return bidderResponse, errs
+}
+
+func validateAndBuildImpExt(imp *openrtb2.Imp) (impExtIncoming, error) {
+	var ext impExtIncoming
+	if err := json.Unmarshal(imp.Ext, &ext); err != nil {
+		return impExtIncoming{}, err
+	}
+
+	if err := validateConnatixExt(&ext.Bidder); err != nil {
+		return impExtIncoming{}, err
+	}
+
+	return ext, nil
+}
+
+func validateConnatixExt(cnxExt *openrtb_ext.ExtImpConnatix) error {
+	if cnxExt.PlacementId == "" {
+		return &errortypes.BadInput{
+			Message: "Placement id is required",
+		}
+	}
+	return nil
+}
+
+func splitRequests(imps []openrtb2.Imp, request *openrtb2.BidRequest, uri string) ([]*adapters.RequestData, []error) {
+	var errs []error
+	// Initial capacity for future array of requests, memory optimization.
+	// Let's say there are 35 impressions and limit impressions per request equals to 10.
+	// In this case we need to create 4 requests with 10, 10, 10 and 5 impressions.
+	// With this formula initial capacity=(35+10-1)/10 = 4
+	initialCapacity := (len(imps) + maxImpsPerReq - 1) / maxImpsPerReq
+	resArr := make([]*adapters.RequestData, 0, initialCapacity)
+	startInd := 0
+	impsLeft := len(imps) > 0
+
+	headers := http.Header{}
+	headers.Add("Content-Type", "application/json;charset=utf-8")
+	headers.Add("Accept", "application/json")
+
+	for impsLeft {
+		endInd := startInd + maxImpsPerReq
+		if endInd >= len(imps) {
+			endInd = len(imps)
+			impsLeft = false
+		}
+		impsForReq := imps[startInd:endInd]
+		request.Imp = impsForReq
+
+		reqJSON, err := json.Marshal(request)
+		if err != nil {
+			errs = append(errs, err)
+			return nil, errs
+		}
+
+		resArr = append(resArr, &adapters.RequestData{
+			Method:  "POST",
+			Uri:     uri,
+			Body:    reqJSON,
+			Headers: headers,
+			ImpIDs:  openrtb_ext.GetImpIDs(request.Imp),
+		})
+		startInd = endInd
+	}
+	return resArr, errs
+}
+
+func buildRequestImp(imp *openrtb2.Imp, ext impExtIncoming, displayManagerVer string, reqInfo *adapters.ExtraRequestInfo) error {
+	if imp.Video == nil && imp.Banner == nil {
+		return &errortypes.BadInput{
+			Message: "Either video or banner object on impression is required",
+		}
+	}
+
+	if imp.Banner != nil {
+		bannerCopy := *imp.Banner
+
+		if bannerCopy.W == nil && bannerCopy.H == nil && len(bannerCopy.Format) > 0 {
+			firstFormat := bannerCopy.Format[0]
+			bannerCopy.W = &(firstFormat.W)
+			bannerCopy.H = &(firstFormat.H)
+		}
+		imp.Banner = &bannerCopy
+	}
+
+	// Populate imp.displaymanagerver if the SDK failed to do it.
+	if len(imp.DisplayManagerVer) == 0 && len(displayManagerVer) > 0 {
+		imp.DisplayManagerVer = displayManagerVer
+	}
+
+	// Check if imp comes with bid floor amount defined in a foreign currency
+	if imp.BidFloor > 0 && imp.BidFloorCur != "" && !strings.EqualFold(imp.BidFloorCur, "USD") {
+		// Convert to US dollars
+		convertedValue, err := reqInfo.ConvertCurrency(imp.BidFloor, imp.BidFloorCur, "USD")
+		if err != nil {
+			return err
+		}
+		// Update after conversion. All imp elements inside request.Imp are shallow copies
+		// therefore, their non-pointer values are not shared memory and are safe to modify.
+		imp.BidFloorCur = "USD"
+		imp.BidFloor = convertedValue
+	}
+
+	impExt := impExt{
+		Connatix: impExtConnatix{
+			PlacementId: ext.Bidder.PlacementId,
+		},
+	}
+
+	var err error
+	imp.Ext, err = json.Marshal(impExt)
+
+	return err
+}
+
+func buildDisplayManageVer(req *openrtb2.BidRequest) string {
+	if req.App == nil {
+		return ""
+	}
+
+	source, err := jsonparser.GetString(req.App.Ext, openrtb_ext.PrebidExtKey, "source")
+	if err != nil {
+		return ""
+	}
+
+	version, err := jsonparser.GetString(req.App.Ext, openrtb_ext.PrebidExtKey, "version")
+	if err != nil {
+		return ""
+	}
+
+	return fmt.Sprintf("%s-%s", source, version)
+}
+
+func getBidType(ext bidExt) openrtb_ext.BidType {
+	if ext.Cnx.MediaType == "video" {
+		return openrtb_ext.BidTypeVideo
+	}
+
+	return openrtb_ext.BidTypeBanner
+}

adapters/connatix/connatix_test.go

@@ -0,0 +1,20 @@
+package connatix
+
+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.BidderConnatix, config.Adapter{
+		Endpoint: "http://example.com"}, config.Server{ExternalUrl: "http://hosturl.com", GvlID: 1, DataCenter: "2"})
+
+	if buildErr != nil {
+		t.Fatalf("Builder returned unexpected error %v", buildErr)
+	}
+
+	adapterstest.RunJSONBidderTest(t, "connatixtest", bidder)
+}