Add regular expression for filtering

cmd/purge/images/images.go

@@ -30,16 +30,16 @@ var Cmd = &cobra.Command{
 			return err
 		}
 
-		images, err := pvmclient.ImgClient.GetAll()
+		images, err := pvmclient.ImgClient.GetAllPurgeable(opt.Before, opt.Since, opt.Expr)
 		if err != nil {
 			return fmt.Errorf("failed to get the list of images: %v", err)
 		}
 		table := utils.NewTable()
 
-		table.Render(images.Images, []string{})
-		if !opt.DryRun && len(images.Images) != 0 {
+		table.Render(images, []string{"href", "specifications"})
+		if !opt.DryRun && len(images) != 0 {
 			if opt.NoPrompt || utils.AskYesOrNo(deletePromptMessage) {
-				for _, image := range images.Images {
+				for _, image := range images {
 					klog.Infof("Deleting the %s, and ID: %s", *image.Name, *image.ImageID)
 					err = pvmclient.ImgClient.Delete(*image.ImageID)
 					if err != nil {

cmd/purge/networks/networks.go

@@ -30,16 +30,16 @@ var Cmd = &cobra.Command{
 		}
 		klog.Infof("Purging the networks for the instance: %v", pvmclient.InstanceID)
 
-		networks, err := pvmclient.NetworkClient.GetAll()
+		networks, err := pvmclient.NetworkClient.GetAllPurgeable(opt.Before, opt.Since, opt.Expr)
 		if err != nil {
 			return fmt.Errorf("failed to get the list of networks: %v", err)
 		}
 		table := utils.NewTable()
 
-		table.Render(networks.Networks, []string{})
-		if !opt.DryRun && len(networks.Networks) != 0 {
+		table.Render(networks, []string{"href"})
+		if !opt.DryRun && len(networks) != 0 {
 			if opt.NoPrompt || utils.AskYesOrNo(deletePromptMessage) {
-				for _, network := range networks.Networks {
+				for _, network := range networks {
 					klog.Infof("Deleting the %s, and ID: %s", *network.Name, *network.NetworkID)
 					err = pvmclient.NetworkClient.Delete(*network.NetworkID)
 					if err != nil {

cmd/purge/purge.go

@@ -38,4 +38,5 @@ func init() {
 	Cmd.PersistentFlags().DurationVar(&pkg.Options.Before, "before", 0*time.Second, "Remove resources before mentioned duration(format: 99h99m00s), mutually exclusive with --since")
 	Cmd.PersistentFlags().BoolVar(&pkg.Options.NoPrompt, "no-prompt", false, "Show prompt before doing any destructive operations")
 	Cmd.PersistentFlags().BoolVar(&pkg.Options.IgnoreErrors, "ignore-errors", false, "Ignore any errors during the operations")
+	Cmd.PersistentFlags().StringVar(&pkg.Options.Expr, "regexp", "", "Regular Expressions for filtering the selection")
 }

cmd/purge/vms/vms.go

@@ -56,7 +56,7 @@ var Cmd = &cobra.Command{
 		})
 		tu.Table.Render()
 
-		instances, err := pvmclient.InstanceClient.GetAllPurgeable(pkg.Options.Before, pkg.Options.Since)
+		instances, err := pvmclient.InstanceClient.GetAllPurgeable(pkg.Options.Before, pkg.Options.Since, pkg.Options.Expr)
 		if err != nil {
 			return err
 		}

cmd/purge/volumes/volumes.go

@@ -32,7 +32,7 @@ var Cmd = &cobra.Command{
 		if err != nil {
 			return err
 		}
-		volumes, err := pvmclient.VolumeClient.GetAllPurgeableByLastUpdateDate(opt.Before, opt.Since)
+		volumes, err := pvmclient.VolumeClient.GetAllPurgeableByLastUpdateDate(opt.Before, opt.Since, opt.Expr)
 		if err != nil {
 			return fmt.Errorf("failed to get the list of volumes: %v", err)
 		}

pkg/client/image/image.go

@@ -6,6 +6,7 @@ import (
 	"github.com/IBM-Cloud/power-go-client/ibmpisession"
 	"github.com/IBM-Cloud/power-go-client/power/models"
 	"github.com/ppc64le-cloud/pvsadm/pkg"
+	"regexp"
 	"time"
 )
 
@@ -34,14 +35,19 @@ func (c *Client) Delete(id string) error {
 	return c.client.Delete(id, c.instanceID)
 }
 
-func (c *Client) GetAllPurgeable(before, since time.Duration) ([]*models.ImageReference, error) {
+func (c *Client) GetAllPurgeable(before, since time.Duration, expr string) ([]*models.ImageReference, error) {
 	images, err := c.GetAll()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get the list of instances: %v", err)
 	}
 
 	var candidates []*models.ImageReference
 	for _, image := range images.Images {
+		if expr != "" {
+			if r, _ := regexp.Compile(expr); !r.MatchString(*image.Name) {
+				continue
+			}
+		}
 		if !pkg.IsPurgeable(time.Time(*image.CreationDate), before, since) {
 			continue
 		}

pkg/client/instance/instance.go

@@ -6,6 +6,7 @@ import (
 	"github.com/IBM-Cloud/power-go-client/ibmpisession"
 	"github.com/IBM-Cloud/power-go-client/power/models"
 	"github.com/ppc64le-cloud/pvsadm/pkg"
+	"regexp"
 	"time"
 )
 
@@ -34,14 +35,19 @@ func (c *Client) Delete(id string) error {
 	return c.client.Delete(id, c.instanceID, pkg.TIMEOUT)
 }
 
-func (c *Client) GetAllPurgeable(before, since time.Duration) ([]*models.PVMInstanceReference, error) {
+func (c *Client) GetAllPurgeable(before, since time.Duration, expr string) ([]*models.PVMInstanceReference, error) {
 	instances, err := c.GetAll()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get the list of instances: %v", err)
 	}
 
 	var candidates []*models.PVMInstanceReference
 	for _, ins := range instances.PvmInstances {
+		if expr != "" {
+			if r, _ := regexp.Compile(expr); !r.MatchString(*ins.ServerName) {
+				continue
+			}
+		}
 		if !pkg.IsPurgeable(time.Time(ins.CreationDate), before, since) {
 			continue
 		}

pkg/client/network/network.go

@@ -9,6 +9,7 @@ import (
 	"github.com/IBM-Cloud/power-go-client/power/models"
 	"github.com/ppc64le-cloud/pvsadm/pkg"
 	"k8s.io/klog/v2"
+	"regexp"
 	"time"
 )
 
@@ -51,14 +52,19 @@ func (c *Client) Delete(id string) error {
 	return c.client.Delete(id, c.instanceID, pkg.TIMEOUT)
 }
 
-func (c *Client) GetAllPurgeable(before, since time.Duration) ([]*models.NetworkReference, error) {
+func (c *Client) GetAllPurgeable(before, since time.Duration, expr string) ([]*models.NetworkReference, error) {
 	networks, err := c.GetAll()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get the list of instances: %v", err)
 	}
 
 	var candidates []*models.NetworkReference
 	for _, network := range networks.Networks {
+		if expr != "" {
+			if r, _ := regexp.Compile(expr); !r.MatchString(*network.Name) {
+				continue
+			}
+		}
 		candidates = append(candidates, network)
 	}
 	return candidates, nil

pkg/client/volume/volume.go

@@ -11,6 +11,7 @@ import (
 	"github.com/ppc64le-cloud/pvsadm/pkg"
 	"k8s.io/klog/v2"
 	"reflect"
+	"regexp"
 	"time"
 )
 
@@ -47,14 +48,19 @@ func (c *Client) GetAll() (*models.Volumes, error) {
 	return resp.Payload, nil
 }
 
-func (c *Client) getAllPurgeable(field string, before, since time.Duration) ([]*models.VolumeReference, error) {
+func (c *Client) getAllPurgeable(field string, before, since time.Duration, expr string) ([]*models.VolumeReference, error) {
 	volumes, err := c.GetAll()
 	if err != nil {
 		return nil, fmt.Errorf("failed to get the list of volumes: %v", err)
 	}
 
 	var candidates []*models.VolumeReference
 	for _, vol := range volumes.Volumes {
+		if expr != "" {
+			if r, _ := regexp.Compile(expr); !r.MatchString(*vol.Name) {
+				continue
+			}
+		}
 		r := reflect.ValueOf(vol)
 		f := reflect.Indirect(r).FieldByName(field)
 		fieldValue := f.Interface()
@@ -67,6 +73,6 @@ func (c *Client) getAllPurgeable(field string, before, since time.Duration) ([]*
 }
 
 // Returns all the Purgeable volumes by Last Update Date
-func (c *Client) GetAllPurgeableByLastUpdateDate(before, since time.Duration) ([]*models.VolumeReference, error) {
-	return c.getAllPurgeable("LastUpdateDate", before, since)
+func (c *Client) GetAllPurgeableByLastUpdateDate(before, since time.Duration, expr string) ([]*models.VolumeReference, error) {
+	return c.getAllPurgeable("LastUpdateDate", before, since, expr)
 }

pkg/options.go

@@ -17,4 +17,5 @@ type options struct {
 	NoPrompt     bool
 	IgnoreErrors bool
 	AuditFile    string
+	Expr         string
 }