mark_all_channel_threads_read.rb

# frozen_string_literal: true

module Jobs
  module Chat
    class MarkAllChannelThreadsRead < Jobs::Base
      sidekiq_options queue: "critical"

      def execute(args = {})
        return if !SiteSetting.enable_experimental_chat_threaded_discussions
        channel = ::Chat::Channel.find_by(id: args[:channel_id])
        return if channel.blank?
        channel.mark_all_threads_as_read
      end
    end
  end
end