@@ -257,7 +257,11 @@ func CreateRepositoryDirectly(ctx context.Context, doer, u *user_model.User, opt
257
257
258
258
// last - clean up if something goes wrong
259
259
// WARNING: Don't override all later err with local variables
260
- defer cleanupRepository (err , doer , repo .ID )
260
+ defer func () {
261
+ if err != nil {
262
+ cleanupRepository (doer , repo .ID )
263
+ }
264
+ }()
261
265
262
266
// No need for init mirror.
263
267
if opts .IsMirror {
@@ -474,14 +478,12 @@ func CreateRepositoryInDB(ctx context.Context, doer, u *user_model.User, repo *r
474
478
return nil
475
479
}
476
480
477
- func cleanupRepository (err error , doer * user_model.User , repoID int64 ) {
478
- if err != nil {
479
- if errDelete := DeleteRepositoryDirectly (db .DefaultContext , doer , repoID ); errDelete != nil {
480
- log .Error ("Rollback deleteRepository: %v" , errDelete )
481
- // add system notice
482
- if err := system_model .CreateRepositoryNotice ("DeleteRepositoryDirectly failed when create repository: %v" , errDelete ); err != nil {
483
- log .Error ("CreateRepositoryNotice: %v" , err )
484
- }
481
+ func cleanupRepository (doer * user_model.User , repoID int64 ) {
482
+ if errDelete := DeleteRepositoryDirectly (db .DefaultContext , doer , repoID ); errDelete != nil {
483
+ log .Error ("Rollback deleteRepository: %v" , errDelete )
484
+ // add system notice
485
+ if err := system_model .CreateRepositoryNotice ("DeleteRepositoryDirectly failed when create repository: %v" , errDelete ); err != nil {
486
+ log .Error ("CreateRepositoryNotice: %v" , err )
485
487
}
486
488
}
487
489
}
0 commit comments