self.process_at_notifications

in models/observers/at_user_observer.rb [9:55]

• 38 lines of code
• 5 McCabe index (conditional complexity)

  def self.process_at_notifications(content)
    text = content.body

    content_type = content.respond_to?(:title) ? :thread : :comment
    text = content.title + "\n\n" + text if content_type == :thread

    at_positions = self.get_valid_at_position_list text 
    prev_at_positions = content.at_position_list

    content.update_attributes!(at_position_list: at_positions)

    prev_user_ids = prev_at_positions.map { |x| x[:user_id] }.to_set
    current_user_ids = at_positions.map { |x| x[:user_id] }.to_set

    new_user_ids = current_user_ids - prev_user_ids

    if content_type == :thread
      thread_title = content.title
      thread_id = content.id
      commentable_id = content.commentable_id
    else
      thread_title = content.comment_thread.title
      thread_id = content.comment_thread.id
      commentable_id = content.comment_thread.commentable_id
    end

    unless new_user_ids.empty?

      notification = Notification.new(
        notification_type: "at_user",
        info: {
          comment_id: (content.id if content_type == :comment),
          content_type: content_type,
          thread_title: thread_title,
          thread_id: thread_id,
          actor_username: content.author_with_anonymity(:username),
          actor_id: content.author_with_anonymity(:id),
          commentable_id: commentable_id,
        }
      )
      receivers = new_user_ids.map { |id| User.find(id) }
      receivers.delete(content.author)
      notification.receivers << receivers
      notification.save!
    end
  end