Add nfty support

README.md

@@ -24,6 +24,7 @@ Currently Frigate only supports notifications through Home Assistant, which I'm
 - SMTP
 - Telegram
 - Pushover
+- Nfty
 
 **Other**
 - Aliveness monitor via HTTP GET (for use with tools like [HealthChecks](https://github.com/healthchecks/healthchecks) or [Uptime Kuma](https://github.com/louislam/uptime-kuma))

config/config.go

@@ -53,6 +53,7 @@ type Alerts struct {
 	SMTP     SMTP     `fig:"smtp"`
 	Telegram Telegram `fig:"telegram"`
 	Pushover Pushover `fig:"pushover"`
+	Nfty     Nfty     `fig:"nfty"`
 }
 
 type General struct {
@@ -110,6 +111,13 @@ type Pushover struct {
 	TTL      int    `fig:"ttl" default:0`
 }
 
+type Nfty struct {
+	Enabled  bool   `fig:"enabled" default:false`
+	Server   string `fig:"server" default:""`
+	Topic    string `fig:"topic" default:""`
+	Insecure bool   `fig:"ignoressl" default:false`
+}
+
 type Monitor struct {
 	Enabled  bool   `fig:"enabled" default:false`
 	URL      string `fig:"url" default:""`
@@ -301,6 +309,16 @@ func validateConfig() {
 			configErrors = append(configErrors, "Pushover TTL cannot be negative!")
 		}
 	}
+	if ConfigData.Alerts.Nfty.Enabled {
+		log.Print("Nfty alerting enabled.")
+		if ConfigData.Alerts.Nfty.Server == "" {
+			configErrors = append(configErrors, "No Nfty server specified!")
+		}
+		if ConfigData.Alerts.Nfty.Topic == "" {
+			configErrors = append(configErrors, "No Nfty topic specified!")
+		}
+
+	}
 
 	// Validate monitoring config
 	if ConfigData.Monitor.Enabled {

docs/changelog.md

@@ -1,5 +1,9 @@
 # Changelog
 
+## [v0.2.8](https://github.com/0x2142/frigate-notify/releases/tag/v0.2.8) - Upcoming Release
+
+- Add support for notifications via [Nfty](https://frigate-notify.0x2142.com/config/#nfty)
+
 ## [v0.2.7](https://github.com/0x2142/frigate-notify/releases/tag/v0.2.7) - May 06 2024
 
 - Allow changing default MQTT topic prefix via config

docs/config.md

@@ -324,6 +324,28 @@ alerts:
     ttl:
 ```
 
+### Nfty
+
+- **enabled** (Optional - Default: `false`)
+    - Set to `true` to enable alerting via Nfty
+- **server** (Required)
+    - Full URL of the desired Nfty server
+    - Required if this alerting method is enabled
+- **topic** (Required)
+    - Destination topic that will receive alert notifications
+    - Required if this alerting method is enabled
+- **ignoressl** (Optional - Default: `false`)
+    - Set to `true` to allow self-signed certificates
+
+```yaml title="Config File Snippet"
+alerts: 
+  nfty:
+    enabled: true
+    server: https://nfty.your.domain.tld
+    topic: frigate
+    ignoressl: true
+```
+
 ## Monitor
 
 If enabled, this application will check in with tools like [HealthChecks](https://github.com/healthchecks/healthchecks) or [Uptime Kuma](https://github.com/louislam/uptime-kuma) on a regular interval for health / status monitoring.
@@ -431,9 +453,15 @@ alerts:
     expire:
     ttl:
 
+  nfty:
+    enabled: false
+    server:
+    topic:
+    ignoressl:
+
 monitor:
   enabled: false
   url: 
   interval: 
   ignoressl: 
-```
+```

docs/index.md

@@ -24,6 +24,7 @@ Currently Frigate only supports notifications through Home Assistant, which I'm
 - SMTP
 - Telegram
 - Pushover
+- Nfty
 
 **Other**
 

example-config.yml

@@ -127,6 +127,16 @@ alerts:
     # Optional message lifetime
     ttl:
 
+  # Nfty Config
+  nfty:
+    # Set to true to enable alerting via
+    enabled: false
+    # URL of Nfty server
+    server:
+    # Nfty topic for notifications
+    topic:
+    # Set to true if using SSL & a self-signed certificate
+    ignoressl:
 
 ## App Monitoring
 # Sends HTTP GET to provided URL for aliveness checks

notifier/alerts.go

@@ -29,4 +29,7 @@ func SendAlert(message, snapshotURL string, snapshot io.Reader, eventid string)
 	if config.ConfigData.Alerts.Pushover.Enabled {
 		SendPushoverMessage(message, bytes.NewReader(snap), eventid)
 	}
+	if config.ConfigData.Alerts.Nfty.Enabled {
+		SendNftyPush(message, bytes.NewReader(snap), eventid)
+	}
 }

notifier/gotify.go

@@ -49,13 +49,14 @@ func SendGotifyPush(message, snapshotURL string, eventid string) {
 
 	data, err := json.Marshal(payload)
 	if err != nil {
-		log.Println("Event ID %v - Unable to build Gotify payload: ", eventid, err)
+		log.Printf("Event ID %v - Unable to build Gotify payload: %v", eventid, err)
 		return
 	}
 
 	gotifyURL := fmt.Sprintf("%s/message?token=%s&", config.ConfigData.Alerts.Gotify.Server, config.ConfigData.Alerts.Gotify.Token)
 
-	response, err := util.HTTPPost(gotifyURL, config.ConfigData.Alerts.Gotify.Insecure, data)
+	header := map[string]string{"Content-Type": "application/json"}
+	response, err := util.HTTPPost(gotifyURL, config.ConfigData.Alerts.Gotify.Insecure, data, header)
 	if err != nil {
 		log.Print("Failed to send Gotify notification: ", err)
 		return

notifier/nfty.go

@@ -0,0 +1,45 @@
+package notifier
+
+import (
+	"fmt"
+	"io"
+	"log"
+	"strings"
+
+	"github.com/0x2142/frigate-notify/config"
+	"github.com/0x2142/frigate-notify/util"
+)
+
+// SendNftyPush forwards alert messages to Nfty server
+func SendNftyPush(message string, snapshot io.Reader, eventid string) {
+	NftyURL := fmt.Sprintf("%s/%s", config.ConfigData.Alerts.Nfty.Server, config.ConfigData.Alerts.Nfty.Topic)
+
+	// Set headers
+	var headers []map[string]string
+	headers = append(headers, map[string]string{"Content-Type": "text/markdown"})
+	headers = append(headers, map[string]string{"X-Title": config.ConfigData.Alerts.General.Title})
+
+	// Set action link to the recorded clip
+	clip := fmt.Sprintf("%s/api/events/%s/clip.mp4", config.ConfigData.Frigate.Server, eventid)
+	headers = append(headers, map[string]string{"X-Actions": "view, View Clip, " + clip + ", clear=true"})
+
+	var attachment []byte
+	if snapshot != nil {
+		headers = append(headers, map[string]string{"X-Filename": "snapshot.jpg"})
+		attachment, _ = io.ReadAll(snapshot)
+	} else {
+		message += "\n\nNo snapshot saved."
+	}
+
+	// Escape newlines in message
+	message = strings.ReplaceAll(message, "\n", "\\n")
+	headers = append(headers, map[string]string{"X-Message": message})
+
+	_, err := util.HTTPPost(NftyURL, config.ConfigData.Alerts.Nfty.Insecure, attachment, headers...)
+	if err != nil {
+		log.Print("Failed to send Nfty notification: ", err)
+		return
+	}
+
+	log.Printf("Event ID %v - Nfty alert sent", eventid)
+}

util/httpclient.go

@@ -43,7 +43,7 @@ func HTTPGet(url string, insecure bool) ([]byte, error) {
 
 // HTTPPost performs an HTTP POST to the target URL
 // and includes auth parameters, ignoring certificates, etc
-func HTTPPost(url string, insecure bool, payload []byte) ([]byte, error) {
+func HTTPPost(url string, insecure bool, payload []byte, headers ...map[string]string) ([]byte, error) {
 	// New HTTP Client
 	client := http.Client{Timeout: 10 * time.Second}
 
@@ -58,7 +58,17 @@ func HTTPPost(url string, insecure bool, payload []byte) ([]byte, error) {
 	if err != nil {
 		return nil, err
 	}
-	req.Header.Set("Content-Type", "application/json")
+	//req.Header.Set("Content-Type", "application/json")
+
+	if len(headers) > 0 {
+		for _, h := range headers {
+			for k, v := range h {
+				req.Header.Add(k, v)
+			}
+
+		}
+
+	}
 
 	// Send HTTP POST
 	response, err := client.Do(req)