ArticleとWork関連の3クラス分newspaperをActiveSupport::Notificationsに移行

app/controllers/articles_controller.rb

@@ -38,7 +38,7 @@ def create
     @article.user = current_user if @article.user.nil?
     set_wip
     if @article.save
-      Newspaper.publish(:create_article, { article: @article })
+      ActiveSupport::Notifications.instrument('article.create', article: @article)
 
       redirect_to redirect_url(@article), notice: notice_message(@article)
     else
@@ -49,7 +49,7 @@ def create
   def update
     set_wip
     if @article.update(article_params)
-      Newspaper.publish(:create_article, { article: @article })
+      ActiveSupport::Notifications.instrument('article.create', article: @article)
       redirect_to redirect_url(@article), notice: notice_message(@article)
     else
       render :edit
@@ -58,7 +58,7 @@ def update
 
   def destroy
     @article.destroy
-    Newspaper.publish(:destroy_article, { article: @article })
+    ActiveSupport::Notifications.instrument('article.destroy', article: @article)
     redirect_to articles_url, notice: '記事を削除しました'
   end
 

app/controllers/works_controller.rb

@@ -27,7 +27,7 @@ def create
     @work = Work.new(work_params)
     @work.user = current_user
     if @work.save
-      Newspaper.publish(:work_create, { work: @work })
+      ActiveSupport::Notifications.instrument('work.create', work: @work)
       redirect_to @work, notice: 'ポートフォリオに作品を追加しました。'
     else
       render :new

app/models/article_notification_destroyer.rb

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 class ArticleNotificationDestroyer
-  def call(payload)
+  def call(_name, _started, _finished, _unique_id, payload)
     article = payload[:article]
     Notification.where(link: "/articles/#{article.id}").destroy_all
   end

app/models/article_notifier.rb

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 class ArticleNotifier
-  def call(payload)
+  def call(_name, _started, _finished, _unique_id, payload)
     article = payload[:article]
     return unless article.saved_change_to_attribute?(:published_at, from: nil)
 

app/models/work_notifier.rb

@@ -1,7 +1,7 @@
 # frozen_string_literal: true
 
 class WorkNotifier
-  def call(payload)
+  def call(_name, _started, _finished, _unique_id, payload)
     work = Work.eager_load(:user).find(payload[:work].id)
 
     User.admins_and_mentors.each do |receiver|

config/initializers/active_support_notifications.rb

@@ -11,4 +11,7 @@
   ActiveSupport::Notifications.subscribe('announcement.create', AnnouncementNotifier.new)
   ActiveSupport::Notifications.subscribe('announcement.update', AnnouncementNotifier.new)
   ActiveSupport::Notifications.subscribe('announcement.destroy', AnnouncementNotificationDestroyer.new)
+  ActiveSupport::Notifications.subscribe('article.create', ArticleNotifier.new)
+  ActiveSupport::Notifications.subscribe('article.destroy', ArticleNotificationDestroyer.new)
+  ActiveSupport::Notifications.subscribe('work.create', WorkNotifier.new)
 end

config/initializers/newspaper.rb

@@ -60,10 +60,6 @@
   Newspaper.subscribe(:came_comment, CommentNotifier.new)
   Newspaper.subscribe(:came_comment_in_talk, CommentNotifierForAdmin.new)
 
-  Newspaper.subscribe(:create_article, ArticleNotifier.new)
-  Newspaper.subscribe(:destroy_article, ArticleNotificationDestroyer.new)
-
-  Newspaper.subscribe(:work_create, WorkNotifier.new)
   Newspaper.subscribe(:work_destroy, WorkNotificationDestroyer.new)
 
   Newspaper.subscribe(:came_inquiry, InquiryNotifier.new)