Added buffered messages test for multipart

Added assertions for `connected` property for all the tests
technoweenie · Oct 20, 2010 · 3ecb37d · 3ecb37d
1 parent 6a67796
commit 3ecb37d
Show file tree

Hide file tree

Showing 3 changed files with 42 additions and 0 deletions.
diff --git a/tests/transports.websocket.js b/tests/transports.websocket.js
@@ -100,6 +100,7 @@ module.exports = {
         sio.clients[sessionid].connection.addListener('end', function(){
           if (!runOnce){
             assert.ok(sio.clients[sessionid]._open == false);
+            assert.ok(sio.clients[sessionid].connected);
             sio.clients[sessionid].send('should get this');
 
             var client2 = new WebSocket('ws://localhost:8083/socket.io/websocket/' + sessionid, 'borf');

diff --git a/tests/transports.xhr-multipart.js b/tests/transports.xhr-multipart.js
@@ -141,6 +141,45 @@ module.exports = {
         });
       });
     });
+  },
+
+  'test buffered messages': function(assert){
+    var _server = server()
+      , _socket = socket(_server, { transportOptions: { 
+        'xhr-multipart': {
+          closeTimeout: 100
+        }
+      } });
+
+    listen(_server, function(){
+      var _client = get(_server, '/socket.io/xhr-multipart', function(response){
+        var once = false;
+        response.on('data', function(data){
+          if (!once){
+            var sessid = decode(data);
+            assert.ok(_socket.clients[sessid]._open === true);
+            assert.ok(_socket.clients[sessid].connected);
+
+            _socket.clients[sessid].connection.addListener('end', function(){
+              assert.ok(_socket.clients[sessid]._open === false);
+              assert.ok(_socket.clients[sessid].connected);
+
+              _socket.clients[sessid].send('from server');
+
+              _client = get(_server, '/socket.io/xhr-multipart/' + sessid, function(response){
+                response.on('data', function(data){
+                  assert.ok(decode(data) == 'from server');
+                  _client.end();
+                  _server.close();
+                });
+              });
+            });
+            _client.end();
+            once = true;
+          }
+        });
+      });
+    });
   }
 
 };
diff --git a/tests/transports.xhr-polling.js b/tests/transports.xhr-polling.js
@@ -116,12 +116,14 @@ module.exports = {
       get(client(_server), '/socket.io/xhr-polling', function(data){
         var sessid = decode(data);
         assert.ok(_socket.clients[sessid]._open === false);
+        assert.ok(_socket.clients[sessid].connected);
         _socket.clients[sessid].send('from server');
         get(client(_server), '/socket.io/xhr-polling/' + sessid, function(data){
           var durationCheck;
           assert.ok(decode(data) == 'from server');
           setTimeout(function(){
             assert.ok(_socket.clients[sessid]._open);
+            assert.ok(_socket.clients[sessid].connected);
             durationCheck = true;
           }, 100);
           get(client(_server), '/socket.io/xhr-polling/' + sessid, function(){