aboutsummaryrefslogtreecommitdiff
path: root/worker/maildir/message.go
diff options
context:
space:
mode:
authorBen Burwell <ben@benburwell.com>2019-10-12 22:17:29 -0400
committerBen Burwell <ben@benburwell.com>2019-10-12 22:17:29 -0400
commit12269c757d9ffcf93ba23a39c8e12cd222c5ae82 (patch)
treecf8f21f72b98355e42a4e9da04d8dbf98f8465b5 /worker/maildir/message.go
parent287bf609554c5b0e9d82f28e89f6ca988b8fd452 (diff)
Add threading support for maildirthreading
Diffstat (limited to 'worker/maildir/message.go')
-rw-r--r--worker/maildir/message.go17
1 files changed, 17 insertions, 0 deletions
diff --git a/worker/maildir/message.go b/worker/maildir/message.go
index dc5646b..283a3cd 100644
--- a/worker/maildir/message.go
+++ b/worker/maildir/message.go
@@ -1,6 +1,7 @@
package maildir
import (
+ "bufio"
"bytes"
"fmt"
"io"
@@ -8,6 +9,7 @@ import (
"github.com/emersion/go-maildir"
"github.com/emersion/go-message"
+ "github.com/emersion/go-message/textproto"
"git.sr.ht/~sircmpwn/aerc/models"
"git.sr.ht/~sircmpwn/aerc/worker/lib"
@@ -119,3 +121,18 @@ func translateFlags(maildirFlags []maildir.Flag) []models.Flag {
func (m Message) UID() uint32 {
return m.uid
}
+
+func (m Message) Headers() (*message.Header, error) {
+ f, err := m.dir.Open(m.key)
+ if err != nil {
+ return nil, err
+ }
+ defer f.Close()
+ br := bufio.NewReader(f)
+ h, err := textproto.ReadHeader(br)
+ if err != nil {
+ return nil, err
+ }
+ mh := message.Header{h}
+ return &mh, nil
+}