🔊 Log an error and continue if an integration fails to send

gabe565 · Jun 7, 2023 · a9a5bf4 · a9a5bf4
1 parent 3f3521f
commit a9a5bf4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 10 deletions.
diff --git a/internal/domain/domain.go b/internal/domain/domain.go
@@ -77,9 +77,7 @@ func (d *Domain) NotifyThreshold() error {
 		for _, threshold := range viper.GetIntSlice("threshold") {
 			if d.TriggeredThreshold != threshold && daysLeft <= threshold {
 				msg := message.NewThresholdMessage(d.Name, daysLeft)
-				if err := integration.Send(msg); err != nil {
-					return err
-				}
+				integration.Send(msg)
 				d.TriggeredThreshold = threshold
 				break
 			}
@@ -97,9 +95,7 @@ func (d *Domain) NotifyStatusChange() error {
 
 		if len(changes) > 0 {
 			msg := message.NewStatusChangedMessage(d.Name, changes)
-			if err := integration.Send(msg); err != nil {
-				return err
-			}
+			integration.Send(msg)
 		}
 	}
 	return nil

diff --git a/internal/integration/integration.go b/internal/integration/integration.go
@@ -49,13 +49,12 @@ func Setup() error {
 	return nil
 }
 
-func Send(message string) error {
-	for _, integration := range Default {
+func Send(message string) {
+	for name, integration := range Default {
 		if err := integration.Send(message); err != nil {
-			return err
+			log.WithField("integration", name).Error(err)
 		}
 	}
-	return nil
 }
 
 func Get(key string) Integration {