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

JS: Automatically subscribe to server.

Browse Source
This commit is contained in:
Arthur Britto
2012-10-17 15:37:23 -07:00
committed by Stefan Thomas
parent 43b7b5f2ff
commit 8b57357231
1 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
js/remote.js
View File

@@ -189,6 +189,7 @@ Remote.prototype._set_state = function (state) {
this.online_state = 'open'; this.online_state = 'open';
this.emit('connected'); this.emit('connected');
break; break;
case 'offline': case 'offline':
this.online_state = 'closed'; this.online_state = 'closed';
this.emit('disconnected'); this.emit('disconnected');
@@ -295,11 +296,11 @@ Remote.prototype._connect_start = function () {
}; };
if (self.online_target) { if (self.online_target) {
if (self.trace) console.log("remote: onopen: %s: online_target2=%s", ws.readyState, self.online_target); self._server_subscribe(); // Automatically subscribe.
self._set_state('online'); self._set_state('online');
} }
else { else {
if (self.trace) console.log("remote: onopen: %s: online_target3=%s", ws.readyState, self.online_target);
self._connect_stop(); self._connect_stop();
} }
}; };
@@ -323,11 +324,12 @@ Remote.prototype._connect_start = function () {
// Node's ws module doesn't pass arguments to onmessage. // Node's ws module doesn't pass arguments to onmessage.
ws.on('message', function (json, flags) { ws.on('message', function (json, flags) {
self._connect_message(json, flags); self._connect_message(ws, json, flags);
}); });
}; };
Remote.prototype._connect_message = function (json, flags) { // It is possible for messages to be dispatched after the connection is closed.
Remote.prototype._connect_message = function (ws, json, flags) {
var message = JSON.parse(json); var message = JSON.parse(json);
var unexpected = false; var unexpected = false;
var request; var request;
@@ -339,7 +341,7 @@ Remote.prototype._connect_message = function (json, flags) {
switch (message.type) { switch (message.type) {
case 'response': case 'response':
{ {
request = this.ws.response[message.id]; request = ws.response[message.id];
if (!request) { if (!request) {
unexpected = true; unexpected = true;
@@ -558,20 +560,23 @@ Remote.prototype.submit = function (transaction) {
// Subscribe to a server to get 'ledger_closed' events. // Subscribe to a server to get 'ledger_closed' events.
// 'subscribed' : This command was successful. // 'subscribed' : This command was successful.
// 'ledger_closed : ledger_closed and ledger_current_index are updated. // 'ledger_closed : ledger_closed and ledger_current_index are updated.
Remote.prototype.server_subscribe = function () { Remote.prototype._server_subscribe = function () {
var self = this; var self = this;
var request = new Request(this, 'server_subscribe'); var request = new Request(this, 'server_subscribe');
request. request.
on('success', function (message) { on('success', function (message) {
self.ledger_closed = message.ledger_closed;
self.ledger_current_index = message.ledger_current_index;
self.stand_alone = !!message.stand_alone; self.stand_alone = !!message.stand_alone;
self.emit('subscribed'); if (message.ledger_closed && message.ledger_current_index) {
self.ledger_closed = message.ledger_closed;
self.ledger_current_index = message.ledger_current_index;
self.emit('ledger_closed', self.ledger_closed, self.ledger_current_index-1); self.emit('ledger_closed', self.ledger_closed, self.ledger_current_index-1);
}
self.emit('subscribed');
}) })
.request(); .request();