diff options
Diffstat (limited to 'app/services/notification_service.rb')
| -rw-r--r-- | app/services/notification_service.rb | 432 |
1 files changed, 0 insertions, 432 deletions
diff --git a/app/services/notification_service.rb b/app/services/notification_service.rb deleted file mode 100644 index cfed7964c37..00000000000 --- a/app/services/notification_service.rb +++ /dev/null @@ -1,432 +0,0 @@ -# NotificationService class -# -# Used for notifying users with emails about different events -# -# Ex. -# NotificationService.new.new_issue(issue, current_user) -# -class NotificationService - # Always notify user about ssh key added - # only if ssh key is not deploy key - # - # This is security email so it will be sent - # even if user disabled notifications - def new_key(key) - if key.user - mailer.new_ssh_key_email(key.id) - end - end - - # Always notify user about email added to profile - def new_email(email) - if email.user - mailer.new_email_email(email.id) - end - end - - # When create an issue we should send next emails: - # - # * issue assignee if their notification level is not Disabled - # * project team members with notification level higher then Participating - # - def new_issue(issue, current_user) - new_resource_email(issue, issue.project, 'new_issue_email') - end - - # When we close an issue we should send next emails: - # - # * issue author if their notification level is not Disabled - # * issue assignee if their notification level is not Disabled - # * project team members with notification level higher then Participating - # - def close_issue(issue, current_user) - close_resource_email(issue, issue.project, current_user, 'closed_issue_email') - end - - # When we reassign an issue we should send next emails: - # - # * issue old assignee if their notification level is not Disabled - # * issue new assignee if their notification level is not Disabled - # - def reassigned_issue(issue, current_user) - reassign_resource_email(issue, issue.project, current_user, 'reassigned_issue_email') - end - - - # When create a merge request we should send next emails: - # - # * mr assignee if their notification level is not Disabled - # - def new_merge_request(merge_request, current_user) - new_resource_email(merge_request, merge_request.target_project, 'new_merge_request_email') - end - - # When we reassign a merge_request we should send next emails: - # - # * merge_request old assignee if their notification level is not Disabled - # * merge_request assignee if their notification level is not Disabled - # - def reassigned_merge_request(merge_request, current_user) - reassign_resource_email(merge_request, merge_request.target_project, current_user, 'reassigned_merge_request_email') - end - - # When we close a merge request we should send next emails: - # - # * merge_request author if their notification level is not Disabled - # * merge_request assignee if their notification level is not Disabled - # * project team members with notification level higher then Participating - # - def close_mr(merge_request, current_user) - close_resource_email(merge_request, merge_request.target_project, current_user, 'closed_merge_request_email') - end - - def reopen_issue(issue, current_user) - reopen_resource_email(issue, issue.project, current_user, 'issue_status_changed_email', 'reopened') - end - - # When we merge a merge request we should send next emails: - # - # * merge_request author if their notification level is not Disabled - # * merge_request assignee if their notification level is not Disabled - # * project team members with notification level higher then Participating - # - def merge_mr(merge_request, current_user) - recipients = reject_muted_users([merge_request.author, merge_request.assignee], merge_request.target_project) - recipients = add_subscribed_users(recipients, merge_request) - recipients = reject_unsubscribed_users(recipients, merge_request) - recipients = recipients.concat(project_watchers(merge_request.target_project)).uniq - recipients.delete(current_user) - - recipients.each do |recipient| - mailer.merged_merge_request_email(recipient.id, merge_request.id, current_user.id) - end - end - - def reopen_mr(merge_request, current_user) - reopen_resource_email(merge_request, merge_request.target_project, current_user, 'merge_request_status_email', 'reopened') - end - - # Notify new user with email after creation - def new_user(user, token = nil) - # Don't email omniauth created users - mailer.new_user_email(user.id, token) unless user.identities.any? - end - - # Notify users on new note in system - # - # TODO: split on methods and refactor - # - def new_note(note) - return true unless note.noteable_type.present? - - # ignore gitlab service messages - return true if note.note.start_with?('Status changed to closed') - return true if note.cross_reference? && note.system == true - - target = note.noteable - - recipients = [] - - if note.commit_id.present? - recipients << note.commit_author - end - - # Add all users participating in the thread (author, assignee, comment authors) - participants = - if target.respond_to?(:participants) - target.participants - elsif target.is_a?(Commit) - author_ids = Note.for_commit_id(target.id).pluck(:author_id).uniq - User.where(id: author_ids) - else - note.mentioned_users - end - recipients = recipients.concat(participants) - - # Merge project watchers - recipients = recipients.concat(project_watchers(note.project)).compact.uniq - - # Reject users with Mention notification level, except those mentioned in _this_ note. - recipients = reject_mention_users(recipients - note.mentioned_users, note.project) - recipients = recipients + note.mentioned_users - - # Reject mutes users - recipients = reject_muted_users(recipients, note.project) - - recipients = add_subscribed_users(recipients, note.noteable) - - recipients = reject_unsubscribed_users(recipients, note.noteable) - - # Reject author - recipients.delete(note.author) - - # build notify method like 'note_commit_email' - notify_method = "note_#{note.noteable_type.underscore}_email".to_sym - - recipients.each do |recipient| - mailer.send(notify_method, recipient.id, note.id) - end - end - - def invite_project_member(project_member, token) - mailer.project_member_invited_email(project_member.id, token) - end - - def accept_project_invite(project_member) - mailer.project_invite_accepted_email(project_member.id) - end - - def decline_project_invite(project_member) - mailer.project_invite_declined_email(project_member.project.id, project_member.invite_email, project_member.access_level, project_member.created_by_id) - end - - def new_project_member(project_member) - mailer.project_access_granted_email(project_member.id) - end - - def update_project_member(project_member) - mailer.project_access_granted_email(project_member.id) - end - - def invite_group_member(group_member, token) - mailer.group_member_invited_email(group_member.id, token) - end - - def accept_group_invite(group_member) - mailer.group_invite_accepted_email(group_member.id) - end - - def decline_group_invite(group_member) - mailer.group_invite_declined_email(group_member.group.id, group_member.invite_email, group_member.access_level, group_member.created_by_id) - end - - def new_group_member(group_member) - mailer.group_access_granted_email(group_member.id) - end - - def update_group_member(group_member) - mailer.group_access_granted_email(group_member.id) - end - - def project_was_moved(project) - recipients = project.team.members - recipients = reject_muted_users(recipients, project) - - recipients.each do |recipient| - mailer.project_was_moved_email(project.id, recipient.id) - end - end - - protected - - # Get project users with WATCH notification level - def project_watchers(project) - project_members = project_member_notification(project) - - users_with_project_level_global = project_member_notification(project, Notification::N_GLOBAL) - users_with_group_level_global = group_member_notification(project, Notification::N_GLOBAL) - users = users_with_global_level_watch([users_with_project_level_global, users_with_group_level_global].flatten.uniq) - - users_with_project_setting = select_project_member_setting(project, users_with_project_level_global, users) - users_with_group_setting = select_group_member_setting(project, project_members, users_with_group_level_global, users) - - User.where(id: users_with_project_setting.concat(users_with_group_setting).uniq).to_a - end - - def project_member_notification(project, notification_level=nil) - project_members = project.project_members - - if notification_level - project_members.where(notification_level: notification_level).pluck(:user_id) - else - project_members.pluck(:user_id) - end - end - - def group_member_notification(project, notification_level) - if project.group - project.group.group_members.where(notification_level: notification_level).pluck(:user_id) - else - [] - end - end - - def users_with_global_level_watch(ids) - User.where( - id: ids, - notification_level: Notification::N_WATCH - ).pluck(:id) - end - - # Build a list of users based on project notifcation settings - def select_project_member_setting(project, global_setting, users_global_level_watch) - users = project_member_notification(project, Notification::N_WATCH) - - # If project setting is global, add to watch list if global setting is watch - global_setting.each do |user_id| - if users_global_level_watch.include?(user_id) - users << user_id - end - end - - users - end - - # Build a list of users based on group notification settings - def select_group_member_setting(project, project_members, global_setting, users_global_level_watch) - uids = group_member_notification(project, Notification::N_WATCH) - - # Group setting is watch, add to users list if user is not project member - users = [] - uids.each do |user_id| - if project_members.exclude?(user_id) - users << user_id - end - end - - # Group setting is global, add to users list if global setting is watch - global_setting.each do |user_id| - if project_members.exclude?(user_id) && users_global_level_watch.include?(user_id) - users << user_id - end - end - - users - end - - # Remove users with disabled notifications from array - # Also remove duplications and nil recipients - def reject_muted_users(users, project = nil) - users = users.to_a.compact.uniq - users = users.reject(&:blocked?) - - users.reject do |user| - next user.notification.disabled? unless project - - member = project.project_members.find_by(user_id: user.id) - - if !member && project.group - member = project.group.group_members.find_by(user_id: user.id) - end - - # reject users who globally disabled notification and has no membership - next user.notification.disabled? unless member - - # reject users who disabled notification in project - next true if member.notification.disabled? - - # reject users who have N_GLOBAL in project and disabled in global settings - member.notification.global? && user.notification.disabled? - end - end - - # Remove users with notification level 'Mentioned' - def reject_mention_users(users, project = nil) - users = users.to_a.compact.uniq - - users.reject do |user| - next user.notification.mention? unless project - - member = project.project_members.find_by(user_id: user.id) - - if !member && project.group - member = project.group.group_members.find_by(user_id: user.id) - end - - # reject users who globally set mention notification and has no membership - next user.notification.mention? unless member - - # reject users who set mention notification in project - next true if member.notification.mention? - - # reject users who have N_MENTION in project and disabled in global settings - member.notification.global? && user.notification.mention? - end - end - - def reject_unsubscribed_users(recipients, target) - return recipients unless target.respond_to? :subscriptions - - recipients.reject do |user| - subscription = target.subscriptions.find_by_user_id(user.id) - subscription && !subscription.subscribed - end - end - - def add_subscribed_users(recipients, target) - return recipients unless target.respond_to? :subscriptions - - subscriptions = target.subscriptions - - if subscriptions.any? - recipients + subscriptions.where(subscribed: true).map(&:user) - else - recipients - end - end - - def new_resource_email(target, project, method) - recipients = build_recipients(target, project) - recipients.delete(target.author) - - recipients.each do |recipient| - mailer.send(method, recipient.id, target.id) - end - end - - def close_resource_email(target, project, current_user, method) - recipients = build_recipients(target, project) - recipients.delete(current_user) - - recipients.each do |recipient| - mailer.send(method, recipient.id, target.id, current_user.id) - end - end - - def reassign_resource_email(target, project, current_user, method) - assignee_id_was = previous_record(target, "assignee_id") - recipients = build_recipients(target, project) - recipients.delete(current_user) - - recipients.each do |recipient| - mailer.send(method, recipient.id, target.id, assignee_id_was, current_user.id) - end - end - - def reopen_resource_email(target, project, current_user, method, status) - recipients = build_recipients(target, project) - recipients.delete(current_user) - - recipients.each do |recipient| - mailer.send(method, recipient.id, target.id, status, current_user.id) - end - end - - def build_recipients(target, project) - recipients = - if target.respond_to?(:participants) - target.participants - else - [target.author, target.assignee] - end - - recipients = reject_muted_users(recipients, project) - recipients = reject_mention_users(recipients, project) - recipients = add_subscribed_users(recipients, target) - recipients = recipients.concat(project_watchers(project)).uniq - recipients = reject_unsubscribed_users(recipients, target) - recipients - end - - def mailer - Notify.delay - end - - def previous_record(object, attribute) - if object && attribute - if object.previous_changes.include?(attribute) - object.previous_changes[attribute].first - end - end - end -end |