-
Notifications
You must be signed in to change notification settings - Fork 1
/
create_git_user.go
137 lines (118 loc) · 3.56 KB
/
create_git_user.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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
package cmd
import (
"fmt"
"io"
"time"
"github.com/jenkins-x/jx/pkg/jx/cmd/templates"
"github.com/jenkins-x/jx/pkg/kube"
"github.com/jenkins-x/jx/pkg/log"
"github.com/jenkins-x/jx/pkg/util"
"github.com/spf13/cobra"
"gopkg.in/AlecAivazis/survey.v1/terminal"
)
var (
create_git_user_long = templates.LongDesc(`
Creates a new user for a Git Server. Only supported for Gitea so far
`)
create_git_user_example = templates.Examples(`
# Creates a new user in the local Gitea server
jx create git user -n local someUserName -p somepassword -e foo@bar.com
`)
)
// CreateGitUserOptions the command line options for the command
type CreateGitUserOptions struct {
CreateOptions
ServerFlags ServerFlags
Username string
Password string
ApiToken string
Email string
IsAdmin bool
}
// NewCmdCreateGitUser creates a command
func NewCmdCreateGitUser(f Factory, in terminal.FileReader, out terminal.FileWriter, errOut io.Writer) *cobra.Command {
options := &CreateGitUserOptions{
CreateOptions: CreateOptions{
CommonOptions: CommonOptions{
Factory: f,
In: in,
Out: out,
Err: errOut,
},
},
}
cmd := &cobra.Command{
Use: "user [username]",
Short: "Adds a new user to the Git server",
Long: create_git_user_long,
Example: create_git_user_example,
Run: func(cmd *cobra.Command, args []string) {
options.Cmd = cmd
options.Args = args
err := options.Run()
CheckErr(err)
},
}
options.addCommonFlags(cmd)
options.ServerFlags.addGitServerFlags(cmd)
cmd.Flags().StringVarP(&options.ApiToken, "api-token", "t", "", "The API Token for the user")
cmd.Flags().StringVarP(&options.Password, "password", "p", "", "The User password to try automatically create a new API Token")
cmd.Flags().StringVarP(&options.Email, "email", "e", "", "The User email address")
cmd.Flags().BoolVarP(&options.IsAdmin, "admin", "a", false, "Whether the user is an admin user")
return cmd
}
// Run implements the command
func (o *CreateGitUserOptions) Run() error {
args := o.Args
if len(args) > 0 {
o.Username = args[0]
}
if len(args) > 1 {
o.ApiToken = args[1]
}
authConfigSvc, err := o.CreateGitAuthConfigService()
if err != nil {
return err
}
config := authConfigSvc.Config()
server, err := o.findGitServer(config, &o.ServerFlags)
if err != nil {
return err
}
// TODO add the API thingy...
if o.Username == "" {
return fmt.Errorf("No Username specified")
}
if o.Password == "" && o.ApiToken == "" {
return fmt.Errorf("No password or ApiToken specified")
}
client, ns, err := o.KubeClient()
if err != nil {
return err
}
deploymentName := "gitea-gitea"
log.Infof("Waiting for pods to be ready for deployment %s\n", deploymentName)
err = kube.WaitForDeploymentToBeReady(client, deploymentName, ns, 5*time.Minute)
if err != nil {
return err
}
pods, err := kube.GetDeploymentPods(client, deploymentName, ns)
if pods == nil || len(pods) == 0 {
return fmt.Errorf("No pod found for namespace %s with name %s", ns, deploymentName)
}
command := "/app/gitea/gitea admin create-user --admin --name " + o.Username + " --password " + o.Password
if o.Email != "" {
command += " --email " + o.Email
}
if o.IsAdmin {
command += " --admin"
}
// default to using the first pods found if more than one exists for the deployment
err = o.RunCommand("kubectl", "exec", "-t", pods[0].Name, "--", "/bin/sh", "-c", command)
if err != nil {
return nil
}
log.Infof("Created user %s API Token for Git server %s at %s\n",
util.ColorInfo(o.Username), util.ColorInfo(server.Name), util.ColorInfo(server.URL))
return nil
}