Districtm Dmx: new adapter

adapters/dmx/dmx.go

@@ -0,0 +1,245 @@
+package dmx
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	"github.com/mxmCherry/openrtb"
+	"github.com/prebid/prebid-server/adapters"
+	"github.com/prebid/prebid-server/errortypes"
+	"github.com/prebid/prebid-server/openrtb_ext"
+	"github.com/prebid/prebid-server/pbs"
+	"net/http"
+	"sort"
+)
+
+type DmxAdapter struct {
+	endpoint    string
+	publisherId string
+}
+
+func New(text string) error {
+	return &errorString{text}
+}
+
+// errorString is a trivial implementation of error.
+type errorString struct {
+	s string
+}
+
+func (e *errorString) Error() string {
+	return e.s
+}
+
+func NewDmxBidder(endpoint string, publisher_id string) *DmxAdapter {
+	return &DmxAdapter{endpoint: endpoint, publisherId: publisher_id}
+}
+
+type dmxBidder struct {
+	Bidder dmxExt `json:"bidder"`
+}
+
+type dmxUser struct {
+	User *openrtb.User `json:"user"`
+}
+
+type dmxExt struct {
+	PublisherId string `json:"publisher_id,omitempty"`
+}
+
+type dmxBanner struct {
+	Banner *openrtb.Banner `json:"banner"`
+}
+
+type dmxSize struct {
+	W uint64
+	H uint64
+	S uint64
+}
+
+type DmxSize []dmxSize
+
+func (a DmxSize) Len() int {
+	return len(a)
+}
+
+func (a DmxSize) Swap(i, j int) {
+	a[i], a[j] = a[j], a[i]
+}
+
+func (a DmxSize) Less(i, j int) bool {
+	return a[i].S > a[j].S
+}
+
+func Remove(toBeRemove []openrtb.Format, a DmxSize) (dmx DmxSize) {
+	for _, value := range toBeRemove {
+		for _, dmxValue := range a {
+			if dmxValue.H == value.H && dmxValue.W == value.W {
+				//fmt.Println("true")
+				dmx = append(dmx, dmxValue)
+			}
+		}
+	}
+	return
+}
+
+var CheckTopSizes = []dmxSize{
+	{300, 250, 100},
+	{728, 90, 95},
+	{320, 50, 90},
+	{160, 600, 88},
+	{300, 600, 85},
+	{300, 50, 80},
+	{970, 250, 75},
+	{970, 90, 70},
+}
+
+func (adapter *DmxAdapter) MakeRequests(request *openrtb.BidRequest, req *adapters.ExtraRequestInfo) (reqsBidder []*adapters.RequestData, errs []error) {
+	var dmxImp dmxBidder
+	var imps []openrtb.Imp
+	//var userParams *dmxUser
+	if err := json.Unmarshal(request.Imp[0].Ext, &dmxImp); err != nil {
+		errs = append(errs, err)
+	}
+
+	//fmt.Println(request.User)
+	if request.User != nil {
+		if request.User.BuyerUID != "" {
+			request.User.ID = request.User.BuyerUID
+
+		}
+	}
+
+	for _, inst := range request.Imp {
+		var banner openrtb.Banner
+		var ins openrtb.Imp
+		//for _, insbanner := range inst.Banner.Format {
+		banner = openrtb.Banner{
+			W:      &inst.Banner.Format[0].W,
+			H:      &inst.Banner.Format[0].H,
+			Format: inst.Banner.Format,
+		}
+		nSize := Remove(inst.Banner.Format, CheckTopSizes)
+		sort.Sort(DmxSize(nSize))
+		if inst.Banner.Format[0].W != 0 {
+			banner.W = &nSize[0].W
+		}
+		if inst.Banner.Format[0].H != 0 {
+			banner.H = &nSize[0].H
+		}
+
+		var intVal int8
+		intVal = 1
+		ins = openrtb.Imp{
+			ID:     inst.ID,
+			Banner: &banner,
+			Ext:    inst.Ext,
+			Secure: &intVal,
+		}
+		imps = append(imps, ins)
+
+	}
+
+	request.Imp = imps
+
+	if dmxImp.Bidder.PublisherId != "" {
+		request.Site.Publisher = &openrtb.Publisher{ID: dmxImp.Bidder.PublisherId}
+	} else {
+		if request.Site.Publisher != nil {
+			request.Site.Publisher.ID = adapter.publisherId
+		}
+	}
+
+	if request.App != nil {
+		request.Site = nil
+		request.App.Publisher = &openrtb.Publisher{ID: dmxImp.Bidder.PublisherId}
+	}
+
+	oJson, _ := json.Marshal(request)
+	headers := http.Header{}
+	headers.Add("Content-Type", "Application/json;charset=utf-8")
+	reqBidder := &adapters.RequestData{
+		Method:  "POST",
+		Uri:     adapter.endpoint, //adapter.endpoint,
+		Body:    oJson,
+		Headers: headers,
+	}
+
+	if request.User == nil {
+		if request.App == nil {
+			return nil, []error{errors.New("no user Id only app send request")}
+		}
+	}
+
+	reqsBidder = append(reqsBidder, reqBidder)
+	return
+}
+
+func (adapter *DmxAdapter) MakeBids(request *openrtb.BidRequest, externalRequest *adapters.RequestData, response *adapters.ResponseData) (*adapters.BidderResponse, []error) {
+	var errs []error
+
+	if http.StatusNoContent == response.StatusCode {
+		return nil, []error{&errortypes.BadInput{
+			Message: fmt.Sprintf("No content to be return"),
+		}}
+	}
+
+	if http.StatusBadRequest == response.StatusCode {
+		return nil, []error{&errortypes.BadInput{
+			Message: fmt.Sprintf("Bad formated request"),
+		}}
+	}
+
+	if http.StatusOK != response.StatusCode {
+		return nil, []error{&errortypes.BadInput{
+			Message: fmt.Sprintf("Something is really wrong"),
+		}}
+	}
+
+	var bidResp openrtb.BidResponse
+
+	if err := json.Unmarshal(response.Body, &bidResp); err != nil {
+		return nil, []error{err}
+	}
+
+	bidResponse := adapters.NewBidderResponseWithBidsCapacity(5)
+
+	for _, sb := range bidResp.SeatBid {
+		for i := range sb.Bid {
+			bidType, err := getMediaTypeForImp(sb.Bid[i].ImpID, request.Imp)
+			if err != nil {
+				errs = append(errs, err)
+			} else {
+				b := &adapters.TypedBid{
+					Bid:     &sb.Bid[i],
+					BidType: bidType,
+				}
+				bidResponse.Bids = append(bidResponse.Bids, b)
+			}
+		}
+	}
+	return bidResponse, errs
+
+	return nil, errs
+}
+
+func getMediaTypeForImp(impID string, imps []openrtb.Imp) (openrtb_ext.BidType, error) {
+	mediaType := openrtb_ext.BidTypeBanner
+	for _, imp := range imps {
+		if imp.ID == impID {
+			if imp.Banner == nil && imp.Video != nil {
+				mediaType = openrtb_ext.BidTypeVideo
+			}
+			return mediaType, nil
+		}
+	}
+
+	// This shouldnt happen. Lets handle it just incase by returning an error.
+	return "", &errortypes.BadInput{
+		Message: fmt.Sprintf("Failed to find impression \"%s\" ", impID),
+	}
+}
+
+func getCookieInfo(request *pbs.PBSRequest) {
+
+}

adapters/dmx/usersync.go

@@ -0,0 +1,12 @@
+package dmx
+
+import (
+	"text/template"
+
+	"github.com/prebid/prebid-server/adapters"
+	"github.com/prebid/prebid-server/usersync"
+)
+
+func NewDmxSyncer(temp *template.Template) usersync.Usersyncer {
+	return adapters.NewSyncer("dmx", 144, temp, adapters.SyncTypeRedirect)
+}

adapters/dmx/usersync_test.go

@@ -0,0 +1,19 @@
+package dmx
+
+import (
+	"testing"
+	"text/template"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestDmxSyncer(t *testing.T) {
+	temp := template.Must(template.New("sync-template").Parse("https://cdn.districtm.io/ids/?sellerid=10007"))
+	syncer := NewDmxSyncer(temp)
+	syncInfo, err := syncer.GetUsersyncInfo("", "")
+	assert.NoError(t, err)
+	assert.Equal(t, "https://cdn.districtm.io/ids/?sellerid=10007", syncInfo.URL)
+	assert.Equal(t, "redirect", syncInfo.Type)
+	assert.EqualValues(t, 144, syncer.GDPRVendorID())
+	assert.Equal(t, false, syncInfo.SupportCORS)
+}

config/config.go

@@ -233,6 +233,9 @@ type Adapter struct {
 	PlatformID string `mapstructure:"platform_id"`
 	AppID      string `mapstructure:"app_id"`
 	AppSecret  string `mapstructure:"app_secret"`
+
+	// needed for district m DMX
+	PublisherId string `mapstructure:"publisher_id"`
 }
 
 // validateAdapterEndpoint makes sure that an adapter has a valid endpoint
@@ -486,6 +489,7 @@ func (cfg *Configuration) setDerivedDefaults() {
 	setDefaultUsersync(cfg.Adapters, openrtb_ext.BidderConsumable, "https://e.serverbid.com/udb/9969/match?gdpr={{.GDPR}}&euconsent={{.GDPRConsent}}&redir="+url.QueryEscape(externalURL)+"%2Fsetuid%3Fbidder%3Dconsumable%26gdpr%3D{{.GDPR}}%26gdpr_consent%3D{{.GDPRConsent}}%26uid%3D")
 	setDefaultUsersync(cfg.Adapters, openrtb_ext.BidderConversant, "https://prebid-match.dotomi.com/prebid/match?rurl="+url.QueryEscape(externalURL)+"%2Fsetuid%3Fbidder%3Dconversant%26gdpr%3D{{.GDPR}}%26gdpr_consent%3D{{.GDPRConsent}}%26uid%3D")
 	setDefaultUsersync(cfg.Adapters, openrtb_ext.BidderDatablocks, "https://search.v5prebid.datablocks.net/s2ssync?gdpr={{.GDPR}}&gdpr_consent={{.GDPRConsent}}&r="+url.QueryEscape(externalURL)+"%2Fsetuid%3Fbidder%3Ddatablocks%26gdpr%3D%24%7Bgdpr%7D%26gdpr_consent%3D%24%7Bgdpr_consent%7D%26uid%3D%24%7Buid%7D")
+	setDefaultUsersync(cfg.Adapters, openrtb_ext.BidderDmx, "https://cdn.districtm.io/ids/?sellerid="+cfg.Adapters[string(openrtb_ext.BidderDmx)].PublisherId+"&gdpr={{.GDPR}}&gdpr_consent={{.GDPRConsent}}")
 	setDefaultUsersync(cfg.Adapters, openrtb_ext.BidderEmxDigital, "https://cs.emxdgt.com/um?ssp=pbs&gdpr={{.GDPR}}&gdpr_consent={{.GDPRConsent}}&redirect="+url.QueryEscape(externalURL)+"%2Fsetuid%3Fbidder%3Demx_digital%26uid%3D%24UID")
 	setDefaultUsersync(cfg.Adapters, openrtb_ext.BidderEPlanning, "https://ads.us.e-planning.net/uspd/1/?du=https%3A%2F%2Fads.us.e-planning.net%2Fgetuid%2F1%2F5a1ad71d2d53a0f5%3F"+url.QueryEscape(externalURL)+"%2Fsetuid%3Fbidder%3Deplanning%26gdpr%3D{{.GDPR}}%26gdpr_consent%3D{{.GDPRConsent}}%26uid%3D%24UID")
 	// openrtb_ext.BidderFacebook doesn't have a good default.
@@ -650,7 +654,7 @@ func SetupViper(v *viper.Viper, filename string) {
 	// for them and specify all the parameters they need for them to work correctly.
 	v.SetDefault("adapters.audiencenetwork.disabled", true)
 	v.SetDefault("adapters.rubicon.disabled", true)
-
+	v.SetDefault("adapters.dmx.endpoint", "https://dmx.districtm.io/b/v2")
 	v.SetDefault("adapters.adtelligent.endpoint", "http://hb.adtelligent.com/auction")
 	v.SetDefault("adapters.adform.endpoint", "http://adx.adform.net/adx")
 	v.SetDefault("adapters.appnexus.endpoint", "http://ib.adnxs.com/openrtb2") // Docs: https://wiki.appnexus.com/display/supply/Incoming+Bid+Request+from+SSPs

exchange/adapter_map.go

@@ -21,6 +21,7 @@ import (
 	"github.com/prebid/prebid-server/adapters/consumable"
 	"github.com/prebid/prebid-server/adapters/conversant"
 	"github.com/prebid/prebid-server/adapters/datablocks"
+	"github.com/prebid/prebid-server/adapters/dmx"
 	"github.com/prebid/prebid-server/adapters/emx_digital"
 	"github.com/prebid/prebid-server/adapters/engagebdr"
 	"github.com/prebid/prebid-server/adapters/eplanning"
@@ -73,6 +74,7 @@ func newAdapterMap(client *http.Client, cfg *config.Configuration, infos adapter
 		openrtb_ext.BidderBrightroll: brightroll.NewBrightrollBidder(cfg.Adapters[string(openrtb_ext.BidderBrightroll)].Endpoint),
 		openrtb_ext.BidderConsumable: consumable.NewConsumableBidder(cfg.Adapters[string(openrtb_ext.BidderConsumable)].Endpoint),
 		openrtb_ext.BidderDatablocks: datablocks.NewDatablocksBidder(cfg.Adapters[string(openrtb_ext.BidderDatablocks)].Endpoint),
+		openrtb_ext.BidderDmx:        dmx.NewDmxBidder(cfg.Adapters[string(openrtb_ext.BidderDmx)].Endpoint, cfg.Adapters[string(openrtb_ext.BidderDmx)].PublisherId),
 		openrtb_ext.BidderEngageBDR:  engagebdr.NewEngageBDRBidder(client, cfg.Adapters[string(openrtb_ext.BidderEngageBDR)].Endpoint),
 		openrtb_ext.BidderEmxDigital: emx_digital.NewEmxDigitalBidder(cfg.Adapters[string(openrtb_ext.BidderEmxDigital)].Endpoint),
 		openrtb_ext.BidderEPlanning:  eplanning.NewEPlanningBidder(client, cfg.Adapters[string(openrtb_ext.BidderEPlanning)].Endpoint),

openrtb_ext/bidders.go

@@ -33,6 +33,7 @@ const (
 	BidderConsumable       BidderName = "consumable"
 	BidderConversant       BidderName = "conversant"
 	BidderDatablocks       BidderName = "datablocks"
+	BidderDmx              BidderName = "dmx"
 	BidderEmxDigital       BidderName = "emx_digital"
 	BidderEPlanning        BidderName = "eplanning"
 	BidderFacebook         BidderName = "audienceNetwork"
@@ -84,6 +85,7 @@ var BidderMap = map[string]BidderName{
 	"consumable":        BidderConsumable,
 	"conversant":        BidderConversant,
 	"datablocks":        BidderDatablocks,
+	"dmx":        		 BidderDmx,
 	"emx_digital":       BidderEmxDigital,
 	"eplanning":         BidderEPlanning,
 	"gamma":             BidderGamma,

static/bidder-info/dmx.yaml

@@ -0,0 +1,9 @@
+maintainer:
+  email: "[email protected]"
+capabilities:
+  site:
+    mediaTypes:
+      - banner
+  app:
+    mediaTypes:
+      - banner

static/bidder-params/dmx.json

@@ -0,0 +1,22 @@
+{
+  "$schema": "http://json-schema.org/draft-04/schema#",
+  "title": "District M DMX Adapter Params",
+  "description": "A schema which validates params accepted by the DMX adapter",
+  "type": "object",
+  "properties": {
+    "memberid" : {
+      "type": "string",
+      "description": "Represent boost MemberId from districtm UI"
+    },
+    "tagid": {
+      "type": "string",
+      "description": "Represent the placement ID, this value is optional"
+    },
+    "bidfloor": {
+      "type": "string",
+      "description": "The minimum price acceptable for a bid"
+    }
+  },
+
+  "required": ["memberid"]
+}

usersync/usersyncers/syncer.go

@@ -19,6 +19,7 @@ import (
 	"github.com/prebid/prebid-server/adapters/consumable"
 	"github.com/prebid/prebid-server/adapters/conversant"
 	"github.com/prebid/prebid-server/adapters/datablocks"
+	"github.com/prebid/prebid-server/adapters/dmx"
 	"github.com/prebid/prebid-server/adapters/emx_digital"
 	"github.com/prebid/prebid-server/adapters/engagebdr"
 	"github.com/prebid/prebid-server/adapters/eplanning"
@@ -73,6 +74,7 @@ func NewSyncerMap(cfg *config.Configuration) map[openrtb_ext.BidderName]usersync
 	insertIntoMap(cfg, syncers, openrtb_ext.BidderConsumable, consumable.NewConsumableSyncer)
 	insertIntoMap(cfg, syncers, openrtb_ext.BidderConversant, conversant.NewConversantSyncer)
 	insertIntoMap(cfg, syncers, openrtb_ext.BidderDatablocks, datablocks.NewDatablocksSyncer)
+	insertIntoMap(cfg, syncers, openrtb_ext.BidderDmx, dmx.NewDmxSyncer)
 	insertIntoMap(cfg, syncers, openrtb_ext.BidderEmxDigital, emx_digital.NewEMXDigitalSyncer)
 	insertIntoMap(cfg, syncers, openrtb_ext.BidderEPlanning, eplanning.NewEPlanningSyncer)
 	insertIntoMap(cfg, syncers, openrtb_ext.BidderFacebook, audienceNetwork.NewFacebookSyncer)

usersync/usersyncers/syncer_test.go

@@ -27,6 +27,7 @@ func TestNewSyncerMap(t *testing.T) {
 			string(openrtb_ext.BidderConsumable):       syncConfig,
 			string(openrtb_ext.BidderConversant):       syncConfig,
 			string(openrtb_ext.BidderDatablocks):       syncConfig,
+			string(openrtb_ext.BidderDmx):       syncConfig,
 			string(openrtb_ext.BidderEmxDigital):       syncConfig,
 			string(openrtb_ext.BidderEPlanning):        syncConfig,
 			string(openrtb_ext.BidderGrid):             syncConfig,