Can parse queues of messages.

adngdb · May 24, 2011 · 3dd83b5 · 3dd83b5
1 parent 3852d1b
commit 3dd83b5
Showing 1 changed file with 25 additions and 2 deletions.
diff --git a/lib/message-parser.js b/lib/message-parser.js
@@ -13,8 +13,16 @@ function MessageParser(engine) {
 MessageParser.prototype = {
 
     parse: function(message, clientId) {
-		var user = this.engine.getUser(clientId);
-		if (user != null) {
+		var user = null;
+
+		if (clientId._client) {
+			user = clientId;
+		}
+		else {
+			user = this.engine.getUser(clientId);
+		}
+
+		if (user) {
 			var obj = JSON.parse(message);
 
 			switch (obj.type) {
@@ -30,6 +38,9 @@ MessageParser.prototype = {
 				case "data":
 					this.parseData(obj.data, user);
 					break;
+				case "queue":
+					this.parseQueue(obj.data, user);
+					break;
 				default:
 					throw "Warning - MessageParser.parse - Unknown message type: " + obj.type; // TODO: using an object of type Exception
 			}
@@ -109,6 +120,18 @@ MessageParser.prototype = {
         return this;
     },
 
+    parseQueue: function(data, user) {
+		var i = 0
+			,ln = data.length
+			;
+
+		for (; i < ln; i++) {
+			this.parse(data[i], user);
+		}
+
+        return this;
+    },
+
 }
 
 module.exports = MessageParser;