ARCHIVE/xahau.js
1
0
Fork 0
mirror of https://github.com/Xahau/xahau.js.git synced 2025-11-26 07:05:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

Multi-server API

Browse Source
This commit is contained in:
wltsmrz
2013-06-26 04:22:12 +09:00
parent 07d33d817b
commit 6e36ded34f
1 changed files with 28 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
src/js/ripple/remote.js
View File

@@ -358,13 +358,28 @@ var Remote = function (opts, trace) {
var server = new Server (this, {url: url}) var server = new Server (this, {url: url})
if ('maxListeners' in opts) { if (!('servers' in opts)) {
// This is used to remove Emitter warnings opts.servers = [
server.setMaxListeners (opts.maxListeners) {
this.setMaxListeners (opts.maxListeners) host: opts.websocket_ip,
port: opts.websocket_port,
secure: opts.websocket_ssl,
trusted: opts.trusted
}
]
} }
this.add_server(server) opts.servers.forEach(function(server) {
var i = Number(server.pool) || 1;
while (i--) { self.add_server(server); }
});
if ('maxListeners' in opts) {
// This is used to remove Emitter warnings
opts.servers.concat(this).forEach(function(emitter) {
emitter.setMaxListeners(opts.maxListeners);
});
}
this.on('newListener', function (type, listener) { this.on('newListener', function (type, listener) {
if ('transaction_all' === type) { if ('transaction_all' === type) {
@@ -428,9 +443,16 @@ var isTefFailure = function (engine_result_code) {
return (engine_result_code >= -299 && engine_result_code < 199); return (engine_result_code >= -299 && engine_result_code < 199);
}; };
Remote.prototype.add_server = function (server) { Remote.prototype.add_server = function (opts) {
var self = this; var self = this;
var url = (opts.secure || opts.websocket_ssl) ? 'wss://' : 'ws://'
+ (opts.host || opts.websocket_ip) + ':'
+ (opts.port || opts.websocket_port)
;
var server = new Server(this, {url: url})
server.on('message', function (data) { server.on('message', function (data) {
self._handle_message(data); self._handle_message(data);
}); });