/
helpers.go
67 lines (59 loc) · 1.5 KB
/
helpers.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
package main
import (
"os"
"os/exec"
"path"
"strings"
"emperror.dev/errors"
"github.com/aviator-co/av/internal/git"
"github.com/aviator-co/av/internal/meta"
"github.com/aviator-co/av/internal/meta/jsonfiledb"
"github.com/aviator-co/av/internal/meta/refmeta"
"github.com/sirupsen/logrus"
)
var cachedRepo *git.Repo
func getRepo() (*git.Repo, error) {
if cachedRepo == nil {
cmd := exec.Command(
"git",
"rev-parse",
"--path-format=absolute",
"--show-toplevel",
"--git-common-dir",
)
if rootFlags.Directory != "" {
cmd.Dir = rootFlags.Directory
}
paths, err := cmd.Output()
if err != nil {
return nil, errors.Wrap(
err,
"failed to find git directory (are you running inside a Git repo?)",
)
}
dir, gitDir, found := strings.Cut(strings.TrimSpace(string(paths)), "\n")
if !found {
return nil, errors.New("Unexpected format, not able to parse toplevel and common dir.")
}
cachedRepo, err = git.OpenRepo(dir, gitDir)
if err != nil {
return nil, errors.Wrap(err, "failed to open git repo")
}
}
return cachedRepo, nil
}
func getDB(repo *git.Repo) (meta.DB, error) {
dbPath := path.Join(repo.AvDir(), "av.db")
existingStat, _ := os.Stat(dbPath)
db, err := jsonfiledb.OpenPath(dbPath)
if err != nil {
return nil, err
}
if existingStat == nil {
logrus.Debug("Initializing new av database")
if err := refmeta.Import(repo, db); err != nil {
return nil, errors.WrapIff(err, "failed to import ref metadata into av database")
}
}
return db, nil
}