mirror of
https://codeberg.org/forgejo/forgejo.git
synced 2024-05-15 10:32:40 +00:00
998a431747
* Split TestPullRequest out of AddTestPullRequestTask * A Created field is added to the Issue table * The Created field is set to the time (with nano resolution) on creation * Record the nano time repo_module.PushUpdateOptions is created by the hook * The decision to update a pull request created before a commit was pushed is based on the time (with nano resolution) the git hook was run and the Created field It ensures the following happens: * commit C is pushed * the git hook queues AddTestPullRequestTask for processing and returns with success * TestPullRequest is not called yet * a pull request P with commit C as the head is created * TestPullRequest runs and ignores P because it was created after the commit was received When the "created" column is NULL, no verification is done, pull requests that were created before the column was created in the database cannot be newer than the latest call to a git hook. Fixes: https://codeberg.org/forgejo/forgejo/issues/2009
40 lines
960 B
Go
40 lines
960 B
Go
// Copyright 2017 The Gitea Authors. All rights reserved.
|
|
// SPDX-License-Identifier: MIT
|
|
|
|
package issues
|
|
|
|
import (
|
|
"context"
|
|
|
|
"code.gitea.io/gitea/models/db"
|
|
)
|
|
|
|
func GetMaxIssueIndexForRepo(ctx context.Context, repoID int64) (int64, error) {
|
|
var max int64
|
|
if _, err := db.GetEngine(ctx).Select("MAX(`index`)").Table("issue").Where("repo_id=?", repoID).Get(&max); err != nil {
|
|
return 0, err
|
|
}
|
|
return max, nil
|
|
}
|
|
|
|
// RecalculateIssueIndexForRepo create issue_index for repo if not exist and
|
|
// update it based on highest index of existing issues assigned to a repo
|
|
func RecalculateIssueIndexForRepo(ctx context.Context, repoID int64) error {
|
|
ctx, committer, err := db.TxContext(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer committer.Close()
|
|
|
|
max, err := GetMaxIssueIndexForRepo(ctx, repoID)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if err = db.SyncMaxResourceIndex(ctx, "issue_index", repoID, max); err != nil {
|
|
return err
|
|
}
|
|
|
|
return committer.Commit()
|
|
}
|