Skip to content

Commit

Permalink
Updated tests + added tests for meta API
Browse files Browse the repository at this point in the history
  • Loading branch information
Konstantin Burkalev authored and Konstantin Burkalev committed Apr 26, 2018
1 parent 3d03ca4 commit 65d2093
Show file tree
Hide file tree
Showing 3 changed files with 56 additions and 34 deletions.
4 changes: 2 additions & 2 deletions test/node-client-cra.js
View file
Expand Up @@ -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();
Expand Down
82 changes: 52 additions & 30 deletions test/node-client-meta.js
View file
Expand Up @@ -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 () {
Expand All @@ -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);
}
});

Expand Down
4 changes: 2 additions & 2 deletions test/node-client.js
View file
Expand Up @@ -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();
Expand Down

0 comments on commit 65d2093

Please sign in to comment.