class Futurism::Channel

Public Instance Methods

receive(data) click to toggle source
# File lib/futurism/channel.rb, line 17
def receive(data)
  resources = data.fetch_values("signed_params", "sgids", "signed_controllers", "urls", "broadcast_each") { |_key| Array.new(data["signed_params"].length, nil) }.transpose

  resolver = Resolver::Resources.new(resource_definitions: resources, connection: connection, params: @params)
  resolver.resolve do |selector, html, broadcast_each|
    cable_ready[stream_name].outer_html(
      selector: selector,
      html: html
    )

    cable_ready.broadcast if broadcast_each
  end

  cable_ready.broadcast
end
stream_name() click to toggle source
# File lib/futurism/channel.rb, line 5
def stream_name
  ids = connection.identifiers.map { |identifier| send(identifier).try(:id) || send(identifier) }
  [
    params[:channel],
    ids.select(&:present?).join(";")
  ].select(&:present?).join(":")
end
subscribed() click to toggle source
# File lib/futurism/channel.rb, line 13
def subscribed
  stream_from stream_name
end