Contents

# frozen_string_literal: true

module CableReady
  class Channel
    attr_reader :identifier, :operations, :available_operations

    def initialize(identifier, available_operations)
      @identifier = identifier
      @available_operations = available_operations
      reset
      available_operations.each do |available_operation, implementation|
        define_singleton_method available_operation, &implementation
      end
    end

    def channel_broadcast(clear)
      operations.select! { |_, list| list.present? }
      operations.deep_transform_keys! { |key| key.to_s.camelize(:lower) }
      ActionCable.server.broadcast identifier, {"cableReady" => true, "operations" => operations}
      reset if clear
    end

    def channel_broadcast_to(model, clear)
      operations.select! { |_, list| list.present? }
      operations.deep_transform_keys! { |key| key.to_s.camelize(:lower) }
      identifier.broadcast_to model, {"cableReady" => true, "operations" => operations}
      reset if clear
    end

    def broadcast(clear = true)
      CableReady::Channels.instance.broadcast(identifier, clear: clear)
    end

    def broadcast_to(model, clear = true)
      CableReady::Channels.instance.broadcast_to(model, identifier, clear: clear)
    end

    private

    def enqueue_operation(key, options)
      operations[key] << options
      self
    end

    def reset
      @operations = Hash.new { |hash, operation| hash[operation] = [] }
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
cable_ready-4.4.6	lib/cable_ready/channel.rb
cable_ready-4.4.5	lib/cable_ready/channel.rb
cable_ready-4.4.3	lib/cable_ready/channel.rb