module Sidekiq  class Subscriber    include ::Sidekiq::Util    def initialize      @done = false      @thread = nil    end    def start      @thread ||= safe_thread("subscriber") {        until @done          Sidekiq.redis do |conn|            # https://redis.io/topics/notifications#configuration            conn.config(:set, "notify-keyspace-events", "E$lshz")            # https://redis.io/topics/notifications#events-generated-by-different-commands            conn.psubscribe("__key*__:*") do |on|              on.psubscribe do                @firehose = Firehose.new              end              on.pmessage do |pattern, command, key|                @firehose.process(command.split(":").last.to_sym, key)              end              on.punsubscribe do                @firehose = nil              end            end          end        end        Sidekiq.logger.info("Subscriber exiting...")      }    end    def terminate      @done = true      if @thread        t = @thread        Thread.kill(@thread)        @thread = nil        t.value      end    end  endendmodule CoreExtensions  module Sidekiq    module Launcher      attr_accessor :subscriber      def initialize(options)        @subscriber = ::Sidekiq::Subscriber.new        super(options)      end      def run        super        subscriber.start      end      def quiet        subscriber.terminate        super      end      def stop        subscriber.terminate        super      end    end  endendSidekiq.configure_server do  require "sidekiq/launcher"  ::Sidekiq::Launcher.prepend(CoreExtensions::Sidekiq::Launcher)end

class Firehose  include CableReady::Broadcaster  attr_reader :redis  def initialize    @redis = Redis.new  end  def process(command, key)    case command # https://github.com/rails/kredis#examples    when :set    # string, integer, json      cable_ready["all_users"].console_log(message: "#{key} was just updated to #{redis.get(key)}").broadcast    when :rpush  # list    when :lrem   # unique_list    when :sadd   # set    when :incr    when :decr    when :incrby    when :decrby    when :exists    when :del      cable_ready["all_users"].console_log(message: "#{key} was deleted").broadcast    else    end  endend