|
|
|
// Copyright 2014 The Gogs Authors. All rights reserved.
|
|
|
|
// Copyright 2019 The Gitea Authors. All rights reserved.
|
|
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
|
|
|
|
package repo
|
|
|
|
|
|
|
|
import (
|
|
|
|
"errors"
|
|
|
|
"fmt"
|
|
|
|
"html/template"
|
|
|
|
"net/http"
|
|
|
|
"path"
|
|
|
|
"strings"
|
|
|
|
|
|
|
|
asymkey_model "code.gitea.io/gitea/models/asymkey"
|
|
|
|
"code.gitea.io/gitea/models/db"
|
|
|
|
git_model "code.gitea.io/gitea/models/git"
|
|
|
|
repo_model "code.gitea.io/gitea/models/repo"
|
|
|
|
user_model "code.gitea.io/gitea/models/user"
|
|
|
|
"code.gitea.io/gitea/modules/base"
|
|
|
|
"code.gitea.io/gitea/modules/charset"
|
|
|
|
"code.gitea.io/gitea/modules/context"
|
|
|
|
"code.gitea.io/gitea/modules/git"
|
|
|
|
"code.gitea.io/gitea/modules/gitgraph"
|
Simplify how git repositories are opened (#28937)
## Purpose
This is a refactor toward building an abstraction over managing git
repositories.
Afterwards, it does not matter anymore if they are stored on the local
disk or somewhere remote.
## What this PR changes
We used `git.OpenRepository` everywhere previously.
Now, we should split them into two distinct functions:
Firstly, there are temporary repositories which do not change:
```go
git.OpenRepository(ctx, diskPath)
```
Gitea managed repositories having a record in the database in the
`repository` table are moved into the new package `gitrepo`:
```go
gitrepo.OpenRepository(ctx, repo_model.Repo)
```
Why is `repo_model.Repository` the second parameter instead of file
path?
Because then we can easily adapt our repository storage strategy.
The repositories can be stored locally, however, they could just as well
be stored on a remote server.
## Further changes in other PRs
- A Git Command wrapper on package `gitrepo` could be created. i.e.
`NewCommand(ctx, repo_model.Repository, commands...)`. `git.RunOpts{Dir:
repo.RepoPath()}`, the directory should be empty before invoking this
method and it can be filled in the function only. #28940
- Remove the `RepoPath()`/`WikiPath()` functions to reduce the
possibility of mistakes.
---------
Co-authored-by: delvh <dev.lh@web.de>
10 months ago
|
|
|
"code.gitea.io/gitea/modules/gitrepo"
|
|
|
|
"code.gitea.io/gitea/modules/log"
|
|
|
|
"code.gitea.io/gitea/modules/markup"
|
|
|
|
"code.gitea.io/gitea/modules/setting"
|
|
|
|
"code.gitea.io/gitea/modules/util"
|
|
|
|
"code.gitea.io/gitea/services/gitdiff"
|
|
|
|
git_service "code.gitea.io/gitea/services/repository"
|
|
|
|
)
|
|
|
|
|
|
|
|
const (
|
|
|
|
tplCommits base.TplName = "repo/commits"
|
|
|
|
tplGraph base.TplName = "repo/graph"
|
|
|
|
tplGraphDiv base.TplName = "repo/graph/div"
|
|
|
|
tplCommitPage base.TplName = "repo/commit_page"
|
|
|
|
)
|
|
|
|
|
|
|
|
// RefCommits render commits page
|
|
|
|
func RefCommits(ctx *context.Context) {
|
|
|
|
switch {
|
|
|
|
case len(ctx.Repo.TreePath) == 0:
|
|
|
|
Commits(ctx)
|
|
|
|
case ctx.Repo.TreePath == "search":
|
|
|
|
SearchCommits(ctx)
|
|
|
|
default:
|
|
|
|
FileHistory(ctx)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// Commits render branch's commits
|
|
|
|
func Commits(ctx *context.Context) {
|
|
|
|
ctx.Data["PageIsCommits"] = true
|
|
|
|
if ctx.Repo.Commit == nil {
|
|
|
|
ctx.NotFound("Commit not found", nil)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
ctx.Data["PageIsViewCode"] = true
|
|
|
|
|
|
|
|
commitsCount, err := ctx.Repo.GetCommitsCount()
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("GetCommitsCount", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
page := ctx.FormInt("page")
|
|
|
|
if page <= 1 {
|
|
|
|
page = 1
|
|
|
|
}
|
|
|
|
|
|
|
|
pageSize := ctx.FormInt("limit")
|
|
|
|
if pageSize <= 0 {
|
|
|
|
pageSize = setting.Git.CommitsRangeSize
|
|
|
|
}
|
|
|
|
|
|
|
|
// Both `git log branchName` and `git log commitId` work.
|
|
|
|
commits, err := ctx.Repo.Commit.CommitsByRange(page, pageSize, "")
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("CommitsByRange", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
ctx.Data["Commits"] = git_model.ConvertFromGitCommit(ctx, commits, ctx.Repo.Repository)
|
|
|
|
|
|
|
|
ctx.Data["Username"] = ctx.Repo.Owner.Name
|
|
|
|
ctx.Data["Reponame"] = ctx.Repo.Repository.Name
|
|
|
|
ctx.Data["CommitCount"] = commitsCount
|
|
|
|
|
|
|
|
pager := context.NewPagination(int(commitsCount), pageSize, page, 5)
|
|
|
|
pager.SetDefaultParams(ctx)
|
|
|
|
ctx.Data["Page"] = pager
|
|
|
|
|
|
|
|
ctx.HTML(http.StatusOK, tplCommits)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Graph render commit graph - show commits from all branches.
|
|
|
|
func Graph(ctx *context.Context) {
|
|
|
|
ctx.Data["Title"] = ctx.Tr("repo.commit_graph")
|
|
|
|
ctx.Data["PageIsCommits"] = true
|
|
|
|
ctx.Data["PageIsViewCode"] = true
|
|
|
|
mode := strings.ToLower(ctx.FormTrim("mode"))
|
|
|
|
if mode != "monochrome" {
|
|
|
|
mode = "color"
|
|
|
|
}
|
|
|
|
ctx.Data["Mode"] = mode
|
|
|
|
hidePRRefs := ctx.FormBool("hide-pr-refs")
|
|
|
|
ctx.Data["HidePRRefs"] = hidePRRefs
|
|
|
|
branches := ctx.FormStrings("branch")
|
|
|
|
realBranches := make([]string, len(branches))
|
|
|
|
copy(realBranches, branches)
|
|
|
|
for i, branch := range realBranches {
|
|
|
|
if strings.HasPrefix(branch, "--") {
|
|
|
|
realBranches[i] = git.BranchPrefix + branch
|
|
|
|
}
|
|
|
|
}
|
|
|
|
ctx.Data["SelectedBranches"] = realBranches
|
|
|
|
files := ctx.FormStrings("file")
|
|
|
|
|
|
|
|
commitsCount, err := ctx.Repo.GetCommitsCount()
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("GetCommitsCount", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
graphCommitsCount, err := ctx.Repo.GetCommitGraphsCount(ctx, hidePRRefs, realBranches, files)
|
|
|
|
if err != nil {
|
|
|
|
log.Warn("GetCommitGraphsCount error for generate graph exclude prs: %t branches: %s in %-v, Will Ignore branches and try again. Underlying Error: %v", hidePRRefs, branches, ctx.Repo.Repository, err)
|
|
|
|
realBranches = []string{}
|
|
|
|
branches = []string{}
|
|
|
|
graphCommitsCount, err = ctx.Repo.GetCommitGraphsCount(ctx, hidePRRefs, realBranches, files)
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("GetCommitGraphsCount", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
page := ctx.FormInt("page")
|
|
|
|
|
|
|
|
graph, err := gitgraph.GetCommitGraph(ctx.Repo.GitRepo, page, 0, hidePRRefs, realBranches, files)
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("GetCommitGraph", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
Add context cache as a request level cache (#22294)
To avoid duplicated load of the same data in an HTTP request, we can set
a context cache to do that. i.e. Some pages may load a user from a
database with the same id in different areas on the same page. But the
code is hidden in two different deep logic. How should we share the
user? As a result of this PR, now if both entry functions accept
`context.Context` as the first parameter and we just need to refactor
`GetUserByID` to reuse the user from the context cache. Then it will not
be loaded twice on an HTTP request.
But of course, sometimes we would like to reload an object from the
database, that's why `RemoveContextData` is also exposed.
The core context cache is here. It defines a new context
```go
type cacheContext struct {
ctx context.Context
data map[any]map[any]any
lock sync.RWMutex
}
var cacheContextKey = struct{}{}
func WithCacheContext(ctx context.Context) context.Context {
return context.WithValue(ctx, cacheContextKey, &cacheContext{
ctx: ctx,
data: make(map[any]map[any]any),
})
}
```
Then you can use the below 4 methods to read/write/del the data within
the same context.
```go
func GetContextData(ctx context.Context, tp, key any) any
func SetContextData(ctx context.Context, tp, key, value any)
func RemoveContextData(ctx context.Context, tp, key any)
func GetWithContextCache[T any](ctx context.Context, cacheGroupKey string, cacheTargetID any, f func() (T, error)) (T, error)
```
Then let's take a look at how `system.GetString` implement it.
```go
func GetSetting(ctx context.Context, key string) (string, error) {
return cache.GetWithContextCache(ctx, contextCacheKey, key, func() (string, error) {
return cache.GetString(genSettingCacheKey(key), func() (string, error) {
res, err := GetSettingNoCache(ctx, key)
if err != nil {
return "", err
}
return res.SettingValue, nil
})
})
}
```
First, it will check if context data include the setting object with the
key. If not, it will query from the global cache which may be memory or
a Redis cache. If not, it will get the object from the database. In the
end, if the object gets from the global cache or database, it will be
set into the context cache.
An object stored in the context cache will only be destroyed after the
context disappeared.
2 years ago
|
|
|
if err := graph.LoadAndProcessCommits(ctx, ctx.Repo.Repository, ctx.Repo.GitRepo); err != nil {
|
|
|
|
ctx.ServerError("LoadAndProcessCommits", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.Data["Graph"] = graph
|
|
|
|
|
|
|
|
gitRefs, err := ctx.Repo.GitRepo.GetRefs()
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("GitRepo.GetRefs", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.Data["AllRefs"] = gitRefs
|
|
|
|
|
|
|
|
ctx.Data["Username"] = ctx.Repo.Owner.Name
|
|
|
|
ctx.Data["Reponame"] = ctx.Repo.Repository.Name
|
|
|
|
ctx.Data["CommitCount"] = commitsCount
|
|
|
|
|
|
|
|
paginator := context.NewPagination(int(graphCommitsCount), setting.UI.GraphMaxCommitNum, page, 5)
|
|
|
|
paginator.AddParam(ctx, "mode", "Mode")
|
|
|
|
paginator.AddParam(ctx, "hide-pr-refs", "HidePRRefs")
|
|
|
|
for _, branch := range branches {
|
|
|
|
paginator.AddParamString("branch", branch)
|
|
|
|
}
|
|
|
|
for _, file := range files {
|
|
|
|
paginator.AddParamString("file", file)
|
|
|
|
}
|
|
|
|
ctx.Data["Page"] = paginator
|
|
|
|
if ctx.FormBool("div-only") {
|
|
|
|
ctx.HTML(http.StatusOK, tplGraphDiv)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.HTML(http.StatusOK, tplGraph)
|
|
|
|
}
|
|
|
|
|
|
|
|
// SearchCommits render commits filtered by keyword
|
|
|
|
func SearchCommits(ctx *context.Context) {
|
|
|
|
ctx.Data["PageIsCommits"] = true
|
|
|
|
ctx.Data["PageIsViewCode"] = true
|
|
|
|
|
|
|
|
query := ctx.FormTrim("q")
|
|
|
|
if len(query) == 0 {
|
|
|
|
ctx.Redirect(ctx.Repo.RepoLink + "/commits/" + ctx.Repo.BranchNameSubURL())
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
all := ctx.FormBool("all")
|
|
|
|
opts := git.NewSearchCommitsOptions(query, all)
|
|
|
|
commits, err := ctx.Repo.Commit.SearchCommits(opts)
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("SearchCommits", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
ctx.Data["CommitCount"] = len(commits)
|
|
|
|
ctx.Data["Commits"] = git_model.ConvertFromGitCommit(ctx, commits, ctx.Repo.Repository)
|
|
|
|
|
|
|
|
ctx.Data["Keyword"] = query
|
|
|
|
if all {
|
|
|
|
ctx.Data["All"] = "checked"
|
|
|
|
}
|
|
|
|
ctx.Data["Username"] = ctx.Repo.Owner.Name
|
|
|
|
ctx.Data["Reponame"] = ctx.Repo.Repository.Name
|
|
|
|
ctx.HTML(http.StatusOK, tplCommits)
|
|
|
|
}
|
|
|
|
|
|
|
|
// FileHistory show a file's reversions
|
|
|
|
func FileHistory(ctx *context.Context) {
|
|
|
|
ctx.Data["IsRepoToolbarCommits"] = true
|
|
|
|
|
|
|
|
fileName := ctx.Repo.TreePath
|
|
|
|
if len(fileName) == 0 {
|
|
|
|
Commits(ctx)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
commitsCount, err := ctx.Repo.GitRepo.FileCommitsCount(ctx.Repo.RefName, fileName)
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("FileCommitsCount", err)
|
|
|
|
return
|
|
|
|
} else if commitsCount == 0 {
|
|
|
|
ctx.NotFound("FileCommitsCount", nil)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
page := ctx.FormInt("page")
|
|
|
|
if page <= 1 {
|
|
|
|
page = 1
|
|
|
|
}
|
|
|
|
|
|
|
|
commits, err := ctx.Repo.GitRepo.CommitsByFileAndRange(
|
|
|
|
git.CommitsByFileAndRangeOptions{
|
|
|
|
Revision: ctx.Repo.RefName,
|
|
|
|
File: fileName,
|
|
|
|
Page: page,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("CommitsByFileAndRange", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
ctx.Data["Commits"] = git_model.ConvertFromGitCommit(ctx, commits, ctx.Repo.Repository)
|
|
|
|
|
|
|
|
ctx.Data["Username"] = ctx.Repo.Owner.Name
|
|
|
|
ctx.Data["Reponame"] = ctx.Repo.Repository.Name
|
|
|
|
ctx.Data["FileName"] = fileName
|
|
|
|
ctx.Data["CommitCount"] = commitsCount
|
|
|
|
|
|
|
|
pager := context.NewPagination(int(commitsCount), setting.Git.CommitsRangeSize, page, 5)
|
|
|
|
pager.SetDefaultParams(ctx)
|
|
|
|
ctx.Data["Page"] = pager
|
|
|
|
|
|
|
|
ctx.HTML(http.StatusOK, tplCommits)
|
|
|
|
}
|
|
|
|
|
|
|
|
func LoadBranchesAndTags(ctx *context.Context) {
|
|
|
|
response, err := git_service.LoadBranchesAndTags(ctx, ctx.Repo, ctx.Params("sha"))
|
|
|
|
if err == nil {
|
|
|
|
ctx.JSON(http.StatusOK, response)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
ctx.NotFoundOrServerError(fmt.Sprintf("could not load branches and tags the commit %s belongs to", ctx.Params("sha")), git.IsErrNotExist, err)
|
|
|
|
}
|
|
|
|
|
|
|
|
// Diff show different from current commit to previous commit
|
|
|
|
func Diff(ctx *context.Context) {
|
|
|
|
ctx.Data["PageIsDiff"] = true
|
|
|
|
|
|
|
|
userName := ctx.Repo.Owner.Name
|
|
|
|
repoName := ctx.Repo.Repository.Name
|
|
|
|
commitID := ctx.Params(":sha")
|
|
|
|
var (
|
|
|
|
gitRepo *git.Repository
|
|
|
|
err error
|
|
|
|
)
|
|
|
|
|
|
|
|
if ctx.Data["PageIsWiki"] != nil {
|
Simplify how git repositories are opened (#28937)
## Purpose
This is a refactor toward building an abstraction over managing git
repositories.
Afterwards, it does not matter anymore if they are stored on the local
disk or somewhere remote.
## What this PR changes
We used `git.OpenRepository` everywhere previously.
Now, we should split them into two distinct functions:
Firstly, there are temporary repositories which do not change:
```go
git.OpenRepository(ctx, diskPath)
```
Gitea managed repositories having a record in the database in the
`repository` table are moved into the new package `gitrepo`:
```go
gitrepo.OpenRepository(ctx, repo_model.Repo)
```
Why is `repo_model.Repository` the second parameter instead of file
path?
Because then we can easily adapt our repository storage strategy.
The repositories can be stored locally, however, they could just as well
be stored on a remote server.
## Further changes in other PRs
- A Git Command wrapper on package `gitrepo` could be created. i.e.
`NewCommand(ctx, repo_model.Repository, commands...)`. `git.RunOpts{Dir:
repo.RepoPath()}`, the directory should be empty before invoking this
method and it can be filled in the function only. #28940
- Remove the `RepoPath()`/`WikiPath()` functions to reduce the
possibility of mistakes.
---------
Co-authored-by: delvh <dev.lh@web.de>
10 months ago
|
|
|
gitRepo, err = gitrepo.OpenWikiRepository(ctx, ctx.Repo.Repository)
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("Repo.GitRepo.GetCommit", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
defer gitRepo.Close()
|
|
|
|
} else {
|
|
|
|
gitRepo = ctx.Repo.GitRepo
|
|
|
|
}
|
|
|
|
|
|
|
|
commit, err := gitRepo.GetCommit(commitID)
|
|
|
|
if err != nil {
|
|
|
|
if git.IsErrNotExist(err) {
|
|
|
|
ctx.NotFound("Repo.GitRepo.GetCommit", err)
|
|
|
|
} else {
|
|
|
|
ctx.ServerError("Repo.GitRepo.GetCommit", err)
|
|
|
|
}
|
|
|
|
return
|
|
|
|
}
|
|
|
|
if len(commitID) != commit.ID.Type().FullLength() {
|
|
|
|
commitID = commit.ID.String()
|
|
|
|
}
|
|
|
|
|
|
|
|
fileOnly := ctx.FormBool("file-only")
|
|
|
|
maxLines, maxFiles := setting.Git.MaxGitDiffLines, setting.Git.MaxGitDiffFiles
|
|
|
|
files := ctx.FormStrings("files")
|
|
|
|
if fileOnly && (len(files) == 2 || len(files) == 1) {
|
|
|
|
maxLines, maxFiles = -1, -1
|
|
|
|
}
|
|
|
|
|
|
|
|
diff, err := gitdiff.GetDiff(ctx, gitRepo, &gitdiff.DiffOptions{
|
|
|
|
AfterCommitID: commitID,
|
|
|
|
SkipTo: ctx.FormString("skip-to"),
|
|
|
|
MaxLines: maxLines,
|
|
|
|
MaxLineCharacters: setting.Git.MaxGitDiffLineCharacters,
|
|
|
|
MaxFiles: maxFiles,
|
|
|
|
WhitespaceBehavior: gitdiff.GetWhitespaceFlag(ctx.Data["WhitespaceBehavior"].(string)),
|
|
|
|
}, files...)
|
|
|
|
if err != nil {
|
|
|
|
ctx.NotFound("GetDiff", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
parents := make([]string, commit.ParentCount())
|
|
|
|
for i := 0; i < commit.ParentCount(); i++ {
|
|
|
|
sha, err := commit.ParentID(i)
|
|
|
|
if err != nil {
|
|
|
|
ctx.NotFound("repo.Diff", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
parents[i] = sha.String()
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.Data["CommitID"] = commitID
|
|
|
|
ctx.Data["AfterCommitID"] = commitID
|
|
|
|
ctx.Data["Username"] = userName
|
|
|
|
ctx.Data["Reponame"] = repoName
|
|
|
|
|
|
|
|
var parentCommit *git.Commit
|
|
|
|
if commit.ParentCount() > 0 {
|
|
|
|
parentCommit, err = gitRepo.GetCommit(parents[0])
|
|
|
|
if err != nil {
|
|
|
|
ctx.NotFound("GetParentCommit", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
setCompareContext(ctx, parentCommit, commit, userName, repoName)
|
|
|
|
ctx.Data["Title"] = commit.Summary() + " · " + base.ShortSha(commitID)
|
|
|
|
ctx.Data["Commit"] = commit
|
|
|
|
ctx.Data["Diff"] = diff
|
|
|
|
|
|
|
|
statuses, _, err := git_model.GetLatestCommitStatus(ctx, ctx.Repo.Repository.ID, commitID, db.ListOptions{ListAll: true})
|
|
|
|
if err != nil {
|
|
|
|
log.Error("GetLatestCommitStatus: %v", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.Data["CommitStatus"] = git_model.CalcCommitStatus(statuses)
|
|
|
|
ctx.Data["CommitStatuses"] = statuses
|
|
|
|
|
Add context cache as a request level cache (#22294)
To avoid duplicated load of the same data in an HTTP request, we can set
a context cache to do that. i.e. Some pages may load a user from a
database with the same id in different areas on the same page. But the
code is hidden in two different deep logic. How should we share the
user? As a result of this PR, now if both entry functions accept
`context.Context` as the first parameter and we just need to refactor
`GetUserByID` to reuse the user from the context cache. Then it will not
be loaded twice on an HTTP request.
But of course, sometimes we would like to reload an object from the
database, that's why `RemoveContextData` is also exposed.
The core context cache is here. It defines a new context
```go
type cacheContext struct {
ctx context.Context
data map[any]map[any]any
lock sync.RWMutex
}
var cacheContextKey = struct{}{}
func WithCacheContext(ctx context.Context) context.Context {
return context.WithValue(ctx, cacheContextKey, &cacheContext{
ctx: ctx,
data: make(map[any]map[any]any),
})
}
```
Then you can use the below 4 methods to read/write/del the data within
the same context.
```go
func GetContextData(ctx context.Context, tp, key any) any
func SetContextData(ctx context.Context, tp, key, value any)
func RemoveContextData(ctx context.Context, tp, key any)
func GetWithContextCache[T any](ctx context.Context, cacheGroupKey string, cacheTargetID any, f func() (T, error)) (T, error)
```
Then let's take a look at how `system.GetString` implement it.
```go
func GetSetting(ctx context.Context, key string) (string, error) {
return cache.GetWithContextCache(ctx, contextCacheKey, key, func() (string, error) {
return cache.GetString(genSettingCacheKey(key), func() (string, error) {
res, err := GetSettingNoCache(ctx, key)
if err != nil {
return "", err
}
return res.SettingValue, nil
})
})
}
```
First, it will check if context data include the setting object with the
key. If not, it will query from the global cache which may be memory or
a Redis cache. If not, it will get the object from the database. In the
end, if the object gets from the global cache or database, it will be
set into the context cache.
An object stored in the context cache will only be destroyed after the
context disappeared.
2 years ago
|
|
|
verification := asymkey_model.ParseCommitWithSignature(ctx, commit)
|
|
|
|
ctx.Data["Verification"] = verification
|
Add context cache as a request level cache (#22294)
To avoid duplicated load of the same data in an HTTP request, we can set
a context cache to do that. i.e. Some pages may load a user from a
database with the same id in different areas on the same page. But the
code is hidden in two different deep logic. How should we share the
user? As a result of this PR, now if both entry functions accept
`context.Context` as the first parameter and we just need to refactor
`GetUserByID` to reuse the user from the context cache. Then it will not
be loaded twice on an HTTP request.
But of course, sometimes we would like to reload an object from the
database, that's why `RemoveContextData` is also exposed.
The core context cache is here. It defines a new context
```go
type cacheContext struct {
ctx context.Context
data map[any]map[any]any
lock sync.RWMutex
}
var cacheContextKey = struct{}{}
func WithCacheContext(ctx context.Context) context.Context {
return context.WithValue(ctx, cacheContextKey, &cacheContext{
ctx: ctx,
data: make(map[any]map[any]any),
})
}
```
Then you can use the below 4 methods to read/write/del the data within
the same context.
```go
func GetContextData(ctx context.Context, tp, key any) any
func SetContextData(ctx context.Context, tp, key, value any)
func RemoveContextData(ctx context.Context, tp, key any)
func GetWithContextCache[T any](ctx context.Context, cacheGroupKey string, cacheTargetID any, f func() (T, error)) (T, error)
```
Then let's take a look at how `system.GetString` implement it.
```go
func GetSetting(ctx context.Context, key string) (string, error) {
return cache.GetWithContextCache(ctx, contextCacheKey, key, func() (string, error) {
return cache.GetString(genSettingCacheKey(key), func() (string, error) {
res, err := GetSettingNoCache(ctx, key)
if err != nil {
return "", err
}
return res.SettingValue, nil
})
})
}
```
First, it will check if context data include the setting object with the
key. If not, it will query from the global cache which may be memory or
a Redis cache. If not, it will get the object from the database. In the
end, if the object gets from the global cache or database, it will be
set into the context cache.
An object stored in the context cache will only be destroyed after the
context disappeared.
2 years ago
|
|
|
ctx.Data["Author"] = user_model.ValidateCommitWithEmail(ctx, commit)
|
|
|
|
ctx.Data["Parents"] = parents
|
|
|
|
ctx.Data["DiffNotAvailable"] = diff.NumFiles == 0
|
|
|
|
|
|
|
|
if err := asymkey_model.CalculateTrustStatus(verification, ctx.Repo.Repository.GetTrustModel(), func(user *user_model.User) (bool, error) {
|
|
|
|
return repo_model.IsOwnerMemberCollaborator(ctx, ctx.Repo.Repository, user.ID)
|
|
|
|
}, nil); err != nil {
|
|
|
|
ctx.ServerError("CalculateTrustStatus", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
note := &git.Note{}
|
|
|
|
err = git.GetNote(ctx, ctx.Repo.GitRepo, commitID, note)
|
|
|
|
if err == nil {
|
|
|
|
ctx.Data["NoteCommit"] = note.Commit
|
Add context cache as a request level cache (#22294)
To avoid duplicated load of the same data in an HTTP request, we can set
a context cache to do that. i.e. Some pages may load a user from a
database with the same id in different areas on the same page. But the
code is hidden in two different deep logic. How should we share the
user? As a result of this PR, now if both entry functions accept
`context.Context` as the first parameter and we just need to refactor
`GetUserByID` to reuse the user from the context cache. Then it will not
be loaded twice on an HTTP request.
But of course, sometimes we would like to reload an object from the
database, that's why `RemoveContextData` is also exposed.
The core context cache is here. It defines a new context
```go
type cacheContext struct {
ctx context.Context
data map[any]map[any]any
lock sync.RWMutex
}
var cacheContextKey = struct{}{}
func WithCacheContext(ctx context.Context) context.Context {
return context.WithValue(ctx, cacheContextKey, &cacheContext{
ctx: ctx,
data: make(map[any]map[any]any),
})
}
```
Then you can use the below 4 methods to read/write/del the data within
the same context.
```go
func GetContextData(ctx context.Context, tp, key any) any
func SetContextData(ctx context.Context, tp, key, value any)
func RemoveContextData(ctx context.Context, tp, key any)
func GetWithContextCache[T any](ctx context.Context, cacheGroupKey string, cacheTargetID any, f func() (T, error)) (T, error)
```
Then let's take a look at how `system.GetString` implement it.
```go
func GetSetting(ctx context.Context, key string) (string, error) {
return cache.GetWithContextCache(ctx, contextCacheKey, key, func() (string, error) {
return cache.GetString(genSettingCacheKey(key), func() (string, error) {
res, err := GetSettingNoCache(ctx, key)
if err != nil {
return "", err
}
return res.SettingValue, nil
})
})
}
```
First, it will check if context data include the setting object with the
key. If not, it will query from the global cache which may be memory or
a Redis cache. If not, it will get the object from the database. In the
end, if the object gets from the global cache or database, it will be
set into the context cache.
An object stored in the context cache will only be destroyed after the
context disappeared.
2 years ago
|
|
|
ctx.Data["NoteAuthor"] = user_model.ValidateCommitWithEmail(ctx, note.Commit)
|
|
|
|
ctx.Data["NoteRendered"], err = markup.RenderCommitMessage(&markup.RenderContext{
|
|
|
|
Links: markup.Links{
|
|
|
|
Base: ctx.Repo.RepoLink,
|
|
|
|
BranchPath: path.Join("commit", util.PathEscapeSegments(commitID)),
|
|
|
|
},
|
|
|
|
Metas: ctx.Repo.Repository.ComposeMetas(ctx),
|
|
|
|
GitRepo: ctx.Repo.GitRepo,
|
|
|
|
Ctx: ctx,
|
|
|
|
}, template.HTMLEscapeString(string(charset.ToUTF8WithFallback(note.Message, charset.ConvertOpts{}))))
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("RenderCommitMessage", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.Data["BranchName"], err = commit.GetBranchName()
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("commit.GetBranchName", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
ctx.HTML(http.StatusOK, tplCommitPage)
|
|
|
|
}
|
|
|
|
|
|
|
|
// RawDiff dumps diff results of repository in given commit ID to io.Writer
|
|
|
|
func RawDiff(ctx *context.Context) {
|
|
|
|
var gitRepo *git.Repository
|
|
|
|
if ctx.Data["PageIsWiki"] != nil {
|
Simplify how git repositories are opened (#28937)
## Purpose
This is a refactor toward building an abstraction over managing git
repositories.
Afterwards, it does not matter anymore if they are stored on the local
disk or somewhere remote.
## What this PR changes
We used `git.OpenRepository` everywhere previously.
Now, we should split them into two distinct functions:
Firstly, there are temporary repositories which do not change:
```go
git.OpenRepository(ctx, diskPath)
```
Gitea managed repositories having a record in the database in the
`repository` table are moved into the new package `gitrepo`:
```go
gitrepo.OpenRepository(ctx, repo_model.Repo)
```
Why is `repo_model.Repository` the second parameter instead of file
path?
Because then we can easily adapt our repository storage strategy.
The repositories can be stored locally, however, they could just as well
be stored on a remote server.
## Further changes in other PRs
- A Git Command wrapper on package `gitrepo` could be created. i.e.
`NewCommand(ctx, repo_model.Repository, commands...)`. `git.RunOpts{Dir:
repo.RepoPath()}`, the directory should be empty before invoking this
method and it can be filled in the function only. #28940
- Remove the `RepoPath()`/`WikiPath()` functions to reduce the
possibility of mistakes.
---------
Co-authored-by: delvh <dev.lh@web.de>
10 months ago
|
|
|
wikiRepo, err := gitrepo.OpenWikiRepository(ctx, ctx.Repo.Repository)
|
|
|
|
if err != nil {
|
|
|
|
ctx.ServerError("OpenRepository", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
defer wikiRepo.Close()
|
|
|
|
gitRepo = wikiRepo
|
|
|
|
} else {
|
|
|
|
gitRepo = ctx.Repo.GitRepo
|
|
|
|
if gitRepo == nil {
|
|
|
|
ctx.ServerError("GitRepo not open", fmt.Errorf("no open git repo for '%s'", ctx.Repo.Repository.FullName()))
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if err := git.GetRawDiff(
|
|
|
|
gitRepo,
|
|
|
|
ctx.Params(":sha"),
|
|
|
|
git.RawDiffType(ctx.Params(":ext")),
|
|
|
|
ctx.Resp,
|
|
|
|
); err != nil {
|
|
|
|
if git.IsErrNotExist(err) {
|
|
|
|
ctx.NotFound("GetRawDiff",
|
|
|
|
errors.New("commit "+ctx.Params(":sha")+" does not exist."))
|
|
|
|
return
|
|
|
|
}
|
|
|
|
ctx.ServerError("GetRawDiff", err)
|
|
|
|
return
|
|
|
|
}
|
|
|
|
}
|