diff options
| author | Paul Buetow <paul@buetow.org> | 2026-04-14 11:31:39 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-04-14 11:31:39 +0300 |
| commit | 0b090c2698607fcdef039fb703c8c6bac5fceca0 (patch) | |
| tree | 77b3ba27e9f07d128115cd5a41ac6c2f6db8c01b /internal/cli/cmd_daemon.go | |
| parent | 0165352a63cb2f78871c2e72d4f2fd4f111637c3 (diff) | |
refactor(cli): split run* handlers into files (ask 24)
Move runImport, runQuery, runReportFromFiles, runDaemon,
runCreateClientKey, and runTests into dedicated cmd_*.go files.
Keep Execute routing in cli.go. defaultListenFromEnv stays with daemon.
Made-with: Cursor
Diffstat (limited to 'internal/cli/cmd_daemon.go')
| -rw-r--r-- | internal/cli/cmd_daemon.go | 43 |
1 files changed, 43 insertions, 0 deletions
diff --git a/internal/cli/cmd_daemon.go b/internal/cli/cmd_daemon.go new file mode 100644 index 0000000..2bd74a8 --- /dev/null +++ b/internal/cli/cmd_daemon.go @@ -0,0 +1,43 @@ +package cli + +import ( + "context" + "errors" + "flag" + "fmt" + "os" + "os/signal" + "syscall" + + "codeberg.org/snonux/goprecords/internal/daemon" +) + +func defaultListenFromEnv() string { + if s := os.Getenv("GOPRECORDS_LISTEN"); s != "" { + return s + } + return ":8080" +} + +func runDaemon(args []string) error { + fs := flag.NewFlagSet("daemon", flag.ExitOnError) + fs.SetOutput(os.Stdout) + statsDir := fs.String("stats-dir", os.Getenv("GOPRECORDS_STATS_DIR"), "Uptimed stats directory (required; env GOPRECORDS_STATS_DIR)") + listen := fs.String("listen", defaultListenFromEnv(), "TCP listen address (env GOPRECORDS_LISTEN, default :8080)") + authDB := fs.String("auth-db", "", "SQLite file for upload API keys (default: <stats-dir>/goprecords-auth.db)") + if err := fs.Parse(args); err != nil { + return err + } + if *statsDir == "" { + fmt.Fprintln(os.Stdout, "daemon: missing required flag: -stats-dir (or GOPRECORDS_STATS_DIR)") + fs.Usage() + return fmt.Errorf("missing -stats-dir") + } + ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt, syscall.SIGTERM) + defer stop() + err := daemon.Run(ctx, daemon.Config{StatsDir: *statsDir, Addr: *listen, AuthDB: *authDB}) + if err != nil && !errors.Is(err, context.Canceled) { + return err + } + return nil +} |
