Basics implemented for call instruction

Author: Josema

src/api/decode.js

@@ -1,17 +1,12 @@
 
 dop.decode = function(data, node) {
-    var functions = [],
-        undefineds = [],
+    var undefineds = [],
         index = 0,
         total,
         output = JSON.parse(data, function(property, value) {
-            return dop.core.decode.call(this, property, value, functions, undefineds);
+            return dop.core.decode.call(this, property, value, node, undefineds);
         });
 
-
-    for (total=functions.length; index<total; ++index)
-        functions[index][0][functions[index][1]] = dop.core.createRemoteFunction(node);
-
     for (total=undefineds.length,index=0; index<total; ++index)
         undefineds[index][0][undefineds[index][1]] = undefined;
 

src/core/error.js

@@ -8,6 +8,7 @@ dop.core.error = {
     reject: {
         OBJECT_NOT_FOUND: 'Object not found',
         SUBSCRIPTION_NOT_FOUND: 'Not subscription found to unsubscribe this object',
+        FUNCTION_NOT_FOUND: 'Function not found',
     }
 
 };

src/core/objects/setActionRemote.js

@@ -1,10 +1,10 @@
 
 dop.core.setActionRemote = function(object, action) {
     dop.util.path({a:action}, null, {a:object}, function(destiny, prop, value, typeofValue, path){
-        return (isFunction(value) && value.name==dop.core.createRemoteFunction.name) ?
-            dop.set(destiny, prop, value(dop.getObjectDop(object)[0], path.slice(1)))
-        :
-            dop.core.setActionMutator(destiny, prop, value, typeofValue, path);
+        if (isFunction(value) && value.name==dop.core.createRemoteFunction.name)
+            dop.set(destiny, prop, value(dop.getObjectDop(object)[0], path.slice(1)));
+        else
+            return dop.core.setActionMutator(destiny, prop, value, typeofValue, path);
     });
     return object;
 };

src/core/protocol/createRemoteFunction.js

@@ -10,9 +10,3 @@ dop.core.createRemoteFunction = function $DOP_REMOTE_FUNCTION_UNSETUP(node) {
         }
     }
 };
-dop.protocol.call = function(node, object_id, path, params) {
-
-    var params = Array.prototype.slice.call(params, 0);
-
-    console.log(node.token, dop.data.object[object_id].node[node.token].owner, path, params);
-};

src/core/protocol/decode.js

@@ -1,18 +1,17 @@
 var regexpdate = /^\d\d\d\d-\d\d-\d\dT\d\d:\d\d:\d\d.\d\d\dZ$/,
     regexpsplit = /\/(.+)\/([gimuy]{0,5})/;
 
-dop.core.decode = function(property, value, functions, undefineds) {
+dop.core.decode = function(property, value, node, undefineds) {
 
     if (typeof value == 'string') {
 
-        if (value === '~F') {
-            functions.push([this, property]);
-            return undefined;
-        }
+        if (value === '~F')
+            return dop.core.createRemoteFunction(node);
 
         if (value == '~U' && isObject(undefineds)) {
-            undefineds.push([this, property]); // http://stackoverflow.com/questions/17648150/how-does-json-parse-manage-undefined
-            return undefined;
+            this[property] = undefined;
+            // undefineds.push([this, property]); // http://stackoverflow.com/questions/17648150/how-does-json-parse-manage-undefined
+            // return undefined;
         }
 
         if (value === '~I')

src/protocol/_onsubscribe.js

@@ -37,5 +37,4 @@ dop.protocol._onsubscribe = function(node, request_id, request, response) {
             }
         }
     }
-
 };

src/protocol/call.js

@@ -0,0 +1,58 @@
+
+dop.protocol.call = function(node, object_id, path, params) {
+
+    var object_data = dop.data.object[object_id];
+
+    if (isObject(object_data) && isObject(object_data.node[node.token]) && object_data.node[node.token].owner>0) {
+        params = Array.prototype.slice.call(params, 0);
+        var request = dop.core.createRequest(
+            node,
+            dop.protocol.instructions.call,
+            object_data.node[node.token].owner,
+            path,
+            params
+        );
+        dop.core.storeSendMessages(node, request);
+        return request.promise;
+    }
+    else
+        return Promise.reject(dop.core.error.reject.OBJECT_NOT_FOUND);
+};
+
+
+dop.protocol.oncall = function(node, request_id, request) {
+    var object_id = request[1],
+        path = request[2],
+        params = request[3],
+        object_data = dop.data.object[object_id];
+
+    if (isObject(object_data) && isObject(object_data.node[node.token]) && object_data.node[node.token].subscriber) {
+        var f = dop.util.get(object_data.object, path);
+        if (isFunction(f)) {
+            dop.core.localProcedureCall(f, params, function(value) {
+                var response = dop.core.createResponse(request_id, 0);
+                if (value !== undefined)
+                    response.push(value);
+                dop.core.storeSendMessages(node, response);
+                return value;
+            }, function(err){
+                dop.core.storeSendMessages(node, dop.core.createResponse(request_id, err));
+            }, function(req) {
+                req.node = node;
+                return req;
+            });
+        }
+    }
+};
+
+
+dop.protocol._oncall = function(node, request_id, request, response) {
+    var rejection = response[0];
+    if (rejection !== undefined) {
+        (rejection !== 0) ?
+            request.promise.reject(rejection)
+        :
+            request.promise.resolve(response[1]);
+    }
+};
+

src/protocol/onsubscribe.js

@@ -3,9 +3,9 @@ dop.protocol.onsubscribe = function(node, request_id, request) {
 
     if (isFunction(dop.data.onsubscribe)) {
 
-        var args = Array.prototype.slice.call(request, 1);
+        var params = Array.prototype.slice.call(request, 1);
 
-        dop.core.localProcedureCall(dop.data.onsubscribe, args, function resolve(value) {
+        dop.core.localProcedureCall(dop.data.onsubscribe, params, function resolve(value) {
             if (isObject(value)) {
                 var object = dop.register(value),
                     object_id = dop.getObjectId(object),

src/protocol/unsubscribe.js

@@ -3,7 +3,7 @@ dop.protocol.unsubscribe = function(node, object) {
     var object_id = dop.getObjectId(object),
         object_data = dop.data.object[object_id];
 
-    if (isObject(object_data) && isObject(object_data.node[node.token]) && object_data.node[node.token].owner) {
+    if (isObject(object_data) && isObject(object_data.node[node.token]) && object_data.node[node.token].owner>0) {
         var request = dop.core.createRequest(
             node,
             dop.protocol.instructions.unsubscribe,