aboutsummaryrefslogtreecommitdiffstats
path: root/worker/imap/movecopy.go
diff options
context:
space:
mode:
Diffstat (limited to 'worker/imap/movecopy.go')
-rw-r--r--worker/imap/movecopy.go27
1 files changed, 27 insertions, 0 deletions
diff --git a/worker/imap/movecopy.go b/worker/imap/movecopy.go
index 8c42a2eb..1234e602 100644
--- a/worker/imap/movecopy.go
+++ b/worker/imap/movecopy.go
@@ -1,6 +1,8 @@
package imap
import (
+ "io"
+
"git.sr.ht/~sircmpwn/aerc2/worker/types"
)
@@ -14,3 +16,28 @@ func (imapw *IMAPWorker) handleCopyMessages(msg *types.CopyMessages) {
imapw.worker.PostMessage(&types.Done{types.RespondTo(msg)}, nil)
}
}
+
+type appendLiteral struct {
+ io.Reader
+ Length int
+}
+
+func (m appendLiteral) Len() int {
+ return m.Length
+}
+
+func (imapw *IMAPWorker) handleAppendMessage(msg *types.AppendMessage) {
+ if err := imapw.client.Append(msg.Destination, msg.Flags, msg.Date,
+ &appendLiteral{
+ Reader: msg.Reader,
+ Length: msg.Length,
+ }); err != nil {
+
+ imapw.worker.PostMessage(&types.Error{
+ Message: types.RespondTo(msg),
+ Error: err,
+ }, nil)
+ } else {
+ imapw.worker.PostMessage(&types.Done{types.RespondTo(msg)}, nil)
+ }
+}