定期イベントの主催者が追加されたら新しく任命された人に通知する

app/controllers/hibernation_controller.rb

@@ -18,8 +18,8 @@ def create
       destroy_subscription!
       notify_to_chat
       notify_to_mentors_and_admins
-      current_user.cancel_participation_from_regular_events
-      current_user.delete_and_assign_new_organizer
+      current_user.cancel_participation_from_holding_regular_events
+      current_user.hand_over_organizers_of_holding_regular_events
       logout
       redirect_to hibernation_path
     else

app/controllers/regular_events_controller.rb

@@ -1,6 +1,6 @@
 # frozen_string_literal: true
 
-class RegularEventsController < ApplicationController
+class RegularEventsController < ApplicationController # rubocop:disable Metrics/ClassLength
   before_action :set_regular_event, only: %i[edit update destroy]
 
   def index
@@ -42,9 +42,12 @@ def edit; end
 
   def update
     set_wip
+    before_organizer_user_ids = @regular_event.organizers.pluck(:user_id)
+
     if @regular_event.update(regular_event_params)
       update_published_at
       ActiveSupport::Notifications.instrument('regular_event.update', regular_event: @regular_event, sender: current_user)
+      @regular_event.notify_new_organizer(sender: current_user, before_organizer_user_ids:)
       set_all_user_participants_and_watchers
       select_redirect_path
     else

app/controllers/training_completion_controller.rb

@@ -13,8 +13,8 @@ def create
     current_user.training_completed_at = Time.current
     if current_user.save(context: :training_completion)
       user = current_user
-      current_user.cancel_participation_from_regular_events
-      current_user.delete_and_assign_new_organizer
+      current_user.cancel_participation_from_holding_regular_events
+      current_user.hand_over_organizers_of_holding_regular_events
       ActiveSupport::Notifications.instrument('training_completion.create', user:)
       user.clear_github_data
       notify_to_user(user)

app/mailers/activity_mailer.rb

@@ -468,4 +468,22 @@ def added_work(args = {})
     message.perform_deliveries = @user.mail_notification? && !@user.retired?
     message
   end
+
+  # required params: regular_event, receiver
+  def added_organizer(args = {})
+    @regular_event ||= args[:regular_event]
+    @receiver ||= args[:receiver]
+    @user = @receiver
+    @link_url = notification_redirector_url(
+      link: "/regular_events/#{@regular_event.id}",
+      kind: Notification.kinds[:added_organizer]
+    )
+
+    subject = "[FBC] 定期イベント【#{@regular_event.title}】の主催者に追加されました。"
+
+    message = mail(to: @user.email, subject:)
+    message.perform_deliveries = @user.mail_notification? && !@user.retired?
+
+    message
+  end
 end

app/models/notification.rb

@@ -43,7 +43,8 @@ class Notification < ApplicationRecord
     create_article: 24,
     added_work: 25,
     came_inquiry: 26,
-    training_completed: 27
+    training_completed: 27,
+    added_organizer: 28
   }
 
   scope :unreads, -> { where(read: false) }

app/models/organizer.rb

@@ -6,9 +6,7 @@ class Organizer < ApplicationRecord
 
   validates :user_id, uniqueness: { scope: :regular_event_id }
 
-  def delete_and_assign_new
-    event = regular_event
-    delete
-    event.assign_admin_as_organizer_if_none
-  end
+  scope :holding, lambda {
+    joins(:regular_event).merge(RegularEvent.holding)
+  }
 end

app/models/organizer_notifier.rb

@@ -0,0 +1,13 @@
+# frozen_string_literal: true
+
+class OrganizerNotifier
+  def call(_name, _started, _finished, _id, payload)
+    regular_event = payload[:regular_event]
+    sender = payload[:sender]
+    new_organizer_users = payload[:new_organizer_users]
+
+    new_organizer_users.each do |user|
+      ActivityDelivery.with(regular_event:, sender:, receiver: user).notify(:added_organizer)
+    end
+  end
+end

app/models/regular_event.rb

@@ -118,13 +118,6 @@ def participated_by?(user)
     regular_event_participations.find_by(user_id: user.id).present?
   end
 
-  def assign_admin_as_organizer_if_none
-    return if organizers.exists?
-
-    admin_user = User.find_by(login_name: User::DEFAULT_REGULAR_EVENT_ORGANIZER)
-    Organizer.new(user: admin_user, regular_event: self).save if admin_user
-  end
-
   def all_scheduled_dates(
     from: Date.current,
     to: Date.current.next_year
@@ -157,6 +150,29 @@ def publish_with_announcement?
     wants_announcement? && !wip?
   end
 
+  def hand_over_organizer(organizer:, sender:)
+    before_organizer_user_ids = organizers.pluck(:user_id)
+
+    organizer.delete
+    assign_admin_as_organizer_if_none
+
+    notify_new_organizer(sender:, before_organizer_user_ids:)
+  end
+
+  def notify_new_organizer(sender:, before_organizer_user_ids:)
+    new_organizer_user_ids = (organizers.pluck(:user_id) - before_organizer_user_ids) - [sender.id]
+    return if new_organizer_user_ids.blank?
+
+    new_organizer_users = User.where(id: new_organizer_user_ids)
+
+    ActiveSupport::Notifications.instrument(
+      'organizer.add',
+      regular_event: self,
+      sender:,
+      new_organizer_users:
+    )
+  end
+
   private
 
   def end_at_be_greater_than_start_at
@@ -197,4 +213,11 @@ def parse_event_time(event_date, event_time)
     str_time = event_time.strftime('%R')
     Time.zone.parse([str_date, str_time].join(' '))
   end
+
+  def assign_admin_as_organizer_if_none
+    return if organizers.exists?
+
+    admin_user = User.find_by(login_name: User::DEFAULT_REGULAR_EVENT_ORGANIZER)
+    Organizer.new(user: admin_user, regular_event: self).save if admin_user
+  end
 end

app/models/regular_event_participation.rb

@@ -5,4 +5,8 @@ class RegularEventParticipation < ApplicationRecord
   belongs_to :regular_event
 
   validates :user_id, uniqueness: { scope: :regular_event_id }
+
+  scope :holding, lambda {
+    joins(:regular_event).merge(RegularEvent.holding)
+  }
 end

app/models/retirement.rb

@@ -75,11 +75,11 @@ def destroy_cards
   end
 
   def cancel_event_subscription
-    @user.cancel_participation_from_regular_events
+    @user.cancel_participation_from_holding_regular_events
   end
 
   def remove_as_event_organizer
-    @user.delete_and_assign_new_organizer
+    @user.hand_over_organizers_of_holding_regular_events
   end
 
   def publish

app/models/user.rb

@@ -883,12 +883,8 @@ def become_watcher!(watchable)
     watches.find_or_create_by!(watchable:)
   end
 
-  def cancel_participation_from_regular_events
-    regular_event_participations.destroy_all
-  end
-
-  def delete_and_assign_new_organizer
-    organizers.each(&:delete_and_assign_new)
+  def cancel_participation_from_holding_regular_events
+    regular_event_participations.holding.destroy_all
   end
 
   def scheduled_retire_at
@@ -958,6 +954,12 @@ def reports_with_learning_times
     reports.joins(:learning_times).distinct.order(reported_on: :asc)
   end
 
+  def hand_over_organizers_of_holding_regular_events
+    organizers.holding.includes(:regular_event).find_each do |organizer|
+      organizer.regular_event.hand_over_organizer(organizer:, sender: self)
+    end
+  end
+
   private
 
   def password_required?

app/notifiers/activity_notifier.rb

@@ -415,4 +415,20 @@ def came_inquiry(params = {})
       read: false
     )
   end
+
+  def added_organizer(params = {})
+    params.merge!(@params)
+    regular_event = params[:regular_event]
+    receiver = params[:receiver]
+    sender = params[:sender]
+
+    notification(
+      body: "定期イベント【#{regular_event.title}】の主催者に追加されました。",
+      kind: :added_organizer,
+      receiver:,
+      sender:,
+      link: Rails.application.routes.url_helpers.polymorphic_path(regular_event),
+      read: false
+    )
+  end
 end

app/views/activity_mailer/added_organizer.html.slim

@@ -0,0 +1,4 @@
+= render '/notification_mailer/notification_mailer_template',
+title: "定期イベント【#{@regular_event.title}】の主催者に追加されました。",
+link_url: @link_url,
+link_text: '定期イベント詳細へ'

config/initializers/active_support_notifications.rb

@@ -35,6 +35,7 @@
   ActiveSupport::Notifications.subscribe('came.comment', CommentNotifier.new)
   ActiveSupport::Notifications.subscribe('graduation.update', GraduationNotifier.new)
   ActiveSupport::Notifications.subscribe('comeback.update', ComebackNotifier.new)
+  ActiveSupport::Notifications.subscribe('organizer.add', OrganizerNotifier.new)
 
   learning_status_updater = LearningStatusUpdater.new
   ActiveSupport::Notifications.subscribe('product.save', learning_status_updater)

test/deliveries/activity_delivery_test.rb

@@ -499,4 +499,28 @@ class ActivityDeliveryTest < ActiveSupport::TestCase
       ActivityDelivery.with(**params).notify(:added_work)
     end
   end
+
+  test '.notify(:added_organizer)' do
+    params = {
+      regular_event: regular_events(:regular_event4),
+      receiver: users(:komagata),
+      sender: users(:kimura)
+    }
+
+    assert_difference -> { AbstractNotifier::Testing::Driver.deliveries.count }, 1 do
+      ActivityDelivery.notify!(:added_organizer, **params)
+    end
+
+    assert_difference -> { AbstractNotifier::Testing::Driver.enqueued_deliveries.count }, 1 do
+      ActivityDelivery.notify(:added_organizer, **params)
+    end
+
+    assert_difference -> { AbstractNotifier::Testing::Driver.deliveries.count }, 1 do
+      ActivityDelivery.with(**params).notify!(:added_organizer)
+    end
+
+    assert_difference -> { AbstractNotifier::Testing::Driver.enqueued_deliveries.count }, 1 do
+      ActivityDelivery.with(**params).notify(:added_organizer)
+    end
+  end
 end

test/mailers/activity_mailer_test.rb

@@ -1285,6 +1285,25 @@ class ActivityMailerTest < ActionMailer::TestCase
     assert_empty ActionMailer::Base.deliveries
   end
 
+  test 'added_organizer' do
+    regular_event = RegularEvent.find(ActiveRecord::FixtureSet.identify(:regular_event1))
+    receiver = User.find(ActiveRecord::FixtureSet.identify(:komagata))
+    sender = User.find(ActiveRecord::FixtureSet.identify(:kimura))
+
+    ActivityMailer.added_organizer(
+      regular_event:,
+      receiver:,
+      sender:
+    ).deliver_now
+
+    assert_not ActionMailer::Base.deliveries.empty?
+    email = ActionMailer::Base.deliveries.last
+    assert_equal ['noreply@bootcamp.fjord.jp'], email.from
+    assert_equal ['komagata@fjord.jp'], email.to
+    assert_equal '[FBC] 定期イベント【開発MTG】の主催者に追加されました。', email.subject
+    assert_match(/定期イベント/, email.body.to_s)
+  end
+
   private
 
   def mailer_url_options

test/mailers/previews/activity_mailer_preview.rb

@@ -186,4 +186,11 @@ def added_work
 
     ActivityMailer.with(work:, sender: user, receiver:).added_work
   end
+
+  def added_organizer
+    regular_event = RegularEvent.find(ActiveRecord::FixtureSet.identify(:regular_event1))
+    receiver = User.find(ActiveRecord::FixtureSet.identify(:komagata))
+    sender = User.find(ActiveRecord::FixtureSet.identify(:kimura))
+    ActivityMailer.with(regular_event:, receiver:, sender:).added_organizer
+  end
 end

test/models/organizer_notifier_test.rb

@@ -0,0 +1,36 @@
+# frozen_string_literal: true
+
+require 'test_helper'
+
+class OrganizerNotifierTest < ActiveSupport::TestCase
+  include ActiveJob::TestHelper
+
+  setup do
+    @regular_event = regular_events(:regular_event4)
+    @sender = users(:kimura)
+  end
+
+  test 'sends a notification when a new organizer is added' do
+    new_organizer_users = [users(:hatsuno)]
+
+    assert_difference -> { AbstractNotifier::Testing::Driver.enqueued_deliveries.count }, 1 do
+      OrganizerNotifier.new.call(nil, nil, nil, nil, { regular_event: @regular_event, new_organizer_users:, sender: @sender })
+    end
+  end
+
+  test 'does not send a notification when no new organizers are added' do
+    new_organizer_users = []
+
+    assert_difference -> { AbstractNotifier::Testing::Driver.enqueued_deliveries.count }, 0 do
+      OrganizerNotifier.new.call(nil, nil, nil, nil, { regular_event: @regular_event, new_organizer_users:, sender: @sender })
+    end
+  end
+
+  test 'sends notifications when multiple organizers are added' do
+    new_organizer_users = [users(:hatsuno), users(:hajime)]
+
+    assert_difference -> { AbstractNotifier::Testing::Driver.enqueued_deliveries.count }, 2 do
+      OrganizerNotifier.new.call(nil, nil, nil, nil, { regular_event: @regular_event, new_organizer_users:, sender: @sender })
+    end
+  end
+end