For analytics records, upload a singular product that was used for an…

… authorized operation. This replaces the existing functionality that picked a random matching product from the credential

analytics/record.go

@@ -86,13 +86,9 @@ func (r Record) EnsureFields(authContext *auth.Context) Record {
 	r.ClientID = authContext.ClientID
 	r.Organization = authContext.Organization()
 	r.Environment = authContext.Environment()
-
 	r.GatewayFlowID = uuid.New().String()
+	r.APIProduct = authContext.AnalyticsProduct
 
-	// select arbitrary APIProduct
-	if len(authContext.APIProducts) > 0 {
-		r.APIProduct = authContext.APIProducts[0]
-	}
 	return r
 }
 

analytics/saas_analytics_test.go

@@ -224,7 +224,6 @@ func TestPushAnalytics(t *testing.T) {
 					{
 						ClientReceivedStartTimestamp: ts * 1000,
 						ClientReceivedEndTimestamp:   ts * 1000,
-						APIProduct:                   "product",
 					},
 				},
 				dir: uploadDir,
@@ -257,6 +256,7 @@ func TestPushAnalytics(t *testing.T) {
 						ClientReceivedStartTimestamp: ts * 1000,
 						ClientReceivedEndTimestamp:   ts * 1000,
 						APIProxy:                     "proxy",
+						APIProduct:                   "product",
 					},
 					{
 						RecordType:                   "APIAnalytics",
@@ -280,6 +280,7 @@ func TestPushAnalytics(t *testing.T) {
 						ClientReceivedStartTimestamp: ts * 1000,
 						ClientReceivedEndTimestamp:   ts * 1000,
 						RequestURI:                   "request URI",
+						APIProduct:                   "product",
 					},
 				},
 				dir: uploadDir,
@@ -293,7 +294,10 @@ func TestPushAnalytics(t *testing.T) {
 	tc := authtest.NewContext(fs.URL())
 	tc.SetOrganization("hi")
 	tc.SetEnvironment("test")
-	authContext := &auth.Context{Context: tc}
+	authContext := &auth.Context{
+		Context:          tc,
+		AnalyticsProduct: "product",
+	}
 
 	if err := m.SendRecords(authContext, sendRecords[t1][0].records); err != nil {
 		t.Errorf("Error on SendRecords(): %s", err)
@@ -308,7 +312,10 @@ func TestPushAnalytics(t *testing.T) {
 	tc = authtest.NewContext(fs.URL())
 	tc.SetOrganization("otherorg")
 	tc.SetEnvironment("test")
-	authContext = &auth.Context{Context: tc}
+	authContext = &auth.Context{
+		Context:          tc,
+		AnalyticsProduct: "product",
+	}
 	if err := m.SendRecords(authContext, sendRecords[t2][0].records); err != nil {
 		t.Errorf("Error on SendRecords(): %s", err)
 	}
@@ -395,7 +402,6 @@ func TestPushAnalyticsMultipleRecords(t *testing.T) {
 				{
 					ClientReceivedStartTimestamp: ts * 1000,
 					ClientReceivedEndTimestamp:   ts * 1000,
-					APIProduct:                   "product",
 				},
 			},
 			dir: uploadDir,
@@ -424,6 +430,7 @@ func TestPushAnalyticsMultipleRecords(t *testing.T) {
 					ClientReceivedStartTimestamp: ts * 1000,
 					ClientReceivedEndTimestamp:   ts * 1000,
 					APIProxy:                     "proxy",
+					APIProduct:                   "product",
 				},
 				{
 					RecordType:                   "APIAnalytics",
@@ -440,6 +447,7 @@ func TestPushAnalyticsMultipleRecords(t *testing.T) {
 					ClientReceivedStartTimestamp: ts * 1000,
 					ClientReceivedEndTimestamp:   ts * 1000,
 					RequestURI:                   "request URI",
+					APIProduct:                   "product",
 				},
 			},
 			dir: uploadDir,
@@ -451,7 +459,10 @@ func TestPushAnalyticsMultipleRecords(t *testing.T) {
 	tc := authtest.NewContext(fs.URL())
 	tc.SetOrganization("hi")
 	tc.SetEnvironment("test")
-	authContext := &auth.Context{Context: tc}
+	authContext := &auth.Context{
+		Context:          tc,
+		AnalyticsProduct: "product",
+	}
 
 	if err := m.SendRecords(authContext, sendRecords[t1][0].records); err != nil {
 		t.Errorf("Error on SendRecords(): %s", err)

auth/context.go

@@ -47,6 +47,7 @@ type Context struct {
 	Scopes           []string
 	APIKey           string
 	CustomAttributes string
+	AnalyticsProduct string // A single product to attatch to analytics records based on matched operations.
 }
 
 // if claims can't be processed, returns error and sets no fields

product/manager.go

@@ -82,6 +82,7 @@ type AuthorizedOperation struct {
 	QuotaLimit    int64
 	QuotaInterval int64
 	QuotaTimeUnit string
+	APIProduct    string
 }
 
 // Authorize a request against API Products and its Operations

product/product.go

@@ -318,6 +318,7 @@ func (p *APIProduct) authorize(authContext *auth.Context, api, path, method stri
 					QuotaLimit:    p.QuotaLimitInt,
 					QuotaInterval: p.QuotaIntervalInt,
 					QuotaTimeUnit: p.QuotaTimeUnit,
+					APIProduct:    p.Name,
 				}
 				// OperationConfig quota is an override
 				if oc.Quota != nil && oc.Quota.LimitInt > 0 {
@@ -353,6 +354,7 @@ func (p *APIProduct) authorize(authContext *auth.Context, api, path, method stri
 		QuotaLimit:    p.QuotaLimitInt,
 		QuotaInterval: p.QuotaIntervalInt,
 		QuotaTimeUnit: p.QuotaTimeUnit,
+		APIProduct:    p.Name,
 	})
 	hint = "    authorized\n"
 

product/product_test.go

@@ -196,6 +196,7 @@ func TestAuthorize(t *testing.T) {
 			wantAuthOp: &AuthorizedOperation{
 				ID:         "Name [email protected]",
 				QuotaLimit: productsMap["Name 2"].QuotaLimitInt,
+				APIProduct: "Name 2",
 			},
 			wantHints: `Authorizing request:
 			environment: prod
@@ -255,6 +256,7 @@ func TestAuthorize(t *testing.T) {
 			wantAuthOp: &AuthorizedOperation{
 				ID:         "Name [email protected]",
 				QuotaLimit: productsMap["Name 1"].QuotaLimitInt,
+				APIProduct: "Name 1",
 			},
 			wantHints: `Authorizing request:
 			environment: prod