Skip to content

Commit

Permalink
reuse default ssh username const
Browse files Browse the repository at this point in the history
  • Loading branch information
tvdfly committed Feb 8, 2023
1 parent 51ea3c5 commit c7ede33
Show file tree
Hide file tree
Showing 6 changed files with 9 additions and 11 deletions.
4 changes: 2 additions & 2 deletions flypg/cmd.go
Expand Up @@ -61,7 +61,7 @@ func (pc *Command) UpdateSettings(ctx context.Context, leaderIp string, config m
subCmd := fmt.Sprintf("update --patch '%s'", string(configBytes))
cmd := fmt.Sprintf("stolonctl-run %s", encodeCommand(subCmd))

resp, err := ssh.RunSSHCommand(ctx, pc.app, pc.dialer, leaderIp, cmd, "root")
resp, err := ssh.RunSSHCommand(ctx, pc.app, pc.dialer, leaderIp, cmd, ssh.DefaultSshUsername)
if err != nil {
return err
}
Expand All @@ -82,7 +82,7 @@ func (pc *Command) UnregisterMember(ctx context.Context, leaderIP string, standb
payload := encodeCommand(standbyIP)
cmd := fmt.Sprintf("pg_unregister %s", payload)

resp, err := ssh.RunSSHCommand(ctx, pc.app, pc.dialer, leaderIP, cmd, "root")
resp, err := ssh.RunSSHCommand(ctx, pc.app, pc.dialer, leaderIP, cmd, ssh.DefaultSshUsername)
if err != nil {
return err
}
Expand Down
6 changes: 2 additions & 4 deletions internal/command/postgres/connect.go
Expand Up @@ -19,8 +19,6 @@ import (
"github.com/superfly/flyctl/internal/flag"
)

const defaultSshUsername = "root"

func newConnect() *cobra.Command {
const (
short = "Connect to the Postgres console"
Expand Down Expand Up @@ -120,7 +118,7 @@ func runMachineConnect(ctx context.Context, app *api.AppCompact) error {
Org: app.Organization,
Dialer: agent.DialerFromContext(ctx),
App: app.Name,
Username: defaultSshUsername,
Username: ssh.DefaultSshUsername,
Cmd: fmt.Sprintf("connect %s %s %s", database, user, password),
Stdin: os.Stdin,
Stdout: ioutils.NewWriteCloserWrapper(colorable.NewColorableStdout(), func() error { return nil }),
Expand Down Expand Up @@ -166,7 +164,7 @@ func runNomadConnect(ctx context.Context, app *api.AppCompact) error {
Org: app.Organization,
Dialer: agent.DialerFromContext(ctx),
App: app.Name,
Username: defaultSshUsername,
Username: ssh.DefaultSshUsername,
Cmd: fmt.Sprintf("connect %s %s %s", database, user, password),
Stdin: os.Stdin,
Stdout: ioutils.NewWriteCloserWrapper(colorable.NewColorableStdout(), func() error { return nil }),
Expand Down
2 changes: 1 addition & 1 deletion internal/command/ssh/console.go
Expand Up @@ -63,7 +63,7 @@ func stdArgsSSH(cmd *cobra.Command) {
Name: "user",
Shorthand: "u",
Description: "Unix username to connect as",
Default: defaultSshUsername,
Default: DefaultSshUsername,
},
)
}
Expand Down
2 changes: 1 addition & 1 deletion internal/command/ssh/issue.go
Expand Up @@ -46,7 +46,7 @@ validity.`
Name: "username",
Shorthand: "u",
Description: "Unix usernames the SSH cert can authenticate as",
Default: []string{defaultSshUsername, "fly"},
Default: []string{DefaultSshUsername, "fly"},
},
flag.Int{
Name: "hours",
Expand Down
2 changes: 1 addition & 1 deletion internal/command/ssh/sftp.go
Expand Up @@ -110,7 +110,7 @@ func newSFTPConnection(ctx context.Context) (*sftp.Client, error) {
Org: app.Organization,
Dialer: dialer,
App: appName,
Username: defaultSshUsername,
Username: DefaultSshUsername,
Stdin: os.Stdin,
Stdout: os.Stdout,
Stderr: os.Stderr,
Expand Down
4 changes: 2 additions & 2 deletions internal/command/ssh/ssh_terminal.go
Expand Up @@ -46,7 +46,7 @@ func spin(in, out string) context.CancelFunc {
return cancel
}

const defaultSshUsername = "root"
const DefaultSshUsername = "root"

type SSHParams struct {
Ctx context.Context
Expand Down Expand Up @@ -155,7 +155,7 @@ func singleUseSSHCertificate(ctx context.Context, org api.OrganizationImpl) (*ap
return nil, nil, err
}

icert, err := client.IssueSSHCertificate(ctx, org, []string{defaultSshUsername, "fly"}, nil, &hours, pub)
icert, err := client.IssueSSHCertificate(ctx, org, []string{DefaultSshUsername, "fly"}, nil, &hours, pub)
if err != nil {
return nil, nil, err
}
Expand Down

0 comments on commit c7ede33

Please sign in to comment.