summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorLunny Xiao <xiaolunwen@gmail.com>2019-05-18 10:37:49 +0800
committerGitHub <noreply@github.com>2019-05-18 10:37:49 +0800
commitc385dcc26b0da7fc1c245a1da316551cb6585ad3 (patch)
tree849ebbdf9ee3dbe2cf99842f26b1bf4ca7426172
parent96b412bb875f534e37b9af3d9e71842a2dadb6e0 (diff)
downloadgitea-c385dcc26b0da7fc1c245a1da316551cb6585ad3.tar.gz
gitea-c385dcc26b0da7fc1c245a1da316551cb6585ad3.zip
Fix index produces problem when issues/pulls deleted (#6973)
* fix index produces problem when issues/pulls deleted * fix tests * fix tests * fix tests
-rw-r--r--models/issue.go29
-rw-r--r--models/repo.go7
-rw-r--r--routers/api/v1/repo/pull.go8
-rw-r--r--routers/repo/pull.go8
4 files changed, 42 insertions, 10 deletions
diff --git a/models/issue.go b/models/issue.go
index f9394594be..999bd2f7a9 100644
--- a/models/issue.go
+++ b/models/issue.go
@@ -5,6 +5,7 @@
package models
import (
+ "errors"
"fmt"
"path"
"regexp"
@@ -1015,9 +1016,35 @@ type NewIssueOptions struct {
IsPull bool
}
+// GetMaxIndexOfIssue returns the max index on issue
+func GetMaxIndexOfIssue(repoID int64) (int64, error) {
+ return getMaxIndexOfIssue(x, repoID)
+}
+
+func getMaxIndexOfIssue(e Engine, repoID int64) (int64, error) {
+ var (
+ maxIndex int64
+ has bool
+ err error
+ )
+
+ has, err = e.SQL("SELECT COALESCE((SELECT MAX(`index`) FROM issue WHERE repo_id = ?),0)", repoID).Get(&maxIndex)
+ if err != nil {
+ return 0, err
+ } else if !has {
+ return 0, errors.New("Retrieve Max index from issue failed")
+ }
+ return maxIndex, nil
+}
+
func newIssue(e *xorm.Session, doer *User, opts NewIssueOptions) (err error) {
opts.Issue.Title = strings.TrimSpace(opts.Issue.Title)
- opts.Issue.Index = opts.Repo.NextIssueIndex()
+
+ maxIndex, err := getMaxIndexOfIssue(e, opts.Issue.RepoID)
+ if err != nil {
+ return err
+ }
+ opts.Issue.Index = maxIndex + 1
if opts.Issue.MilestoneID > 0 {
milestone, err := getMilestoneByRepoID(e, opts.Issue.RepoID, opts.Issue.MilestoneID)
diff --git a/models/repo.go b/models/repo.go
index b37120236f..3283223d5b 100644
--- a/models/repo.go
+++ b/models/repo.go
@@ -687,13 +687,6 @@ func (repo *Repository) getUsersWithAccessMode(e Engine, mode AccessMode) (_ []*
return users, nil
}
-// NextIssueIndex returns the next issue index
-// FIXME: should have a mutex to prevent producing same index for two issues that are created
-// closely enough.
-func (repo *Repository) NextIssueIndex() int64 {
- return int64(repo.NumIssues+repo.NumPulls) + 1
-}
-
var (
descPattern = regexp.MustCompile(`https?://\S+`)
)
diff --git a/routers/api/v1/repo/pull.go b/routers/api/v1/repo/pull.go
index dda8387913..f53ab4b8f3 100644
--- a/routers/api/v1/repo/pull.go
+++ b/routers/api/v1/repo/pull.go
@@ -251,9 +251,15 @@ func CreatePullRequest(ctx *context.APIContext, form api.CreatePullRequestOption
deadlineUnix = util.TimeStamp(form.Deadline.Unix())
}
+ maxIndex, err := models.GetMaxIndexOfIssue(repo.ID)
+ if err != nil {
+ ctx.ServerError("GetPatch", err)
+ return
+ }
+
prIssue := &models.Issue{
RepoID: repo.ID,
- Index: repo.NextIssueIndex(),
+ Index: maxIndex + 1,
Title: form.Title,
PosterID: ctx.User.ID,
Poster: ctx.User,
diff --git a/routers/repo/pull.go b/routers/repo/pull.go
index d1e2f0b0b3..412750dd55 100644
--- a/routers/repo/pull.go
+++ b/routers/repo/pull.go
@@ -946,9 +946,15 @@ func CompareAndPullRequestPost(ctx *context.Context, form auth.CreateIssueForm)
return
}
+ maxIndex, err := models.GetMaxIndexOfIssue(repo.ID)
+ if err != nil {
+ ctx.ServerError("GetPatch", err)
+ return
+ }
+
pullIssue := &models.Issue{
RepoID: repo.ID,
- Index: repo.NextIssueIndex(),
+ Index: maxIndex + 1,
Title: form.Title,
PosterID: ctx.User.ID,
Poster: ctx.User,