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_by(id: group_id)
      raise Discourse::InvalidParameters.new(:group_id) if group.nil?

      return unless group.automatic_membership_retroactive

      domains = group.automatic_membership_email_domains.gsub('.', '\.')

      User.joins(:user_emails)
        .where("user_emails.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|
        next unless user.email_confirmed?
        group.add(user)
        GroupActionLogger.new(Discourse.system_user, group).log_add_user_to_group(user)
      end

      Group.reset_counters(group.id, :group_users)
    end

  end

end