Fix partial cloning a repo (#18373)
- Pass the Global command args into serviceRPC. - Fixes error with partial cloning. - Add partial clone test - Include diff Co-authored-by: Lunny Xiao <xiaolunwen@gmail.com>
This commit is contained in:
parent
5e5740af69
commit
c2e13fb763
6 changed files with 24 additions and 4 deletions
|
@ -122,6 +122,17 @@ func doGitClone(dstLocalPath string, u *url.URL) func(*testing.T) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func doPartialGitClone(dstLocalPath string, u *url.URL) func(*testing.T) {
|
||||||
|
return func(t *testing.T) {
|
||||||
|
assert.NoError(t, git.CloneWithArgs(context.Background(), u.String(), dstLocalPath, allowLFSFilters(), git.CloneRepoOptions{
|
||||||
|
Filter: "blob:none",
|
||||||
|
}))
|
||||||
|
exist, err := util.IsExist(filepath.Join(dstLocalPath, "README.md"))
|
||||||
|
assert.NoError(t, err)
|
||||||
|
assert.True(t, exist)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
func doGitCloneFail(u *url.URL) func(*testing.T) {
|
func doGitCloneFail(u *url.URL) func(*testing.T) {
|
||||||
return func(t *testing.T) {
|
return func(t *testing.T) {
|
||||||
tmpDir, err := os.MkdirTemp("", "doGitCloneFail")
|
tmpDir, err := os.MkdirTemp("", "doGitCloneFail")
|
||||||
|
|
|
@ -69,6 +69,12 @@ func testGit(t *testing.T, u *url.URL) {
|
||||||
|
|
||||||
t.Run("Clone", doGitClone(dstPath, u))
|
t.Run("Clone", doGitClone(dstPath, u))
|
||||||
|
|
||||||
|
dstPath2, err := os.MkdirTemp("", httpContext.Reponame)
|
||||||
|
assert.NoError(t, err)
|
||||||
|
defer util.RemoveAll(dstPath2)
|
||||||
|
|
||||||
|
t.Run("Partial Clone", doPartialGitClone(dstPath2, u))
|
||||||
|
|
||||||
little, big := standardCommitAndPushTest(t, dstPath)
|
little, big := standardCommitAndPushTest(t, dstPath)
|
||||||
littleLFS, bigLFS := lfsCommitAndPushTest(t, dstPath)
|
littleLFS, bigLFS := lfsCommitAndPushTest(t, dstPath)
|
||||||
rawTest(t, &httpContext, little, big, littleLFS, bigLFS)
|
rawTest(t, &httpContext, little, big, littleLFS, bigLFS)
|
||||||
|
|
|
@ -81,7 +81,7 @@ func GetRepoRawDiffForFile(repo *Repository, startCommit, endCommit string, diff
|
||||||
}
|
}
|
||||||
|
|
||||||
stderr := new(bytes.Buffer)
|
stderr := new(bytes.Buffer)
|
||||||
cmd := NewCommandContextNoGlobals(repo.Ctx, args...)
|
cmd := NewCommandContext(repo.Ctx, args...)
|
||||||
if err = cmd.RunWithContext(&RunContext{
|
if err = cmd.RunWithContext(&RunContext{
|
||||||
Timeout: -1,
|
Timeout: -1,
|
||||||
Dir: repo.Path,
|
Dir: repo.Path,
|
||||||
|
|
|
@ -101,6 +101,7 @@ type CloneRepoOptions struct {
|
||||||
Shared bool
|
Shared bool
|
||||||
NoCheckout bool
|
NoCheckout bool
|
||||||
Depth int
|
Depth int
|
||||||
|
Filter string
|
||||||
}
|
}
|
||||||
|
|
||||||
// Clone clones original repository to target path.
|
// Clone clones original repository to target path.
|
||||||
|
@ -136,7 +137,9 @@ func CloneWithArgs(ctx context.Context, from, to string, args []string, opts Clo
|
||||||
if opts.Depth > 0 {
|
if opts.Depth > 0 {
|
||||||
cmd.AddArguments("--depth", strconv.Itoa(opts.Depth))
|
cmd.AddArguments("--depth", strconv.Itoa(opts.Depth))
|
||||||
}
|
}
|
||||||
|
if opts.Filter != "" {
|
||||||
|
cmd.AddArguments("--filter", opts.Filter)
|
||||||
|
}
|
||||||
if len(opts.Branch) > 0 {
|
if len(opts.Branch) > 0 {
|
||||||
cmd.AddArguments("-b", opts.Branch)
|
cmd.AddArguments("-b", opts.Branch)
|
||||||
}
|
}
|
||||||
|
|
|
@ -485,7 +485,7 @@ func serviceRPC(ctx gocontext.Context, h serviceHandler, service string) {
|
||||||
}
|
}
|
||||||
|
|
||||||
var stderr bytes.Buffer
|
var stderr bytes.Buffer
|
||||||
cmd := git.NewCommandContextNoGlobals(h.r.Context(), service, "--stateless-rpc", h.dir)
|
cmd := git.NewCommandContext(h.r.Context(), service, "--stateless-rpc", h.dir)
|
||||||
cmd.SetDescription(fmt.Sprintf("%s %s %s [repo_path: %s]", git.GitExecutable, service, "--stateless-rpc", h.dir))
|
cmd.SetDescription(fmt.Sprintf("%s %s %s [repo_path: %s]", git.GitExecutable, service, "--stateless-rpc", h.dir))
|
||||||
if err := cmd.RunWithContext(&git.RunContext{
|
if err := cmd.RunWithContext(&git.RunContext{
|
||||||
Timeout: -1,
|
Timeout: -1,
|
||||||
|
|
|
@ -1376,7 +1376,7 @@ func GetDiff(gitRepo *git.Repository, opts *DiffOptions, files ...string) (*Diff
|
||||||
}()
|
}()
|
||||||
|
|
||||||
go func(ctx context.Context, diffArgs []string, repoPath string, writer *io.PipeWriter) {
|
go func(ctx context.Context, diffArgs []string, repoPath string, writer *io.PipeWriter) {
|
||||||
cmd := git.NewCommandContextNoGlobals(ctx, diffArgs...)
|
cmd := git.NewCommandContext(ctx, diffArgs...)
|
||||||
cmd.SetDescription(fmt.Sprintf("GetDiffRange [repo_path: %s]", repoPath))
|
cmd.SetDescription(fmt.Sprintf("GetDiffRange [repo_path: %s]", repoPath))
|
||||||
if err := cmd.RunWithContext(&git.RunContext{
|
if err := cmd.RunWithContext(&git.RunContext{
|
||||||
Timeout: time.Duration(setting.Git.Timeout.Default) * time.Second,
|
Timeout: time.Duration(setting.Git.Timeout.Default) * time.Second,
|
||||||
|
|
Reference in a new issue