aboutsummaryrefslogtreecommitdiffstats
path: root/worker
diff options
context:
space:
mode:
authorReto Brunner <reto@labrat.space>2019-12-21 16:21:26 +0100
committerDrew DeVault <sir@cmpwn.com>2019-12-21 11:20:11 -0500
commit40ceee969bd29508c1da28052c95eb85a52650ba (patch)
tree0224774c182196a7352496c7f461136285de0471 /worker
parent2705d8460d7e974ee01ad41ce063ae3feeb30317 (diff)
downloadaerc-40ceee969bd29508c1da28052c95eb85a52650ba.tar.gz
notmuch: emit LabelList event
Diffstat (limited to 'worker')
-rw-r--r--worker/notmuch/lib/database.go17
-rw-r--r--worker/notmuch/worker.go12
2 files changed, 29 insertions, 0 deletions
diff --git a/worker/notmuch/lib/database.go b/worker/notmuch/lib/database.go
index f4fd588d..0706bbcc 100644
--- a/worker/notmuch/lib/database.go
+++ b/worker/notmuch/lib/database.go
@@ -55,6 +55,23 @@ func (db *DB) connectRO() error {
return nil
}
+// ListTags lists all known tags
+func (db *DB) ListTags() ([]string, error) {
+ if db.ro == nil {
+ return nil, fmt.Errorf("not connected to the notmuch db")
+ }
+ tags, err := db.ro.Tags()
+ if err != nil {
+ return nil, err
+ }
+ var result []string
+ var tag *notmuch.Tag
+ for tags.Next(&tag) {
+ result = append(result, tag.Value)
+ }
+ return result, nil
+}
+
//getQuery returns a query based on the provided query string.
//It also configures the query as specified on the worker
func (db *DB) newQuery(query string) (*notmuch.Query, error) {
diff --git a/worker/notmuch/worker.go b/worker/notmuch/worker.go
index ef4d4bfb..96ec0cb5 100644
--- a/worker/notmuch/worker.go
+++ b/worker/notmuch/worker.go
@@ -153,6 +153,7 @@ func (w *worker) handleConnect(msg *types.Connect) error {
return err
}
w.done(msg)
+ w.emitLabelList()
return nil
}
@@ -383,6 +384,8 @@ func (w *worker) handleModifyLabels(msg *types.ModifyLabels) error {
if err != nil {
return err
}
+ // and update the list of possible tags
+ w.emitLabelList()
w.done(msg)
return nil
}
@@ -460,6 +463,15 @@ func (w *worker) emitMessageInfo(m *Message,
return nil
}
+func (w *worker) emitLabelList() {
+ tags, err := w.db.ListTags()
+ if err != nil {
+ w.w.Logger.Printf("could not load tags: %v", err)
+ return
+ }
+ w.w.PostMessage(&types.LabelList{Labels: tags}, nil)
+}
+
func (w *worker) sort(uids []uint32,
criteria []*types.SortCriterion) ([]uint32, error) {
if len(criteria) == 0 {