added endpoint deletion

cmd/dbaas_external_endpoint_delete.go

@@ -0,0 +1,83 @@
+package cmd
+
+import (
+	"fmt"
+
+	"github.com/exoscale/cli/pkg/account"
+	"github.com/exoscale/cli/pkg/globalstate"
+	v3 "github.com/exoscale/egoscale/v3"
+	"github.com/spf13/cobra"
+)
+
+type dbaasExternalEndpointDeleteCmd struct {
+	cliCommandSettings `cli-cmd:"-"`
+
+	_ bool `cli-cmd:"delete"`
+
+	Type       string `cli-arg:"#"`
+	EndpointID string `cli-arg:"#"`
+}
+
+func (c *dbaasExternalEndpointDeleteCmd) cmdAliases() []string {
+	return gDeleteAlias
+}
+
+func (c *dbaasExternalEndpointDeleteCmd) cmdLong() string {
+	return "Delete a DBaaS external endpoint"
+}
+
+func (c *dbaasExternalEndpointDeleteCmd) cmdShort() string {
+	return "Delete a DBaaS external endpoint"
+}
+
+func (c *dbaasExternalEndpointDeleteCmd) cmdPreRun(cmd *cobra.Command, args []string) error {
+	return cliCommandDefaultPreRun(c, cmd, args)
+}
+
+func (c *dbaasExternalEndpointDeleteCmd) cmdRun(cmd *cobra.Command, args []string) error {
+
+	ctx := gContext
+
+	client, err := switchClientZoneV3(ctx, globalstate.EgoscaleV3Client, v3.ZoneName(account.CurrentAccount.DefaultZone))
+	if err != nil {
+		return err
+	}
+
+	endpointUUID, err := v3.ParseUUID(c.EndpointID)
+	if err != nil {
+		return fmt.Errorf("invalid endpoint ID: %w", err)
+	}
+
+	var op *v3.Operation
+	var errOp error
+	switch c.Type {
+	case "datadog":
+		op, errOp = client.DeleteDBAASExternalEndpointDatadog(ctx, endpointUUID)
+	case "opensearch":
+		op, errOp = client.DeleteDBAASExternalEndpointOpensearch(ctx, endpointUUID)
+	case "elasticsearch":
+		op, errOp = client.DeleteDBAASExternalEndpointElasticsearch(ctx, endpointUUID)
+	case "prometheus":
+		op, errOp = client.DeleteDBAASExternalEndpointPrometheus(ctx, endpointUUID)
+	case "rsyslog":
+		op, errOp = client.DeleteDBAASExternalEndpointRsyslog(ctx, endpointUUID)
+	default:
+		return fmt.Errorf("unsupported external endpoint type %q", c.Type)
+	}
+
+	if errOp != nil {
+		return errOp
+	}
+
+	decorateAsyncOperation(fmt.Sprintf("Deleting external endpoint %s %s", c.Type, endpointUUID), func() {
+		_, err = client.Wait(ctx, op, v3.OperationStateSuccess)
+	})
+
+	return err
+}
+
+func init() {
+	cobra.CheckErr(registerCLICommand(dbaasExternalEndpointCmd, &dbaasExternalEndpointDeleteCmd{
+		cliCommandSettings: defaultCLICmdSettings(),
+	}))
+}