Skip to content

Commit

Permalink
move getProject/op call and allow sending objects in delete (#1888)
Browse files Browse the repository at this point in the history
  • Loading branch information
modular-magician authored and danawillow committed Aug 16, 2018
1 parent 5a34315 commit 81420a2
Show file tree
Hide file tree
Showing 22 changed files with 491 additions and 524 deletions.
48 changes: 21 additions & 27 deletions google/resource_compute_address.go
Original file line number Diff line number Diff line change
Expand Up @@ -125,11 +125,6 @@ func resourceComputeAddress() *schema.Resource {
func resourceComputeAddressCreate(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

obj := make(map[string]interface{})
addressProp, err := expandComputeAddressAddress(d.Get("address"), d, config)
if err != nil {
Expand Down Expand Up @@ -198,6 +193,10 @@ func resourceComputeAddressCreate(d *schema.ResourceData, meta interface{}) erro
}
d.SetId(id)

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
Expand Down Expand Up @@ -260,11 +259,6 @@ func resourceComputeAddressCreate(d *schema.ResourceData, meta interface{}) erro
func resourceComputeAddressRead(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

url, err := replaceVars(d, config, "https://www.googleapis.com/compute/beta/projects/{{project}}/regions/{{region}}/addresses/{{name}}")
if err != nil {
return err
Expand Down Expand Up @@ -311,6 +305,10 @@ func resourceComputeAddressRead(d *schema.ResourceData, meta interface{}) error
if err := d.Set("self_link", ConvertSelfLinkToV1(res["selfLink"].(string))); err != nil {
return fmt.Errorf("Error reading Address: %s", err)
}
project, err := getProject(d, config)
if err != nil {
return err
}
if err := d.Set("project", project); err != nil {
return fmt.Errorf("Error reading Address: %s", err)
}
Expand All @@ -321,15 +319,6 @@ func resourceComputeAddressRead(d *schema.ResourceData, meta interface{}) error
func resourceComputeAddressUpdate(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

var url string
var res map[string]interface{}
op := &compute.Operation{}

d.Partial(true)

if d.HasChange("labels") || d.HasChange("label_fingerprint") {
Expand All @@ -343,15 +332,20 @@ func resourceComputeAddressUpdate(d *schema.ResourceData, meta interface{}) erro
labelFingerprintProp := d.Get("label_fingerprint")
obj["labelFingerprint"] = labelFingerprintProp

url, err = replaceVars(d, config, "https://www.googleapis.com/compute/beta/projects/{{project}}/regions/{{region}}/addresses/{{name}}/setLabels")
url, err := replaceVars(d, config, "https://www.googleapis.com/compute/beta/projects/{{project}}/regions/{{region}}/addresses/{{name}}/setLabels")
if err != nil {
return err
}
res, err = sendRequest(config, "POST", url, obj)
res, err := sendRequest(config, "POST", url, obj)
if err != nil {
return fmt.Errorf("Error updating Address %q: %s", d.Id(), err)
}

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
return err
Expand All @@ -377,22 +371,22 @@ func resourceComputeAddressUpdate(d *schema.ResourceData, meta interface{}) erro
func resourceComputeAddressDelete(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

url, err := replaceVars(d, config, "https://www.googleapis.com/compute/beta/projects/{{project}}/regions/{{region}}/addresses/{{name}}")
if err != nil {
return err
}

var obj map[string]interface{}
log.Printf("[DEBUG] Deleting Address %q", d.Id())
res, err := sendRequest(config, "DELETE", url, nil)
res, err := sendRequest(config, "DELETE", url, obj)
if err != nil {
return handleNotFoundError(err, d, "Address")
}

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
Expand Down
39 changes: 18 additions & 21 deletions google/resource_compute_autoscaler.go
Original file line number Diff line number Diff line change
Expand Up @@ -157,11 +157,6 @@ func resourceComputeAutoscaler() *schema.Resource {
func resourceComputeAutoscalerCreate(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

obj := make(map[string]interface{})
nameProp, err := expandComputeAutoscalerName(d.Get("name"), d, config)
if err != nil {
Expand Down Expand Up @@ -212,6 +207,10 @@ func resourceComputeAutoscalerCreate(d *schema.ResourceData, meta interface{}) e
}
d.SetId(id)

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
Expand All @@ -236,11 +235,6 @@ func resourceComputeAutoscalerCreate(d *schema.ResourceData, meta interface{}) e
func resourceComputeAutoscalerRead(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

url, err := replaceVars(d, config, "https://www.googleapis.com/compute/v1/projects/{{project}}/zones/{{zone}}/autoscalers/{{name}}")
if err != nil {
return err
Expand Down Expand Up @@ -272,6 +266,10 @@ func resourceComputeAutoscalerRead(d *schema.ResourceData, meta interface{}) err
if err := d.Set("self_link", ConvertSelfLinkToV1(res["selfLink"].(string))); err != nil {
return fmt.Errorf("Error reading Autoscaler: %s", err)
}
project, err := getProject(d, config)
if err != nil {
return err
}
if err := d.Set("project", project); err != nil {
return fmt.Errorf("Error reading Autoscaler: %s", err)
}
Expand All @@ -282,11 +280,6 @@ func resourceComputeAutoscalerRead(d *schema.ResourceData, meta interface{}) err
func resourceComputeAutoscalerUpdate(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

obj := make(map[string]interface{})
nameProp, err := expandComputeAutoscalerName(d.Get("name"), d, config)
if err != nil {
Expand Down Expand Up @@ -331,6 +324,10 @@ func resourceComputeAutoscalerUpdate(d *schema.ResourceData, meta interface{}) e
return fmt.Errorf("Error updating Autoscaler %q: %s", d.Id(), err)
}

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
Expand All @@ -351,22 +348,22 @@ func resourceComputeAutoscalerUpdate(d *schema.ResourceData, meta interface{}) e
func resourceComputeAutoscalerDelete(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

url, err := replaceVars(d, config, "https://www.googleapis.com/compute/v1/projects/{{project}}/zones/{{zone}}/autoscalers/{{name}}")
if err != nil {
return err
}

var obj map[string]interface{}
log.Printf("[DEBUG] Deleting Autoscaler %q", d.Id())
res, err := sendRequest(config, "DELETE", url, nil)
res, err := sendRequest(config, "DELETE", url, obj)
if err != nil {
return handleNotFoundError(err, d, "Autoscaler")
}

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
Expand Down
39 changes: 18 additions & 21 deletions google/resource_compute_backend_bucket.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,11 +81,6 @@ func resourceComputeBackendBucket() *schema.Resource {
func resourceComputeBackendBucketCreate(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

obj := make(map[string]interface{})
bucketNameProp, err := expandComputeBackendBucketBucketName(d.Get("bucket_name"), d, config)
if err != nil {
Expand Down Expand Up @@ -130,6 +125,10 @@ func resourceComputeBackendBucketCreate(d *schema.ResourceData, meta interface{}
}
d.SetId(id)

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
Expand All @@ -154,11 +153,6 @@ func resourceComputeBackendBucketCreate(d *schema.ResourceData, meta interface{}
func resourceComputeBackendBucketRead(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

url, err := replaceVars(d, config, "https://www.googleapis.com/compute/v1/projects/{{project}}/global/backendBuckets/{{name}}")
if err != nil {
return err
Expand Down Expand Up @@ -187,6 +181,10 @@ func resourceComputeBackendBucketRead(d *schema.ResourceData, meta interface{})
if err := d.Set("self_link", ConvertSelfLinkToV1(res["selfLink"].(string))); err != nil {
return fmt.Errorf("Error reading BackendBucket: %s", err)
}
project, err := getProject(d, config)
if err != nil {
return err
}
if err := d.Set("project", project); err != nil {
return fmt.Errorf("Error reading BackendBucket: %s", err)
}
Expand All @@ -197,11 +195,6 @@ func resourceComputeBackendBucketRead(d *schema.ResourceData, meta interface{})
func resourceComputeBackendBucketUpdate(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

obj := make(map[string]interface{})
bucketNameProp, err := expandComputeBackendBucketBucketName(d.Get("bucket_name"), d, config)
if err != nil {
Expand Down Expand Up @@ -240,6 +233,10 @@ func resourceComputeBackendBucketUpdate(d *schema.ResourceData, meta interface{}
return fmt.Errorf("Error updating BackendBucket %q: %s", d.Id(), err)
}

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
Expand All @@ -260,22 +257,22 @@ func resourceComputeBackendBucketUpdate(d *schema.ResourceData, meta interface{}
func resourceComputeBackendBucketDelete(d *schema.ResourceData, meta interface{}) error {
config := meta.(*Config)

project, err := getProject(d, config)
if err != nil {
return err
}

url, err := replaceVars(d, config, "https://www.googleapis.com/compute/v1/projects/{{project}}/global/backendBuckets/{{name}}")
if err != nil {
return err
}

var obj map[string]interface{}
log.Printf("[DEBUG] Deleting BackendBucket %q", d.Id())
res, err := sendRequest(config, "DELETE", url, nil)
res, err := sendRequest(config, "DELETE", url, obj)
if err != nil {
return handleNotFoundError(err, d, "BackendBucket")
}

project, err := getProject(d, config)
if err != nil {
return err
}
op := &compute.Operation{}
err = Convert(res, op)
if err != nil {
Expand Down
Loading

0 comments on commit 81420a2

Please sign in to comment.