Skip to content

Commit d483c76

Browse files
committed
Use db.WithTx for database transaction
1 parent 6fec27f commit d483c76

File tree

1 file changed

+8
-14
lines changed

1 file changed

+8
-14
lines changed

services/pull/check.go

Lines changed: 8 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -301,23 +301,17 @@ func manuallyMerged(ctx context.Context, pr *issues_model.PullRequest) bool {
301301
pr.Merger = merger
302302
pr.MergerID = merger.ID
303303

304-
ctx, committer, err := db.TxContext(ctx)
305-
if err != nil {
306-
log.Error("%-v db.TxContext: %v", pr, err)
307-
return false
308-
}
309-
defer committer.Close()
310-
if merged, err := pr.SetMerged(ctx); err != nil {
304+
if err := db.WithTx(ctx, func(ctx context.Context) error {
305+
if merged, err := pr.SetMerged(ctx); err != nil {
306+
return err
307+
} else if !merged {
308+
return errors.New("setMerged failed")
309+
}
310+
return nil
311+
}); err != nil {
311312
log.Error("%-v setMerged : %v", pr, err)
312313
return false
313-
} else if !merged {
314-
return false
315-
}
316-
if err := committer.Commit(); err != nil {
317-
log.Error("%-v committer.Commit: %v", pr, err)
318-
return false
319314
}
320-
committer.Close()
321315

322316
notify_service.MergePullRequest(ctx, merger, pr)
323317

0 commit comments

Comments
 (0)