blob: 464f0c1ff78fe1d37830c3bb35fd7fd5c4088821 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
|
# 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: ->
return if @isState("open", "connecting")
@webSocket = new WebSocket(@consumer.url)
@installEventHandlers()
close: ->
return if @isState("closed", "closing")
@webSocket?.close()
reopen: ->
if @isOpen()
@closeSilently => @open()
else
@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
closeSilently: (callback = ->) ->
@uninstallEventHandlers()
@installEventHandler("close", callback)
@installEventHandler("error", callback)
try
@webSocket.close()
finally
@uninstallEventHandlers()
installEventHandlers: ->
for eventName of @events
@installEventHandler(eventName)
installEventHandler: (eventName, handler) ->
handler ?= @events[eventName].bind(this)
@webSocket.addEventListener(eventName, handler)
uninstallEventHandlers: ->
for eventName of @events
@webSocket.removeEventListener(eventName)
events:
message: (event) ->
{identifier, message} = JSON.parse(event.data)
@consumer.subscriptions.notify(identifier, "received", message)
open: ->
@consumer.subscriptions.reload()
close: ->
@consumer.subscriptions.notifyAll("disconnected")
error: ->
@consumer.subscriptions.notifyAll("disconnected")
@closeSilently()
toJSON: ->
state: @getState()
|
