Redmine

    # users = issue.notified_users | issue.notified_watchers | issue.notified_mentions

    recipients = NotificationRecipients::BuildService::issue_add(issue)

    recipients.each do |r|

      issue_add(r.user, issue).deliver_later

    recipients = NotificationRecipients::BuildService::issue_edit(journal)

    recipients.each do |r|

      issue_edit(r.user, journal).deliver_later

# frozen_string_literal: true

# Redmine - project management software

# Copyright (C) 2006-2023  Jean-Philippe Lang

#

# This program is free software; you can redistribute it and/or

# modify it under the terms of the GNU General Public License

# as published by the Free Software Foundation; either version 2

# of the License, or (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU General Public License for more details.

#

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

class UserNotificationRecipient

  INVOLVED = 'involved'

  MENTIONED = 'mentioned'

  WATCHER = 'watcher'

  SUBSCRIBED = 'subscribed'

  ADMIN = 'admin'

  REASON_PRIORITY = [

    INVOLVED,

    MENTIONED,

    WATCHER,

    SUBSCRIBED,

    ADMIN

  ].freeze

  attr_reader :user, :reason

  def initialize(user, reason)

    @user = user

    @reason = reason

  end

  def self.reorder_by_priority(users)

    users = users.sort_by { |r| priority(r.notification_reason) }

    users.uniq!

    users

  end

  def self.priority(reason)

    REASON_PRIORITY.index(reason) || REASON_PRIORITY.length + 1

  end

end

# frozen_string_literal: true

# Redmine - project management software

# Copyright (C) 2006-  Jean-Philippe Lang

#

# This program is free software; you can redistribute it and/or

# modify it under the terms of the GNU General Public License

# as published by the Free Software Foundation; either version 2

# of the License, or (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU General Public License for more details.

#

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.

module NotificationRecipients

  module BuildService

    def self.issue_add(issue)

      ::NotificationRecipients::Builder::Issue.new(issue).notified_recipients

    end

    def self.issue_edit(journal)

      ::NotificationRecipients::Builder::Journal.new(journal).notified_recipients

    end

  end

end

module NotificationRecipients

  module Builder

    class Base

      attr_reader :target

      def initialize(target)

        @target = target

      end

      def notified_recipients

        build_notified_recipients

        filter!

        reorder!

        self.recipients.freeze

      end

      def notified_users

        build_notified_users

        filter!

        reorder!

        self.recipients.freeze

      end

      def notified_mentions

        build_notified_mentions

        filter!

        self.recipients.freeze

      end

      def notified_watchers

        add_watchers(target)

        self.recipients.freeze

      end

      protected

      def recipients

        @recipients ||= []

      end

      def build_notified_watchers

        add_watchers(target)

      end

      def build_notified_mentions

        add_mentions(target)

      end

      def add_mentions(target)

        users = target.notified_mentions

        users.each do |user|

          add_recipient(user, UserNotificationRecipient::MENTIONED)

        end

      end

      def add_watchers(target)

        users = target.notified_watchers

        users.each do |user|

          add_recipient(user, UserNotificationRecipient::WATCHER)

        end

      end

      def add_recipient(user, reason)

        recipients.push(UserNotificationRecipient.new(user, reason))

      end

      def filter!

      end

      def reorder!

        self.recipients.sort_by! { |r| UserNotificationRecipient::priority(r.reason) }

        self.recipients.uniq!(&:user)

      end

    end

  end

end

module NotificationRecipients

  module Builder

    class Issue < Base

      protected

      def build_notified_recipients

        build_notified_users

        build_notified_mentions

        build_notified_watchers

      end

      def build_notified_users

        add_involved_users

        add_subscribed_users

        add_high_priority_users

      end

      def add_involved_users

        notified = [target.author, target.assigned_to, target.previous_assignee].compact.uniq

        notified = notified.map {|n| n.is_a?(Group) ? n.users : n}.flatten

        notified.uniq!

        notified = notified.select {|u| u.active? && u.notify_about?(target)}

        # Remove users that can not view the issue

        notified.reject! {|user| !target.visible?(user)}

        notified.each do |user|

          add_recipient(user, UserNotificationRecipient::INVOLVED)

        end

      end

      def add_subscribed_users

        notified = target.project.notified_users.to_a

        # Remove users that can not view the issue

        notified.reject! {|user| !target.visible?(user)}

        notified.each do |user|

          add_recipient(user, UserNotificationRecipient::SUBSCRIBED)

        end

      end

      def add_high_priority_users

        if target.priority.high?

          project.users.preload(:preference).select(&:notify_about_high_priority_issues?).each do |user|

            next unless target.visible?(user)

            add_recipient(user, UserNotificationRecipient::HIGH_PRIORITY)

          end

        end

      end

    end

  end

end

module NotificationRecipients

  module Builder

    class Journal < Base

      protected

      def build_notified_users

        recipients.concat(::NotificationRecipients::Builder::Issue.new(target.journalized).notified_users)

      end

      def build_notified_recipients

        build_notified_users

        build_notified_watchers

        build_notified_mentions

      end

      def build_notified_watchers

        add_watchers(target.journalized)

      end

      def build_notified_mentions

        add_mentions(target)

        add_mentions(target.journalized)

      end

      def filter!

        if target.private_notes?

          self.recipients.select! {|r | r.user.allowed_to?(:view_private_notes, target.journalized.project)}

          self.recipients.select! {|r | target.notes? || target.visible_details(r.user).any? }

        end

      end

    end

  end

end