imap: stop checkmail if there are pending actions
Pass message containing remaining directories to check. Account widget will recursively call CheckMail with the remaining directories until a Done message is returned. Only needed for IMAP worker as other workers run check-mail-cmd in a separate goroutine. Suggested-By: Tim Culverhouse <tim@timculverhouse.com> Signed-off-by: kt programs <ktprograms@gmail.com> Tested-by: Tim Culverhouse <tim@timculverhouse.com>
This commit is contained in:
parent
bf2bf8c242
commit
9c0e54f9d9
3 changed files with 37 additions and 6 deletions
|
@ -438,12 +438,25 @@ func (acct *AccountView) CheckMail() {
|
||||||
Timeout: acct.acct.CheckMailTimeout,
|
Timeout: acct.acct.CheckMailTimeout,
|
||||||
}
|
}
|
||||||
acct.checkingMail = true
|
acct.checkingMail = true
|
||||||
acct.worker.PostAction(msg, func(_ types.WorkerMessage) {
|
|
||||||
|
var cb func(types.WorkerMessage)
|
||||||
|
cb = func(response types.WorkerMessage) {
|
||||||
|
dirsMsg, ok := response.(*types.CheckMailDirectories)
|
||||||
|
if ok {
|
||||||
|
checkMailMsg := &types.CheckMail{
|
||||||
|
Directories: dirsMsg.Directories,
|
||||||
|
Command: acct.acct.CheckMailCmd,
|
||||||
|
Timeout: acct.acct.CheckMailTimeout,
|
||||||
|
}
|
||||||
|
acct.worker.PostAction(checkMailMsg, cb)
|
||||||
|
} else { // Done
|
||||||
acct.SetStatus(statusline.ConnectionActivity(""))
|
acct.SetStatus(statusline.ConnectionActivity(""))
|
||||||
acct.Lock()
|
acct.Lock()
|
||||||
acct.checkingMail = false
|
acct.checkingMail = false
|
||||||
acct.Unlock()
|
acct.Unlock()
|
||||||
})
|
}
|
||||||
|
}
|
||||||
|
acct.worker.PostAction(msg, cb)
|
||||||
}
|
}
|
||||||
|
|
||||||
// CheckMailReset resets the check-mail timer
|
// CheckMailReset resets the check-mail timer
|
||||||
|
|
|
@ -13,7 +13,13 @@ func (w *IMAPWorker) handleCheckMailMessage(msg *types.CheckMail) {
|
||||||
imap.StatusRecent,
|
imap.StatusRecent,
|
||||||
imap.StatusUnseen,
|
imap.StatusUnseen,
|
||||||
}
|
}
|
||||||
|
var remaining []string
|
||||||
for _, dir := range msg.Directories {
|
for _, dir := range msg.Directories {
|
||||||
|
if len(w.worker.Actions) > 0 {
|
||||||
|
remaining = append(remaining, dir)
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
logging.Debugf("Getting status of directory %s", dir)
|
logging.Debugf("Getting status of directory %s", dir)
|
||||||
status, err := w.client.Status(dir, items)
|
status, err := w.client.Status(dir, items)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
@ -38,5 +44,12 @@ func (w *IMAPWorker) handleCheckMailMessage(msg *types.CheckMail) {
|
||||||
}, nil)
|
}, nil)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
if len(remaining) > 0 {
|
||||||
|
w.worker.PostMessage(&types.CheckMailDirectories{
|
||||||
|
Message: types.RespondTo(msg),
|
||||||
|
Directories: remaining,
|
||||||
|
}, nil)
|
||||||
|
return
|
||||||
|
}
|
||||||
w.worker.PostMessage(&types.Done{Message: types.RespondTo(msg)}, nil)
|
w.worker.PostMessage(&types.Done{Message: types.RespondTo(msg)}, nil)
|
||||||
}
|
}
|
||||||
|
|
|
@ -255,3 +255,8 @@ type LabelList struct {
|
||||||
Message
|
Message
|
||||||
Labels []string
|
Labels []string
|
||||||
}
|
}
|
||||||
|
|
||||||
|
type CheckMailDirectories struct {
|
||||||
|
Message
|
||||||
|
Directories []string
|
||||||
|
}
|
||||||
|
|
Loading…
Reference in a new issue