login.go

package openshift

import (
	"io"
	"io/ioutil"
	"os"
	"path/filepath"
	"strings"

	"github.com/golang/glog"
	"github.com/spf13/cobra"
	kclientcmd "k8s.io/client-go/tools/clientcmd"
	kclientcmdapi "k8s.io/client-go/tools/clientcmd/api"

	"github.com/openshift/origin/pkg/cmd/cli/cmd/login"
	"github.com/openshift/origin/pkg/cmd/cli/config"
	"github.com/openshift/origin/pkg/cmd/util/clientcmd"
)

// Login logs into the specified server using given credentials and CA file
func Login(username, password, server, configDir string, f *clientcmd.Factory, c *cobra.Command, out io.Writer) error {
	existingConfig, err := f.OpenShiftClientConfig().RawConfig()
	if err != nil {
		if !os.IsNotExist(err) {
			return err
		}
		existingConfig = *(kclientcmdapi.NewConfig())
	}
	adminConfig, err := kclientcmd.LoadFromFile(filepath.Join(configDir, "master", "admin.kubeconfig"))
	if err != nil {
		return err
	}
	for k := range adminConfig.AuthInfos {
		adminConfig.AuthInfos[k].LocationOfOrigin = ""
	}
	serverFound := false
	for k := range adminConfig.Clusters {
		adminConfig.Clusters[k].LocationOfOrigin = ""
		if adminConfig.Clusters[k].Server == server {
			serverFound = true
		}
	}
	if !serverFound {
		// Create a server entry and admin context for
		// local cluster
		for k := range adminConfig.Clusters {
			localCluster := *adminConfig.Clusters[k]
			localCluster.Server = server
			adminConfig.Clusters["local-cluster"] = &localCluster
			for u := range adminConfig.AuthInfos {
				if strings.HasPrefix(u, "system:admin") {
					context := kclientcmdapi.NewContext()
					context.Cluster = "local-cluster"
					context.AuthInfo = u
					context.Namespace = "default"
					adminConfig.Contexts["default/local-cluster/system:admin"] = context
				}
			}
			break
		}
	}
	newConfig, err := config.MergeConfig(existingConfig, *adminConfig)
	if err != nil {
		return err
	}
	output := ioutil.Discard
	if glog.V(1) {
		output = out
	}
	opts := &login.LoginOptions{
		Server:             server,
		Username:           username,
		Password:           password,
		Out:                output,
		StartingKubeConfig: newConfig,
		PathOptions:        config.NewPathOptions(c),
	}
	return login.RunLogin(nil, opts)
}