Added three nodes test

Author: Josema

test/ES6/call.js

@@ -275,3 +275,58 @@ test('Promise.reject', async function(t) {
     t.end()
     closeServer()
 })
+
+test('basic three nodes', async t => {
+    const {
+        dopServer,
+        dopClient,
+        nodeClient,
+        nodeSubClient,
+        close
+    } = await connect(t)
+    const objectServer = {
+        times: (a, b) => a * b
+    }
+    dopServer.onSubscribe(() => objectServer)
+    const objectClient = await nodeClient.subscribe()
+    dopClient.onSubscribe(() => objectClient)
+    const objectSubClient = await nodeSubClient.subscribe()
+
+    t.equal(await objectClient.times(5, 5), 25)
+    t.equal(await objectSubClient.times(4, 2), 8)
+    close()
+})
+
+test('throwing error three nodes', async t => {
+    const {
+        dopServer,
+        dopClient,
+        nodeClient,
+        nodeSubClient,
+        close
+    } = await connect(t)
+    const objectServer = {
+        error: customerror => {
+            throw customerror
+        }
+    }
+    dopServer.onSubscribe(() => objectServer)
+    const objectClient = await nodeClient.subscribe()
+    dopClient.onSubscribe(() => objectClient)
+    const objectSubClient = await nodeSubClient.subscribe()
+
+    try {
+        await objectClient.error('Custom remote error')
+        t.equal(true, false, 'This should not happen one')
+    } catch (e) {
+        t.equal(e, 'Custom remote error')
+    }
+
+    try {
+        await objectSubClient.error('Custom sub remote error')
+        t.equal(true, false, 'This should not happen two')
+    } catch (e) {
+        t.equal(e, 'Custom sub remote error')
+    }
+    close()
+})

test/ES6/subscribe.js

@@ -95,35 +95,23 @@ test('observe mutations after subscription', async t => {
     await nodeClient.subscribe().into(objectClient)
 })
 
-// test('into() observe', t => {
-//     const dopServer = dop.create()
-//     const dopClient = dop.create()
-//     const objectServer = dopServer.register({ inc: 0 })
-//     const objectClient = dopClient.register({ deep: {} })
-//     const transportServer = dopServer.listen({ transport: transportListen })
-//     dopServer.onSubscribe(() => objectServer)
-//     ;(function loop(times) {
-//         const transportClient = dopClient.connect({
-//             transport: transportConnect
-//         })
-//         transportClient.on('connect', async nodeClient => {
-//             // t.notDeepEqual(objectServer, objectClient.deep)
-//             await nodeClient.subscribe().into(objectClient.deep)
-//             t.deepEqual(objectServer, objectClient.deep)
-//             const observer = dopClient.createObserver(() => {
-//                 t.deepEqual(objectServer, objectClient.deep)
-//                 setTimeout(() => {
-//                     nodeClient.disconnect()
-//                     if (times === 2) {
-//                         t.end()
-//                         transportServer.socket.close()
-//                     } else {
-//                         loop(times + 1)
-//                     }
-//                 }, 0)
-//             })
-//             observer.observeAll(objectClient)
-//             objectServer.inc += 1
-//         })
-//     })(1)
-// })
+test('basic three nodes', async t => {
+    const {
+        dopServer,
+        dopClient,
+        nodeClient,
+        nodeSubClient,
+        close
+    } = await connect(t)
+    const objectServer = {
+        hello: 'world',
+        deep: { hola: 'mundo' }
+    }
+    dopServer.onSubscribe(() => objectServer)
+    const objectClient = await nodeClient.subscribe()
+    dopClient.onSubscribe(() => objectClient)
+    const objectSubClient = await nodeSubClient.subscribe()
+    t.deepEqual(objectServer, objectClient)
+    t.deepEqual(objectSubClient, objectClient)
+    close()
+})

test/protocol/.connect.js

@@ -3,29 +3,47 @@ const transportName = process.argv[2] || 'local'
 const transportListen = require('dop-transports').listen[transportName]
 const transportConnect = require('dop-transports').connect[transportName]
 
-function connect(t, end = true) {
+function connect(t, end = true, port2 = 56724) {
     return new Promise(function(response, reject) {
         const dopServer = dop.create()
         const dopClient = dop.create()
+        const dopSubClient = dop.create()
         dopServer.env = 'SERVER'
-        dopClient.env = 'CLIENT1'
+        dopClient.env = 'CLIENT'
+        dopSubClient.env = 'SUBCLIENT'
         const transportServer = dopServer.listen({ transport: transportListen })
+        const transportClientListen = dopClient.listen({
+            transport: transportListen,
+            port: port2
+        })
         const transportClient = dopClient.connect({
             transport: transportConnect
         })
+
         transportClient.on('connect', function(nodeClient) {
-            const close = function() {
-                nodeClient.disconnect()
-                transportServer.socket.close()
-                if (end) t.end()
-            }
-            response({
-                dopServer,
-                dopClient,
-                transportServer,
-                transportClient,
-                nodeClient,
-                close
+            const transportSubClient = dopSubClient.connect({
+                transport: transportConnect,
+                url: 'ws://localhost:' + port2
+            })
+            transportSubClient.on('connect', function(nodeSubClient) {
+                const close = function() {
+                    nodeSubClient.disconnect()
+                    transportServer.socket.close()
+                    nodeClient.disconnect()
+                    transportClientListen.socket.close()
+                    if (end) t.end()
+                }
+                response({
+                    dopServer,
+                    dopClient,
+                    dopSubClient,
+                    transportServer,
+                    transportClient,
+                    transportSubClient,
+                    nodeClient,
+                    nodeSubClient,
+                    close
+                })
             })
         })
     })