71 lines
1.6 KiB
Go
71 lines
1.6 KiB
Go
package memory
|
|
|
|
import (
|
|
"bytes"
|
|
"time"
|
|
|
|
"github.com/emersion/go-imap"
|
|
"github.com/emersion/go-imap/backend/backendutil"
|
|
"github.com/emersion/go-message"
|
|
)
|
|
|
|
type Message struct {
|
|
Uid uint32
|
|
Date time.Time
|
|
Size uint32
|
|
Flags []string
|
|
Body []byte
|
|
}
|
|
|
|
func (m *Message) entity() (*message.Entity, error) {
|
|
return message.Read(bytes.NewReader(m.Body))
|
|
}
|
|
|
|
func (m *Message) Fetch(seqNum uint32, items []imap.FetchItem) (*imap.Message, error) {
|
|
fetched := imap.NewMessage(seqNum, items)
|
|
for _, item := range items {
|
|
switch item {
|
|
case imap.FetchEnvelope:
|
|
e, _ := m.entity()
|
|
fetched.Envelope, _ = backendutil.FetchEnvelope(e.Header)
|
|
case imap.FetchBody, imap.FetchBodyStructure:
|
|
e, _ := m.entity()
|
|
fetched.BodyStructure, _ = backendutil.FetchBodyStructure(e, item == imap.FetchBodyStructure)
|
|
case imap.FetchFlags:
|
|
fetched.Flags = m.Flags
|
|
case imap.FetchInternalDate:
|
|
fetched.InternalDate = m.Date
|
|
case imap.FetchRFC822Size:
|
|
fetched.Size = m.Size
|
|
case imap.FetchUid:
|
|
fetched.Uid = m.Uid
|
|
default:
|
|
section, err := imap.ParseBodySectionName(item)
|
|
if err != nil {
|
|
break
|
|
}
|
|
|
|
e, _ := m.entity()
|
|
l, _ := backendutil.FetchBodySection(e, section)
|
|
fetched.Body[section] = l
|
|
}
|
|
}
|
|
|
|
return fetched, nil
|
|
}
|
|
|
|
func (m *Message) Match(seqNum uint32, c *imap.SearchCriteria) (bool, error) {
|
|
if !backendutil.MatchSeqNumAndUid(seqNum, m.Uid, c) {
|
|
return false, nil
|
|
}
|
|
if !backendutil.MatchDate(m.Date, c) {
|
|
return false, nil
|
|
}
|
|
if !backendutil.MatchFlags(m.Flags, c) {
|
|
return false, nil
|
|
}
|
|
|
|
e, _ := m.entity()
|
|
return backendutil.Match(e, c)
|
|
}
|