Add Apprise notification support to configuration and notification handling

Author: carsso

VERSION

@@ -1 +1 @@
-0.73.31
+0.73.32

etc/wigo.conf

@@ -118,6 +118,12 @@ OnProbeChange               = false
 HttpEnabled                 = 0                     # -> 0: disabled, 1: enabled
 HttpUrl                     = ""
 
+# Apprise https://github.com/caronc/apprise
+AppriseEnabled              = 0                     # -> 0: disabled, 1: enabled
+ApprisePath                 = "/usr/local/bin/apprise" # Path to the Apprise binary, you need to install it first
+# List of Apprise URLs to send notifications to, see https://github.com/caronc/apprise/wiki/Notify_urls
+AppriseUrls                 = []
+
 # EMAIL
 EmailEnabled                = 0                     # -> 0: disabled, 1: enabled, 2: only if http failed
 EmailSmtpServer             = "smtp.domain.tld:25"

src/wigo.go

@@ -281,6 +281,7 @@ func threadRemoteChecks(remoteWigos []wigo.AdvancedRemoteWigoConfig) {
 func threadCallbacks(chanCallbacks chan wigo.INotification) {
 	httpEnabled := wigo.GetLocalWigo().GetConfig().Notifications.HttpEnabled
 	mailEnabled := wigo.GetLocalWigo().GetConfig().Notifications.EmailEnabled
+	appriseEnabled := wigo.GetLocalWigo().GetConfig().Notifications.AppriseEnabled
 
 	for {
 		notification := <-chanCallbacks
@@ -304,6 +305,10 @@ func threadCallbacks(chanCallbacks chan wigo.INotification) {
 			if mailEnabled == 1 {
 				wigo.SendMail(notification.GetSummary(), notification.GetMessage())
 			}
+
+			if appriseEnabled != 0 {
+				wigo.SendApprise(notification.GetSummary(), notification.GetMessage())
+			}
 		}()
 	}
 }

src/wigo/config.go

@@ -109,6 +109,10 @@ func NewConfig(configFile string) (this *Config) {
 	this.Notifications.EmailFromName = ""
 	this.Notifications.EmailRecipients = nil
 
+	this.Notifications.AppriseEnabled = 0
+	this.Notifications.ApprisePath = "/usr/local/bin/apprise"
+	this.Notifications.AppriseUrls = nil
+
 	// OpenTSDB
 	this.OpenTSDB.Enabled = false
 	this.OpenTSDB.Address = nil
@@ -239,6 +243,10 @@ type NotificationConfig struct {
 	EmailRecipients  []string
 	EmailFromName    string
 	EmailFromAddress string
+
+	AppriseEnabled int
+	ApprisePath    string
+	AppriseUrls    []string
 }
 
 type AdvancedRemoteWigoConfig struct {

src/wigo/notification.go

@@ -2,6 +2,7 @@ package wigo
 
 import (
 	"bytes"
+	"context"
 	"crypto/tls"
 	"encoding/json"
 	"fmt"
@@ -11,6 +12,7 @@ import (
 	"net/mail"
 	"net/smtp"
 	"net/url"
+	"os/exec"
 	"time"
 )
 
@@ -257,3 +259,60 @@ func CallbackHttp(json string) (e error) {
 
 	return nil
 }
+
+func SendApprise(summary string, message string) {
+
+	log.Printf("We're gonna launch apprise notif...")
+
+	config := GetLocalWigo().GetConfig().Notifications
+
+	// Check if Apprise is enabled
+	if config.AppriseEnabled == 0 {
+		return
+	}
+
+	// Check if URLs are configured
+	if len(config.AppriseUrls) == 0 {
+		log.Printf("Apprise is enabled but no URLs are configured")
+		return
+	}
+
+	apprisePath := config.ApprisePath
+
+	// Ensure summary is not empty (Apprise requires it)
+	appriseSummary := summary
+	if appriseSummary == "" {
+		appriseSummary = message
+		if appriseSummary == "" {
+			appriseSummary = "Wigo notification"
+		}
+	}
+
+	// Send to each URL in a separate goroutine
+	for _, url := range config.AppriseUrls {
+		go func(appriseUrl string) {
+			// Create context with timeout (10 seconds)
+			ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
+			defer cancel()
+
+			// Create command: apprise -v -t "title" -b "body" url
+			cmd := exec.CommandContext(ctx, apprisePath, "-v", "-t", message, "-b", appriseSummary, appriseUrl)
+
+			// Execute command
+			output, err := cmd.CombinedOutput()
+			if err != nil {
+				log.Printf("Error sending apprise notification to %s : %s", appriseUrl, err)
+				if len(output) > 0 {
+					log.Printf("Apprise verbose output for %s : %s", appriseUrl, string(output))
+				}
+				return
+			}
+
+			// Log verbose output even on success for debugging
+			if len(output) > 0 {
+				log.Printf("Apprise verbose output for %s : %s", appriseUrl, string(output))
+			}
+			log.Printf(" - Sent to apprise url : %s", appriseUrl)
+		}(url)
+	}
+}