diff options
Diffstat (limited to 'commands/compose/send.go')
-rw-r--r-- | commands/compose/send.go | 48 |
1 files changed, 28 insertions, 20 deletions
diff --git a/commands/compose/send.go b/commands/compose/send.go index 1047ebad..91fd42bd 100644 --- a/commands/compose/send.go +++ b/commands/compose/send.go @@ -228,8 +228,7 @@ func send(composer *app.Composer, ctx sendCtx, } if ctx.copyto != "" && ctx.scheme != "jmap" { app.PushStatus("Copying to "+ctx.copyto, 10*time.Second) - errch := copyToSent(composer.Worker(), ctx.copyto, - copyBuf.Len(), ©Buf) + errch := copyToSent(ctx.copyto, copyBuf.Len(), ©Buf) err = <-errch if err != nil { errmsg := fmt.Sprintf( @@ -558,23 +557,32 @@ func newJmapSender( return writer, err } -func copyToSent(worker *types.Worker, dest string, - n int, msg io.Reader, -) <-chan error { - errCh := make(chan error) - worker.PostAction(&types.AppendMessage{ - Destination: dest, - Flags: models.SeenFlag, - Date: time.Now(), - Reader: msg, - Length: n, - }, func(msg types.WorkerMessage) { - switch msg := msg.(type) { - case *types.Done: - errCh <- nil - case *types.Error: - errCh <- msg.Error - } - }) +func copyToSent(dest string, n int, msg io.Reader) <-chan error { + errCh := make(chan error, 1) + acct := app.SelectedAccount() + if acct == nil { + errCh <- errors.New("No account selected") + return errCh + } + store := acct.Store() + if store == nil { + errCh <- errors.New("No message store selected") + return errCh + } + store.Append( + dest, + models.SeenFlag, + time.Now(), + msg, + n, + func(msg types.WorkerMessage) { + switch msg := msg.(type) { + case *types.Done: + errCh <- nil + case *types.Error: + errCh <- msg.Error + } + }, + ) return errCh } |