diff options
| author | jakka <jakkadoujin@gmail.com> | 2025-04-12 19:30:05 +0300 |
|---|---|---|
| committer | jakka <jakkadoujin@gmail.com> | 2025-04-12 19:30:05 +0300 |
| commit | 4ab05592633ae75de5a39d16495f57eb6ea263a2 (patch) | |
| tree | b674ee9229d9a85abb59fd03b2400d37e82ea915 /cmd | |
| parent | 1675136966473083e970badfe92433a05d2d7fee (diff) | |
reimplemented database in badger so it actually works
Diffstat (limited to 'cmd')
| -rw-r--r-- | cmd/cmd.go | 25 | ||||
| -rw-r--r-- | cmd/init.go | 4 | ||||
| -rw-r--r-- | cmd/main.go | 2 |
3 files changed, 13 insertions, 18 deletions
@@ -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", diff --git a/cmd/init.go b/cmd/init.go index 18e3b65..2459315 100644 --- a/cmd/init.go +++ b/cmd/init.go @@ -34,7 +34,7 @@ func getDb(cCtx *cli.Context) (context.Context, error) { return context.WithValue(cCtx.Context, "dbfile", ""), errors.New("failed to locate application data folder") } - return context.WithValue(cCtx.Context, "dbfile", filepath.Join(localFolder, "reencoder.db")), nil + return context.WithValue(cCtx.Context, "dbfile", filepath.Join(localFolder, "reencoder")), nil } if _, err := os.Stat(cCtx.Path("dbfile")); err != nil { return context.WithValue(cCtx.Context, "dbfile", ""), err @@ -52,7 +52,7 @@ func checkTools() error { return nil } -func initCmd(cCtx *cli.Context) (context.Context, error) { +func initArgs(cCtx *cli.Context) (context.Context, error) { if err := checkTools(); err != nil { return nil, err } diff --git a/cmd/main.go b/cmd/main.go index 6d4c482..52cefc8 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -1,5 +1,5 @@ package main func main() { - start() + Start() } |
