*

internal/authPostman.go

@@ -65,19 +65,11 @@ func (s *AuthPostmanServer) ReadMessage(offset int64) error {
 		// postman := telegram.NewService(s.config.Telegram.ChatToken)
 		// message := postman.NewMessage(s.config.Telegram.ChatID, text)
 		// ers := postman.SendMessage(message)
-		// if ers != nil {
-		// 	s.logger.Print(ers)
-		// } else {
-		// 	s.logger.Printf("send code %s to %s completed", amsg.Code, amsg.Email)
-		// }
 
-		//
+		postman := smtp.NewService(s.config.Smtp.Host, s.config.Smtp.Port, s.config.Smtp.Sender, s.config.Smtp.Password)
 		message := smtp.NewMessage("Confirmation code", text)
 		message.AppendRecipient(msg.Email)
-
-		//
-		smtpSender := smtp.NewService(s.config.Smtp.Host, s.config.Smtp.Port, s.config.Smtp.Sender, s.config.Smtp.Password)
-		ers := smtpSender.Send(message)
+		ers := postman.Send(message)
 		if ers != nil {
 			s.logger.Print(ers)
 		} else {

scripts/start.sh

@@ -2,10 +2,10 @@
 
 export SMTP_HOST=smtp.mail.ru
 export SMTP_PORT=587
-export SMTP_SENDER=test3kbot@mail.ru
-export SMTP_PASSWORD=ip02TsJTEaDTyehpGYQH
-export KAFKA_PORT=9092
+export SMTP_SENDER=test3kbotan@mail.ru
+export SMTP_PASSWORD=vSJYfUbpamiUFkKx1DJA
+export KAFKA_PORT=19092
 export KAFKA_HOST=127.0.0.1
-export KAFKA_HOST=37.143.12.169
+# export KAFKA_HOST=37.143.12.169
 
 ./authPostmanService