Release 0.7.6

History.md

@@ -1,4 +1,19 @@
 
+0.7.6 / 2011-06-30
+==================
+
+  * Fixed general dispatching when a client has closed.
+
+0.7.5 / 2011-06-30
+==================
+
+  * Fixed dispatching to clients that are disconnected.
+
+0.7.4 / 2011-06-30
+==================
+
+  * Fixed; only clear handlers if they were set. [level09]
+
 0.7.3 / 2011-06-30
 ==================
 

examples/chat/app.js

@@ -62,11 +62,7 @@ var io = sio.listen(app)
   , nicknames = {};
 
 io.set('transports', [
-    'websocket'
-  , 'flashsocket'
-  , 'htmlfile'
   , 'xhr-polling'
-  , 'jsonp-polling'
 ]);
 
 io.sockets.on('connection', function (socket) {

lib/manager.js

@@ -326,6 +326,8 @@ Manager.prototype.onOpen = function (id) {
 Manager.prototype.onDispatch = function (room, packet, volatile, exceptions) {
   // go through the users who have pending buffers
   for (var i = 0, l = this.closedA.length; i < l; i++) {
+    if (!this.roomClients[this.closedA[i]]) continue;
+
     if (this.roomClients[this.closedA[i]][room]) {
       if (!~exceptions.indexOf(this.closedA[i])) {
         this.closed[this.closedA[i]].push(packet);
@@ -407,7 +409,9 @@ Manager.prototype.onClose = function (id) {
  */
 
 Manager.prototype.onClientDispatch = function (id, packet) {
-  this.closed[id].push(packet);
+  if (this.closed[id]) {
+    this.closed[id].push(packet);
+  }
 };
 
 /**

lib/socket.io.js

@@ -15,7 +15,7 @@ var client = require('socket.io-client');
  * Version.
  */
 
-exports.version = '0.7.3';
+exports.version = '0.7.6';
 
 /**
  * Supported protocol version.

lib/transport.js

@@ -115,6 +115,8 @@ Transport.prototype.setHandlers = function () {
   this.socket.on('close', this.bound.close);
   this.socket.on('error', this.bound.error);
   this.socket.on('drain', this.bound.drain);
+
+  this.handlersSet = true;
 };
 
 /**
@@ -124,14 +126,16 @@ Transport.prototype.setHandlers = function () {
  */
 
 Transport.prototype.clearHandlers = function () {
-  this.store.unsubscribe('disconnect-force:' + this.id);
-  this.store.unsubscribe('heartbeat-clear:' + this.id);
-  this.store.unsubscribe('dispatch:' + this.id);
+  if (this.handlersSet) {
+    this.store.unsubscribe('disconnect-force:' + this.id);
+    this.store.unsubscribe('heartbeat-clear:' + this.id);
+    this.store.unsubscribe('dispatch:' + this.id);
 
-  this.socket.removeListener('end', this.bound.end);
-  this.socket.removeListener('close', this.bound.close);
-  this.socket.removeListener('error', this.bound.error);
-  this.socket.removeListener('drain', this.bound.drain);
+    this.socket.removeListener('end', this.bound.end);
+    this.socket.removeListener('close', this.bound.close);
+    this.socket.removeListener('error', this.bound.error);
+    this.socket.removeListener('drain', this.bound.drain);
+  }
 };
 
 /**

package.json

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