2019-05-14 19:07:48 +02:00
|
|
|
package compose
|
|
|
|
|
|
|
|
import (
|
2019-05-14 20:05:29 +02:00
|
|
|
"crypto/tls"
|
|
|
|
"fmt"
|
2019-05-16 01:41:21 +02:00
|
|
|
"io"
|
2019-05-14 20:05:29 +02:00
|
|
|
"net/mail"
|
|
|
|
"net/url"
|
2019-07-27 17:19:49 +02:00
|
|
|
"os/exec"
|
2019-05-14 20:05:29 +02:00
|
|
|
"strings"
|
2019-05-14 20:18:01 +02:00
|
|
|
"time"
|
2019-05-14 20:05:29 +02:00
|
|
|
|
|
|
|
"github.com/emersion/go-sasl"
|
|
|
|
"github.com/emersion/go-smtp"
|
2019-07-28 14:33:46 +02:00
|
|
|
"github.com/google/shlex"
|
2019-05-16 01:41:21 +02:00
|
|
|
"github.com/miolini/datacounter"
|
2019-05-25 17:56:56 +02:00
|
|
|
"github.com/pkg/errors"
|
2019-05-14 19:07:48 +02:00
|
|
|
|
2020-03-03 14:45:06 +01:00
|
|
|
"git.sr.ht/~sircmpwn/aerc/models"
|
2019-05-18 02:57:10 +02:00
|
|
|
"git.sr.ht/~sircmpwn/aerc/widgets"
|
|
|
|
"git.sr.ht/~sircmpwn/aerc/worker/types"
|
2019-05-14 19:07:48 +02:00
|
|
|
)
|
|
|
|
|
2019-06-27 19:33:11 +02:00
|
|
|
type Send struct{}
|
|
|
|
|
2019-05-14 19:07:48 +02:00
|
|
|
func init() {
|
2019-06-27 19:33:11 +02:00
|
|
|
register(Send{})
|
|
|
|
}
|
|
|
|
|
2019-09-03 21:34:03 +02:00
|
|
|
func (Send) Aliases() []string {
|
2019-06-27 19:33:11 +02:00
|
|
|
return []string{"send"}
|
|
|
|
}
|
|
|
|
|
2019-09-03 21:34:03 +02:00
|
|
|
func (Send) Complete(aerc *widgets.Aerc, args []string) []string {
|
2019-06-27 19:33:11 +02:00
|
|
|
return nil
|
2019-05-14 19:07:48 +02:00
|
|
|
}
|
|
|
|
|
2019-09-03 21:34:03 +02:00
|
|
|
func (Send) Execute(aerc *widgets.Aerc, args []string) error {
|
2019-05-14 19:07:48 +02:00
|
|
|
if len(args) > 1 {
|
2019-06-27 19:33:11 +02:00
|
|
|
return errors.New("Usage: send")
|
2019-05-14 19:07:48 +02:00
|
|
|
}
|
|
|
|
composer, _ := aerc.SelectedTab().(*widgets.Composer)
|
2019-05-14 20:05:29 +02:00
|
|
|
config := composer.Config()
|
|
|
|
|
|
|
|
if config.Outgoing == "" {
|
|
|
|
return errors.New(
|
|
|
|
"No outgoing mail transport configured for this account")
|
|
|
|
}
|
|
|
|
|
2019-06-21 20:33:09 +02:00
|
|
|
aerc.Logger().Println("Sending mail")
|
|
|
|
|
2019-05-14 20:05:29 +02:00
|
|
|
uri, err := url.Parse(config.Outgoing)
|
2019-05-14 19:07:48 +02:00
|
|
|
if err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return errors.Wrap(err, "url.Parse(outgoing)")
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
|
|
|
var (
|
|
|
|
scheme string
|
|
|
|
auth string = "plain"
|
|
|
|
)
|
2019-07-27 17:19:49 +02:00
|
|
|
if uri.Scheme != "" {
|
|
|
|
parts := strings.Split(uri.Scheme, "+")
|
|
|
|
if len(parts) == 1 {
|
|
|
|
scheme = parts[0]
|
|
|
|
} else if len(parts) == 2 {
|
|
|
|
scheme = parts[0]
|
|
|
|
auth = parts[1]
|
|
|
|
} else {
|
|
|
|
return fmt.Errorf("Unknown transfer protocol %s", uri.Scheme)
|
|
|
|
}
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
|
|
|
|
2019-05-16 16:49:50 +02:00
|
|
|
header, rcpts, err := composer.PrepareHeader()
|
2019-05-14 20:05:29 +02:00
|
|
|
if err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return errors.Wrap(err, "PrepareHeader")
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
if config.From == "" {
|
|
|
|
return errors.New("No 'From' configured for this account")
|
|
|
|
}
|
|
|
|
from, err := mail.ParseAddress(config.From)
|
|
|
|
if err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return errors.Wrap(err, "ParseAddress(config.From)")
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
var (
|
|
|
|
saslClient sasl.Client
|
|
|
|
conn *smtp.Client
|
|
|
|
)
|
|
|
|
switch auth {
|
|
|
|
case "":
|
|
|
|
fallthrough
|
|
|
|
case "none":
|
|
|
|
saslClient = nil
|
2019-10-29 18:11:38 +01:00
|
|
|
case "login":
|
|
|
|
password, _ := uri.User.Password()
|
|
|
|
saslClient = sasl.NewLoginClient(uri.User.Username(), password)
|
2019-05-14 20:05:29 +02:00
|
|
|
case "plain":
|
|
|
|
password, _ := uri.User.Password()
|
|
|
|
saslClient = sasl.NewPlainClient("", uri.User.Username(), password)
|
|
|
|
default:
|
|
|
|
return fmt.Errorf("Unsupported auth mechanism %s", auth)
|
|
|
|
}
|
|
|
|
|
2019-05-14 20:29:50 +02:00
|
|
|
aerc.RemoveTab(composer)
|
2019-05-14 20:18:01 +02:00
|
|
|
|
2019-05-17 17:22:30 +02:00
|
|
|
var starttls bool
|
|
|
|
if starttls_, ok := config.Params["smtp-starttls"]; ok {
|
|
|
|
starttls = starttls_ == "yes"
|
|
|
|
}
|
|
|
|
|
2019-07-27 17:19:49 +02:00
|
|
|
smtpAsync := func() (int, error) {
|
2019-05-14 20:18:01 +02:00
|
|
|
switch scheme {
|
|
|
|
case "smtp":
|
|
|
|
host := uri.Host
|
2019-05-20 23:25:12 +02:00
|
|
|
serverName := uri.Host
|
2019-05-14 20:18:01 +02:00
|
|
|
if !strings.ContainsRune(host, ':') {
|
|
|
|
host = host + ":587" // Default to submission port
|
2019-05-20 23:25:12 +02:00
|
|
|
} else {
|
|
|
|
serverName = host[:strings.IndexRune(host, ':')]
|
2019-05-14 20:18:01 +02:00
|
|
|
}
|
|
|
|
conn, err = smtp.Dial(host)
|
|
|
|
if err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return 0, errors.Wrap(err, "smtp.Dial")
|
2019-05-14 20:18:01 +02:00
|
|
|
}
|
|
|
|
defer conn.Close()
|
|
|
|
if sup, _ := conn.Extension("STARTTLS"); sup {
|
2019-05-17 17:22:30 +02:00
|
|
|
if !starttls {
|
|
|
|
err := errors.New("STARTTLS is supported by this server, " +
|
|
|
|
"but not set in accounts.conf. " +
|
|
|
|
"Add smtp-starttls=yes")
|
|
|
|
return 0, err
|
|
|
|
}
|
2019-05-20 23:25:12 +02:00
|
|
|
if err = conn.StartTLS(&tls.Config{
|
|
|
|
ServerName: serverName,
|
|
|
|
}); err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return 0, errors.Wrap(err, "StartTLS")
|
2019-05-17 17:22:30 +02:00
|
|
|
}
|
|
|
|
} else {
|
|
|
|
if starttls {
|
|
|
|
err := errors.New("STARTTLS requested, but not supported " +
|
|
|
|
"by this SMTP server. Is someone tampering with your " +
|
|
|
|
"connection?")
|
|
|
|
return 0, err
|
2019-05-14 20:18:01 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
case "smtps":
|
|
|
|
host := uri.Host
|
2019-05-20 23:25:12 +02:00
|
|
|
serverName := uri.Host
|
2019-05-14 20:18:01 +02:00
|
|
|
if !strings.ContainsRune(host, ':') {
|
|
|
|
host = host + ":465" // Default to smtps port
|
2019-05-20 23:25:12 +02:00
|
|
|
} else {
|
|
|
|
serverName = host[:strings.IndexRune(host, ':')]
|
2019-05-14 20:18:01 +02:00
|
|
|
}
|
2019-05-20 23:25:12 +02:00
|
|
|
conn, err = smtp.DialTLS(host, &tls.Config{
|
|
|
|
ServerName: serverName,
|
|
|
|
})
|
2019-05-14 20:18:01 +02:00
|
|
|
if err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return 0, errors.Wrap(err, "smtp.DialTLS")
|
2019-05-14 20:18:01 +02:00
|
|
|
}
|
|
|
|
defer conn.Close()
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
2019-05-14 20:18:01 +02:00
|
|
|
|
|
|
|
if saslClient != nil {
|
|
|
|
if err = conn.Auth(saslClient); err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return 0, errors.Wrap(err, "conn.Auth")
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
|
|
|
}
|
2019-05-14 20:18:01 +02:00
|
|
|
// TODO: the user could conceivably want to use a different From and sender
|
2020-03-03 17:55:06 +01:00
|
|
|
if err = conn.Mail(from.Address, nil); err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return 0, errors.Wrap(err, "conn.Mail")
|
2019-05-14 20:18:01 +02:00
|
|
|
}
|
2019-06-21 20:33:09 +02:00
|
|
|
aerc.Logger().Printf("rcpt to: %v", rcpts)
|
2019-05-14 20:18:01 +02:00
|
|
|
for _, rcpt := range rcpts {
|
|
|
|
if err = conn.Rcpt(rcpt); err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return 0, errors.Wrap(err, "conn.Rcpt")
|
2019-05-14 20:18:01 +02:00
|
|
|
}
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
2019-05-14 20:18:01 +02:00
|
|
|
wc, err := conn.Data()
|
2019-05-14 20:05:29 +02:00
|
|
|
if err != nil {
|
2019-05-25 17:56:56 +02:00
|
|
|
return 0, errors.Wrap(err, "conn.Data")
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
2019-05-14 20:18:01 +02:00
|
|
|
defer wc.Close()
|
2019-05-16 01:41:21 +02:00
|
|
|
ctr := datacounter.NewWriterCounter(wc)
|
|
|
|
composer.WriteMessage(header, ctr)
|
|
|
|
return int(ctr.Count()), nil
|
2019-05-14 20:05:29 +02:00
|
|
|
}
|
|
|
|
|
2019-07-27 17:19:49 +02:00
|
|
|
sendmailAsync := func() (int, error) {
|
2019-07-28 14:33:46 +02:00
|
|
|
args, err := shlex.Split(uri.Path)
|
|
|
|
if err != nil {
|
|
|
|
return 0, err
|
|
|
|
}
|
|
|
|
if len(args) == 0 {
|
|
|
|
return 0, fmt.Errorf("no command specified")
|
|
|
|
}
|
|
|
|
bin := args[0]
|
|
|
|
args = append(args[1:], rcpts...)
|
|
|
|
cmd := exec.Command(bin, args...)
|
2019-07-27 17:19:49 +02:00
|
|
|
wc, err := cmd.StdinPipe()
|
|
|
|
if err != nil {
|
|
|
|
return 0, errors.Wrap(err, "cmd.StdinPipe")
|
|
|
|
}
|
|
|
|
defer wc.Close()
|
|
|
|
go cmd.Run()
|
|
|
|
ctr := datacounter.NewWriterCounter(wc)
|
|
|
|
composer.WriteMessage(header, ctr)
|
|
|
|
return int(ctr.Count()), nil
|
|
|
|
}
|
|
|
|
|
|
|
|
sendAsync := func() (int, error) {
|
2019-07-27 18:36:30 +02:00
|
|
|
fmt.Println(scheme)
|
2019-07-27 17:19:49 +02:00
|
|
|
switch scheme {
|
|
|
|
case "smtp":
|
2019-07-27 18:36:30 +02:00
|
|
|
fallthrough
|
2019-07-27 17:19:49 +02:00
|
|
|
case "smtps":
|
|
|
|
return smtpAsync()
|
|
|
|
case "":
|
|
|
|
return sendmailAsync()
|
|
|
|
}
|
|
|
|
return 0, errors.New("Unknown scheme")
|
|
|
|
}
|
|
|
|
|
2019-05-14 20:18:01 +02:00
|
|
|
go func() {
|
2020-05-28 16:32:32 +02:00
|
|
|
aerc.PushStatus("Sending...", 10*time.Second)
|
2019-05-16 01:41:21 +02:00
|
|
|
nbytes, err := sendAsync()
|
|
|
|
if err != nil {
|
2020-05-27 07:37:02 +02:00
|
|
|
aerc.SetError(" " + err.Error())
|
2019-05-16 01:41:21 +02:00
|
|
|
return
|
|
|
|
}
|
|
|
|
if config.CopyTo != "" {
|
2020-05-28 16:32:32 +02:00
|
|
|
aerc.PushStatus("Copying to "+config.CopyTo, 10*time.Second)
|
2019-05-16 01:41:21 +02:00
|
|
|
worker := composer.Worker()
|
|
|
|
r, w := io.Pipe()
|
|
|
|
worker.PostAction(&types.AppendMessage{
|
|
|
|
Destination: config.CopyTo,
|
2020-03-03 14:45:06 +01:00
|
|
|
Flags: []models.Flag{models.SeenFlag},
|
2019-05-18 21:34:16 +02:00
|
|
|
Date: time.Now(),
|
|
|
|
Reader: r,
|
|
|
|
Length: nbytes,
|
2019-05-16 01:41:21 +02:00
|
|
|
}, func(msg types.WorkerMessage) {
|
|
|
|
switch msg := msg.(type) {
|
|
|
|
case *types.Done:
|
2020-05-28 16:32:32 +02:00
|
|
|
aerc.PushStatus("Message sent.", 10*time.Second)
|
2019-05-16 01:41:21 +02:00
|
|
|
r.Close()
|
2020-05-25 16:59:48 +02:00
|
|
|
composer.SetSent()
|
2019-05-16 01:41:21 +02:00
|
|
|
composer.Close()
|
|
|
|
case *types.Error:
|
2020-05-28 16:32:32 +02:00
|
|
|
aerc.PushError(" "+msg.Error.Error(), 10*time.Second)
|
2019-05-16 01:41:21 +02:00
|
|
|
r.Close()
|
|
|
|
composer.Close()
|
|
|
|
}
|
|
|
|
})
|
2019-05-16 16:49:50 +02:00
|
|
|
header, _, _ := composer.PrepareHeader()
|
2019-05-16 01:41:21 +02:00
|
|
|
composer.WriteMessage(header, w)
|
|
|
|
w.Close()
|
|
|
|
} else {
|
2020-05-28 16:32:32 +02:00
|
|
|
aerc.PushStatus("Message sent.", 10*time.Second)
|
2020-05-25 16:59:48 +02:00
|
|
|
composer.SetSent()
|
2019-05-16 01:41:21 +02:00
|
|
|
composer.Close()
|
|
|
|
}
|
2019-05-14 20:18:01 +02:00
|
|
|
}()
|
2019-05-14 19:07:48 +02:00
|
|
|
return nil
|
|
|
|
}
|