2011-12-17 14:58:35 +01:00
|
|
|
class MailerObserver < ActiveRecord::Observer
|
2012-06-20 19:48:34 +02:00
|
|
|
observe :note, :merge_request
|
2011-12-17 14:58:35 +01:00
|
|
|
cattr_accessor :current_user
|
|
|
|
|
|
|
|
def after_create(model)
|
|
|
|
new_note(model) if model.kind_of?(Note)
|
2011-12-17 17:07:28 +01:00
|
|
|
new_merge_request(model) if model.kind_of?(MergeRequest)
|
2011-12-17 14:58:35 +01:00
|
|
|
end
|
|
|
|
|
2011-12-18 14:46:06 +01:00
|
|
|
def after_update(model)
|
|
|
|
changed_merge_request(model) if model.kind_of?(MergeRequest)
|
|
|
|
end
|
|
|
|
|
2011-12-17 14:58:35 +01:00
|
|
|
protected
|
|
|
|
|
2012-01-03 20:46:53 +01:00
|
|
|
def new_note(note)
|
2012-02-10 03:59:39 +01:00
|
|
|
if note.notify
|
2012-06-14 07:24:10 +02:00
|
|
|
# Notify whole team except author of note
|
|
|
|
notify_note(note)
|
2012-02-10 03:59:39 +01:00
|
|
|
elsif note.notify_author
|
2012-06-14 07:24:10 +02:00
|
|
|
# Notify only author of resource
|
2012-05-16 04:27:35 +02:00
|
|
|
Notify.note_commit_email(note.commit_author.id, note.id).deliver
|
2012-06-14 07:24:10 +02:00
|
|
|
else
|
|
|
|
# Otherwise ignore it
|
|
|
|
nil
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def notify_note note
|
|
|
|
# reject author of note from mail list
|
|
|
|
users = note.project.users.reject { |u| u.id == current_user.id }
|
|
|
|
|
|
|
|
users.each do |u|
|
|
|
|
case note.noteable_type
|
|
|
|
when "Commit"; Notify.note_commit_email(u.id, note.id).deliver
|
|
|
|
when "Issue"; Notify.note_issue_email(u.id, note.id).deliver
|
|
|
|
when "MergeRequest"; Notify.note_merge_request_email(u.id, note.id).deliver
|
|
|
|
when "Snippet"; true
|
|
|
|
else
|
|
|
|
Notify.note_wall_email(u.id, note.id).deliver
|
|
|
|
end
|
2011-12-17 14:58:35 +01:00
|
|
|
end
|
2012-01-03 20:46:53 +01:00
|
|
|
end
|
2011-12-17 14:58:35 +01:00
|
|
|
|
2012-01-03 20:46:53 +01:00
|
|
|
def new_merge_request(merge_request)
|
2012-07-17 07:19:16 +02:00
|
|
|
if merge_request.assignee && merge_request.assignee != current_user
|
2012-05-16 04:27:35 +02:00
|
|
|
Notify.new_merge_request_email(merge_request.id).deliver
|
2011-12-17 17:07:28 +01:00
|
|
|
end
|
2012-01-03 20:46:53 +01:00
|
|
|
end
|
2011-12-17 17:07:28 +01:00
|
|
|
|
2012-01-03 20:46:53 +01:00
|
|
|
def changed_merge_request(merge_request)
|
2012-06-14 11:45:22 +02:00
|
|
|
status_notify_and_comment merge_request, :reassigned_merge_request_email
|
2012-01-03 20:46:53 +01:00
|
|
|
end
|
2011-12-18 15:07:47 +01:00
|
|
|
|
2012-06-14 07:24:10 +02:00
|
|
|
# This method used for Issues & Merge Requests
|
2012-05-21 19:30:53 +02:00
|
|
|
#
|
2012-06-14 07:24:10 +02:00
|
|
|
# It create a comment for Issue or MR if someone close/reopen.
|
|
|
|
# It also notify via email if assignee was changed
|
|
|
|
#
|
|
|
|
def status_notify_and_comment target, mail_method
|
|
|
|
# If assigne changed - notify to recipients
|
|
|
|
if target.assignee_id_changed?
|
|
|
|
recipients_ids = target.assignee_id_was, target.assignee_id
|
2012-01-03 20:46:53 +01:00
|
|
|
recipients_ids.delete current_user.id
|
2011-12-18 15:07:47 +01:00
|
|
|
|
2012-05-15 05:27:52 +02:00
|
|
|
recipients_ids.each do |recipient_id|
|
2012-06-14 07:24:10 +02:00
|
|
|
Notify.send(mail_method, recipient_id, target.id, target.assignee_id_was).deliver
|
2011-12-29 21:50:26 +01:00
|
|
|
end
|
2012-01-03 20:46:53 +01:00
|
|
|
end
|
|
|
|
|
2012-06-14 07:24:10 +02:00
|
|
|
# Create comment about status changed
|
|
|
|
if target.closed_changed?
|
|
|
|
note = Note.new(:noteable => target, :project => target.project)
|
2012-01-03 20:46:53 +01:00
|
|
|
note.author = current_user
|
2012-06-14 07:24:10 +02:00
|
|
|
note.note = "_Status changed to #{target.closed ? 'closed' : 'reopened'}_"
|
2012-01-03 20:46:53 +01:00
|
|
|
note.save()
|
|
|
|
end
|
2011-12-29 21:50:26 +01:00
|
|
|
end
|
2011-12-17 14:58:35 +01:00
|
|
|
end
|