From 4ab05592633ae75de5a39d16495f57eb6ea263a2 Mon Sep 17 00:00:00 2001 From: jakka Date: Sat, 12 Apr 2025 19:30:05 +0300 Subject: reimplemented database in badger so it actually works --- cmd/cmd.go | 25 ++++++++++--------------- 1 file changed, 10 insertions(+), 15 deletions(-) (limited to 'cmd/cmd.go') diff --git a/cmd/cmd.go b/cmd/cmd.go index 82a9cd5..974770d 100644 --- a/cmd/cmd.go +++ b/cmd/cmd.go @@ -5,33 +5,24 @@ import ( "os" "os/signal" - "github.com/justjakka/reencoder/files" - "github.com/tidwall/buntdb" + badger "github.com/dgraph-io/badger/v4" "github.com/urfave/cli/v2" + + "github.com/justjakka/reencoder/files" ) func runCmd(cCtx *cli.Context) error { - ctx, err := initCmd(cCtx) + ctx, err := initArgs(cCtx) if err != nil { return err } - db, err := buntdb.Open(ctx.Value("dbfile").(string)) + db, err := badger.Open(files.Options(ctx.Value("dbfile").(string))) if err != nil { return err } defer db.Close() - if err := db.Shrink(); err != nil { - return err - } - - if err := db.CreateIndex("process", "*", buntdb.IndexJSON("process")); err != nil { - if err != buntdb.ErrIndexExists { - return err - } - } - ctx = context.WithValue(ctx, "database", db) ctx, stop := signal.NotifyContext(ctx, os.Interrupt) @@ -41,6 +32,10 @@ func runCmd(cCtx *cli.Context) error { return err } + if err = files.ReencodeFlacs(ctx); err != nil { + return err + } + return nil /* @@ -63,7 +58,7 @@ func runCmd(cCtx *cli.Context) error { return cCtx.Err() */ } -func start() { +func Start() { app := &cli.App{ Name: "reencoder", Usage: "reencodes and stores info", -- cgit v1.3.1