2015-08-02 05:22:18 -04:00
|
|
|
require 'active_support/core_ext/object/to_param'
|
|
|
|
|
2015-07-21 21:03:47 -04:00
|
|
|
module ActionCable
|
|
|
|
module Channel
|
|
|
|
module Broadcasting
|
|
|
|
extend ActiveSupport::Concern
|
|
|
|
|
|
|
|
delegate :broadcasting_for, to: :class
|
|
|
|
|
|
|
|
class_methods do
|
|
|
|
# Broadcast a hash to a unique broadcasting for this <tt>model</tt> in this channel.
|
|
|
|
def broadcast_to(model, message)
|
|
|
|
ActionCable.server.broadcast(broadcasting_for([ channel_name, model ]), message)
|
|
|
|
end
|
|
|
|
|
|
|
|
def broadcasting_for(model) #:nodoc:
|
|
|
|
case
|
|
|
|
when model.is_a?(Array)
|
|
|
|
model.map { |m| broadcasting_for(m) }.join(':')
|
|
|
|
when model.respond_to?(:to_gid_param)
|
|
|
|
model.to_gid_param
|
|
|
|
else
|
|
|
|
model.to_param
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|