taiga
/
taiga-events
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Merge pull request #29 from taigaio/increase-robustness 

Increase robustness
master
Jesús Espino 2017-04-06 13:36:35 +02:00 committed by GitHub
parent 237cc65e0c 28052d66f7
commit c4a95a3de9
2 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
client.coffee
View File

@ -15,15 +15,18 @@ class Client
@ws.on 'message', @.handleMessage.bind(@) @ws.on 'message', @.handleMessage.bind(@)
handleMessage: (message) -> handleMessage: (message) ->
try
msg = JSON.parse(message) msg = JSON.parse(message)
catch e
return null
if msg.cmd == 'ping' if msg.cmd == 'ping'
@.sendPong() @.sendPong()
else if msg.cmd == 'auth' else if msg.cmd == 'auth' and msg.data
@.authUser(msg.data) @.authUser(msg.data)
else if msg.cmd == 'subscribe' else if msg.cmd == 'subscribe' and msg.routing_key
@.addSubscription(msg.routing_key) @.addSubscription(msg.routing_key)
else if msg.cmd == 'unsubscribe' else if msg.cmd == 'unsubscribe' and msg.routing_key
@.removeSubscription(msg.routing_key) @.removeSubscription(msg.routing_key)
authUser: (auth) -> authUser: (auth) ->

4
rabbit.coffee
View File

@ -105,7 +105,9 @@ subscriptions = do ->
unsubscribe = (client_id, routing_key) -> unsubscribe = (client_id, routing_key) ->
channels.get(client_id).then (channel) -> channels.get(client_id).then (channel) ->
channel.cancel(subs[client_id][routing_key]) consumerTag = subs[client_id][routing_key]
if consumerTag != undefined
channel.cancel(consumerTag)
removeClient = (client_id) -> removeClient = (client_id) ->
delete subs[client_id] delete subs[client_id]