Renamed mutation -> patche on protocol, and building it

Author: Josema

.gitignore

@@ -1,4 +1,5 @@
 node_modules/
 npm-debug.log
 .vscode
-test*.js
+test*.js
+log

package.json

@@ -57,14 +57,14 @@
   "scripts": {
     "grunt": "grunt",
     "build": "grunt --build",
-    "test": "tap test/**.js test/transports/**.js",
+    "test": "tap test/**.js test/protocol/**.js",
     "test-electron": "browserify test/*.js | tape-run --render=\"faucet\"",
     "test-chrome": "browserify test/*.js | tape-run --render=\"faucet\" --browser chrome",
     "test-safari": "browserify test/*.js | tape-run --render=\"faucet\" --browser safari",
     "test-firefox": "browserify test/*.js | tape-run --render=\"faucet\" --browser firefox",
-    "test-websockets": "tap test/transports/**.js --test-arg=websockets",
-    "test-socketio": "tap test/transports/**.js --test-arg=socketio",
-    "test-sockjs": "tap test/transports/**.js --test-arg=sockjs",
-    "test-local": "tap test/transports/**.js --test-arg=local"
+    "test-websockets": "tap test/protocol/**.js --test-arg=websockets",
+    "test-socketio": "tap test/protocol/**.js --test-arg=socketio",
+    "test-sockjs": "tap test/protocol/**.js --test-arg=sockjs",
+    "test-local": "tap test/protocol/**.js --test-arg=local"
   }
 }

src/core/error.js

@@ -13,7 +13,7 @@ dop.core.error = {
     // Remote rejects
     reject_remote: {
         OBJECT_NOT_FOUND: 1,
-        1: 'Remote object not found or not permissions to be subscribed',
+        1: 'Remote object not found or not permissions to use it',
         SUBSCRIPTION_NOT_FOUND: 2,
         2: 'Subscription not found to unsubscribe this object',
         FUNCTION_NOT_FOUND: 3,

src/core/protocol/emitNodes.js

@@ -7,7 +7,7 @@ dop.core.emitNodes = function(action) {
             for (node_token in object_data.node) {
                 if (object_data.node[node_token].subscriber===1) {
                     node = dop.data.node[node_token];
-                    dop.protocol.mutation(node, object_id, action[object_id].action);
+                    dop.protocol.patch(node, Number(object_id), action[object_id].action);
                 }
             }
         }

src/core/protocol/registerObjectToNode.js

@@ -16,9 +16,11 @@ dop.core.registerObjectToNode = function(node, object) {
         object_data.nodes_total += 1;
         object_data.node[node.token] = {
             subscriber: 0, // 0 or 1 || false true 
-            owner: 0, // object_id_owner
+            owner: 0, // object_id_owner || 0 === false
             subscriber_version: 0, 
-            owner_version: 0
+            owner_version: 0,
+            pending_version: 0,
+            pending: {}
         };
     }
 

src/protocol/instructions.js

@@ -41,7 +41,7 @@ dop.protocol.instructions = {
                         // [-1234, 0, <return>]
 
                         // Owner -> Subscriptor
-    mutation: 5,        // [ 1234, <instruction>, <object_id>, <version>, <mutation>]
+    patch: 5,           // [ 1234, <instruction>, <object_id>, <version>, <patch>]
                         // [-1234, 0]
 };
 

src/protocol/mutation.js

@@ -0,0 +1,54 @@
+
+dop.protocol.patch = function(node, object_id, patch) {
+    var object_node = dop.data.object[object_id].node[node.token],
+        version = ++object_node.subscriber_version,
+        request = dop.core.createRequest(
+            node,
+            dop.protocol.instructions.patch,
+            object_id,
+            version,
+            patch
+        );
+
+    object_node.pending[version] = patch;
+    dop.core.storeSendMessages(node, request, dop.encodeFunction);
+    return request.promise;
+};
+
+dop.protocol.onpatch = function(node, request_id, request) {
+    var object_id = request[1],
+        version = request[2],
+        patch = request[3],
+        response = dop.core.createResponse(request_id),
+        object_data = dop.data.object[object_id],
+        object_node;
+    
+    if (isObject(object_data) && isObject(object_data.node[node.token]) && object_data.node[node.token].owner===object_id) {
+        object_node = object_data.node[node.token];
+        if (object_node.owner_version+1 === version) {
+            // We apply patch
+            object_node.owner_version += 1;
+            collector = dop.collectFirst();
+            dop.core.setActionFunction(object_data.object, patch);
+            collector.emitAndDestroy();
+            response.push(0);
+        }
+    }
+    else
+        response.push(dop.core.error.reject_remote.OBJECT_NOT_FOUND);
+    
+    dop.core.storeSendMessages(node, response);
+};
+
+dop.protocol._onpatch = function(node, request_id, request, response) {
+    var rejection = response[0],
+        promise = request.promise;
+    if (rejection !== undefined) {
+        if (rejection === 0) {
+            
+            promise.resolve(response[1]);
+        }
+        else
+            promise.reject(dop.core.getRejectError(rejection));
+    }
+};