1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
package imap
import (
"fmt"
"github.com/ProtonMail/gluon/rfc822"
"github.com/bradenaw/juniper/xslices"
)
type ParsedMessage struct {
Body string
Structure string
Envelope string
}
func NewParsedMessage(literal []byte) (*ParsedMessage, error) {
root := rfc822.Parse(literal)
body, structure, err := Structure(root)
if err != nil {
return nil, fmt.Errorf("failed to build message body and structure: %w", err)
}
header, err := root.ParseHeader()
if err != nil {
return nil, fmt.Errorf("failed to parser message header: %w", err)
}
envelope, err := Envelope(header)
if err != nil {
return nil, fmt.Errorf("failed to build message envelope: %w", err)
}
return &ParsedMessage{
Body: body,
Structure: structure,
Envelope: envelope,
}, nil
}
type MessagesCreated struct {
updateBase
*updateWaiter
Messages []*MessageCreated
// IgnoreUnknownMailboxIDs will allow message creation when one or more MailboxIDs are not yet known when set to true.
IgnoreUnknownMailboxIDs bool
}
type MessageCreated struct {
Message Message
Literal []byte
MailboxIDs []MailboxID
ParsedMessage *ParsedMessage
}
func NewMessagesCreated(ignoreUnknownMailboxIDs bool, updates ...*MessageCreated) *MessagesCreated {
return &MessagesCreated{
updateWaiter: newUpdateWaiter(),
Messages: updates,
IgnoreUnknownMailboxIDs: ignoreUnknownMailboxIDs,
}
}
func (u *MessagesCreated) String() string {
return fmt.Sprintf("MessagesCreated: MessageCount=%v Messages=%v",
len(u.Messages),
xslices.Map(u.Messages, func(m *MessageCreated) string {
return fmt.Sprintf("ID:%v Mailboxes:%v Flags:%s",
m.Message.ID.ShortID(),
xslices.Map(m.MailboxIDs, func(mboxID MailboxID) string {
return mboxID.ShortID()
}),
m.Message.Flags.ToSlice(),
)
}),
)
}
|
