summaryrefslogtreecommitdiff
path: root/internal/cli/cmd_daemon.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-04-14 11:31:39 +0300
committerPaul Buetow <paul@buetow.org>2026-04-14 11:31:39 +0300
commit0b090c2698607fcdef039fb703c8c6bac5fceca0 (patch)
tree77b3ba27e9f07d128115cd5a41ac6c2f6db8c01b /internal/cli/cmd_daemon.go
parent0165352a63cb2f78871c2e72d4f2fd4f111637c3 (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.go43
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
+}