tests: Check data subscription support

Author: jonnor

spec/01transport.coffee

@@ -99,6 +99,7 @@ transportTests = (type) ->
   broker = null
 
   describeIfRoundRobinSupport = if type == 'AMQP' then describe else describe.skip
+  describeIfSubscribeSupport = if type != 'AMQP' then describe else describe.skip
 
   beforeEach (done) ->
     broker = transport.getBroker address
@@ -363,6 +364,53 @@ transportTests = (type) ->
       it 'only NACKed message is sent to deadletter', ->
         chai.expect(received.deadletter).to.eql [ { foo: 'nack'} ]
 
+  describeIfSubscribeSupport 'subscribing to bound topics', ->
+    sendQueue = 'sub-send-36'
+    receiveQueue = 'sub-receive-36'
+    binding = { type:'pubsub', src:sendQueue, tgt:receiveQueue }
+    connectionData = []
+    clients = null
+
+    # Should be a before, but the 'beforeEach' of higher scope are ran afterwards...
+    setup = (done) ->
+      createConnectClients address, ['sender', 'receiver'], (err, c) ->
+        clients = c
+        createQueues [
+          [ clients.receiver, 'inqueue', receiveQueue ]
+          [ clients.sender, 'outqueue', sendQueue ]
+        ], (err) ->
+          chai.expect(err).to.not.exist
+          broker.addBinding binding, (err) ->
+            chai.expect(err).to.be.a 'null'
+            return done null
+
+    it 'should provide data sent on connection', (done) ->
+      payloads =
+        one: { foo: 'sub-96' }
+        two: { bar: 'sub-97' }
+  
+      onData = (bind, data) ->
+        chai.expect(bind.src).to.equal binding.src
+        chai.expect(bind.tgt).to.equal binding.tgt
+        connectionData.push data
+        # wait until we've gotten two packets
+        if connectionData.length == 2
+          [one, two] = connectionData
+          chai.expect(one).to.eql payloads.one
+          chai.expect(two).to.eql payloads.two
+          return done null
+        else if connectionData.length > 2
+          return done new Error "Got more data than expected"
+
+      setup (err) ->
+        return done err if err
+        broker.subscribeData binding, onData, (err) ->
+          return done err if err
+          clients.sender.sendTo 'outqueue', sendQueue, payloads.one, (err) ->
+            return done err if err
+            clients.sender.sendTo 'outqueue', sendQueue, payloads.two, (err) ->
+              return done err if err
+
 describe 'Transport', ->
   Object.keys(transports).forEach (type) =>
     describe "#{type}", () ->