Release 0.7.1

History.md

@@ -1,5 +1,11 @@
 
-0.0.1 / 2010-01-03
+0.7.1 / 2011-06-21 
 ==================
 
-  * Initial release
+  * Fixed cross-domain XHR.
+  * Added CORS test to xhr-polling suite.
+
+0.7.0 / 2010-06-21
+==================
+
+  * http://socket.io/announcement.html

lib/transports/http.js

@@ -46,7 +46,7 @@ HTTPTransport.prototype.handleRequest = function (req) {
     var buffer = ''
       , res = req.res
       , origin = req.headers.origin
-      , headers = { 'Content-Length': 0 }
+      , headers = { 'Content-Length': 1 }
       , self = this;
 
     req.on('data', function (data) {
@@ -66,8 +66,8 @@ HTTPTransport.prototype.handleRequest = function (req) {
       }
     }
 
-    res.writeHead(200);
-    res.end('');
+    res.writeHead(200, headers);
+    res.end('1');
   } else {
     this.response = req.res;
 

package.json

@@ -1,6 +1,6 @@
 {
     "name": "socket.io"
-  , "version": "0.7.0"
+  , "version": "0.7.1"
   , "description": "Realtime apps made cross-browser & easy with a WebSocket-like API"
   , "homepage": "http://socket.io"
   , "keywords": ["websocket", "socket", "realtime", "socket.io", "comet", "ajax"]

test/common.js

@@ -53,10 +53,10 @@ HTTPClient.prototype.request = function (path, opts, fn) {
   opts.host = 'localhost';
   opts.port = this.port;
   opts.path = path.replace(/{protocol}/g, io.protocol);
-  opts.headers = {
-      'Host': 'localhost'
-    , 'Connection': 'keep-alive'
-  };
+
+  opts.headers = opts.headers || {};
+  opts.headers.Host = 'localhost';
+  opts.headers.Connection = 'keep-alive';
 
   var req = http.request(opts, function (res) {
     if (false === opts.buffer)

test/transports.jsonp-polling.test.js

@@ -327,7 +327,7 @@ module.exports = {
         , parser.encodePacket({ type: 'disconnect' })
         , function (res, data) {
             res.statusCode.should.eql(200);
-            data.should.eql('');
+            data.should.eql('1');
           }
       );
 
@@ -398,7 +398,7 @@ module.exports = {
           ])
         , function (res, data) {
             res.statusCode.should.eql(200);
-            data.should.eql('');
+            data.should.eql('1');
           }
       );
 
@@ -507,7 +507,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/woot' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
       });
@@ -588,21 +588,21 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/woot' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/jsonp-polling/' + sid
                 , parser.encodePacket({ type: 'disconnect', endpoint: '/woot' })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
 
                     cl.post(
                         '/socket.io/{protocol}/jsonp-polling/' + sid
                       , parser.encodePacket({ type: 'message', data: 'ferret' })
                       , function (res, data) {
                           res.statusCode.should.eql(200);
-                          data.should.eql('');
+                          data.should.eql('1');
                         }
                     );
                   }
@@ -658,7 +658,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/a' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
 
@@ -667,7 +667,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/b' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
       });
@@ -723,7 +723,7 @@ module.exports = {
           , parser.encodePacket({ type: 'message', data: '' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
 
@@ -732,14 +732,14 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/a' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/jsonp-polling/' + sid
                 , parser.encodePacket({ type: 'message', endpoint: '/a', data: 'a' })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
                   }
               );
             }
@@ -750,14 +750,14 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/b' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/jsonp-polling/' + sid
                 , parser.encodePacket({ type: 'message', endpoint: '/b', data: 'b' })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
                   }
               );
             }

test/transports.xhr-polling.test.js

@@ -263,7 +263,7 @@ module.exports = {
         , parser.encodePacket({ type: 'disconnect' })
         , function (res, data) {
             res.statusCode.should.eql(200);
-            data.should.eql('');
+            data.should.eql('1');
           }
       );
 
@@ -334,7 +334,7 @@ module.exports = {
           ])
         , function (res, data) {
             res.statusCode.should.eql(200);
-            data.should.eql('');
+            data.should.eql('1');
           }
       );
 
@@ -443,7 +443,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/woot' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
       });
@@ -524,21 +524,21 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/woot' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
                 , parser.encodePacket({ type: 'disconnect', endpoint: '/woot' })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
 
                     cl.post(
                         '/socket.io/{protocol}/xhr-polling/' + sid
                       , parser.encodePacket({ type: 'message', data: 'ferret' })
                       , function (res, data) {
                           res.statusCode.should.eql(200);
-                          data.should.eql('');
+                          data.should.eql('1');
                         }
                     );
                   }
@@ -594,7 +594,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/a' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
 
@@ -603,7 +603,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/b' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
       });
@@ -659,7 +659,7 @@ module.exports = {
           , parser.encodePacket({ type: 'message', data: '' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
 
@@ -668,14 +668,14 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/a' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
                 , parser.encodePacket({ type: 'message', endpoint: '/a', data: 'a' })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
                   }
               );
             }
@@ -686,14 +686,14 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/b' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
                 , parser.encodePacket({ type: 'message', endpoint: '/b', data: 'b' })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
                   }
               );
             }
@@ -795,8 +795,9 @@ module.exports = {
                 type: 'json'
               , data: { tobi: 'rocks' }
             })
-          , function (res) {
+          , function (res, data) {
               res.statusCode.should.eql(200);
+              data.should.equal('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -804,8 +805,9 @@ module.exports = {
                       type: 'json'
                     , data: 5000
                   })
-                , function (res) {
+                , function (res, data) {
                     res.statusCode.should.eql(200);
+                    data.should.equal('1');
                   }
               );
             }
@@ -932,8 +934,9 @@ module.exports = {
                 type: 'event'
               , name: 'jane'
             })
-          , function (res) {
+          , function (res, data) {
               res.statusCode.should.eql(200);
+              data.should.equal('1');
             }
         );
       });
@@ -979,8 +982,9 @@ module.exports = {
               , name: 'woot'
               , args: ['a', 2, [1, 2]]
             })
-          , function (res) {
+          , function (res, data) {
               res.statusCode.should.eql(200);
+              data.should.equal('1');
             }
         );
       });
@@ -1246,7 +1250,7 @@ module.exports = {
             })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -1315,7 +1319,7 @@ module.exports = {
           })
         , function (res, data) {
             res.statusCode.should.eql(200);
-            data.should.eql('');
+            data.should.eql('1');
           }
       );
     });
@@ -1364,7 +1368,7 @@ module.exports = {
             })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
             }
         );
       });
@@ -1500,7 +1504,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -1566,7 +1570,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/a' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -1577,7 +1581,7 @@ module.exports = {
                   })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
                   }
               );
             }
@@ -1616,7 +1620,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -1674,7 +1678,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -1740,7 +1744,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/a' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -1751,7 +1755,7 @@ module.exports = {
                   })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
                   }
               );
             }
@@ -1800,7 +1804,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/a' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -1812,7 +1816,7 @@ module.exports = {
                   })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
                   }
               );
             }
@@ -1850,7 +1854,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               s.volatile.send('woot');
 
@@ -1902,7 +1906,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               s.volatile.json.send(15);
 
@@ -1954,7 +1958,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               s.volatile.json.emit('woot');
 
@@ -2006,7 +2010,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2073,7 +2077,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2140,7 +2144,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/chrislee' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2211,7 +2215,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/tobi' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2223,7 +2227,7 @@ module.exports = {
                   })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
 
                     cl.get(
                         '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2286,7 +2290,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/tobi' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2299,7 +2303,7 @@ module.exports = {
                   })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
 
                     cl.get(
                         '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2362,7 +2366,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/tobi' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.post(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2376,7 +2380,7 @@ module.exports = {
                   })
                 , function (res, data) {
                     res.statusCode.should.eql(200);
-                    data.should.eql('');
+                    data.should.eql('1');
 
                     cl.get(
                         '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2438,7 +2442,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/woot' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2466,7 +2470,7 @@ module.exports = {
                         })
                       , function (res, data) {
                           res.statusCode.should.eql(200);
-                          data.should.eql('');
+                          data.should.eql('1');
                         }
                     );
                   }
@@ -2514,7 +2518,7 @@ module.exports = {
           , parser.encodePacket({ type: 'connect', endpoint: '/rapture' })
           , function (res, data) {
               res.statusCode.should.eql(200);
-              data.should.eql('');
+              data.should.eql('1');
 
               cl.get(
                   '/socket.io/{protocol}/xhr-polling/' + sid
@@ -2545,7 +2549,7 @@ module.exports = {
                         })
                       , function (res, data) {
                           res.statusCode.should.eql(200);
-                          data.should.eql('');
+                          data.should.eql('1');
                         }
                     );
                   }
@@ -2554,6 +2558,65 @@ module.exports = {
         );
       });
     });
-  }
+  },
+
+  'test CORS': function (done) {
+    var cl = client(++ports)
+      , io = create(cl)
+      , messaged = false;
+
+    io.configure(function () {
+      io.set('polling duration', .05);
+      io.set('close timeout', .05);
+    });
+
+    io.sockets.on('connection', function (socket) {
+      socket.send('woot');
+
+      socket.on('message', function (msg) {
+        msg.should.equal('woot');
+        messaged = true;
+      });
+
+      socket.on('disconnect', function () {
+        cl.end();
+        io.server.close();
+        done();
+      });
+    });
+
+    cl.handshake(function (sid) {
+      cl.get('/socket.io/{protocol}/xhr-polling/' + sid, {
+        headers: {
+          Origin: 'http://localhost:3500'
+        }
+      }, function (res, packs) {
+        var headers = res.headers;
+
+        headers['access-control-allow-origin'].should.equal('*');
+        should.strictEqual(headers['access-control-allow-credentials'], undefined);
+
+        packs.should.have.length(1);
+        packs[0].type.should.eql('message');
+        packs[0].data.should.eql('woot');
+
+        cl.post('/socket.io/{protocol}/xhr-polling/' + sid, parser.encodePacket({
+            type: 'message'
+          , data: 'woot'
+        }), {
+          headers: {
+              Origin: 'http://localhost:3500'
+            , Cookie: 'woot=woot'
+          }
+        }, function (res, data) {
+          var headers = res.headers;
+          headers['access-control-allow-origin'].should.equal('*');
+          headers['access-control-allow-credentials'].should.equal('true');
+
+          data.should.equal('1');
+        });
+      });
+    });
+  },
 
 };