Merge pull request #12 from perebaj/call_email_trigg

✨ call email trigger

cmd/newsletter/main.go

@@ -19,6 +19,7 @@ type Config struct {
 	LogLevel string
 	LogType  string
 	Mongo    mongodb.Config
+	Email    newsletter.EmailConfig
 }
 
 func main() {
@@ -29,6 +30,10 @@ func main() {
 		Mongo: mongodb.Config{
 			URI: getEnvWithDefault("NL_MONGO_URI", ""),
 		},
+		Email: newsletter.EmailConfig{
+			Password: getEnvWithDefault("NL_EMAIL_PASSWORD", ""),
+			Username: getEnvWithDefault("NL_EMAIL_USERNAME", ""),
+		},
 	}
 
 	signalCh := make(chan os.Signal, 1)
@@ -77,6 +82,18 @@ func main() {
 		crawler.Run(ctx, storage, newsletter.Fetch)
 	}()
 
+	mail := newsletter.NewMailClient(cfg.Email)
+
+	go func() {
+		for range time.Tick(time.Duration(50) * time.Second) {
+			err := newsletter.EmailTrigger(ctx, storage, mail)
+			if err != nil {
+				slog.Error("error sending email", "error", err)
+				signalCh <- syscall.SIGTERM
+			}
+		}
+	}()
+
 	<-signalCh
 }
 

mail.go

@@ -13,7 +13,7 @@ const SMTPServer = "smtp.gmail.com"
 // EmailConfig contains the necessary information to authenticate in the SMTP server
 type EmailConfig struct {
 	Password string
-	UserName string
+	Username string
 }
 
 // MailClient is the client that sends emails
@@ -35,14 +35,14 @@ type Email interface {
 
 // Send sends an email to the given destination
 func (m MailClient) Send(dest []string, bodyMessage string) error {
-	auth := smtp.PlainAuth("", m.cfg.UserName, m.cfg.Password, SMTPServer)
+	auth := smtp.PlainAuth("", m.cfg.Username, m.cfg.Password, SMTPServer)
 
 	msg := []byte("To: " + dest[0] + "\r\n" +
 		"Subject: Newsletter\r\n" +
 		"\r\n" +
 		bodyMessage + "\r\n")
 
-	err := smtp.SendMail(SMTPServer+":587", auth, m.cfg.UserName, dest, []byte(msg))
+	err := smtp.SendMail(SMTPServer+":587", auth, m.cfg.Username, dest, []byte(msg))
 	if err != nil {
 		return fmt.Errorf("error sending email: %v", err)
 	}