summaryrefslogtreecommitdiff
path: root/scanRepoDir.go
diff options
context:
space:
mode:
Diffstat (limited to 'scanRepoDir.go')
-rw-r--r--scanRepoDir.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/scanRepoDir.go b/scanRepoDir.go
index 6cc2762..1e6c7e2 100644
--- a/scanRepoDir.go
+++ b/scanRepoDir.go
@@ -7,9 +7,9 @@ import (
"path/filepath"
"github.com/destel/rill"
- "go.wit.com/lib/ENV"
"go.wit.com/lib/cobol"
"go.wit.com/lib/config"
+ "go.wit.com/lib/env"
"go.wit.com/lib/protobuf/gitpb"
"go.wit.com/log"
)
@@ -39,7 +39,7 @@ func (f *Forge) checkNamespace(fullpath string) (*gitpb.Repo, error) {
}
func (f *Forge) RescanRepos() error {
- gopath := ENV.Get("gopath")
+ gopath := env.Get("gopath")
log.Info("RescanRepos() running in", gopath)
f.scanRepoDir(gopath)
f.Save()
@@ -83,13 +83,13 @@ func (f *Forge) rillScanDirsNew(fullpaths []string) (int, error) {
ids := rill.FromSlice(fullpaths, nil)
// Read users from the API. // Concurrency = 20
- dirs := rill.Map(ids, cobol.Int(ENV.Get("RillX")), func(id string) (*gitpb.Repo, error) {
+ dirs := rill.Map(ids, cobol.Int(env.Get("RillX")), func(id string) (*gitpb.Repo, error) {
return f.checkNamespace(id)
})
var counter int
// Activate users. // Concurrency = 10
- err := rill.ForEach(dirs, cobol.Int(ENV.Get("RillY")), func(repo *gitpb.Repo) error {
+ err := rill.ForEach(dirs, cobol.Int(env.Get("RillY")), func(repo *gitpb.Repo) error {
if repo == nil {
return nil
}