Mirrors/gitea
0
0
Fork 0
mirror of https://github.com/go-gitea/gitea.git synced 2025-11-08 20:32:29 +01:00
Code Issues Activity

rename

Browse Source
This commit is contained in:
Lunny Xiao 2025-10-21 20:34:42 -07:00
parent 573a55d556
commit 0f822038a6
No known key found for this signature in database
GPG Key ID: C3B7C91B632F738A
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
services/migrations/migrate.go
View File

@ -394,7 +394,7 @@ func migrateRepository(ctx context.Context, doer *user_model.User, downloader ba
log.Trace("migrating pull requests and comments") log.Trace("migrating pull requests and comments")
messenger("repo.migrate.migrating_pulls") messenger("repo.migrate.migrating_pulls")
prBatchSize := uploader.MaxBatchInsertSize("pullrequest") prBatchSize := uploader.MaxBatchInsertSize("pullrequest")
mapInsertedIssueIndexes := container.Set[int64]{} mapInsertedPRIndexes := container.Set[int64]{}
for i := 1; ; i++ { for i := 1; ; i++ {
prs, isEnd, err := downloader.GetPullRequests(ctx, i, prBatchSize) prs, isEnd, err := downloader.GetPullRequests(ctx, i, prBatchSize)
if err != nil { if err != nil {
@ -405,12 +405,12 @@ func migrateRepository(ctx context.Context, doer *user_model.User, downloader ba
break break
} }
for i := 0; i < len(prs); i++ { for i := 0; i < len(prs); i++ {
if mapInsertedIssueIndexes.Contains(prs[i].Number) { if mapInsertedPRIndexes.Contains(prs[i].Number) {
prs = append(prs[:i], prs[i+1:]...) prs = append(prs[:i], prs[i+1:]...)
i-- i--
continue continue
} }
mapInsertedIssueIndexes.Add(prs[i].Number) mapInsertedPRIndexes.Add(prs[i].Number)
} }
if err := uploader.CreatePullRequests(ctx, prs...); err != nil { if err := uploader.CreatePullRequests(ctx, prs...); err != nil {