123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309 |
- // Copyright 2018 The Gogs Authors. All rights reserved.
- // Copyright 2019 The Gitea Authors. All rights reserved.
- // Use of this source code is governed by a MIT-style
- // license that can be found in the LICENSE file.
-
- package repo
-
- import (
- "fmt"
- "math"
- "net/http"
- "strconv"
- "time"
-
- "code.gitea.io/gitea/models"
- "code.gitea.io/gitea/modules/context"
- "code.gitea.io/gitea/modules/git"
- "code.gitea.io/gitea/modules/setting"
- api "code.gitea.io/gitea/modules/structs"
- "code.gitea.io/gitea/modules/validation"
- "code.gitea.io/gitea/routers/api/v1/utils"
- )
-
- // GetSingleCommit get a commit via sha
- func GetSingleCommit(ctx *context.APIContext) {
- // swagger:operation GET /repos/{owner}/{repo}/git/commits/{sha} repository repoGetSingleCommit
- // ---
- // summary: Get a single commit from a repository
- // produces:
- // - application/json
- // parameters:
- // - name: owner
- // in: path
- // description: owner of the repo
- // type: string
- // required: true
- // - name: repo
- // in: path
- // description: name of the repo
- // type: string
- // required: true
- // - name: sha
- // in: path
- // description: a git ref or commit sha
- // type: string
- // required: true
- // responses:
- // "200":
- // "$ref": "#/responses/Commit"
- // "422":
- // "$ref": "#/responses/validationError"
- // "404":
- // "$ref": "#/responses/notFound"
-
- sha := ctx.Params(":sha")
- if (validation.GitRefNamePatternInvalid.MatchString(sha) || !validation.CheckGitRefAdditionalRulesValid(sha)) && !git.SHAPattern.MatchString(sha) {
- ctx.Error(http.StatusUnprocessableEntity, "no valid ref or sha", fmt.Sprintf("no valid ref or sha: %s", sha))
- return
- }
- getCommit(ctx, sha)
- }
-
- func getCommit(ctx *context.APIContext, identifier string) {
- gitRepo, err := git.OpenRepository(ctx.Repo.Repository.RepoPath())
- if err != nil {
- ctx.ServerError("OpenRepository", err)
- return
- }
- defer gitRepo.Close()
- commit, err := gitRepo.GetCommit(identifier)
- if err != nil {
- ctx.NotFoundOrServerError("GetCommit", git.IsErrNotExist, err)
- return
- }
-
- json, err := toCommit(ctx, ctx.Repo.Repository, commit, nil)
- if err != nil {
- ctx.ServerError("toCommit", err)
- return
- }
- ctx.JSON(http.StatusOK, json)
- }
-
- // GetAllCommits get all commits via
- func GetAllCommits(ctx *context.APIContext) {
- // swagger:operation GET /repos/{owner}/{repo}/commits repository repoGetAllCommits
- // ---
- // summary: Get a list of all commits from a repository
- // produces:
- // - application/json
- // parameters:
- // - name: owner
- // in: path
- // description: owner of the repo
- // type: string
- // required: true
- // - name: repo
- // in: path
- // description: name of the repo
- // type: string
- // required: true
- // - name: sha
- // in: query
- // description: SHA or branch to start listing commits from (usually 'master')
- // type: string
- // - name: page
- // in: query
- // description: page number of results to return (1-based)
- // type: integer
- // - name: limit
- // in: query
- // description: page size of results, maximum page size is 50
- // type: integer
- // responses:
- // "200":
- // "$ref": "#/responses/CommitList"
- // "404":
- // "$ref": "#/responses/notFound"
- // "409":
- // "$ref": "#/responses/EmptyRepository"
-
- if ctx.Repo.Repository.IsEmpty {
- ctx.JSON(http.StatusConflict, api.APIError{
- Message: "Git Repository is empty.",
- URL: setting.API.SwaggerURL,
- })
- return
- }
-
- gitRepo, err := git.OpenRepository(ctx.Repo.Repository.RepoPath())
- if err != nil {
- ctx.ServerError("OpenRepository", err)
- return
- }
- defer gitRepo.Close()
-
- listOptions := utils.GetListOptions(ctx)
- if listOptions.Page <= 0 {
- listOptions.Page = 1
- }
-
- if listOptions.PageSize > git.CommitsRangeSize {
- listOptions.PageSize = git.CommitsRangeSize
- }
-
- sha := ctx.Query("sha")
-
- var baseCommit *git.Commit
- if len(sha) == 0 {
- // no sha supplied - use default branch
- head, err := gitRepo.GetHEADBranch()
- if err != nil {
- ctx.ServerError("GetHEADBranch", err)
- return
- }
-
- baseCommit, err = gitRepo.GetBranchCommit(head.Name)
- if err != nil {
- ctx.ServerError("GetCommit", err)
- return
- }
- } else {
- // get commit specified by sha
- baseCommit, err = gitRepo.GetCommit(sha)
- if err != nil {
- ctx.ServerError("GetCommit", err)
- return
- }
- }
-
- // Total commit count
- commitsCountTotal, err := baseCommit.CommitsCount()
- if err != nil {
- ctx.ServerError("GetCommitsCount", err)
- return
- }
-
- pageCount := int(math.Ceil(float64(commitsCountTotal) / float64(listOptions.PageSize)))
-
- // Query commits
- commits, err := baseCommit.CommitsByRange(listOptions.Page, listOptions.PageSize)
- if err != nil {
- ctx.ServerError("CommitsByRange", err)
- return
- }
-
- userCache := make(map[string]*models.User)
-
- apiCommits := make([]*api.Commit, commits.Len())
-
- i := 0
- for commitPointer := commits.Front(); commitPointer != nil; commitPointer = commitPointer.Next() {
- commit := commitPointer.Value.(*git.Commit)
-
- // Create json struct
- apiCommits[i], err = toCommit(ctx, ctx.Repo.Repository, commit, userCache)
- if err != nil {
- ctx.ServerError("toCommit", err)
- return
- }
-
- i++
- }
-
- ctx.SetLinkHeader(int(commitsCountTotal), listOptions.PageSize)
-
- ctx.Header().Set("X-Page", strconv.Itoa(listOptions.Page))
- ctx.Header().Set("X-PerPage", strconv.Itoa(listOptions.PageSize))
- ctx.Header().Set("X-Total", strconv.FormatInt(commitsCountTotal, 10))
- ctx.Header().Set("X-PageCount", strconv.Itoa(pageCount))
- ctx.Header().Set("X-HasMore", strconv.FormatBool(listOptions.Page < pageCount))
-
- ctx.JSON(http.StatusOK, &apiCommits)
- }
-
- func toCommit(ctx *context.APIContext, repo *models.Repository, commit *git.Commit, userCache map[string]*models.User) (*api.Commit, error) {
-
- var apiAuthor, apiCommitter *api.User
-
- // Retrieve author and committer information
-
- var cacheAuthor *models.User
- var ok bool
- if userCache == nil {
- cacheAuthor = ((*models.User)(nil))
- ok = false
- } else {
- cacheAuthor, ok = userCache[commit.Author.Email]
- }
-
- if ok {
- apiAuthor = cacheAuthor.APIFormat()
- } else {
- author, err := models.GetUserByEmail(commit.Author.Email)
- if err != nil && !models.IsErrUserNotExist(err) {
- return nil, err
- } else if err == nil {
- apiAuthor = author.APIFormat()
- if userCache != nil {
- userCache[commit.Author.Email] = author
- }
- }
- }
-
- var cacheCommitter *models.User
- if userCache == nil {
- cacheCommitter = ((*models.User)(nil))
- ok = false
- } else {
- cacheCommitter, ok = userCache[commit.Committer.Email]
- }
-
- if ok {
- apiCommitter = cacheCommitter.APIFormat()
- } else {
- committer, err := models.GetUserByEmail(commit.Committer.Email)
- if err != nil && !models.IsErrUserNotExist(err) {
- return nil, err
- } else if err == nil {
- apiCommitter = committer.APIFormat()
- if userCache != nil {
- userCache[commit.Committer.Email] = committer
- }
- }
- }
-
- // Retrieve parent(s) of the commit
- apiParents := make([]*api.CommitMeta, commit.ParentCount())
- for i := 0; i < commit.ParentCount(); i++ {
- sha, _ := commit.ParentID(i)
- apiParents[i] = &api.CommitMeta{
- URL: repo.APIURL() + "/git/commits/" + sha.String(),
- SHA: sha.String(),
- }
- }
-
- return &api.Commit{
- CommitMeta: &api.CommitMeta{
- URL: repo.APIURL() + "/git/commits/" + commit.ID.String(),
- SHA: commit.ID.String(),
- },
- HTMLURL: repo.HTMLURL() + "/commit/" + commit.ID.String(),
- RepoCommit: &api.RepoCommit{
- URL: repo.APIURL() + "/git/commits/" + commit.ID.String(),
- Author: &api.CommitUser{
- Identity: api.Identity{
- Name: commit.Committer.Name,
- Email: commit.Committer.Email,
- },
- Date: commit.Author.When.Format(time.RFC3339),
- },
- Committer: &api.CommitUser{
- Identity: api.Identity{
- Name: commit.Committer.Name,
- Email: commit.Committer.Email,
- },
- Date: commit.Committer.When.Format(time.RFC3339),
- },
- Message: commit.Message(),
- Tree: &api.CommitMeta{
- URL: repo.APIURL() + "/git/trees/" + commit.ID.String(),
- SHA: commit.ID.String(),
- },
- },
- Author: apiAuthor,
- Committer: apiCommitter,
- Parents: apiParents,
- }, nil
- }
|