ARCHIVE/xahau.js
1
0
Fork 0
mirror of https://github.com/Xahau/xahau.js.git synced 2025-11-21 20:55:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Enhanced security for idle server reconnect

Browse Source
This commit is contained in:
wltsmrz
2013-11-27 15:42:05 -08:00
parent b6a66e1820
commit dc04bbe737
1 changed files with 11 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/js/ripple/server.js
View File

@@ -45,13 +45,16 @@ function Server(remote, opts) {
}); });
function checkServerActivity() { function checkServerActivity() {
if (isNaN(self._lastLedgerClose)) return;
var delta = Date.now() - self._lastLedgerClose; var delta = Date.now() - self._lastLedgerClose;
if (delta > (1000 * 20)) { if (delta > (1000 * 20)) {
self.reconnect(); self.reconnect();
} }
}; };
this.once('connect', function() { this.once('ledger_closed', function() {
setInterval(checkServerActivity, 1000); setInterval(checkServerActivity, 1000);
}); });
}; };
@@ -251,8 +254,10 @@ Server.prototype.disconnect = function() {
*/ */
Server.prototype.reconnect = function() { Server.prototype.reconnect = function() {
if (this._ws) {
this._ws.once('close', this.connect.bind(this));
this.disconnect(); this.disconnect();
this.connect(); }
}; };
/** /**
@@ -336,6 +341,7 @@ Server.prototype._handleMessage = function(message) {
case 'ledgerClosed': case 'ledgerClosed':
this._lastLedgerClose = Date.now(); this._lastLedgerClose = Date.now();
this.emit('ledger_closed', message);
break; break;
case 'path_find': case 'path_find':
@@ -360,6 +366,8 @@ Server.prototype._handleMessage = function(message) {
} else if (message.error) { } else if (message.error) {
this._remote._trace('server: error: %s', message); this._remote._trace('server: error: %s', message);
console.log('ERROR', message);
request.emit('error', { request.emit('error', {
error : 'remoteError', error : 'remoteError',
error_message : 'Remote reported an error.', error_message : 'Remote reported an error.',