forked from drew/smtprelay
117 lines
2.9 KiB
Go
117 lines
2.9 KiB
Go
package main
|
|
|
|
import (
|
|
"crypto/tls"
|
|
"flag"
|
|
"log"
|
|
"net"
|
|
"net/smtp"
|
|
"strings"
|
|
"time"
|
|
|
|
"github.com/chrj/smtpd"
|
|
"github.com/vharitonsky/iniflags"
|
|
)
|
|
|
|
var (
|
|
hostName = flag.String("hostname", "localhost.localdomain", "Server hostname")
|
|
welcomeMsg = flag.String("welcome_msg", "", "Welcome message for SMTP session")
|
|
listen = flag.String("listen", "127.0.0.1:25 [::1]:25", "Address and port to listen for incoming SMTP")
|
|
localCert = flag.String("local_cert", "", "SSL certificate for STARTTLS/TLS")
|
|
localKey = flag.String("local_key", "", "SSL private key for STARTTLS/TLS")
|
|
localForceTLS = flag.Bool("local_forcetls", false, "Force STARTTLS (needs local_cert and local_key)")
|
|
remoteHost = flag.String("remote_host", "smtp.gmail.com:587", "Outgoing SMTP server")
|
|
remoteUser = flag.String("remote_user", "", "Username for authentication on outgoing SMTP server")
|
|
remotePass = flag.String("remote_pass", "", "Password for authentication on outgoing SMTP server")
|
|
)
|
|
|
|
func handler(peer smtpd.Peer, env smtpd.Envelope) error {
|
|
|
|
var auth smtp.Auth
|
|
host, _, _ := net.SplitHostPort(*remoteHost)
|
|
|
|
if *remoteUser != "" && *remotePass != "" {
|
|
auth = smtp.PlainAuth("", *remoteUser, *remotePass, host)
|
|
}
|
|
|
|
return smtp.SendMail(
|
|
*remoteHost,
|
|
auth,
|
|
env.Sender,
|
|
env.Recipients,
|
|
env.Data,
|
|
)
|
|
}
|
|
|
|
func main() {
|
|
|
|
iniflags.Parse()
|
|
|
|
listeners := strings.Split(*listen, " ")
|
|
|
|
for i := range(listeners) {
|
|
listener := listeners[i]
|
|
|
|
server := &smtpd.Server{
|
|
Hostname: *hostName,
|
|
WelcomeMessage: *welcomeMsg,
|
|
Handler: handler,
|
|
}
|
|
|
|
if strings.Index(listeners[i], "://") == -1 {
|
|
log.Printf("Listen on %s ...\n", listener)
|
|
go server.ListenAndServe(listener)
|
|
} else if strings.HasPrefix(listeners[i], "starttls://") {
|
|
listener = strings.TrimPrefix(listener, "starttls://")
|
|
|
|
if *localCert == "" || *localKey == "" {
|
|
log.Fatal("TLS certificate/key not defined in config")
|
|
}
|
|
|
|
cert, err := tls.LoadX509KeyPair(*localCert, *localKey)
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
server.TLSConfig = &tls.Config {
|
|
Certificates: [] tls.Certificate{cert},
|
|
}
|
|
server.ForceTLS = *localForceTLS
|
|
|
|
log.Printf("Listen on %s (STARTSSL) ...\n", listener)
|
|
lsnr, err := net.Listen("tcp", listener)
|
|
defer lsnr.Close()
|
|
|
|
go server.Serve(lsnr)
|
|
} else if strings.HasPrefix(listeners[i], "tls://") {
|
|
|
|
listener = strings.TrimPrefix(listener, "tls://")
|
|
|
|
if *localCert == "" || *localKey == "" {
|
|
log.Fatal("TLS certificate/key not defined in config")
|
|
}
|
|
|
|
cert, err := tls.LoadX509KeyPair(*localCert, *localKey)
|
|
if err != nil {
|
|
log.Fatal(err)
|
|
}
|
|
|
|
server.TLSConfig = &tls.Config {
|
|
Certificates: [] tls.Certificate{cert},
|
|
}
|
|
|
|
log.Printf("Listen on %s (TLS) ...\n", listener)
|
|
lsnr, err := tls.Listen("tcp", listener, server.TLSConfig)
|
|
defer lsnr.Close()
|
|
|
|
go server.Serve(lsnr)
|
|
} else {
|
|
log.Fatal("Unknown protocol in listener ", listener)
|
|
}
|
|
}
|
|
|
|
for true {
|
|
time.Sleep(time.Minute)
|
|
}
|
|
}
|