93 lines
2.9 KiB
Go
93 lines
2.9 KiB
Go
package email
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
"net/url"
|
|
"time"
|
|
|
|
"github.com/rideaware/admin-panel/internal/config"
|
|
"github.com/rideaware/admin-panel/internal/database"
|
|
|
|
"github.com/wneessen/go-mail"
|
|
)
|
|
|
|
// SendUpdate sends a newsletter with the given subject and body to all subscriber emails stored in the database.
|
|
// It returns a human-readable status message and, when subscriber retrieval fails, the underlying error.
|
|
// - If retrieving subscribers fails: returns "Failed to retrieve subscribers" and the error.
|
|
// - If no subscribers are found: returns "No subscribers found." and nil.
|
|
// - If sending to a specific subscriber fails: returns "Failed to send to <email>" and nil.
|
|
// - On success: returns "Email has been sent to all subscribers." and nil.
|
|
// Note: logging the newsletter entry in the database is attempted after sending and any logging failure is non-fatal.
|
|
func SendUpdate(subject, body string) (string, error) {
|
|
subscribers, err := database.GetAllEmails()
|
|
if err != nil {
|
|
return "Failed to retrieve subscribers", err
|
|
}
|
|
if len(subscribers) == 0 {
|
|
return "No subscribers found.", nil
|
|
}
|
|
var succeeded, failed int
|
|
for _, email := range subscribers {
|
|
if send(subject, body, email) {
|
|
succeeded++
|
|
} else {
|
|
failed++
|
|
}
|
|
}
|
|
if err := database.LogNewsletter(subject, body); err != nil {
|
|
log.Printf("Error logging newsletter: %v", err)
|
|
}
|
|
if failed == 0 {
|
|
return fmt.Sprintf("Email sent to all %d subscribers.", succeeded), nil
|
|
}
|
|
return fmt.Sprintf("Sent to %d/%d subscribers; %d failed.", succeeded, succeeded+failed, failed), nil
|
|
}
|
|
|
|
// send constructs and sends an HTML newsletter update to the specified recipient using the current SMTP configuration.
|
|
// It embeds an unsubscribe link for the recipient and returns true if the message was sent successfully, false if client creation, message setup, or sending fails.
|
|
func send(subject, body, recipient string) bool {
|
|
cfg := config.Current
|
|
|
|
client, err := mail.NewClient(
|
|
cfg.SMTPServer,
|
|
mail.WithPort(cfg.SMTPPort),
|
|
mail.WithSMTPAuth(mail.SMTPAuthPlain),
|
|
mail.WithUsername(cfg.SMTPUser),
|
|
mail.WithPassword(cfg.SMTPPassword),
|
|
mail.WithTimeout(10*time.Second),
|
|
)
|
|
if err != nil {
|
|
log.Printf("Failed to create mail client: %v", err)
|
|
return false
|
|
}
|
|
defer client.Close()
|
|
|
|
m := mail.NewMsg()
|
|
if err := m.From(cfg.SenderEmail); err != nil {
|
|
log.Printf("Failed to set from: %v", err)
|
|
return false
|
|
}
|
|
if err := m.To(recipient); err != nil {
|
|
log.Printf("Failed to set to: %v", err)
|
|
return false
|
|
}
|
|
m.Subject(subject)
|
|
|
|
unsubLink := fmt.Sprintf("https://%s/unsubscribe?email=%s",
|
|
cfg.BaseURL, url.QueryEscape(recipient))
|
|
|
|
htmlBody := fmt.Sprintf(
|
|
"%s<br><br>If you ever wish to unsubscribe, "+
|
|
"please click <a href='%s'>here</a>",
|
|
body, unsubLink)
|
|
m.SetBodyString(mail.TypeTextHTML, htmlBody)
|
|
|
|
if err := client.Send(m); err != nil {
|
|
log.Printf("Failed to send email to %s: %v", recipient, err)
|
|
return false
|
|
}
|
|
|
|
log.Printf("Update email sent to: %s", recipient)
|
|
return true
|
|
} |