Function daemonStop

cmd/daemon.go:126–168

─── stop ──────────────────────────────────────────────────────

(args []string, logger *zap.Logger)

// ─── stop ──────────────────────────────────────────────────────

func daemonStop(args []string, logger *zap.Logger) error {
	fs := flag.NewFlagSet("daemon stop", flag.ContinueOnError)
	socket := fs.String("socket", "", "override socket path")
	if err := fs.Parse(args); err != nil {
		return err
	}
	cfg := scheduler.LoadConfigFromEnv()
	if *socket != "" {
		cfg.DaemonSocket = *socket
	}
	s := scheduler.DefaultSocketPath(cfg)
	if err := scheduler.CheckDaemon(s); err != nil {
		return fmt.Errorf("daemon: no reachable daemon at %s (%w)", s, err)
	}
	// We send SIGTERM to the PID referenced by <socket>.pid.
	data, err := os.ReadFile(s + ".pid") // #nosec G304 -- daemon-scoped
	if err != nil {
		return fmt.Errorf("daemon: read pid file: %w", err)
	}
	pid, err := strconv.Atoi(strings.TrimSpace(string(data)))
	if err != nil {
		return fmt.Errorf("daemon: parse pid: %w", err)
	}
	proc, err := os.FindProcess(pid)
	if err != nil {
		return fmt.Errorf("daemon: find process: %w", err)
	}
	if err := proc.Signal(syscall.SIGTERM); err != nil {
		return fmt.Errorf("daemon: send SIGTERM: %w", err)
	}
	// Wait for socket to disappear.
	deadline := time.Now().Add(15 * time.Second)
	for time.Now().Before(deadline) {
		if scheduler.CheckDaemon(s) != nil {
			_, _ = fmt.Fprintln(os.Stdout, "chatcli daemon stopped")
			return nil
		}
		time.Sleep(200 * time.Millisecond)
	}
	logger.Warn("daemon did not exit within 15s; forcing SIGKILL")
	_ = proc.Signal(syscall.SIGKILL)
	return nil
}

// ─── status / ping / install ──────────────────────────────────