}
// FIXME: need some kind of mechanism to record failure. HINT: system notice
-// DeleteUser completely and permanently deletes everything of user.
+// DeleteUser completely and permanently deletes everything of a user,
+// but issues/comments/pulls will be kept and shown as someone has been deleted.
func DeleteUser(u *User) error {
+ // Note: A user owns any repository or belongs to any organization
+ // cannot perform delete operation.
+
// Check ownership of repository.
count, err := GetRepositoryCount(u)
if err != nil {
return ErrUserHasOrgs{UID: u.Id}
}
- // Get watches before session.
+ sess := x.NewSession()
+ defer sessionRelease(sess)
+ if err = sess.Begin(); err != nil {
+ return err
+ }
+
+ // ***** START: Watch *****
watches := make([]*Watch, 0, 10)
- if err = x.Where("user_id=?", u.Id).Find(&watches); err != nil {
+ if err = x.Find(&watches, &Watch{UserID: u.Id}); err != nil {
return fmt.Errorf("get all watches: %v", err)
}
- repoIDs := make([]int64, 0, len(watches))
for i := range watches {
- repoIDs = append(repoIDs, watches[i].RepoID)
+ if _, err = sess.Exec("UPDATE `repository` SET num_watches=num_watches-1 WHERE id=?", watches[i].RepoID); err != nil {
+ return fmt.Errorf("decrease repository watch number[%d]: %v", watches[i].RepoID, err)
+ }
}
+ // ***** END: Watch *****
- // FIXME: check issues, other repos' commits
+ // ***** START: Star *****
+ stars := make([]*Star, 0, 10)
+ if err = x.Find(&stars, &Star{UID: u.Id}); err != nil {
+ return fmt.Errorf("get all stars: %v", err)
+ }
+ for i := range stars {
+ if _, err = sess.Exec("UPDATE `repository` SET num_stars=num_stars-1 WHERE id=?", stars[i].RepoID); err != nil {
+ return fmt.Errorf("decrease repository star number[%d]: %v", stars[i].RepoID, err)
+ }
+ }
+ // ***** END: Star *****
- sess := x.NewSession()
- defer sessionRelease(sess)
- if err = sess.Begin(); err != nil {
- return err
+ // ***** START: Follow *****
+ followers := make([]*Follow, 0, 10)
+ if err = x.Find(&followers, &Follow{UserID: u.Id}); err != nil {
+ return fmt.Errorf("get all followers: %v", err)
+ }
+ for i := range followers {
+ if _, err = sess.Exec("UPDATE `user` SET num_followers=num_followers-1 WHERE id=?", followers[i].UserID); err != nil {
+ return fmt.Errorf("decrease user follower number[%d]: %v", followers[i].UserID, err)
+ }
}
+ // ***** END: Follow *****
if err = DeleteBeans(sess,
- &Follow{FollowID: u.Id},
&Oauth2{Uid: u.Id},
- &Action{UserID: u.Id},
- &Access{UserID: u.Id},
+ &AccessToken{UID: u.Id},
&Collaboration{UserID: u.Id},
- &EmailAddress{Uid: u.Id},
+ &Access{UserID: u.Id},
&Watch{UserID: u.Id},
+ &Star{UID: u.Id},
+ &Follow{FollowID: u.Id},
+ &Action{UserID: u.Id},
&IssueUser{UID: u.Id},
+ &EmailAddress{Uid: u.Id},
); err != nil {
- return err
+ return fmt.Errorf("DeleteBeans: %v", err)
}
- // Decrease all watch numbers.
- for i := range repoIDs {
- if _, err = sess.Exec("UPDATE `repository` SET num_watches=num_watches-1 WHERE id=?", repoIDs[i]); err != nil {
- return err
- }
- }
-
- // Delete all SSH keys.
+ // ***** START: PublicKey *****
keys := make([]*PublicKey, 0, 10)
if err = sess.Find(&keys, &PublicKey{OwnerID: u.Id}); err != nil {
- return err
+ return fmt.Errorf("get all public keys: %v", err)
}
for _, key := range keys {
if err = deletePublicKey(sess, key); err != nil {
- return err
+ return fmt.Errorf("deletePublicKey: %v", err)
}
}
+ // ***** END: PublicKey *****
// Clear assignee.
if _, err = sess.Exec("UPDATE `issue` SET assignee_id=0 WHERE assignee_id=?", u.Id); err != nil {
- return err
+ return fmt.Errorf("clear assignee: %v", err)
}
if _, err = sess.Delete(u); err != nil {
- return err
+ return fmt.Errorf("Delete: %v", err)
}
- // Delete user data.
- if err = os.RemoveAll(UserPath(u.Name)); err != nil {
- return err
+ if err = sess.Commit(); err != nil {
+ return fmt.Errorf("Commit: %v", err)
}
- // Delete avatar.
+
+ // FIXME: system notice
+ // Note: There are something just cannot be roll back,
+ // so just keep error logs of those operations.
+
+ RewriteAllPublicKeys()
+ os.RemoveAll(UserPath(u.Name))
os.Remove(u.CustomAvatarPath())
- return sess.Commit()
+ return nil
}
// DeleteInactivateUsers deletes all inactivate users and email addresses.
-func DeleteInactivateUsers() error {
- _, err := x.Where("is_active=?", false).Delete(new(User))
- if err == nil {
- _, err = x.Where("is_activated=?", false).Delete(new(EmailAddress))
+func DeleteInactivateUsers() (err error) {
+ users := make([]*User, 0, 10)
+ if err = x.Where("is_active=?", false).Find(&users); err != nil {
+ return fmt.Errorf("get all inactive users: %v", err)
+ }
+ for _, u := range users {
+ if err = DeleteUser(u); err != nil {
+ // Ignore users that were set inactive by admin.
+ if IsErrUserOwnRepos(err) || IsErrUserHasOrgs(err) {
+ continue
+ }
+ return err
+ }
}
+
+ _, err = x.Where("is_activated=?", false).Delete(new(EmailAddress))
return err
}
// Follow is connection request for receiving user notification.
type Follow struct {
- Id int64
- UserID int64 `xorm:"unique(follow)"`
- FollowID int64 `xorm:"unique(follow)"`
+ ID int64 `xorm:"pk autoincr"`
+ UserID int64 `xorm:"UNIQUE(follow)"`
+ FollowID int64 `xorm:"UNIQUE(follow)"`
}
// FollowUser marks someone be another's follower.
projects / gitea.git / commitdiff