Added sweeper for bigtable instances (#4806) (#3276)

Signed-off-by: Modular Magician <[email protected]>

Author: modular-magician

.changelog/4806.txt

@@ -0,0 +1,3 @@
+```release-note:none
+
+```

google-beta/resource_bigtable_instance_sweeper_test.go

@@ -0,0 +1,83 @@
+package google
+
+import (
+	"context"
+	"log"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+)
+
+// This will sweep GCE Disk resources
+func init() {
+	resource.AddTestSweepers("BigtableInstance", &resource.Sweeper{
+		Name: "BigtableInstance",
+		F:    testSweepBigtableInstance,
+	})
+}
+
+// At the time of writing, the CI only passes us-central1 as the region
+// We don't have a way to filter the list by zone, and it's not clear it's worth the
+// effort as we only create within us-central1.
+func testSweepBigtableInstance(region string) error {
+	resourceName := "BigtableInstance"
+	log.Printf("[INFO][SWEEPER_LOG] Starting sweeper for %s", resourceName)
+
+	config, err := 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
+	}
+	servicesUrl := "https://bigtableadmin.googleapis.com/v2/projects/" + config.Project + "/instances"
+	res, err := sendRequest(config, "GET", config.Project, servicesUrl, config.userAgent, nil)
+	if err != nil {
+		log.Printf("[INFO][SWEEPER_LOG] Error in response from request %s: %s", servicesUrl, err)
+		return nil
+	}
+
+	resourceList, ok := res["instances"]
+	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)
+	// Count items that weren't sweeped.
+	nonPrefixCount := 0
+	for _, ri := range rl {
+		obj := ri.(map[string]interface{})
+		if obj["name"] == nil {
+			log.Printf("[INFO][SWEEPER_LOG] %s resource id was nil", resourceName)
+			return nil
+		}
+
+		id := obj["displayName"].(string)
+		// Increment count and skip if resource is not sweepable.
+		if !isSweepableTestResource(id) {
+			nonPrefixCount++
+			continue
+		}
+
+		deleteUrl := servicesUrl + "/" + id
+		// Don't wait on operations as we may have a lot to delete
+		_, err = sendRequest(config, "DELETE", config.Project, deleteUrl, config.userAgent, nil)
+		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, id)
+		}
+	}
+
+	if nonPrefixCount > 0 {
+		log.Printf("[INFO][SWEEPER_LOG] %d items without tf-test prefix remain.", nonPrefixCount)
+	}
+
+	return nil
+}