websocket-rails/websocket-rails

###
The channel object is returned when you subscribe to a channel.

For instance:
  var dispatcher = new WebSocketRails('localhost:3000/websocket');
  var awesome_channel = dispatcher.subscribe('awesome_channel');
  awesome_channel.bind('event', function(data) { console.log('channel event!'); });
  awesome_channel.trigger('awesome_event', awesome_object);

If you want to unbind an event, you can use the unbind function :
  awesome_channel.unbind('event')
###
class WebSocketRails.Channel

  constructor: (@name, @_dispatcher, @is_private = false, @on_success, @on_failure) ->
    @_callbacks = {}
    @_token = undefined
    @_queue = []
    if @is_private
      event_name = 'websocket_rails.subscribe_private'
    else
      event_name = 'websocket_rails.subscribe'

    @connection_id = @_dispatcher._conn?.connection_id
    event = new WebSocketRails.Event( [event_name, {data: {channel: @name}}, @connection_id], @_success_launcher, @_failure_launcher)
    @_dispatcher.trigger_event event

  destroy: ->
    if @connection_id == @_dispatcher._conn?.connection_id
      event_name = 'websocket_rails.unsubscribe'
      event =  new WebSocketRails.Event( [event_name, {data: {channel: @name}}, @connection_id] )
      @_dispatcher.trigger_event event
    @_callbacks = {}

  bind: (event_name, callback) ->
    @_callbacks[event_name] ?= []
    @_callbacks[event_name].push callback

  unbind: (event_name) ->
    delete @_callbacks[event_name]

  trigger: (event_name, message) ->
    event = new WebSocketRails.Event( [event_name, {channel: @name, data: message, token: @_token}, @connection_id] )
    if !@_token
      @_queue.push event
    else
      @_dispatcher.trigger_event event

  dispatch: (event_name, message) ->
    if event_name == 'websocket_rails.channel_token'
      @connection_id = @_dispatcher._conn?.connection_id
      @_token = message['token']
      @flush_queue()
    else
      return unless @_callbacks[event_name]?
      for callback in @_callbacks[event_name]
        callback message

  # using this method because @on_success will not be defined when the constructor is executed
  _success_launcher: (data) =>
    @on_success(data) if @on_success?

  # using this method because @on_failure will not be defined when the constructor is executed
  _failure_launcher: (data) =>
    @on_failure(data) if @on_failure?

  flush_queue: ->
    for event in @_queue
      @_dispatcher.trigger_event event
    @_queue = []