aboutsummaryrefslogtreecommitdiff
path: root/worker
diff options
context:
space:
mode:
authorReto Brunner <reto@labrat.space>2020-02-15 14:14:45 +0100
committerDrew DeVault <sir@cmpwn.com>2020-02-16 10:41:18 -0500
commitbb09694f07a1ff281be0e14a07b6576c9949442f (patch)
treea46721487842591a3b67251868c7626b932bc69a /worker
parent89b742dc6c2cc4e70cc7fd44454ee184dcc4b627 (diff)
notmuch: emit DirInfo upon request
Diffstat (limited to 'worker')
-rw-r--r--worker/notmuch/worker.go56
1 files changed, 44 insertions, 12 deletions
diff --git a/worker/notmuch/worker.go b/worker/notmuch/worker.go
index 96ec0cb..43d60e2 100644
--- a/worker/notmuch/worker.go
+++ b/worker/notmuch/worker.go
@@ -103,6 +103,8 @@ func (w *worker) handleMessage(msg types.WorkerMessage) error {
return w.handleSearchDirectory(msg)
case *types.ModifyLabels:
return w.handleModifyLabels(msg)
+ case *types.DirectoryInfoUpdateRequest:
+ return w.handleDirInfoUpdateRequest(msg)
// not implemented, they are generally not used
// in a notmuch based workflow
@@ -171,21 +173,15 @@ func (w *worker) handleListDirectories(msg *types.ListDirectories) error {
return nil
}
-func (w *worker) handleOpenDirectory(msg *types.OpenDirectory) error {
- w.w.Logger.Printf("opening %s", msg.Directory)
- // try the friendly name first, if that fails assume it's a query
- q, ok := w.nameQueryMap[msg.Directory]
- if !ok {
- q = msg.Directory
- }
- w.query = q
- count, err := w.db.QueryCountMessages(w.query)
+func (w *worker) gatherDirectoryInfo(name string, query string) (
+ *types.DirectoryInfo, error) {
+ count, err := w.db.QueryCountMessages(query)
if err != nil {
- return err
+ return nil, err
}
info := &types.DirectoryInfo{
Info: &models.DirectoryInfo{
- Name: msg.Directory,
+ Name: name,
Flags: []string{},
ReadOnly: false,
// total messages
@@ -193,9 +189,45 @@ func (w *worker) handleOpenDirectory(msg *types.OpenDirectory) error {
// new messages since mailbox was last opened
Recent: 0,
// total unread
- Unseen: count.Unread,
+ Unseen: count.Unread,
+ AccurateCounts: true,
},
}
+ return info, nil
+}
+
+func (w *worker) handleDirInfoUpdateRequest(
+ msg *types.DirectoryInfoUpdateRequest) error {
+ query := w.queryFromName(msg.Name)
+ info, err := w.gatherDirectoryInfo(msg.Name, query)
+ if err != nil {
+ return err
+ }
+ info.Message = types.RespondTo(msg)
+ w.w.PostMessage(info, nil)
+ return nil
+}
+
+//queryFromName either returns the friendly ID if aliased or the name itself
+//assuming it to be the query
+func (w *worker) queryFromName(name string) string {
+ // try the friendly name first, if that fails assume it's a query
+ q, ok := w.nameQueryMap[name]
+ if !ok {
+ return name
+ }
+ return q
+}
+
+func (w *worker) handleOpenDirectory(msg *types.OpenDirectory) error {
+ w.w.Logger.Printf("opening %s", msg.Directory)
+ // try the friendly name first, if that fails assume it's a query
+ w.query = w.queryFromName(msg.Directory)
+ info, err := w.gatherDirectoryInfo(msg.Directory, w.query)
+ if err != nil {
+ return err
+ }
+ info.Message = types.RespondTo(msg)
//TODO: why does this need to be sent twice??
w.w.PostMessage(info, nil)
w.w.PostMessage(info, nil)