update modeperm for directory creation on clone

cmd/mg/.gitignore

@@ -0,0 +1 @@
+main

cmd/mg/cmd/clone.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"log"
 	"os"
+	"path/filepath"
 	"sync"
 
 	git "github.com/go-git/go-git/v5"
@@ -37,46 +38,55 @@ var (
 			mutex := sync.Mutex{}
 			wg := sync.WaitGroup{}
 			wg.Add(len(conf.Repos))
-			for i := 0; i < jobs; i++ {
-				go func() {
-					for repo := range repoChan {
-						_, err := git.PlainOpenWithOptions(repo.Remote, &(git.PlainOpenOptions{DetectDotGit: true}))
-						if err == nil {
-							log.Printf("already cloned: %s\n", repo.Path)
-							mutex.Lock()
-							alreadyCloned++
-							mutex.Unlock()
-						} else if err == git.ErrRepositoryNotExists {
-							log.Printf("attempting clone: %s\n", repo)
-							_, err = git.PlainClone(repo.Path, false, &git.CloneOptions{
-								URL: repo.Remote,
-							})
-							if err != nil {
-								mutex.Lock()
-								errs = append(errs, RepoError{Error: err, Repo: repo.Path})
-								mutex.Unlock()
-								log.Printf("clone failed for %s: %v\n", repo.Path, err)
-								wg.Done()
-								continue
-							}
-							fmt.Printf("successfully cloned %s\n", repo)
-							wg.Done()
-							continue
-						} else {
+			cloneFunc := func() {
+				for repo := range repoChan {
+					_, err := git.PlainOpenWithOptions(repo.Path, &(git.PlainOpenOptions{DetectDotGit: true}))
+					if err == nil {
+						log.Printf("already cloned: %s\n", repo.Path)
+						mutex.Lock()
+						alreadyCloned++
+						mutex.Unlock()
+						wg.Done()
+						continue
+					} else if err == git.ErrRepositoryNotExists {
+						log.Printf("attempting clone: %s\n", repo.Path)
+						parentPath := filepath.Dir(repo.Path)
+						if _, err := os.Stat(parentPath); err != nil {
+							os.MkdirAll(parentPath, os.ModeDir|os.ModePerm)
+						}
+						_, err = git.PlainClone(repo.Path, false, &git.CloneOptions{
+							URL: repo.Remote,
+						})
+						if err != nil {
 							mutex.Lock()
 							errs = append(errs, RepoError{Error: err, Repo: repo.Path})
 							mutex.Unlock()
-							log.Printf("clone failed for %s: %v\n", repo, err)
+							log.Printf("clone failed for %s: %v\n", repo.Path, err)
 							wg.Done()
 							continue
 						}
+						fmt.Printf("successfully cloned %s\n", repo.Path)
+						wg.Done()
+						continue
+					} else {
+						mutex.Lock()
+						errs = append(errs, RepoError{Error: err, Repo: repo.Path})
+						mutex.Unlock()
+						log.Printf("clone failed for %s: %v\n", repo.Path, err)
+						wg.Done()
+						continue
 					}
-				}()
+				}
 			}
+			for i := 0; i < jobs; i++ {
+				go cloneFunc()
+			}
+			fmt.Println(len(conf.Repos))
 			for _, repo := range conf.Repos {
 				repoChan <- repo
 			}
 			close(repoChan)
+			fmt.Println("waiting...")
 			wg.Wait()
 			for _, err := range errs {
 				log.Printf("error pulling %s: %s\n", err.Repo, err.Error)

cmd/mg/cmd/pull.go

@@ -15,7 +15,7 @@ var (
 	jobs    int
 	pullCmd = &cobra.Command{
 		Use:   "pull",
-		Short: "add current path to list of repos",
+		Short: "update all git repos specified in config",
 		Run: func(_ *cobra.Command, args []string) {
 			type RepoError struct {
 				Error error

go.mod

@@ -1,6 +1,6 @@
 module github.com/taigrr/mg
 
-go 1.21
+go 1.23.1
 
 require (
 	github.com/go-git/go-git/v5 v5.11.0