create_docker_auth.go

package cmd

import (
	b64 "encoding/base64"
	"encoding/json"
	"github.com/jenkins-x/jx/pkg/jx/cmd/templates"
	"github.com/jenkins-x/jx/pkg/util"
	"github.com/spf13/cobra"
	"gopkg.in/AlecAivazis/survey.v1"
	"io"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

const (
	username = "user"
	host     = "host"
)

type Config struct {
	Auths map[string]*Auth `json:"auths,omitempty"`
}

type Auth struct {
	Auth  string `json:"auth,omitempty"`
	Email string `json:"email,omitempty"`
}

var (
	createDockerAuthLong = templates.LongDesc(`
		Creates/updates an entry for secret in the config.json for a given user, host
`)

	createDockerAuthExample = templates.Examples(`
		# Create/update docker auth entry in the config.json file
		jx create auth --host "foo.private.docker.registry" --user "foo" --secret "FooDockerHubToken" --email "fakeemail@gmail.com"
	`)
)

// CreateDockerAuthOptions the options for the create docker auth command
type CreateDockerAuthOptions struct {
	CreateOptions

	Host   string
	User   string
	Secret string
	Email  string
}

// NewCmdCreateIssue creates a command object for the "create" command
func NewCmdCreateDockerAuth(f Factory, out io.Writer, errOut io.Writer) *cobra.Command {
	options := &CreateDockerAuthOptions{
		CreateOptions: CreateOptions{
			CommonOptions: CommonOptions{
				Factory: f,
				Out:     out,
				Err:     errOut,
			},
		},
	}

	cmd := &cobra.Command{
		Use:     "docker auth",
		Short:   "Create/update docker auth for a given host and user in the config.json file",
		Long:    createDockerAuthLong,
		Example: createDockerAuthExample,
		Run: func(cmd *cobra.Command, args []string) {
			options.Cmd = cmd
			options.Args = args
			err := options.Run()
			CheckErr(err)
		},
	}

	cmd.Flags().StringVarP(&options.Host, host, "h", "", "The docker host")
	cmd.Flags().StringVarP(&options.User, username, "u", "", "The user to associate auth component of config.json")
	cmd.Flags().StringVarP(&options.Secret, "secret", "s", "", "The secret to associate auth component of config.json")
	cmd.Flags().StringVarP(&options.Secret, "email", "e", "", "The email to associate auth component of config.json")
	options.addCommonFlags(cmd)
	return cmd
}

// Run implements the command
func (o *CreateDockerAuthOptions) Run() error {
	if o.Host == "" {
		return util.MissingOption(host)
	}
	if o.User == "" {
		return util.MissingOption(username)
	}
	secret := o.Secret
	if secret == "" {
		prompt := &survey.Password{
			Message: "Please provide secret for the host: " + o.Host + "  and user: " + o.User,
		}
		survey.AskOne(prompt, &secret, nil)
	}
	email := o.Email
	if email == "" {
		prompt := &survey.Input{
			Message: "Please provide email ID for the host: " + o.Host + "  and user: " + o.User,
		}
		survey.AskOne(prompt, &secret, nil)
	}
	kubeClient, currentNs, err := o.KubeClient()
	if err != nil {
		return err
	}
	secretFromConfig, err := kubeClient.CoreV1().Secrets(currentNs).Get("jenkins-docker-cfg", metav1.GetOptions{})
	if err != nil {
		return nil
	}
	dockerConfig := &Config{}
	err = json.Unmarshal(secretFromConfig.Data["config.json"], dockerConfig)
	if err != nil {
		return err
	}
	foundAuth := false
	for k, v := range dockerConfig.Auths {
		if util.StringMatchesPattern(k, o.Host) {
			v.Auth = b64.StdEncoding.EncodeToString([]byte(o.User + ":" + o.Secret))
			v.Email = email
			foundAuth = true
			break
		}
	}
	if foundAuth != true {
		newConfigData := &Auth{}
		newConfigData.Auth = b64.StdEncoding.EncodeToString([]byte(o.User + ":" + o.Secret))
		newConfigData.Email = email
		dockerConfig.Auths[o.Host] = newConfigData
	}
	secretFromConfig.Data["config.json"], err = json.Marshal(dockerConfig)
	if err != nil {
		return err
	}
	kubeClient.CoreV1().Secrets(currentNs).Update(secretFromConfig)
	return nil
}