diff options
Diffstat (limited to 'services/packages/packages.go')
| -rw-r--r-- | services/packages/packages.go | 19 |
1 files changed, 5 insertions, 14 deletions
diff --git a/services/packages/packages.go b/services/packages/packages.go index 4b16ee7285..22b26b6563 100644 --- a/services/packages/packages.go +++ b/services/packages/packages.go @@ -469,24 +469,15 @@ func RemovePackageVersionByNameAndVersion(ctx context.Context, doer *user_model. // RemovePackageVersion deletes the package version and all associated files func RemovePackageVersion(ctx context.Context, doer *user_model.User, pv *packages_model.PackageVersion) error { - dbCtx, committer, err := db.TxContext(ctx) + pd, err := packages_model.GetPackageDescriptor(ctx, pv) if err != nil { return err } - defer committer.Close() - - pd, err := packages_model.GetPackageDescriptor(dbCtx, pv) - if err != nil { - return err - } - - log.Trace("Deleting package: %v", pv.ID) - if err := DeletePackageVersionAndReferences(dbCtx, pv); err != nil { - return err - } - - if err := committer.Commit(); err != nil { + if err := db.WithTx(ctx, func(ctx context.Context) error { + log.Trace("Deleting package: %v", pv.ID) + return DeletePackageVersionAndReferences(ctx, pv) + }); err != nil { return err } |