diff --git a/common/message/main.go b/common/message/main.go index a7d3269d..20bab35e 100644 --- a/common/message/main.go +++ b/common/message/main.go @@ -12,6 +12,22 @@ const ( ) func Notify(by string, title string, description string, content string) error { + + if by == ByAll { + var errMsgs []string + if err := SendEmail(title, config.RootUserEmail, content); err != nil { + errMsgs = append(errMsgs, fmt.Sprintf("failed to send email: %v", err)) + } + if err := SendMessage(title, description, content); err != nil { + errMsgs = append(errMsgs, fmt.Sprintf("failed to send message: %v", err)) + } + + if len(errMsgs) > 0 { + return fmt.Errorf("multiple errors occurred: %v", errMsgs) + } + return nil + } + if by == ByEmail { return SendEmail(title, config.RootUserEmail, content) } diff --git a/controller/channel-test.go b/controller/channel-test.go index 0cd0fd30..f4d72cfd 100644 --- a/controller/channel-test.go +++ b/controller/channel-test.go @@ -270,7 +270,7 @@ func testChannels(ctx context.Context, notify bool, scope string) error { if notify { err := message.Notify(message.ByAll, "Channel test completed", "", "Channel test completed, if you have not received the disable notification, it means that all channels are normal") if err != nil { - logger.SysError(fmt.Sprintf("failed to send email: %s", err.Error())) + logger.SysError(fmt.Sprintf("failed to send notify: %s", err.Error())) } } }()