2014-03-13 09:16:14 +04:00
// Copyright 2014 The Gogs Authors. All rights reserved.
2019-05-01 19:21:05 +03:00
// Copyright 2019 The Gitea Authors. All rights reserved.
2014-03-13 09:16:14 +04:00
// Use of this source code is governed by a MIT-style
// license that can be found in the LICENSE file.
package models
import (
2014-05-06 19:50:31 +04:00
"fmt"
2019-05-10 20:48:28 +03:00
"html"
2014-07-26 08:24:27 +04:00
"path"
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-03-22 14:20:00 +04:00
2016-11-10 19:24:48 +03:00
"code.gitea.io/gitea/modules/base"
2019-08-21 08:16:22 +03:00
"code.gitea.io/gitea/modules/git"
2016-11-10 19:24:48 +03:00
"code.gitea.io/gitea/modules/log"
2019-10-14 01:29:10 +03:00
"code.gitea.io/gitea/modules/references"
2016-11-10 19:24:48 +03:00
"code.gitea.io/gitea/modules/setting"
2019-05-11 13:21:34 +03:00
api "code.gitea.io/gitea/modules/structs"
2019-08-15 17:46:21 +03:00
"code.gitea.io/gitea/modules/timeutil"
2017-12-03 05:20:12 +03:00
2019-08-23 19:40:30 +03:00
"github.com/unknwon/com"
2019-06-23 18:22:43 +03:00
"xorm.io/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
2018-09-07 05:06:09 +03:00
ActionMirrorSyncPush // 18
ActionMirrorSyncCreate // 19
ActionMirrorSyncDelete // 20
2014-03-13 09:16:14 +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
2019-08-15 17:46:21 +03:00
IsPrivate bool ` xorm:"INDEX NOT NULL DEFAULT false" `
Content string ` xorm:"TEXT" `
CreatedUnix timeutil . 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 {
2019-04-02 10:48:31 +03:00
log . Error ( "GetUserByID(%d): %v" , a . ActUserID , err )
2017-05-26 04:38:18 +03:00
}
}
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 {
2019-04-02 10:48:31 +03:00
log . Error ( "GetRepositoryByID(%d): %v" , a . RepoID , err )
2017-05-26 04:38:18 +03:00
}
}
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
}
2019-05-08 11:41:35 +03:00
// GetDisplayName gets the action's display name based on DEFAULT_SHOW_FULL_NAME
func ( a * Action ) GetDisplayName ( ) string {
if setting . UI . DefaultShowFullName {
return a . GetActFullName ( )
}
return a . ShortActUserName ( )
}
// GetDisplayNameTitle gets the action's display name used for the title (tooltip) based on DEFAULT_SHOW_FULL_NAME
func ( a * Action ) GetDisplayNameTitle ( ) string {
if setting . UI . DefaultShowFullName {
return a . ShortActUserName ( )
}
return a . GetActFullName ( )
}
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
}
2019-05-01 19:21:05 +03:00
// GetRepositoryFromMatch returns a *Repository from a username and repo strings
func GetRepositoryFromMatch ( ownerName string , repoName string ) ( * Repository , error ) {
var err error
refRepo , err := GetRepositoryByOwnerAndName ( ownerName , repoName )
if err != nil {
if IsErrRepoNotExist ( err ) {
log . Warn ( "Repository referenced in commit but does not exist: %v" , err )
return nil , err
}
log . Error ( "GetRepositoryByOwnerAndName: %v" , err )
return nil , err
}
return refRepo , nil
}
2017-06-25 21:20:29 +03:00
// GetCommentLink returns link to action comment.
func ( a * Action ) GetCommentLink ( ) string {
2018-12-13 18:55:43 +03:00
return a . getCommentLink ( x )
}
func ( a * Action ) getCommentLink ( e Engine ) string {
2017-06-25 21:20:29 +03:00
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 "#"
}
2018-12-13 18:55:43 +03:00
issue , err := getIssueByID ( e , issueID )
2017-06-25 21:20:29 +03:00
if err != nil {
return "#"
}
2018-12-13 18:55:43 +03:00
if err = issue . loadRepo ( e ) ; err != nil {
return "#"
}
2017-06-25 21:20:29 +03:00
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 {
2019-04-02 10:48:31 +03:00
log . Error ( "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 {
2019-04-02 10:48:31 +03:00
log . Error ( "GetIssueByIndex: %v" , err )
2015-11-13 20:11:45 +03:00
return "500 when get issue"
}
return issue . Content
}
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
2018-12-13 18:55:43 +03:00
avatars map [ string ] string
emailUsers map [ string ] * User
2015-11-14 01:10:25 +03:00
}
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 {
2018-12-13 18:55:43 +03:00
avatars : make ( map [ string ] string ) ,
emailUsers : make ( map [ string ] * User ) ,
2015-11-14 01:10:25 +03:00
}
}
2016-11-22 13:43:30 +03:00
// ToAPIPayloadCommits converts a PushCommits object to
// api.PayloadCommit format.
2019-08-21 08:16:22 +03:00
func ( pc * PushCommits ) ToAPIPayloadCommits ( repoPath , repoLink string ) ( [ ] * api . PayloadCommit , error ) {
2015-12-10 04:46:05 +03:00
commits := make ( [ ] * api . PayloadCommit , len ( pc . Commits ) )
2018-12-13 18:55:43 +03:00
if pc . emailUsers == nil {
pc . emailUsers = make ( map [ string ] * User )
}
var err error
2016-08-10 04:28:06 +03:00
for i , commit := range pc . Commits {
authorUsername := ""
2018-12-13 18:55:43 +03:00
author , ok := pc . emailUsers [ commit . AuthorEmail ]
if ! ok {
author , err = GetUserByEmail ( commit . AuthorEmail )
if err == nil {
authorUsername = author . Name
pc . emailUsers [ commit . AuthorEmail ] = author
}
} else {
2016-08-10 04:28:06 +03:00
authorUsername = author . Name
2015-12-10 04:46:05 +03:00
}
2018-12-13 18:55:43 +03:00
2016-08-10 08:01:57 +03:00
committerUsername := ""
2018-12-13 18:55:43 +03:00
committer , ok := pc . emailUsers [ commit . CommitterEmail ]
if ! ok {
committer , err = GetUserByEmail ( commit . CommitterEmail )
if err == nil {
// TODO: check errors other than email not found.
committerUsername = committer . Name
pc . emailUsers [ commit . CommitterEmail ] = committer
}
} else {
2016-08-10 08:01:57 +03:00
committerUsername = committer . Name
}
2019-08-21 08:16:22 +03:00
fileStatus , err := git . GetCommitFileStatus ( repoPath , commit . Sha1 )
if err != nil {
return nil , fmt . Errorf ( "FileStatus [commit_sha1: %s]: %v" , commit . Sha1 , err )
}
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 ,
} ,
2019-08-21 08:16:22 +03:00
Added : fileStatus . Added ,
Removed : fileStatus . Removed ,
Modified : fileStatus . Modified ,
2016-08-10 04:28:06 +03:00
Timestamp : commit . Timestamp ,
2015-12-10 04:46:05 +03:00
}
}
2019-08-21 08:16:22 +03:00
return commits , nil
2015-12-10 04:46:05 +03:00
}
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 {
2019-07-30 04:59:10 +03:00
if pc . avatars == nil {
pc . avatars = make ( map [ string ] string )
}
2018-12-13 18:55:43 +03:00
avatar , ok := pc . avatars [ email ]
if ok {
return avatar
}
u , ok := pc . emailUsers [ email ]
2015-11-14 01:10:25 +03:00
if ! ok {
2018-12-13 18:55:43 +03:00
var err error
u , err = GetUserByEmail ( email )
2015-11-14 01:10:25 +03:00
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 ) {
2019-04-02 10:48:31 +03:00
log . Error ( "GetUserByEmail: %v" , err )
2018-12-13 18:55:43 +03:00
return ""
2015-11-14 01:10:25 +03:00
}
} else {
2018-12-13 18:55:43 +03:00
pc . emailUsers [ email ] = u
2015-11-14 01:10:25 +03:00
}
}
2018-12-13 18:55:43 +03:00
if u != nil {
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
2019-10-14 01:29:10 +03:00
// if the provided ref references a non-existent issue.
func getIssueFromRef ( repo * Repository , index int64 ) ( * Issue , error ) {
issue , err := GetIssueByIndex ( repo . ID , index )
2017-12-03 05:20:12 +03:00
if err != nil {
if IsErrIssueNotExist ( err ) {
return nil , nil
}
return nil , err
}
return issue , nil
}
2019-10-14 01:29:10 +03:00
func changeIssueStatus ( repo * Repository , issue * Issue , doer * User , status bool ) error {
2019-01-04 12:22:58 +03:00
2019-02-05 14:38:11 +03:00
stopTimerIfAvailable := func ( doer * User , issue * Issue ) error {
if StopwatchExists ( doer . ID , issue . ID ) {
if err := CreateOrStopIssueStopwatch ( doer , issue ) ; err != nil {
return err
}
}
return nil
}
2019-01-04 12:22:58 +03:00
issue . Repo = repo
2019-10-14 01:29:10 +03:00
if err := issue . ChangeStatus ( doer , status ) ; err != nil {
2019-01-04 12:22:58 +03:00
// Don't return an error when dependencies are open as this would let the push fail
if IsErrDependenciesLeft ( err ) {
2019-02-05 14:38:11 +03:00
return stopTimerIfAvailable ( doer , issue )
2019-01-04 12:22:58 +03:00
}
return err
}
2019-02-05 14:38:11 +03:00
return stopTimerIfAvailable ( doer , issue )
2019-01-04 12:22:58 +03:00
}
2016-08-17 09:06:38 +03:00
// UpdateIssuesCommit checks if issues are manipulated by commit message.
2019-01-04 12:22:58 +03:00
func UpdateIssuesCommit ( doer * User , repo * Repository , commits [ ] * PushCommit , branchName string ) 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 ]
2019-10-14 01:29:10 +03:00
type markKey struct {
ID int64
Action references . XRefAction
}
refMarked := make ( map [ markKey ] bool )
2019-05-01 19:21:05 +03:00
var refRepo * Repository
2019-10-14 01:29:10 +03:00
var refIssue * Issue
2019-05-01 19:21:05 +03:00
var err error
2019-10-14 01:29:10 +03:00
for _ , ref := range references . FindAllIssueReferences ( c . Message ) {
2019-05-01 19:21:05 +03:00
// issue is from another repo
2019-10-14 01:29:10 +03:00
if len ( ref . Owner ) > 0 && len ( ref . Name ) > 0 {
refRepo , err = GetRepositoryFromMatch ( ref . Owner , ref . Name )
2019-05-01 19:21:05 +03:00
if err != nil {
continue
}
} else {
refRepo = repo
}
2019-10-14 01:29:10 +03:00
if refIssue , err = getIssueFromRef ( refRepo , ref . Index ) ; err != nil {
2014-07-23 15:48:06 +04:00
return err
}
2019-10-14 01:29:10 +03:00
if refIssue == nil {
2015-09-03 11:34:08 +03:00
continue
}
2019-10-14 01:29:10 +03:00
perm , err := GetUserRepoPermission ( refRepo , doer )
if err != nil {
2014-07-23 15:48:06 +04:00
return err
}
2015-02-02 18:34:07 +03:00
2019-10-14 01:29:10 +03:00
key := markKey { ID : refIssue . ID , Action : ref . Action }
if refMarked [ key ] {
2019-05-01 19:21:05 +03:00
continue
}
2019-10-14 01:29:10 +03:00
refMarked [ key ] = true
2019-05-01 19:21:05 +03:00
2019-10-14 01:29:10 +03:00
// only create comments for issues if user has permission for it
if perm . IsAdmin ( ) || perm . IsOwner ( ) || perm . CanWrite ( UnitTypeIssues ) {
message := fmt . Sprintf ( ` <a href="%s/commit/%s">%s</a> ` , repo . Link ( ) , c . Sha1 , html . EscapeString ( c . Message ) )
if err = CreateRefComment ( doer , refRepo , refIssue , message , c . Sha1 ) ; err != nil {
2019-05-01 19:21:05 +03:00
return err
}
}
2015-02-07 04:34:49 +03:00
2019-10-14 01:29:10 +03:00
// Process closing/reopening keywords
if ref . Action != references . XRefActionCloses && ref . Action != references . XRefActionReopens {
2019-05-01 19:21:05 +03:00
continue
}
2019-10-14 01:29:10 +03:00
// Change issue status only if the commit has been pushed to the default branch.
// and if the repo is configured to allow only that
// FIXME: we should be using Issue.ref if set instead of repo.DefaultBranch
if repo . DefaultBranch != branchName && ! repo . CloseIssuesViaCommitInAnyBranch {
continue
2015-02-07 04:47:21 +03:00
}
2019-05-01 19:21:05 +03:00
2019-10-14 01:29:10 +03:00
// only close issues in another repo if user has push access
if perm . IsAdmin ( ) || perm . IsOwner ( ) || perm . CanWrite ( UnitTypeCode ) {
if err := changeIssueStatus ( refRepo , refIssue , doer , ref . Action == references . XRefActionCloses ) ; err != nil {
2019-05-01 19:21:05 +03:00
return err
}
}
2015-02-07 04:47:21 +03:00
}
}
2014-07-23 15:48:06 +04:00
return nil
}
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
}