feat: deprecate old notification module and introduce new notifier module

internal/workflow/node-processor/notify_node.go

@@ -30,25 +30,50 @@ func (n *notifyNode) Process(ctx context.Context) error {
 
 	nodeConfig := n.node.GetConfigForNotify()
 
-	// 获取通知配置
-	settings, err := n.settingsRepo.GetByName(ctx, "notifyChannels")
+	if nodeConfig.Provider == "" {
+		// Deprecated: v0.4.x 将废弃
+		// 兼容旧版本的通知渠道
+		n.logger.Warn("WARNING! you are using the notification channel from global settings, which will be deprecated in the future")
+
+		// 获取通知配置
+		settings, err := n.settingsRepo.GetByName(ctx, "notifyChannels")
+		if err != nil {
+			return err
+		}
+
+		// 获取通知渠道
+		channelConfig, err := settings.GetNotifyChannelConfig(nodeConfig.Channel)
+		if err != nil {
+			return err
+		}
+
+		// 发送通知
+		if err := notify.SendToChannel(nodeConfig.Subject, nodeConfig.Message, nodeConfig.Channel, channelConfig); err != nil {
+			n.logger.Warn("failed to notify", slog.String("channel", nodeConfig.Channel))
+			return err
+		}
+
+		n.logger.Info("notify completed")
+		return nil
+	}
+
+	// 初始化通知器
+	deployer, err := notify.NewWithWorkflowNode(notify.NotifierWithWorkflowNodeConfig{
+		Node:    n.node,
+		Logger:  n.logger,
+		Subject: nodeConfig.Subject,
+		Message: nodeConfig.Message,
+	})
 	if err != nil {
+		n.logger.Warn("failed to create notifier provider")
 		return err
 	}
 
-	// 获取通知渠道
-	channelConfig, err := settings.GetNotifyChannelConfig(nodeConfig.Channel)
-	if err != nil {
+	// 推送通知
+	if err := deployer.Notify(ctx); err != nil {
+		n.logger.Warn("failed to notify")
 		return err
 	}
 
-	// 发送通知
-	if err := notify.SendToChannel(nodeConfig.Subject, nodeConfig.Message, nodeConfig.Channel, channelConfig); err != nil {
-		n.logger.Warn("failed to notify", slog.String("channel", nodeConfig.Channel))
-		return err
-	}
-
-	n.logger.Info("notify completed")
-
 	return nil
 }