forked from openshift/origin
-
Notifications
You must be signed in to change notification settings - Fork 1
/
project.go
69 lines (59 loc) · 2 KB
/
project.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
package openshift
import (
"io"
"io/ioutil"
"k8s.io/apimachinery/pkg/api/errors"
kclientcmd "k8s.io/client-go/tools/clientcmd"
"k8s.io/kubernetes/pkg/kubectl/genericclioptions"
"github.com/openshift/origin/pkg/oc/cli/project"
"github.com/openshift/origin/pkg/oc/cli/requestproject"
"github.com/openshift/origin/pkg/oc/lib/kubeconfig"
projectclientinternal "github.com/openshift/origin/pkg/project/generated/internalclientset"
)
// createProject creates a project
func CreateProject(f genericclioptions.RESTClientGetter, name, display, desc, basecmd string, out io.Writer) error {
clientConfig, err := f.ToRESTConfig()
if err != nil {
return err
}
projectClient, err := projectclientinternal.NewForConfig(clientConfig)
if err != nil {
return err
}
pathOptions := kubeconfig.NewPathOptionsWithConfig("")
opt := &requestproject.RequestProjectOptions{
ProjectName: name,
DisplayName: display,
Description: desc,
Name: basecmd,
Client: projectClient.Project(),
ProjectOptions: &project.ProjectOptions{PathOptions: pathOptions},
IOStreams: genericclioptions.NewTestIOStreamsDiscard(),
}
err = opt.ProjectOptions.Complete(f, []string{})
if err != nil {
return err
}
err = opt.Run()
if err != nil {
if errors.IsAlreadyExists(err) {
return setCurrentProject(f, name, out)
}
return err
}
return nil
}
func setCurrentProject(f genericclioptions.RESTClientGetter, name string, out io.Writer) error {
pathOptions := kubeconfig.NewPathOptionsWithConfig("")
opt := &project.ProjectOptions{PathOptions: pathOptions, IOStreams: genericclioptions.IOStreams{Out: out, ErrOut: ioutil.Discard}}
opt.Complete(f, []string{name})
return opt.RunProject()
}
func LoggedInUserFactory() (genericclioptions.RESTClientGetter, error) {
cfg, err := kclientcmd.NewDefaultClientConfigLoadingRules().Load()
if err != nil {
return nil, err
}
defaultCfg := kclientcmd.NewDefaultClientConfig(*cfg, &kclientcmd.ConfigOverrides{})
return genericclioptions.NewTestConfigFlags().WithClientConfig(defaultCfg), nil
}