Class: Jobs::NotifyReviewable
- Defined in:
- app/jobs/regular/notify_reviewable.rb
Instance Method Summary collapse
Methods inherited from Base
acquire_cluster_concurrency_lock!, clear_cluster_concurrency_lock!, cluster_concurrency, cluster_concurrency_redis_key, delayed_perform, #error_context, get_cluster_concurrency, #last_db_duration, #log, #perform, #perform_immediately
Instance Method Details
#execute(args) ⇒ Object
4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 |
# File 'app/jobs/regular/notify_reviewable.rb', line 4 def execute(args) return unless reviewable = Reviewable.find_by(id: args[:reviewable_id]) @contacted = Set.new all_updates = Hash.new { |h, k| h[k] = {} } if args[:updated_reviewable_ids].present? Reviewable .where(id: args[:updated_reviewable_ids]) .each do |r| payload = { last_performing_username: args[:performing_username], status: r.status } all_updates[:admins][r.id] = payload all_updates[:moderators][r.id] = payload if r.reviewable_by_moderator? all_updates[r.reviewable_by_group_id][r.id] = payload if r.reviewable_by_group_id end end DistributedMutex.synchronize("notify_reviewable_job", validity: 120) do counts = Hash.new(0) Reviewable .default_visible .pending .group(:reviewable_by_moderator, :reviewable_by_group_id) .pluck(:reviewable_by_moderator, :reviewable_by_group_id, "count(*)") .each do |reviewable_by_moderator, reviewable_by_group_id, count| counts[:admins] += count counts[:moderators] += count if reviewable_by_moderator counts[reviewable_by_group_id] += count if reviewable_by_group_id end notify_users(User.real.admins, all_updates[:admins]) if reviewable.reviewable_by_moderator? notify_users( User.real.moderators.where("id NOT IN (?)", @contacted), all_updates[:moderators], ) end if SiteSetting.enable_category_group_moderation? && (group = reviewable.reviewable_by_group) users = group.users.includes(:group_users).where("users.id NOT IN (?)", @contacted) users.find_each do |user| count = 0 updates = {} user.group_users.each do |gu| updates.merge!(all_updates[gu.group_id]) count += counts[gu.group_id] end notify_user(user, updates) end @contacted += users.pluck(:id) end end end |