socket: fix emit

dkgaoqi · Dec 24, 2012 · eb02138 · eb02138
1 parent de8e746
commit eb02138
Showing 1 changed file with 12 additions and 4 deletions.
diff --git a/lib/socket.js b/lib/socket.js
@@ -109,12 +109,20 @@ Socket.prototype.emit = function(ev){
       packet.id = this.nsp.ids++;
     }
 
-    // dispatch packet
-    this.packet(packet);
+    if (this.rooms || (this.flags && this.flags.broadcast)) {
+      this.adapter.broadcast(packet, {
+        except: [this.id],
+        rooms: this.rooms,
+        flags: this.flags
+      });
+    } else {
+      // dispatch packet
+      this.packet(packet);
+    }
 
     // reset flags
-    if (this.flags.length) this.flags = [];
-    if (this.rooms.lenth) this.rooms = [];
+    delete this.rooms;
+    delete this.flags;
   }
   return this;
 };