91 lines
2.9 KiB
Ruby
91 lines
2.9 KiB
Ruby
require_dependency 'ip_addr'
|
|
|
|
# Responsible for destroying a User record
|
|
class UserDestroyer
|
|
|
|
class PostsExistError < RuntimeError; end
|
|
|
|
def initialize(actor)
|
|
@actor = actor
|
|
raise Discourse::InvalidParameters.new('acting user is nil') unless @actor and @actor.is_a?(User)
|
|
@guardian = Guardian.new(actor)
|
|
end
|
|
|
|
# Returns false if the user failed to be deleted.
|
|
# Returns a frozen instance of the User if the delete succeeded.
|
|
def destroy(user, opts={})
|
|
raise Discourse::InvalidParameters.new('user is nil') unless user and user.is_a?(User)
|
|
@guardian.ensure_can_delete_user!(user)
|
|
raise PostsExistError if !opts[:delete_posts] && user.posts.count != 0
|
|
|
|
User.transaction do
|
|
|
|
Draft.where(user_id: user.id).delete_all
|
|
QueuedPost.where(user_id: user.id).delete_all
|
|
|
|
if opts[:delete_posts]
|
|
user.posts.each do |post|
|
|
# agree with flags
|
|
PostAction.agree_flags!(post, @actor) if opts[:delete_as_spammer]
|
|
|
|
# block all external urls
|
|
if opts[:block_urls]
|
|
post.topic_links.each do |link|
|
|
unless link.internal or Oneboxer.oneboxer_exists_for_url?(link.url)
|
|
ScreenedUrl.watch(link.url, link.domain, ip_address: user.ip_address).try(:record_match!)
|
|
end
|
|
end
|
|
end
|
|
|
|
PostDestroyer.new(@actor.staff? ? @actor : Discourse.system_user, post).destroy
|
|
|
|
if post.topic and post.is_first_post?
|
|
Topic.unscoped.where(id: post.topic.id).update_all(user_id: nil)
|
|
end
|
|
end
|
|
end
|
|
|
|
user.post_actions.each do |post_action|
|
|
post_action.remove_act!(Discourse.system_user)
|
|
end
|
|
|
|
user.destroy.tap do |u|
|
|
if u
|
|
|
|
if opts[:block_email]
|
|
b = ScreenedEmail.block(u.email, ip_address: u.ip_address)
|
|
b.record_match! if b
|
|
end
|
|
|
|
if opts[:block_ip] && u.ip_address
|
|
b = ScreenedIpAddress.watch(u.ip_address)
|
|
b.record_match! if b
|
|
if u.registration_ip_address && u.ip_address != u.registration_ip_address
|
|
b = ScreenedIpAddress.watch(u.registration_ip_address)
|
|
b.record_match! if b
|
|
end
|
|
end
|
|
|
|
Post.with_deleted.where(user_id: user.id).update_all("user_id = NULL")
|
|
|
|
# If this user created categories, fix those up:
|
|
categories = Category.where(user_id: user.id)
|
|
categories.each do |c|
|
|
c.user_id = Discourse.system_user.id
|
|
c.save!
|
|
if topic = Topic.with_deleted.find_by(id: c.topic_id)
|
|
topic.try(:recover!)
|
|
topic.user_id = Discourse.system_user.id
|
|
topic.save!
|
|
end
|
|
end
|
|
|
|
StaffActionLogger.new(@actor == user ? Discourse.system_user : @actor).log_user_deletion(user, opts.slice(:context))
|
|
MessageBus.publish "/file-change", ["refresh"], user_ids: [user.id]
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
end
|