feat: implement gotify hook type

internal/hook/gotifyhook.go

@@ -0,0 +1,60 @@
+package hook
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/url"
+	"strings"
+
+	v1 "github.com/garethgeorge/backrest/gen/go/v1"
+)
+
+func (h *Hook) doGotify(cmd *v1.Hook_ActionGotify, vars HookVars, output io.Writer) error {
+	payload, err := h.renderTemplateOrDefault(cmd.ActionGotify.GetTemplate(), defaultTemplate, vars)
+	if err != nil {
+		return fmt.Errorf("template rendering: %w", err)
+	}
+
+	title, err := h.renderTemplateOrDefault(cmd.ActionGotify.GetTitleTemplate(), "Backrest Event", vars)
+	if err != nil {
+		return fmt.Errorf("title template rendering: %w", err)
+	}
+
+	message := struct {
+		Message  string `json:"message"`
+		Title    string `json:"title"`
+		Priority int    `json:"priority"`
+	}{
+		Title:    title,
+		Priority: 5,
+		Message:  payload,
+	}
+
+	b, err := json.Marshal(message)
+	if err != nil {
+		return fmt.Errorf("json marshal: %w", err)
+	}
+
+	baseUrl := strings.Trim(cmd.ActionGotify.GetBaseUrl(), "/")
+
+	postUrl := fmt.Sprintf(
+		"%s/message?token=%s",
+		baseUrl,
+		url.QueryEscape(cmd.ActionGotify.GetToken()))
+
+	output.Write([]byte(fmt.Sprintf("Sending gotify message to %s\n", postUrl)))
+
+	body, err := post(postUrl, "application/json", bytes.NewReader(b))
+
+	if err != nil {
+		return fmt.Errorf("send gotify message: %w", err)
+	}
+
+	if body != "" {
+		output.Write([]byte(body))
+	}
+
+	return nil
+}

internal/hook/hook.go

@@ -17,7 +17,7 @@ import (
 )
 
 var (
-	defaultTemplate = `{{.Summary}}`
+	defaultTemplate = `{{ .Summary }}`
 )
 
 // ExecuteHooks schedules tasks for the hooks subscribed to the given event. The vars map is used to substitute variables
@@ -138,6 +138,8 @@ func (h *Hook) Do(event v1.Hook_Condition, vars HookVars, output io.Writer) erro
 		return h.doCommand(action, vars, output)
 	case *v1.Hook_ActionDiscord:
 		return h.doDiscord(action, vars, output)
+	case *v1.Hook_ActionGotify:
+		return h.doGotify(action, vars, output)
 	default:
 		return fmt.Errorf("unknown hook action: %v", action)
 	}

internal/hook/httputil.go

@@ -9,7 +9,7 @@ import (
 func post(url string, contentType string, body io.Reader) (string, error) {
 	r, err := http.Post(url, contentType, body)
 	if err != nil {
-		return "", fmt.Errorf("send request: %w", url, err)
+		return "", fmt.Errorf("send request %v: %w", url, err)
 	}
 	if r.StatusCode == 204 {
 		return "", nil

internal/orchestrator/taskcollectgarbage.go

@@ -17,7 +17,7 @@ const (
 	// - it has no snapshot associated with it
 	// - it has a forgotten snapshot associated with it
 	gcHistoryAge      = 30 * 24 * time.Hour
-	gcHistoryMaxCount = 200
+	gcHistoryMaxCount = 1000
 )
 
 type CollectGarbageTask struct {

proto/v1/config.proto

@@ -78,6 +78,7 @@ message Hook {
     Command action_command = 100 [json_name="actionCommand"];
     Webhook action_webhook = 101 [json_name="actionWebhook"];
     Discord action_discord = 102 [json_name="actionDiscord"];
+    Gotify action_gotify = 103 [json_name="actionGotify"];
   }
 
   message Command {
@@ -90,7 +91,14 @@ message Hook {
 
   message Discord {
     string webhook_url = 1 [json_name="webhookUrl"];
-    string template = 2; // template for the webhook payload.
+    string template = 2 [json_name="template"]; // template for the webhook payload.
+  }
+
+  message Gotify {
+    string base_url = 1 [json_name="baseUrl"];
+    string token = 3 [json_name="token"];
+    string template = 100 [json_name="template"]; // template for the webhook payload.
+    string title_template = 101 [json_name="titleTemplate"]; // template for the webhook title.
   }
 }