package auth import ( "crypto/ed25519" "crypto/x509" "encoding/pem" "errors" "fmt" "log" "os" "path/filepath" "reflect" "strings" tea "github.com/charmbracelet/bubbletea" "github.com/charmbracelet/lipgloss" "golang.org/x/crypto/ssh" "github.com/kyren223/eko/internal/client/config" "github.com/kyren223/eko/internal/client/ui" "github.com/kyren223/eko/internal/client/ui/choicepopup" "github.com/kyren223/eko/internal/client/ui/colors" "github.com/kyren223/eko/internal/client/ui/core" authfield "github.com/kyren223/eko/internal/client/ui/field" "github.com/kyren223/eko/pkg/assert" ) const ( usernameField = iota privateKeyField passphraseField passphraseConfirmField authWidth = 52 authHeight = 21 ) var ( grayStyle = lipgloss.NewStyle().Foreground(colors.Gray) focusedStyle = lipgloss.NewStyle().Foreground(colors.Focus) errorStyle = lipgloss.NewStyle().Foreground(colors.Error) fieldBlurredStyle = lipgloss.NewStyle(). PaddingLeft(1). Border(lipgloss.RoundedBorder()). BorderForeground(colors.DarkCyan) fieldFocusedStyle = fieldBlurredStyle. BorderForeground(focusedStyle.GetForeground()). Border(lipgloss.ThickBorder()) focusedSignupButton = focusedStyle.Bold(true).Render("[ SIGN-UP ]") focusedSigninButton = focusedStyle.Bold(true).Render("[ SIGN-IN ]") blurredSignupButton = fmt.Sprintf("[ %s ]", grayStyle.Render("sign-up")) blurredSigninButton = fmt.Sprintf("[ %s ]", grayStyle.Render("sign-in")) headerStyle = lipgloss.NewStyle().Foreground(colors.Turquoise) titleStyle = focusedStyle.Width(authWidth).Bold(true).AlignHorizontal(lipgloss.Center) signupTitle = titleStyle.Render(` ____ _ ____ _ _ _ _ ___ [__ | | __ |\ | __ | | |__] ___] | |__] | \| |__| | `) signinTitle = titleStyle.Render(` ____ _ ____ _ _ _ _ _ [__ | | __ |\ | __ | |\ | ___] | |__] | \| | | \|`) revealIcon = lipgloss.NewStyle().PaddingLeft(1).Render("󰈈 ") concealIcon = lipgloss.NewStyle().PaddingLeft(1).Render("󰈉 ") popupStyle = lipgloss.NewStyle().Border(lipgloss.ThickBorder()) choiceSelectedStyle = lipgloss.NewStyle().Padding(0, 1).Margin(0, 1).Background(colors.Blue) choiceUnselectedStyle = lipgloss.NewStyle().Padding(0, 1).Margin(0, 1).Background(colors.Gray) blurredRememberChecked = "[x] Remember" blurredRememberUnchecked = "[ ] Remember" focusedRememberChecked = focusedStyle.Render(blurredRememberChecked) focusedRememberUnchecked = focusedStyle.Render(blurredRememberUnchecked) centerStyle = lipgloss.NewStyle().Width(authWidth).AlignHorizontal(0.5) ) func init() { // HACK: to avoid a circular dependency, so core can transition to this // I don't like how go has this issue, I would rather slower compilations ui.NewAuth = func() tea.Model { return New() } } type Model struct { popup *choicepopup.Model fields []authfield.Model focusIndex int remember bool signup bool } func New() Model { m := Model{ fields: make([]authfield.Model, 4), } for i := range m.fields { field := authfield.New(48) field.Input.Cursor.Style = focusedStyle field.BlurredStyle = fieldBlurredStyle field.FocusedStyle = fieldFocusedStyle field.ErrorStyle = errorStyle field.FocusedTextStyle = focusedStyle field.BlurredTextStyle = lipgloss.NewStyle() switch i { case usernameField: field.Header = headerStyle.Render("Username") field.Input.Placeholder = "Username" field.Input.CharLimit = 48 field.Input.Validate = func(username string) error { if len(username) == 0 { return errors.New("Required") } return nil } case privateKeyField: field.Header = headerStyle.Render("Private Key") field.Input.Placeholder = "Path to Private Key" field.Input.CharLimit = 100 field.Input.Validate = func(privKey string) error { if len(privKey) == 0 { return errors.New("Required") } return nil } case passphraseField: field.Header = headerStyle.Render("Passphrase (Optional)") field.Input.Placeholder = "Passphrase" field.SetRevealIcon(revealIcon) field.SetConcealIcon(concealIcon) field.SetRevealed(false) field.Input.EchoCharacter = '*' case passphraseConfirmField: field.Header = headerStyle.Render("Passphrase Confirm") field.Input.Placeholder = "Repeated Passphrase" field.SetRevealIcon(revealIcon) field.SetConcealIcon(concealIcon) field.SetRevealed(false) field.Input.EchoCharacter = '*' } m.fields[i] = field } m.SetSignup(false) return m } func (m Model) Init() tea.Cmd { return nil } func (m Model) View() string { var builder strings.Builder var title string if m.signup { title = signupTitle } else { title = signinTitle } builder.WriteString(title) builder.WriteString("\n\n") if !m.signup { builder.WriteString("\n") } for i, field := range m.fields { if field.Visisble { field := centerStyle.Render(m.fields[i].View()) builder.WriteString(field) } builder.WriteRune('\n') } var checkbox *string if !m.signup { if m.remember { if m.focusIndex == len(m.fields) { checkbox = &focusedRememberChecked } else { checkbox = &blurredRememberChecked } } else { if m.focusIndex == len(m.fields) { checkbox = &focusedRememberUnchecked } else { checkbox = &blurredRememberUnchecked } } builder.WriteString(*checkbox) } var button *string if m.signup { if m.focusIndex == m.ButtonIndex() { button = &focusedSignupButton } else { button = &blurredSignupButton } } else { if m.focusIndex == m.ButtonIndex() { button = &focusedSigninButton } else { button = &blurredSigninButton } } height := authHeight - lipgloss.Height(builder.String()) builder.WriteString(centerStyle.Height(height).AlignVertical(lipgloss.Bottom).Render(*button)) result := lipgloss.NewStyle(). Width(authWidth).Height(authHeight). Margin(0, 5). Render(builder.String()) result = lipgloss.NewStyle(). Border(lipgloss.RoundedBorder()). BorderForeground(colors.DarkCyan). Render(result) result = lipgloss.Place( ui.Width, ui.Height, lipgloss.Center, lipgloss.Center, result, ) if m.popup != nil { popup := m.popup.View() x := (ui.Width - lipgloss.Width(popup)) / 2 y := (ui.Height - lipgloss.Height(popup)) / 2 result = ui.PlaceOverlay(x, y, popup, result) } return result } func (m Model) Update(msg tea.Msg) (tea.Model, tea.Cmd) { switch msg := msg.(type) { case tea.KeyMsg: key := msg.Type switch key { case tea.KeyCtrlS: cmd := m.SetSignup(!m.signup) return m, cmd case tea.KeyCtrlT: if m.popup == nil && (m.focusIndex == passphraseField || m.focusIndex == passphraseConfirmField) { m.fields[m.focusIndex].SetRevealed(!m.fields[m.focusIndex].Revealed()) } return m, nil case tea.KeyEnter: if m.popup != nil { _, choice := m.popup.Select() if choice == "sign-up" { m.popup = nil return m, m.SetSignup(true) } if choice == "sign-in" { m.popup = nil return m, m.SetSignup(false) } if choice == "cancel" { m.popup = nil return m, nil } assert.Never("unexpected choice", "choice", choice) } if !m.signup && m.focusIndex == len(m.fields) { m.remember = !m.remember return m, nil } if m.focusIndex == m.ButtonIndex() { return m, m.ButtonPressed(msg) } case tea.KeyShiftTab, tea.KeyUp: if m.popup != nil { m.popup.ScrollLeft() return m, nil } m.CycleBack() return m, m.updateFocus() case tea.KeyDown, tea.KeyTab: if m.popup != nil { m.popup.ScrollRight() return m, nil } m.CycleForward() return m, m.updateFocus() } } if m.popup != nil { return m, nil } cmds := make([]tea.Cmd, len(m.fields)) for i := range m.fields { m.fields[i], cmds[i] = m.fields[i].Update(msg) } return m, tea.Batch(cmds...) } func (m *Model) CycleBack() { for i := 0; ; i++ { m.focusIndex-- if m.focusIndex < 0 { m.focusIndex = m.ButtonIndex() } if m.focusIndex >= len(m.fields) || m.fields[m.focusIndex].Visisble { break } assert.Assert(i < 2*len(m.fields), "CycleBack infinite loop", "i", i) } } func (m *Model) CycleForward() { for i := 0; ; i++ { m.focusIndex++ if m.focusIndex > m.ButtonIndex() { m.focusIndex = 0 } if m.focusIndex >= len(m.fields) || m.fields[m.focusIndex].Visisble { break } assert.Assert(i < 2*len(m.fields), "CycleForward infinite loop", "i", i) } } func (m *Model) updateFocus() tea.Cmd { cmds := make([]tea.Cmd, len(m.fields)) for i := 0; i < len(m.fields); i++ { if i == m.focusIndex { cmds[i] = m.fields[i].Focus() } else { m.fields[i].Blur() } } return tea.Batch(cmds...) } func (m *Model) SetSignup(signup bool) tea.Cmd { m.signup = signup for i, field := range m.fields { visible := m.signup || (i == privateKeyField || i == passphraseField) field.Visisble = visible field.Input.Err = nil m.fields[i] = field } m.focusIndex = -1 m.CycleForward() privateKey := config.Read().PrivateKeyPath if !m.signup && privateKey != "" { m.fields[privateKeyField].Input.SetValue(privateKey) } return m.updateFocus() } func (m *Model) ButtonPressed(msg tea.Msg) tea.Cmd { var cmds []tea.Cmd for i, field := range m.fields { if !field.Visisble || field.Input.Validate == nil { continue } field.Input.Err = field.Input.Validate(field.Input.Value()) if field.Input.Err != nil { var cmd tea.Cmd m.fields[i], cmd = field.Update(msg) cmds = append(cmds, cmd) } } if len(cmds) != 0 { return tea.Batch(cmds...) } if m.signup { return m.Signup() } else { return m.signin() } } func (m *Model) Signup() tea.Cmd { username := m.fields[usernameField].Input.Value() assert.Assert(len(username) != 0, "username must not be empty") passphrase := m.fields[passphraseField].Input.Value() confirmation := m.fields[passphraseConfirmField].Input.Value() hasPassphrase := len(passphrase) != 0 hasConfirmation := len(confirmation) != 0 if hasPassphrase && !hasConfirmation { m.fields[passphraseConfirmField].Input.Err = errors.New("confirmation required") return nil } else if !hasPassphrase && hasConfirmation { m.fields[passphraseField].Input.Err = errors.New("empty passphrase") return nil } else if hasPassphrase && hasConfirmation && passphrase != confirmation { m.fields[passphraseConfirmField].Input.Err = errors.New("passphrase mismatch") return nil } privateKeyFilepath := expandPath(m.fields[privateKeyField].Input.Value()) err := os.MkdirAll(filepath.Dir(privateKeyFilepath), 0o755) if err != nil { m.fields[privateKeyField].Input.Err = errors.Unwrap(err) assert.NotNil(errors.Unwrap(err), "there should always be an error to unwrap", "err", err) return nil } file, err := os.OpenFile(privateKeyFilepath, os.O_WRONLY|os.O_CREATE|os.O_EXCL, 0o600) if errors.Is(err, os.ErrExist) { info, e := os.Stat(privateKeyFilepath) assert.NoError(e, "if file exists it should be fine to stat it") if info.IsDir() { m.fields[privateKeyField].Input.Err = errors.New("file is a directory") return nil } content := fmt.Sprintf("File '%s' exists.\nDo you want to sign-in instead?", privateKeyFilepath) m.popup = createPopup(content, []string{"sign-in"}, []string{"cancel"}) return nil } if err != nil { m.fields[privateKeyField].Input.Err = errors.Unwrap(err) if errors.Unwrap(err).Error() == "is a directory" { m.fields[privateKeyField].Input.Err = errors.New("file is a directory") } log.Println("signup open file error:", err) assert.NotNil(errors.Unwrap(err), "there should always be an error to unwrap", "err", err) return nil } defer file.Close() _, privKey, err := ed25519.GenerateKey(nil) if err != nil { m.fields[privateKeyField].Input.Err = errors.New("failed private key generation") log.Println("ed25519 generate key error:", err) return nil } var pemBlock *pem.Block if hasPassphrase { pemBlock, err = ssh.MarshalPrivateKeyWithPassphrase(privKey, username, []byte(passphrase)) } else { pemBlock, err = ssh.MarshalPrivateKey(privKey, username) } if err != nil { m.fields[privateKeyField].Input.Err = errors.New("failed private key marshaling") log.Println("ssh marshaling error:", err) return nil } err = pem.Encode(file, pemBlock) if err != nil { m.fields[privateKeyField].Input.Err = errors.New("failed writing to disk") log.Println("pem encoding to file error:", err) return nil } return ui.Transition(core.New(privKey, username)) } func (m *Model) signin() tea.Cmd { privateKeyFilepath := expandPath(m.fields[privateKeyField].Input.Value()) file, err := os.ReadFile(privateKeyFilepath) if errors.Is(err, os.ErrNotExist) { content := fmt.Sprintf("File '%s' doesn't exist.\nDo you want to sign-up instead?", privateKeyFilepath) m.popup = createPopup(content, []string{"sign-up"}, []string{"cancel"}) return nil } if err != nil { m.fields[privateKeyField].Input.Err = errors.Unwrap(err) if errors.Unwrap(err).Error() == "is a directory" { m.fields[privateKeyField].Input.Err = errors.New("file is a directory") } assert.NotNil(errors.Unwrap(err), "there should always be an error to unwrap", "err", err) return nil } var privateKey any passphrase := m.fields[passphraseField].Input.Value() if len(passphrase) == 0 { privateKey, err = ssh.ParseRawPrivateKey(file) if err, ok := err.(*ssh.PassphraseMissingError); ok { m.fields[passphraseField].Input.Err = errors.New("missing passphrase") log.Println("passphrase missing:", err) return nil } if err != nil { m.fields[privateKeyField].Input.Err = errors.New("invalid private key file format") log.Println("passphrase error:", err) return nil } } else { privateKey, err = ssh.ParseRawPrivateKeyWithPassphrase(file, []byte(passphrase)) if err == x509.IncorrectPasswordError { m.fields[passphraseField].Input.Err = errors.New("incorrect Passphrase") return nil } if err != nil && (err.Error() == "ssh: not an encrypted key" || err.Error() == "ssh: key is not password protected") { privateKey, err = ssh.ParseRawPrivateKey(file) } if err != nil { m.fields[privateKeyField].Input.Err = errors.New("invalid private key file format") log.Println("passphrase error:", err) return nil } } privKey, ok := privateKey.(*ed25519.PrivateKey) if !ok { m.fields[privateKeyField].Input.Err = errors.New("must be ed25519") keyType := reflect.TypeOf(privateKey) log.Println("incorrect private key type, got:", keyType.String(), reflect.ValueOf(privateKey).String()) return nil } if m.remember { config.Use(func(config *config.Config) { config.PrivateKeyPath = privateKeyFilepath }) } return ui.Transition(core.New(*privKey, "")) } func (m Model) ButtonIndex() int { if m.signup { return len(m.fields) } else { return len(m.fields) + 1 } } func createPopup(content string, leftChoices, rightChoices []string) *choicepopup.Model { content = lipgloss.NewStyle().Padding(0, 1). Border(lipgloss.NormalBorder(), false, false, true). Render(content) popup := choicepopup.New(lipgloss.Width(content), lipgloss.Height(content)+1) popup.SetContent(content) popup.SetChoices(leftChoices, rightChoices) popup.Cycle = true popup.Style = popupStyle popup.SelectedStyle = choiceSelectedStyle popup.UnselectedStyle = choiceUnselectedStyle return &popup } func expandPath(path string) string { if strings.HasPrefix(path, "~") { home, err := os.UserHomeDir() assert.NoError(err, "home directory should always be defined") if !strings.HasPrefix(path, "~/") { return home } return filepath.Join(home, path[2:]) } return path }