Making mutation instruction

Author: Josema

src/core/objects/emitObservers.js

@@ -18,7 +18,7 @@ dop.core.emitObservers = function(mutations) {
         subobject = mutation.object;
         object_dop = dop.getObjectDop(subobject);
 
-        if (!mutationsWithSubscribers /*&& dop.data.object_data[object_dop[0]].nodes > 0*/)
+        if (!mutationsWithSubscribers && isObject(dop.data.object[object_dop[0]]))
             mutationsWithSubscribers = true;
 
         // Emiting mutations to observerProperties

src/core/protocol/emitNodes.js

@@ -1,12 +1,15 @@
 
 dop.core.emitNodes = function(action) {
-    // var object_id, node_token, node;
-    // for (object_id in action) {
-    //     if (dop.data.object_data[object_id].nodes > 0) {
-    //         for (node_token in dop.data.object_data[object_id].node) {
-    //             node = dop.data.node[node_token];
-    //             dop.protocol.merge(node, object_id, action[object_id]);
-    //         }
-    //     }
-    // }
+    var object_id, node_token, node, object_data;
+    for (object_id in action) {
+        if (isObject(dop.data.object[object_id])) {
+            object_data = dop.data.object[object_id];
+            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);
+                }
+            }
+        }
+    }
 };

src/protocol/mutation.js

@@ -1,9 +1,12 @@
 
 dop.protocol.mutation = function(node, object_id, action) {
-    
-    console.log(node.token, object_id, action);
-    // node.send(JSON.stringify(
-    //     dop.core.createRequest(node, dop.protocol.instructions.connect, token)
-    //));
+    var version = ++dop.data.object[object_id].node[node.token].subscriber_version,
+        request = dop.core.createRequest(node, dop.protocol.instructions.mutation, object_id, version, action);
 
-};
+    dop.core.storeSendMessages(node, request);
+    return request.promise;
+};
+
+dop.protocol.onmutation = function(node, request_id, request) {
+    console.log( dop.env,request_id,request );
+}

test/protocol/mutations.js

@@ -0,0 +1,66 @@
+var test = require('tape');
+var dop = require('../../dist/nodejs').create();
+var dopClient1 = require('../../dist/nodejs').create();
+var dopClient2 = require('../../dist/nodejs').create();
+var transportName = process.argv[2] || 'local';
+var transportListen = require('dop-transports').listen[transportName];
+var transportConnect = require('dop-transports').connect[transportName];
+
+dop.env = 'SERVER';
+dopClient1.env = 'CLIENT1';
+dopClient2.env = 'CLIENT2';
+
+var server = dop.listen({transport:transportListen})
+var client1 = dopClient1.connect({transport:transportConnect, listener:server})
+var client2 = dopClient2.connect({transport:transportConnect, listener:server})
+
+
+
+
+
+var objServer = dop.register({
+    number:1,
+    subobject:{},
+    arr:[]
+})
+dop.onsubscribe(function(){
+    return objServer;
+})
+
+
+
+
+
+// // setBroadcastFunction(object, 'namefunction')
+
+// test('BROADCASTING TO CLIENTS', function(t) {
+
+client1.subscribe().into({subobject:{broadcast:function(a,b){return a+b}}})
+.then(function(obj) {
+    return client2.subscribe().into({subobject:{broadcast:function(a,b){return a*b}}})
+})
+.then(function(obj) {
+    
+    // var collector = dop.collect();
+    objServer.number = 25;
+    objServer.arr = [1,2,3];
+    // collector.emitAndDestroy();
+
+//     var promises = objServer.subobject.broadcast(2,5);
+//     t.equal(Array.isArray(promises), true, 'Promises is array');
+//     t.equal(promises.length, 2, 'Promises are two promises');
+//     t.equal(promises[0] instanceof Promise, true, 'First promise is instanceof Promise');
+//     Promise.all(promises)
+//     .then(function(values){
+//         t.equal(values[0], 7, 'First value must be 2+5=7');
+//         t.equal(values[0], 7, 'Second value must be 2*5=10');
+//         t.end()
+//     })
+//     // .catch(function(err){
+//     //     console.log( err );
+//     // })
+})
+// })
+
+
+// // More test todo