用例:我们有一个邮箱,我们可以在其中接收来自客户的邮件。在进一步处理之前,我必须检查它们是否符合协议(主题必须匹配正则表达式,每封邮件只有一个附件等)我有以下申请:
import (
"fmt"
"imaptest/src/db"
"io"
"log"
"path/filepath"
"strings"
"github.com/emersion/go-imap"
"github.com/emersion/go-imap/client"
"github.com/emersion/go-message"
"github.com/iglin/go-config"
)
(...)
//Channel for the messages
messages := make(chan *imap.Message, 10)
//Channel for retrieve if an error appeared
done := make(chan error, 1)
go func() {
seqset := new(imap.SeqSet)
seqset.AddRange(1, mbox.Messages)
//Fetch the messages and push them into the channel
done <- c.Fetch(seqset, []imap.FetchItem{imap.FetchEnvelope, imap.FetchRFC822}, messages)
}()
//SeqSet for invalid messages
seqsetErrorMessages := new(imap.SeqSet)
//SeqSet for valid messages
seqsetValidMessages := new(imap.SeqSet)
for msg := range messages {
//Different checks like are there attachments
//Matches the subject with a specific regex
if isMessageValid(msg) {
//Message is valid
seqsetValidMessages.AddNum(msg.SeqNum)
} else {
//Message is invalid
seqsetErrorMessages.AddNum(msg.SeqNum)
}
}
//Check if there was an error when fetching the messages
if err := <-done; err != nil {
log.Fatal(err)
}
//Move all invalid messages to error
if !seqsetErrorMessages.Empty() {
if err := c.Move(seqsetErrorMessages, FOLDER_ERROR); err != nil {
log.Fatalf("Error on move to %s: %v", FOLDER_ERROR, err)
}
}
//Move all valid messages to toExport
if !seqsetValidMessages.Empty() {
if err := c.Move(seqsetValidMessages, FOLDER_OUT); err != nil {
log.Fatalf("Error on move to %s: %v", FOLDER_OUT, err)
}
}
FOLDER_OUT 和 FOLDER_ERROR 是此邮箱中现有文件夹的常量字符串。
在源文件夹的所有邮件都有效(或无效)的情况下,一切都很好,所有邮件都被移动了。
但是如果我遇到同时存在有效邮件和无效邮件的情况,我会收到以下错误:
移动到错误时出错:指定的消息集无效。
我还尝试使用“msg.Uid”和“c.UidMove()”代替“msg.Seqnum”和“c.Move()”,但这会导致相同的结果。
这怎么能解决?
森栏
相关分类