Removed connect instruction from protocol, now is concern of the transport

Author: Josema

package.json

@@ -3,6 +3,7 @@
   "version": "0.6.0",
   "main": "./dist/nodejs.js",
   "browser": "./dist/browser.js",
+  "unpkg": "./dist/browser.min.js",
   "license": "MIT",
   "url": "http://www.distributedobjectprotocol.org",
   "repository": {

src/core/api_transports/emitConnect.js

@@ -4,4 +4,5 @@ dop.core.emitConnect = function(node) {
     if (node.listener)
         node.listener.emit('connect', node);
     node.emit('connect');
+    dop.core.sendMessages(node);
 };

src/core/api_transports/emitMessage.js

@@ -19,7 +19,7 @@ dop.core.emitMessage = function(node, message_string, message_raw) {
 
 
     // Managing protocol
-    if (dop.util.typeof(messages) == 'array') {
+    if (isArray(messages)) {
 
         // Detecting if is multimessage
         if (typeof messages[0] == 'number')

src/core/api_transports/emitReconnect.js

@@ -5,4 +5,5 @@ dop.core.emitReconnect = function(node, oldSocket, newNode) {
         node.listener.emit('reconnect', node, oldSocket);
     }
     node.emit('reconnect', oldSocket);
+    dop.core.sendMessages(node);
 };

src/core/api_transports/sendConnect.js

@@ -5,7 +5,7 @@ dop.core.node = function() {
     this.connected = false;
     this.request_inc = 1;
     this.requests = {};
-    this.requests_queue = [];
+    this.message_queue = []; // Response / Request / instrunctions queue
     this.object_subscribed = {};
     this.object_owner = {};
     // Generating token
@@ -39,16 +39,15 @@ dop.protocol.unsubscribe = function(node, object) {
 
     if (isObject(object_data) && isObject(object_data.node[node.token]) && object_data.node[node.token].owner) {
         var request = dop.core.createRequest(node, dop.protocol.instructions.unsubscribe, object_id);
-        dop.core.storeRequest(node, request);
-        if (node.connected)
-            dop.core.sendRequests(node);
+        dop.core.storeSendMessages(node, request);
         return request.promise;
     }
     else
         return Promise.reject(dop.core.error.reject.SUBSCRIPTION_NOT_FOUND);
 };
 
 
+
 dop.protocol.onunsubscribe = function(node, request_id, request) {
     var object_id = request[1],
         object_data = dop.data.object[object_id],
@@ -70,5 +69,5 @@ dop.protocol.onunsubscribe = function(node, request_id, request) {
     else
         response.push(dop.core.error.reject.SUBSCRIPTION_NOT_FOUND);
 
-    dop.core.sendResponse(node, response);
+    dop.core.storeSendMessages(node, response);
 };

src/core/constructors/node.js

@@ -2,6 +2,7 @@
 dop.core.createRequest = function(node, instruction) {
     var request_id = node.request_inc++,
         request = Array.prototype.slice.call(arguments, 1);
+    node.requests[request_id] = request;
     request.unshift(request_id);
     request.promise = dop.core.createAsync();
     return request;

src/core/protocol/createRequest.js

@@ -0,0 +1,29 @@
+
+dop.core.sendMessages = function(node) {
+    var total = node.message_queue.length;
+    if (total>0 && node.connected) {
+        var index = 0,
+            messages_wrapped = [],
+            message_string;
+        
+        for (;index<total; ++index)
+            messages_wrapped.push( node.message_queue[index][1](node.message_queue[index][0]) );
+
+        
+        message_string = (index>1) ? '['+messages_wrapped.join(',')+']' : messages_wrapped[0];
+
+        node.message_queue = [];
+        node.send(message_string);
+    }
+};
+
+
+
+        // var index = 0,
+        //     message = wrapper((total>1) ? requests : requests[0]);
+
+        // for (;index<total; ++index)
+        //     node.requests[requests[index][0]] = requests[index];
+
+        // node.requests_queue = [];
+        // node.send(message);