Class: NotificationService
- Inherits:
-
Object
- Object
- NotificationService
- Defined in:
- app/services/notification_service.rb
Overview
NotificationService class
Used for notifying users with emails about different events
Ex.
NotificationService.new.new_issue(issue, current_user)
When calculating the recipients of a notification is expensive (for instance, in the new issue case), `#async` will make that calculation happen in Sidekiq instead:
NotificationService.new.async.new_issue(issue, current_user)
Defined Under Namespace
Classes: Async
Constant Summary collapse
- NEW_COMMIT_EMAIL_DISPLAY_LIMIT =
20
Instance Method Summary collapse
- #accept_group_invite(group_member) ⇒ Object
- #accept_project_invite(project_member) ⇒ Object
-
#access_token_about_to_expire(user, token_names) ⇒ Object
Notify the owner of the personal access token, when it is about to expire And mark the token with about_to_expire_delivered.
-
#access_token_created(user, token_name) ⇒ Object
Notify the owner of the account when a new personal access token is created.
-
#access_token_expired(user) ⇒ Object
Notify the user when at least one of their personal access tokens has expired today.
- #approve_mr(merge_request, current_user) ⇒ Object
- #async ⇒ Object
- #attention_requested_of_merge_request(merge_request, current_user, user) ⇒ Object
- #autodevops_disabled(pipeline, recipients) ⇒ Object
- #change_in_merge_request_draft_status(merge_request, current_user) ⇒ Object
- #changed_milestone_issue(issue, new_milestone, current_user) ⇒ Object
- #changed_milestone_merge_request(merge_request, new_milestone, current_user) ⇒ Object
-
#changed_reviewer_of_merge_request(merge_request, current_user, previous_reviewers = []) ⇒ Object
When we change reviewer in a merge_request we should send an email to:.
-
#close_issue(issue, current_user, params = {}) ⇒ Object
When we close an issue we should send an email to:.
- #close_mr(merge_request, current_user) ⇒ Object
- #decline_access_request(member) ⇒ Object
- #decline_group_invite(group_member) ⇒ Object
- #decline_project_invite(project_member) ⇒ Object
- #disabled_two_factor(user) ⇒ Object
- #group_was_exported(group, current_user) ⇒ Object
- #group_was_not_exported(group, current_user, errors) ⇒ Object
- #in_product_marketing(user_id, group_id, track, series) ⇒ Object
-
#invite_group_member(group_member, token) ⇒ Object
Group invite.
- #invite_member_reminder(group_member, token, reminder_index) ⇒ Object
-
#invite_project_member(project_member, token) ⇒ Object
Project invite.
- #issue_cloned(issue, new_issue, current_user) ⇒ Object
- #issue_due(issue) ⇒ Object
- #issue_moved(issue, new_issue, current_user) ⇒ Object
- #merge_mr(merge_request, current_user) ⇒ Object
-
#merge_request_unmergeable(merge_request) ⇒ Object
When a merge request is found to be unmergeable, we should send an email to:.
- #merge_when_pipeline_succeeds(merge_request, current_user) ⇒ Object
-
#new_access_request(member) ⇒ Object
Members.
-
#new_email_address_added(user, email) ⇒ Object
Notify a user when a new email address is added to the their account.
-
#new_gpg_key(gpg_key) ⇒ Object
Always notify the user about gpg key added.
- #new_group_member(group_member) ⇒ Object
- #new_instance_access_request(user) ⇒ Object
-
#new_issue(issue, current_user) ⇒ Object
When create an issue we should send an email to:.
-
#new_key(key) ⇒ Object
Always notify user about ssh key added only if ssh key is not deploy key.
-
#new_mentions_in_issue(issue, new_mentioned_users, current_user) ⇒ Object
When issue text is updated, we should send an email to:.
-
#new_mentions_in_merge_request(merge_request, new_mentioned_users, current_user) ⇒ Object
When merge request text is updated, we should send an email to:.
-
#new_merge_request(merge_request, current_user) ⇒ Object
When create a merge request we should send an email to:.
-
#new_note(note) ⇒ Object
Notify users on new note in system.
- #new_project_member(project_member) ⇒ Object
-
#new_review(review) ⇒ Object
Notify users on new review in system.
-
#new_user(user, token = nil) ⇒ Object
Notify new user with email after creation.
- #pages_domain_auto_ssl_failed(domain) ⇒ Object
- #pages_domain_disabled(domain) ⇒ Object
- #pages_domain_enabled(domain) ⇒ Object
- #pages_domain_verification_failed(domain) ⇒ Object
- #pages_domain_verification_succeeded(domain) ⇒ Object
- #pipeline_finished(pipeline, ref_status: nil, recipients: nil) ⇒ Object
- #project_exported(project, current_user) ⇒ Object
- #project_not_exported(project, current_user, errors) ⇒ Object
- #project_was_moved(project, old_path_with_namespace) ⇒ Object
- #prometheus_alerts_fired(project, alerts) ⇒ Object
- #push_to_merge_request(merge_request, current_user, new_commits: [], existing_commits: []) ⇒ Object
-
#reassigned_issue(issue, current_user, previous_assignees = []) ⇒ Object
When we reassign an issue we should send an email to:.
-
#reassigned_merge_request(merge_request, current_user, previous_assignees = []) ⇒ Object
When we reassign a merge_request we should send an email to:.
-
#relabeled_issue(issue, added_labels, current_user) ⇒ Object
When we add labels to an issue we should send an email to:.
-
#relabeled_merge_request(merge_request, added_labels, current_user) ⇒ Object
When we add labels to a merge request we should send an email to:.
- #remote_mirror_update_failed(remote_mirror) ⇒ Object
- #removed_milestone_issue(issue, current_user) ⇒ Object
- #removed_milestone_merge_request(merge_request, current_user) ⇒ Object
- #reopen_issue(issue, current_user) ⇒ Object
- #reopen_mr(merge_request, current_user) ⇒ Object
- #repository_cleanup_failure(project, user, error) ⇒ Object
- #repository_cleanup_success(project, user) ⇒ Object
- #resolve_all_discussions(merge_request, current_user) ⇒ Object
- #review_requested_of_merge_request(merge_request, current_user, reviewer) ⇒ Object
- #send_new_note_notifications(note) ⇒ Object
-
#send_new_release_notifications(release) ⇒ Object
Notify users when a new release is created.
- #send_service_desk_notification(note) ⇒ Object
-
#ssh_key_expired(user, fingerprints) ⇒ Object
Notify the user when at least one of their ssh key has expired today.
-
#ssh_key_expiring_soon(user, fingerprints) ⇒ Object
Notify the user when at least one of their ssh key is expiring soon.
- #unapprove_mr(merge_request, current_user) ⇒ Object
-
#unknown_sign_in(user, ip, time) ⇒ Object
Notify a user when a previously unknown IP or device is used to sign in to their account.
- #update_group_member(group_member) ⇒ Object
- #update_project_member(project_member) ⇒ Object
- #updated_group_member_expiration(group_member) ⇒ Object
- #user_admin_rejection(name, email) ⇒ Object
- #user_deactivated(name, email) ⇒ Object
Instance Method Details
#accept_group_invite(group_member) ⇒ Object
544 545 546 |
# File 'app/services/notification_service.rb', line 544 def accept_group_invite(group_member) mailer.member_invite_accepted_email(group_member.real_source_type, group_member.id).deliver_later end |
#accept_project_invite(project_member) ⇒ Object
505 506 507 508 509 |
# File 'app/services/notification_service.rb', line 505 def accept_project_invite(project_member) return true unless project_member.notifiable?(:subscription) mailer.member_invite_accepted_email(project_member.real_source_type, project_member.id).deliver_later end |
#access_token_about_to_expire(user, token_names) ⇒ Object
Notify the owner of the personal access token, when it is about to expire And mark the token with about_to_expire_delivered
77 78 79 80 81 |
# File 'app/services/notification_service.rb', line 77 def access_token_about_to_expire(user, token_names) return unless user.can?(:receive_notifications) mailer.access_token_about_to_expire_email(user, token_names).deliver_later end |
#access_token_created(user, token_name) ⇒ Object
Notify the owner of the account when a new personal access token is created
69 70 71 72 73 |
# File 'app/services/notification_service.rb', line 69 def access_token_created(user, token_name) return unless user.can?(:receive_notifications) mailer.access_token_created_email(user, token_name).deliver_later end |
#access_token_expired(user) ⇒ Object
Notify the user when at least one of their personal access tokens has expired today
84 85 86 87 88 |
# File 'app/services/notification_service.rb', line 84 def access_token_expired(user) return unless user.can?(:receive_notifications) mailer.access_token_expired_email(user).deliver_later end |
#approve_mr(merge_request, current_user) ⇒ Object
764 765 766 |
# File 'app/services/notification_service.rb', line 764 def approve_mr(merge_request, current_user) approve_mr_email(merge_request, merge_request.target_project, current_user) end |
#async ⇒ Object
35 36 37 |
# File 'app/services/notification_service.rb', line 35 def async @async ||= Async.new(self) end |
#attention_requested_of_merge_request(merge_request, current_user, user) ⇒ Object
336 337 338 339 340 341 342 |
# File 'app/services/notification_service.rb', line 336 def attention_requested_of_merge_request(merge_request, current_user, user) recipients = NotificationRecipients::BuildService.build_attention_requested_recipients(merge_request, current_user, user) recipients.each do |recipient| mailer.attention_requested_merge_request_email(recipient.user.id, merge_request.id, current_user.id, recipient.reason).deliver_later end end |
#autodevops_disabled(pipeline, recipients) ⇒ Object
646 647 648 649 650 651 652 |
# File 'app/services/notification_service.rb', line 646 def autodevops_disabled(pipeline, recipients) return if pipeline.project.emails_disabled? recipients.each do |recipient| mailer.autodevops_disabled_email(pipeline, recipient).deliver_later end end |
#change_in_merge_request_draft_status(merge_request, current_user) ⇒ Object
238 239 240 241 242 243 244 245 246 247 248 249 250 |
# File 'app/services/notification_service.rb', line 238 def change_in_merge_request_draft_status(merge_request, current_user) recipients = NotificationRecipients::BuildService.build_recipients(merge_request, current_user, action: "draft_status_change") recipients.each do |recipient| mailer.send( :change_in_merge_request_draft_status_email, recipient.user.id, merge_request.id, current_user.id, recipient.reason ).deliver_later end end |
#changed_milestone_issue(issue, new_milestone, current_user) ⇒ Object
194 195 196 |
# File 'app/services/notification_service.rb', line 194 def changed_milestone_issue(issue, new_milestone, current_user) changed_milestone_resource_email(issue, new_milestone, current_user, :changed_milestone_issue_email) end |
#changed_milestone_merge_request(merge_request, new_milestone, current_user) ⇒ Object
356 357 358 |
# File 'app/services/notification_service.rb', line 356 def changed_milestone_merge_request(merge_request, new_milestone, current_user) changed_milestone_resource_email(merge_request, new_milestone, current_user, :changed_milestone_merge_request_email) end |
#changed_reviewer_of_merge_request(merge_request, current_user, previous_reviewers = []) ⇒ Object
When we change reviewer in a merge_request we should send an email to:
* merge_request old reviewers if their notification level is not Disabled
* merge_request new reviewers if their notification level is not Disabled
* users with custom level checked with "change reviewer merge request"
307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 |
# File 'app/services/notification_service.rb', line 307 def changed_reviewer_of_merge_request(merge_request, current_user, previous_reviewers = []) recipients = NotificationRecipients::BuildService.build_recipients( merge_request, current_user, action: "change_reviewer", previous_assignees: previous_reviewers ) previous_reviewer_ids = previous_reviewers.map(&:id) recipients.each do |recipient| mailer.changed_reviewer_of_merge_request_email( recipient.user.id, merge_request.id, previous_reviewer_ids, current_user.id, recipient.reason ).deliver_later end end |
#close_issue(issue, current_user, params = {}) ⇒ Object
When we close an issue we should send an email to:
* 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
* users with custom level checked with "close issue"
150 151 152 |
# File 'app/services/notification_service.rb', line 150 def close_issue(issue, current_user, params = {}) close_resource_email(issue, current_user, :closed_issue_email, closed_via: params[:closed_via]) end |
#close_mr(merge_request, current_user) ⇒ Object
360 361 362 |
# File 'app/services/notification_service.rb', line 360 def close_mr(merge_request, current_user) close_resource_email(merge_request, current_user, :closed_merge_request_email) end |
#decline_access_request(member) ⇒ Object
492 493 494 495 496 |
# File 'app/services/notification_service.rb', line 492 def decline_access_request(member) return true unless member.notifiable?(:subscription) mailer.member_access_denied_email(member.real_source_type, member.source_id, member.user_id).deliver_later end |
#decline_group_invite(group_member) ⇒ Object
548 549 550 551 552 553 554 555 556 557 558 |
# File 'app/services/notification_service.rb', line 548 def decline_group_invite(group_member) # Must always send, regardless of project/namespace configuration since it's a # response to the user's action. mailer.member_invite_declined_email( group_member.real_source_type, group_member.group.id, group_member.invite_email, group_member.created_by_id ).deliver_later end |
#decline_project_invite(project_member) ⇒ Object
511 512 513 514 515 516 517 518 519 520 521 |
# File 'app/services/notification_service.rb', line 511 def decline_project_invite(project_member) # Must always send, regardless of project/namespace configuration since it's a # response to the user's action. mailer.member_invite_declined_email( project_member.real_source_type, project_member.project.id, project_member.invite_email, project_member.created_by_id ).deliver_later end |
#disabled_two_factor(user) ⇒ Object
39 40 41 42 43 |
# File 'app/services/notification_service.rb', line 39 def disabled_two_factor(user) return unless user.can?(:receive_notifications) mailer.disabled_two_factor_email(user).deliver_later end |
#group_was_exported(group, current_user) ⇒ Object
726 727 728 729 730 |
# File 'app/services/notification_service.rb', line 726 def group_was_exported(group, current_user) return true unless notifiable?(current_user, :mention, group: group) mailer.group_was_exported_email(current_user, group).deliver_later end |
#group_was_not_exported(group, current_user, errors) ⇒ Object
732 733 734 735 736 |
# File 'app/services/notification_service.rb', line 732 def group_was_not_exported(group, current_user, errors) return true unless notifiable?(current_user, :mention, group: group) mailer.group_was_not_exported_email(current_user, group, errors).deliver_later end |
#in_product_marketing(user_id, group_id, track, series) ⇒ Object
760 761 762 |
# File 'app/services/notification_service.rb', line 760 def in_product_marketing(user_id, group_id, track, series) mailer.in_product_marketing_email(user_id, group_id, track, series).deliver_later end |
#invite_group_member(group_member, token) ⇒ Object
Group invite
536 537 538 |
# File 'app/services/notification_service.rb', line 536 def invite_group_member(group_member, token) mailer.member_invited_email(group_member.real_source_type, group_member.id, token).deliver_later end |
#invite_member_reminder(group_member, token, reminder_index) ⇒ Object
540 541 542 |
# File 'app/services/notification_service.rb', line 540 def invite_member_reminder(group_member, token, reminder_index) mailer.member_invited_reminder_email(group_member.real_source_type, group_member.id, token, reminder_index).deliver_later end |
#invite_project_member(project_member, token) ⇒ Object
Project invite
499 500 501 502 503 |
# File 'app/services/notification_service.rb', line 499 def invite_project_member(project_member, token) return true unless project_member.notifiable?(:subscription) mailer.member_invited_email(project_member.real_source_type, project_member.id, token).deliver_later end |
#issue_cloned(issue, new_issue, current_user) ⇒ Object
601 602 603 604 605 606 607 608 609 |
# File 'app/services/notification_service.rb', line 601 def issue_cloned(issue, new_issue, current_user) recipients = NotificationRecipients::BuildService.build_recipients(issue, current_user, action: 'cloned') recipients.map do |recipient| email = mailer.issue_cloned_email(recipient.user, issue, new_issue, current_user, recipient.reason) email.deliver_later email end end |
#issue_due(issue) ⇒ Object
684 685 686 687 688 689 690 691 692 693 694 695 696 |
# File 'app/services/notification_service.rb', line 684 def issue_due(issue) recipients = NotificationRecipients::BuildService.build_recipients( issue, issue., action: 'due', custom_action: :issue_due, skip_current_user: false ) recipients.each do |recipient| mailer.send(:issue_due_email, recipient.user.id, issue.id, recipient.reason).deliver_later end end |
#issue_moved(issue, new_issue, current_user) ⇒ Object
591 592 593 594 595 596 597 598 599 |
# File 'app/services/notification_service.rb', line 591 def issue_moved(issue, new_issue, current_user) recipients = NotificationRecipients::BuildService.build_recipients(issue, current_user, action: 'moved') recipients.map do |recipient| email = mailer.issue_moved_email(recipient.user, issue, new_issue, current_user, recipient.reason) email.deliver_later email end end |
#merge_mr(merge_request, current_user) ⇒ Object
368 369 370 371 372 373 374 375 |
# File 'app/services/notification_service.rb', line 368 def merge_mr(merge_request, current_user) close_resource_email( merge_request, current_user, :merged_merge_request_email, skip_current_user: !merge_request.auto_merge_enabled? ) end |
#merge_request_unmergeable(merge_request) ⇒ Object
When a merge request is found to be unmergeable, we should send an email to:
* mr author
* mr merge user if set
257 258 259 |
# File 'app/services/notification_service.rb', line 257 def merge_request_unmergeable(merge_request) merge_request_unmergeable_email(merge_request) end |
#merge_when_pipeline_succeeds(merge_request, current_user) ⇒ Object
747 748 749 750 751 752 753 754 755 756 757 758 |
# File 'app/services/notification_service.rb', line 747 def merge_when_pipeline_succeeds(merge_request, current_user) recipients = ::NotificationRecipients::BuildService.build_recipients( merge_request, current_user, action: 'merge_when_pipeline_succeeds', custom_action: :merge_when_pipeline_succeeds ) recipients.each do |recipient| mailer.merge_when_pipeline_succeeds_email(recipient.user.id, merge_request.id, current_user.id).deliver_later end end |
#new_access_request(member) ⇒ Object
Members
476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 |
# File 'app/services/notification_service.rb', line 476 def new_access_request(member) return true unless member.notifiable?(:subscription) source = member.source recipients = source.access_request_approvers_to_be_notified if fallback_to_group_access_request_approvers?(recipients, source) recipients = source.group.access_request_approvers_to_be_notified end return true if recipients.empty? recipients.each { |recipient| deliver_access_request_email(recipient, member) } end |
#new_email_address_added(user, email) ⇒ Object
Notify a user when a new email address is added to the their account
113 114 115 116 117 |
# File 'app/services/notification_service.rb', line 113 def new_email_address_added(user, email) return unless user.can?(:receive_notifications) mailer.new_email_address_added_email(user, email).deliver_later end |
#new_gpg_key(gpg_key) ⇒ Object
Always notify the user about gpg key added
This is a security email so it will be sent even if the user disabled notifications
62 63 64 65 66 |
# File 'app/services/notification_service.rb', line 62 def new_gpg_key(gpg_key) if gpg_key.user&.can?(:receive_notifications) mailer.new_gpg_key_email(gpg_key.id).deliver_later end end |
#new_group_member(group_member) ⇒ Object
560 561 562 563 564 |
# File 'app/services/notification_service.rb', line 560 def new_group_member(group_member) return true unless group_member.notifiable?(:mention) mailer.member_access_granted_email(group_member.real_source_type, group_member.id).deliver_later end |
#new_instance_access_request(user) ⇒ Object
457 458 459 460 461 462 463 464 465 |
# File 'app/services/notification_service.rb', line 457 def new_instance_access_request(user) recipients = User.instance_access_request_approvers_to_be_notified # https://gitlab.com/gitlab-org/gitlab/-/issues/277016 will change this return true if recipients.empty? recipients.each do |recipient| mailer.instance_access_request_email(user, recipient).deliver_later end end |
#new_issue(issue, current_user) ⇒ Object
When create an issue we should send an email to:
* issue assignee if their notification level is not Disabled
* project team members with notification level higher then Participating
* watchers of the issue's labels
* users with custom level checked with "new issue"
126 127 128 |
# File 'app/services/notification_service.rb', line 126 def new_issue(issue, current_user) new_resource_email(issue, current_user, :new_issue_email) end |
#new_key(key) ⇒ Object
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. However, it won't be sent to internal users like the ghost user or the EE support bot.
52 53 54 55 56 |
# File 'app/services/notification_service.rb', line 52 def new_key(key) if key.user&.can?(:receive_notifications) mailer.new_ssh_key_email(key.id).deliver_later end end |
#new_mentions_in_issue(issue, new_mentioned_users, current_user) ⇒ Object
When issue text is updated, we should send an email to:
* newly mentioned project team members with notification level higher than Participating
134 135 136 137 138 139 140 141 |
# File 'app/services/notification_service.rb', line 134 def new_mentions_in_issue(issue, new_mentioned_users, current_user) new_mentions_in_resource_email( issue, new_mentioned_users, current_user, :new_mention_in_issue_email ) end |
#new_mentions_in_merge_request(merge_request, new_mentioned_users, current_user) ⇒ Object
When merge request text is updated, we should send an email to:
* newly mentioned project team members with notification level higher than Participating
265 266 267 268 269 270 271 272 |
# File 'app/services/notification_service.rb', line 265 def new_mentions_in_merge_request(merge_request, new_mentioned_users, current_user) new_mentions_in_resource_email( merge_request, new_mentioned_users, current_user, :new_mention_in_merge_request_email ) end |
#new_merge_request(merge_request, current_user) ⇒ Object
When create a merge request we should send an email to:
* mr author
* mr assignees if their notification level is not Disabled
* project team members with notification level higher then Participating
* watchers of the mr's labels
* users with custom level checked with "new merge request"
In EE, approvers of the merge request are also included
207 208 209 |
# File 'app/services/notification_service.rb', line 207 def new_merge_request(merge_request, current_user) new_resource_email(merge_request, current_user, :new_merge_request_email) end |
#new_note(note) ⇒ Object
Notify users on new note in system
406 407 408 409 410 411 412 413 414 |
# File 'app/services/notification_service.rb', line 406 def new_note(note) return true unless note.noteable_type.present? # ignore gitlab service messages return true if note.system_note_with_references? send_new_note_notifications(note) send_service_desk_notification(note) end |
#new_project_member(project_member) ⇒ Object
523 524 525 526 527 |
# File 'app/services/notification_service.rb', line 523 def new_project_member(project_member) return true unless project_member.notifiable?(:mention, skip_read_ability: true) mailer.member_access_granted_email(project_member.real_source_type, project_member.id).deliver_later end |
#new_review(review) ⇒ Object
Notify users on new review in system
739 740 741 742 743 744 745 |
# File 'app/services/notification_service.rb', line 739 def new_review(review) recipients = NotificationRecipients::BuildService.build_new_review_recipients(review) recipients.each do |recipient| mailer.new_review_email(recipient.user.id, review.id).deliver_later end end |
#new_user(user, token = nil) ⇒ Object
Notify new user with email after creation
398 399 400 401 402 403 |
# File 'app/services/notification_service.rb', line 398 def new_user(user, token = nil) return true unless notifiable?(user, :mention) # Don't email omniauth created users mailer.new_user_email(user.id, token).deliver_later unless user.identities.any? end |
#pages_domain_auto_ssl_failed(domain) ⇒ Object
678 679 680 681 682 |
# File 'app/services/notification_service.rb', line 678 def pages_domain_auto_ssl_failed(domain) project_maintainers_recipients(domain, action: 'disabled').each do |recipient| mailer.pages_domain_auto_ssl_failed_email(domain, recipient.user).deliver_later end end |
#pages_domain_disabled(domain) ⇒ Object
672 673 674 675 676 |
# File 'app/services/notification_service.rb', line 672 def pages_domain_disabled(domain) project_maintainers_recipients(domain, action: 'disabled').each do |recipient| mailer.pages_domain_disabled_email(domain, recipient.user).deliver_later end end |
#pages_domain_enabled(domain) ⇒ Object
666 667 668 669 670 |
# File 'app/services/notification_service.rb', line 666 def pages_domain_enabled(domain) project_maintainers_recipients(domain, action: 'enabled').each do |recipient| mailer.pages_domain_enabled_email(domain, recipient.user).deliver_later end end |
#pages_domain_verification_failed(domain) ⇒ Object
660 661 662 663 664 |
# File 'app/services/notification_service.rb', line 660 def pages_domain_verification_failed(domain) project_maintainers_recipients(domain, action: 'failed').each do |recipient| mailer.pages_domain_verification_failed_email(domain, recipient.user).deliver_later end end |
#pages_domain_verification_succeeded(domain) ⇒ Object
654 655 656 657 658 |
# File 'app/services/notification_service.rb', line 654 def pages_domain_verification_succeeded(domain) project_maintainers_recipients(domain, action: 'succeeded').each do |recipient| mailer.pages_domain_verification_succeeded_email(domain, recipient.user).deliver_later end end |
#pipeline_finished(pipeline, ref_status: nil, recipients: nil) ⇒ Object
623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 |
# File 'app/services/notification_service.rb', line 623 def pipeline_finished(pipeline, ref_status: nil, recipients: nil) # Must always check project configuration since recipients could be a list of emails # from the PipelinesEmailService integration. return if pipeline.project.emails_disabled? status = pipeline_notification_status(ref_status, pipeline) email_template = "pipeline_#{status}_email" return unless mailer.respond_to?(email_template) recipients ||= notifiable_users( [pipeline.user], :watch, custom_action: :"#{status}_pipeline", target: pipeline ).map do |user| user.notification_email_for(pipeline.project.group) end recipients.each do |recipient| mailer.public_send(email_template, pipeline, recipient).deliver_later end end |
#project_exported(project, current_user) ⇒ Object
611 612 613 614 615 |
# File 'app/services/notification_service.rb', line 611 def project_exported(project, current_user) return true unless notifiable?(current_user, :mention, project: project) mailer.project_was_exported_email(current_user, project).deliver_later end |
#project_not_exported(project, current_user, errors) ⇒ Object
617 618 619 620 621 |
# File 'app/services/notification_service.rb', line 617 def project_not_exported(project, current_user, errors) return true unless notifiable?(current_user, :mention, project: project) mailer.project_was_not_exported_email(current_user, project, errors).deliver_later end |
#project_was_moved(project, old_path_with_namespace) ⇒ Object
578 579 580 581 582 583 584 585 586 587 588 589 |
# File 'app/services/notification_service.rb', line 578 def project_was_moved(project, old_path_with_namespace) recipients = project_moved_recipients(project) recipients = notifiable_users(recipients, :custom, custom_action: :moved_project, project: project) recipients.each do |recipient| mailer.project_was_moved_email( project.id, recipient.id, old_path_with_namespace ).deliver_later end end |
#prometheus_alerts_fired(project, alerts) ⇒ Object
718 719 720 721 722 723 724 |
# File 'app/services/notification_service.rb', line 718 def prometheus_alerts_fired(project, alerts) return if project.emails_disabled? owners_and_maintainers_without_invites(project).to_a.product(alerts).each do |recipient, alert| mailer.prometheus_alert_fired_email(project, recipient.user, alert).deliver_later end end |
#push_to_merge_request(merge_request, current_user, new_commits: [], existing_commits: []) ⇒ Object
212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 |
# File 'app/services/notification_service.rb', line 212 def push_to_merge_request(merge_request, current_user, new_commits: [], existing_commits: []) total_new_commits_count = new_commits.count truncated_new_commits = new_commits.first(NEW_COMMIT_EMAIL_DISPLAY_LIMIT).map do |commit| { short_id: commit.short_id, title: commit.title } end # We don't need the list of all existing commits. We need the first, the # last, and the total number of existing commits only. total_existing_commits_count = existing_commits.count existing_commits = [existing_commits.first, existing_commits.last] if total_existing_commits_count > 2 existing_commits = existing_commits.map do |commit| { short_id: commit.short_id, title: commit.title } end recipients = NotificationRecipients::BuildService.build_recipients(merge_request, current_user, action: "push_to") recipients.each do |recipient| mailer.send( :push_to_merge_request_email, recipient.user.id, merge_request.id, current_user.id, recipient.reason, new_commits: truncated_new_commits, total_new_commits_count: total_new_commits_count, existing_commits: existing_commits, total_existing_commits_count: total_existing_commits_count ).deliver_later end end |
#reassigned_issue(issue, current_user, previous_assignees = []) ⇒ Object
When we reassign an issue we should send an email to:
* issue old assignees if their notification level is not Disabled
* issue new assignees if their notification level is not Disabled
* users with custom level checked with "reassign issue"
160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 |
# File 'app/services/notification_service.rb', line 160 def reassigned_issue(issue, current_user, previous_assignees = []) recipients = NotificationRecipients::BuildService.build_recipients( issue, current_user, action: "reassign", previous_assignees: previous_assignees ) previous_assignee_ids = previous_assignees.map(&:id) recipients.each do |recipient| mailer.send( :reassigned_issue_email, recipient.user.id, issue.id, previous_assignee_ids, current_user.id, recipient.reason ).deliver_later end end |
#reassigned_merge_request(merge_request, current_user, previous_assignees = []) ⇒ Object
When we reassign a merge_request we should send an email to:
* merge_request old assignees if their notification level is not Disabled
* merge_request new assignees if their notification level is not Disabled
* users with custom level checked with "reassign merge request"
280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 |
# File 'app/services/notification_service.rb', line 280 def reassigned_merge_request(merge_request, current_user, previous_assignees = []) recipients = NotificationRecipients::BuildService.build_recipients( merge_request, current_user, action: "reassign", previous_assignees: previous_assignees ) previous_assignee_ids = previous_assignees.map(&:id) recipients.each do |recipient| mailer.reassigned_merge_request_email( recipient.user.id, merge_request.id, previous_assignee_ids, current_user.id, recipient.reason ).deliver_later end end |
#relabeled_issue(issue, added_labels, current_user) ⇒ Object
When we add labels to an issue we should send an email to:
* watchers of the issue's labels
186 187 188 |
# File 'app/services/notification_service.rb', line 186 def relabeled_issue(issue, added_labels, current_user) relabeled_resource_email(issue, added_labels, current_user, :relabeled_issue_email) end |
#relabeled_merge_request(merge_request, added_labels, current_user) ⇒ Object
When we add labels to a merge request we should send an email to:
* watchers of the mr's labels
348 349 350 |
# File 'app/services/notification_service.rb', line 348 def relabeled_merge_request(merge_request, added_labels, current_user) relabeled_resource_email(merge_request, added_labels, current_user, :relabeled_merge_request_email) end |
#remote_mirror_update_failed(remote_mirror) ⇒ Object
710 711 712 713 714 715 716 |
# File 'app/services/notification_service.rb', line 710 def remote_mirror_update_failed(remote_mirror) recipients = project_maintainers_recipients(remote_mirror, action: 'update_failed') recipients.each do |recipient| mailer.remote_mirror_update_failed_email(remote_mirror.id, recipient.user.id).deliver_later end end |
#removed_milestone_issue(issue, current_user) ⇒ Object
190 191 192 |
# File 'app/services/notification_service.rb', line 190 def removed_milestone_issue(issue, current_user) removed_milestone_resource_email(issue, current_user, :removed_milestone_issue_email) end |
#removed_milestone_merge_request(merge_request, current_user) ⇒ Object
352 353 354 |
# File 'app/services/notification_service.rb', line 352 def removed_milestone_merge_request(merge_request, current_user) removed_milestone_resource_email(merge_request, current_user, :removed_milestone_merge_request_email) end |
#reopen_issue(issue, current_user) ⇒ Object
364 365 366 |
# File 'app/services/notification_service.rb', line 364 def reopen_issue(issue, current_user) reopen_resource_email(issue, current_user, :issue_status_changed_email, 'reopened') end |
#reopen_mr(merge_request, current_user) ⇒ Object
377 378 379 380 381 382 383 384 |
# File 'app/services/notification_service.rb', line 377 def reopen_mr(merge_request, current_user) reopen_resource_email( merge_request, current_user, :merge_request_status_email, 'reopened' ) end |
#repository_cleanup_failure(project, user, error) ⇒ Object
704 705 706 707 708 |
# File 'app/services/notification_service.rb', line 704 def repository_cleanup_failure(project, user, error) return if project.emails_disabled? mailer.send(:repository_cleanup_failure_email, project, user, error).deliver_later end |
#repository_cleanup_success(project, user) ⇒ Object
698 699 700 701 702 |
# File 'app/services/notification_service.rb', line 698 def repository_cleanup_success(project, user) return if project.emails_disabled? mailer.send(:repository_cleanup_success_email, project, user).deliver_later end |
#resolve_all_discussions(merge_request, current_user) ⇒ Object
386 387 388 389 390 391 392 393 394 395 |
# File 'app/services/notification_service.rb', line 386 def resolve_all_discussions(merge_request, current_user) recipients = NotificationRecipients::BuildService.build_recipients( merge_request, current_user, action: "resolve_all_discussions") recipients.each do |recipient| mailer.resolved_all_discussions_email(recipient.user.id, merge_request.id, current_user.id, recipient.reason).deliver_later end end |
#review_requested_of_merge_request(merge_request, current_user, reviewer) ⇒ Object
328 329 330 331 332 333 334 |
# File 'app/services/notification_service.rb', line 328 def review_requested_of_merge_request(merge_request, current_user, reviewer) recipients = NotificationRecipients::BuildService.build_requested_review_recipients(merge_request, current_user, reviewer) recipients.each do |recipient| mailer.request_review_merge_request_email(recipient.user.id, merge_request.id, current_user.id, recipient.reason).deliver_later end end |
#send_new_note_notifications(note) ⇒ Object
416 417 418 419 420 421 422 423 |
# File 'app/services/notification_service.rb', line 416 def send_new_note_notifications(note) notify_method = "note_#{note.noteable_ability_name}_email".to_sym recipients = NotificationRecipients::BuildService.build_new_note_recipients(note) recipients.each do |recipient| mailer.send(notify_method, recipient.user.id, note.id, recipient.reason).deliver_later end end |
#send_new_release_notifications(release) ⇒ Object
Notify users when a new release is created
444 445 446 447 448 449 450 451 452 453 454 455 |
# File 'app/services/notification_service.rb', line 444 def send_new_release_notifications(release) unless release.&.can_trigger_notifications? warn_skipping_notifications(release., release) return false end recipients = NotificationRecipients::BuildService.build_new_release_recipients(release) recipients.each do |recipient| mailer.new_release_email(recipient.user.id, release, recipient.reason).deliver_later end end |
#send_service_desk_notification(note) ⇒ Object
425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 |
# File 'app/services/notification_service.rb', line 425 def send_service_desk_notification(note) return unless note.noteable_type == 'Issue' return if note.confidential issue = note.noteable recipients = issue.email_participants_emails return unless recipients.any? support_bot = User.support_bot recipients.delete(issue.) if note. == support_bot recipients.each do |recipient| mailer.service_desk_new_note_email(issue.id, note.id, recipient).deliver_later Gitlab::Metrics::BackgroundTransaction.current&.add_event(:service_desk_new_note_email) end end |
#ssh_key_expired(user, fingerprints) ⇒ Object
Notify the user when at least one of their ssh key has expired today
91 92 93 94 95 |
# File 'app/services/notification_service.rb', line 91 def ssh_key_expired(user, fingerprints) return unless user.can?(:receive_notifications) mailer.ssh_key_expired_email(user, fingerprints).deliver_later end |
#ssh_key_expiring_soon(user, fingerprints) ⇒ Object
Notify the user when at least one of their ssh key is expiring soon
98 99 100 101 102 |
# File 'app/services/notification_service.rb', line 98 def ssh_key_expiring_soon(user, fingerprints) return unless user.can?(:receive_notifications) mailer.ssh_key_expiring_soon_email(user, fingerprints).deliver_later end |
#unapprove_mr(merge_request, current_user) ⇒ Object
768 769 770 |
# File 'app/services/notification_service.rb', line 768 def unapprove_mr(merge_request, current_user) unapprove_mr_email(merge_request, merge_request.target_project, current_user) end |
#unknown_sign_in(user, ip, time) ⇒ Object
Notify a user when a previously unknown IP or device is used to sign in to their account
106 107 108 109 110 |
# File 'app/services/notification_service.rb', line 106 def unknown_sign_in(user, ip, time) return unless user.can?(:receive_notifications) mailer.unknown_sign_in_email(user, ip, time).deliver_later end |
#update_group_member(group_member) ⇒ Object
566 567 568 569 570 |
# File 'app/services/notification_service.rb', line 566 def update_group_member(group_member) return true unless group_member.notifiable?(:mention) mailer.member_access_granted_email(group_member.real_source_type, group_member.id).deliver_later end |
#update_project_member(project_member) ⇒ Object
529 530 531 532 533 |
# File 'app/services/notification_service.rb', line 529 def update_project_member(project_member) return true unless project_member.notifiable?(:mention) mailer.member_access_granted_email(project_member.real_source_type, project_member.id).deliver_later end |
#updated_group_member_expiration(group_member) ⇒ Object
572 573 574 575 576 |
# File 'app/services/notification_service.rb', line 572 def updated_group_member_expiration(group_member) return true unless group_member.notifiable?(:mention) mailer.member_expiration_date_updated_email(group_member.real_source_type, group_member.id).deliver_later end |
#user_admin_rejection(name, email) ⇒ Object
467 468 469 |
# File 'app/services/notification_service.rb', line 467 def user_admin_rejection(name, email) mailer.user_admin_rejection_email(name, email).deliver_later end |
#user_deactivated(name, email) ⇒ Object
471 472 473 |
# File 'app/services/notification_service.rb', line 471 def user_deactivated(name, email) mailer.user_deactivated_email(name, email).deliver_later end |