chore(namespace_filter): Remove namespace filter

cmd/dump/dump.go

@@ -1,12 +1,10 @@
 package dump
 
 import (
-	"context"
 	"os"
 
 	"github.com/clevyr/kubedb/internal/actions/dump"
 	"github.com/clevyr/kubedb/internal/config/flags"
-	"github.com/clevyr/kubedb/internal/config/namespace_filter"
 	"github.com/clevyr/kubedb/internal/consts"
 	"github.com/clevyr/kubedb/internal/util"
 	"github.com/spf13/cobra"
@@ -53,7 +51,6 @@ the generated filename might look like "` + dump.HelpFilename() + `"`,
 	flags.RemoteGzip(cmd)
 	flags.Spinner(cmd, &action.Spinner)
 
-	cmd.SetContext(namespace_filter.NewContext(context.Background(), namespace_filter.ReadOnly))
 	return cmd
 }
 

cmd/exec/exec.go

@@ -1,11 +1,8 @@
 package exec
 
 import (
-	"context"
-
 	"github.com/clevyr/kubedb/internal/actions/exec"
 	"github.com/clevyr/kubedb/internal/config/flags"
-	"github.com/clevyr/kubedb/internal/config/namespace_filter"
 	"github.com/clevyr/kubedb/internal/consts"
 	"github.com/clevyr/kubedb/internal/util"
 	"github.com/spf13/cobra"
@@ -32,7 +29,6 @@ func New() *cobra.Command {
 	flags.Password(cmd)
 	cmd.Flags().StringVarP(&action.Command, consts.CommandFlag, "c", "", "Run a single command and exit")
 
-	cmd.SetContext(namespace_filter.NewContext(context.Background(), namespace_filter.ReadWrite))
 	return cmd
 }
 

cmd/port_forward/port_forward.go

@@ -1,12 +1,10 @@
 package port_forward
 
 import (
-	"context"
 	"strconv"
 
 	"github.com/clevyr/kubedb/internal/actions/port_forward"
 	"github.com/clevyr/kubedb/internal/config/flags"
-	"github.com/clevyr/kubedb/internal/config/namespace_filter"
 	"github.com/clevyr/kubedb/internal/consts"
 	"github.com/clevyr/kubedb/internal/util"
 	"github.com/spf13/cobra"
@@ -57,7 +55,6 @@ func New() *cobra.Command {
 		panic(err)
 	}
 
-	cmd.SetContext(namespace_filter.NewContext(context.Background(), namespace_filter.ReadWrite))
 	return cmd
 }
 

cmd/restore/restore.go

@@ -1,14 +1,12 @@
 package restore
 
 import (
-	"context"
 	"errors"
 	"os"
 
 	"github.com/AlecAivazis/survey/v2"
 	"github.com/clevyr/kubedb/internal/actions/restore"
 	"github.com/clevyr/kubedb/internal/config/flags"
-	"github.com/clevyr/kubedb/internal/config/namespace_filter"
 	"github.com/clevyr/kubedb/internal/consts"
 	"github.com/clevyr/kubedb/internal/util"
 	"github.com/spf13/cobra"
@@ -55,7 +53,6 @@ Supported Input Filetypes:
 	flags.Spinner(cmd, &action.Spinner)
 	cmd.Flags().BoolVarP(&action.Force, consts.ForceFlag, "f", false, "Do not prompt before restore")
 
-	cmd.SetContext(namespace_filter.NewContext(context.Background(), namespace_filter.ReadWrite))
 	return cmd
 }
 

cmd/status/status.go

@@ -1,7 +1,6 @@
 package status
 
 import (
-	"context"
 	"errors"
 	"fmt"
 	"os"
@@ -10,7 +9,6 @@ import (
 
 	"github.com/clevyr/kubedb/internal/config"
 	"github.com/clevyr/kubedb/internal/config/flags"
-	"github.com/clevyr/kubedb/internal/config/namespace_filter"
 	"github.com/clevyr/kubedb/internal/database"
 	"github.com/clevyr/kubedb/internal/kubernetes"
 	"github.com/clevyr/kubedb/internal/util"
@@ -34,7 +32,6 @@ func New() *cobra.Command {
 	flags.Username(cmd)
 	flags.Password(cmd)
 
-	cmd.SetContext(namespace_filter.NewContext(context.Background(), namespace_filter.ReadOnly))
 	return cmd
 }
 

internal/config/flags/kubernetes.go

@@ -4,7 +4,6 @@ import (
 	"os"
 	"path/filepath"
 
-	"github.com/clevyr/kubedb/internal/config/namespace_filter"
 	"github.com/clevyr/kubedb/internal/consts"
 	"github.com/clevyr/kubedb/internal/kubernetes"
 	"github.com/spf13/cobra"
@@ -68,11 +67,8 @@ func Namespace(cmd *cobra.Command) {
 				return nil, cobra.ShellCompDirectiveError
 			}
 			names := make([]string, 0, len(namespaces.Items))
-			access := namespace_filter.NewFromContext(cmd.Context())
 			for _, namespace := range namespaces.Items {
-				if access.Match(namespace.Name) {
-					names = append(names, namespace.Name)
-				}
+				names = append(names, namespace.Name)
 			}
 			return names, cobra.ShellCompDirectiveNoFileComp
 		})

internal/consts/viper.go

@@ -1,17 +1,14 @@
 package consts
 
 const (
-	AnalyzeKey           = "restore.analyze"
-	SpinnerKey           = "spinner.name"
-	KubeconfigKey        = "kubernetes.kubeconfig"
-	JobPodLabelsKey      = "kubernetes.job-pod-labels"
-	NoJobKey             = "kubernetes.no-job"
-	LogLevelKey          = "log.level"
-	LogFormatKey         = "log.format"
-	LogRedactKey         = "log.redact"
-	RemoteGzipKey        = "remote-gzip"
-	NamespaceFilterKey   = "namespace.filter"
-	NamespaceFilterROKey = "namespace.ro"
-	NamespaceFilterRWKey = "namespace.rw"
-	PortForwardAddrKey   = "port-forward.address"
+	AnalyzeKey         = "restore.analyze"
+	SpinnerKey         = "spinner.name"
+	KubeconfigKey      = "kubernetes.kubeconfig"
+	JobPodLabelsKey    = "kubernetes.job-pod-labels"
+	NoJobKey           = "kubernetes.no-job"
+	LogLevelKey        = "log.level"
+	LogFormatKey       = "log.format"
+	LogRedactKey       = "log.redact"
+	RemoteGzipKey      = "remote-gzip"
+	PortForwardAddrKey = "port-forward.address"
 )

internal/util/cmd_setup.go

@@ -10,7 +10,6 @@ import (
 
 	"github.com/AlecAivazis/survey/v2"
 	"github.com/clevyr/kubedb/internal/config"
-	"github.com/clevyr/kubedb/internal/config/namespace_filter"
 	"github.com/clevyr/kubedb/internal/consts"
 	"github.com/clevyr/kubedb/internal/database"
 	"github.com/clevyr/kubedb/internal/kubernetes"
@@ -53,11 +52,6 @@ func DefaultSetup(cmd *cobra.Command, conf *config.Global, opts SetupOptions) (e
 	conf.Context = conf.Client.Context
 	conf.Namespace = conf.Client.Namespace
 
-	access := namespace_filter.NewFromContext(ctx)
-	if !access.Match(conf.Client.Namespace) {
-		return errors.New("The current action is disabled for namespace " + conf.Client.Namespace)
-	}
-
 	if _, err := conf.Client.Namespaces().Get(ctx, conf.Namespace, metav1.GetOptions{}); err != nil {
 		log.WithError(err).Warn("namespace may not exist")
 	}