Add experimental destination-protocol flag to map-route

actor/v7action/cloud_controller_client.go

@@ -139,7 +139,7 @@ type CloudControllerClient interface {
 	GetUser(userGUID string) (resources.User, ccv3.Warnings, error)
 	GetUsers(query ...ccv3.Query) ([]resources.User, ccv3.Warnings, error)
 	MakeRequestSendReceiveRaw(Method string, URL string, headers http.Header, requestBody []byte) ([]byte, *http.Response, error)
-	MapRoute(routeGUID string, appGUID string) (ccv3.Warnings, error)
+	MapRoute(routeGUID string, appGUID string, destinationProtocol string) (ccv3.Warnings, error)
 	PollJob(jobURL ccv3.JobURL) (ccv3.Warnings, error)
 	PollJobForState(jobURL ccv3.JobURL, state constant.JobState) (ccv3.Warnings, error)
 	PollJobToEventStream(jobURL ccv3.JobURL) chan ccv3.PollJobEvent

actor/v7action/route.go

@@ -369,8 +369,8 @@ func (actor Actor) GetRouteByAttributes(domain resources.Domain, hostname string
 	return routes[0], Warnings(ccWarnings), nil
 }
 
-func (actor Actor) MapRoute(routeGUID string, appGUID string) (Warnings, error) {
-	warnings, err := actor.CloudControllerClient.MapRoute(routeGUID, appGUID)
+func (actor Actor) MapRoute(routeGUID string, appGUID string, destinationProtocol string) (Warnings, error) {
+	warnings, err := actor.CloudControllerClient.MapRoute(routeGUID, appGUID, destinationProtocol)
 	return Warnings(warnings), err
 }
 

actor/v7action/route_test.go

@@ -1453,20 +1453,22 @@ var _ = Describe("Route Actions", func() {
 
 	Describe("MapRoute", func() {
 		var (
-			routeGUID string
-			appGUID   string
+			routeGUID           string
+			appGUID             string
+			destinationProtocol string
 
 			executeErr error
 			warnings   Warnings
 		)
 
 		JustBeforeEach(func() {
-			warnings, executeErr = actor.MapRoute(routeGUID, appGUID)
+			warnings, executeErr = actor.MapRoute(routeGUID, appGUID, destinationProtocol)
 		})
 
 		BeforeEach(func() {
 			routeGUID = "route-guid"
 			appGUID = "app-guid"
+			destinationProtocol = "http2"
 		})
 
 		When("the cloud controller client errors", func() {
@@ -1485,6 +1487,13 @@ var _ = Describe("Route Actions", func() {
 				fakeCloudControllerClient.MapRouteReturns(ccv3.Warnings{"map-route-warning"}, nil)
 			})
 
+			It("calls the cloud controller client with the right arguments", func() {
+				actualRouteGUID, actualAppGUID, actualDestinationProtocol := fakeCloudControllerClient.MapRouteArgsForCall(0)
+				Expect(actualRouteGUID).To(Equal("route-guid"))
+				Expect(actualAppGUID).To(Equal("app-guid"))
+				Expect(actualDestinationProtocol).To(Equal("http2"))
+			})
+
 			It("returns the error and warnings", func() {
 				Expect(executeErr).ToNot(HaveOccurred())
 				Expect(warnings).To(ConsistOf("map-route-warning"))

actor/v7pushaction/v7_actor.go

@@ -25,7 +25,7 @@ type V7Actor interface {
 	GetDomain(domainGUID string) (resources.Domain, v7action.Warnings, error)
 	GetRouteByAttributes(domain resources.Domain, hostname, path string, port int) (resources.Route, v7action.Warnings, error)
 	GetRouteDestinationByAppGUID(route resources.Route, appGUID string) (resources.RouteDestination, error)
-	MapRoute(routeGUID string, appGUID string) (v7action.Warnings, error)
+	MapRoute(routeGUID string, appGUID string, destinationProtocol string) (v7action.Warnings, error)
 	PollBuild(buildGUID string, appName string) (resources.Droplet, v7action.Warnings, error)
 	PollPackage(pkg resources.Package) (resources.Package, v7action.Warnings, error)
 	PollStart(app resources.Application, noWait bool, handleProcessStats func(string)) (v7action.Warnings, error)

api/cloudcontroller/ccv3/route.go

@@ -82,7 +82,7 @@ func (client Client) GetRoutes(query ...Query) ([]resources.Route, Warnings, err
 	return routes, warnings, err
 }
 
-func (client Client) MapRoute(routeGUID string, appGUID string) (Warnings, error) {
+func (client Client) MapRoute(routeGUID string, appGUID string, destinationProtocol string) (Warnings, error) {
 	type destinationProcess struct {
 		ProcessType string `json:"process_type"`
 	}
@@ -92,7 +92,8 @@ func (client Client) MapRoute(routeGUID string, appGUID string) (Warnings, error
 		Process *destinationProcess `json:"process,omitempty"`
 	}
 	type destination struct {
-		App destinationApp `json:"app"`
+		App      destinationApp `json:"app"`
+		Protocol string         `json:"protocol,omitempty"`
 	}
 
 	type body struct {
@@ -101,9 +102,14 @@ func (client Client) MapRoute(routeGUID string, appGUID string) (Warnings, error
 
 	requestBody := body{
 		Destinations: []destination{
-			{App: destinationApp{GUID: appGUID}},
+			{
+				App: destinationApp{GUID: appGUID},
+			},
 		},
 	}
+	if destinationProtocol != "" {
+		requestBody.Destinations[0].Protocol = destinationProtocol
+	}
 
 	_, warnings, err := client.MakeRequest(RequestParams{
 		RequestName: internal.MapRouteRequest,

api/cloudcontroller/ccv3/route_test.go

@@ -537,39 +537,40 @@ var _ = Describe("Route", func() {
 
 	Describe("MapRoute", func() {
 		var (
-			routeGUID  = "route-guid"
-			appGUID    = "app-guid"
-			warnings   Warnings
-			executeErr error
+			routeGUID           = "route-guid"
+			appGUID             = "app-guid"
+			destinationProtocol = "http2"
+			expectedBody        string
+			warnings            Warnings
+			executeErr          error
 		)
 
 		JustBeforeEach(func() {
-			warnings, executeErr = client.MapRoute(routeGUID, appGUID)
+			response := `{}`
+			server.AppendHandlers(
+				CombineHandlers(
+					VerifyRequest(http.MethodPost, "/v3/routes/route-guid/destinations"),
+					VerifyJSON(expectedBody),
+					RespondWith(http.StatusOK, response, http.Header{"X-Cf-Warnings": {"warning-1"}}),
+				),
+			)
+			warnings, executeErr = client.MapRoute(routeGUID, appGUID, destinationProtocol)
 		})
 
 		When("the request is successful", func() {
 			BeforeEach(func() {
-				expectedBody := fmt.Sprintf(`
+				expectedBody = fmt.Sprintf(`
 					{
 						"destinations": [
 						 {
 							"app": {
 								"guid": "%s"
-							}
+							},
+							"protocol": "%s"
 						 }
 						]
 					}
-				`, appGUID)
-
-				response := `{}`
-
-				server.AppendHandlers(
-					CombineHandlers(
-						VerifyRequest(http.MethodPost, "/v3/routes/route-guid/destinations"),
-						VerifyJSON(expectedBody),
-						RespondWith(http.StatusOK, response, http.Header{"X-Cf-Warnings": {"warning-1"}}),
-					),
-				)
+				`, appGUID, destinationProtocol)
 			})
 
 			It("returns the warnings and no error", func() {
@@ -578,6 +579,27 @@ var _ = Describe("Route", func() {
 			})
 		})
 
+		Context("when destination protocol is not provided", func() {
+			BeforeEach(func() {
+				destinationProtocol = ""
+				expectedBody = fmt.Sprintf(`
+					{
+						"destinations": [
+						 {
+							"app": {
+								"guid": "%s"
+							}
+						 }
+						]
+					}
+				`, appGUID)
+			})
+
+			It("does not include it in the request", func() {
+				Expect(executeErr).ToNot(HaveOccurred())
+			})
+		})
+
 		When("the cloud controller returns errors and warnings", func() {
 			BeforeEach(func() {
 				response := `{

command/v7/actor.go

@@ -178,7 +178,7 @@ type Actor interface {
 	GetUnstagedNewestPackageGUID(appGuid string) (string, v7action.Warnings, error)
 	GetUser(username, origin string) (resources.User, error)
 	MakeCurlRequest(httpMethod string, path string, customHeaders []string, httpData string, failOnHTTPError bool) ([]byte, *http.Response, error)
-	MapRoute(routeGUID string, appGUID string) (v7action.Warnings, error)
+	MapRoute(routeGUID string, appGUID string, destinationProtocol string) (v7action.Warnings, error)
 	Marketplace(filter v7action.MarketplaceFilter) ([]v7action.ServiceOfferingWithPlans, v7action.Warnings, error)
 	ParseAccessToken(accessToken string) (jwt.JWT, error)
 	PollBuild(buildGUID string, appName string) (resources.Droplet, v7action.Warnings, error)