Log warning if Community License is used with non-demo namespace (#136)

/cherry-pick

Signed-off-by: 1gtm <1gtm@appscode.com>

Author: 1gtm

go.mod

@@ -18,7 +18,7 @@ require (
 	k8s.io/client-go v0.21.1
 	k8s.io/klog/v2 v2.8.0
 	k8s.io/kubectl v0.21.1
-	kmodules.xyz/client-go v0.0.0-20210909114628-15cac6c74063
+	kmodules.xyz/client-go v0.0.0-20210921150324-f005c6dfcb32
 	kmodules.xyz/custom-resources v0.0.0-20210829135624-c63be82e13c0 // indirect
 	kmodules.xyz/objectstore-api v0.0.0-20210829122106-d39859fc2d56
 	kmodules.xyz/offshoot-api v0.0.0-20210804100837-d0388be3e60d

go.sum

@@ -1144,8 +1144,8 @@ kmodules.xyz/client-go v0.0.0-20210715065708-d4f0cc74ead1/go.mod h1:E/vGngai00Ut
 kmodules.xyz/client-go v0.0.0-20210719120358-dd0503cf99cf/go.mod h1:E/vGngai00UtVwP8R4PWpPUBF/EZa6Ub9WS5+tVcs4M=
 kmodules.xyz/client-go v0.0.0-20210822203828-5e9cebbf1dfa/go.mod h1:0gkPeALtYjB27OHt4rd6+ZmMgoVTHVLtEJQeU23/gtA=
 kmodules.xyz/client-go v0.0.0-20210827153326-54ead9c6225f/go.mod h1:0gkPeALtYjB27OHt4rd6+ZmMgoVTHVLtEJQeU23/gtA=
-kmodules.xyz/client-go v0.0.0-20210909114628-15cac6c74063 h1:u+/fmk4N1LsxeCU7q7vnNgaADK73UeyNWKzNtjFe3Bs=
-kmodules.xyz/client-go v0.0.0-20210909114628-15cac6c74063/go.mod h1:0gkPeALtYjB27OHt4rd6+ZmMgoVTHVLtEJQeU23/gtA=
+kmodules.xyz/client-go v0.0.0-20210921150324-f005c6dfcb32 h1:ZXVJStHHjppRoaUw5JQ5KzMjK+EiY1GkcPigPHfkvSg=
+kmodules.xyz/client-go v0.0.0-20210921150324-f005c6dfcb32/go.mod h1:0gkPeALtYjB27OHt4rd6+ZmMgoVTHVLtEJQeU23/gtA=
 kmodules.xyz/constants v0.0.0-20210218100002-2c304bfda278/go.mod h1:DbiFk1bJ1KEO94t1SlAn7tzc+Zz95rSXgyUKa2nzPmY=
 kmodules.xyz/crd-schema-fuzz v0.0.0-20210618002152-fae23aef5fb4/go.mod h1:IIkUctlfoptoci0BOrsUf8ya+MOG5uaeh1PE4uzaIbA=
 kmodules.xyz/custom-resources v0.0.0-20210618003440-c6bb400da153/go.mod h1:/NLuNSf299U0XVuNEh2swtw3EczWFRL3Sx24WhNoWCM=

vendor/kmodules.xyz/client-go/tools/exec/lib.go

@@ -19,6 +19,7 @@ package exec
 import (
 	"bytes"
 	"context"
+	"errors"
 	"fmt"
 	"net/http"
 	"strings"
@@ -32,9 +33,12 @@ import (
 	"k8s.io/client-go/tools/remotecommand"
 )
 
+var NotRunning = errors.New("container not running")
+
 type Options struct {
 	core.PodExecOptions
 	remotecommand.StreamOptions
+	CheckForRunningContainer bool
 }
 
 func Container(container string) func(*Options) {
@@ -49,6 +53,12 @@ func Command(cmd ...string) func(*Options) {
 	}
 }
 
+func CheckForRunningContainer(check bool) func(*Options) {
+	return func(opts *Options) {
+		opts.CheckForRunningContainer = check
+	}
+}
+
 func Input(in string) func(*Options) {
 	return func(opts *Options) {
 		opts.PodExecOptions.Stdin = true
@@ -102,6 +112,23 @@ func execIntoPod(config *rest.Config, kc kubernetes.Interface, pod *core.Pod, op
 		option(opts)
 	}
 
+	if opts.CheckForRunningContainer {
+		for _, status := range pod.Status.ContainerStatuses {
+			if status.Name == opts.PodExecOptions.Container {
+				if status.State.Running == nil {
+					return "", NotRunning
+				}
+			}
+		}
+		for _, status := range pod.Status.InitContainerStatuses {
+			if status.Name == opts.PodExecOptions.Container {
+				if status.State.Running == nil {
+					return "", NotRunning
+				}
+			}
+		}
+	}
+
 	req := kc.CoreV1().RESTClient().Post().
 		Resource("pods").
 		Name(pod.Name).
@@ -115,14 +142,12 @@ func execIntoPod(config *rest.Config, kc kubernetes.Interface, pod *core.Pod, op
 	}
 
 	err = exec.Stream(opts.StreamOptions)
-
 	if err != nil {
 		return "", fmt.Errorf("could not execute: %v", err)
 	}
 
 	if execErr.Len() > 0 {
 		return "", fmt.Errorf("stderr: %v", execErr.String())
 	}
-
 	return execOut.String(), nil
 }

vendor/modules.txt

@@ -659,7 +659,7 @@ k8s.io/utils/integer
 k8s.io/utils/io
 k8s.io/utils/pointer
 k8s.io/utils/trace
-# kmodules.xyz/client-go v0.0.0-20210909114628-15cac6c74063
+# kmodules.xyz/client-go v0.0.0-20210921150324-f005c6dfcb32
 ## explicit
 kmodules.xyz/client-go
 kmodules.xyz/client-go/api/v1