Subscription implemented

Author: Josema

src/core/objects/configureRemoteFunctions.js

@@ -0,0 +1,10 @@
+dop.core.configureRemoteFunctions = function(node, object, object_owner_id) {
+    dop.util.path(object, function(source, prop, value, destiny, path) {
+        if (
+            isFunction(value) &&
+            value._name == dop.cons.REMOTE_FUNCTION_UNSETUP
+        ) {
+            dop.set(source, prop, value(node, object_owner_id, path.slice(0)))
+        }
+    })
+}

src/protocol/_onbroadcast.js

@@ -48,19 +48,3 @@ dop.protocol._onsubscribe = function(node, request_id, request, response) {
         }
     }
 }
-
-dop.core.configureRemoteFunctions = function(node, object, object_owner_id) {
-    dop.util.path(
-        object,
-        function(source, prop, value, destiny, path) {
-            console.log(prop, object_owner_id, path.slice(0))
-            if (
-                isFunction(value) &&
-                value._name == dop.cons.REMOTE_FUNCTION_UNSETUP
-            ) {
-                // dop.set(source, prop, value(node, object_owner_id, path.slice(0)))
-            }
-        },
-        {}
-    )
-}

src/protocol/_onsubscribe.js

@@ -1,16 +1,11 @@
-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
-    ) {
+dop.protocol.call = function(node, object_owner_id, path, params) {
+    var owner = node.owner[object_owner_id]
+    if (isObject(owner)) {
         params = Array.prototype.slice.call(params, 0)
         var request = dop.core.createRequest(
             node,
             dop.protocol.instructions.call,
-            object_data.node[node.token].owner,
+            object_owner_id,
             path,
             params
         )

src/protocol/broadcast.js

@@ -1,7 +1,57 @@
-dop.protocol.oncall = function(node, request_id, request) {
-    dop.protocol.onfunction(node, request_id, request, request[1], function(
-        permission
-    ) {
-        return permission.subscriber === 1
-    })
+dop.protocol.oncall = function(node, request_id, request, object_id) {
+    var path = request[2],
+        params = request[3],
+        subscriber = node.subscriber[object_id]
+
+    if (isObject(subscriber)) {
+        var function_name = path.pop(),
+            object = dop.util.get(subscriber.object, path),
+            f = object[function_name]
+
+        if (isFunction(f)) {
+            function resolve(value) {
+                var response = dop.core.createResponse(request_id, 0)
+                if (value !== undefined) response.push(value)
+                dop.core.storeAndSendRequests(node, response)
+                return value
+            }
+            function reject(err) {
+                dop.core.storeAndSendRequests(
+                    node,
+                    dop.core.createResponse(
+                        request_id,
+                        dop.core.error.reject_remote.CUSTOM_REJECTION,
+                        err
+                    )
+                )
+            }
+
+            if (dop.isRemoteFunction(f))
+                f.apply(null, params)
+                    .then(resolve)
+                    .catch(reject)
+            else
+                dop.core.localProcedureCall(
+                    f,
+                    params,
+                    resolve,
+                    reject,
+                    function(req) {
+                        req.node = node
+                        return req
+                    },
+                    dop.getObjectProxy(object)
+                )
+
+            return
+        }
+    }
+
+    dop.core.storeAndSendRequests(
+        node,
+        dop.core.createResponse(
+            request_id,
+            dop.core.error.reject_remote.FUNCTION_NOT_FOUND
+        )
+    )
 }

src/protocol/call.js

@@ -46,7 +46,8 @@ dop.util.pathRecursive = function(
                 skip !== true &&
                 value !== source &&
                 circular.indexOf(value) == -1 &&
-                (has_destiny && destiny[prop] !== undefined)
+                // ((has_destiny && destiny[prop] !== undefined) ||
+                source[prop] !== undefined
             ) {
                 circular.push(value)
                 dop.util.pathRecursive(