forked from Shiloh/githaven
97 lines
2.7 KiB
Go
97 lines
2.7 KiB
Go
|
// Copyright 2020 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 migrations
|
||
|
|
|
||
|
|
import (
|
||
|
|
"fmt"
|
||
|
|
"path/filepath"
|
||
|
|
"strings"
|
||
|
|
|
||
|
|
"code.gitea.io/gitea/modules/git"
|
||
|
|
"code.gitea.io/gitea/modules/log"
|
||
|
|
"code.gitea.io/gitea/modules/setting"
|
||
|
|
|
||
|
|
"xorm.io/xorm"
|
||
|
|
)
|
||
|
|
|
||
|
|
func refixMergeBase(x *xorm.Engine) error {
|
||
|
|
type Repository struct {
|
||
|
|
ID int64 `xorm:"pk autoincr"`
|
||
|
|
OwnerID int64 `xorm:"UNIQUE(s) index"`
|
||
|
|
OwnerName string
|
||
|
|
LowerName string `xorm:"UNIQUE(s) INDEX NOT NULL"`
|
||
|
|
Name string `xorm:"INDEX NOT NULL"`
|
||
|
|
}
|
||
|
|
|
||
|
|
type PullRequest struct {
|
||
|
|
ID int64 `xorm:"pk autoincr"`
|
||
|
|
Index int64
|
||
|
|
HeadRepoID int64 `xorm:"INDEX"`
|
||
|
|
BaseRepoID int64 `xorm:"INDEX"`
|
||
|
|
HeadBranch string
|
||
|
|
BaseBranch string
|
||
|
|
MergeBase string `xorm:"VARCHAR(40)"`
|
||
|
|
|
||
|
|
HasMerged bool `xorm:"INDEX"`
|
||
|
|
MergedCommitID string `xorm:"VARCHAR(40)"`
|
||
|
|
}
|
||
|
|
|
||
|
|
var limit = setting.Database.IterateBufferSize
|
||
|
|
if limit <= 0 {
|
||
|
|
limit = 50
|
||
|
|
}
|
||
|
|
|
||
|
|
i := 0
|
||
|
|
for {
|
||
|
|
prs := make([]PullRequest, 0, 50)
|
||
|
|
if err := x.Limit(limit, i).Asc("id").Where("has_merged = ?", true).Find(&prs); err != nil {
|
||
|
|
return fmt.Errorf("Find: %v", err)
|
||
|
|
}
|
||
|
|
if len(prs) == 0 {
|
||
|
|
break
|
||
|
|
}
|
||
|
|
|
||
|
|
i += len(prs)
|
||
|
|
for _, pr := range prs {
|
||
|
|
baseRepo := &Repository{ID: pr.BaseRepoID}
|
||
|
|
has, err := x.Table("repository").Get(baseRepo)
|
||
|
|
if err != nil {
|
||
|
|
return fmt.Errorf("Unable to get base repo %d %v", pr.BaseRepoID, err)
|
||
|
|
}
|
||
|
|
if !has {
|
||
|
|
log.Error("Missing base repo with id %d for PR ID %d", pr.BaseRepoID, pr.ID)
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
userPath := filepath.Join(setting.RepoRootPath, strings.ToLower(baseRepo.OwnerName))
|
||
|
|
repoPath := filepath.Join(userPath, strings.ToLower(baseRepo.Name)+".git")
|
||
|
|
|
||
|
|
gitRefName := fmt.Sprintf("refs/pull/%d/head", pr.Index)
|
||
|
|
|
||
|
|
parentsString, err := git.NewCommand("rev-list", "--parents", "-n", "1", pr.MergedCommitID).RunInDir(repoPath)
|
||
|
|
if err != nil {
|
||
|
|
log.Error("Unable to get parents for merged PR ID %d, Index %d in %s/%s. Error: %v", pr.ID, pr.Index, baseRepo.OwnerName, baseRepo.Name, err)
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
parents := strings.Split(strings.TrimSpace(parentsString), " ")
|
||
|
|
if len(parents) < 3 {
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
|
||
|
|
// we should recalculate
|
||
|
|
args := append([]string{"merge-base", "--"}, parents[1:]...)
|
||
|
|
args = append(args, gitRefName)
|
||
|
|
|
||
|
|
pr.MergeBase, err = git.NewCommand(args...).RunInDir(repoPath)
|
||
|
|
if err != nil {
|
||
|
|
log.Error("Unable to get merge base for merged PR ID %d, Index %d in %s/%s. Error: %v", pr.ID, pr.Index, baseRepo.OwnerName, baseRepo.Name, err)
|
||
|
|
continue
|
||
|
|
}
|
||
|
|
pr.MergeBase = strings.TrimSpace(pr.MergeBase)
|
||
|
|
x.ID(pr.ID).Cols("merge_base").Update(pr)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|