Sidekiq notification

home_controller.rb

# app/controllers/home_controller.rb

class HomeController < ApplicationController
  def index
    @news = News.get_recent
    @notifications = current_user.notifications
  end
end

news.rb

# app/models/news.rb

class News < ActiveRecord::Base
  belongs_to :channel
  after_create :send_creation_notification
  
  def send_creation_notification
    NotificationWorker.perform_async(self.id, news.channel.subscribers.map(&:id), NOTIFICATION_TYPES[:creation])
  end
end

notifications_worker.rb

# workers/notification_worker.rb

class NotificationWorker
  include Sidekiq::Worker
  
  def perform(news_id, subscribers, notification_type)
    Subscriber.where(id: subscribers).each do |subscriber|
      subscriber.notifications.create(news_id: news_id, notification_type: notification_type)
    end
  end
end