Fixed the Domain and Page for AMP requests. (#685)

endpoints/openrtb2/amp_auction.go

@@ -7,6 +7,7 @@ import (
 	"errors"
 	"fmt"
 	"net/http"
+	"net/url"
 	"strconv"
 	"strings"
 	"time"
@@ -315,6 +316,14 @@ func (deps *endpointDeps) overrideWithParams(httpRequest *http.Request, req *ope
 		} else {
 			req.Site.Page = canonicalURL
 		}
+		// Fixes #683
+		if parsedURL, err := url.Parse(canonicalURL); err == nil {
+			domain := parsedURL.Host
+			if colonIndex := strings.LastIndex(domain, ":"); colonIndex != -1 {
+				domain = domain[:colonIndex]
+			}
+			req.Site.Domain = domain
+		}
 	}
 
 	slot := httpRequest.FormValue("slot")

endpoints/openrtb2/amp_auction_test.go

@@ -6,12 +6,14 @@ import (
 	"fmt"
 	"net/http"
 	"net/http/httptest"
+	"net/url"
 	"reflect"
 	"strconv"
 	"testing"
 
 	"github.com/mxmCherry/openrtb"
 	analyticsConf "github.com/prebid/prebid-server/analytics/config"
+	"github.com/stretchr/testify/assert"
 
 	"github.com/prebid/prebid-server/config"
 	"github.com/prebid/prebid-server/exchange"
@@ -74,6 +76,29 @@ func TestGoodAmpRequests(t *testing.T) {
 	}
 }
 
+// Prevents #683
+func TestAMPPageInfo(t *testing.T) {
+	const page = "http://test.somepage.co.uk:1234?myquery=1&other=2"
+	stored := map[string]json.RawMessage{
+		"1": json.RawMessage(validRequest(t, "site.json")),
+	}
+	theMetrics := pbsmetrics.NewMetrics(metrics.NewRegistry(), openrtb_ext.BidderList())
+	exchange := &mockAmpExchange{}
+	endpoint, _ := NewAmpEndpoint(exchange, newParamsValidator(t), &mockAmpStoredReqFetcher{stored}, &config.Configuration{MaxRequestSize: maxSize}, theMetrics, analyticsConf.NewPBSAnalytics(&config.Analytics{}))
+	request := httptest.NewRequest("GET", fmt.Sprintf("/openrtb2/auction/amp?tag_id=1&curl=%s", url.QueryEscape(page)), nil)
+	recorder := httptest.NewRecorder()
+	endpoint(recorder, request, nil)
+
+	if !assert.NotNil(t, exchange.lastRequest, "Endpoint responded with %d: %s", recorder.Code, recorder.Body.String()) {
+		return
+	}
+	if !assert.NotNil(t, exchange.lastRequest.Site) {
+		return
+	}
+	assert.Equal(t, page, exchange.lastRequest.Site.Page)
+	assert.Equal(t, "test.somepage.co.uk", exchange.lastRequest.Site.Domain)
+}
+
 // TestBadRequests makes sure we return 400's on bad requests.
 func TestAmpBadRequests(t *testing.T) {
 	files := fetchFiles(t, "sample-requests/invalid-whole")