Use custom pod when applicable in purchase API

Author: majd

pkg/appstore/appstore_purchase.go

@@ -96,8 +96,13 @@ func (t *appstore) purchaseWithParams(acc Account, app App, guid string, pricing
 }
 
 func (t *appstore) purchaseRequest(acc Account, app App, storeFront, guid string, pricingParameters string) http.Request {
+	podPrefix := ""
+	if acc.Pod != "" {
+		podPrefix = "p" + acc.Pod + "-"
+	}
+
 	return http.Request{
-		URL:            fmt.Sprintf("https://%s%s", PrivateAppStoreAPIDomain, PrivateAppStoreAPIPathPurchase),
+		URL:            fmt.Sprintf("https://%s%s%s", podPrefix, PrivateAppStoreAPIDomain, PrivateAppStoreAPIPathPurchase),
 		Method:         http.MethodPOST,
 		ResponseFormat: http.ResponseFormatXML,
 		Headers: map[string]string{

pkg/appstore/appstore_purchase_test.go

@@ -93,6 +93,40 @@ var _ = Describe("AppStore (Purchase)", func() {
 		})
 	})
 
+	When("request uses a custom pod", func() {
+		const (
+			testPod  = "42"
+			testGUID = "001122334455"
+		)
+
+		BeforeEach(func() {
+			mockMachine.EXPECT().
+				MacAddress().
+				Return("00:11:22:33:44:55", nil)
+
+			mockPurchaseClient.EXPECT().
+				Send(gomock.Any()).
+				Do(func(req http.Request) {
+					expectedURL := "https://p" + testPod + "-" + PrivateAppStoreAPIDomain + PrivateAppStoreAPIPathPurchase
+					Expect(req.URL).To(Equal(expectedURL))
+					Expect(req.Payload).To(BeAssignableToTypeOf(&http.XMLPayload{}))
+					payload := req.Payload.(*http.XMLPayload)
+					Expect(payload.Content["guid"]).To(Equal(testGUID))
+				}).
+				Return(http.Result[purchaseResult]{}, errors.New(""))
+		})
+
+		It("sends the request to the pod-specific host", func() {
+			err := as.Purchase(PurchaseInput{
+				Account: Account{
+					StoreFront: "143441",
+					Pod:        testPod,
+				},
+			})
+			Expect(err).To(HaveOccurred())
+		})
+	})
+
 	When("password token is expired", func() {
 		BeforeEach(func() {
 			mockMachine.EXPECT().