Add eCloud VPC VPN Gateway management commands

cmd/ecloud/ecloud.go

@@ -13,7 +13,7 @@
 	"github.com/spf13/cobra"
 )
 
 func ECloudRootCmd(f factory.ClientFactory, fs afero.Fs) *cobra.Command {
 	cmd := &cobra.Command{
 		Use:   "ecloud",
 		Short: "Commands relating to eCloud service",
@@ -69,6 +69,7 @@
 		cmd.AddCommand(ecloudVPNProfileGroupRootCmd(f))
 		cmd.AddCommand(ecloudVPNServiceRootCmd(f))
 		cmd.AddCommand(ecloudVPNSessionRootCmd(f))
+		cmd.AddCommand(ecloudVPNGatewayRootCmd(f))
 		cmd.AddCommand(ecloudVolumeGroupRootCmd(f))
 		cmd.AddCommand(ecloudAffinityRuleRootCmd(f))
 		cmd.AddCommand(ecloudAffinityRuleMemberRootCmd(f))
@@ -111,18 +112,18 @@
 // GetKeyValueFromStringFlag returns a string map from given string flag. Expects format 'key=value'
 func GetKeyValueFromStringFlag(flag string) (key, value string, err error) {
 	if flag == "" {
 		return key, value, errors.New("Missing key/value")
 	}
 
 	parts := strings.Split(flag, "=")
 	if len(parts) < 2 || len(parts) > 2 {
 		return key, value, errors.New("Invalid format, expecting: key=value")
 	}
 	if parts[0] == "" {
 		return key, value, errors.New("Missing key")
 	}
 	if parts[1] == "" {
 		return key, value, errors.New("Missing value")
 	}
 
 	return parts[0], parts[1], nil
@@ -137,7 +138,7 @@
 				return (exists == false), nil
 			}
 
 			return false, fmt.Errorf("Failed to retrieve solution template [%s]: %s", templateName, err.Error())
 		}
 
 		return (exists == true), nil
@@ -153,7 +154,7 @@
 				return (exists == false), nil
 			}
 
 			return false, fmt.Errorf("Failed to retrieve pod template [%s]: %s", templateName, err.Error())
 		}
 
 		return (exists == true), nil
@@ -166,10 +167,10 @@
 	return func() (finished bool, err error) {
 		status, err := fn()
 		if err != nil {
 			return false, fmt.Errorf("Failed to retrieve status for resource: %s", err)
 		}
 		if status == ecloud.SyncStatusFailed {
 			return false, fmt.Errorf("Resource in [%s] state", ecloud.SyncStatusFailed.String())
 		}
 		if status == expectedStatus {
 			return true, nil
@@ -183,10 +184,10 @@
 	return func() (finished bool, err error) {
 		task, err := service.GetTask(taskID)
 		if err != nil {
 			return false, fmt.Errorf("Failed to retrieve task status: %s", err)
 		}
 		if task.Status == ecloud.TaskStatusFailed {
 			return false, fmt.Errorf("Task in [%s] state", ecloud.TaskStatusFailed)
 		}
 		if task.Status == expectedStatus {
 			return true, nil

cmd/ecloud/ecloud_vpngateway.go

@@ -0,0 +1,234 @@
+package ecloud
+
+import (
+	"errors"
+	"fmt"
+
+	"github.com/ans-group/cli/internal/pkg/factory"
+	"github.com/ans-group/cli/internal/pkg/helper"
+	"github.com/ans-group/cli/internal/pkg/output"
+	"github.com/ans-group/sdk-go/pkg/service/ecloud"
+	"github.com/spf13/cobra"
+)
+
+func ecloudVPNGatewayRootCmd(f factory.ClientFactory) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "vpngateway",
+		Short: "sub-commands relating to VPN gateways",
+	}
+
+	// Child commands
+	cmd.AddCommand(ecloudVPNGatewayUserRootCmd(f))
+	cmd.AddCommand(ecloudVPNGatewaySpecificationRootCmd(f))
+	cmd.AddCommand(ecloudVPNGatewayListCmd(f))
+	cmd.AddCommand(ecloudVPNGatewayShowCmd(f))
+	cmd.AddCommand(ecloudVPNGatewayCreateCmd(f))
+	cmd.AddCommand(ecloudVPNGatewayUpdateCmd(f))
+	cmd.AddCommand(ecloudVPNGatewayDeleteCmd(f))
+
+	return cmd
+}
+
+func ecloudVPNGatewayListCmd(f factory.ClientFactory) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:     "list",
+		Short:   "Lists VPN gateways",
+		Example: "ans ecloud vpngateway list",
+		RunE:    ecloudCobraRunEFunc(f, ecloudVPNGatewayList),
+	}
+
+	cmd.Flags().String("name", "", "VPN gateway name for filtering")
+
+	return cmd
+}
+
+func ecloudVPNGatewayList(service ecloud.ECloudService, cmd *cobra.Command, args []string) error {
+	params, err := helper.GetAPIRequestParametersFromFlags(cmd,
+		helper.NewStringFilterFlagOption("name", "name"),
+	)
+	if err != nil {
+		return err
+	}
+
+	gateways, err := service.GetVPNGateways(params)
+	if err != nil {
+		return fmt.Errorf("Error retrieving VPN gateways: %s", err)
+	}
+
+	return output.CommandOutput(cmd, OutputECloudVPNGatewaysProvider(gateways))
+}
+
+func ecloudVPNGatewayShowCmd(f factory.ClientFactory) *cobra.Command {
+	return &cobra.Command{
+		Use:     "show <gateway: id>...",
+		Short:   "Show details of a VPN gateway",
+		Example: "ans ecloud vpngateway show vpng-abcdef12",
+		Args: func(cmd *cobra.Command, args []string) error {
+			if len(args) < 1 {
+				return errors.New("Missing VPN gateway")
+			}
+
+			return nil
+		},
+		RunE: ecloudCobraRunEFunc(f, ecloudVPNGatewayShow),
+	}
+}
+
+func ecloudVPNGatewayShow(service ecloud.ECloudService, cmd *cobra.Command, args []string) error {
+	var vpnGateways []ecloud.VPNGateway
+	for _, arg := range args {
+		vpnGateway, err := service.GetVPNGateway(arg)
+		if err != nil {
+			output.OutputWithErrorLevelf("Error retrieving VPN gateway [%s]: %s", arg, err)
+			continue
+		}
+
+		vpnGateways = append(vpnGateways, vpnGateway)
+	}
+
+	return output.CommandOutput(cmd, OutputECloudVPNGatewaysProvider(vpnGateways))
+}
+
+func ecloudVPNGatewayCreateCmd(f factory.ClientFactory) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:     "create",
+		Short:   "Creates a VPN gateway",
+		Example: "ans ecloud vpngateway create --router rtr-abcdef12 --specification vpngs-abcdef12",
+		RunE:    ecloudCobraRunEFunc(f, ecloudVPNGatewayCreate),
+	}
+
+	// Setup flags
+	cmd.Flags().String("name", "", "Name of gateway")
+	cmd.Flags().String("router", "", "ID of router")
+	cmd.MarkFlagRequired("router")
+	cmd.Flags().String("specification", "", "ID of VPN gateway specification")
+	cmd.MarkFlagRequired("specification")
+	cmd.Flags().Bool("wait", false, "Specifies that the command should wait until the VPN gateway has been completely created")
+
+	return cmd
+}
+
+func ecloudVPNGatewayCreate(service ecloud.ECloudService, cmd *cobra.Command, args []string) error {
+	createRequest := ecloud.CreateVPNGatewayRequest{}
+	createRequest.Name, _ = cmd.Flags().GetString("name")
+	createRequest.RouterID, _ = cmd.Flags().GetString("router")
+	createRequest.SpecificationID, _ = cmd.Flags().GetString("specification")
+
+	taskRef, err := service.CreateVPNGateway(createRequest)
+	if err != nil {
+		return fmt.Errorf("Error creating VPN gateway: %s", err)
+	}
+
+	waitFlag, _ := cmd.Flags().GetBool("wait")
+	if waitFlag {
+		err := helper.WaitForCommand(TaskStatusWaitFunc(service, taskRef.TaskID, ecloud.TaskStatusComplete))
+		if err != nil {
+			return fmt.Errorf("Error waiting for VPN gateway task to complete: %s", err)
+		}
+	}
+
+	vpnGateway, err := service.GetVPNGateway(taskRef.ResourceID)
+	if err != nil {
+		return fmt.Errorf("Error retrieving new VPN gateway: %s", err)
+	}
+
+	return output.CommandOutput(cmd, OutputECloudVPNGatewaysProvider([]ecloud.VPNGateway{vpnGateway}))
+}
+
+func ecloudVPNGatewayUpdateCmd(f factory.ClientFactory) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:     "update <gateway: id>...",
+		Short:   "Updates a VPN gateway",
+		Long:    "Update the name of a VPN gateway",
+		Example: "ans ecloud vpngateway update vpng-abcdef12 --name \"my gateway\"",
+		Args: func(cmd *cobra.Command, args []string) error {
+			if len(args) < 1 {
+				return errors.New("Missing VPN gateway")
+			}
+
+			return nil
+		},
+		RunE: ecloudCobraRunEFunc(f, ecloudVPNGatewayUpdate),
+	}
+
+	cmd.Flags().String("name", "", "Name of gateway")
+	cmd.Flags().Bool("wait", false, "Specifies that the command should wait until the VPN gateway has been completely updated")
+
+	return cmd
+}
+
+func ecloudVPNGatewayUpdate(service ecloud.ECloudService, cmd *cobra.Command, args []string) error {
+	patchRequest := ecloud.PatchVPNGatewayRequest{}
+
+	if cmd.Flags().Changed("name") {
+		patchRequest.Name, _ = cmd.Flags().GetString("name")
+	}
+
+	var vpnGateways []ecloud.VPNGateway
+	for _, arg := range args {
+		task, err := service.PatchVPNGateway(arg, patchRequest)
+		if err != nil {
+			output.OutputWithErrorLevelf("Error updating VPN gateway [%s]: %s", arg, err)
+			continue
+		}
+
+		waitFlag, _ := cmd.Flags().GetBool("wait")
+		if waitFlag {
+			err := helper.WaitForCommand(TaskStatusWaitFunc(service, task.TaskID, ecloud.TaskStatusComplete))
+			if err != nil {
+				output.OutputWithErrorLevelf("Error waiting for task to complete for VPN gateway [%s]: %s", arg, err)
+				continue
+			}
+		}
+
+		vpnGateway, err := service.GetVPNGateway(arg)
+		if err != nil {
+			output.OutputWithErrorLevelf("Error retrieving updated VPN gateway [%s]: %s", arg, err)
+			continue
+		}
+
+		vpnGateways = append(vpnGateways, vpnGateway)
+	}
+
+	return output.CommandOutput(cmd, OutputECloudVPNGatewaysProvider(vpnGateways))
+}
+
+func ecloudVPNGatewayDeleteCmd(f factory.ClientFactory) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:     "delete <gateway: id>...",
+		Short:   "Removes a VPN gateway",
+		Example: "ans ecloud vpngateway delete vpng-abcdef12",
+		Args: func(cmd *cobra.Command, args []string) error {
+			if len(args) < 1 {
+				return errors.New("Missing VPN gateway")
+			}
+
+			return nil
+		},
+		RunE: ecloudCobraRunEFunc(f, ecloudVPNGatewayDelete),
+	}
+
+	cmd.Flags().Bool("wait", false, "Specifies that the command should wait until the VPN gateway has been completely removed")
+
+	return cmd
+}
+
+func ecloudVPNGatewayDelete(service ecloud.ECloudService, cmd *cobra.Command, args []string) error {
+	for _, arg := range args {
+		taskID, err := service.DeleteVPNGateway(arg)
+		if err != nil {
+			output.OutputWithErrorLevelf("Error removing VPN gateway [%s]: %s", arg, err)
+			continue
+		}
+
+		waitFlag, _ := cmd.Flags().GetBool("wait")
+		if waitFlag {
+			err := helper.WaitForCommand(TaskStatusWaitFunc(service, taskID, ecloud.TaskStatusComplete))
+			if err != nil {
+				output.OutputWithErrorLevelf("Error waiting for task to complete for VPN gateway [%s]: %s", arg, err)
+				continue
+			}
+		}
+	}
+	return nil
+}

cmd/ecloud/ecloud_vpngateway_specs.go

@@ -0,0 +1,85 @@
+package ecloud
+
+import (
+	"errors"
+	"fmt"
+
+	"github.com/ans-group/cli/internal/pkg/factory"
+	"github.com/ans-group/cli/internal/pkg/helper"
+	"github.com/ans-group/cli/internal/pkg/output"
+	"github.com/ans-group/sdk-go/pkg/service/ecloud"
+	"github.com/spf13/cobra"
+)
+
+func ecloudVPNGatewaySpecificationRootCmd(f factory.ClientFactory) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "spec",
+		Short: "sub-commands relating to VPN gateway specifications",
+	}
+
+	// Child commands
+	cmd.AddCommand(ecloudVPNGatewaySpecificationListCmd(f))
+	cmd.AddCommand(ecloudVPNGatewaySpecificationShowCmd(f))
+
+	return cmd
+}
+
+func ecloudVPNGatewaySpecificationListCmd(f factory.ClientFactory) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:     "list",
+		Short:   "Lists VPN gateway specifications",
+		Example: "ans ecloud vpngateway spec list",
+		RunE:    ecloudCobraRunEFunc(f, ecloudVPNGatewaySpecificationList),
+	}
+
+	cmd.Flags().String("name", "", "VPN gateway specification name for filtering")
+
+	return cmd
+}
+
+func ecloudVPNGatewaySpecificationList(service ecloud.ECloudService, cmd *cobra.Command, args []string) error {
+	params, err := helper.GetAPIRequestParametersFromFlags(cmd,
+		helper.NewStringFilterFlagOption("name", "name"),
+	)
+	if err != nil {
+		return err
+	}
+
+	specs, err := service.GetVPNGatewaySpecifications(params)
+	if err != nil {
+		return fmt.Errorf("Error retrieving VPN gateway specifications: %s", err)
+	}
+
+	return output.CommandOutput(cmd, OutputECloudVPNGatewaySpecificationsProvider(specs))
+}
+
+func ecloudVPNGatewaySpecificationShowCmd(f factory.ClientFactory) *cobra.Command {
+	return &cobra.Command{
+		Use:     "show <specification: id>...",
+		Short:   "Show details of a VPN gateway specification",
+		Example: "ans ecloud vpngateway spec show vpngs-abcdef12",
+		Args: func(cmd *cobra.Command, args []string) error {
+			if len(args) < 1 {
+				return errors.New("Missing VPN gateway specification")
+			}
+
+			return nil
+		},
+		RunE: ecloudCobraRunEFunc(f, ecloudVPNGatewaySpecificationShow),
+	}
+}
+
+func ecloudVPNGatewaySpecificationShow(service ecloud.ECloudService, cmd *cobra.Command, args []string) error {
+	var specs []ecloud.VPNGatewaySpecification
+	for _, arg := range args {
+		spec, err := service.GetVPNGatewaySpecification(arg)
+		if err != nil {
+			output.OutputWithErrorLevelf("Error retrieving VPN gateway specification [%s]: %s", arg, err)
+			continue
+		}
+
+		specs = append(specs, spec)
+	}
+
+	return output.CommandOutput(cmd, OutputECloudVPNGatewaySpecificationsProvider(specs))
+}