diff options
Diffstat (limited to 'worker/maildir/worker.go')
-rw-r--r-- | worker/maildir/worker.go | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/worker/maildir/worker.go b/worker/maildir/worker.go index 7ff5093d..2c5bc893 100644 --- a/worker/maildir/worker.go +++ b/worker/maildir/worker.go @@ -317,6 +317,8 @@ func (w *Worker) handleMessage(msg types.WorkerMessage) error { return w.handleFlagMessages(msg) case *types.AnsweredMessages: return w.handleAnsweredMessages(msg) + case *types.ForwardedMessages: + return w.handleForwardedMessages(msg) case *types.CopyMessages: return w.handleCopyMessages(msg) case *types.MoveMessages: @@ -782,6 +784,27 @@ func (w *Worker) handleAnsweredMessages(msg *types.AnsweredMessages) error { return nil } +func (w *Worker) handleForwardedMessages(msg *types.ForwardedMessages) error { + for _, uid := range msg.Uids { + m, err := w.c.Message(*w.selected, uid) + if err != nil { + w.worker.Errorf("could not get message: %v", err) + w.err(msg, err) + continue + } + if err := m.MarkForwarded(msg.Forwarded); err != nil { + w.worker.Errorf("could not mark message as answered: %v", err) + w.err(msg, err) + continue + } + + w.worker.PostMessage(&types.DirectoryInfo{ + Info: w.getDirectoryInfo(w.selectedName), + }, nil) + } + return nil +} + func (w *Worker) handleFlagMessages(msg *types.FlagMessages) error { for _, uid := range msg.Uids { m, err := w.c.Message(*w.selected, uid) |