From a8f837798d45ecdc0aa2a3b4f422b8b01d07b538 Mon Sep 17 00:00:00 2001 From: Paul Morie Date: Mon, 12 Jun 2017 11:46:19 -0400 Subject: [PATCH] Stop sending accepts_incomplete in provision request body --- .../open_service_broker_client.go | 20 ++++++++++++++++++- 1 file changed, 19 insertions(+), 1 deletion(-) diff --git a/pkg/brokerapi/openservicebroker/open_service_broker_client.go b/pkg/brokerapi/openservicebroker/open_service_broker_client.go index 7f8e48c77a5..608fa311584 100644 --- a/pkg/brokerapi/openservicebroker/open_service_broker_client.go +++ b/pkg/brokerapi/openservicebroker/open_service_broker_client.go @@ -134,9 +134,27 @@ func (c *openServiceBrokerClient) GetCatalog() (*brokerapi.Catalog, error) { return &catalog, nil } +type createServiceInstanceRequestBody struct { + ServiceID string `json:"service_id,omitempty"` + PlanID string `json:"plan_id,omitempty"` + OrgID string `json:"organization_guid,omitempty"` + SpaceID string `json:"space_guid,omitempty"` + Parameters map[string]interface{} `json:"parameters,omitempty"` + ContextProfile brokerapi.ContextProfile `json:"context,omitempty"` +} + func (c *openServiceBrokerClient) CreateServiceInstance(ID string, req *brokerapi.CreateServiceInstanceRequest) (*brokerapi.CreateServiceInstanceResponse, int, error) { serviceInstanceURL := fmt.Sprintf(serviceInstanceFormatString, c.url, ID) + requestBody := &createServiceInstanceRequestBody{ + ServiceID: req.ServiceID, + PlanID: req.PlanID, + OrgID: req.OrgID, + SpaceID: req.SpaceID, + Parameters: req.Parameters, + ContextProfile: req.ContextProfile, + } + resp, err := sendOSBRequest( c, http.MethodPut, @@ -144,7 +162,7 @@ func (c *openServiceBrokerClient) CreateServiceInstance(ID string, req *brokerap map[string]string{ "accepts_incomplete": fmt.Sprintf("%t", req.AcceptsIncomplete), }, - req, + requestBody, ) if err != nil { glog.Errorf("Error sending create service instance request to broker %q at %v: response: %v error: %#v", c.name, serviceInstanceURL, resp, err)