taigrr/mg
1
0
Fork 0
mirror of https://github.com/taigrr/mg.git synced 2026-04-02 03:28:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

fixup clone error

Browse Source
This commit is contained in:
Tai Groot
2024-02-02 16:24:06 -08:00
parent e93a0489d3
commit 01c736b54e
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cmd/mg/.gitignore vendored Normal file
View File

@@ -0,0 +1 @@
main

8
cmd/mg/cmd/clone.go
View File

@@ -40,14 +40,16 @@ var (
for i := 0; i < jobs; i++ { for i := 0; i < jobs; i++ {
go func() { go func() {
for repo := range repoChan { for repo := range repoChan {
_, err := git.PlainOpenWithOptions(repo.Remote, &(git.PlainOpenOptions{DetectDotGit: true})) _, err := git.PlainOpenWithOptions(repo.Path, &(git.PlainOpenOptions{DetectDotGit: true}))
if err == nil { if err == nil {
log.Printf("already cloned: %s\n", repo.Path) log.Printf("already cloned: %s\n", repo.Path)
mutex.Lock() mutex.Lock()
alreadyCloned++ alreadyCloned++
mutex.Unlock() mutex.Unlock()
wg.Done()
continue
} else if err == git.ErrRepositoryNotExists { } else if err == git.ErrRepositoryNotExists {
log.Printf("attempting clone: %s\n", repo) log.Printf("attempting clone: %s\n", repo.Path)
_, err = git.PlainClone(repo.Path, false, &git.CloneOptions{ _, err = git.PlainClone(repo.Path, false, &git.CloneOptions{
URL: repo.Remote, URL: repo.Remote,
}) })
@@ -73,10 +75,12 @@ var (
} }
}() }()
} }
fmt.Println(len(conf.Repos))
for _, repo := range conf.Repos { for _, repo := range conf.Repos {
repoChan <- repo repoChan <- repo
} }
close(repoChan) close(repoChan)
fmt.Println("waiting...")
wg.Wait() wg.Wait()
for _, err := range errs { for _, err := range errs {
log.Printf("error pulling %s: %s\n", err.Repo, err.Error) log.Printf("error pulling %s: %s\n", err.Repo, err.Error)