aboutsummaryrefslogtreecommitdiffstats
path: root/worker/imap/fetch.go
diff options
context:
space:
mode:
Diffstat (limited to 'worker/imap/fetch.go')
-rw-r--r--worker/imap/fetch.go29
1 files changed, 2 insertions, 27 deletions
diff --git a/worker/imap/fetch.go b/worker/imap/fetch.go
index 74ac4827..bf60aa91 100644
--- a/worker/imap/fetch.go
+++ b/worker/imap/fetch.go
@@ -2,7 +2,6 @@ package imap
import (
"bufio"
- "bytes"
"encoding/base64"
"fmt"
"io"
@@ -61,6 +60,7 @@ func (imapw *IMAPWorker) handleFetchFullMessages(
imapw.worker.Logger.Printf("Fetching full messages")
section := &imap.BodySectionName{}
items := []imap.FetchItem{
+ imap.FetchEnvelope,
imap.FetchFlags,
imap.FetchUid,
section.FetchItem(),
@@ -103,16 +103,11 @@ func (imapw *IMAPWorker) handleFetchMessages(
done <- fmt.Errorf("could not get section %#v", section)
return
}
- reader, err := fullReader(r)
- if err != nil {
- done <- fmt.Errorf("could not read mail %#v", section)
- return
- }
imapw.worker.PostMessage(&types.FullMessage{
Message: types.RespondTo(msg),
Content: &models.FullMessage{
- Reader: reader,
+ Reader: bufio.NewReader(r),
Uid: _msg.Uid,
},
}, nil)
@@ -191,26 +186,6 @@ func getDecodedPart(task *types.FetchMessageBodyPart, msg *imap.Message,
return r, err
}
-func fullReader(r io.Reader) (io.Reader, error) {
- // parse the header for the encoding and also return it in the reader
- br := bufio.NewReader(r)
- textprotoHeader, err := textproto.ReadHeader(br)
- if err != nil {
- return nil, err
- }
- header := &mail.Header{message.Header{textprotoHeader}}
- enc := header.Get("Content-Transfer-Encoding")
-
- var buf bytes.Buffer
- err = textproto.WriteHeader(&buf, textprotoHeader)
- if err != nil {
- return nil, err
- }
- er := encodingReader(enc, br)
- full := io.MultiReader(&buf, er)
- return full, nil
-}
-
func encodingReader(encoding string, r io.Reader) io.Reader {
reader := r
// email parts are encoded as 7bit (plaintext), quoted-printable, or base64