return false
}
-func (server *smtpServer) OnMessageDelivered(en smtp.Envelope) *smtp.ReplyLine {
+func (server *smtpServer) DeliverMessage(en smtp.Envelope) *smtp.ReplyLine {
maildrop := server.maildropForAddress(en.RcptTo[0])
if maildrop == "" {
// TODO: log error
env.Data = append(trace, env.Data...)
if conn.delivery == deliverInbound {
- if reply := conn.server.OnMessageDelivered(env); reply != nil {
+ if reply := conn.server.DeliverMessage(env); reply != nil {
conn.log.Warn("message was rejected", zap.String("id", env.ID))
conn.reply(*reply)
return
mw.Close()
failure.Data = buf.Bytes()
- server.OnMessageDelivered(failure)
+ server.DeliverMessage(failure)
}
messages []Envelope
}
-func (s *deliveryServer) OnMessageDelivered(env Envelope) *ReplyLine {
+func (s *deliveryServer) DeliverMessage(env Envelope) *ReplyLine {
s.messages = append(s.messages, env)
return nil
}
VerifyAddress(mail.Address) ReplyLine
// Verify that the authc+passwd identity can send mail as authz.
Authenticate(authz, authc, passwd string) bool
- OnMessageDelivered(Envelope) *ReplyLine
+ DeliverMessage(Envelope) *ReplyLine
// RelayMessage instructs the server to send the Envelope to another
// MTA for outbound delivery.
return false
}
-func (*EmptyServerCallbacks) OnMessageDelivered(Envelope) *ReplyLine {
+func (*EmptyServerCallbacks) DeliverMessage(Envelope) *ReplyLine {
return nil
}
ID: "msgid",
}
- if rl := s.OnMessageDelivered(env); rl != nil {
+ if rl := s.DeliverMessage(env); rl != nil {
t.Errorf("Failed to deliver message: %v", rl)
}