Merge branch 'refactor.notification-recipient-builders' into 'master'
Refactor.notification recipient builders See merge request !13197
This commit is contained in:
commit
ee908e2382
|
@ -0,0 +1,125 @@
|
||||||
|
class NotificationRecipient
|
||||||
|
attr_reader :user, :type
|
||||||
|
def initialize(
|
||||||
|
user, type,
|
||||||
|
custom_action: nil,
|
||||||
|
target: nil,
|
||||||
|
acting_user: nil,
|
||||||
|
project: nil
|
||||||
|
)
|
||||||
|
@custom_action = custom_action
|
||||||
|
@acting_user = acting_user
|
||||||
|
@target = target
|
||||||
|
@project = project || @target&.project
|
||||||
|
@user = user
|
||||||
|
@type = type
|
||||||
|
end
|
||||||
|
|
||||||
|
def notification_setting
|
||||||
|
@notification_setting ||= find_notification_setting
|
||||||
|
end
|
||||||
|
|
||||||
|
def raw_notification_level
|
||||||
|
notification_setting&.level&.to_sym
|
||||||
|
end
|
||||||
|
|
||||||
|
def notification_level
|
||||||
|
# custom is treated the same as watch if it's enabled - otherwise it's
|
||||||
|
# set to :custom, meaning to send exactly when our type is :participating
|
||||||
|
# or :mention.
|
||||||
|
@notification_level ||=
|
||||||
|
case raw_notification_level
|
||||||
|
when :custom
|
||||||
|
if @custom_action && notification_setting&.event_enabled?(@custom_action)
|
||||||
|
:watch
|
||||||
|
else
|
||||||
|
:custom
|
||||||
|
end
|
||||||
|
else
|
||||||
|
raw_notification_level
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def notifiable?
|
||||||
|
return false unless has_access?
|
||||||
|
return false if own_activity?
|
||||||
|
|
||||||
|
return true if @type == :subscription
|
||||||
|
|
||||||
|
return false if notification_level.nil? || notification_level == :disabled
|
||||||
|
|
||||||
|
return %i[participating mention].include?(@type) if notification_level == :custom
|
||||||
|
|
||||||
|
return false if %i[watch participating].include?(notification_level) && excluded_watcher_action?
|
||||||
|
|
||||||
|
return false unless NotificationSetting.levels[notification_level] <= NotificationSetting.levels[@type]
|
||||||
|
|
||||||
|
return false if unsubscribed?
|
||||||
|
|
||||||
|
true
|
||||||
|
end
|
||||||
|
|
||||||
|
def unsubscribed?
|
||||||
|
return false unless @target
|
||||||
|
return false unless @target.respond_to?(:subscriptions)
|
||||||
|
|
||||||
|
subscription = @target.subscriptions.find_by_user_id(@user.id)
|
||||||
|
subscription && !subscription.subscribed
|
||||||
|
end
|
||||||
|
|
||||||
|
def own_activity?
|
||||||
|
return false unless @acting_user
|
||||||
|
return false if @acting_user.notified_of_own_activity?
|
||||||
|
|
||||||
|
user == @acting_user
|
||||||
|
end
|
||||||
|
|
||||||
|
def has_access?
|
||||||
|
DeclarativePolicy.subject_scope do
|
||||||
|
return false unless user.can?(:receive_notifications)
|
||||||
|
return false if @project && !user.can?(:read_project, @project)
|
||||||
|
|
||||||
|
return true unless read_ability
|
||||||
|
return true unless DeclarativePolicy.has_policy?(@target)
|
||||||
|
|
||||||
|
user.can?(read_ability, @target)
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def excluded_watcher_action?
|
||||||
|
return false unless @custom_action
|
||||||
|
return false if raw_notification_level == :custom
|
||||||
|
|
||||||
|
NotificationSetting::EXCLUDED_WATCHER_EVENTS.include?(@custom_action)
|
||||||
|
end
|
||||||
|
|
||||||
|
private
|
||||||
|
|
||||||
|
def read_ability
|
||||||
|
return @read_ability if instance_variable_defined?(:@read_ability)
|
||||||
|
|
||||||
|
@read_ability =
|
||||||
|
case @target
|
||||||
|
when Issuable
|
||||||
|
:"read_#{@target.to_ability_name}"
|
||||||
|
when Ci::Pipeline
|
||||||
|
:read_build # We have build trace in pipeline emails
|
||||||
|
when ActiveRecord::Base
|
||||||
|
:"read_#{@target.class.model_name.name.underscore}"
|
||||||
|
else
|
||||||
|
nil
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def find_notification_setting
|
||||||
|
project_setting = @project && user.notification_settings_for(@project)
|
||||||
|
|
||||||
|
return project_setting unless project_setting.nil? || project_setting.global?
|
||||||
|
|
||||||
|
group_setting = @project&.group && user.notification_settings_for(@project.group)
|
||||||
|
|
||||||
|
return group_setting unless group_setting.nil? || group_setting.global?
|
||||||
|
|
||||||
|
user.global_notification_setting
|
||||||
|
end
|
||||||
|
end
|
|
@ -1,331 +1,288 @@
|
||||||
#
|
#
|
||||||
# Used by NotificationService to determine who should receive notification
|
# Used by NotificationService to determine who should receive notification
|
||||||
#
|
#
|
||||||
class NotificationRecipientService
|
module NotificationRecipientService
|
||||||
attr_reader :project
|
def self.notifiable_users(users, *args)
|
||||||
|
users.compact.map { |u| NotificationRecipient.new(u, *args) }.select(&:notifiable?).map(&:user)
|
||||||
def initialize(project)
|
|
||||||
@project = project
|
|
||||||
end
|
end
|
||||||
|
|
||||||
def build_recipients(target, current_user, action:, previous_assignee: nil, skip_current_user: true)
|
def self.notifiable?(user, *args)
|
||||||
custom_action = build_custom_key(action, target)
|
NotificationRecipient.new(user, *args).notifiable?
|
||||||
|
|
||||||
recipients = participants(target, current_user)
|
|
||||||
recipients = add_project_watchers(recipients)
|
|
||||||
recipients = add_custom_notifications(recipients, custom_action)
|
|
||||||
recipients = reject_mention_users(recipients)
|
|
||||||
|
|
||||||
# Re-assign is considered as a mention of the new assignee so we add the
|
|
||||||
# new assignee to the list of recipients after we rejected users with
|
|
||||||
# the "on mention" notification level
|
|
||||||
case custom_action
|
|
||||||
when :reassign_merge_request
|
|
||||||
recipients << previous_assignee if previous_assignee
|
|
||||||
recipients << target.assignee
|
|
||||||
when :reassign_issue
|
|
||||||
previous_assignees = Array(previous_assignee)
|
|
||||||
recipients.concat(previous_assignees)
|
|
||||||
recipients.concat(target.assignees)
|
|
||||||
end
|
|
||||||
|
|
||||||
recipients = reject_muted_users(recipients)
|
|
||||||
recipients = add_subscribed_users(recipients, target)
|
|
||||||
|
|
||||||
if [:new_issue, :new_merge_request].include?(custom_action)
|
|
||||||
recipients = add_labels_subscribers(recipients, target)
|
|
||||||
end
|
|
||||||
|
|
||||||
recipients = reject_unsubscribed_users(recipients, target)
|
|
||||||
recipients = reject_users_without_access(recipients, target)
|
|
||||||
|
|
||||||
recipients.delete(current_user) if skip_current_user && !current_user.notified_of_own_activity?
|
|
||||||
|
|
||||||
recipients.uniq
|
|
||||||
end
|
end
|
||||||
|
|
||||||
def build_pipeline_recipients(target, current_user, action:)
|
def self.build_recipients(*a)
|
||||||
return [] unless current_user
|
Builder::Default.new(*a).recipient_users
|
||||||
|
end
|
||||||
|
|
||||||
custom_action =
|
def self.build_new_note_recipients(*a)
|
||||||
case action.to_s
|
Builder::NewNote.new(*a).recipient_users
|
||||||
when 'failed'
|
end
|
||||||
:failed_pipeline
|
|
||||||
when 'success'
|
module Builder
|
||||||
:success_pipeline
|
class Base
|
||||||
|
def initialize(*)
|
||||||
|
raise 'abstract'
|
||||||
end
|
end
|
||||||
|
|
||||||
notification_setting = notification_setting_for_user_project(current_user, target.project)
|
def build!
|
||||||
|
raise 'abstract'
|
||||||
|
end
|
||||||
|
|
||||||
return [] if notification_setting.mention? || notification_setting.disabled?
|
def filter!
|
||||||
|
recipients.select!(&:notifiable?)
|
||||||
|
end
|
||||||
|
|
||||||
return [] if notification_setting.custom? && !notification_setting.event_enabled?(custom_action)
|
def acting_user
|
||||||
|
current_user
|
||||||
|
end
|
||||||
|
|
||||||
return [] if (notification_setting.watch? || notification_setting.participating?) && NotificationSetting::EXCLUDED_WATCHER_EVENTS.include?(custom_action)
|
def target
|
||||||
|
raise 'abstract'
|
||||||
|
end
|
||||||
|
|
||||||
reject_users_without_access([current_user], target)
|
# rubocop:disable Rails/Delegate
|
||||||
end
|
def project
|
||||||
|
target.project
|
||||||
|
end
|
||||||
|
|
||||||
def build_relabeled_recipients(target, current_user, labels:)
|
def recipients
|
||||||
recipients = add_labels_subscribers([], target, labels: labels)
|
@recipients ||= []
|
||||||
recipients = reject_unsubscribed_users(recipients, target)
|
end
|
||||||
recipients = reject_users_without_access(recipients, target)
|
|
||||||
recipients.delete(current_user) unless current_user.notified_of_own_activity?
|
|
||||||
recipients.uniq
|
|
||||||
end
|
|
||||||
|
|
||||||
def build_new_note_recipients(note)
|
def <<(pair)
|
||||||
target = note.noteable
|
users, type = pair
|
||||||
|
|
||||||
ability, subject = if note.for_personal_snippet?
|
if users.is_a?(ActiveRecord::Relation)
|
||||||
[:read_personal_snippet, note.noteable]
|
users = users.includes(:notification_settings)
|
||||||
else
|
end
|
||||||
[:read_project, note.project]
|
|
||||||
end
|
|
||||||
|
|
||||||
mentioned_users = note.mentioned_users.select { |user| user.can?(ability, subject) }
|
users = Array(users)
|
||||||
|
users.compact!
|
||||||
|
recipients.concat(users.map { |u| make_recipient(u, type) })
|
||||||
|
end
|
||||||
|
|
||||||
# Add all users participating in the thread (author, assignee, comment authors)
|
def user_scope
|
||||||
recipients = participants(target, note.author) || mentioned_users
|
User.includes(:notification_settings)
|
||||||
|
end
|
||||||
|
|
||||||
unless note.for_personal_snippet?
|
def make_recipient(user, type)
|
||||||
# Merge project watchers
|
NotificationRecipient.new(
|
||||||
recipients = add_project_watchers(recipients)
|
user, type,
|
||||||
|
project: project,
|
||||||
|
custom_action: custom_action,
|
||||||
|
target: target,
|
||||||
|
acting_user: acting_user
|
||||||
|
)
|
||||||
|
end
|
||||||
|
|
||||||
# Merge project with custom notification
|
def recipient_users
|
||||||
recipients = add_custom_notifications(recipients, :new_note)
|
@recipient_users ||=
|
||||||
end
|
begin
|
||||||
|
build!
|
||||||
|
filter!
|
||||||
|
users = recipients.map(&:user)
|
||||||
|
users.uniq!
|
||||||
|
users.freeze
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
# Reject users with Mention notification level, except those mentioned in _this_ note.
|
def custom_action
|
||||||
recipients = reject_mention_users(recipients - mentioned_users)
|
nil
|
||||||
recipients = recipients + mentioned_users
|
end
|
||||||
|
|
||||||
recipients = reject_muted_users(recipients)
|
protected
|
||||||
|
|
||||||
recipients = add_subscribed_users(recipients, note.noteable)
|
def add_participants(user)
|
||||||
recipients = reject_unsubscribed_users(recipients, note.noteable)
|
return unless target.respond_to?(:participants)
|
||||||
recipients = reject_users_without_access(recipients, note.noteable)
|
|
||||||
|
|
||||||
recipients.delete(note.author) unless note.author.notified_of_own_activity?
|
self << [target.participants(user), :watch]
|
||||||
recipients.uniq
|
end
|
||||||
end
|
|
||||||
|
|
||||||
# Remove users with disabled notifications from array
|
# Get project/group users with CUSTOM notification level
|
||||||
# Also remove duplications and nil recipients
|
def add_custom_notifications
|
||||||
def reject_muted_users(users)
|
user_ids = []
|
||||||
reject_users(users, :disabled)
|
|
||||||
end
|
|
||||||
|
|
||||||
protected
|
# Users with a notification setting on group or project
|
||||||
|
user_ids += user_ids_notifiable_on(project, :custom)
|
||||||
|
user_ids += user_ids_notifiable_on(project.group, :custom)
|
||||||
|
|
||||||
# Ensure that if we modify this array, we aren't modifying the memoised
|
# Users with global level custom
|
||||||
# participants on the target.
|
user_ids_with_project_level_global = user_ids_notifiable_on(project, :global)
|
||||||
def participants(target, user)
|
user_ids_with_group_level_global = user_ids_notifiable_on(project.group, :global)
|
||||||
return unless target.respond_to?(:participants)
|
|
||||||
|
|
||||||
target.participants(user).dup
|
global_users_ids = user_ids_with_project_level_global.concat(user_ids_with_group_level_global)
|
||||||
end
|
user_ids += user_ids_with_global_level_custom(global_users_ids, custom_action)
|
||||||
|
|
||||||
# Get project/group users with CUSTOM notification level
|
self << [user_scope.where(id: user_ids), :watch]
|
||||||
def add_custom_notifications(recipients, action)
|
end
|
||||||
user_ids = []
|
|
||||||
|
|
||||||
# Users with a notification setting on group or project
|
def add_project_watchers
|
||||||
user_ids += user_ids_notifiable_on(project, :custom, action)
|
self << [project_watchers, :watch]
|
||||||
user_ids += user_ids_notifiable_on(project.group, :custom, action)
|
end
|
||||||
|
|
||||||
# Users with global level custom
|
# Get project users with WATCH notification level
|
||||||
user_ids_with_project_level_global = user_ids_notifiable_on(project, :global)
|
def project_watchers
|
||||||
user_ids_with_group_level_global = user_ids_notifiable_on(project.group, :global)
|
project_members_ids = user_ids_notifiable_on(project)
|
||||||
|
|
||||||
global_users_ids = user_ids_with_project_level_global.concat(user_ids_with_group_level_global)
|
user_ids_with_project_global = user_ids_notifiable_on(project, :global)
|
||||||
user_ids += user_ids_with_global_level_custom(global_users_ids, action)
|
user_ids_with_group_global = user_ids_notifiable_on(project.group, :global)
|
||||||
|
|
||||||
recipients.concat(User.find(user_ids))
|
user_ids = user_ids_with_global_level_watch((user_ids_with_project_global + user_ids_with_group_global).uniq)
|
||||||
end
|
|
||||||
|
|
||||||
def add_project_watchers(recipients)
|
user_ids_with_project_setting = select_project_members_ids(user_ids_with_project_global, user_ids)
|
||||||
recipients.concat(project_watchers).compact
|
user_ids_with_group_setting = select_group_members_ids(project.group, project_members_ids, user_ids_with_group_global, user_ids)
|
||||||
end
|
|
||||||
|
|
||||||
# Get project users with WATCH notification level
|
user_scope.where(id: user_ids_with_project_setting.concat(user_ids_with_group_setting).uniq)
|
||||||
def project_watchers
|
end
|
||||||
project_members_ids = user_ids_notifiable_on(project)
|
|
||||||
|
|
||||||
user_ids_with_project_global = user_ids_notifiable_on(project, :global)
|
def add_subscribed_users
|
||||||
user_ids_with_group_global = user_ids_notifiable_on(project.group, :global)
|
return unless target.respond_to? :subscribers
|
||||||
|
|
||||||
user_ids = user_ids_with_global_level_watch((user_ids_with_project_global + user_ids_with_group_global).uniq)
|
self << [target.subscribers(project), :subscription]
|
||||||
|
end
|
||||||
|
|
||||||
user_ids_with_project_setting = select_project_members_ids(project, user_ids_with_project_global, user_ids)
|
def user_ids_notifiable_on(resource, notification_level = nil)
|
||||||
user_ids_with_group_setting = select_group_members_ids(project.group, project_members_ids, user_ids_with_group_global, user_ids)
|
return [] unless resource
|
||||||
|
|
||||||
User.where(id: user_ids_with_project_setting.concat(user_ids_with_group_setting).uniq).to_a
|
scope = resource.notification_settings
|
||||||
end
|
|
||||||
|
|
||||||
# Remove users with notification level 'Mentioned'
|
if notification_level
|
||||||
def reject_mention_users(users)
|
scope = scope.where(level: NotificationSetting.levels[notification_level])
|
||||||
reject_users(users, :mention)
|
end
|
||||||
end
|
|
||||||
|
|
||||||
def add_subscribed_users(recipients, target)
|
scope.pluck(:user_id)
|
||||||
return recipients unless target.respond_to? :subscribers
|
end
|
||||||
|
|
||||||
recipients + target.subscribers(project)
|
# Build a list of user_ids based on project notification settings
|
||||||
end
|
def select_project_members_ids(global_setting, user_ids_global_level_watch)
|
||||||
|
user_ids = user_ids_notifiable_on(project, :watch)
|
||||||
|
|
||||||
def user_ids_notifiable_on(resource, notification_level = nil, action = nil)
|
# If project setting is global, add to watch list if global setting is watch
|
||||||
return [] unless resource
|
user_ids + (global_setting & user_ids_global_level_watch)
|
||||||
|
end
|
||||||
|
|
||||||
if notification_level
|
# Build a list of user_ids based on group notification settings
|
||||||
settings = resource.notification_settings.where(level: NotificationSetting.levels[notification_level])
|
def select_group_members_ids(group, project_members, global_setting, user_ids_global_level_watch)
|
||||||
settings = settings.select { |setting| setting.event_enabled?(action) } if action.present?
|
uids = user_ids_notifiable_on(group, :watch)
|
||||||
settings.map(&:user_id)
|
|
||||||
else
|
|
||||||
resource.notification_settings.pluck(:user_id)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
# Build a list of user_ids based on project notification settings
|
# Group setting is global, add to user_ids list if global setting is watch
|
||||||
def select_project_members_ids(project, global_setting, user_ids_global_level_watch)
|
uids + (global_setting & user_ids_global_level_watch) - project_members
|
||||||
user_ids = user_ids_notifiable_on(project, :watch)
|
end
|
||||||
|
|
||||||
# If project setting is global, add to watch list if global setting is watch
|
def user_ids_with_global_level_watch(ids)
|
||||||
global_setting.each do |user_id|
|
settings_with_global_level_of(:watch, ids).pluck(:user_id)
|
||||||
if user_ids_global_level_watch.include?(user_id)
|
end
|
||||||
user_ids << user_id
|
|
||||||
|
def user_ids_with_global_level_custom(ids, action)
|
||||||
|
settings_with_global_level_of(:custom, ids).pluck(:user_id)
|
||||||
|
end
|
||||||
|
|
||||||
|
def settings_with_global_level_of(level, ids)
|
||||||
|
NotificationSetting.where(
|
||||||
|
user_id: ids,
|
||||||
|
source_type: nil,
|
||||||
|
level: NotificationSetting.levels[level]
|
||||||
|
)
|
||||||
|
end
|
||||||
|
|
||||||
|
def add_labels_subscribers(labels: nil)
|
||||||
|
return unless target.respond_to? :labels
|
||||||
|
|
||||||
|
(labels || target.labels).each do |label|
|
||||||
|
self << [label.subscribers(project), :subscription]
|
||||||
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
user_ids
|
class Default < Base
|
||||||
end
|
attr_reader :target
|
||||||
|
attr_reader :current_user
|
||||||
|
attr_reader :action
|
||||||
|
attr_reader :previous_assignee
|
||||||
|
attr_reader :skip_current_user
|
||||||
|
def initialize(target, current_user, action:, previous_assignee: nil, skip_current_user: true)
|
||||||
|
@target = target
|
||||||
|
@current_user = current_user
|
||||||
|
@action = action
|
||||||
|
@previous_assignee = previous_assignee
|
||||||
|
@skip_current_user = skip_current_user
|
||||||
|
end
|
||||||
|
|
||||||
# Build a list of user_ids based on group notification settings
|
def build!
|
||||||
def select_group_members_ids(group, project_members, global_setting, user_ids_global_level_watch)
|
add_participants(current_user)
|
||||||
uids = user_ids_notifiable_on(group, :watch)
|
add_project_watchers
|
||||||
|
add_custom_notifications
|
||||||
|
|
||||||
# Group setting is watch, add to user_ids list if user is not project member
|
# Re-assign is considered as a mention of the new assignee
|
||||||
user_ids = []
|
case custom_action
|
||||||
uids.each do |user_id|
|
when :reassign_merge_request
|
||||||
if project_members.exclude?(user_id)
|
self << [previous_assignee, :mention]
|
||||||
user_ids << user_id
|
self << [target.assignee, :mention]
|
||||||
|
when :reassign_issue
|
||||||
|
previous_assignees = Array(previous_assignee)
|
||||||
|
self << [previous_assignees, :mention]
|
||||||
|
self << [target.assignees, :mention]
|
||||||
|
end
|
||||||
|
|
||||||
|
add_subscribed_users
|
||||||
|
|
||||||
|
if [:new_issue, :new_merge_request].include?(custom_action)
|
||||||
|
add_labels_subscribers
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
def acting_user
|
||||||
|
current_user if skip_current_user
|
||||||
|
end
|
||||||
|
|
||||||
|
# Build event key to search on custom notification level
|
||||||
|
# Check NotificationSetting::EMAIL_EVENTS
|
||||||
|
def custom_action
|
||||||
|
@custom_action ||= "#{action}_#{target.class.model_name.name.underscore}".to_sym
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
# Group setting is global, add to user_ids list if global setting is watch
|
class NewNote < Base
|
||||||
global_setting.each do |user_id|
|
attr_reader :note
|
||||||
if project_members.exclude?(user_id) && user_ids_global_level_watch.include?(user_id)
|
def initialize(note)
|
||||||
user_ids << user_id
|
@note = note
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
user_ids
|
|
||||||
end
|
|
||||||
|
|
||||||
def user_ids_with_global_level_watch(ids)
|
|
||||||
settings_with_global_level_of(:watch, ids).pluck(:user_id)
|
|
||||||
end
|
|
||||||
|
|
||||||
def user_ids_with_global_level_custom(ids, action)
|
|
||||||
settings = settings_with_global_level_of(:custom, ids)
|
|
||||||
settings = settings.select { |setting| setting.event_enabled?(action) }
|
|
||||||
settings.map(&:user_id)
|
|
||||||
end
|
|
||||||
|
|
||||||
def settings_with_global_level_of(level, ids)
|
|
||||||
NotificationSetting.where(
|
|
||||||
user_id: ids,
|
|
||||||
source_type: nil,
|
|
||||||
level: NotificationSetting.levels[level]
|
|
||||||
)
|
|
||||||
end
|
|
||||||
|
|
||||||
# Reject users which has certain notification level
|
|
||||||
#
|
|
||||||
# Example:
|
|
||||||
# reject_users(users, :watch, project)
|
|
||||||
#
|
|
||||||
def reject_users(users, level)
|
|
||||||
level = level.to_s
|
|
||||||
|
|
||||||
unless NotificationSetting.levels.keys.include?(level)
|
|
||||||
raise 'Invalid notification level'
|
|
||||||
end
|
|
||||||
|
|
||||||
users = users.to_a.compact.uniq
|
|
||||||
users = users.select { |u| u.can?(:receive_notifications) }
|
|
||||||
|
|
||||||
users.reject do |user|
|
|
||||||
global_notification_setting = user.global_notification_setting
|
|
||||||
|
|
||||||
next global_notification_setting.level == level unless project
|
|
||||||
|
|
||||||
setting = user.notification_settings_for(project)
|
|
||||||
|
|
||||||
if project.group && (setting.nil? || setting.global?)
|
|
||||||
setting = user.notification_settings_for(project.group)
|
|
||||||
end
|
end
|
||||||
|
|
||||||
# reject users who globally set mention notification and has no setting per project/group
|
def target
|
||||||
next global_notification_setting.level == level unless setting
|
note.noteable
|
||||||
|
end
|
||||||
|
|
||||||
# reject users who set mention notification in project
|
# NOTE: may be nil, in the case of a PersonalSnippet
|
||||||
next true if setting.level == level
|
#
|
||||||
|
# (this is okay because NotificationRecipient is written
|
||||||
|
# to handle nil projects)
|
||||||
|
def project
|
||||||
|
note.project
|
||||||
|
end
|
||||||
|
|
||||||
# reject users who have mention level in project and disabled in global settings
|
def build!
|
||||||
setting.global? && global_notification_setting.level == level
|
# Add all users participating in the thread (author, assignee, comment authors)
|
||||||
|
add_participants(note.author)
|
||||||
|
self << [note.mentioned_users, :mention]
|
||||||
|
|
||||||
|
unless note.for_personal_snippet?
|
||||||
|
# Merge project watchers
|
||||||
|
add_project_watchers
|
||||||
|
|
||||||
|
# Merge project with custom notification
|
||||||
|
add_custom_notifications
|
||||||
|
end
|
||||||
|
|
||||||
|
add_subscribed_users
|
||||||
|
end
|
||||||
|
|
||||||
|
def custom_action
|
||||||
|
:new_note
|
||||||
|
end
|
||||||
|
|
||||||
|
def acting_user
|
||||||
|
note.author
|
||||||
|
end
|
||||||
end
|
end
|
||||||
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 reject_users_without_access(recipients, target)
|
|
||||||
ability = case target
|
|
||||||
when Issuable
|
|
||||||
:"read_#{target.to_ability_name}"
|
|
||||||
when Ci::Pipeline
|
|
||||||
:read_build # We have build trace in pipeline emails
|
|
||||||
end
|
|
||||||
|
|
||||||
return recipients unless ability
|
|
||||||
|
|
||||||
recipients.select do |user|
|
|
||||||
user.can?(ability, target)
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
def add_labels_subscribers(recipients, target, labels: nil)
|
|
||||||
return recipients unless target.respond_to? :labels
|
|
||||||
|
|
||||||
(labels || target.labels).each do |label|
|
|
||||||
recipients += label.subscribers(project)
|
|
||||||
end
|
|
||||||
|
|
||||||
recipients
|
|
||||||
end
|
|
||||||
|
|
||||||
# Build event key to search on custom notification level
|
|
||||||
# Check NotificationSetting::EMAIL_EVENTS
|
|
||||||
def build_custom_key(action, object)
|
|
||||||
"#{action}_#{object.class.model_name.name.underscore}".to_sym
|
|
||||||
end
|
|
||||||
|
|
||||||
def notification_setting_for_user_project(user, project)
|
|
||||||
project_setting = user.notification_settings_for(project)
|
|
||||||
|
|
||||||
return project_setting unless project_setting.global?
|
|
||||||
|
|
||||||
group_setting = user.notification_settings_for(project.group)
|
|
||||||
|
|
||||||
return group_setting unless group_setting.global?
|
|
||||||
|
|
||||||
user.global_notification_setting
|
|
||||||
end
|
|
||||||
end
|
end
|
||||||
|
|
|
@ -42,7 +42,7 @@ class NotificationService
|
||||||
# * users with custom level checked with "new issue"
|
# * users with custom level checked with "new issue"
|
||||||
#
|
#
|
||||||
def new_issue(issue, current_user)
|
def new_issue(issue, current_user)
|
||||||
new_resource_email(issue, issue.project, :new_issue_email)
|
new_resource_email(issue, :new_issue_email)
|
||||||
end
|
end
|
||||||
|
|
||||||
# When issue text is updated, we should send an email to:
|
# When issue text is updated, we should send an email to:
|
||||||
|
@ -52,7 +52,6 @@ class NotificationService
|
||||||
def new_mentions_in_issue(issue, new_mentioned_users, current_user)
|
def new_mentions_in_issue(issue, new_mentioned_users, current_user)
|
||||||
new_mentions_in_resource_email(
|
new_mentions_in_resource_email(
|
||||||
issue,
|
issue,
|
||||||
issue.project,
|
|
||||||
new_mentioned_users,
|
new_mentioned_users,
|
||||||
current_user,
|
current_user,
|
||||||
:new_mention_in_issue_email
|
:new_mention_in_issue_email
|
||||||
|
@ -67,7 +66,7 @@ class NotificationService
|
||||||
# * users with custom level checked with "close issue"
|
# * users with custom level checked with "close issue"
|
||||||
#
|
#
|
||||||
def close_issue(issue, current_user)
|
def close_issue(issue, current_user)
|
||||||
close_resource_email(issue, issue.project, current_user, :closed_issue_email)
|
close_resource_email(issue, current_user, :closed_issue_email)
|
||||||
end
|
end
|
||||||
|
|
||||||
# When we reassign an issue we should send an email to:
|
# When we reassign an issue we should send an email to:
|
||||||
|
@ -77,7 +76,7 @@ class NotificationService
|
||||||
# * users with custom level checked with "reassign issue"
|
# * users with custom level checked with "reassign issue"
|
||||||
#
|
#
|
||||||
def reassigned_issue(issue, current_user, previous_assignees = [])
|
def reassigned_issue(issue, current_user, previous_assignees = [])
|
||||||
recipients = NotificationRecipientService.new(issue.project).build_recipients(
|
recipients = NotificationRecipientService.build_recipients(
|
||||||
issue,
|
issue,
|
||||||
current_user,
|
current_user,
|
||||||
action: "reassign",
|
action: "reassign",
|
||||||
|
@ -102,7 +101,7 @@ class NotificationService
|
||||||
# * watchers of the issue's labels
|
# * watchers of the issue's labels
|
||||||
#
|
#
|
||||||
def relabeled_issue(issue, added_labels, current_user)
|
def relabeled_issue(issue, added_labels, current_user)
|
||||||
relabeled_resource_email(issue, issue.project, added_labels, current_user, :relabeled_issue_email)
|
relabeled_resource_email(issue, added_labels, current_user, :relabeled_issue_email)
|
||||||
end
|
end
|
||||||
|
|
||||||
# When create a merge request we should send an email to:
|
# When create a merge request we should send an email to:
|
||||||
|
@ -113,7 +112,7 @@ class NotificationService
|
||||||
# * users with custom level checked with "new merge request"
|
# * users with custom level checked with "new merge request"
|
||||||
#
|
#
|
||||||
def new_merge_request(merge_request, current_user)
|
def new_merge_request(merge_request, current_user)
|
||||||
new_resource_email(merge_request, merge_request.target_project, :new_merge_request_email)
|
new_resource_email(merge_request, :new_merge_request_email)
|
||||||
end
|
end
|
||||||
|
|
||||||
# When merge request text is updated, we should send an email to:
|
# When merge request text is updated, we should send an email to:
|
||||||
|
@ -123,7 +122,6 @@ class NotificationService
|
||||||
def new_mentions_in_merge_request(merge_request, new_mentioned_users, current_user)
|
def new_mentions_in_merge_request(merge_request, new_mentioned_users, current_user)
|
||||||
new_mentions_in_resource_email(
|
new_mentions_in_resource_email(
|
||||||
merge_request,
|
merge_request,
|
||||||
merge_request.target_project,
|
|
||||||
new_mentioned_users,
|
new_mentioned_users,
|
||||||
current_user,
|
current_user,
|
||||||
:new_mention_in_merge_request_email
|
:new_mention_in_merge_request_email
|
||||||
|
@ -137,7 +135,7 @@ class NotificationService
|
||||||
# * users with custom level checked with "reassign merge request"
|
# * users with custom level checked with "reassign merge request"
|
||||||
#
|
#
|
||||||
def reassigned_merge_request(merge_request, current_user)
|
def reassigned_merge_request(merge_request, current_user)
|
||||||
reassign_resource_email(merge_request, merge_request.target_project, current_user, :reassigned_merge_request_email)
|
reassign_resource_email(merge_request, current_user, :reassigned_merge_request_email)
|
||||||
end
|
end
|
||||||
|
|
||||||
# When we add labels to a merge request we should send an email to:
|
# When we add labels to a merge request we should send an email to:
|
||||||
|
@ -145,21 +143,20 @@ class NotificationService
|
||||||
# * watchers of the mr's labels
|
# * watchers of the mr's labels
|
||||||
#
|
#
|
||||||
def relabeled_merge_request(merge_request, added_labels, current_user)
|
def relabeled_merge_request(merge_request, added_labels, current_user)
|
||||||
relabeled_resource_email(merge_request, merge_request.target_project, added_labels, current_user, :relabeled_merge_request_email)
|
relabeled_resource_email(merge_request, added_labels, current_user, :relabeled_merge_request_email)
|
||||||
end
|
end
|
||||||
|
|
||||||
def close_mr(merge_request, current_user)
|
def close_mr(merge_request, current_user)
|
||||||
close_resource_email(merge_request, merge_request.target_project, current_user, :closed_merge_request_email)
|
close_resource_email(merge_request, current_user, :closed_merge_request_email)
|
||||||
end
|
end
|
||||||
|
|
||||||
def reopen_issue(issue, current_user)
|
def reopen_issue(issue, current_user)
|
||||||
reopen_resource_email(issue, issue.project, current_user, :issue_status_changed_email, 'reopened')
|
reopen_resource_email(issue, current_user, :issue_status_changed_email, 'reopened')
|
||||||
end
|
end
|
||||||
|
|
||||||
def merge_mr(merge_request, current_user)
|
def merge_mr(merge_request, current_user)
|
||||||
close_resource_email(
|
close_resource_email(
|
||||||
merge_request,
|
merge_request,
|
||||||
merge_request.target_project,
|
|
||||||
current_user,
|
current_user,
|
||||||
:merged_merge_request_email,
|
:merged_merge_request_email,
|
||||||
skip_current_user: !merge_request.merge_when_pipeline_succeeds?
|
skip_current_user: !merge_request.merge_when_pipeline_succeeds?
|
||||||
|
@ -169,7 +166,6 @@ class NotificationService
|
||||||
def reopen_mr(merge_request, current_user)
|
def reopen_mr(merge_request, current_user)
|
||||||
reopen_resource_email(
|
reopen_resource_email(
|
||||||
merge_request,
|
merge_request,
|
||||||
merge_request.target_project,
|
|
||||||
current_user,
|
current_user,
|
||||||
:merge_request_status_email,
|
:merge_request_status_email,
|
||||||
'reopened'
|
'reopened'
|
||||||
|
@ -177,7 +173,7 @@ class NotificationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def resolve_all_discussions(merge_request, current_user)
|
def resolve_all_discussions(merge_request, current_user)
|
||||||
recipients = NotificationRecipientService.new(merge_request.target_project).build_recipients(
|
recipients = NotificationRecipientService.build_recipients(
|
||||||
merge_request,
|
merge_request,
|
||||||
current_user,
|
current_user,
|
||||||
action: "resolve_all_discussions")
|
action: "resolve_all_discussions")
|
||||||
|
@ -202,7 +198,7 @@ class NotificationService
|
||||||
|
|
||||||
notify_method = "note_#{note.to_ability_name}_email".to_sym
|
notify_method = "note_#{note.to_ability_name}_email".to_sym
|
||||||
|
|
||||||
recipients = NotificationRecipientService.new(note.project).build_new_note_recipients(note)
|
recipients = NotificationRecipientService.build_new_note_recipients(note)
|
||||||
recipients.each do |recipient|
|
recipients.each do |recipient|
|
||||||
mailer.send(notify_method, recipient.id, note.id).deliver_later
|
mailer.send(notify_method, recipient.id, note.id).deliver_later
|
||||||
end
|
end
|
||||||
|
@ -270,8 +266,7 @@ class NotificationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def project_was_moved(project, old_path_with_namespace)
|
def project_was_moved(project, old_path_with_namespace)
|
||||||
recipients = project.team.members
|
recipients = NotificationRecipientService.notifiable_users(project.team.members, :mention, project: project)
|
||||||
recipients = NotificationRecipientService.new(project).reject_muted_users(recipients)
|
|
||||||
|
|
||||||
recipients.each do |recipient|
|
recipients.each do |recipient|
|
||||||
mailer.project_was_moved_email(
|
mailer.project_was_moved_email(
|
||||||
|
@ -283,7 +278,7 @@ class NotificationService
|
||||||
end
|
end
|
||||||
|
|
||||||
def issue_moved(issue, new_issue, current_user)
|
def issue_moved(issue, new_issue, current_user)
|
||||||
recipients = NotificationRecipientService.new(issue.project).build_recipients(issue, current_user, action: 'moved')
|
recipients = NotificationRecipientService.build_recipients(issue, current_user, action: 'moved')
|
||||||
|
|
||||||
recipients.map do |recipient|
|
recipients.map do |recipient|
|
||||||
email = mailer.issue_moved_email(recipient, issue, new_issue, current_user)
|
email = mailer.issue_moved_email(recipient, issue, new_issue, current_user)
|
||||||
|
@ -305,10 +300,10 @@ class NotificationService
|
||||||
|
|
||||||
return unless mailer.respond_to?(email_template)
|
return unless mailer.respond_to?(email_template)
|
||||||
|
|
||||||
recipients ||= NotificationRecipientService.new(pipeline.project).build_pipeline_recipients(
|
recipients ||= NotificationRecipientService.notifiable_users(
|
||||||
pipeline,
|
[pipeline.user], :watch,
|
||||||
pipeline.user,
|
custom_action: :"#{pipeline.status}_pipeline",
|
||||||
action: pipeline.status
|
target: pipeline
|
||||||
).map(&:notification_email)
|
).map(&:notification_email)
|
||||||
|
|
||||||
if recipients.any?
|
if recipients.any?
|
||||||
|
@ -318,16 +313,16 @@ class NotificationService
|
||||||
|
|
||||||
protected
|
protected
|
||||||
|
|
||||||
def new_resource_email(target, project, method)
|
def new_resource_email(target, method)
|
||||||
recipients = NotificationRecipientService.new(project).build_recipients(target, target.author, action: "new")
|
recipients = NotificationRecipientService.build_recipients(target, target.author, action: "new")
|
||||||
|
|
||||||
recipients.each do |recipient|
|
recipients.each do |recipient|
|
||||||
mailer.send(method, recipient.id, target.id).deliver_later
|
mailer.send(method, recipient.id, target.id).deliver_later
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def new_mentions_in_resource_email(target, project, new_mentioned_users, current_user, method)
|
def new_mentions_in_resource_email(target, new_mentioned_users, current_user, method)
|
||||||
recipients = NotificationRecipientService.new(project).build_recipients(target, current_user, action: "new")
|
recipients = NotificationRecipientService.build_recipients(target, current_user, action: "new")
|
||||||
recipients = recipients & new_mentioned_users
|
recipients = recipients & new_mentioned_users
|
||||||
|
|
||||||
recipients.each do |recipient|
|
recipients.each do |recipient|
|
||||||
|
@ -335,10 +330,10 @@ class NotificationService
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def close_resource_email(target, project, current_user, method, skip_current_user: true)
|
def close_resource_email(target, current_user, method, skip_current_user: true)
|
||||||
action = method == :merged_merge_request_email ? "merge" : "close"
|
action = method == :merged_merge_request_email ? "merge" : "close"
|
||||||
|
|
||||||
recipients = NotificationRecipientService.new(project).build_recipients(
|
recipients = NotificationRecipientService.build_recipients(
|
||||||
target,
|
target,
|
||||||
current_user,
|
current_user,
|
||||||
action: action,
|
action: action,
|
||||||
|
@ -350,11 +345,11 @@ class NotificationService
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def reassign_resource_email(target, project, current_user, method)
|
def reassign_resource_email(target, current_user, method)
|
||||||
previous_assignee_id = previous_record(target, 'assignee_id')
|
previous_assignee_id = previous_record(target, 'assignee_id')
|
||||||
previous_assignee = User.find_by(id: previous_assignee_id) if previous_assignee_id
|
previous_assignee = User.find_by(id: previous_assignee_id) if previous_assignee_id
|
||||||
|
|
||||||
recipients = NotificationRecipientService.new(project).build_recipients(
|
recipients = NotificationRecipientService.build_recipients(
|
||||||
target,
|
target,
|
||||||
current_user,
|
current_user,
|
||||||
action: "reassign",
|
action: "reassign",
|
||||||
|
@ -372,8 +367,14 @@ class NotificationService
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def relabeled_resource_email(target, project, labels, current_user, method)
|
def relabeled_resource_email(target, labels, current_user, method)
|
||||||
recipients = NotificationRecipientService.new(project).build_relabeled_recipients(target, current_user, labels: labels)
|
recipients = labels.flat_map { |l| l.subscribers(target.project) }
|
||||||
|
recipients = NotificationRecipientService.notifiable_users(
|
||||||
|
recipients, :subscription,
|
||||||
|
target: target,
|
||||||
|
acting_user: current_user
|
||||||
|
)
|
||||||
|
|
||||||
label_names = labels.map(&:name)
|
label_names = labels.map(&:name)
|
||||||
|
|
||||||
recipients.each do |recipient|
|
recipients.each do |recipient|
|
||||||
|
@ -381,8 +382,8 @@ class NotificationService
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def reopen_resource_email(target, project, current_user, method, status)
|
def reopen_resource_email(target, current_user, method, status)
|
||||||
recipients = NotificationRecipientService.new(project).build_recipients(target, current_user, action: "reopen")
|
recipients = NotificationRecipientService.build_recipients(target, current_user, action: "reopen")
|
||||||
|
|
||||||
recipients.each do |recipient|
|
recipients.each do |recipient|
|
||||||
mailer.send(method, recipient.id, target.id, status, current_user.id).deliver_later
|
mailer.send(method, recipient.id, target.id, status, current_user.id).deliver_later
|
||||||
|
|
|
@ -28,7 +28,13 @@ module DeclarativePolicy
|
||||||
|
|
||||||
subject = find_delegate(subject)
|
subject = find_delegate(subject)
|
||||||
|
|
||||||
class_for_class(subject.class)
|
policy_class = class_for_class(subject.class)
|
||||||
|
raise "no policy for #{subject.class.name}" if policy_class.nil?
|
||||||
|
policy_class
|
||||||
|
end
|
||||||
|
|
||||||
|
def has_policy?(subject)
|
||||||
|
!class_for_class(subject.class).nil?
|
||||||
end
|
end
|
||||||
|
|
||||||
private
|
private
|
||||||
|
@ -51,9 +57,7 @@ module DeclarativePolicy
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
policy_class = subject_class.instance_variable_get(CLASS_CACHE_IVAR)
|
subject_class.instance_variable_get(CLASS_CACHE_IVAR)
|
||||||
raise "no policy for #{subject.class.name}" if policy_class.nil?
|
|
||||||
policy_class
|
|
||||||
end
|
end
|
||||||
|
|
||||||
def compute_class_for_class(subject_class)
|
def compute_class_for_class(subject_class)
|
||||||
|
@ -71,6 +75,8 @@ module DeclarativePolicy
|
||||||
nil
|
nil
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
|
nil
|
||||||
end
|
end
|
||||||
|
|
||||||
def find_delegate(subject)
|
def find_delegate(subject)
|
||||||
|
|
|
@ -1,34 +0,0 @@
|
||||||
require 'spec_helper'
|
|
||||||
|
|
||||||
describe NotificationRecipientService do
|
|
||||||
set(:user) { create(:user) }
|
|
||||||
set(:project) { create(:project, :public) }
|
|
||||||
set(:issue) { create(:issue, project: project) }
|
|
||||||
|
|
||||||
set(:watcher) do
|
|
||||||
watcher = create(:user)
|
|
||||||
setting = watcher.notification_settings_for(project)
|
|
||||||
setting.level = :watch
|
|
||||||
setting.save
|
|
||||||
|
|
||||||
watcher
|
|
||||||
end
|
|
||||||
|
|
||||||
subject { described_class.new(project) }
|
|
||||||
|
|
||||||
describe '#build_recipients' do
|
|
||||||
it 'does not modify the participants of the target' do
|
|
||||||
expect { subject.build_recipients(issue, user, action: :new_issue) }
|
|
||||||
.not_to change { issue.participants(user) }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
|
|
||||||
describe '#build_new_note_recipients' do
|
|
||||||
set(:note) { create(:note_on_issue, noteable: issue, project: project) }
|
|
||||||
|
|
||||||
it 'does not modify the participants of the target' do
|
|
||||||
expect { subject.build_new_note_recipients(note) }
|
|
||||||
.not_to change { note.noteable.participants(note.author) }
|
|
||||||
end
|
|
||||||
end
|
|
||||||
end
|
|
|
@ -306,6 +306,11 @@ describe NotificationService, :mailer do
|
||||||
|
|
||||||
before do
|
before do
|
||||||
build_team(note.project)
|
build_team(note.project)
|
||||||
|
|
||||||
|
# make sure these users can read the project snippet!
|
||||||
|
project.add_guest(@u_guest_watcher)
|
||||||
|
project.add_guest(@u_guest_custom)
|
||||||
|
|
||||||
note.project.add_master(note.author)
|
note.project.add_master(note.author)
|
||||||
reset_delivered_emails!
|
reset_delivered_emails!
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in New Issue