diff --git a/internal/postman.go b/internal/postman.go index ea4fb8e..a60e437 100644 --- a/internal/postman.go +++ b/internal/postman.go @@ -10,7 +10,7 @@ import ( "test3k/authPostman/internal/config" "time" - // smtp "test3k/authPostman/internal/smtp" + smtp "test3k/authPostman/internal/smtp" "github.com/segmentio/kafka-go" ) @@ -68,16 +68,16 @@ func (s *AuthPostmanServer) ReadMessage(offset int64) error { log.Printf("send code %s to %s ...", amsg.Code, amsg.Email) // log.Printf("message at offset %d: %s = %s\n", m.Offset, string(m.Key), string(m.Value)) - // // - // message := smtp.NewMessage("Confirmation code", amsg.Code) - // message.AppendRecipient(amsg.Email) + // + message := smtp.NewMessage("Confirmation code", amsg.Code) + message.AppendRecipient(amsg.Email) - // // - // smtpSender := smtp.NewService(s.config.Smtp.Host, s.config.Smtp.Port, s.config.Smtp.Sender, s.config.Smtp.Password) - // ers := smtpSender.Send(message) - // if ers != nil { - // log.Print(ers) - // } + // + smtpSender := smtp.NewService(s.config.Smtp.Host, s.config.Smtp.Port, s.config.Smtp.Sender, s.config.Smtp.Password) + ers := smtpSender.Send(message) + if ers != nil { + log.Print(ers) + } log.Printf("send code %s to %s completed", amsg.Code, amsg.Email) }