From 96c7b5dfb69b7d155aee5d2d8e3069584526be6a Mon Sep 17 00:00:00 2001
From: Songmu <y.songmu@gmail.com>
Date: Tue, 7 May 2019 02:53:58 +0900
Subject: [PATCH] get lock using repoPath to avoid duplicate get on import

---
 getter.go | 42 +++++++++++++++++++++++++++++-------------
 1 file changed, 29 insertions(+), 13 deletions(-)

diff --git a/getter.go b/getter.go
index 2f5a403a..743e4e6f 100644
--- a/getter.go
+++ b/getter.go
@@ -5,11 +5,26 @@ import (
 	"os"
 	"path/filepath"
 	"strings"
+	"sync"
 
 	"github.com/motemen/ghq/logger"
 	"golang.org/x/xerrors"
 )
 
+var (
+	seen = make(map[string]bool)
+	mu   = &sync.Mutex{}
+)
+
+func getRepoLock(repoPath string) bool {
+	mu.Lock()
+	defer func() {
+		seen[repoPath] = true
+		mu.Unlock()
+	}()
+	return !seen[repoPath]
+}
+
 type getter struct {
 	update, shallow, silent, ssh bool
 	vcs                          string
@@ -106,21 +121,22 @@ func (g *getter) getRemoteRepository(remote RemoteRepository) error {
 			}
 			repoPath = strings.TrimSuffix(filepath.Join(root, repoURL.Host, repoURL.Path), ".git")
 		}
-		err := vcs.Clone(repoURL, repoPath, g.shallow, g.silent)
-		if err != nil {
-			return err
+		if getRepoLock(repoPath) {
+			return vcs.Clone(repoURL, repoPath, g.shallow, g.silent)
 		}
-	} else {
-		if g.update {
-			logger.Log("update", path)
-			vcs, repoPath := local.VCS()
-			if vcs == nil {
-				return fmt.Errorf("failed to detect VCS for %q", path)
-			}
-			vcs.Update(repoPath, g.silent)
-		} else {
-			logger.Log("exists", path)
+		return nil
+	}
+	if g.update {
+		logger.Log("update", path)
+		vcs, repoPath := local.VCS()
+		if vcs == nil {
+			return fmt.Errorf("failed to detect VCS for %q", path)
+		}
+		if getRepoLock(repoPath) {
+			return vcs.Update(repoPath, g.silent)
 		}
+		return nil
 	}
+	logger.Log("exists", path)
 	return nil
 }