aboutsummaryrefslogtreecommitdiffstats
path: root/lib/assets/javascripts/cable/connection.coffee
diff options
context:
space:
mode:
authorJavan Makhmali <javan@javan.us>2015-11-06 14:09:38 -0500
committerJavan Makhmali <javan@javan.us>2015-11-06 14:09:38 -0500
commit365891d5eff15a53919688ac78ac9af3edc0d664 (patch)
tree4f7804c0459ec6d37e151610271d56efd4ee9fea /lib/assets/javascripts/cable/connection.coffee
parente2ed68cc70925372681c2fb50b505b110825c8f7 (diff)
downloadrails-365891d5eff15a53919688ac78ac9af3edc0d664.tar.gz
rails-365891d5eff15a53919688ac78ac9af3edc0d664.tar.bz2
rails-365891d5eff15a53919688ac78ac9af3edc0d664.zip
Share internal identifiers and message types with the JavaScript client
Diffstat (limited to 'lib/assets/javascripts/cable/connection.coffee')
-rw-r--r--lib/assets/javascripts/cable/connection.coffee15
1 files changed, 7 insertions, 8 deletions
diff --git a/lib/assets/javascripts/cable/connection.coffee b/lib/assets/javascripts/cable/connection.coffee
index 7823240587..b2abe8dcb2 100644
--- a/lib/assets/javascripts/cable/connection.coffee
+++ b/lib/assets/javascripts/cable/connection.coffee
@@ -1,4 +1,7 @@
# Encapsulate the cable connection held by the consumer. This is an internal class not intended for direct user manipulation.
+
+{message_types} = Cable.INTERNAL
+
class Cable.Connection
@reopenDelay: 500
@@ -54,17 +57,13 @@ class Cable.Connection
message: (event) ->
{identifier, message, type} = JSON.parse(event.data)
- if type?
- @onTypeMessage(type)
- else
- @consumer.subscriptions.notify(identifier, "received", message)
-
- onTypeMessage: (type) ->
switch type
- when Cable.INTERNAL_MESSAGES.SUBSCRIPTION_CONFIRMATION
+ when message_types.confirmation
@consumer.subscriptions.notify(identifier, "connected")
- when Cable.INTERNAL_MESSAGES.SUBSCRIPTION_REJECTION
+ when message_types.rejection
@consumer.subscriptions.reject(identifier)
+ else
+ @consumer.subscriptions.notify(identifier, "received", message)
open: ->
@disconnected = false