Wait for reader clients to close in test suite

Author: João Barbosa

Readme.md

@@ -28,7 +28,7 @@ $ npm install nsq.js
   except fo the framer:
 
 ```
-$ DEBUG=nsq*,-nsq:framer node test
+$ DEBUG=nsq*,-nsq:framer npm test
 
 nsq:reader connect nsqd 0.0.0.0:4150 events/ingestion [5] +0ms
 nsq:connection connect: 0.0.0.0:4150 V2 +0ms

package.json

@@ -23,6 +23,7 @@
   "devDependencies": {
     "bytes": "~2.4.0",
     "jstrace": "~0.3.0",
+    "lodash.get": "^4.4.2",
     "mocha": "*",
     "should": "*",
     "superagent": "~2.3.0"

test/acceptance/connection.js

@@ -1,18 +1,10 @@
 
+require('./hooks');
+
 var Connection = require('../../lib/connection');
 var assert = require('assert');
-var utils = require('../utils');
-var uid = require('uid');
 
 describe('Connection', function(){
-  var topic = uid();
-  afterEach(function(done){
-    utils.deleteTopic(topic, function(){
-      topic = uid();
-      done();
-    });
-  })
-
   it('should identify on connect', function(done){
     var conn = new Connection;
 
@@ -41,7 +33,7 @@ describe('Connection', function(){
 
     sub.on('message', function(msg){
       msg.finish();
-      done();
+      sub.close(done);
     });
 
     pub.connect();

test/acceptance/hooks.js

@@ -0,0 +1,17 @@
+
+var assert = require('assert');
+var get = require('lodash.get');
+var utils = require('../utils');
+
+beforeEach(function(done){
+  utils.deleteTopic('test', done);
+})
+
+afterEach(function(done){
+  utils.stats('test', 'reader', function(err, stats){
+    if (err) return done(err);
+    var state = get(stats.body.data, 'topics[0].channels[0].clients[0].state');
+    assert(state != 3, 'client in subscribed state');
+    done();
+  })
+});