新增:贡献者新方案解决效率

This commit is contained in:
yystopf 2023-02-28 10:48:49 +08:00
parent ab66f7a4de
commit dc9cd9e168
2 changed files with 90 additions and 3 deletions

View File

@ -0,0 +1,88 @@
package git
import (
"bufio"
"context"
"os"
"strconv"
"strings"
gitea_git "code.gitea.io/gitea/modules/git"
)
type RepoContributor struct {
Name string `json:"name"`
Email string `json:"email"`
Commits int `json:"commits"`
}
func GetRepoContributors(repo *gitea_git.Repository, page, pageSize int) (int, []*RepoContributor, error) {
var total, skip int
var contributors []*RepoContributor
skip = (page - 1) * pageSize
stdoutReader, stdoutWriter, err := os.Pipe()
if err != nil {
return total, nil, err
}
defer func() {
_ = stdoutReader.Close()
_ = stdoutWriter.Close()
}()
cmd := gitea_git.NewCommand(repo.Ctx, "shortlog", "-sne", "HEAD")
stderr := new(strings.Builder)
err = cmd.Run(&gitea_git.RunOpts{
Env: []string{},
Dir: repo.Path,
Stdout: stdoutWriter,
Stderr: stderr,
PipelineFunc: func(ctx context.Context, cancel context.CancelFunc) error {
_ = stdoutWriter.Close()
scanner := bufio.NewScanner(stdoutReader)
scanner.Split(bufio.ScanLines)
var ca int
for scanner.Scan() {
total++
if skip > 0 {
skip--
} else {
if ca < pageSize {
l := strings.TrimSpace(scanner.Text())
commits := l[0:strings.Index(l, "\t")]
commitsInt, err := strconv.Atoi(commits)
if err != nil {
return err
}
name := l[strings.Index(l, "\t")+1 : strings.Index(l, " <")]
email := l[strings.Index(l, "<")+1 : strings.Index(l, ">")]
contributors = append(contributors, &RepoContributor{
Commits: commitsInt,
Name: name,
Email: email,
})
ca++
}
}
}
_ = stdoutReader.Close()
return nil
},
})
// skip := (page - 1) * pageSize
// for _, con := range contributorsArr {
// if skip > 0 {
// contributors = append(contributors, &RepoContributor{
// Commits: con,
// })
// skip--
// }
// }
return total, contributors, nil
}

View File

@ -483,11 +483,10 @@ func SetDiffViewStyle(ctx *context.Context) {
func GetContributors(ctx *context.APIContext) {
listOptions := utils.GetListOptions(ctx)
branch := ctx.FormString("branch")
total, list, err := hat_git.GetPaginateCodeAuthorsWithoutSince(ctx.Repo.GitRepo, branch, listOptions.Page, listOptions.PageSize)
total, list, err := hat_git.GetRepoContributors(ctx.Repo.GitRepo, listOptions.Page, listOptions.PageSize)
if err != nil {
ctx.Error(http.StatusInternalServerError, "GetContributors", err)
ctx.Error(http.StatusInternalServerError, "GetRepoContributors", err)
return
}