blob: 2259ddcedd4f29514baf5e0f1aa4c8f8b49bcf1d (
plain) (
tree)
|
|
# Encapsulate the cable connection held by the consumer. This is an internal class not intended for direct user manipulation.
class Cable.Connection
constructor: (@consumer) ->
@open()
send: (data) ->
if @isOpen()
@webSocket.send(JSON.stringify(data))
true
else
false
open: ->
if @isOpen()
throw new Error("Must close existing connection before opening")
else
@webSocket = new WebSocket(@consumer.url)
@installEventHandlers()
close: ->
@webSocket?.close()
reopen: ->
@close()
@open()
isOpen: ->
@isState("open")
# Private
isState: (states...) ->
@getState() in states
getState: ->
return state.toLowerCase() for state, value of WebSocket when value is @webSocket?.readyState
null
installEventHandlers: ->
for eventName of @events
handler = @events[eventName].bind(this)
@webSocket["on#{eventName}"] = handler
events:
message: (event) ->
{identifier, message} = JSON.parse(event.data)
@consumer.subscriptions.notify(identifier, "received", message)
open: ->
@disconnected = false
@consumer.subscriptions.reload()
close: ->
@disconnect()
error: ->
@disconnect()
disconnect: ->
return if @disconnected
@disconnected = true
@consumer.subscriptions.notifyAll("disconnected")
toJSON: ->
state: @getState()
|