2015-01-23 12:25:43 -05:00
|
|
|
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('.', '\.')
|
|
|
|
|
2015-01-26 17:17:29 -05:00
|
|
|
User.where("email ~* '@(#{domains})$'").find_each do |user|
|
2015-06-17 11:45:53 -04:00
|
|
|
begin
|
|
|
|
group.add(user)
|
|
|
|
rescue ActiveRecord::RecordNotUnique, PG::UniqueViolation
|
|
|
|
# we don't care about this
|
|
|
|
end
|
2015-01-23 12:25:43 -05:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|
|
|
|
|
|
|
|
end
|