more propagation

zeripath · zeripath · commit a7276d99cff7 · 2021-12-03T17:16:02.000Z
Signed-off-by: Andrew Thornton &lt;art27@cantab.net&gt;
diff --git a/modules/context/api.go b/modules/context/api.go
@@ -328,7 +328,7 @@ func ReferencesGitRepo(allowEmpty bool) func(http.Handler) http.Handler {
 			// For API calls.
 			if ctx.Repo.GitRepo == nil {
 				repoPath := models.RepoPath(ctx.Repo.Owner.Name, ctx.Repo.Repository.Name)
-				gitRepo, err := git.OpenRepository(repoPath)
+				gitRepo, err := git.OpenRepositoryCtx(ctx, repoPath)
 				if err != nil {
 					ctx.Error(http.StatusInternalServerError, "RepoRef Invalid repo "+repoPath, err)
 					return
@@ -386,7 +386,7 @@ func RepoRefForAPI(next http.Handler) http.Handler {
 
 		if ctx.Repo.GitRepo == nil {
 			repoPath := models.RepoPath(ctx.Repo.Owner.Name, ctx.Repo.Repository.Name)
-			ctx.Repo.GitRepo, err = git.OpenRepository(repoPath)
+			ctx.Repo.GitRepo, err = git.OpenRepositoryCtx(ctx, repoPath)
 			if err != nil {
 				ctx.InternalServerError(err)
 				return
diff --git a/routers/api/v1/repo/blob.go b/routers/api/v1/repo/blob.go
@@ -45,7 +45,7 @@ func GetBlob(ctx *context.APIContext) {
 		ctx.Error(http.StatusBadRequest, "", "sha not provided")
 		return
 	}
-	if blob, err := files_service.GetBlobBySHA(ctx.Repo.Repository, sha); err != nil {
+	if blob, err := files_service.GetBlobBySHA(ctx, ctx.Repo.Repository, sha); err != nil {
 		ctx.Error(http.StatusBadRequest, "", err)
 	} else {
 		ctx.JSON(http.StatusOK, blob)
diff --git a/routers/api/v1/repo/file.go b/routers/api/v1/repo/file.go
@@ -554,7 +554,7 @@ func GetContents(ctx *context.APIContext) {
 	treePath := ctx.Params("*")
 	ref := ctx.FormTrim("ref")
 
-	if fileList, err := files_service.GetContentsOrList(ctx.Repo.Repository, treePath, ref); err != nil {
+	if fileList, err := files_service.GetContentsOrList(ctx, ctx.Repo.Repository, treePath, ref); err != nil {
 		if git.IsErrNotExist(err) {
 			ctx.NotFound("GetContentsOrList", err)
 			return
diff --git a/routers/api/v1/repo/status.go b/routers/api/v1/repo/status.go
@@ -62,7 +62,7 @@ func NewCommitStatus(ctx *context.APIContext) {
 		Description: form.Description,
 		Context:     form.Context,
 	}
-	if err := files_service.CreateCommitStatus(ctx.Repo.Repository, ctx.User, sha, status); err != nil {
+	if err := files_service.CreateCommitStatus(ctx, ctx.Repo.Repository, ctx.User, sha, status); err != nil {
 		ctx.Error(http.StatusInternalServerError, "CreateCommitStatus", err)
 		return
 	}
diff --git a/routers/api/v1/repo/tree.go b/routers/api/v1/repo/tree.go
@@ -60,7 +60,7 @@ func GetTree(ctx *context.APIContext) {
 		ctx.Error(http.StatusBadRequest, "", "sha not provided")
 		return
 	}
-	if tree, err := files_service.GetTreeBySHA(ctx.Repo.Repository, sha, ctx.FormInt("page"), ctx.FormInt("per_page"), ctx.FormBool("recursive")); err != nil {
+	if tree, err := files_service.GetTreeBySHA(ctx, ctx.Repo.Repository, sha, ctx.FormInt("page"), ctx.FormInt("per_page"), ctx.FormBool("recursive")); err != nil {
 		ctx.Error(http.StatusBadRequest, "", err.Error())
 	} else {
 		ctx.JSON(http.StatusOK, tree)
diff --git a/routers/api/v1/repo/wiki.go b/routers/api/v1/repo/wiki.go
@@ -456,7 +456,7 @@ func findEntryForFile(commit *git.Commit, target string) (*git.TreeEntry, error)
 // findWikiRepoCommit opens the wiki repo and returns the latest commit, writing to context on error.
 // The caller is responsible for closing the returned repo again
 func findWikiRepoCommit(ctx *context.APIContext) (*git.Repository, *git.Commit) {
-	wikiRepo, err := git.OpenRepository(ctx.Repo.Repository.WikiPath())
+	wikiRepo, err := git.OpenRepositoryCtx(ctx, ctx.Repo.Repository.WikiPath())
 	if err != nil {
 
 		if git.IsErrNotExist(err) || err.Error() == "no such file or directory" {
diff --git a/services/migrations/gitea_uploader.go b/services/migrations/gitea_uploader.go
@@ -132,7 +132,7 @@ func (g *GiteaLocalUploader) CreateRepo(repo *base.Repository, opts base.Migrate
 	if err != nil {
 		return err
 	}
-	g.gitRepo, err = git.OpenRepository(r.RepoPath())
+	g.gitRepo, err = git.OpenRepositoryCtx(g.ctx, r.RepoPath())
 	return err
 }
 
diff --git a/services/repository/adopt.go b/services/repository/adopt.go
@@ -120,7 +120,7 @@ func adoptRepository(ctx context.Context, repoPath string, u *user_model.User, r
 	}
 
 	repo.IsEmpty = false
-	gitRepo, err := git.OpenRepository(repo.RepoPath())
+	gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())
 	if err != nil {
 		return fmt.Errorf("openRepository: %v", err)
 	}
diff --git a/services/repository/files/commit.go b/services/repository/files/commit.go
@@ -5,6 +5,7 @@
 package files
 
 import (
+	"context"
 	"fmt"
 
 	"code.gitea.io/gitea/models"
@@ -16,11 +17,11 @@ import (
 // CreateCommitStatus creates a new CommitStatus given a bunch of parameters
 // NOTE: All text-values will be trimmed from whitespaces.
 // Requires: Repo, Creator, SHA
-func CreateCommitStatus(repo *models.Repository, creator *user_model.User, sha string, status *models.CommitStatus) error {
+func CreateCommitStatus(ctx context.Context, repo *models.Repository, creator *user_model.User, sha string, status *models.CommitStatus) error {
 	repoPath := repo.RepoPath()
 
 	// confirm that commit is exist
-	gitRepo, err := git.OpenRepository(repoPath)
+	gitRepo, err := git.OpenRepositoryCtx(ctx, repoPath)
 	if err != nil {
 		return fmt.Errorf("OpenRepository[%s]: %v", repoPath, err)
 	}
diff --git a/services/repository/files/content.go b/services/repository/files/content.go
@@ -5,6 +5,7 @@
 package files
 
 import (
+	"context"
 	"fmt"
 	"net/url"
 	"path"
@@ -38,7 +39,7 @@ func (ct *ContentType) String() string {
 
 // GetContentsOrList gets the meta data of a file's contents (*ContentsResponse) if treePath not a tree
 // directory, otherwise a listing of file contents ([]*ContentsResponse). Ref can be a branch, commit or tag
-func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface{}, error) {
+func GetContentsOrList(ctx context.Context, repo *models.Repository, treePath, ref string) (interface{}, error) {
 	if repo.IsEmpty {
 		return make([]interface{}, 0), nil
 	}
@@ -56,7 +57,7 @@ func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface
 	}
 	treePath = cleanTreePath
 
-	gitRepo, err := git.OpenRepository(repo.RepoPath())
+	gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())
 	if err != nil {
 		return nil, err
 	}
@@ -74,7 +75,7 @@ func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface
 	}
 
 	if entry.Type() != "tree" {
-		return GetContents(repo, treePath, origRef, false)
+		return GetContents(ctx, repo, treePath, origRef, false)
 	}
 
 	// We are in a directory, so we return a list of FileContentResponse objects
@@ -90,7 +91,7 @@ func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface
 	}
 	for _, e := range entries {
 		subTreePath := path.Join(treePath, e.Name())
-		fileContentResponse, err := GetContents(repo, subTreePath, origRef, true)
+		fileContentResponse, err := GetContents(ctx, repo, subTreePath, origRef, true)
 		if err != nil {
 			return nil, err
 		}
@@ -100,7 +101,7 @@ func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface
 }
 
 // GetContents gets the meta data on a file's contents. Ref can be a branch, commit or tag
-func GetContents(repo *models.Repository, treePath, ref string, forList bool) (*api.ContentsResponse, error) {
+func GetContents(ctx context.Context, repo *models.Repository, treePath, ref string, forList bool) (*api.ContentsResponse, error) {
 	if ref == "" {
 		ref = repo.DefaultBranch
 	}
@@ -115,7 +116,7 @@ func GetContents(repo *models.Repository, treePath, ref string, forList bool) (*
 	}
 	treePath = cleanTreePath
 
-	gitRepo, err := git.OpenRepository(repo.RepoPath())
+	gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())
 	if err != nil {
 		return nil, err
 	}
@@ -162,7 +163,7 @@ func GetContents(repo *models.Repository, treePath, ref string, forList bool) (*
 	// Now populate the rest of the ContentsResponse based on entry type
 	if entry.IsRegular() || entry.IsExecutable() {
 		contentsResponse.Type = string(ContentTypeRegular)
-		if blobResponse, err := GetBlobBySHA(repo, entry.ID.String()); err != nil {
+		if blobResponse, err := GetBlobBySHA(ctx, repo, entry.ID.String()); err != nil {
 			return nil, err
 		} else if !forList {
 			// We don't show the content if we are getting a list of FileContentResponses
@@ -218,8 +219,8 @@ func GetContents(repo *models.Repository, treePath, ref string, forList bool) (*
 }
 
 // GetBlobBySHA get the GitBlobResponse of a repository using a sha hash.
-func GetBlobBySHA(repo *models.Repository, sha string) (*api.GitBlobResponse, error) {
-	gitRepo, err := git.OpenRepository(repo.RepoPath())
+func GetBlobBySHA(ctx context.Context, repo *models.Repository, sha string) (*api.GitBlobResponse, error) {
+	gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())
 	if err != nil {
 		return nil, err
 	}
diff --git a/services/repository/files/content_test.go b/services/repository/files/content_test.go
@@ -63,14 +63,14 @@ func TestGetContents(t *testing.T) {
 
 	expectedContentsResponse := getExpectedReadmeContentsResponse()
 
-	t.Run("Get README.md contents with GetContents()", func(t *testing.T) {
-		fileContentResponse, err := GetContents(ctx.Repo.Repository, treePath, ref, false)
+	t.Run("Get README.md contents with GetContents(ctx, )", func(t *testing.T) {
+		fileContentResponse, err := GetContents(ctx, ctx.Repo.Repository, treePath, ref, false)
 		assert.EqualValues(t, expectedContentsResponse, fileContentResponse)
 		assert.NoError(t, err)
 	})
 
-	t.Run("Get README.md contents with ref as empty string (should then use the repo's default branch) with GetContents()", func(t *testing.T) {
-		fileContentResponse, err := GetContents(ctx.Repo.Repository, treePath, "", false)
+	t.Run("Get README.md contents with ref as empty string (should then use the repo's default branch) with GetContents(ctx, )", func(t *testing.T) {
+		fileContentResponse, err := GetContents(ctx, ctx.Repo.Repository, treePath, "", false)
 		assert.EqualValues(t, expectedContentsResponse, fileContentResponse)
 		assert.NoError(t, err)
 	})
@@ -98,14 +98,14 @@ func TestGetContentsOrListForDir(t *testing.T) {
 		readmeContentsResponse,
 	}
 
-	t.Run("Get root dir contents with GetContentsOrList()", func(t *testing.T) {
-		fileContentResponse, err := GetContentsOrList(ctx.Repo.Repository, treePath, ref)
+	t.Run("Get root dir contents with GetContentsOrList(ctx, )", func(t *testing.T) {
+		fileContentResponse, err := GetContentsOrList(ctx, ctx.Repo.Repository, treePath, ref)
 		assert.EqualValues(t, expectedContentsListResponse, fileContentResponse)
 		assert.NoError(t, err)
 	})
 
-	t.Run("Get root dir contents with ref as empty string (should then use the repo's default branch) with GetContentsOrList()", func(t *testing.T) {
-		fileContentResponse, err := GetContentsOrList(ctx.Repo.Repository, treePath, "")
+	t.Run("Get root dir contents with ref as empty string (should then use the repo's default branch) with GetContentsOrList(ctx, )", func(t *testing.T) {
+		fileContentResponse, err := GetContentsOrList(ctx, ctx.Repo.Repository, treePath, "")
 		assert.EqualValues(t, expectedContentsListResponse, fileContentResponse)
 		assert.NoError(t, err)
 	})
@@ -126,14 +126,14 @@ func TestGetContentsOrListForFile(t *testing.T) {
 
 	expectedContentsResponse := getExpectedReadmeContentsResponse()
 
-	t.Run("Get README.md contents with GetContentsOrList()", func(t *testing.T) {
-		fileContentResponse, err := GetContentsOrList(ctx.Repo.Repository, treePath, ref)
+	t.Run("Get README.md contents with GetContentsOrList(ctx, )", func(t *testing.T) {
+		fileContentResponse, err := GetContentsOrList(ctx, ctx.Repo.Repository, treePath, ref)
 		assert.EqualValues(t, expectedContentsResponse, fileContentResponse)
 		assert.NoError(t, err)
 	})
 
-	t.Run("Get README.md contents with ref as empty string (should then use the repo's default branch) with GetContentsOrList()", func(t *testing.T) {
-		fileContentResponse, err := GetContentsOrList(ctx.Repo.Repository, treePath, "")
+	t.Run("Get README.md contents with ref as empty string (should then use the repo's default branch) with GetContentsOrList(ctx, )", func(t *testing.T) {
+		fileContentResponse, err := GetContentsOrList(ctx, ctx.Repo.Repository, treePath, "")
 		assert.EqualValues(t, expectedContentsResponse, fileContentResponse)
 		assert.NoError(t, err)
 	})
@@ -155,15 +155,15 @@ func TestGetContentsErrors(t *testing.T) {
 
 	t.Run("bad treePath", func(t *testing.T) {
 		badTreePath := "bad/tree.md"
-		fileContentResponse, err := GetContents(repo, badTreePath, ref, false)
+		fileContentResponse, err := GetContents(ctx, repo, badTreePath, ref, false)
 		assert.Error(t, err)
 		assert.EqualError(t, err, "object does not exist [id: , rel_path: bad]")
 		assert.Nil(t, fileContentResponse)
 	})
 
 	t.Run("bad ref", func(t *testing.T) {
 		badRef := "bad_ref"
-		fileContentResponse, err := GetContents(repo, treePath, badRef, false)
+		fileContentResponse, err := GetContents(ctx, repo, treePath, badRef, false)
 		assert.Error(t, err)
 		assert.EqualError(t, err, "object does not exist [id: "+badRef+", rel_path: ]")
 		assert.Nil(t, fileContentResponse)
@@ -186,15 +186,15 @@ func TestGetContentsOrListErrors(t *testing.T) {
 
 	t.Run("bad treePath", func(t *testing.T) {
 		badTreePath := "bad/tree.md"
-		fileContentResponse, err := GetContentsOrList(repo, badTreePath, ref)
+		fileContentResponse, err := GetContentsOrList(ctx, repo, badTreePath, ref)
 		assert.Error(t, err)
 		assert.EqualError(t, err, "object does not exist [id: , rel_path: bad]")
 		assert.Nil(t, fileContentResponse)
 	})
 
 	t.Run("bad ref", func(t *testing.T) {
 		badRef := "bad_ref"
-		fileContentResponse, err := GetContentsOrList(repo, treePath, badRef)
+		fileContentResponse, err := GetContentsOrList(ctx, repo, treePath, badRef)
 		assert.Error(t, err)
 		assert.EqualError(t, err, "object does not exist [id: "+badRef+", rel_path: ]")
 		assert.Nil(t, fileContentResponse)
@@ -213,7 +213,7 @@ func TestGetContentsOrListOfEmptyRepos(t *testing.T) {
 	repo := ctx.Repo.Repository
 
 	t.Run("empty repo", func(t *testing.T) {
-		contents, err := GetContentsOrList(repo, "", "")
+		contents, err := GetContentsOrList(ctx, repo, "", "")
 		assert.NoError(t, err)
 		assert.Empty(t, contents)
 	})
@@ -232,7 +232,7 @@ func TestGetBlobBySHA(t *testing.T) {
 	ctx.SetParams(":id", "1")
 	ctx.SetParams(":sha", sha)
 
-	gbr, err := GetBlobBySHA(ctx.Repo.Repository, ctx.Params(":sha"))
+	gbr, err := GetBlobBySHA(ctx, ctx.Repo.Repository, ctx.Params(":sha"))
 	expectedGBR := &api.GitBlobResponse{
 		Content:  "dHJlZSAyYTJmMWQ0NjcwNzI4YTJlMTAwNDllMzQ1YmQ3YTI3NjQ2OGJlYWI2CmF1dGhvciB1c2VyMSA8YWRkcmVzczFAZXhhbXBsZS5jb20+IDE0ODk5NTY0NzkgLTA0MDAKY29tbWl0dGVyIEV0aGFuIEtvZW5pZyA8ZXRoYW50a29lbmlnQGdtYWlsLmNvbT4gMTQ4OTk1NjQ3OSAtMDQwMAoKSW5pdGlhbCBjb21taXQK",
 		Encoding: "base64",
diff --git a/services/repository/files/delete.go b/services/repository/files/delete.go
@@ -191,7 +191,7 @@ func DeleteRepoFile(ctx context.Context, repo *models.Repository, doer *user_mod
 		return nil, err
 	}
 
-	file, err := GetFileResponseFromCommit(repo, commit, opts.NewBranch, treePath)
+	file, err := GetFileResponseFromCommit(ctx, repo, commit, opts.NewBranch, treePath)
 	if err != nil {
 		return nil, err
 	}
diff --git a/services/repository/files/file.go b/services/repository/files/file.go
@@ -5,6 +5,7 @@
 package files
 
 import (
+	"context"
 	"fmt"
 	"net/url"
 	"path"
@@ -18,9 +19,9 @@ import (
 )
 
 // GetFileResponseFromCommit Constructs a FileResponse from a Commit object
-func GetFileResponseFromCommit(repo *models.Repository, commit *git.Commit, branch, treeName string) (*api.FileResponse, error) {
-	fileContents, _ := GetContents(repo, treeName, branch, false) // ok if fails, then will be nil
-	fileCommitResponse, _ := GetFileCommitResponse(repo, commit)  // ok if fails, then will be nil
+func GetFileResponseFromCommit(ctx context.Context, repo *models.Repository, commit *git.Commit, branch, treeName string) (*api.FileResponse, error) {
+	fileContents, _ := GetContents(ctx, repo, treeName, branch, false) // ok if fails, then will be nil
+	fileCommitResponse, _ := GetFileCommitResponse(repo, commit)       // ok if fails, then will be nil
 	verification := GetPayloadCommitVerification(commit)
 	fileResponse := &api.FileResponse{
 		Content:      fileContents,
diff --git a/services/repository/files/file_test.go b/services/repository/files/file_test.go
@@ -109,12 +109,12 @@ func TestGetFileResponseFromCommit(t *testing.T) {
 	repo := ctx.Repo.Repository
 	branch := repo.DefaultBranch
 	treePath := "README.md"
-	gitRepo, _ := git.OpenRepository(repo.RepoPath())
+	gitRepo, _ := git.OpenRepositoryCtx(ctx, repo.RepoPath())
 	defer gitRepo.Close()
 	commit, _ := gitRepo.GetBranchCommit(branch)
 	expectedFileResponse := getExpectedFileResponse()
 
-	fileResponse, err := GetFileResponseFromCommit(repo, commit, branch, treePath)
+	fileResponse, err := GetFileResponseFromCommit(ctx, repo, commit, branch, treePath)
 	assert.NoError(t, err)
 	assert.EqualValues(t, expectedFileResponse, fileResponse)
 }
diff --git a/services/repository/files/tree.go b/services/repository/files/tree.go
@@ -5,6 +5,7 @@
 package files
 
 import (
+	"context"
 	"fmt"
 	"net/url"
 
@@ -15,8 +16,8 @@ import (
 )
 
 // GetTreeBySHA get the GitTreeResponse of a repository using a sha hash.
-func GetTreeBySHA(repo *models.Repository, sha string, page, perPage int, recursive bool) (*api.GitTreeResponse, error) {
-	gitRepo, err := git.OpenRepository(repo.RepoPath())
+func GetTreeBySHA(ctx context.Context, repo *models.Repository, sha string, page, perPage int, recursive bool) (*api.GitTreeResponse, error) {
+	gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())
 	if err != nil {
 		return nil, err
 	}
diff --git a/services/repository/files/tree_test.go b/services/repository/files/tree_test.go
@@ -29,7 +29,7 @@ func TestGetTreeBySHA(t *testing.T) {
 	ctx.SetParams(":id", "1")
 	ctx.SetParams(":sha", sha)
 
-	tree, err := GetTreeBySHA(ctx.Repo.Repository, ctx.Params(":sha"), page, perPage, true)
+	tree, err := GetTreeBySHA(ctx, ctx.Repo.Repository, ctx.Params(":sha"), page, perPage, true)
 	assert.NoError(t, err)
 	expectedTree := &api.GitTreeResponse{
 		SHA: "65f1bf27bc3bf70f64657658635e66094edbcb4d",
diff --git a/services/repository/files/update.go b/services/repository/files/update.go
@@ -433,7 +433,7 @@ func CreateOrUpdateRepoFile(ctx context.Context, repo *models.Repository, doer *
 		return nil, err
 	}
 
-	file, err := GetFileResponseFromCommit(repo, commit, opts.NewBranch, treePath)
+	file, err := GetFileResponseFromCommit(ctx, repo, commit, opts.NewBranch, treePath)
 	if err != nil {
 		return nil, err
 	}

Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ func GetBlob(ctx *context.APIContext) {`
`45`	`45`	`ctx.Error(http.StatusBadRequest, "", "sha not provided")`
`46`	`46`	`return`
`47`	`47`	`}`
`48`		`- if blob, err := files_service.GetBlobBySHA(ctx.Repo.Repository, sha); err != nil {`
	`48`	`+ if blob, err := files_service.GetBlobBySHA(ctx, ctx.Repo.Repository, sha); err != nil {`
`49`	`49`	`ctx.Error(http.StatusBadRequest, "", err)`
`50`	`50`	`} else {`
`51`	`51`	`ctx.JSON(http.StatusOK, blob)`
Original file line number	Diff line number	Diff line change
`@@ -62,7 +62,7 @@ func NewCommitStatus(ctx *context.APIContext) {`
`62`	`62`	`Description: form.Description,`
`63`	`63`	`Context: form.Context,`
`64`	`64`	`}`
`65`		`- if err := files_service.CreateCommitStatus(ctx.Repo.Repository, ctx.User, sha, status); err != nil {`
	`65`	`+ if err := files_service.CreateCommitStatus(ctx, ctx.Repo.Repository, ctx.User, sha, status); err != nil {`
`66`	`66`	`ctx.Error(http.StatusInternalServerError, "CreateCommitStatus", err)`
`67`	`67`	`return`
`68`	`68`	`}`
Original file line number	Diff line number	Diff line change
`@@ -60,7 +60,7 @@ func GetTree(ctx *context.APIContext) {`
`60`	`60`	`ctx.Error(http.StatusBadRequest, "", "sha not provided")`
`61`	`61`	`return`
`62`	`62`	`}`
`63`		`- if tree, err := files_service.GetTreeBySHA(ctx.Repo.Repository, sha, ctx.FormInt("page"), ctx.FormInt("per_page"), ctx.FormBool("recursive")); err != nil {`
	`63`	`+ if tree, err := files_service.GetTreeBySHA(ctx, ctx.Repo.Repository, sha, ctx.FormInt("page"), ctx.FormInt("per_page"), ctx.FormBool("recursive")); err != nil {`
`64`	`64`	`ctx.Error(http.StatusBadRequest, "", err.Error())`
`65`	`65`	`} else {`
`66`	`66`	`ctx.JSON(http.StatusOK, tree)`
Original file line number	Diff line number	Diff line change
`@@ -132,7 +132,7 @@ func (g GiteaLocalUploader) CreateRepo(repo base.Repository, opts base.Migrate`
`132`	`132`	`if err != nil {`
`133`	`133`	`return err`
`134`	`134`	`}`
`135`		`- g.gitRepo, err = git.OpenRepository(r.RepoPath())`
	`135`	`+ g.gitRepo, err = git.OpenRepositoryCtx(g.ctx, r.RepoPath())`
`136`	`136`	`return err`
`137`	`137`	`}`
`138`	`138`
Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,7 @@ func adoptRepository(ctx context.Context, repoPath string, u *user_model.User, r`
`120`	`120`	`}`
`121`	`121`
`122`	`122`	`repo.IsEmpty = false`
`123`		`- gitRepo, err := git.OpenRepository(repo.RepoPath())`
	`123`	`+ gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())`
`124`	`124`	`if err != nil {`
`125`	`125`	`return fmt.Errorf("openRepository: %v", err)`
`126`	`126`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,6 +5,7 @@`
`5`	`5`	`package files`
`6`	`6`
`7`	`7`	`import (`
	`8`	`+ "context"`
`8`	`9`	`"fmt"`
`9`	`10`	`"net/url"`
`10`	`11`	`"path"`
`@@ -38,7 +39,7 @@ func (ct *ContentType) String() string {`
`38`	`39`
`39`	`40`	`// GetContentsOrList gets the meta data of a file's contents (*ContentsResponse) if treePath not a tree`
`40`	`41`	`// directory, otherwise a listing of file contents ([]*ContentsResponse). Ref can be a branch, commit or tag`
`41`		`-func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface{}, error) {`
	`42`	`+func GetContentsOrList(ctx context.Context, repo *models.Repository, treePath, ref string) (interface{}, error) {`
`42`	`43`	`if repo.IsEmpty {`
`43`	`44`	`return make([]interface{}, 0), nil`
`44`	`45`	`}`
`@@ -56,7 +57,7 @@ func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface`
`56`	`57`	`}`
`57`	`58`	`treePath = cleanTreePath`
`58`	`59`
`59`		`- gitRepo, err := git.OpenRepository(repo.RepoPath())`
	`60`	`+ gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())`
`60`	`61`	`if err != nil {`
`61`	`62`	`return nil, err`
`62`	`63`	`}`
`@@ -74,7 +75,7 @@ func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface`
`74`	`75`	`}`
`75`	`76`
`76`	`77`	`if entry.Type() != "tree" {`
`77`		`- return GetContents(repo, treePath, origRef, false)`
	`78`	`+ return GetContents(ctx, repo, treePath, origRef, false)`
`78`	`79`	`}`
`79`	`80`
`80`	`81`	`// We are in a directory, so we return a list of FileContentResponse objects`
`@@ -90,7 +91,7 @@ func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface`
`90`	`91`	`}`
`91`	`92`	`for _, e := range entries {`
`92`	`93`	`subTreePath := path.Join(treePath, e.Name())`
`93`		`- fileContentResponse, err := GetContents(repo, subTreePath, origRef, true)`
	`94`	`+ fileContentResponse, err := GetContents(ctx, repo, subTreePath, origRef, true)`
`94`	`95`	`if err != nil {`
`95`	`96`	`return nil, err`
`96`	`97`	`}`
`@@ -100,7 +101,7 @@ func GetContentsOrList(repo *models.Repository, treePath, ref string) (interface`
`100`	`101`	`}`
`101`	`102`
`102`	`103`	`// GetContents gets the meta data on a file's contents. Ref can be a branch, commit or tag`
`103`		`-func GetContents(repo models.Repository, treePath, ref string, forList bool) (api.ContentsResponse, error) {`
	`104`	`+func GetContents(ctx context.Context, repo models.Repository, treePath, ref string, forList bool) (api.ContentsResponse, error) {`
`104`	`105`	`if ref == "" {`
`105`	`106`	`ref = repo.DefaultBranch`
`106`	`107`	`}`
`@@ -115,7 +116,7 @@ func GetContents(repo models.Repository, treePath, ref string, forList bool) (`
`115`	`116`	`}`
`116`	`117`	`treePath = cleanTreePath`
`117`	`118`
`118`		`- gitRepo, err := git.OpenRepository(repo.RepoPath())`
	`119`	`+ gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())`
`119`	`120`	`if err != nil {`
`120`	`121`	`return nil, err`
`121`	`122`	`}`
`@@ -162,7 +163,7 @@ func GetContents(repo models.Repository, treePath, ref string, forList bool) (`
`162`	`163`	`// Now populate the rest of the ContentsResponse based on entry type`
`163`	`164`	`if entry.IsRegular() \|\| entry.IsExecutable() {`
`164`	`165`	`contentsResponse.Type = string(ContentTypeRegular)`
`165`		`- if blobResponse, err := GetBlobBySHA(repo, entry.ID.String()); err != nil {`
	`166`	`+ if blobResponse, err := GetBlobBySHA(ctx, repo, entry.ID.String()); err != nil {`
`166`	`167`	`return nil, err`
`167`	`168`	`} else if !forList {`
`168`	`169`	`// We don't show the content if we are getting a list of FileContentResponses`
`@@ -218,8 +219,8 @@ func GetContents(repo models.Repository, treePath, ref string, forList bool) (`
`218`	`219`	`}`
`219`	`220`
`220`	`221`	`// GetBlobBySHA get the GitBlobResponse of a repository using a sha hash.`
`221`		`-func GetBlobBySHA(repo models.Repository, sha string) (api.GitBlobResponse, error) {`
`222`		`- gitRepo, err := git.OpenRepository(repo.RepoPath())`
	`222`	`+func GetBlobBySHA(ctx context.Context, repo models.Repository, sha string) (api.GitBlobResponse, error) {`
	`223`	`+ gitRepo, err := git.OpenRepositoryCtx(ctx, repo.RepoPath())`
`223`	`224`	`if err != nil {`
`224`	`225`	`return nil, err`
`225`	`226`	`}`