Added selector filtering

Signed-off-by: Dmitry Chepurovskiy <dm3ch@dm3ch.net>

pkg/action/list.go

@@ -20,6 +20,8 @@ import (
 	"path"
 	"regexp"
 
+	"k8s.io/apimachinery/pkg/labels"
+
 	"helm.sh/helm/v3/pkg/release"
 	"helm.sh/helm/v3/pkg/releaseutil"
 )
@@ -152,6 +154,11 @@ func (l *List) Run() ([]*release.Release, error) {
 		}
 	}
 
+	selectorObj, err := labels.Parse(l.Selector)
+	if err != nil {
+		return nil, err
+	}
+
 	results, err := l.cfg.Releases.List(func(rel *release.Release) bool {
 		// Skip anything that the mask doesn't cover
 		currentStatus := l.StateMask.FromName(rel.Info.Status.String())
@@ -163,6 +170,12 @@ func (l *List) Run() ([]*release.Release, error) {
 		if filter != nil && !filter.MatchString(rel.Name) {
 			return false
 		}
+
+		// Skip anything that doesn't match the selector
+		if ! selectorObj.Matches(labels.Set(rel.Labels)) {
+			return false
+		}
+		
 		return true
 	})
 

pkg/storage/driver/cfgmaps.go

@@ -105,8 +105,10 @@ func (cfgmaps *ConfigMaps) List(filter func(*rspb.Release) bool) ([]*rspb.Releas
 			cfgmaps.Log("list: failed to decode release: %v: %s", item, err)
 			continue
 		}
+
+		rls.Labels = item.ObjectMeta.Labels
+
 		if filter(rls) {
-			rls.Labels = item.ObjectMeta.Labels
 			results = append(results, rls)
 		}
 	}

pkg/storage/driver/secrets.go

@@ -97,8 +97,10 @@ func (secrets *Secrets) List(filter func(*rspb.Release) bool) ([]*rspb.Release,
 			secrets.Log("list: failed to decode release: %v: %s", item, err)
 			continue
 		}
+		
+		rls.Labels = item.ObjectMeta.Labels
+
 		if filter(rls) {
-			rls.Labels = item.ObjectMeta.Labels
 			results = append(results, rls)
 		}
 	}