| // Copyright (c) HashiCorp, Inc. |
| // SPDX-License-Identifier: MPL-2.0 |
| |
| // ---------------------------------------------------------------------------- |
| // |
| // *** AUTO GENERATED CODE *** Type: MMv1 *** |
| // |
| // ---------------------------------------------------------------------------- |
| // |
| // This file is automatically generated by Magic Modules and manual |
| // changes will be clobbered when the file is regenerated. |
| // |
| // Please read more about how to change this file in |
| // .github/CONTRIBUTING.md. |
| // |
| // ---------------------------------------------------------------------------- |
| |
| package gkeonprem |
| |
| import ( |
| "context" |
| "log" |
| "strings" |
| "testing" |
| |
| "github.com/hashicorp/terraform-provider-google-beta/google-beta/envvar" |
| "github.com/hashicorp/terraform-provider-google-beta/google-beta/sweeper" |
| "github.com/hashicorp/terraform-provider-google-beta/google-beta/tpgresource" |
| transport_tpg "github.com/hashicorp/terraform-provider-google-beta/google-beta/transport" |
| ) |
| |
| func init() { |
| sweeper.AddTestSweepers("GkeonpremVmwareNodePool", testSweepGkeonpremVmwareNodePool) |
| } |
| |
| // At the time of writing, the CI only passes us-central1 as the region |
| func testSweepGkeonpremVmwareNodePool(region string) error { |
| resourceName := "GkeonpremVmwareNodePool" |
| log.Printf("[INFO][SWEEPER_LOG] Starting sweeper for %s", resourceName) |
| |
| config, err := sweeper.SharedConfigForRegion(region) |
| if err != nil { |
| log.Printf("[INFO][SWEEPER_LOG] error getting shared config for region: %s", err) |
| return err |
| } |
| |
| err = config.LoadAndValidate(context.Background()) |
| if err != nil { |
| log.Printf("[INFO][SWEEPER_LOG] error loading: %s", err) |
| return err |
| } |
| |
| t := &testing.T{} |
| billingId := envvar.GetTestBillingAccountFromEnv(t) |
| |
| // Setup variables to replace in list template |
| d := &tpgresource.ResourceDataMock{ |
| FieldsInSchema: map[string]interface{}{ |
| "project": config.Project, |
| "region": region, |
| "location": region, |
| "zone": "-", |
| "billing_account": billingId, |
| }, |
| } |
| |
| listTemplate := strings.Split("https://gkeonprem.googleapis.com/v1/projects/{{project}}/locations/{{location}}/vmwareClusters/{{vmware_cluster}}/vmwareNodePools", "?")[0] |
| listUrl, err := tpgresource.ReplaceVars(d, config, listTemplate) |
| if err != nil { |
| log.Printf("[INFO][SWEEPER_LOG] error preparing sweeper list url: %s", err) |
| return nil |
| } |
| |
| res, err := transport_tpg.SendRequest(transport_tpg.SendRequestOptions{ |
| Config: config, |
| Method: "GET", |
| Project: config.Project, |
| RawURL: listUrl, |
| UserAgent: config.UserAgent, |
| }) |
| if err != nil { |
| log.Printf("[INFO][SWEEPER_LOG] Error in response from request %s: %s", listUrl, err) |
| return nil |
| } |
| |
| resourceList, ok := res["vmwareNodePools"] |
| if !ok { |
| log.Printf("[INFO][SWEEPER_LOG] Nothing found in response.") |
| return nil |
| } |
| |
| rl := resourceList.([]interface{}) |
| |
| log.Printf("[INFO][SWEEPER_LOG] Found %d items in %s list response.", len(rl), resourceName) |
| // Keep count of items that aren't sweepable for logging. |
| nonPrefixCount := 0 |
| for _, ri := range rl { |
| obj := ri.(map[string]interface{}) |
| if obj["name"] == nil { |
| log.Printf("[INFO][SWEEPER_LOG] %s resource name was nil", resourceName) |
| return nil |
| } |
| |
| name := tpgresource.GetResourceNameFromSelfLink(obj["name"].(string)) |
| // Skip resources that shouldn't be sweeped |
| if !sweeper.IsSweepableTestResource(name) { |
| nonPrefixCount++ |
| continue |
| } |
| |
| deleteTemplate := "https://gkeonprem.googleapis.com/v1/projects/{{project}}/locations/{{location}}/vmwareClusters/{{vmware_cluster}}/vmwareNodePools/{{name}}" |
| deleteUrl, err := tpgresource.ReplaceVars(d, config, deleteTemplate) |
| if err != nil { |
| log.Printf("[INFO][SWEEPER_LOG] error preparing delete url: %s", err) |
| return nil |
| } |
| deleteUrl = deleteUrl + name |
| |
| // Don't wait on operations as we may have a lot to delete |
| _, err = transport_tpg.SendRequest(transport_tpg.SendRequestOptions{ |
| Config: config, |
| Method: "DELETE", |
| Project: config.Project, |
| RawURL: deleteUrl, |
| UserAgent: config.UserAgent, |
| }) |
| if err != nil { |
| log.Printf("[INFO][SWEEPER_LOG] Error deleting for url %s : %s", deleteUrl, err) |
| } else { |
| log.Printf("[INFO][SWEEPER_LOG] Sent delete request for %s resource: %s", resourceName, name) |
| } |
| } |
| |
| if nonPrefixCount > 0 { |
| log.Printf("[INFO][SWEEPER_LOG] %d items were non-sweepable and skipped.", nonPrefixCount) |
| } |
| |
| return nil |
| } |