Add notification action support

README.md

@@ -55,6 +55,8 @@ ntfy:
   notification:
     # The topic can either be a hardcoded string or a gval expression that evaluates to a string
     topic: alertmanager
+    # true to send all labels as tags, false to only send labels that are explicitly defined in the tags section
+    convertLabelsToTags: true
     # Priority reference: https://docs.ntfy.sh/publish/#message-priority
     # Can either be a hardcoded string or a gval expression that evaluates to a string
     priority: |
@@ -71,6 +73,16 @@ ntfy:
         {{ if eq .Status "resolved" }}Resolved: {{ end }}{{ index .Annotations "summary" }}
       description: |
         {{ index .Annotations "description" }}
+      # Add ntfy actions https://docs.ntfy.sh/publish/?h=action#open-websiteapp
+      actions: 
+        - action: "view"
+          label: "Dashboard"
+          url: "{{ .GeneratorURL }}"
+          condition: 'GeneratorURL != ""'
+        - action: "view"
+          label: "Runbook"
+          url: '{{ index .Annotations "runbook_url" }}'
+          condition: 'status == "firing" &&  annotations["runbook_url"] != ""' 
       headers:
         X-Click: |
           {{ .GeneratorURL }}

cmd/alertmanager-ntfy/main.go

@@ -32,8 +32,9 @@ var (
 			BaseURL: "https://ntfy.sh",
 			Timeout: 10 * time.Second,
 			Notification: config.Notification{
-				Topic:    config.StringExpression{Text: getDefaultTopic()},
-				Priority: &config.StringExpression{Text: "default"},
+				Topic:               config.StringExpression{Text: getDefaultTopic()},
+				Priority:            &config.StringExpression{Text: "default"},
+				ConvertLabelsToTags: true,
 			},
 		},
 		Log: getDefaultLogConfig(zapcore.InfoLevel),

config.example.yml

@@ -14,6 +14,8 @@ ntfy:
   notification:
     # The topic can either be a hardcoded string or a gval expression that evaluates to a string
     topic: alertmanager
+    # true to send all labels as tags, false to only send labels that are explicitly defined in the tags section
+    convertLabelsToTags: true
     # Priority reference: https://docs.ntfy.sh/publish/#message-priority
     # Can either be a hardcoded string or a gval expression that evaluates to a string
     priority: |
@@ -30,6 +32,16 @@ ntfy:
         {{ if eq .Status "resolved" }}Resolved: {{ end }}{{ index .Annotations "summary" }}
       description: |
         {{ index .Annotations "description" }}
+      # Add ntfy actions https://docs.ntfy.sh/publish/?h=action#open-websiteapp
+      actions: 
+        - action: "view"
+          label: "Dashboard"
+          url: "{{ .GeneratorURL }}"
+          condition: 'GeneratorURL != ""'
+        - action: "view"
+          label: "Runbook"
+          url: '{{ index .Annotations "runbook_url" }}'
+          condition: 'status == "firing" &&  annotations["runbook_url"] != ""' 
       headers:
         X-Click: |
           {{ .GeneratorURL }}

docker-compose.yaml

@@ -0,0 +1,12 @@
+services:
+  alertmanager-ntfy:
+    image: "ghcr.io/alexbakker/alertmanager-ntfy:latest"
+    volumes:
+      - ./config:/config
+    environment:
+      - USER_ID=1000
+      - GROUP_ID=1000
+      # Defaults to "/config/config.yml". Multiple files can be specified with a comma-separated list.
+      # - CONFIG_FILES="/config/config.yaml,/secret/secret.yaml"
+    ports:
+      - "8000:8000"

internal/alertmanager/format.go

@@ -31,6 +31,11 @@ type Alert struct {
 }
 
 func (a *Alert) Map() map[string]interface{} {
+	// Ensure annotations is initialized to prevent nil map access
+	if a.Annotations == nil {
+		a.Annotations = make(map[string]string)
+	}
+
 	s := structs.New(a)
 	s.TagName = "json"
 	return s.Map()

internal/config/config.go

@@ -28,6 +28,7 @@ type Expression struct {
 type Templates struct {
 	Title       *Template            `yaml:"title"`
 	Description *Template            `yaml:"description"`
+	Actions     []Action             `yaml:"actions,omitempty"`
 	Headers     map[string]*Template `yaml:headers`
 }
 
@@ -47,10 +48,11 @@ type StringExpression struct {
 }
 
 type Notification struct {
-	Topic     StringExpression  `yaml:"topic"`
-	Priority  *StringExpression `yaml:"priority"`
-	Tags      []*Tag            `yaml:"tags"`
-	Templates *Templates        `yaml:"templates"`
+	Topic               StringExpression  `yaml:"topic"`
+	Priority            *StringExpression `yaml:"priority"`
+	Tags                []*Tag            `yaml:"tags"`
+	Templates           *Templates        `yaml:"templates"`
+	ConvertLabelsToTags bool              `yaml:"convertLabelsToTags"`
 }
 
 type NtfyAuth struct {
@@ -77,6 +79,13 @@ type Config struct {
 	Log  *zap.Config `yaml:"log"`
 }
 
+type Action struct {
+	Action    string      `yaml:"action"`
+	Label     string      `yaml:"label"`
+	URL       string      `yaml:"url"`
+	Condition *Expression `yaml:"condition,omitempty"`
+}
+
 // UnmarshalText implements the encoding.TextUnmarshaler interface.
 func (t *Template) UnmarshalText(text []byte) error {
 	s := strings.TrimSpace(string(text))

internal/server/server.go

@@ -30,6 +30,20 @@ type Server struct {
 	http   *http.Client
 }
 
+type ntfyAction struct {
+	Action string `json:"action"`
+	Label  string `json:"label"`
+	URL    string `json:"url"`
+}
+
+// HealthCheck handles health check requests
+func HealthCheck(logger *zap.Logger) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		logger.Debug("Health check request received")
+		c.String(http.StatusOK, "ok")
+	}
+}
+
 func New(logger *zap.Logger, cfg *config.Config) *Server {
 	gin.SetMode(gin.ReleaseMode)
 	e := gin.New()
@@ -190,14 +204,86 @@ func (s *Server) forwardAlert(logger *zap.Logger, alert *alertmanager.Alert) err
 
 		tags = append(tags, tag.Tag)
 	}
-	tags = append(tags, convertLabelsToTags(alert.Labels)...)
+	// Only convert labels to tags if enabled in config
+	if s.cfg.Ntfy.Notification.ConvertLabelsToTags {
+		tags = append(tags, convertLabelsToTags(alert.Labels)...)
+	}
 
 	if title != "" {
 		req.Header.Set("X-Title", title)
 	}
 	if len(tags) > 0 {
 		req.Header.Set("X-Tags", strings.Join(tags, tagSeparator))
 	}
+
+	// Add actions if configured
+	if len(s.cfg.Ntfy.Notification.Templates.Actions) > 0 {
+		var validActions []ntfyAction
+		alertMap := alert.Map()
+		for _, actionConfig := range s.cfg.Ntfy.Notification.Templates.Actions {
+			// Check condition if present
+			if actionConfig.Condition != nil {
+				match, err := actionConfig.Condition.Evaluable.EvalBool(context.Background(), alertMap)
+				// Log detailed action info
+				logger.Debug("Action condition evaluation details",
+					zap.String("action", actionConfig.Label),
+					zap.String("condition", actionConfig.Condition.Text),
+					zap.Any("match", match),
+					zap.Any("alert_map", alertMap),
+					zap.Error(err))
+				if err != nil {
+					logger.Warn("Action condition evaluation failed, skipping action",
+						zap.String("action", actionConfig.Label),
+						zap.String("condition", actionConfig.Condition.Text),
+						zap.Error(err))
+					continue // Skip this action but continue processing others
+				}
+				if !match {
+					logger.Debug("Action condition not met",
+						zap.String("action", actionConfig.Label),
+						zap.String("condition", actionConfig.Condition.Text))
+					continue
+				}
+			}
+
+			// Execute URL template
+			var urlBuf bytes.Buffer
+			urlTmpl, err := template.New("url").Option("missingkey=zero").Parse(actionConfig.URL)
+			if err != nil {
+				logger.Warn("Invalid URL template, skipping action",
+					zap.String("action", actionConfig.Label),
+					zap.Error(err))
+				continue // Skip this action but continue processing others
+			}
+
+			if err := urlTmpl.Execute(&urlBuf, alertMap); err != nil {
+				logger.Warn("Failed to render URL template, skipping action",
+					zap.String("action", actionConfig.Label),
+					zap.Error(err))
+				continue // Skip this action but continue processing others
+			}
+
+			// Add valid action to the list
+			validActions = append(validActions, ntfyAction{
+				Action: actionConfig.Action,
+				Label:  actionConfig.Label,
+				URL:    strings.TrimSpace(urlBuf.String()),
+			})
+		}
+
+		// Only set X-Actions header if we have valid actions
+		if len(validActions) > 0 {
+			if jsonActions, err := json.Marshal(validActions); err == nil {
+				req.Header.Set("X-Actions", string(jsonActions))
+				logger.Debug("Set X-Actions header",
+					zap.String("actions", string(jsonActions)))
+			} else {
+				logger.Warn("Failed to marshal actions, sending alert without actions",
+					zap.Error(err))
+			}
+		}
+	}
+
 	if s.cfg.Ntfy.Notification.Priority != nil {
 		priority, err := evalStringExpr(s.cfg.Ntfy.Notification.Priority, alert)
 		if err != nil {