59 lines
1.3 KiB
Go
59 lines
1.3 KiB
Go
package smtp
|
|
|
|
import (
|
|
"context"
|
|
"os"
|
|
"time"
|
|
|
|
"github.com/emersion/go-smtp"
|
|
"github.com/getsentry/sentry-go"
|
|
"gitlab.com/etke.cc/go/logger"
|
|
)
|
|
|
|
// msa is mail submission agent, implements smtp.Backend
|
|
type msa struct {
|
|
log *logger.Logger
|
|
domain string
|
|
bot Bot
|
|
}
|
|
|
|
func (m *msa) newSession() *msasession {
|
|
return &msasession{
|
|
ctx: sentry.SetHubOnContext(context.Background(), sentry.CurrentHub().Clone()),
|
|
log: m.log,
|
|
bot: m.bot,
|
|
domain: m.domain,
|
|
}
|
|
}
|
|
|
|
func (m *msa) Login(state *smtp.ConnectionState, username, password string) (smtp.Session, error) {
|
|
return nil, smtp.ErrAuthUnsupported
|
|
}
|
|
|
|
func (m *msa) AnonymousLogin(state *smtp.ConnectionState) (smtp.Session, error) {
|
|
return m.newSession(), nil
|
|
}
|
|
|
|
func Start(domain, port, loglevel string, maxSize int, bot Bot) error {
|
|
log := logger.New("smtp.", loglevel)
|
|
sender := NewMTA(loglevel)
|
|
receiver := &msa{
|
|
log: log,
|
|
bot: bot,
|
|
domain: domain,
|
|
}
|
|
receiver.bot.SetMTA(sender)
|
|
s := smtp.NewServer(receiver)
|
|
s.Addr = ":" + port
|
|
s.Domain = domain
|
|
s.ReadTimeout = 10 * time.Second
|
|
s.WriteTimeout = 10 * time.Second
|
|
s.MaxMessageBytes = maxSize * 1024 * 1024
|
|
if log.GetLevel() == "DEBUG" || log.GetLevel() == "TRACE" {
|
|
s.Debug = os.Stdout
|
|
}
|
|
|
|
log.Info("Starting SMTP server on %s:%s", domain, port)
|
|
return s.ListenAndServe()
|
|
}
|