Restart daemon on update and add hook args

Bump version to v0.1.51. Improve auto-update flow to detect if the konta daemon is running and automatically restart it via systemctl, with logging and a fallback instruction if restart fails. Propagate context into hook invocations: pass reconciled project list to success hooks and include formatted error messages to failure hooks. Update hooks Runner API to accept arguments (RunSuccess(apps []string), RunFailure(errorMessage string)) and make the internal run() variadic so hook scripts receive these values as command-line arguments.

Author: talyguryn

cmd/konta/main.go

@@ -9,7 +9,7 @@ import (
 	"github.com/talyguryn/konta/internal/logger"
 )
 
-const Version = "0.1.50"
+const Version = "0.1.51"
 
 func main() {
 	if len(os.Args) < 2 {

internal/cmd/cmd.go

@@ -815,7 +815,26 @@ func autoUpdate(currentVersion string, release *githubRelease) error {
 
 	runPostUpdateHook()
 
-	logger.Info("Auto-update complete: v%s installed. Restart the daemon to apply.", latestVersion)
+	// Check if daemon is running
+	statusCmd := exec.Command("systemctl", "is-active", "konta")
+	err := statusCmd.Run()
+	isDaemonRunning := err == nil
+
+	if isDaemonRunning {
+		logger.Info("Auto-update complete: v%s installed. Restarting daemon...", latestVersion)
+
+		// Restart the daemon automatically
+		restartCmd := exec.Command("systemctl", "restart", "konta")
+		if err := restartCmd.Run(); err != nil {
+			logger.Warn("Failed to restart daemon after auto-update: %v", err)
+			logger.Info("Please restart manually: sudo konta restart")
+		} else {
+			logger.Info("Daemon restarted successfully with new version")
+		}
+	} else {
+		logger.Info("Auto-update complete: v%s installed. Daemon is not running.", latestVersion)
+	}
+
 	return nil
 }
 
@@ -1128,7 +1147,7 @@ func reconcileOnce(dryRun bool, version string) error {
 	// Run pre-hook
 	if err := hookRunner.RunPre(); err != nil {
 		logger.Error("Pre-hook failed: %v", err)
-		_ = hookRunner.RunFailure()
+		_ = hookRunner.RunFailure(fmt.Sprintf("Pre-hook failed: %v", err))
 		return err
 	}
 
@@ -1138,15 +1157,15 @@ func reconcileOnce(dryRun bool, version string) error {
 	reconciledProjects, err := reconciler.Reconcile()
 	if err != nil {
 		logger.Error("Reconciliation failed: %v", err)
-		_ = hookRunner.RunFailure()
+		_ = hookRunner.RunFailure(fmt.Sprintf("Reconciliation failed: %v", err))
 		return err
 	}
 
 	// Atomic switch (only if not dry-run)
 	if !dryRun {
 		if err := atomicSwitch(newCommit, releaseDir); err != nil {
 			logger.Error("Atomic switch failed: %v", err)
-			_ = hookRunner.RunFailure()
+			_ = hookRunner.RunFailure(fmt.Sprintf("Atomic switch failed: %v", err))
 			return err
 		}
 
@@ -1163,10 +1182,10 @@ func reconcileOnce(dryRun bool, version string) error {
 	if !dryRun {
 		currentLink := state.GetCurrentLink()
 		successHookRunner := hooks.New(currentLink, cfg.Hooks.StartedAbs, cfg.Hooks.PreAbs, cfg.Hooks.SuccessAbs, cfg.Hooks.FailureAbs, cfg.Hooks.PostUpdateAbs)
-		if err := successHookRunner.RunSuccess(); err != nil {
+		if err := successHookRunner.RunSuccess(reconciledProjects); err != nil {
 			logger.Error("Success hook failed: %v", err)
 		}
-	} else if err := hookRunner.RunSuccess(); err != nil {
+	} else if err := hookRunner.RunSuccess(reconciledProjects); err != nil {
 		logger.Error("Success hook failed: %v", err)
 	}
 

internal/hooks/hooks.go

@@ -40,21 +40,23 @@ func (r *Runner) RunPre() error {
 }
 
 // RunSuccess runs the success hook
-func (r *Runner) RunSuccess() error {
-	return r.run("success")
+// apps: list of applications that were successfully updated
+func (r *Runner) RunSuccess(apps []string) error {
+	return r.run("success", apps...)
 }
 
 // RunFailure runs the failure hook
-func (r *Runner) RunFailure() error {
-	return r.run("failure")
+// errorMessage: the error message that caused the failure
+func (r *Runner) RunFailure(errorMessage string) error {
+	return r.run("failure", errorMessage)
 }
 
 // RunPostUpdate runs the post-update hook (executed after konta binary update)
 func (r *Runner) RunPostUpdate() error {
 	return r.run("post_update")
 }
 
-func (r *Runner) run(hookType string) error {
+func (r *Runner) run(hookType string, args ...string) error {
 	hookPath := r.hookPaths[hookType]
 	if hookPath == "" {
 		logger.Debug("No %s hook configured", hookType)
@@ -74,7 +76,9 @@ func (r *Runner) run(hookType string) error {
 
 	logger.Debug("Running %s hook: %s", hookType, hookPath)
 
-	cmd := exec.Command("bash", hookPath)
+	// Prepare command arguments: bash hook_script.sh [arg1] [arg2] ...
+	cmdArgs := append([]string{hookPath}, args...)
+	cmd := exec.Command("bash", cmdArgs...)
 	cmd.Dir = r.repoDir
 
 	// Suppress output for post_update hook, show output for other hooks