Release 0.6.16

The WebSocket.buffer would continue to grow, unabated, for each new message.
This buffer is now only utilized to process the nonce, and is set to empty (and no longer filled) once nonce has been received.
Parser instance appears to handle all message buffering, instead of WebSocket entity.

History.md

@@ -1,4 +1,24 @@
 
+0.6.16 / 2011-03-04
+===================
+
+  * Fixed cross domain xhr-polling in Safari [tifroz]
+
+0.6.15 / 2011-02-23
+===================
+
+  * Fixed memory leak in WebSocket transport [belorion]
+
+0.6.14 / 2011-02-18
+===================
+
+  * Fixed logging scope issue [shripad]
+
+0.6.13 / 2011-02-18
+===================
+
+  * Fixed references to listener when logging
+
 0.6.12 / 2011-02-18
 ===================
 

lib/socket.io/index.js

@@ -23,4 +23,4 @@ exports.Listener = require('./listener');
  * Version
  */
 
-exports.version = '0.6.12';
+exports.version = '0.6.16';

lib/socket.io/transports/htmlfile.js

@@ -33,7 +33,7 @@ HTMLFile.prototype._onConnect = function(req, res){
           var msg = qs.parse(body);
           self._onMessage(msg.data);
         } catch(e){
-          listener.options.log('htmlfile message handler error - ' + e.stack);
+          self.listener.options.log('htmlfile message handler error - ' + e.stack);
         }
         res.writeHead(200, {'Content-Type': 'text/plain'});
         res.write('ok');

lib/socket.io/transports/websocket.js

@@ -99,18 +99,16 @@ WebSocket.prototype._onConnect = function(req, socket){
   this.buffer = "";
   
   this.connection.addListener('data', function(data){
-    self.buffer += data;
     if (self.waitingForNonce) {
+    		self.buffer += data;
+
   		if (self.buffer.length < 8) { return; }
   		// Restore the connection to utf8 encoding after receiving the nonce
   		self.connection.setEncoding('utf8');
   		self.waitingForNonce = false;
   		// Stuff the nonce into the location where it's expected to be
   		self.upgradeHead = self.buffer.substr(0,8);
-  		self.buffer = self.buffer.substr(8);
-  		if (self.buffer.length > 0) {
-  		  self.parser.add(self.buffer);
-  		}
+                self.buffer = '';
   		if (self._proveReception(self._headers)) { self._payload(); }
   		return;
   	}

lib/socket.io/transports/xhr-multipart.js

@@ -47,7 +47,7 @@ Multipart.prototype._onConnect = function(req, res){
           var msg = qs.parse(body);
           self._onMessage(msg.data);
         } catch(e){
-          listener.options.log('xhr-multipart message handler error - ' + e.stack);
+          self.listener.options.log('xhr-multipart message handler error - ' + e.stack);
         }
         res.writeHead(200, headers);
         res.write('ok');

lib/socket.io/transports/xhr-polling.js

@@ -49,7 +49,7 @@ Polling.prototype._onConnect = function(req, res){
           var msg = qs.parse(body);
           self._onMessage(msg.data);
         } catch(e){
-          listener.options.log('xhr-polling message handler error - ' + e.stack);
+          self.listener.options.log('xhr-polling message handler error - ' + e.stack);
         }
         res.writeHead(200, headers);
         res.write('ok');
@@ -69,7 +69,7 @@ Polling.prototype._write = function(message){
     var headers = {'Content-Type': 'text/plain; charset=UTF-8', 'Content-Length': Buffer.byteLength(message)};
     // https://developer.mozilla.org/En/HTTP_Access_Control
     if (this.request.headers.origin && this._verifyOrigin(this.request.headers.origin)){
-      headers['Access-Control-Allow-Origin'] = this.request.headers.origin;
+      headers['Access-Control-Allow-Origin'] = (this.request.headers.origin === 'null' ? '*' : this.request.headers.origin);
       if (this.request.headers.cookie) headers['Access-Control-Allow-Credentials'] = 'true';
     }
     this.response.writeHead(200, headers);

package.json

@@ -1,6 +1,6 @@
 { "name" : "socket.io"
 , "description" : "The cross-browser WebSocket"
-, "version" : "0.6.12"
+, "version" : "0.6.16"
 , "author" : "LearnBoost"
 , "licenses" :
   [ { "type" : "MIT"