From 65d2093e55f172140e149d278ea51312b9f43247 Mon Sep 17 00:00:00 2001 From: Konstantin Burkalev Date: Thu, 26 Apr 2018 18:13:35 +0300 Subject: [PATCH] Updated tests + added tests for meta API --- test/node-client-cra.js | 4 +- test/node-client-meta.js | 82 +++++++++++++++++++++++++--------------- test/node-client.js | 4 +- 3 files changed, 56 insertions(+), 34 deletions(-) diff --git a/test/node-client-cra.js b/test/node-client-cra.js index 626b810..031b861 100644 --- a/test/node-client-cra.js +++ b/test/node-client-cra.js @@ -30,8 +30,8 @@ ws = new Wampy('ws://webxp/ws/', { ws.publish('message.received', ['New message'], null, { exclude_me: false }); }, 5000); }, - onError: function (err, details) { console.log('+' + (Date.now() - d) + 'ms: Subscription error:' + err); }, - onEvent: function (arrayPayload, objectPayload) { + onError: function (err) { console.log('+' + (Date.now() - d) + 'ms: Subscription error:' + err); }, + onEvent: function (res) { console.log('+' + (Date.now() - d) + 'ms: Received new message!'); console.log('+' + (Date.now() - d) + 'ms: Closing connection...'); ws.disconnect(); diff --git a/test/node-client-meta.js b/test/node-client-meta.js index 234c92f..fc0250d 100644 --- a/test/node-client-meta.js +++ b/test/node-client-meta.js @@ -16,58 +16,81 @@ ws = new Wampy('ws://webxp/ws/', { onConnect: function () { console.log('+' + (Date.now() - d) + 'ms: Yahoo! We are online!'); ws.subscribe('wamp.session.on_join', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.session.on_join message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); + ws.call('wamp.session.count', null, function (result) { + console.log('Received RPC wamp.session.count result!'); + console.log(result); + }); } }).subscribe('wamp.session.on_leave', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.session.on_leave message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); + ws.call('wamp.session.count', null, function (result) { + console.log('Received RPC wamp.session.count result!'); + console.log(result); + }); } }).subscribe('wamp.subscription.on_create', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.subscription.on_create message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); } }).subscribe('wamp.subscription.on_subscribe', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.subscription.on_subscribe message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); + ws.call('wamp.subscription.list_subscribers', res.argsList[1], function (result) { + console.log('Received RPC wamp.subscription.list_subscribers result!'); + console.log(result); + }); + ws.call('wamp.subscription.count_subscribers', res.argsList[1], function (result) { + console.log('Received RPC wamp.subscription.count_subscribers result!'); + console.log(result); + }); } }).subscribe('wamp.subscription.on_unsubscribe', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.subscription.on_unsubscribe message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); + ws.call('wamp.subscription.list_subscribers', res.argsList[1], function (result) { + console.log('Received RPC wamp.subscription.list_subscribers result!'); + console.log(result); + }); + ws.call('wamp.subscription.count_subscribers', res.argsList[1], function (result) { + console.log('Received RPC wamp.subscription.count_subscribers result!'); + console.log(result); + }); } }).subscribe('wamp.subscription.on_delete', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.subscription.on_delete message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); } }).subscribe('wamp.registration.on_create', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.registration.on_create message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); } }).subscribe('wamp.registration.on_register', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.registration.on_register message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); + ws.call('wamp.registration.list_callees', res.argsList[1], function (result) { + console.log('Received RPC wamp.registration.list_callees result!'); + console.log(result); + }); + ws.call('wamp.registration.count_callees', res.argsList[1], function (result) { + console.log('Received RPC wamp.registration.count_callees result!'); + console.log(result); + }); } }).subscribe('wamp.registration.on_unregister', { - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.registration.on_unregister message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); } }).subscribe('wamp.registration.on_delete', { onSuccess: function () { @@ -87,10 +110,9 @@ ws = new Wampy('ws://webxp/ws/', { }); }, 5000); }, - onEvent: function (arrayPayload, objectPayload) { + onEvent: function (res) { console.log('Received wamp.registration.on_delete message!'); - console.log(arrayPayload); - console.log(objectPayload); + console.log(res); } }); diff --git a/test/node-client.js b/test/node-client.js index bdd1fe2..d19ad9e 100644 --- a/test/node-client.js +++ b/test/node-client.js @@ -22,8 +22,8 @@ ws = new Wampy('ws://webxp/ws/', { ws.publish('message.received', ['New message'], null, { exclude_me: false }); }, 5000); }, - onError: function (err, details) { console.log('+' + (Date.now() - d) + 'ms: Subscription error:' + err); }, - onEvent: function (arrayPayload, objectPayload) { + onError: function (err) { console.log('+' + (Date.now() - d) + 'ms: Subscription error:' + err); }, + onEvent: function (res) { console.log('+' + (Date.now() - d) + 'ms: Received new message!'); console.log('+' + (Date.now() - d) + 'ms: Closing connection...'); ws.disconnect();