From 0b090c2698607fcdef039fb703c8c6bac5fceca0 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Tue, 14 Apr 2026 11:31:39 +0300 Subject: 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 --- internal/cli/cmd_import.go | 38 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 internal/cli/cmd_import.go (limited to 'internal/cli/cmd_import.go') diff --git a/internal/cli/cmd_import.go b/internal/cli/cmd_import.go new file mode 100644 index 0000000..f3ecad5 --- /dev/null +++ b/internal/cli/cmd_import.go @@ -0,0 +1,38 @@ +package cli + +import ( + "context" + "flag" + "fmt" + "os" + + "codeberg.org/snonux/goprecords/internal/storage" +) + +func runImport(args []string) error { + fs := flag.NewFlagSet("import", flag.ExitOnError) + statsDir := fs.String("stats-dir", "", "Directory containing .records files (required)") + dbPath := fs.String("db", "goprecords.db", "SQLite database path") + if err := fs.Parse(args); err != nil { + return err + } + if *statsDir == "" { + fmt.Fprintln(os.Stderr, "import: missing required flag: -stats-dir") + fs.Usage() + return fmt.Errorf("missing -stats-dir") + } + ctx := context.Background() + db, err := storage.Open(ctx, *dbPath) + if err != nil { + return fmt.Errorf("open db: %w", err) + } + defer db.Close() + if err := storage.CreateSchema(ctx, db); err != nil { + return fmt.Errorf("schema: %w", err) + } + if err := storage.ImportFromDir(ctx, db, *statsDir); err != nil { + return fmt.Errorf("import: %w", err) + } + fmt.Fprintf(os.Stderr, "imported %s into %s\n", *statsDir, *dbPath) + return nil +} -- cgit v1.2.3