class Slanger::Channel
Attributes
channel_id[R]
Public Class Methods
all()
click to toggle source
# File lib/slanger/channel.rb, line 34 def all @all ||= [] end
create(params = {})
click to toggle source
# File lib/slanger/channel.rb, line 30 def create(params = {}) new(params).tap { |r| all << r } end
from(channel_id)
click to toggle source
# File lib/slanger/channel.rb, line 20 def from channel_id klass = channel_id[/\Apresence-/] ? PresenceChannel : Channel klass.lookup(channel_id) || klass.create(channel_id: channel_id) end
lookup(channel_id)
click to toggle source
# File lib/slanger/channel.rb, line 26 def lookup(channel_id) all.detect { |o| o.channel_id == channel_id } end
new(attrs)
click to toggle source
# File lib/slanger/channel.rb, line 47 def initialize(attrs) @channel_id = attrs.with_indifferent_access[:channel_id] Slanger::Redis.subscribe channel_id end
send_client_message(msg)
click to toggle source
# File lib/slanger/channel.rb, line 42 def send_client_message msg from(msg['channel']).try :send_client_message, msg end
unsubscribe(channel_id, subscription_id)
click to toggle source
# File lib/slanger/channel.rb, line 38 def unsubscribe channel_id, subscription_id from(channel_id).try :unsubscribe, subscription_id end
Public Instance Methods
authenticated?()
click to toggle source
# File lib/slanger/channel.rb, line 90 def authenticated? channel_id =~ /\Aprivate-/ || channel_id =~ /\Apresence-/ end
channel()
click to toggle source
# File lib/slanger/channel.rb, line 52 def channel @channel ||= EM::Channel.new end
dispatch(message, channel)
click to toggle source
Send an event received from Redis
to the EventMachine channel which will send it to subscribed clients.
# File lib/slanger/channel.rb, line 84 def dispatch(message, channel) push(Oj.dump(message, mode: :compat)) unless channel =~ /\Aslanger:/ perform_client_webhook!(message) end
send_client_message(message)
click to toggle source
Send a client event to the EventMachine channel. Only events to channels requiring authentication (private or presence) are accepted. Public channels only get events from the API.
# File lib/slanger/channel.rb, line 78 def send_client_message(message) Slanger::Redis.publish(message['channel'], Oj.dump(message, mode: :compat)) if authenticated? end
subscribe(*a, &blk)
click to toggle source
# File lib/slanger/channel.rb, line 56 def subscribe *a, &blk Slanger::Redis.hincrby('channel_subscriber_count', channel_id, 1). callback do |value| Slanger::Webhook.post name: 'channel_occupied', channel: channel_id if value == 1 end channel.subscribe *a, &blk end
unsubscribe(*a, &blk)
click to toggle source
# File lib/slanger/channel.rb, line 65 def unsubscribe *a, &blk Slanger::Redis.hincrby('channel_subscriber_count', channel_id, -1). callback do |value| Slanger::Webhook.post name: 'channel_vacated', channel: channel_id if value == 0 end channel.unsubscribe *a, &blk end
Private Instance Methods
perform_client_webhook!(message)
click to toggle source
# File lib/slanger/channel.rb, line 96 def perform_client_webhook!(message) if (message['event'].start_with?('client-')) then event = message.merge({'name' => 'client_event'}) event['data'] = Oj.dump(event['data']) Slanger::Webhook.post(event) end end