mirror of
				https://github.com/go-gitea/gitea.git
				synced 2025-10-25 04:08:26 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			790 lines
		
	
	
		
			21 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			790 lines
		
	
	
		
			21 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
| // Copyright 2014 The Gogs 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 models
 | |
| 
 | |
| import (
 | |
| 	"encoding/json"
 | |
| 	"fmt"
 | |
| 	"path"
 | |
| 	"regexp"
 | |
| 	"strconv"
 | |
| 	"strings"
 | |
| 	"time"
 | |
| 	"unicode"
 | |
| 
 | |
| 	"code.gitea.io/git"
 | |
| 	"code.gitea.io/gitea/modules/base"
 | |
| 	"code.gitea.io/gitea/modules/log"
 | |
| 	"code.gitea.io/gitea/modules/setting"
 | |
| 	"code.gitea.io/gitea/modules/util"
 | |
| 	api "code.gitea.io/sdk/gitea"
 | |
| 
 | |
| 	"github.com/Unknwon/com"
 | |
| 	"github.com/go-xorm/builder"
 | |
| )
 | |
| 
 | |
| // ActionType represents the type of an action.
 | |
| type ActionType int
 | |
| 
 | |
| // Possible action types.
 | |
| const (
 | |
| 	ActionCreateRepo        ActionType = iota + 1 // 1
 | |
| 	ActionRenameRepo                              // 2
 | |
| 	ActionStarRepo                                // 3
 | |
| 	ActionWatchRepo                               // 4
 | |
| 	ActionCommitRepo                              // 5
 | |
| 	ActionCreateIssue                             // 6
 | |
| 	ActionCreatePullRequest                       // 7
 | |
| 	ActionTransferRepo                            // 8
 | |
| 	ActionPushTag                                 // 9
 | |
| 	ActionCommentIssue                            // 10
 | |
| 	ActionMergePullRequest                        // 11
 | |
| 	ActionCloseIssue                              // 12
 | |
| 	ActionReopenIssue                             // 13
 | |
| 	ActionClosePullRequest                        // 14
 | |
| 	ActionReopenPullRequest                       // 15
 | |
| 	ActionDeleteTag                               // 16
 | |
| 	ActionDeleteBranch                            // 17
 | |
| )
 | |
| 
 | |
| var (
 | |
| 	// Same as Github. See
 | |
| 	// https://help.github.com/articles/closing-issues-via-commit-messages
 | |
| 	issueCloseKeywords  = []string{"close", "closes", "closed", "fix", "fixes", "fixed", "resolve", "resolves", "resolved"}
 | |
| 	issueReopenKeywords = []string{"reopen", "reopens", "reopened"}
 | |
| 
 | |
| 	issueCloseKeywordsPat, issueReopenKeywordsPat *regexp.Regexp
 | |
| 	issueReferenceKeywordsPat                     *regexp.Regexp
 | |
| )
 | |
| 
 | |
| const issueRefRegexpStr = `(?:\S+/\S=)?#\d+`
 | |
| 
 | |
| func assembleKeywordsPattern(words []string) string {
 | |
| 	return fmt.Sprintf(`(?i)(?:%s) %s`, strings.Join(words, "|"), issueRefRegexpStr)
 | |
| }
 | |
| 
 | |
| func init() {
 | |
| 	issueCloseKeywordsPat = regexp.MustCompile(assembleKeywordsPattern(issueCloseKeywords))
 | |
| 	issueReopenKeywordsPat = regexp.MustCompile(assembleKeywordsPattern(issueReopenKeywords))
 | |
| 	issueReferenceKeywordsPat = regexp.MustCompile(issueRefRegexpStr)
 | |
| }
 | |
| 
 | |
| // Action represents user operation type and other information to
 | |
| // repository. It implemented interface base.Actioner so that can be
 | |
| // used in template render.
 | |
| type Action struct {
 | |
| 	ID          int64 `xorm:"pk autoincr"`
 | |
| 	UserID      int64 `xorm:"INDEX"` // Receiver user id.
 | |
| 	OpType      ActionType
 | |
| 	ActUserID   int64       `xorm:"INDEX"` // Action user id.
 | |
| 	ActUser     *User       `xorm:"-"`
 | |
| 	RepoID      int64       `xorm:"INDEX"`
 | |
| 	Repo        *Repository `xorm:"-"`
 | |
| 	CommentID   int64       `xorm:"INDEX"`
 | |
| 	Comment     *Comment    `xorm:"-"`
 | |
| 	IsDeleted   bool        `xorm:"INDEX NOT NULL DEFAULT false"`
 | |
| 	RefName     string
 | |
| 	IsPrivate   bool           `xorm:"INDEX NOT NULL DEFAULT false"`
 | |
| 	Content     string         `xorm:"TEXT"`
 | |
| 	CreatedUnix util.TimeStamp `xorm:"INDEX created"`
 | |
| }
 | |
| 
 | |
| // GetOpType gets the ActionType of this action.
 | |
| func (a *Action) GetOpType() ActionType {
 | |
| 	return a.OpType
 | |
| }
 | |
| 
 | |
| func (a *Action) loadActUser() {
 | |
| 	if a.ActUser != nil {
 | |
| 		return
 | |
| 	}
 | |
| 	var err error
 | |
| 	a.ActUser, err = GetUserByID(a.ActUserID)
 | |
| 	if err == nil {
 | |
| 		return
 | |
| 	} else if IsErrUserNotExist(err) {
 | |
| 		a.ActUser = NewGhostUser()
 | |
| 	} else {
 | |
| 		log.Error(4, "GetUserByID(%d): %v", a.ActUserID, err)
 | |
| 	}
 | |
| }
 | |
| 
 | |
| func (a *Action) loadRepo() {
 | |
| 	if a.Repo != nil {
 | |
| 		return
 | |
| 	}
 | |
| 	var err error
 | |
| 	a.Repo, err = GetRepositoryByID(a.RepoID)
 | |
| 	if err != nil {
 | |
| 		log.Error(4, "GetRepositoryByID(%d): %v", a.RepoID, err)
 | |
| 	}
 | |
| }
 | |
| 
 | |
| // GetActFullName gets the action's user full name.
 | |
| func (a *Action) GetActFullName() string {
 | |
| 	a.loadActUser()
 | |
| 	return a.ActUser.FullName
 | |
| }
 | |
| 
 | |
| // GetActUserName gets the action's user name.
 | |
| func (a *Action) GetActUserName() string {
 | |
| 	a.loadActUser()
 | |
| 	return a.ActUser.Name
 | |
| }
 | |
| 
 | |
| // ShortActUserName gets the action's user name trimmed to max 20
 | |
| // chars.
 | |
| func (a *Action) ShortActUserName() string {
 | |
| 	return base.EllipsisString(a.GetActUserName(), 20)
 | |
| }
 | |
| 
 | |
| // GetActAvatar the action's user's avatar link
 | |
| func (a *Action) GetActAvatar() string {
 | |
| 	a.loadActUser()
 | |
| 	return a.ActUser.RelAvatarLink()
 | |
| }
 | |
| 
 | |
| // GetRepoUserName returns the name of the action repository owner.
 | |
| func (a *Action) GetRepoUserName() string {
 | |
| 	a.loadRepo()
 | |
| 	return a.Repo.MustOwner().Name
 | |
| }
 | |
| 
 | |
| // ShortRepoUserName returns the name of the action repository owner
 | |
| // trimmed to max 20 chars.
 | |
| func (a *Action) ShortRepoUserName() string {
 | |
| 	return base.EllipsisString(a.GetRepoUserName(), 20)
 | |
| }
 | |
| 
 | |
| // GetRepoName returns the name of the action repository.
 | |
| func (a *Action) GetRepoName() string {
 | |
| 	a.loadRepo()
 | |
| 	return a.Repo.Name
 | |
| }
 | |
| 
 | |
| // ShortRepoName returns the name of the action repository
 | |
| // trimmed to max 33 chars.
 | |
| func (a *Action) ShortRepoName() string {
 | |
| 	return base.EllipsisString(a.GetRepoName(), 33)
 | |
| }
 | |
| 
 | |
| // GetRepoPath returns the virtual path to the action repository.
 | |
| func (a *Action) GetRepoPath() string {
 | |
| 	return path.Join(a.GetRepoUserName(), a.GetRepoName())
 | |
| }
 | |
| 
 | |
| // ShortRepoPath returns the virtual path to the action repository
 | |
| // trimmed to max 20 + 1 + 33 chars.
 | |
| func (a *Action) ShortRepoPath() string {
 | |
| 	return path.Join(a.ShortRepoUserName(), a.ShortRepoName())
 | |
| }
 | |
| 
 | |
| // GetRepoLink returns relative link to action repository.
 | |
| func (a *Action) GetRepoLink() string {
 | |
| 	if len(setting.AppSubURL) > 0 {
 | |
| 		return path.Join(setting.AppSubURL, a.GetRepoPath())
 | |
| 	}
 | |
| 	return "/" + a.GetRepoPath()
 | |
| }
 | |
| 
 | |
| // GetCommentLink returns link to action comment.
 | |
| func (a *Action) GetCommentLink() string {
 | |
| 	if a == nil {
 | |
| 		return "#"
 | |
| 	}
 | |
| 	if a.Comment == nil && a.CommentID != 0 {
 | |
| 		a.Comment, _ = GetCommentByID(a.CommentID)
 | |
| 	}
 | |
| 	if a.Comment != nil {
 | |
| 		return a.Comment.HTMLURL()
 | |
| 	}
 | |
| 	if len(a.GetIssueInfos()) == 0 {
 | |
| 		return "#"
 | |
| 	}
 | |
| 	//Return link to issue
 | |
| 	issueIDString := a.GetIssueInfos()[0]
 | |
| 	issueID, err := strconv.ParseInt(issueIDString, 10, 64)
 | |
| 	if err != nil {
 | |
| 		return "#"
 | |
| 	}
 | |
| 
 | |
| 	issue, err := GetIssueByID(issueID)
 | |
| 	if err != nil {
 | |
| 		return "#"
 | |
| 	}
 | |
| 
 | |
| 	return issue.HTMLURL()
 | |
| }
 | |
| 
 | |
| // GetBranch returns the action's repository branch.
 | |
| func (a *Action) GetBranch() string {
 | |
| 	return a.RefName
 | |
| }
 | |
| 
 | |
| // GetContent returns the action's content.
 | |
| func (a *Action) GetContent() string {
 | |
| 	return a.Content
 | |
| }
 | |
| 
 | |
| // GetCreate returns the action creation time.
 | |
| func (a *Action) GetCreate() time.Time {
 | |
| 	return a.CreatedUnix.AsTime()
 | |
| }
 | |
| 
 | |
| // GetIssueInfos returns a list of issues associated with
 | |
| // the action.
 | |
| func (a *Action) GetIssueInfos() []string {
 | |
| 	return strings.SplitN(a.Content, "|", 2)
 | |
| }
 | |
| 
 | |
| // GetIssueTitle returns the title of first issue associated
 | |
| // with the action.
 | |
| func (a *Action) GetIssueTitle() string {
 | |
| 	index := com.StrTo(a.GetIssueInfos()[0]).MustInt64()
 | |
| 	issue, err := GetIssueByIndex(a.RepoID, index)
 | |
| 	if err != nil {
 | |
| 		log.Error(4, "GetIssueByIndex: %v", err)
 | |
| 		return "500 when get issue"
 | |
| 	}
 | |
| 	return issue.Title
 | |
| }
 | |
| 
 | |
| // GetIssueContent returns the content of first issue associated with
 | |
| // this action.
 | |
| func (a *Action) GetIssueContent() string {
 | |
| 	index := com.StrTo(a.GetIssueInfos()[0]).MustInt64()
 | |
| 	issue, err := GetIssueByIndex(a.RepoID, index)
 | |
| 	if err != nil {
 | |
| 		log.Error(4, "GetIssueByIndex: %v", err)
 | |
| 		return "500 when get issue"
 | |
| 	}
 | |
| 	return issue.Content
 | |
| }
 | |
| 
 | |
| func newRepoAction(e Engine, u *User, repo *Repository) (err error) {
 | |
| 	if err = notifyWatchers(e, &Action{
 | |
| 		ActUserID: u.ID,
 | |
| 		ActUser:   u,
 | |
| 		OpType:    ActionCreateRepo,
 | |
| 		RepoID:    repo.ID,
 | |
| 		Repo:      repo,
 | |
| 		IsPrivate: repo.IsPrivate,
 | |
| 	}); err != nil {
 | |
| 		return fmt.Errorf("notify watchers '%d/%d': %v", u.ID, repo.ID, err)
 | |
| 	}
 | |
| 
 | |
| 	log.Trace("action.newRepoAction: %s/%s", u.Name, repo.Name)
 | |
| 	return err
 | |
| }
 | |
| 
 | |
| // NewRepoAction adds new action for creating repository.
 | |
| func NewRepoAction(u *User, repo *Repository) (err error) {
 | |
| 	return newRepoAction(x, u, repo)
 | |
| }
 | |
| 
 | |
| func renameRepoAction(e Engine, actUser *User, oldRepoName string, repo *Repository) (err error) {
 | |
| 	if err = notifyWatchers(e, &Action{
 | |
| 		ActUserID: actUser.ID,
 | |
| 		ActUser:   actUser,
 | |
| 		OpType:    ActionRenameRepo,
 | |
| 		RepoID:    repo.ID,
 | |
| 		Repo:      repo,
 | |
| 		IsPrivate: repo.IsPrivate,
 | |
| 		Content:   oldRepoName,
 | |
| 	}); err != nil {
 | |
| 		return fmt.Errorf("notify watchers: %v", err)
 | |
| 	}
 | |
| 
 | |
| 	log.Trace("action.renameRepoAction: %s/%s", actUser.Name, repo.Name)
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| // RenameRepoAction adds new action for renaming a repository.
 | |
| func RenameRepoAction(actUser *User, oldRepoName string, repo *Repository) error {
 | |
| 	return renameRepoAction(x, actUser, oldRepoName, repo)
 | |
| }
 | |
| 
 | |
| func issueIndexTrimRight(c rune) bool {
 | |
| 	return !unicode.IsDigit(c)
 | |
| }
 | |
| 
 | |
| // PushCommit represents a commit in a push operation.
 | |
| type PushCommit struct {
 | |
| 	Sha1           string
 | |
| 	Message        string
 | |
| 	AuthorEmail    string
 | |
| 	AuthorName     string
 | |
| 	CommitterEmail string
 | |
| 	CommitterName  string
 | |
| 	Timestamp      time.Time
 | |
| }
 | |
| 
 | |
| // PushCommits represents list of commits in a push operation.
 | |
| type PushCommits struct {
 | |
| 	Len        int
 | |
| 	Commits    []*PushCommit
 | |
| 	CompareURL string
 | |
| 
 | |
| 	avatars map[string]string
 | |
| }
 | |
| 
 | |
| // NewPushCommits creates a new PushCommits object.
 | |
| func NewPushCommits() *PushCommits {
 | |
| 	return &PushCommits{
 | |
| 		avatars: make(map[string]string),
 | |
| 	}
 | |
| }
 | |
| 
 | |
| // ToAPIPayloadCommits converts a PushCommits object to
 | |
| // api.PayloadCommit format.
 | |
| func (pc *PushCommits) ToAPIPayloadCommits(repoLink string) []*api.PayloadCommit {
 | |
| 	commits := make([]*api.PayloadCommit, len(pc.Commits))
 | |
| 	for i, commit := range pc.Commits {
 | |
| 		authorUsername := ""
 | |
| 		author, err := GetUserByEmail(commit.AuthorEmail)
 | |
| 		if err == nil {
 | |
| 			authorUsername = author.Name
 | |
| 		}
 | |
| 		committerUsername := ""
 | |
| 		committer, err := GetUserByEmail(commit.CommitterEmail)
 | |
| 		if err == nil {
 | |
| 			// TODO: check errors other than email not found.
 | |
| 			committerUsername = committer.Name
 | |
| 		}
 | |
| 		commits[i] = &api.PayloadCommit{
 | |
| 			ID:      commit.Sha1,
 | |
| 			Message: commit.Message,
 | |
| 			URL:     fmt.Sprintf("%s/commit/%s", repoLink, commit.Sha1),
 | |
| 			Author: &api.PayloadUser{
 | |
| 				Name:     commit.AuthorName,
 | |
| 				Email:    commit.AuthorEmail,
 | |
| 				UserName: authorUsername,
 | |
| 			},
 | |
| 			Committer: &api.PayloadUser{
 | |
| 				Name:     commit.CommitterName,
 | |
| 				Email:    commit.CommitterEmail,
 | |
| 				UserName: committerUsername,
 | |
| 			},
 | |
| 			Timestamp: commit.Timestamp,
 | |
| 		}
 | |
| 	}
 | |
| 	return commits
 | |
| }
 | |
| 
 | |
| // AvatarLink tries to match user in database with e-mail
 | |
| // in order to show custom avatar, and falls back to general avatar link.
 | |
| func (pc *PushCommits) AvatarLink(email string) string {
 | |
| 	_, ok := pc.avatars[email]
 | |
| 	if !ok {
 | |
| 		u, err := GetUserByEmail(email)
 | |
| 		if err != nil {
 | |
| 			pc.avatars[email] = base.AvatarLink(email)
 | |
| 			if !IsErrUserNotExist(err) {
 | |
| 				log.Error(4, "GetUserByEmail: %v", err)
 | |
| 			}
 | |
| 		} else {
 | |
| 			pc.avatars[email] = u.RelAvatarLink()
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	return pc.avatars[email]
 | |
| }
 | |
| 
 | |
| // getIssueFromRef returns the issue referenced by a ref. Returns a nil *Issue
 | |
| // if the provided ref is misformatted or references a non-existent issue.
 | |
| func getIssueFromRef(repo *Repository, ref string) (*Issue, error) {
 | |
| 	ref = ref[strings.IndexByte(ref, ' ')+1:]
 | |
| 	ref = strings.TrimRightFunc(ref, issueIndexTrimRight)
 | |
| 
 | |
| 	var refRepo *Repository
 | |
| 	poundIndex := strings.IndexByte(ref, '#')
 | |
| 	if poundIndex < 0 {
 | |
| 		return nil, nil
 | |
| 	} else if poundIndex == 0 {
 | |
| 		refRepo = repo
 | |
| 	} else {
 | |
| 		slashIndex := strings.IndexByte(ref, '/')
 | |
| 		if slashIndex < 0 || slashIndex >= poundIndex {
 | |
| 			return nil, nil
 | |
| 		}
 | |
| 		ownerName := ref[:slashIndex]
 | |
| 		repoName := ref[slashIndex+1 : poundIndex]
 | |
| 		var err error
 | |
| 		refRepo, err = GetRepositoryByOwnerAndName(ownerName, repoName)
 | |
| 		if err != nil {
 | |
| 			if IsErrRepoNotExist(err) {
 | |
| 				return nil, nil
 | |
| 			}
 | |
| 			return nil, err
 | |
| 		}
 | |
| 	}
 | |
| 	issueIndex, err := strconv.ParseInt(ref[poundIndex+1:], 10, 64)
 | |
| 	if err != nil {
 | |
| 		return nil, nil
 | |
| 	}
 | |
| 
 | |
| 	issue, err := GetIssueByIndex(refRepo.ID, int64(issueIndex))
 | |
| 	if err != nil {
 | |
| 		if IsErrIssueNotExist(err) {
 | |
| 			return nil, nil
 | |
| 		}
 | |
| 		return nil, err
 | |
| 	}
 | |
| 	return issue, nil
 | |
| }
 | |
| 
 | |
| // UpdateIssuesCommit checks if issues are manipulated by commit message.
 | |
| func UpdateIssuesCommit(doer *User, repo *Repository, commits []*PushCommit) error {
 | |
| 	// Commits are appended in the reverse order.
 | |
| 	for i := len(commits) - 1; i >= 0; i-- {
 | |
| 		c := commits[i]
 | |
| 
 | |
| 		refMarked := make(map[int64]bool)
 | |
| 		for _, ref := range issueReferenceKeywordsPat.FindAllString(c.Message, -1) {
 | |
| 			issue, err := getIssueFromRef(repo, ref)
 | |
| 			if err != nil {
 | |
| 				return err
 | |
| 			}
 | |
| 
 | |
| 			if issue == nil || refMarked[issue.ID] {
 | |
| 				continue
 | |
| 			}
 | |
| 			refMarked[issue.ID] = true
 | |
| 
 | |
| 			message := fmt.Sprintf(`<a href="%s/commit/%s">%s</a>`, repo.Link(), c.Sha1, c.Message)
 | |
| 			if err = CreateRefComment(doer, repo, issue, message, c.Sha1); err != nil {
 | |
| 				return err
 | |
| 			}
 | |
| 		}
 | |
| 
 | |
| 		refMarked = make(map[int64]bool)
 | |
| 		// FIXME: can merge this one and next one to a common function.
 | |
| 		for _, ref := range issueCloseKeywordsPat.FindAllString(c.Message, -1) {
 | |
| 			issue, err := getIssueFromRef(repo, ref)
 | |
| 			if err != nil {
 | |
| 				return err
 | |
| 			}
 | |
| 
 | |
| 			if issue == nil || refMarked[issue.ID] {
 | |
| 				continue
 | |
| 			}
 | |
| 			refMarked[issue.ID] = true
 | |
| 
 | |
| 			if issue.RepoID != repo.ID || issue.IsClosed {
 | |
| 				continue
 | |
| 			}
 | |
| 
 | |
| 			if err = issue.ChangeStatus(doer, repo, true); err != nil {
 | |
| 				// Don't return an error when dependencies are open as this would let the push fail
 | |
| 				if IsErrDependenciesLeft(err) {
 | |
| 					return nil
 | |
| 				}
 | |
| 				return err
 | |
| 			}
 | |
| 		}
 | |
| 
 | |
| 		// It is conflict to have close and reopen at same time, so refsMarked doesn't need to reinit here.
 | |
| 		for _, ref := range issueReopenKeywordsPat.FindAllString(c.Message, -1) {
 | |
| 			issue, err := getIssueFromRef(repo, ref)
 | |
| 			if err != nil {
 | |
| 				return err
 | |
| 			}
 | |
| 
 | |
| 			if issue == nil || refMarked[issue.ID] {
 | |
| 				continue
 | |
| 			}
 | |
| 			refMarked[issue.ID] = true
 | |
| 
 | |
| 			if issue.RepoID != repo.ID || !issue.IsClosed {
 | |
| 				continue
 | |
| 			}
 | |
| 
 | |
| 			if err = issue.ChangeStatus(doer, repo, false); err != nil {
 | |
| 				return err
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| // CommitRepoActionOptions represent options of a new commit action.
 | |
| type CommitRepoActionOptions struct {
 | |
| 	PusherName  string
 | |
| 	RepoOwnerID int64
 | |
| 	RepoName    string
 | |
| 	RefFullName string
 | |
| 	OldCommitID string
 | |
| 	NewCommitID string
 | |
| 	Commits     *PushCommits
 | |
| }
 | |
| 
 | |
| // CommitRepoAction adds new commit action to the repository, and prepare
 | |
| // corresponding webhooks.
 | |
| func CommitRepoAction(opts CommitRepoActionOptions) error {
 | |
| 	pusher, err := GetUserByName(opts.PusherName)
 | |
| 	if err != nil {
 | |
| 		return fmt.Errorf("GetUserByName [%s]: %v", opts.PusherName, err)
 | |
| 	}
 | |
| 
 | |
| 	repo, err := GetRepositoryByName(opts.RepoOwnerID, opts.RepoName)
 | |
| 	if err != nil {
 | |
| 		return fmt.Errorf("GetRepositoryByName [owner_id: %d, name: %s]: %v", opts.RepoOwnerID, opts.RepoName, err)
 | |
| 	}
 | |
| 
 | |
| 	refName := git.RefEndName(opts.RefFullName)
 | |
| 	if repo.IsBare && refName != repo.DefaultBranch {
 | |
| 		repo.DefaultBranch = refName
 | |
| 	}
 | |
| 
 | |
| 	// Change repository bare status and update last updated time.
 | |
| 	repo.IsBare = repo.IsBare && opts.Commits.Len <= 0
 | |
| 	if err = UpdateRepository(repo, false); err != nil {
 | |
| 		return fmt.Errorf("UpdateRepository: %v", err)
 | |
| 	}
 | |
| 
 | |
| 	isNewBranch := false
 | |
| 	opType := ActionCommitRepo
 | |
| 	// Check it's tag push or branch.
 | |
| 	if strings.HasPrefix(opts.RefFullName, git.TagPrefix) {
 | |
| 		opType = ActionPushTag
 | |
| 		if opts.NewCommitID == git.EmptySHA {
 | |
| 			opType = ActionDeleteTag
 | |
| 		}
 | |
| 		opts.Commits = &PushCommits{}
 | |
| 	} else if opts.NewCommitID == git.EmptySHA {
 | |
| 		opType = ActionDeleteBranch
 | |
| 		opts.Commits = &PushCommits{}
 | |
| 	} else {
 | |
| 		// if not the first commit, set the compare URL.
 | |
| 		if opts.OldCommitID == git.EmptySHA {
 | |
| 			isNewBranch = true
 | |
| 		} else {
 | |
| 			opts.Commits.CompareURL = repo.ComposeCompareURL(opts.OldCommitID, opts.NewCommitID)
 | |
| 		}
 | |
| 
 | |
| 		if err = UpdateIssuesCommit(pusher, repo, opts.Commits.Commits); err != nil {
 | |
| 			log.Error(4, "updateIssuesCommit: %v", err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if len(opts.Commits.Commits) > setting.UI.FeedMaxCommitNum {
 | |
| 		opts.Commits.Commits = opts.Commits.Commits[:setting.UI.FeedMaxCommitNum]
 | |
| 	}
 | |
| 
 | |
| 	data, err := json.Marshal(opts.Commits)
 | |
| 	if err != nil {
 | |
| 		return fmt.Errorf("Marshal: %v", err)
 | |
| 	}
 | |
| 
 | |
| 	if err = NotifyWatchers(&Action{
 | |
| 		ActUserID: pusher.ID,
 | |
| 		ActUser:   pusher,
 | |
| 		OpType:    opType,
 | |
| 		Content:   string(data),
 | |
| 		RepoID:    repo.ID,
 | |
| 		Repo:      repo,
 | |
| 		RefName:   refName,
 | |
| 		IsPrivate: repo.IsPrivate,
 | |
| 	}); err != nil {
 | |
| 		return fmt.Errorf("NotifyWatchers: %v", err)
 | |
| 	}
 | |
| 
 | |
| 	defer func() {
 | |
| 		go HookQueue.Add(repo.ID)
 | |
| 	}()
 | |
| 
 | |
| 	apiPusher := pusher.APIFormat()
 | |
| 	apiRepo := repo.APIFormat(AccessModeNone)
 | |
| 
 | |
| 	var shaSum string
 | |
| 	var isHookEventPush = false
 | |
| 	switch opType {
 | |
| 	case ActionCommitRepo: // Push
 | |
| 		isHookEventPush = true
 | |
| 
 | |
| 		if isNewBranch {
 | |
| 			gitRepo, err := git.OpenRepository(repo.RepoPath())
 | |
| 			if err != nil {
 | |
| 				log.Error(4, "OpenRepository[%s]: %v", repo.RepoPath(), err)
 | |
| 			}
 | |
| 
 | |
| 			shaSum, err = gitRepo.GetBranchCommitID(refName)
 | |
| 			if err != nil {
 | |
| 				log.Error(4, "GetBranchCommitID[%s]: %v", opts.RefFullName, err)
 | |
| 			}
 | |
| 			if err = PrepareWebhooks(repo, HookEventCreate, &api.CreatePayload{
 | |
| 				Ref:     refName,
 | |
| 				Sha:     shaSum,
 | |
| 				RefType: "branch",
 | |
| 				Repo:    apiRepo,
 | |
| 				Sender:  apiPusher,
 | |
| 			}); err != nil {
 | |
| 				return fmt.Errorf("PrepareWebhooks: %v", err)
 | |
| 			}
 | |
| 		}
 | |
| 
 | |
| 	case ActionDeleteBranch: // Delete Branch
 | |
| 		isHookEventPush = true
 | |
| 
 | |
| 		if err = PrepareWebhooks(repo, HookEventDelete, &api.DeletePayload{
 | |
| 			Ref:        refName,
 | |
| 			RefType:    "branch",
 | |
| 			PusherType: api.PusherTypeUser,
 | |
| 			Repo:       apiRepo,
 | |
| 			Sender:     apiPusher,
 | |
| 		}); err != nil {
 | |
| 			return fmt.Errorf("PrepareWebhooks.(delete branch): %v", err)
 | |
| 		}
 | |
| 
 | |
| 	case ActionPushTag: // Create
 | |
| 		isHookEventPush = true
 | |
| 
 | |
| 		gitRepo, err := git.OpenRepository(repo.RepoPath())
 | |
| 		if err != nil {
 | |
| 			log.Error(4, "OpenRepository[%s]: %v", repo.RepoPath(), err)
 | |
| 		}
 | |
| 		shaSum, err = gitRepo.GetTagCommitID(refName)
 | |
| 		if err != nil {
 | |
| 			log.Error(4, "GetTagCommitID[%s]: %v", opts.RefFullName, err)
 | |
| 		}
 | |
| 		if err = PrepareWebhooks(repo, HookEventCreate, &api.CreatePayload{
 | |
| 			Ref:     refName,
 | |
| 			Sha:     shaSum,
 | |
| 			RefType: "tag",
 | |
| 			Repo:    apiRepo,
 | |
| 			Sender:  apiPusher,
 | |
| 		}); err != nil {
 | |
| 			return fmt.Errorf("PrepareWebhooks: %v", err)
 | |
| 		}
 | |
| 	case ActionDeleteTag: // Delete Tag
 | |
| 		isHookEventPush = true
 | |
| 
 | |
| 		if err = PrepareWebhooks(repo, HookEventDelete, &api.DeletePayload{
 | |
| 			Ref:        refName,
 | |
| 			RefType:    "tag",
 | |
| 			PusherType: api.PusherTypeUser,
 | |
| 			Repo:       apiRepo,
 | |
| 			Sender:     apiPusher,
 | |
| 		}); err != nil {
 | |
| 			return fmt.Errorf("PrepareWebhooks.(delete tag): %v", err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if isHookEventPush {
 | |
| 		if err = PrepareWebhooks(repo, HookEventPush, &api.PushPayload{
 | |
| 			Ref:        opts.RefFullName,
 | |
| 			Before:     opts.OldCommitID,
 | |
| 			After:      opts.NewCommitID,
 | |
| 			CompareURL: setting.AppURL + opts.Commits.CompareURL,
 | |
| 			Commits:    opts.Commits.ToAPIPayloadCommits(repo.HTMLURL()),
 | |
| 			Repo:       apiRepo,
 | |
| 			Pusher:     apiPusher,
 | |
| 			Sender:     apiPusher,
 | |
| 		}); err != nil {
 | |
| 			return fmt.Errorf("PrepareWebhooks: %v", err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| func transferRepoAction(e Engine, doer, oldOwner *User, repo *Repository) (err error) {
 | |
| 	if err = notifyWatchers(e, &Action{
 | |
| 		ActUserID: doer.ID,
 | |
| 		ActUser:   doer,
 | |
| 		OpType:    ActionTransferRepo,
 | |
| 		RepoID:    repo.ID,
 | |
| 		Repo:      repo,
 | |
| 		IsPrivate: repo.IsPrivate,
 | |
| 		Content:   path.Join(oldOwner.Name, repo.Name),
 | |
| 	}); err != nil {
 | |
| 		return fmt.Errorf("notifyWatchers: %v", err)
 | |
| 	}
 | |
| 
 | |
| 	// Remove watch for organization.
 | |
| 	if oldOwner.IsOrganization() {
 | |
| 		if err = watchRepo(e, oldOwner.ID, repo.ID, false); err != nil {
 | |
| 			return fmt.Errorf("watchRepo [false]: %v", err)
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	return nil
 | |
| }
 | |
| 
 | |
| // TransferRepoAction adds new action for transferring repository,
 | |
| // the Owner field of repository is assumed to be new owner.
 | |
| func TransferRepoAction(doer, oldOwner *User, repo *Repository) error {
 | |
| 	return transferRepoAction(x, doer, oldOwner, repo)
 | |
| }
 | |
| 
 | |
| func mergePullRequestAction(e Engine, doer *User, repo *Repository, issue *Issue) error {
 | |
| 	return notifyWatchers(e, &Action{
 | |
| 		ActUserID: doer.ID,
 | |
| 		ActUser:   doer,
 | |
| 		OpType:    ActionMergePullRequest,
 | |
| 		Content:   fmt.Sprintf("%d|%s", issue.Index, issue.Title),
 | |
| 		RepoID:    repo.ID,
 | |
| 		Repo:      repo,
 | |
| 		IsPrivate: repo.IsPrivate,
 | |
| 	})
 | |
| }
 | |
| 
 | |
| // MergePullRequestAction adds new action for merging pull request.
 | |
| func MergePullRequestAction(actUser *User, repo *Repository, pull *Issue) error {
 | |
| 	return mergePullRequestAction(x, actUser, repo, pull)
 | |
| }
 | |
| 
 | |
| // GetFeedsOptions options for retrieving feeds
 | |
| type GetFeedsOptions struct {
 | |
| 	RequestedUser    *User
 | |
| 	RequestingUserID int64
 | |
| 	IncludePrivate   bool // include private actions
 | |
| 	OnlyPerformedBy  bool // only actions performed by requested user
 | |
| 	IncludeDeleted   bool // include deleted actions
 | |
| }
 | |
| 
 | |
| // GetFeeds returns actions according to the provided options
 | |
| func GetFeeds(opts GetFeedsOptions) ([]*Action, error) {
 | |
| 	cond := builder.NewCond()
 | |
| 
 | |
| 	var repoIDs []int64
 | |
| 	if opts.RequestedUser.IsOrganization() {
 | |
| 		env, err := opts.RequestedUser.AccessibleReposEnv(opts.RequestingUserID)
 | |
| 		if err != nil {
 | |
| 			return nil, fmt.Errorf("AccessibleReposEnv: %v", err)
 | |
| 		}
 | |
| 		if repoIDs, err = env.RepoIDs(1, opts.RequestedUser.NumRepos); err != nil {
 | |
| 			return nil, fmt.Errorf("GetUserRepositories: %v", err)
 | |
| 		}
 | |
| 
 | |
| 		cond = cond.And(builder.In("repo_id", repoIDs))
 | |
| 	}
 | |
| 
 | |
| 	cond = cond.And(builder.Eq{"user_id": opts.RequestedUser.ID})
 | |
| 
 | |
| 	if opts.OnlyPerformedBy {
 | |
| 		cond = cond.And(builder.Eq{"act_user_id": opts.RequestedUser.ID})
 | |
| 	}
 | |
| 	if !opts.IncludePrivate {
 | |
| 		cond = cond.And(builder.Eq{"is_private": false})
 | |
| 	}
 | |
| 
 | |
| 	if !opts.IncludeDeleted {
 | |
| 		cond = cond.And(builder.Eq{"is_deleted": false})
 | |
| 	}
 | |
| 
 | |
| 	actions := make([]*Action, 0, 20)
 | |
| 
 | |
| 	if err := x.Limit(20).Desc("id").Where(cond).Find(&actions); err != nil {
 | |
| 		return nil, fmt.Errorf("Find: %v", err)
 | |
| 	}
 | |
| 
 | |
| 	if err := ActionList(actions).LoadAttributes(); err != nil {
 | |
| 		return nil, fmt.Errorf("LoadAttributes: %v", err)
 | |
| 	}
 | |
| 
 | |
| 	return actions, nil
 | |
| }
 |