68 lines
2.2 KiB
Ruby
68 lines
2.2 KiB
Ruby
# -*- encoding : utf-8 -*-
|
|
module Modules::Observers::ActivityFeed::Issue
|
|
extend ActiveSupport::Concern
|
|
|
|
included do
|
|
after_commit :new_issue_notifications, :on => :create
|
|
|
|
after_commit :send_assign_notifications, :on => :create
|
|
after_commit -> { send_assign_notifications(:update) }, :on => :update
|
|
|
|
after_commit :send_hooks, :on => :create
|
|
after_commit -> { send_hooks(:update) }, :on => :update, :if => :status_changed?
|
|
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) || assignee_id_changed?
|
|
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)
|
|
end
|
|
|
|
def send_hooks(action = :create)
|
|
project.hooks.each{ |h| h.receive_issues(self, action) }
|
|
end
|
|
|
|
end |