diff options
author | Drew DeVault <sir@cmpwn.com> | 2019-01-13 16:18:10 -0500 |
---|---|---|
committer | Drew DeVault <sir@cmpwn.com> | 2019-01-13 16:18:10 -0500 |
commit | 2750f99a6049322b1361b5bfa4dff3b1df2b36ab (patch) | |
tree | 0c18f4a8180f1eda1616c07296d20323edfeab62 /worker/imap | |
parent | cf664620005cf65d060e689fbb27b939dd3192a7 (diff) | |
download | aerc-2750f99a6049322b1361b5bfa4dff3b1df2b36ab.tar.gz |
Issue IMAP SELECT command
Diffstat (limited to 'worker/imap')
-rw-r--r-- | worker/imap/open.go | 20 | ||||
-rw-r--r-- | worker/imap/worker.go | 20 |
2 files changed, 39 insertions, 1 deletions
diff --git a/worker/imap/open.go b/worker/imap/open.go new file mode 100644 index 0000000..d90a292 --- /dev/null +++ b/worker/imap/open.go @@ -0,0 +1,20 @@ +package imap + +import ( + "git.sr.ht/~sircmpwn/aerc2/worker/types" +) + +func (imapw *IMAPWorker) handleOpenDirectory(msg *types.OpenDirectory) { + imapw.worker.Logger.Printf("Opening %s", msg.Directory) + go func() { + _, err := imapw.client.Select(msg.Directory, false) + if err != nil { + imapw.worker.PostMessage(&types.Error{ + Message: types.RespondTo(msg), + Error: err, + }, nil) + } else { + imapw.worker.PostMessage(&types.Done{types.RespondTo(msg)}, nil) + } + }() +} diff --git a/worker/imap/worker.go b/worker/imap/worker.go index d75dbb0..4381e22 100644 --- a/worker/imap/worker.go +++ b/worker/imap/worker.go @@ -149,12 +149,30 @@ func (w *IMAPWorker) handleMessage(msg types.WorkerMessage) error { w.worker.PostMessage(&types.Done{types.RespondTo(msg)}, nil) case *types.ListDirectories: w.handleListDirectories(msg) + case *types.OpenDirectory: + w.handleOpenDirectory(msg) default: return errUnsupported } return nil } +func (w *IMAPWorker) handleImapUpdate(update client.Update) { + w.worker.Logger.Printf("(= %T", update) + switch update := update.(type) { + case *client.MailboxUpdate: + status := update.Mailbox + w.worker.PostMessage(&types.DirectoryInfo{ + ReadOnly: status.ReadOnly, + Flags: status.Flags, + + Exists: int(status.Messages), + Recent: int(status.Recent), + Unseen: int(status.Unseen), + }, nil) + } +} + func (w *IMAPWorker) Run() { for { select { @@ -171,7 +189,7 @@ func (w *IMAPWorker) Run() { }, nil) } case update := <-w.updates: - w.worker.Logger.Printf("(= %T", update) + w.handleImapUpdate(update) } } } |