2023-03-23 09:47:29 +02:00
|
|
|
package helpers
|
|
|
|
|
|
|
|
import (
|
|
|
|
"time"
|
|
|
|
|
2023-07-09 03:32:27 +02:00
|
|
|
"github.com/jesseduffield/gocui"
|
2023-03-23 09:47:29 +02:00
|
|
|
"github.com/jesseduffield/lazygit/pkg/gui/status"
|
2023-12-22 18:31:13 +02:00
|
|
|
"github.com/jesseduffield/lazygit/pkg/gui/types"
|
2023-08-29 14:15:36 +02:00
|
|
|
"github.com/jesseduffield/lazygit/pkg/utils"
|
2023-03-23 09:47:29 +02:00
|
|
|
)
|
|
|
|
|
|
|
|
type AppStatusHelper struct {
|
|
|
|
c *HelperCommon
|
|
|
|
|
2023-08-27 16:29:14 +02:00
|
|
|
statusMgr func() *status.StatusManager
|
|
|
|
modeHelper *ModeHelper
|
2023-03-23 09:47:29 +02:00
|
|
|
}
|
|
|
|
|
2023-08-27 16:29:14 +02:00
|
|
|
func NewAppStatusHelper(c *HelperCommon, statusMgr func() *status.StatusManager, modeHelper *ModeHelper) *AppStatusHelper {
|
2023-03-23 09:47:29 +02:00
|
|
|
return &AppStatusHelper{
|
2023-08-27 16:29:14 +02:00
|
|
|
c: c,
|
|
|
|
statusMgr: statusMgr,
|
|
|
|
modeHelper: modeHelper,
|
2023-03-23 09:47:29 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2023-12-22 18:31:13 +02:00
|
|
|
func (self *AppStatusHelper) Toast(message string, kind types.ToastKind) {
|
2023-08-30 10:54:32 +02:00
|
|
|
if self.c.RunningIntegrationTest() {
|
|
|
|
// Don't bother showing toasts in integration tests. You can't check for
|
|
|
|
// them anyway, and they would only slow down the test unnecessarily by
|
|
|
|
// two seconds.
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
2023-12-22 18:31:13 +02:00
|
|
|
self.statusMgr().AddToastStatus(message, kind)
|
2023-03-23 09:47:29 +02:00
|
|
|
|
|
|
|
self.renderAppStatus()
|
|
|
|
}
|
|
|
|
|
2023-09-20 08:43:42 +02:00
|
|
|
// A custom task for WithWaitingStatus calls; it wraps the original one and
|
|
|
|
// hides the status whenever the task is paused, and shows it again when
|
|
|
|
// continued.
|
|
|
|
type appStatusHelperTask struct {
|
|
|
|
gocui.Task
|
|
|
|
waitingStatusHandle *status.WaitingStatusHandle
|
|
|
|
}
|
|
|
|
|
|
|
|
// poor man's version of explicitly saying that struct X implements interface Y
|
|
|
|
var _ gocui.Task = appStatusHelperTask{}
|
|
|
|
|
|
|
|
func (self appStatusHelperTask) Pause() {
|
|
|
|
self.waitingStatusHandle.Hide()
|
|
|
|
self.Task.Pause()
|
|
|
|
}
|
|
|
|
|
|
|
|
func (self appStatusHelperTask) Continue() {
|
|
|
|
self.Task.Continue()
|
|
|
|
self.waitingStatusHandle.Show()
|
|
|
|
}
|
|
|
|
|
2023-03-23 09:47:29 +02:00
|
|
|
// withWaitingStatus wraps a function and shows a waiting status while the function is still executing
|
2023-07-09 13:09:52 +02:00
|
|
|
func (self *AppStatusHelper) WithWaitingStatus(message string, f func(gocui.Task) error) {
|
|
|
|
self.c.OnWorker(func(task gocui.Task) {
|
2023-09-20 08:43:42 +02:00
|
|
|
self.statusMgr().WithWaitingStatus(message, self.renderAppStatus, func(waitingStatusHandle *status.WaitingStatusHandle) {
|
|
|
|
if err := f(appStatusHelperTask{task, waitingStatusHandle}); err != nil {
|
2023-03-23 09:47:29 +02:00
|
|
|
self.c.OnUIThread(func() error {
|
|
|
|
return self.c.Error(err)
|
|
|
|
})
|
|
|
|
}
|
|
|
|
})
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
2023-08-27 16:29:14 +02:00
|
|
|
func (self *AppStatusHelper) WithWaitingStatusSync(message string, f func() error) {
|
|
|
|
self.statusMgr().WithWaitingStatus(message, func() {}, func(*status.WaitingStatusHandle) {
|
|
|
|
stop := make(chan struct{})
|
|
|
|
defer func() { close(stop) }()
|
|
|
|
self.renderAppStatusSync(stop)
|
|
|
|
|
|
|
|
if err := f(); err != nil {
|
|
|
|
_ = self.c.Error(err)
|
|
|
|
}
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
2023-03-23 09:47:29 +02:00
|
|
|
func (self *AppStatusHelper) HasStatus() bool {
|
|
|
|
return self.statusMgr().HasStatus()
|
|
|
|
}
|
|
|
|
|
|
|
|
func (self *AppStatusHelper) GetStatusString() string {
|
2023-12-22 18:31:13 +02:00
|
|
|
appStatus, _ := self.statusMgr().GetStatusString()
|
|
|
|
return appStatus
|
2023-03-23 09:47:29 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
func (self *AppStatusHelper) renderAppStatus() {
|
2023-07-09 13:09:52 +02:00
|
|
|
self.c.OnWorker(func(_ gocui.Task) {
|
2023-08-29 14:15:36 +02:00
|
|
|
ticker := time.NewTicker(time.Millisecond * utils.LoaderAnimationInterval)
|
2023-03-23 09:47:29 +02:00
|
|
|
defer ticker.Stop()
|
|
|
|
for range ticker.C {
|
2023-12-22 18:31:13 +02:00
|
|
|
appStatus, color := self.statusMgr().GetStatusString()
|
|
|
|
self.c.Views().AppStatus.FgColor = color
|
2023-03-23 09:47:29 +02:00
|
|
|
self.c.OnUIThread(func() error {
|
|
|
|
self.c.SetViewContent(self.c.Views().AppStatus, appStatus)
|
|
|
|
return nil
|
|
|
|
})
|
|
|
|
|
|
|
|
if appStatus == "" {
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
})
|
|
|
|
}
|
2023-08-27 16:29:14 +02:00
|
|
|
|
|
|
|
func (self *AppStatusHelper) renderAppStatusSync(stop chan struct{}) {
|
|
|
|
go func() {
|
|
|
|
ticker := time.NewTicker(time.Millisecond * 50)
|
|
|
|
defer ticker.Stop()
|
|
|
|
|
|
|
|
// Forcing a re-layout and redraw after we added the waiting status;
|
|
|
|
// this is needed in case the gui.showBottomLine config is set to false,
|
|
|
|
// to make sure the bottom line appears. It's also useful for redrawing
|
|
|
|
// once after each of several consecutive keypresses, e.g. pressing
|
|
|
|
// ctrl-j to move a commit down several steps.
|
|
|
|
_ = self.c.GocuiGui().ForceLayoutAndRedraw()
|
|
|
|
|
|
|
|
self.modeHelper.SetSuppressRebasingMode(true)
|
|
|
|
defer func() { self.modeHelper.SetSuppressRebasingMode(false) }()
|
|
|
|
|
|
|
|
outer:
|
|
|
|
for {
|
|
|
|
select {
|
|
|
|
case <-ticker.C:
|
2023-12-22 18:31:13 +02:00
|
|
|
appStatus, color := self.statusMgr().GetStatusString()
|
|
|
|
self.c.Views().AppStatus.FgColor = color
|
2023-08-27 16:29:14 +02:00
|
|
|
self.c.SetViewContent(self.c.Views().AppStatus, appStatus)
|
|
|
|
// Redraw all views of the bottom line:
|
|
|
|
bottomLineViews := []*gocui.View{
|
|
|
|
self.c.Views().AppStatus, self.c.Views().Options, self.c.Views().Information,
|
|
|
|
self.c.Views().StatusSpacer1, self.c.Views().StatusSpacer2,
|
|
|
|
}
|
|
|
|
_ = self.c.GocuiGui().ForceRedrawViews(bottomLineViews...)
|
|
|
|
case <-stop:
|
|
|
|
break outer
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}()
|
|
|
|
}
|