@ -8,15 +8,47 @@ package pull
import (
import (
"code.gitea.io/gitea/models"
"code.gitea.io/gitea/models"
"code.gitea.io/gitea/modules/git"
"code.gitea.io/gitea/modules/git"
"code.gitea.io/gitea/modules/structs"
"github.com/pkg/errors"
"github.com/pkg/errors"
)
)
// MergeRequiredContextsCommitStatus returns a commit status state for given required contexts
func MergeRequiredContextsCommitStatus ( commitStatuses [ ] * models . CommitStatus , requiredContexts [ ] string ) structs . CommitStatusState {
if len ( requiredContexts ) == 0 {
status := models . CalcCommitStatus ( commitStatuses )
if status != nil {
return status . State
}
return structs . CommitStatusSuccess
}
var returnedStatus = structs . CommitStatusPending
for _ , ctx := range requiredContexts {
var targetStatus structs . CommitStatusState
for _ , commitStatus := range commitStatuses {
if commitStatus . Context == ctx {
targetStatus = commitStatus . State
break
}
}
if targetStatus == "" {
targetStatus = structs . CommitStatusPending
}
if targetStatus . NoBetterThan ( returnedStatus ) {
returnedStatus = targetStatus
}
}
return returnedStatus
}
// IsCommitStatusContextSuccess returns true if all required status check contexts succeed.
// IsCommitStatusContextSuccess returns true if all required status check contexts succeed.
func IsCommitStatusContextSuccess ( commitStatuses [ ] * models . CommitStatus , requiredContexts [ ] string ) bool {
func IsCommitStatusContextSuccess ( commitStatuses [ ] * models . CommitStatus , requiredContexts [ ] string ) bool {
// If no specific context is required, require that last commit status is a success
// If no specific context is required, require that last commit status is a success
if len ( requiredContexts ) == 0 {
if len ( requiredContexts ) == 0 {
status := models . CalcCommitStatus ( commitStatuses )
status := models . CalcCommitStatus ( commitStatuses )
if status == nil || status . State != models . CommitStatusSuccess {
if status == nil || status . State != struct s. CommitStatusSuccess {
return false
return false
}
}
return true
return true
@ -26,7 +58,7 @@ func IsCommitStatusContextSuccess(commitStatuses []*models.CommitStatus, require
var found bool
var found bool
for _ , commitStatus := range commitStatuses {
for _ , commitStatus := range commitStatuses {
if commitStatus . Context == ctx {
if commitStatus . Context == ctx {
if commitStatus . State != model s. CommitStatusSuccess {
if commitStatus . State != struct s. CommitStatusSuccess {
return false
return false
}
}
@ -50,30 +82,39 @@ func IsPullCommitStatusPass(pr *models.PullRequest) (bool, error) {
return true , nil
return true , nil
}
}
state , err := GetPullRequestCommitStatusState ( pr )
if err != nil {
return false , err
}
return state . IsSuccess ( ) , nil
}
// GetPullRequestCommitStatusState returns pull request merged commit status state
func GetPullRequestCommitStatusState ( pr * models . PullRequest ) ( structs . CommitStatusState , error ) {
// check if all required status checks are successful
// check if all required status checks are successful
headGitRepo , err := git . OpenRepository ( pr . HeadRepo . RepoPath ( ) )
headGitRepo , err := git . OpenRepository ( pr . HeadRepo . RepoPath ( ) )
if err != nil {
if err != nil {
return false , errors . Wrap ( err , "OpenRepository" )
return "" , errors . Wrap ( err , "OpenRepository" )
}
}
defer headGitRepo . Close ( )
defer headGitRepo . Close ( )
if ! headGitRepo . IsBranchExist ( pr . HeadBranch ) {
if ! headGitRepo . IsBranchExist ( pr . HeadBranch ) {
return false , errors . New ( "Head branch does not exist, can not merge" )
return "" , errors . New ( "Head branch does not exist, can not merge" )
}
}
sha , err := headGitRepo . GetBranchCommitID ( pr . HeadBranch )
sha , err := headGitRepo . GetBranchCommitID ( pr . HeadBranch )
if err != nil {
if err != nil {
return false , errors . Wrap ( err , "GetBranchCommitID" )
return "" , errors . Wrap ( err , "GetBranchCommitID" )
}
}
if err := pr . LoadBaseRepo ( ) ; err != nil {
if err := pr . LoadBaseRepo ( ) ; err != nil {
return false , errors . Wrap ( err , "LoadBaseRepo" )
return "" , errors . Wrap ( err , "LoadBaseRepo" )
}
}
commitStatuses , err := models . GetLatestCommitStatus ( pr . BaseRepo , sha , 0 )
commitStatuses , err := models . GetLatestCommitStatus ( pr . BaseRepo , sha , 0 )
if err != nil {
if err != nil {
return false , errors . Wrap ( err , "GetLatestCommitStatus" )
return "" , errors . Wrap ( err , "GetLatestCommitStatus" )
}
}
return IsCommitStatusContextSucces s( commitStatuses , pr . ProtectedBranch . StatusCheckContexts ) , nil
return MergeRequiredContextsCommitStatu s( commitStatuses , pr . ProtectedBranch . StatusCheckContexts ) , nil
}
}