fix: 🐛 fix exec_die actions interpreted as die

.env.example

@@ -79,6 +79,9 @@ RECONCILE_INTERVAL=60s
 # Coalesces rapid bursts (e.g. rolling restarts) into a single reconcile.
 DEBOUNCE_DELAY=5s
 
+# Log level for watcher output. Allowed: debug, info, warn, error
+LOG_LEVEL=info
+
 # ── Docker ────────────────────────────────────────────────────────────────────
 
 # Docker daemon endpoint. Leave empty to use the default Unix socket.

config.go

@@ -30,6 +30,7 @@ type Config struct {
 
 	ReconcileInterval time.Duration
 	DebounceDelay     time.Duration
+	LogLevel          string
 
 	RecordTTL         int
 	CloudflareAutoTTL bool
@@ -98,6 +99,13 @@ func LoadConfig() (*Config, error) {
 		return nil, fmt.Errorf("CF_AUTO_TTL: invalid boolean %q: %w", autoTTLStr, err)
 	}
 
+	cfg.LogLevel = strings.ToLower(envOrDefault("LOG_LEVEL", "info"))
+	switch cfg.LogLevel {
+	case "debug", "info", "warn", "error":
+	default:
+		return nil, fmt.Errorf("LOG_LEVEL: invalid value %q (allowed: debug, info, warn, error)", cfg.LogLevel)
+	}
+
 	cfg.ExcludeRouters = make(map[string]struct{})
 	if v := os.Getenv("EXCLUDE_ROUTERS"); v != "" {
 		for _, r := range strings.Split(v, ",") {

main.go

@@ -22,21 +22,28 @@ func main() {
 		return
 	}
 
-	slog.SetDefault(slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{
-		Level: slog.LevelInfo,
-	})))
-
 	cfg, err := LoadConfig()
 	if err != nil {
-		slog.Error("configuration error", "error", err)
+		fmt.Fprintln(os.Stderr, "configuration error:", err)
 		os.Exit(1)
 	}
 
+	logLevel, err := parseLogLevel(cfg.LogLevel)
+	if err != nil {
+		fmt.Fprintln(os.Stderr, "configuration error:", err)
+		os.Exit(1)
+	}
+
+	slog.SetDefault(slog.New(slog.NewTextHandler(os.Stdout, &slog.HandlerOptions{
+		Level: logLevel,
+	})))
+
 	slog.Info("traefik-dns-watcher starting",
 		"traefik_url", cfg.TraefikURL,
 		"zones", cfg.Zones,
 		"repo_path", cfg.RepoPath,
 		"dynamic_dir", cfg.DynamicDir,
+		"log_level", cfg.LogLevel,
 		"git_https_token_enabled", cfg.GitAuthToken != "",
 		"git_auth_username", cfg.GitAuthUsername,
 		"reconcile_interval", cfg.ReconcileInterval,
@@ -115,6 +122,21 @@ func main() {
 	slog.Info("traefik-dns-watcher stopped")
 }
 
+func parseLogLevel(v string) (slog.Level, error) {
+	switch strings.ToLower(v) {
+	case "debug":
+		return slog.LevelDebug, nil
+	case "info":
+		return slog.LevelInfo, nil
+	case "warn":
+		return slog.LevelWarn, nil
+	case "error":
+		return slog.LevelError, nil
+	default:
+		return 0, fmt.Errorf("LOG_LEVEL: invalid value %q (allowed: debug, info, warn, error)", v)
+	}
+}
+
 // maybeHandleGitAskpass serves username/password for git HTTPS auth in non-interactive mode.
 // This process mode is only enabled for git child processes that set TDW_GIT_ASKPASS=1.
 func maybeHandleGitAskpass() bool {
@@ -173,7 +195,8 @@ type dockerEvent struct {
 	Type   string `json:"Type"`
 	Action string `json:"Action"`
 	Actor  struct {
-		ID string `json:"ID"`
+		ID         string            `json:"ID"`
+		Attributes map[string]string `json:"Attributes"`
 	} `json:"Actor"`
 }
 
@@ -187,7 +210,7 @@ func runDockerEventLoop(ctx context.Context, trigger func()) error {
 		return fmt.Errorf("build docker HTTP client: %w", err)
 	}
 
-	filterVal := `{"type":["container"]}`
+	filterVal := `{"type":["container"],"event":["start","stop","die","destroy"]}`
 	eventsURL := baseURL + "/events?filters=" + url.QueryEscape(filterVal)
 
 	req, err := http.NewRequestWithContext(ctx, http.MethodGet, eventsURL, nil)
@@ -221,13 +244,20 @@ func runDockerEventLoop(ctx context.Context, trigger func()) error {
 		if evt.Type != "container" {
 			continue
 		}
-		switch evt.Action {
+		// Docker may append extra details after ":" for some event kinds.
+		// We only care about the base action token.
+		action := evt.Action
+		if idx := strings.Index(action, ":"); idx >= 0 {
+			action = strings.TrimSpace(action[:idx])
+		}
+
+		switch action {
 		case "start", "stop", "die", "destroy":
 			actorID := evt.Actor.ID
 			if len(actorID) > 12 {
 				actorID = actorID[:12]
 			}
-			slog.Debug("docker event received", "action", evt.Action, "id", actorID)
+			slog.Debug("docker event received", "action", action, "id", actorID)
 			trigger()
 		}
 	}