Skip to content

Commit

Permalink
Send also empty group payloads
Browse files Browse the repository at this point in the history
  • Loading branch information
bergie committed Mar 30, 2018
1 parent 01a5111 commit 099c68f
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions src/protocol/Network.coffee
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ prepareSocketEvent = (event, graphName) ->
port: event.socket.to.port
if event.subgraph
payload.subgraph = event.subgraph
if event.group
if typeof event.group isnt 'undefined'
payload.group = event.group
if event.datatype
payload.type = event.datatype
Expand All @@ -39,6 +39,7 @@ prepareSocketEvent = (event, graphName) ->
if event.metadata?.secure
# Don't send actual payload for private connections
payload.data = 'DATA'

payload

getPortSignature = (item) ->
Expand Down Expand Up @@ -173,15 +174,15 @@ class NetworkProtocol extends EventEmitter
switch event.type
when 'openBracket'
protocolEvent.type = 'begingroup'
protocolEvent.group = event.data
protocolEvent.group = event.data or ''
when 'data'
protocolEvent.type = 'data'
protocolEvent.data = event.data
protocolEvent.datatype = event.datatype
protocolEvent.schema = event.schema
when 'closeBracket'
protocolEvent.type = 'endgroup'
protocolEvent.group = event.data
protocolEvent.group = event.data or ''
@sendAll protocolEvent.type, prepareSocketEvent(protocolEvent, graphName), context
network.on 'process-error', (event) =>
error = event.error.message
Expand Down

0 comments on commit 099c68f

Please sign in to comment.