discourse/app/jobs/regular/automatic_group_membership.rb

32 lines
802 B
Ruby
Raw Normal View History

module Jobs
class AutomaticGroupMembership < Jobs::Base
def execute(args)
group_id = args[:group_id]
raise Discourse::InvalidParameters.new(:group_id) if group_id.blank?
group = Group.find(group_id)
return unless group.automatic_membership_retroactive
domains = group.automatic_membership_email_domains.gsub('.', '\.')
User.where("email ~* '@(#{domains})$'")
.where("users.id NOT IN (SELECT user_id FROM group_users WHERE group_users.group_id = ?)", group_id)
.activated
.where(staged: false)
.find_each do |user|
2016-12-11 10:36:15 -05:00
2015-06-17 11:45:53 -04:00
group.add(user)
2016-12-11 10:36:15 -05:00
GroupActionLogger.new(Discourse.system_user, group).log_add_user_to_group(user)
end
Group.reset_counters(group.id, :group_users)
end
end
end