rosa-build/lib/modules/observers/activity_feed/issue.rb

module Modules::Observers::ActivityFeed::Issue
  extend ActiveSupport::Concern

  included do
    after_commit :new_issue_notifications, :on => :create

    after_commit :send_assign_notifications,                :on => :create, :if => Proc.new { |i| i.assignee }
    after_commit -> { send_assign_notifications(:update) }, :on => :update

    after_commit :send_hooks,                :on => :create
    after_commit -> { send_hooks(:update) }, :on => :update, :if => Proc.new { |i| i.previous_changes['status'].present? }
  end

  private

  def new_issue_notifications
    collect_recipients.each do |recipient|
      next if user_id == recipient.id
      if recipient.notifier.can_notify && recipient.notifier.new_issue && assignee_id != recipient.id
        UserMailer.new_issue_notification(self, recipient).deliver
      end
      ActivityFeed.create(
        :user => recipient,
        :kind => 'new_issue_notification',
        :data => {
          :user_name        => user.name,
          :user_email       => user.email,
          :user_id          => user_id,
          :issue_serial_id  => serial_id,
          :issue_title      => title,
          :project_id       => project.id,
          :project_name     => project.name,
          :project_owner    => project.owner.uname
        }
      )
    end
    Comment.create_link_on_issues_from_item(self)
  end

  def send_assign_notifications(action = :create)
    if(action == :create && assignee_id) || previous_changes['assignee_id'].present?
      if assignee.notifier.issue_assign && assignee.notifier.can_notify
        UserMailer.issue_assign_notification(self, assignee).deliver
      end
      ActivityFeed.create(
        :user => assignee,
        :kind => 'issue_assign_notification',
        :data => {
          :user_name        => assignee.name,
          :user_email       => assignee.email,
          :issue_serial_id  => serial_id,
          :issue_title      => title,
          :project_id       => project.id,
          :project_name     => project.name,
          :project_owner    => project.owner.uname
        }
      )
    end
    # dont remove outdated issues link
    Comment.create_link_on_issues_from_item(self) if previous_changes['title'].present? || previous_changes['body'].present?
  end

  def send_hooks(action = :create)
    project.hooks.each{ |h| h.receive_issues(self, action) }
  end
end