increase test-connection timeout and invoke in goroutines
This commit is contained in:
@@ -37,15 +37,17 @@ func (s *ServerManager) ConnectToServer(conf *ServerConfig, password string) err
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *ServerManager) TestConnectionAndAuth(hostname, username, password string) error {
|
func (s *ServerManager) TestConnectionAndAuth(hostname, username, password string, timeout time.Duration) error {
|
||||||
err := ErrUnreachable
|
err := ErrUnreachable
|
||||||
done := make(chan bool)
|
done := make(chan bool)
|
||||||
go func() {
|
go func() {
|
||||||
_, err = s.testConnectionAndCreateClient(hostname, username, password)
|
_, err = s.testConnectionAndCreateClient(hostname, username, password)
|
||||||
close(done)
|
close(done)
|
||||||
}()
|
}()
|
||||||
|
t := time.NewTimer(timeout)
|
||||||
|
defer t.Stop()
|
||||||
select {
|
select {
|
||||||
case <-time.After(200 * time.Millisecond):
|
case <-t.C:
|
||||||
return err
|
return err
|
||||||
case <-done:
|
case <-done:
|
||||||
return err
|
return err
|
||||||
|
|||||||
+44
-29
@@ -6,6 +6,7 @@ import (
|
|||||||
"supersonic/backend"
|
"supersonic/backend"
|
||||||
"supersonic/ui/dialogs"
|
"supersonic/ui/dialogs"
|
||||||
"supersonic/ui/util"
|
"supersonic/ui/util"
|
||||||
|
"time"
|
||||||
|
|
||||||
"fyne.io/fyne/v2"
|
"fyne.io/fyne/v2"
|
||||||
"fyne.io/fyne/v2/canvas"
|
"fyne.io/fyne/v2/canvas"
|
||||||
@@ -43,16 +44,20 @@ func (m Controller) PromptForFirstServer() {
|
|||||||
d := dialogs.NewAddEditServerDialog("Connect to Server", nil)
|
d := dialogs.NewAddEditServerDialog("Connect to Server", nil)
|
||||||
pop := widget.NewModalPopUp(d, m.MainWindow.Canvas())
|
pop := widget.NewModalPopUp(d, m.MainWindow.Canvas())
|
||||||
d.OnSubmit = func() {
|
d.OnSubmit = func() {
|
||||||
if m.testConnectionAndUpdateDialogError(d) {
|
d.DisableSubmit()
|
||||||
// connection is good
|
go func() {
|
||||||
pop.Hide()
|
if m.testConnectionAndUpdateDialogText(d) {
|
||||||
server := m.App.Config.AddServer(d.Nickname, d.Host, d.Username)
|
// connection is good
|
||||||
if err := m.App.ServerManager.SetServerPassword(server, d.Password); err != nil {
|
pop.Hide()
|
||||||
log.Printf("error setting keyring credentials: %v", err)
|
server := m.App.Config.AddServer(d.Nickname, d.Host, d.Username)
|
||||||
// TODO: handle?
|
if err := m.App.ServerManager.SetServerPassword(server, d.Password); err != nil {
|
||||||
|
log.Printf("error setting keyring credentials: %v", err)
|
||||||
|
// TODO: handle?
|
||||||
|
}
|
||||||
|
m.DoConnectToServerWorkflow(server)
|
||||||
}
|
}
|
||||||
m.DoConnectToServerWorkflow(server)
|
d.EnableSubmit()
|
||||||
}
|
}()
|
||||||
}
|
}
|
||||||
pop.Show()
|
pop.Show()
|
||||||
}
|
}
|
||||||
@@ -110,29 +115,38 @@ func (m Controller) PromptForLoginAndConnect() {
|
|||||||
d := dialogs.NewLoginDialog(m.App.Config.Servers)
|
d := dialogs.NewLoginDialog(m.App.Config.Servers)
|
||||||
pop := widget.NewModalPopUp(d, m.MainWindow.Canvas())
|
pop := widget.NewModalPopUp(d, m.MainWindow.Canvas())
|
||||||
d.OnSubmit = func(server *backend.ServerConfig, password string) {
|
d.OnSubmit = func(server *backend.ServerConfig, password string) {
|
||||||
err := m.App.ServerManager.TestConnectionAndAuth(server.Hostname, server.Username, password)
|
d.DisableSubmit()
|
||||||
if err == backend.ErrUnreachable {
|
d.SetInfoText("Testing connection...")
|
||||||
d.SetErrorText("Server unreachable")
|
go func() {
|
||||||
} else if err != nil {
|
err := m.App.ServerManager.TestConnectionAndAuth(server.Hostname, server.Username, password, 5*time.Second)
|
||||||
d.SetErrorText("Authentication failed")
|
if err == backend.ErrUnreachable {
|
||||||
} else {
|
d.SetErrorText("Server unreachable")
|
||||||
pop.Hide()
|
} else if err != nil {
|
||||||
m.trySetPasswordAndConnectToServer(server, password)
|
d.SetErrorText("Authentication failed")
|
||||||
}
|
} else {
|
||||||
|
pop.Hide()
|
||||||
|
m.trySetPasswordAndConnectToServer(server, password)
|
||||||
|
}
|
||||||
|
d.EnableSubmit()
|
||||||
|
}()
|
||||||
}
|
}
|
||||||
d.OnEditServer = func(server *backend.ServerConfig) {
|
d.OnEditServer = func(server *backend.ServerConfig) {
|
||||||
pop.Hide()
|
pop.Hide()
|
||||||
editD := dialogs.NewAddEditServerDialog("Edit server", server)
|
editD := dialogs.NewAddEditServerDialog("Edit server", server)
|
||||||
editPop := widget.NewModalPopUp(editD, m.MainWindow.Canvas())
|
editPop := widget.NewModalPopUp(editD, m.MainWindow.Canvas())
|
||||||
editD.OnSubmit = func() {
|
editD.OnSubmit = func() {
|
||||||
if m.testConnectionAndUpdateDialogError(editD) {
|
d.DisableSubmit()
|
||||||
// connection is good
|
go func() {
|
||||||
editPop.Hide()
|
if m.testConnectionAndUpdateDialogText(editD) {
|
||||||
server.Hostname = editD.Host
|
// connection is good
|
||||||
server.Nickname = editD.Nickname
|
editPop.Hide()
|
||||||
server.Username = editD.Username
|
server.Hostname = editD.Host
|
||||||
m.trySetPasswordAndConnectToServer(server, editD.Password)
|
server.Nickname = editD.Nickname
|
||||||
}
|
server.Username = editD.Username
|
||||||
|
m.trySetPasswordAndConnectToServer(server, editD.Password)
|
||||||
|
}
|
||||||
|
d.EnableSubmit()
|
||||||
|
}()
|
||||||
}
|
}
|
||||||
editPop.Show()
|
editPop.Show()
|
||||||
}
|
}
|
||||||
@@ -150,7 +164,7 @@ func (c Controller) trySetPasswordAndConnectToServer(server *backend.ServerConfi
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (c Controller) tryConnectToServer(server *backend.ServerConfig, password string) error {
|
func (c Controller) tryConnectToServer(server *backend.ServerConfig, password string) error {
|
||||||
if err := c.App.ServerManager.TestConnectionAndAuth(server.Hostname, server.Username, password); err != nil {
|
if err := c.App.ServerManager.TestConnectionAndAuth(server.Hostname, server.Username, password, 10*time.Second); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
if err := c.App.ServerManager.ConnectToServer(server, password); err != nil {
|
if err := c.App.ServerManager.ConnectToServer(server, password); err != nil {
|
||||||
@@ -160,8 +174,9 @@ func (c Controller) tryConnectToServer(server *backend.ServerConfig, password st
|
|||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c Controller) testConnectionAndUpdateDialogError(dlg *dialogs.AddEditServerDialog) bool {
|
func (c Controller) testConnectionAndUpdateDialogText(dlg *dialogs.AddEditServerDialog) bool {
|
||||||
err := c.App.ServerManager.TestConnectionAndAuth(dlg.Host, dlg.Username, dlg.Password)
|
dlg.SetInfoText("Testing connection...")
|
||||||
|
err := c.App.ServerManager.TestConnectionAndAuth(dlg.Host, dlg.Username, dlg.Password, 5*time.Second)
|
||||||
if err == backend.ErrUnreachable {
|
if err == backend.ErrUnreachable {
|
||||||
dlg.SetErrorText("Could not reach server (wrong hostname?)")
|
dlg.SetErrorText("Could not reach server (wrong hostname?)")
|
||||||
return false
|
return false
|
||||||
|
|||||||
@@ -20,8 +20,9 @@ type AddEditServerDialog struct {
|
|||||||
Password string
|
Password string
|
||||||
OnSubmit func()
|
OnSubmit func()
|
||||||
|
|
||||||
errPromptText *widget.RichText
|
submitBtn *widget.Button
|
||||||
container *fyne.Container
|
promptText *widget.RichText
|
||||||
|
container *fyne.Container
|
||||||
}
|
}
|
||||||
|
|
||||||
var _ fyne.Widget = (*AddEditServerDialog)(nil)
|
var _ fyne.Widget = (*AddEditServerDialog)(nil)
|
||||||
@@ -43,15 +44,14 @@ func NewAddEditServerDialog(title string, prefillServer *backend.ServerConfig) *
|
|||||||
hostField.SetPlaceHolder("http://localhost:4533")
|
hostField.SetPlaceHolder("http://localhost:4533")
|
||||||
userField := widget.NewEntryWithData(binding.BindString(&a.Username))
|
userField := widget.NewEntryWithData(binding.BindString(&a.Username))
|
||||||
passField := widget.NewPasswordEntry()
|
passField := widget.NewPasswordEntry()
|
||||||
submit := widget.NewButton("Enter", func() {
|
a.submitBtn = widget.NewButton("Enter", func() {
|
||||||
a.Password = passField.Text
|
a.Password = passField.Text
|
||||||
if a.OnSubmit != nil {
|
if a.OnSubmit != nil {
|
||||||
a.OnSubmit()
|
a.OnSubmit()
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
a.errPromptText = widget.NewRichTextWithText("")
|
a.promptText = widget.NewRichTextWithText("")
|
||||||
a.errPromptText.Segments[0].(*widget.TextSegment).Style.ColorName = theme.ColorNameError
|
a.promptText.Hidden = true
|
||||||
a.errPromptText.Hidden = true
|
|
||||||
|
|
||||||
a.container = container.NewVBox(
|
a.container = container.NewVBox(
|
||||||
container.NewHBox(layout.NewSpacer(), titleLabel, layout.NewSpacer()),
|
container.NewHBox(layout.NewSpacer(), titleLabel, layout.NewSpacer()),
|
||||||
@@ -67,21 +67,41 @@ func NewAddEditServerDialog(title string, prefillServer *backend.ServerConfig) *
|
|||||||
),
|
),
|
||||||
widget.NewSeparator(),
|
widget.NewSeparator(),
|
||||||
container.NewHBox(
|
container.NewHBox(
|
||||||
a.errPromptText,
|
a.promptText,
|
||||||
layout.NewSpacer(),
|
layout.NewSpacer(),
|
||||||
submit),
|
a.submitBtn),
|
||||||
)
|
)
|
||||||
return a
|
return a
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (a *AddEditServerDialog) SetInfoText(text string) {
|
||||||
|
a.doSetPromptText(text, theme.ColorNameForeground)
|
||||||
|
}
|
||||||
|
|
||||||
func (a *AddEditServerDialog) SetErrorText(text string) {
|
func (a *AddEditServerDialog) SetErrorText(text string) {
|
||||||
a.errPromptText.Segments[0].(*widget.TextSegment).Text = text
|
a.doSetPromptText(text, theme.ColorNameError)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *AddEditServerDialog) EnableSubmit() {
|
||||||
|
a.submitBtn.Enable()
|
||||||
|
a.submitBtn.Refresh()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *AddEditServerDialog) DisableSubmit() {
|
||||||
|
a.submitBtn.Disable()
|
||||||
|
a.submitBtn.Refresh()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (a *AddEditServerDialog) doSetPromptText(text string, color fyne.ThemeColorName) {
|
||||||
|
ts := a.promptText.Segments[0].(*widget.TextSegment)
|
||||||
|
ts.Text = text
|
||||||
|
ts.Style.ColorName = color
|
||||||
if text != "" {
|
if text != "" {
|
||||||
a.errPromptText.Show()
|
a.promptText.Show()
|
||||||
} else {
|
} else {
|
||||||
a.errPromptText.Hide()
|
a.promptText.Hide()
|
||||||
}
|
}
|
||||||
a.errPromptText.Refresh()
|
a.promptText.Refresh()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (a *AddEditServerDialog) MinSize() fyne.Size {
|
func (a *AddEditServerDialog) MinSize() fyne.Size {
|
||||||
|
|||||||
+34
-13
@@ -16,10 +16,11 @@ type LoginDialog struct {
|
|||||||
OnSubmit func(server *backend.ServerConfig, password string)
|
OnSubmit func(server *backend.ServerConfig, password string)
|
||||||
OnEditServer func(server *backend.ServerConfig)
|
OnEditServer func(server *backend.ServerConfig)
|
||||||
|
|
||||||
servers []*backend.ServerConfig
|
servers []*backend.ServerConfig
|
||||||
serverSelect *widget.Select
|
serverSelect *widget.Select
|
||||||
passField *widget.Entry
|
passField *widget.Entry
|
||||||
errPromptText *widget.RichText
|
promptText *widget.RichText
|
||||||
|
submitBtn *widget.Button
|
||||||
|
|
||||||
container *fyne.Container
|
container *fyne.Container
|
||||||
}
|
}
|
||||||
@@ -39,11 +40,11 @@ func NewLoginDialog(servers []*backend.ServerConfig) *LoginDialog {
|
|||||||
l.serverSelect.SetSelectedIndex(0)
|
l.serverSelect.SetSelectedIndex(0)
|
||||||
editBtn := widget.NewButtonWithIcon("", theme.DocumentCreateIcon(), l.onEditServer)
|
editBtn := widget.NewButtonWithIcon("", theme.DocumentCreateIcon(), l.onEditServer)
|
||||||
l.passField = widget.NewPasswordEntry()
|
l.passField = widget.NewPasswordEntry()
|
||||||
okBtn := widget.NewButton("OK", l.onSubmit)
|
l.submitBtn = widget.NewButton("OK", l.onSubmit)
|
||||||
|
|
||||||
l.errPromptText = widget.NewRichTextWithText("")
|
l.promptText = widget.NewRichTextWithText("")
|
||||||
l.errPromptText.Segments[0].(*widget.TextSegment).Style.ColorName = theme.ColorNameError
|
l.promptText.Segments[0].(*widget.TextSegment).Style.ColorName = theme.ColorNameError
|
||||||
l.errPromptText.Hidden = true
|
l.promptText.Hidden = true
|
||||||
|
|
||||||
l.container = container.NewVBox(
|
l.container = container.NewVBox(
|
||||||
container.NewHBox(layout.NewSpacer(), titleLabel, layout.NewSpacer()),
|
container.NewHBox(layout.NewSpacer(), titleLabel, layout.NewSpacer()),
|
||||||
@@ -53,19 +54,39 @@ func NewLoginDialog(servers []*backend.ServerConfig) *LoginDialog {
|
|||||||
widget.NewLabel("Password"),
|
widget.NewLabel("Password"),
|
||||||
l.passField),
|
l.passField),
|
||||||
widget.NewSeparator(),
|
widget.NewSeparator(),
|
||||||
container.NewHBox(l.errPromptText, layout.NewSpacer(), okBtn),
|
container.NewHBox(l.promptText, layout.NewSpacer(), l.submitBtn),
|
||||||
)
|
)
|
||||||
return l
|
return l
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (l *LoginDialog) SetInfoText(text string) {
|
||||||
|
l.doSetPromptText(text, theme.ColorNameForeground)
|
||||||
|
}
|
||||||
|
|
||||||
func (l *LoginDialog) SetErrorText(text string) {
|
func (l *LoginDialog) SetErrorText(text string) {
|
||||||
l.errPromptText.Segments[0].(*widget.TextSegment).Text = text
|
l.doSetPromptText(text, theme.ColorNameError)
|
||||||
|
}
|
||||||
|
|
||||||
|
func (l *LoginDialog) EnableSubmit() {
|
||||||
|
l.submitBtn.Enable()
|
||||||
|
l.submitBtn.Refresh()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (l *LoginDialog) DisableSubmit() {
|
||||||
|
l.submitBtn.Disable()
|
||||||
|
l.submitBtn.Refresh()
|
||||||
|
}
|
||||||
|
|
||||||
|
func (l *LoginDialog) doSetPromptText(text string, color fyne.ThemeColorName) {
|
||||||
|
ts := l.promptText.Segments[0].(*widget.TextSegment)
|
||||||
|
ts.Text = text
|
||||||
|
ts.Style.ColorName = color
|
||||||
if text != "" {
|
if text != "" {
|
||||||
l.errPromptText.Show()
|
l.promptText.Show()
|
||||||
} else {
|
} else {
|
||||||
l.errPromptText.Hide()
|
l.promptText.Hide()
|
||||||
}
|
}
|
||||||
l.errPromptText.Refresh()
|
l.promptText.Refresh()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (l *LoginDialog) CreateRenderer() fyne.WidgetRenderer {
|
func (l *LoginDialog) CreateRenderer() fyne.WidgetRenderer {
|
||||||
|
|||||||
Reference in New Issue
Block a user