feat: notifier

internal/pkg/core/notifier/notifier.go

@@ -0,0 +1,23 @@
+package notifier
+
+import "context"
+
+// 表示定义消息通知器的抽象类型接口。
+type Notifier interface {
+	// 发送通知。
+	//
+	// 入参：
+	//   - ctx：上下文。
+	//   - subject：通知主题。
+	//   - message：通知内容。
+	//
+	// 出参：
+	//   - res：发送结果。
+	//   - err: 错误。
+	Notify(ctx context.Context, subject string, message string) (res *NotifyResult, err error)
+}
+
+// 表示通知发送结果的数据结构。
+type NotifyResult struct {
+	NotificationData map[string]any `json:"notificationData,omitempty"`
+}

internal/pkg/core/notifier/providers/bark/bark.go

@@ -0,0 +1,48 @@
+package email
+
+import (
+	"context"
+	"errors"
+
+	"github.com/nikoksr/notify"
+	"github.com/nikoksr/notify/service/bark"
+
+	"github.com/usual2970/certimate/internal/pkg/core/notifier"
+)
+
+type BarkNotifierConfig struct {
+	ServerUrl string `json:"serverUrl"`
+	DeviceKey string `json:"deviceKey"`
+}
+
+type BarkNotifier struct {
+	config *BarkNotifierConfig
+}
+
+var _ notifier.Notifier = (*BarkNotifier)(nil)
+
+func New(config *BarkNotifierConfig) (*BarkNotifier, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
+	return &BarkNotifier{
+		config: config,
+	}, nil
+}
+
+func (n *BarkNotifier) Notify(ctx context.Context, subject string, message string) (res *notifier.NotifyResult, err error) {
+	var srv notify.Notifier
+	if n.config.ServerUrl == "" {
+		srv = bark.New(n.config.DeviceKey)
+	} else {
+		srv = bark.NewWithServers(n.config.DeviceKey, n.config.ServerUrl)
+	}
+
+	err = srv.Send(ctx, subject, message)
+	if err != nil {
+		return nil, err
+	}
+
+	return &notifier.NotifyResult{}, nil
+}

internal/pkg/core/notifier/providers/dingtalk/dingtalk.go

@@ -0,0 +1,45 @@
+package email
+
+import (
+	"context"
+	"errors"
+
+	"github.com/nikoksr/notify/service/dingding"
+
+	"github.com/usual2970/certimate/internal/pkg/core/notifier"
+)
+
+type DingTalkNotifierConfig struct {
+	AccessToken string `json:"accessToken"`
+	Secret      string `json:"secret"`
+}
+
+type DingTalkNotifier struct {
+	config *DingTalkNotifierConfig
+}
+
+var _ notifier.Notifier = (*DingTalkNotifier)(nil)
+
+func New(config *DingTalkNotifierConfig) (*DingTalkNotifier, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
+	return &DingTalkNotifier{
+		config: config,
+	}, nil
+}
+
+func (n *DingTalkNotifier) Notify(ctx context.Context, subject string, message string) (res *notifier.NotifyResult, err error) {
+	srv := dingding.New(&dingding.Config{
+		Token:  n.config.AccessToken,
+		Secret: n.config.Secret,
+	})
+
+	err = srv.Send(ctx, subject, message)
+	if err != nil {
+		return nil, err
+	}
+
+	return &notifier.NotifyResult{}, nil
+}

internal/pkg/core/notifier/providers/email/email.go

@@ -0,0 +1,69 @@
+package email
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"net/smtp"
+	"os"
+
+	"github.com/domodwyer/mailyak/v3"
+
+	"github.com/usual2970/certimate/internal/pkg/core/notifier"
+)
+
+type EmailNotifierConfig struct {
+	SmtpHost        string `json:"smtpHost"`
+	SmtpPort        int32  `json:"smtpPort"`
+	SmtpTLS         bool   `json:"smtpTLS"`
+	Username        string `json:"username"`
+	Password        string `json:"password"`
+	SenderAddress   string `json:"senderAddress"`
+	ReceiverAddress string `json:"receiverAddress"`
+}
+
+type EmailNotifier struct {
+	config *EmailNotifierConfig
+}
+
+var _ notifier.Notifier = (*EmailNotifier)(nil)
+
+func New(config *EmailNotifierConfig) (*EmailNotifier, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
+	return &EmailNotifier{
+		config: config,
+	}, nil
+}
+
+func (n *EmailNotifier) Notify(ctx context.Context, subject string, message string) (res *notifier.NotifyResult, err error) {
+	var smtpAuth smtp.Auth
+	if n.config.Username != "" || n.config.Password != "" {
+		smtpAuth = smtp.PlainAuth("", n.config.Username, n.config.Password, n.config.SmtpHost)
+	}
+
+	var yak *mailyak.MailYak
+	if n.config.SmtpTLS {
+		os.Setenv("GODEBUG", "tlsrsakex=1") // Fix for TLS handshake error
+		yak, err = mailyak.NewWithTLS(fmt.Sprintf("%s:%d", n.config.SmtpHost, n.config.SmtpPort), smtpAuth, nil)
+		if err != nil {
+			return nil, err
+		}
+	} else {
+		yak = mailyak.New(fmt.Sprintf("%s:%d", n.config.SmtpHost, n.config.SmtpPort), smtpAuth)
+	}
+
+	yak.From(n.config.SenderAddress)
+	yak.To(n.config.ReceiverAddress)
+	yak.Subject(subject)
+	yak.Plain().Set(message)
+
+	err = yak.Send()
+	if err != nil {
+		return nil, err
+	}
+
+	return &notifier.NotifyResult{}, nil
+}

internal/pkg/core/notifier/providers/lark/lark.go

@@ -0,0 +1,41 @@
+package email
+
+import (
+	"context"
+	"errors"
+
+	"github.com/nikoksr/notify/service/lark"
+
+	"github.com/usual2970/certimate/internal/pkg/core/notifier"
+)
+
+type LarkNotifierConfig struct {
+	WebhookUrl string `json:"webhookUrl"`
+}
+
+type LarkNotifier struct {
+	config *LarkNotifierConfig
+}
+
+var _ notifier.Notifier = (*LarkNotifier)(nil)
+
+func New(config *LarkNotifierConfig) (*LarkNotifier, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
+	return &LarkNotifier{
+		config: config,
+	}, nil
+}
+
+func (n *LarkNotifier) Notify(ctx context.Context, subject string, message string) (res *notifier.NotifyResult, err error) {
+	srv := lark.NewWebhookService(n.config.WebhookUrl)
+
+	err = srv.Send(ctx, subject, message)
+	if err != nil {
+		return nil, err
+	}
+
+	return &notifier.NotifyResult{}, nil
+}

internal/pkg/core/notifier/providers/telegram/telegram.go

@@ -0,0 +1,47 @@
+package email
+
+import (
+	"context"
+	"errors"
+
+	"github.com/nikoksr/notify/service/telegram"
+
+	"github.com/usual2970/certimate/internal/pkg/core/notifier"
+)
+
+type TelegramNotifierConfig struct {
+	ApiToken string `json:"apiToken"`
+	ChatId   int64  `json:"chatId"`
+}
+
+type TelegramNotifier struct {
+	config *TelegramNotifierConfig
+}
+
+var _ notifier.Notifier = (*TelegramNotifier)(nil)
+
+func New(config *TelegramNotifierConfig) (*TelegramNotifier, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
+	return &TelegramNotifier{
+		config: config,
+	}, nil
+}
+
+func (n *TelegramNotifier) Notify(ctx context.Context, subject string, message string) (res *notifier.NotifyResult, err error) {
+	srv, err := telegram.New(n.config.ApiToken)
+	if err != nil {
+		return nil, err
+	}
+
+	srv.AddReceivers(n.config.ChatId)
+
+	err = srv.Send(ctx, subject, message)
+	if err != nil {
+		return nil, err
+	}
+
+	return &notifier.NotifyResult{}, nil
+}

internal/pkg/core/notifier/providers/webhook/webhook.go

@@ -0,0 +1,43 @@
+package email
+
+import (
+	"context"
+	"errors"
+
+	"github.com/nikoksr/notify/service/http"
+
+	"github.com/usual2970/certimate/internal/pkg/core/notifier"
+)
+
+type WebhookNotifierConfig struct {
+	Url string `json:"url"`
+}
+
+type WebhookNotifier struct {
+	config *WebhookNotifierConfig
+}
+
+var _ notifier.Notifier = (*WebhookNotifier)(nil)
+
+func New(config *WebhookNotifierConfig) (*WebhookNotifier, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
+	return &WebhookNotifier{
+		config: config,
+	}, nil
+}
+
+func (n *WebhookNotifier) Notify(ctx context.Context, subject string, message string) (res *notifier.NotifyResult, err error) {
+	srv := http.New()
+
+	srv.AddReceiversURLs(n.config.Url)
+
+	err = srv.Send(ctx, subject, message)
+	if err != nil {
+		return nil, err
+	}
+
+	return &notifier.NotifyResult{}, nil
+}

internal/pkg/core/uploader/providers/aliyun-cas/aliyun_cas.go

@@ -2,6 +2,7 @@
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -29,6 +30,10 @@ type AliyunCASUploader struct {
 var _ uploader.Uploader = (*AliyunCASUploader)(nil)
 
 func New(config *AliyunCASUploaderConfig) (*AliyunCASUploader, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
 	client, err := createSdkClient(
 		config.AccessKeyId,
 		config.AccessKeySecret,

internal/pkg/core/uploader/providers/aliyun-slb/aliyun_slb.go

@@ -4,6 +4,7 @@ import (
 	"context"
 	"crypto/sha256"
 	"encoding/hex"
+	"errors"
 	"fmt"
 	"strings"
 	"time"
@@ -31,6 +32,10 @@ type AliyunSLBUploader struct {
 var _ uploader.Uploader = (*AliyunSLBUploader)(nil)
 
 func New(config *AliyunSLBUploaderConfig) (*AliyunSLBUploader, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
 	client, err := createSdkClient(
 		config.AccessKeyId,
 		config.AccessKeySecret,

internal/pkg/core/uploader/providers/dogecloud/dogecloud.go

@@ -2,6 +2,7 @@
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -24,6 +25,10 @@ type DogeCloudUploader struct {
 var _ uploader.Uploader = (*DogeCloudUploader)(nil)
 
 func New(config *DogeCloudUploaderConfig) (*DogeCloudUploader, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
 	client, err := createSdkClient(
 		config.AccessKey,
 		config.SecretKey,

internal/pkg/core/uploader/providers/huaweicloud-elb/huaweicloud_elb.go

@@ -35,6 +35,10 @@ type HuaweiCloudELBUploader struct {
 var _ uploader.Uploader = (*HuaweiCloudELBUploader)(nil)
 
 func New(config *HuaweiCloudELBUploaderConfig) (*HuaweiCloudELBUploader, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
 	client, err := createSdkClient(
 		config.AccessKeyId,
 		config.SecretAccessKey,

internal/pkg/core/uploader/providers/huaweicloud-scm/huaweicloud_scm.go

@@ -2,6 +2,7 @@
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -30,6 +31,10 @@ type HuaweiCloudSCMUploader struct {
 var _ uploader.Uploader = (*HuaweiCloudSCMUploader)(nil)
 
 func New(config *HuaweiCloudSCMUploaderConfig) (*HuaweiCloudSCMUploader, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
 	client, err := createSdkClient(
 		config.AccessKeyId,
 		config.SecretAccessKey,

internal/pkg/core/uploader/providers/qiniu-sslcert/qiniu_sslcert.go

@@ -2,6 +2,7 @@
 
 import (
 	"context"
+	"errors"
 	"fmt"
 	"time"
 
@@ -26,6 +27,10 @@ type QiniuSSLCertUploader struct {
 var _ uploader.Uploader = (*QiniuSSLCertUploader)(nil)
 
 func New(config *QiniuSSLCertUploaderConfig) (*QiniuSSLCertUploader, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
 	client, err := createSdkClient(
 		config.AccessKey,
 		config.SecretKey,

internal/pkg/core/uploader/providers/tencentcloud-ssl/tencentcloud_ssl.go

@@ -2,6 +2,7 @@
 
 import (
 	"context"
+	"errors"
 
 	xerrors "github.com/pkg/errors"
 	"github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common"
@@ -24,6 +25,10 @@ type TencentCloudSSLUploader struct {
 var _ uploader.Uploader = (*TencentCloudSSLUploader)(nil)
 
 func New(config *TencentCloudSSLUploaderConfig) (*TencentCloudSSLUploader, error) {
+	if config == nil {
+		return nil, errors.New("config is nil")
+	}
+
 	client, err := createSdkClient(
 		config.SecretId,
 		config.SecretKey,