Prepared cloudjs for tunneling possibility

digitalwm · Feb 27, 2012 · 335862a · 335862a
1 parent f20e099
commit 335862a
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/cloudjs.js b/cloudjs.js
@@ -464,14 +464,14 @@ Clouder.prototype.connect = function () {
             if(self.messagesInjected.removeElement(buf.toString().hashCode()) === true) {
                 return;
             }
+            self.emit("rawdata", buf);
 
             if(self._hasEncription === true) {
                 mode = new crypto.mode.ECB(crypto.pad.pkcs7);
                 dataBytes = crypto.util.hexToBytes(buf.toString());
                 dataDecripted = crypto.DES.decrypt(dataBytes, self._encryptionKey, {asBytes: true, mode: mode});
                 buf = crypto.charenc.UTF8.bytesToString(dataDecripted);
             }
-            self.emit("rawdata", buf.toString());
             msg = serializer.parse(buf);
             if(typeof(msg.type) === 'undefined' || typeof(msg.title) === 'undefined' || typeof(msg.body) === 'undefined') {
                 return;
@@ -600,10 +600,8 @@ Clouder.prototype.connect = function () {
     };
 
     this.inject = function(data) {
-        var messageBuffer;
+        this.messagesInjected.push(data.toString().hashCode());
-        messageBuffer = new Buffer(data);
+        this.socket.send(data, 0, data.length, this.port, this.group);
-        this.messagesInjected.push(messageBuffer.toString().hashCode());
-        this.socket.send(messageBuffer, 0, messageBuffer.length, this.port, this.group);
     };
 
     this.sendWithCallback = function(title, message, callback, timeout) {