feat: add mail push

新增电子邮箱推送

internal/domain/notify.go

@@ -6,6 +6,7 @@ const (
 	NotifyChannelTelegram = "telegram"
 	NotifyChannelLark     = "lark"
 	NotifyChannelServerChan = "serverchan"
+	NotifyChannelMail = "mail"
 )
 
 type NotifyTestPushReq struct {

internal/notify/mail.go

@@ -0,0 +1,58 @@
+package notify
+
+import (
+	"context"
+	"net/smtp"
+)
+
+type Mail struct {
+	senderAddress     string
+	smtpHostAddr      string
+	smtpHostPort	  string
+	smtpAuth          smtp.Auth
+	receiverAddresses string
+}
+
+func NewMail(senderAddress, receiverAddresses, smtpHostAddr, smtpHostPort string) *Mail {
+	if(smtpHostPort == "") {
+		smtpHostPort = "25"
+	}
+
+	return &Mail{
+		senderAddress:     senderAddress,
+		smtpHostAddr:      smtpHostAddr,
+		smtpHostPort:      smtpHostPort,
+		receiverAddresses: receiverAddresses,
+	}
+}
+
+func (m *Mail) SetAuth(username, password string) {
+	m.smtpAuth = smtp.PlainAuth("", username, password, m.smtpHostAddr)
+}
+
+func (m *Mail) Send(ctx context.Context, subject, message string) error {
+	// 构建邮件
+    from := m.senderAddress
+    to := []string{m.receiverAddresses}
+    msg := []byte(
+		"From: " + from + "\r\n" +
+		"To: " + m.receiverAddresses + "\r\n" +
+        "Subject: " + subject + "\r\n" +
+        "\r\n" +
+        message + "\r\n")
+	
+	var smtpAddress string
+	// 组装邮箱服务器地址
+	if(m.smtpHostPort == "25"){
+		smtpAddress = m.smtpHostAddr
+	}else{
+		smtpAddress = m.smtpHostAddr + ":" + m.smtpHostPort
+	}
+
+    err := smtp.SendMail(smtpAddress, m.smtpAuth, from, to, msg)
+    if err != nil {
+        return err
+    }
+
+	return nil
+}

internal/notify/notify.go

@@ -106,6 +106,8 @@ func getNotifier(channel string, conf map[string]any) (notifyPackage.Notifier, e
 		return getWebhookNotifier(conf), nil
 	case domain.NotifyChannelServerChan:
 		return getServerChanNotifier(conf), nil
+	case domain.NotifyChannelMail:
+		return getMailNotifier(conf), nil
 	}
 
 	return nil, fmt.Errorf("notifier not found")
@@ -166,6 +168,14 @@ func getLarkNotifier(conf map[string]any) notifyPackage.Notifier {
 	return lark.NewWebhookService(getString(conf, "webhookUrl"))
 }
 
+func getMailNotifier(conf map[string]any) notifyPackage.Notifier {
+	rs := NewMail(getString(conf, "senderAddress"),getString(conf,"receiverAddress"), getString(conf, "smtpHostAddr"), getString(conf, "smtpHostPort"))
+
+	rs.SetAuth(getString(conf, "username"), getString(conf, "password"))
+
+	return rs
+}
+
 func getString(conf map[string]any, key string) string {
 	if _, ok := conf[key]; !ok {
 		return ""