2014-03-13 09:16:14 +04:00
// 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 (
2014-03-16 19:02:59 +04:00
"encoding/json"
2014-05-06 19:50:31 +04:00
"fmt"
2014-07-26 08:24:27 +04:00
"path"
2014-07-23 15:48:06 +04:00
"regexp"
2017-06-25 21:20:29 +03:00
"strconv"
2014-04-14 06:20:28 +04:00
"strings"
2014-03-13 09:16:14 +04:00
"time"
2014-07-24 12:15:05 +04:00
"unicode"
2014-03-22 14:20:00 +04:00
2016-11-10 19:24:48 +03:00
"code.gitea.io/git"
"code.gitea.io/gitea/modules/base"
"code.gitea.io/gitea/modules/log"
"code.gitea.io/gitea/modules/setting"
2017-12-11 07:37:04 +03:00
"code.gitea.io/gitea/modules/util"
2017-12-03 05:20:12 +03:00
api "code.gitea.io/sdk/gitea"
"github.com/Unknwon/com"
"github.com/go-xorm/builder"
2014-03-13 09:16:14 +04:00
)
2016-11-22 13:43:30 +03:00
// ActionType represents the type of an action.
2014-07-26 08:24:27 +04:00
type ActionType int
2016-11-22 13:43:30 +03:00
// Possible action types.
2014-03-13 09:16:14 +04:00
const (
2016-11-10 18:16:32 +03:00
ActionCreateRepo ActionType = iota + 1 // 1
ActionRenameRepo // 2
ActionStarRepo // 3
ActionWatchRepo // 4
ActionCommitRepo // 5
ActionCreateIssue // 6
2016-11-07 18:37:32 +03:00
ActionCreatePullRequest // 7
2016-11-10 18:16:32 +03:00
ActionTransferRepo // 8
ActionPushTag // 9
ActionCommentIssue // 10
2016-11-07 18:37:32 +03:00
ActionMergePullRequest // 11
2016-11-10 18:16:32 +03:00
ActionCloseIssue // 12
ActionReopenIssue // 13
2016-11-07 18:37:32 +03:00
ActionClosePullRequest // 14
ActionReopenPullRequest // 15
2017-09-21 10:43:26 +03:00
ActionDeleteTag // 16
ActionDeleteBranch // 17
2014-03-13 09:16:14 +04:00
)
2014-07-23 15:48:06 +04:00
var (
2016-11-22 13:43:30 +03:00
// 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" }
2015-02-07 04:47:21 +03:00
2016-11-22 13:43:30 +03:00
issueCloseKeywordsPat , issueReopenKeywordsPat * regexp . Regexp
issueReferenceKeywordsPat * regexp . Regexp
2014-07-23 15:48:06 +04:00
)
2017-12-03 05:20:12 +03:00
const issueRefRegexpStr = ` (?:\S+/\S=)?#\d+ `
2015-02-07 04:47:21 +03:00
func assembleKeywordsPattern ( words [ ] string ) string {
2017-12-03 05:20:12 +03:00
return fmt . Sprintf ( ` (?i)(?:%s) %s ` , strings . Join ( words , "|" ) , issueRefRegexpStr )
2015-02-07 04:47:21 +03:00
}
2014-07-23 15:48:06 +04:00
func init ( ) {
2016-11-22 13:43:30 +03:00
issueCloseKeywordsPat = regexp . MustCompile ( assembleKeywordsPattern ( issueCloseKeywords ) )
issueReopenKeywordsPat = regexp . MustCompile ( assembleKeywordsPattern ( issueReopenKeywords ) )
2017-12-03 05:20:12 +03:00
issueReferenceKeywordsPat = regexp . MustCompile ( issueRefRegexpStr )
2014-07-23 15:48:06 +04:00
}
2016-11-22 13:43:30 +03:00
// Action represents user operation type and other information to
// repository. It implemented interface base.Actioner so that can be
// used in template render.
2014-03-13 09:16:14 +04:00
type Action struct {
2017-05-26 04:38:18 +03:00
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:"-" `
2017-06-25 21:20:29 +03:00
CommentID int64 ` xorm:"INDEX" `
Comment * Comment ` xorm:"-" `
IsDeleted bool ` xorm:"INDEX NOT NULL DEFAULT false" `
2017-05-26 04:38:18 +03:00
RefName string
2017-12-11 07:37:04 +03:00
IsPrivate bool ` xorm:"INDEX NOT NULL DEFAULT false" `
Content string ` xorm:"TEXT" `
CreatedUnix util . TimeStamp ` xorm:"INDEX created" `
2015-08-19 19:12:43 +03:00
}
2016-11-22 13:43:30 +03:00
// GetOpType gets the ActionType of this action.
2017-09-20 04:22:42 +03:00
func ( a * Action ) GetOpType ( ) ActionType {
return a . OpType
2014-03-15 08:50:51 +04:00
}
2017-05-26 04:38:18 +03:00
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 ( ) {
2017-06-14 03:37:50 +03:00
if a . Repo != nil {
2017-05-26 04:38:18 +03:00
return
}
var err error
a . Repo , err = GetRepositoryByID ( a . RepoID )
if err != nil {
log . Error ( 4 , "GetRepositoryByID(%d): %v" , a . RepoID , err )
}
}
2018-07-05 20:48:18 +03:00
// GetActFullName gets the action's user full name.
func ( a * Action ) GetActFullName ( ) string {
a . loadActUser ( )
return a . ActUser . FullName
}
2016-11-22 13:43:30 +03:00
// GetActUserName gets the action's user name.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetActUserName ( ) string {
2017-05-26 04:38:18 +03:00
a . loadActUser ( )
return a . ActUser . Name
2014-03-15 08:50:51 +04:00
}
2016-11-22 13:43:30 +03:00
// ShortActUserName gets the action's user name trimmed to max 20
// chars.
2016-01-11 15:41:43 +03:00
func ( a * Action ) ShortActUserName ( ) string {
2017-05-26 04:38:18 +03:00
return base . EllipsisString ( a . GetActUserName ( ) , 20 )
2016-01-11 15:41:43 +03:00
}
2017-05-27 06:34:11 +03:00
// GetActAvatar the action's user's avatar link
func ( a * Action ) GetActAvatar ( ) string {
a . loadActUser ( )
2017-10-31 11:08:23 +03:00
return a . ActUser . RelAvatarLink ( )
2017-05-27 06:34:11 +03:00
}
2016-11-22 13:43:30 +03:00
// GetRepoUserName returns the name of the action repository owner.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetRepoUserName ( ) string {
2017-05-26 04:38:18 +03:00
a . loadRepo ( )
return a . Repo . MustOwner ( ) . Name
2014-05-09 10:42:50 +04:00
}
2016-11-22 13:43:30 +03:00
// ShortRepoUserName returns the name of the action repository owner
// trimmed to max 20 chars.
2016-01-11 15:41:43 +03:00
func ( a * Action ) ShortRepoUserName ( ) string {
2017-05-26 04:38:18 +03:00
return base . EllipsisString ( a . GetRepoUserName ( ) , 20 )
2016-01-11 15:41:43 +03:00
}
2016-11-22 13:43:30 +03:00
// GetRepoName returns the name of the action repository.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetRepoName ( ) string {
2017-05-26 04:38:18 +03:00
a . loadRepo ( )
return a . Repo . Name
2014-03-13 09:16:14 +04:00
}
2016-11-22 13:43:30 +03:00
// ShortRepoName returns the name of the action repository
// trimmed to max 33 chars.
2016-01-11 15:41:43 +03:00
func ( a * Action ) ShortRepoName ( ) string {
2017-05-26 04:38:18 +03:00
return base . EllipsisString ( a . GetRepoName ( ) , 33 )
2016-01-11 15:41:43 +03:00
}
2016-11-22 13:43:30 +03:00
// GetRepoPath returns the virtual path to the action repository.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetRepoPath ( ) string {
2017-05-26 04:38:18 +03:00
return path . Join ( a . GetRepoUserName ( ) , a . GetRepoName ( ) )
2016-01-15 13:00:39 +03:00
}
2016-11-22 13:43:30 +03:00
// ShortRepoPath returns the virtual path to the action repository
2017-01-05 03:50:34 +03:00
// trimmed to max 20 + 1 + 33 chars.
2016-01-15 13:00:39 +03:00
func ( a * Action ) ShortRepoPath ( ) string {
2016-01-11 15:41:43 +03:00
return path . Join ( a . ShortRepoUserName ( ) , a . ShortRepoName ( ) )
2015-03-12 23:01:23 +03:00
}
2016-11-22 13:43:30 +03:00
// GetRepoLink returns relative link to action repository.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetRepoLink ( ) string {
2016-11-27 13:14:25 +03:00
if len ( setting . AppSubURL ) > 0 {
return path . Join ( setting . AppSubURL , a . GetRepoPath ( ) )
2015-03-12 23:01:23 +03:00
}
return "/" + a . GetRepoPath ( )
2014-07-26 08:24:27 +04:00
}
2017-06-25 21:20:29 +03:00
// 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 ( )
}
2016-11-22 13:43:30 +03:00
// GetBranch returns the action's repository branch.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetBranch ( ) string {
2014-03-23 14:27:01 +04:00
return a . RefName
2014-03-16 19:30:35 +04:00
}
2016-11-22 13:43:30 +03:00
// GetContent returns the action's content.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetContent ( ) string {
2014-03-23 14:27:01 +04:00
return a . Content
2014-03-23 14:00:09 +04:00
}
2016-11-22 13:43:30 +03:00
// GetCreate returns the action creation time.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetCreate ( ) time . Time {
2017-12-11 07:37:04 +03:00
return a . CreatedUnix . AsTime ( )
2014-07-26 08:24:27 +04:00
}
2016-11-22 13:43:30 +03:00
// GetIssueInfos returns a list of issues associated with
// the action.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetIssueInfos ( ) [ ] string {
2014-07-26 08:24:27 +04:00
return strings . SplitN ( a . Content , "|" , 2 )
}
2016-11-22 13:43:30 +03:00
// GetIssueTitle returns the title of first issue associated
// with the action.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetIssueTitle ( ) string {
2015-11-13 18:05:50 +03:00
index := com . StrTo ( a . GetIssueInfos ( ) [ 0 ] ) . MustInt64 ( )
issue , err := GetIssueByIndex ( a . RepoID , index )
2015-11-13 00:16:51 +03:00
if err != nil {
2015-11-13 18:05:50 +03:00
log . Error ( 4 , "GetIssueByIndex: %v" , err )
2015-11-13 20:11:45 +03:00
return "500 when get issue"
2015-11-13 00:16:51 +03:00
}
2016-08-14 13:32:24 +03:00
return issue . Title
2015-11-12 23:09:48 +03:00
}
2016-11-22 13:43:30 +03:00
// GetIssueContent returns the content of first issue associated with
// this action.
2016-01-11 15:41:43 +03:00
func ( a * Action ) GetIssueContent ( ) string {
2015-11-13 20:11:45 +03:00
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
}
2015-09-01 16:29:52 +03:00
func newRepoAction ( e Engine , u * User , repo * Repository ) ( err error ) {
if err = notifyWatchers ( e , & Action {
2017-05-26 04:38:18 +03:00
ActUserID : u . ID ,
ActUser : u ,
OpType : ActionCreateRepo ,
RepoID : repo . ID ,
Repo : repo ,
IsPrivate : repo . IsPrivate ,
2015-09-01 16:29:52 +03:00
} ) ; err != nil {
2016-07-23 20:08:22 +03:00
return fmt . Errorf ( "notify watchers '%d/%d': %v" , u . ID , repo . ID , err )
2015-09-01 16:29:52 +03:00
}
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 )
}
2015-09-01 18:43:53 +03:00
func renameRepoAction ( e Engine , actUser * User , oldRepoName string , repo * Repository ) ( err error ) {
if err = notifyWatchers ( e , & Action {
2017-05-26 04:38:18 +03:00
ActUserID : actUser . ID ,
ActUser : actUser ,
OpType : ActionRenameRepo ,
RepoID : repo . ID ,
Repo : repo ,
IsPrivate : repo . IsPrivate ,
Content : oldRepoName ,
2015-09-01 18:43:53 +03:00
} ) ; 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 )
}
2015-09-03 11:34:08 +03:00
func issueIndexTrimRight ( c rune ) bool {
return ! unicode . IsDigit ( c )
}
2016-11-22 13:43:30 +03:00
// PushCommit represents a commit in a push operation.
2015-11-14 01:10:25 +03:00
type PushCommit struct {
2016-08-10 08:01:57 +03:00
Sha1 string
Message string
AuthorEmail string
AuthorName string
CommitterEmail string
CommitterName string
Timestamp time . Time
2015-11-14 01:10:25 +03:00
}
2016-11-22 13:43:30 +03:00
// PushCommits represents list of commits in a push operation.
2015-11-14 01:10:25 +03:00
type PushCommits struct {
Len int
Commits [ ] * PushCommit
2016-08-14 14:17:26 +03:00
CompareURL string
2015-11-14 01:10:25 +03:00
avatars map [ string ] string
}
2016-11-22 13:43:30 +03:00
// NewPushCommits creates a new PushCommits object.
2015-11-14 01:10:25 +03:00
func NewPushCommits ( ) * PushCommits {
return & PushCommits {
avatars : make ( map [ string ] string ) ,
}
}
2016-11-22 13:43:30 +03:00
// ToAPIPayloadCommits converts a PushCommits object to
// api.PayloadCommit format.
func ( pc * PushCommits ) ToAPIPayloadCommits ( repoLink string ) [ ] * api . PayloadCommit {
2015-12-10 04:46:05 +03:00
commits := make ( [ ] * api . PayloadCommit , len ( pc . Commits ) )
2016-08-10 04:28:06 +03:00
for i , commit := range pc . Commits {
authorUsername := ""
author , err := GetUserByEmail ( commit . AuthorEmail )
2015-12-10 04:46:05 +03:00
if err == nil {
2016-08-10 04:28:06 +03:00
authorUsername = author . Name
2015-12-10 04:46:05 +03:00
}
2016-08-10 08:01:57 +03:00
committerUsername := ""
committer , err := GetUserByEmail ( commit . CommitterEmail )
if err == nil {
// TODO: check errors other than email not found.
committerUsername = committer . Name
}
2015-12-10 04:46:05 +03:00
commits [ i ] = & api . PayloadCommit {
2016-08-10 04:28:06 +03:00
ID : commit . Sha1 ,
Message : commit . Message ,
URL : fmt . Sprintf ( "%s/commit/%s" , repoLink , commit . Sha1 ) ,
2016-08-14 14:17:26 +03:00
Author : & api . PayloadUser {
2016-08-10 04:28:06 +03:00
Name : commit . AuthorName ,
Email : commit . AuthorEmail ,
UserName : authorUsername ,
2015-12-10 04:46:05 +03:00
} ,
2016-08-14 14:17:26 +03:00
Committer : & api . PayloadUser {
2016-08-10 08:01:57 +03:00
Name : commit . CommitterName ,
Email : commit . CommitterEmail ,
UserName : committerUsername ,
} ,
2016-08-10 04:28:06 +03:00
Timestamp : commit . Timestamp ,
2015-12-10 04:46:05 +03:00
}
}
return commits
}
2015-11-14 01:10:25 +03:00
// AvatarLink tries to match user in database with e-mail
// in order to show custom avatar, and falls back to general avatar link.
2016-11-22 13:43:30 +03:00
func ( pc * PushCommits ) AvatarLink ( email string ) string {
_ , ok := pc . avatars [ email ]
2015-11-14 01:10:25 +03:00
if ! ok {
u , err := GetUserByEmail ( email )
if err != nil {
2016-11-22 13:43:30 +03:00
pc . avatars [ email ] = base . AvatarLink ( email )
2015-11-14 01:10:25 +03:00
if ! IsErrUserNotExist ( err ) {
log . Error ( 4 , "GetUserByEmail: %v" , err )
}
} else {
2016-11-22 13:43:30 +03:00
pc . avatars [ email ] = u . RelAvatarLink ( )
2015-11-14 01:10:25 +03:00
}
}
2016-11-22 13:43:30 +03:00
return pc . avatars [ email ]
2015-11-14 01:10:25 +03:00
}
2017-12-03 05:20:12 +03:00
// 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
}
2016-08-17 09:06:38 +03:00
// UpdateIssuesCommit checks if issues are manipulated by commit message.
func UpdateIssuesCommit ( doer * User , repo * Repository , commits [ ] * PushCommit ) error {
2015-09-26 03:35:56 +03:00
// Commits are appended in the reverse order.
for i := len ( commits ) - 1 ; i >= 0 ; i -- {
c := commits [ i ]
2015-09-03 11:34:08 +03:00
refMarked := make ( map [ int64 ] bool )
2016-11-22 13:43:30 +03:00
for _ , ref := range issueReferenceKeywordsPat . FindAllString ( c . Message , - 1 ) {
2017-12-03 05:20:12 +03:00
issue , err := getIssueFromRef ( repo , ref )
2014-07-23 15:48:06 +04:00
if err != nil {
return err
}
2017-12-03 05:20:12 +03:00
if issue == nil || refMarked [ issue . ID ] {
2015-09-03 11:34:08 +03:00
continue
}
refMarked [ issue . ID ] = true
2016-08-17 09:06:38 +03:00
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 {
2014-07-23 15:48:06 +04:00
return err
}
2015-02-02 18:34:07 +03:00
}
2015-09-03 11:34:08 +03:00
refMarked = make ( map [ int64 ] bool )
2015-09-03 11:44:20 +03:00
// FIXME: can merge this one and next one to a common function.
2016-11-22 13:43:30 +03:00
for _ , ref := range issueCloseKeywordsPat . FindAllString ( c . Message , - 1 ) {
2017-12-03 05:20:12 +03:00
issue , err := getIssueFromRef ( repo , ref )
2015-02-02 18:34:07 +03:00
if err != nil {
return err
}
2014-07-23 15:48:06 +04:00
2017-12-03 05:20:12 +03:00
if issue == nil || refMarked [ issue . ID ] {
2015-09-03 11:34:08 +03:00
continue
}
refMarked [ issue . ID ] = true
if issue . RepoID != repo . ID || issue . IsClosed {
continue
}
2016-08-17 09:06:38 +03:00
if err = issue . ChangeStatus ( doer , repo , true ) ; err != nil {
2018-07-18 00:23:58 +03:00
// Don't return an error when dependencies are open as this would let the push fail
if IsErrDependenciesLeft ( err ) {
return nil
}
2015-09-03 11:34:08 +03:00
return err
2014-07-23 15:48:06 +04:00
}
}
2015-02-07 04:34:49 +03:00
2017-01-05 03:50:34 +03:00
// It is conflict to have close and reopen at same time, so refsMarked doesn't need to reinit here.
2016-11-22 13:43:30 +03:00
for _ , ref := range issueReopenKeywordsPat . FindAllString ( c . Message , - 1 ) {
2017-12-03 05:20:12 +03:00
issue , err := getIssueFromRef ( repo , ref )
2015-02-07 04:47:21 +03:00
if err != nil {
return err
}
2017-12-03 05:20:12 +03:00
if issue == nil || refMarked [ issue . ID ] {
2015-09-03 11:34:08 +03:00
continue
}
refMarked [ issue . ID ] = true
if issue . RepoID != repo . ID || ! issue . IsClosed {
continue
}
2016-08-17 09:06:38 +03:00
if err = issue . ChangeStatus ( doer , repo , false ) ; err != nil {
2015-09-03 11:34:08 +03:00
return err
2015-02-07 04:47:21 +03:00
}
}
}
2014-07-23 15:48:06 +04:00
return nil
}
2016-11-22 13:43:30 +03:00
// CommitRepoActionOptions represent options of a new commit action.
2016-08-17 09:06:38 +03:00
type CommitRepoActionOptions struct {
PusherName string
RepoOwnerID int64
RepoName string
RefFullName string
OldCommitID string
NewCommitID string
Commits * PushCommits
}
2015-08-28 18:36:13 +03:00
2016-11-22 13:43:30 +03:00
// CommitRepoAction adds new commit action to the repository, and prepare
// corresponding webhooks.
2016-08-17 09:06:38 +03:00
func CommitRepoAction ( opts CommitRepoActionOptions ) error {
pusher , err := GetUserByName ( opts . PusherName )
2015-08-28 18:36:13 +03:00
if err != nil {
2016-08-17 09:06:38 +03:00
return fmt . Errorf ( "GetUserByName [%s]: %v" , opts . PusherName , err )
2015-08-28 18:36:13 +03:00
}
2016-08-17 09:06:38 +03:00
repo , err := GetRepositoryByName ( opts . RepoOwnerID , opts . RepoName )
2015-08-28 18:36:13 +03:00
if err != nil {
2016-08-17 09:06:38 +03:00
return fmt . Errorf ( "GetRepositoryByName [owner_id: %d, name: %s]: %v" , opts . RepoOwnerID , opts . RepoName , err )
2015-08-28 18:36:13 +03:00
}
2014-04-14 05:00:12 +04:00
2018-03-25 16:00:07 +03:00
refName := git . RefEndName ( opts . RefFullName )
if repo . IsBare && refName != repo . DefaultBranch {
repo . DefaultBranch = refName
}
2015-11-01 01:59:07 +03:00
// Change repository bare status and update last updated time.
2017-05-29 05:25:23 +03:00
repo . IsBare = repo . IsBare && opts . Commits . Len <= 0
2015-11-06 03:18:59 +03:00
if err = UpdateRepository ( repo , false ) ; err != nil {
return fmt . Errorf ( "UpdateRepository: %v" , err )
2015-11-01 01:59:07 +03:00
}
2015-08-28 18:36:13 +03:00
isNewBranch := false
2016-11-07 18:37:32 +03:00
opType := ActionCommitRepo
2014-04-14 05:00:12 +04:00
// Check it's tag push or branch.
2016-12-22 12:30:52 +03:00
if strings . HasPrefix ( opts . RefFullName , git . TagPrefix ) {
2016-11-07 18:37:32 +03:00
opType = ActionPushTag
2017-09-21 10:43:26 +03:00
if opts . NewCommitID == git . EmptySHA {
opType = ActionDeleteTag
}
opts . Commits = & PushCommits { }
} else if opts . NewCommitID == git . EmptySHA {
opType = ActionDeleteBranch
2016-08-17 09:06:38 +03:00
opts . Commits = & PushCommits { }
2015-08-28 18:36:13 +03:00
} else {
2016-08-17 09:06:38 +03:00
// if not the first commit, set the compare URL.
2016-12-22 12:30:52 +03:00
if opts . OldCommitID == git . EmptySHA {
2015-08-28 18:36:13 +03:00
isNewBranch = true
2016-08-17 09:06:38 +03:00
} else {
opts . Commits . CompareURL = repo . ComposeCompareURL ( opts . OldCommitID , opts . NewCommitID )
2015-08-28 18:36:13 +03:00
}
2014-04-14 06:20:28 +04:00
2016-08-17 09:06:38 +03:00
if err = UpdateIssuesCommit ( pusher , repo , opts . Commits . Commits ) ; err != nil {
2015-09-26 04:06:31 +03:00
log . Error ( 4 , "updateIssuesCommit: %v" , err )
2015-08-28 18:36:13 +03:00
}
2014-10-11 05:40:51 +04:00
}
2014-03-24 17:32:24 +04:00
2016-08-17 09:06:38 +03:00
if len ( opts . Commits . Commits ) > setting . UI . FeedMaxCommitNum {
opts . Commits . Commits = opts . Commits . Commits [ : setting . UI . FeedMaxCommitNum ]
2015-09-26 03:35:56 +03:00
}
2016-08-17 09:06:38 +03:00
data , err := json . Marshal ( opts . Commits )
2014-03-16 19:02:59 +04:00
if err != nil {
2015-08-13 11:07:11 +03:00
return fmt . Errorf ( "Marshal: %v" , err )
2014-03-16 19:02:59 +04:00
}
2014-03-20 07:39:00 +04:00
2015-03-18 04:51:39 +03:00
if err = NotifyWatchers ( & Action {
2017-05-26 04:38:18 +03:00
ActUserID : pusher . ID ,
ActUser : pusher ,
OpType : opType ,
Content : string ( data ) ,
RepoID : repo . ID ,
Repo : repo ,
RefName : refName ,
IsPrivate : repo . IsPrivate ,
2015-03-18 04:51:39 +03:00
} ) ; err != nil {
2015-08-28 18:36:13 +03:00
return fmt . Errorf ( "NotifyWatchers: %v" , err )
2014-09-04 15:17:00 +04:00
}
2016-08-17 09:06:38 +03:00
defer func ( ) {
go HookQueue . Add ( repo . ID )
} ( )
2014-09-17 17:11:51 +04:00
2016-08-17 09:06:38 +03:00
apiPusher := pusher . APIFormat ( )
2016-12-06 02:48:51 +03:00
apiRepo := repo . APIFormat ( AccessModeNone )
2016-11-29 11:13:30 +03:00
var shaSum string
2017-09-21 10:43:26 +03:00
var isHookEventPush = false
2015-08-28 18:36:13 +03:00
switch opType {
2016-11-07 18:37:32 +03:00
case ActionCommitRepo : // Push
2017-09-21 10:43:26 +03:00
isHookEventPush = true
2014-05-06 19:50:31 +04:00
2015-08-28 18:36:13 +03:00
if isNewBranch {
2016-11-29 11:13:30 +03:00
gitRepo , err := git . OpenRepository ( repo . RepoPath ( ) )
if err != nil {
log . Error ( 4 , "OpenRepository[%s]: %v" , repo . RepoPath ( ) , err )
}
2017-09-21 10:43:26 +03:00
2016-12-13 10:19:42 +03:00
shaSum , err = gitRepo . GetBranchCommitID ( refName )
2016-11-29 11:13:30 +03:00
if err != nil {
log . Error ( 4 , "GetBranchCommitID[%s]: %v" , opts . RefFullName , err )
}
2017-09-21 10:43:26 +03:00
if err = PrepareWebhooks ( repo , HookEventCreate , & api . CreatePayload {
2015-08-28 18:36:13 +03:00
Ref : refName ,
2016-11-29 11:13:30 +03:00
Sha : shaSum ,
2015-08-28 18:36:13 +03:00
RefType : "branch" ,
2016-08-14 14:17:26 +03:00
Repo : apiRepo ,
Sender : apiPusher ,
2017-09-21 10:43:26 +03:00
} ) ; err != nil {
return fmt . Errorf ( "PrepareWebhooks: %v" , err )
}
2015-03-18 11:51:02 +03:00
}
2017-09-21 10:43:26 +03:00
case ActionDeleteBranch : // Delete Branch
isHookEventPush = true
2018-05-16 17:01:55 +03:00
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 )
}
2016-11-07 18:37:32 +03:00
case ActionPushTag : // Create
2017-09-21 10:43:26 +03:00
isHookEventPush = true
2016-11-29 11:13:30 +03:00
gitRepo , err := git . OpenRepository ( repo . RepoPath ( ) )
if err != nil {
log . Error ( 4 , "OpenRepository[%s]: %v" , repo . RepoPath ( ) , err )
}
2016-12-22 17:57:48 +03:00
shaSum , err = gitRepo . GetTagCommitID ( refName )
2016-11-29 11:13:30 +03:00
if err != nil {
log . Error ( 4 , "GetTagCommitID[%s]: %v" , opts . RefFullName , err )
}
2017-09-21 10:43:26 +03:00
if err = PrepareWebhooks ( repo , HookEventCreate , & api . CreatePayload {
2015-08-28 18:36:13 +03:00
Ref : refName ,
2016-11-29 09:58:01 +03:00
Sha : shaSum ,
2015-08-28 18:36:13 +03:00
RefType : "tag" ,
2016-08-14 14:17:26 +03:00
Repo : apiRepo ,
Sender : apiPusher ,
2017-09-21 10:43:26 +03:00
} ) ; err != nil {
return fmt . Errorf ( "PrepareWebhooks: %v" , err )
}
case ActionDeleteTag : // Delete Tag
isHookEventPush = true
2018-05-16 17:01:55 +03:00
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 )
}
2017-09-21 10:43:26 +03:00
}
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 )
}
2014-05-06 19:50:31 +04:00
}
2014-09-10 16:53:16 +04:00
2014-03-20 07:39:00 +04:00
return nil
2014-03-16 08:18:34 +04:00
}
2016-08-17 09:06:38 +03:00
func transferRepoAction ( e Engine , doer , oldOwner * User , repo * Repository ) ( err error ) {
2015-09-01 16:29:52 +03:00
if err = notifyWatchers ( e , & Action {
2017-05-26 04:38:18 +03:00
ActUserID : doer . ID ,
ActUser : doer ,
OpType : ActionTransferRepo ,
RepoID : repo . ID ,
Repo : repo ,
IsPrivate : repo . IsPrivate ,
Content : path . Join ( oldOwner . Name , repo . Name ) ,
2015-09-01 16:29:52 +03:00
} ) ; err != nil {
2016-08-17 09:06:38 +03:00
return fmt . Errorf ( "notifyWatchers: %v" , err )
2014-04-05 02:31:09 +04:00
}
2014-09-26 06:42:31 +04:00
// Remove watch for organization.
2016-08-17 09:06:38 +03:00
if oldOwner . IsOrganization ( ) {
if err = watchRepo ( e , oldOwner . ID , repo . ID , false ) ; err != nil {
return fmt . Errorf ( "watchRepo [false]: %v" , err )
2014-09-26 06:42:31 +04:00
}
}
2015-02-13 08:58:46 +03:00
return nil
}
2016-08-17 09:06:38 +03:00
// 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 )
2014-04-05 02:31:09 +04:00
}
2016-08-17 09:06:38 +03:00
func mergePullRequestAction ( e Engine , doer * User , repo * Repository , issue * Issue ) error {
2015-09-02 23:18:09 +03:00
return notifyWatchers ( e , & Action {
2017-05-26 04:38:18 +03:00
ActUserID : doer . ID ,
ActUser : doer ,
OpType : ActionMergePullRequest ,
Content : fmt . Sprintf ( "%d|%s" , issue . Index , issue . Title ) ,
RepoID : repo . ID ,
Repo : repo ,
IsPrivate : repo . IsPrivate ,
2015-09-02 23:18:09 +03:00
} )
}
// MergePullRequestAction adds new action for merging pull request.
func MergePullRequestAction ( actUser * User , repo * Repository , pull * Issue ) error {
return mergePullRequestAction ( x , actUser , repo , pull )
}
2017-06-02 03:42:25 +03:00
// 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
2017-06-25 21:20:29 +03:00
IncludeDeleted bool // include deleted actions
2017-06-02 03:42:25 +03:00
}
// GetFeeds returns actions according to the provided options
func GetFeeds ( opts GetFeedsOptions ) ( [ ] * Action , error ) {
2017-08-23 04:30:54 +03:00
cond := builder . NewCond ( )
2017-06-02 03:42:25 +03:00
var repoIDs [ ] int64
if opts . RequestedUser . IsOrganization ( ) {
env , err := opts . RequestedUser . AccessibleReposEnv ( opts . RequestingUserID )
2016-07-24 09:32:46 +03:00
if err != nil {
2017-01-25 18:41:38 +03:00
return nil , fmt . Errorf ( "AccessibleReposEnv: %v" , err )
2016-02-06 10:52:21 +03:00
}
2017-06-02 03:42:25 +03:00
if repoIDs , err = env . RepoIDs ( 1 , opts . RequestedUser . NumRepos ) ; err != nil {
2017-01-25 18:41:38 +03:00
return nil , fmt . Errorf ( "GetUserRepositories: %v" , err )
2016-02-06 10:52:21 +03:00
}
2017-08-23 04:30:54 +03:00
cond = cond . And ( builder . In ( "repo_id" , repoIDs ) )
}
2017-08-28 05:26:04 +03:00
cond = cond . And ( builder . Eq { "user_id" : opts . RequestedUser . ID } )
2016-02-06 10:52:21 +03:00
2017-06-02 03:42:25 +03:00
if opts . OnlyPerformedBy {
2017-08-23 04:30:54 +03:00
cond = cond . And ( builder . Eq { "act_user_id" : opts . RequestedUser . ID } )
2017-06-02 03:42:25 +03:00
}
if ! opts . IncludePrivate {
2017-08-23 04:30:54 +03:00
cond = cond . And ( builder . Eq { "is_private" : false } )
2017-06-02 03:42:25 +03:00
}
2017-06-25 21:20:29 +03:00
if ! opts . IncludeDeleted {
2017-08-23 04:30:54 +03:00
cond = cond . And ( builder . Eq { "is_deleted" : false } )
2017-06-25 21:20:29 +03:00
}
2017-08-23 04:30:54 +03:00
actions := make ( [ ] * Action , 0 , 20 )
2018-02-21 13:55:34 +03:00
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
2014-03-13 09:16:14 +04:00
}