@@ -257,7 +257,11 @@ func CreateRepositoryDirectly(ctx context.Context, doer, u *user_model.User, opt
257257
258258 // last - clean up if something goes wrong
259259 // 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+ }()
261265
262266 // No need for init mirror.
263267 if opts .IsMirror {
@@ -474,14 +478,12 @@ func CreateRepositoryInDB(ctx context.Context, doer, u *user_model.User, repo *r
474478 return nil
475479}
476480
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 )
485487 }
486488 }
487489}
0 commit comments