Add environment variables support, if set

1. KUBECONFIG will be used by default as the part
2. CODEFRESH_TOKEN will be used by default

Author: olegs-codefresh

cli.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"errors"
 	"fmt"
 	"os"
 
@@ -16,20 +17,41 @@ func setupCli() *cli.App {
 	return app
 }
 
+var (
+	codefreshJwt   string
+	kubeConfigPath string
+)
+
 func setupCommands(app *cli.App) {
 	app.Commands = []cli.Command{
 		{
 			Name:        "create",
 			Description: "Create clusters in Codefresh",
 			Action:      create,
+			Before: func(c *cli.Context) error {
+				jwtFromOsEnv := os.Getenv("CODEFRESH_TOKEN")
+				if jwtFromOsEnv != "" {
+					c.Set("token", jwtFromOsEnv)
+				}
+				if !c.IsSet("token") {
+					fmt.Printf("not set")
+					return errors.New("--token nigther CODEFREHS_TOKEN is set")
+				}
+				return nil
+			},
 			Flags: []cli.Flag{
 				cli.StringFlag{
-					Name: "token",
+					Name:        "token",
+					Usage:       "Codefresh JWT token",
+					EnvVar:      "CODEFRESH_TOKEN",
+					Destination: &codefreshJwt,
 				},
 				cli.StringFlag{
-					Name:  "config",
-					Usage: "Kubernetes config file to be used as input",
-					Value: fmt.Sprintf("%s/.kube/config", os.Getenv("HOME")),
+					Name:        "config",
+					Usage:       "Kubernetes config file to be used as input",
+					Value:       fmt.Sprintf("%s/.kube/config", os.Getenv("HOME")),
+					EnvVar:      "KUBECONFIG",
+					Destination: &kubeConfigPath,
 				},
 			},
 		},

create-clusters.go

@@ -29,9 +29,7 @@ func init() {
 }
 
 func create(cli *cli.Context) {
-	pathToKubeConfig := cli.String("config")
-	jwt := cli.String("token")
-	cnf := clientcmd.GetConfigFromFileOrDie(pathToKubeConfig)
+	cnf := clientcmd.GetConfigFromFileOrDie(kubeConfigPath)
 	c := *cnf
 	override := clientcmd.ConfigOverrides{
 		ClusterInfo: api.Cluster{
@@ -80,7 +78,7 @@ func create(cli *cli.Context) {
 		fmt.Println("Found secret")
 
 		fmt.Println("Creating cluster in Codefresh")
-		body, e := addCluser(clientCnf.Host, contextName, secret.Data["token"], secret.Data["ca.crt"], jwt)
+		body, e := addCluser(clientCnf.Host, contextName, secret.Data["token"], secret.Data["ca.crt"])
 		if e != nil {
 			fmt.Println("Error!!")
 			fmt.Println(e)
@@ -93,7 +91,7 @@ func create(cli *cli.Context) {
 	}
 }
 
-func addCluser(host string, contextName string, token []byte, crt []byte, jwt string) ([]byte, error) {
+func addCluser(host string, contextName string, token []byte, crt []byte) ([]byte, error) {
 	url := baseCodefreshURL + "api/clusters/local/cluster"
 	payload := &requestPayload{
 		Type:                "sat",
@@ -105,15 +103,15 @@ func addCluser(host string, contextName string, token []byte, crt []byte, jwt st
 	}
 	mar, _ := json.Marshal(payload)
 	p := strings.NewReader(string(mar))
-	err := testConnection(payload, jwt)
+	err := testConnection(payload)
 	if err != nil {
 		return nil, err
 	}
 	req, err := http.NewRequest("POST", url, p)
 	if err != nil {
 		return nil, err
 	}
-	req.Header.Add("X-Access-Token", jwt)
+	req.Header.Add("X-Access-Token", codefreshJwt)
 	req.Header.Add("content-type", "application/json")
 	res, err := http.DefaultClient.Do(req)
 	if err != nil {
@@ -127,15 +125,15 @@ func addCluser(host string, contextName string, token []byte, crt []byte, jwt st
 	return body, nil
 }
 
-func testConnection(payload *requestPayload, jwt string) error {
+func testConnection(payload *requestPayload) error {
 	url := baseCodefreshURL + "api/kubernetes/test"
 	mar, _ := json.Marshal(payload)
 	p := strings.NewReader(string(mar))
 	req, err := http.NewRequest("POST", url, p)
 	if err != nil {
 		return err
 	}
-	req.Header.Add("X-Access-Token", jwt)
+	req.Header.Add("X-Access-Token", codefreshJwt)
 	req.Header.Add("content-type", "application/json")
 	res, err := http.DefaultClient.Do(req)
 	if err != nil {