CB-28588 Add new module to delete GCP database instances

Add new module to delete GCP database instances

Author: abd-khaliq

action/termination.go

@@ -48,6 +48,8 @@ func (a terminationAction) Execute(op types.OpType, filters []types.FilterType,
 					errors = deleteImages(provider, cloudItems)
 				case types.Alert:
 					errors = deleteAlerts(provider, cloudItems)
+				case types.Database:
+					errors = deleteDatabases(provider, cloudItems)
 				default:
 					panic(fmt.Sprintf("[TERMINATION] Operation on type %T is not allowed", t))
 				}
@@ -108,3 +110,12 @@ func deleteAlerts(provider types.CloudProvider, items []*types.CloudItem) []erro
 	}
 	return provider.DeleteAlerts(types.NewAlertContainer(alerts))
 }
+
+func deleteDatabases(provider types.CloudProvider, items []*types.CloudItem) []error {
+	var databases []*types.Database
+	for _, item := range items {
+		database := (*item).GetItem().(types.Database)
+		databases = append(databases, &database)
+	}
+	return provider.DeleteDatabases(types.NewDatabaseContainer(databases))
+}

action/termination_test.go

@@ -47,6 +47,10 @@ func (p *mockProvider) GetDatabases() ([]*types.Database, error) {
 	return nil, nil
 }
 
+func (p *mockProvider) DeleteDatabases(databases *types.DatabaseContainer) []error {
+	return nil
+}
+
 func (p *mockProvider) GetDisks() ([]*types.Disk, error) {
 	return nil, nil
 }

aws/aws.go

@@ -218,6 +218,10 @@ func (p awsProvider) GetDatabases() ([]*types.Database, error) {
 	return getDatabases(p.GetCloudType(), rdsClients, ctClients)
 }
 
+func (p awsProvider) DeleteDatabases(databases *types.DatabaseContainer) []error {
+	return []error{errors.New("[AWS] Deleting databases is not supported yet")}
+}
+
 func (p awsProvider) GetDisks() ([]*types.Disk, error) {
 	log.Debug("[AWS] Fetch volumes")
 	ec2Clients, _ := p.getEc2AndCTClientsByRegion()

azure/azure.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+
 	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
 	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/compute/armcompute/v6"
 	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/postgresql/armpostgresqlflexibleservers/v4"
@@ -481,6 +482,10 @@ func (p azureProvider) GetDatabases() ([]*types.Database, error) {
 	return databases, nil
 }
 
+func (p azureProvider) DeleteDatabases(databases *types.DatabaseContainer) []error {
+	return []error{errors.New("[AZURE] Deleting databases is not supported yet")}
+}
+
 func (p azureProvider) GetAlerts() ([]*types.Alert, error) {
 	return nil, errors.New("[AZURE] Getting alerts is not supported yet")
 }

gcp/gcp.go

@@ -791,6 +791,43 @@ func (p gcpProvider) GetDatabases() ([]*types.Database, error) {
 	return p.getDatabases(aggregator)
 }
 
+func (p gcpProvider) DeleteDatabases(databases *types.DatabaseContainer) []error {
+	gcpDatabases := databases.Get(types.GCP)
+	log.Debugf("[GCP] Deleting databases: %v", gcpDatabases)
+
+	wg := sync.WaitGroup{}
+	wg.Add(len(gcpDatabases))
+	errChan := make(chan error)
+
+	for _, database := range gcpDatabases {
+
+		go func(database *types.Database) {
+			defer wg.Done()
+
+			if ctx.DryRun {
+				log.Infof("[GCP] Dry-run set, db is not deleted: %s", database.Name)
+			} else {
+				err := p.doAndPollSqlCall(p.sqlClient.Instances.Delete(p.projectID, database.Name))
+				if err != nil {
+					log.Errorf("[GCP] Failed to delete db %s, err: %s", database.Name, err)
+					errChan <- err
+				}
+			}
+		}(database)
+	}
+
+	go func() {
+		wg.Wait()
+		close(errChan)
+	}()
+
+	var errs []error
+	for err := range errChan {
+		errs = append(errs, err)
+	}
+	return errs
+}
+
 type instancesListAggregator interface {
 	Do(...googleapi.CallOption) (*compute.InstanceAggregatedList, error)
 }

operation/common_test.go

@@ -89,6 +89,10 @@ func (p dummyProvider) GetDatabases() ([]*types.Database, error) {
 	return nil, nil
 }
 
+func (p dummyProvider) DeleteDatabases(databases *types.DatabaseContainer) []error {
+	return nil
+}
+
 func (p dummyProvider) GetDisks() ([]*types.Disk, error) {
 	return nil, nil
 }

types/cloud.go

@@ -35,6 +35,7 @@ type CloudProvider interface {
 	DeleteAlerts(*AlertContainer) []error
 	GetAccesses() ([]*Access, error)
 	GetDatabases() ([]*Database, error)
+	DeleteDatabases(*DatabaseContainer) []error
 	GetDisks() ([]*Disk, error)
 	DeleteDisks(*DiskContainer) []error
 	GetImages() ([]*Image, error)