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

Fixing OrderBook#_subscribe (WIP).

Browse Source
This commit is contained in:
Stefan Thomas
2013-12-24 14:57:39 -08:00
parent 96b46d2394
commit 38a6e8b009
1 changed files with 37 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

51
src/js/ripple/orderbook.js
View File

@@ -37,9 +37,11 @@ function OrderBook(remote, currency_gets, issuer_gets, currency_pays, issuer_pay
this.on('newListener', function (type, listener) {
if (~OrderBook.subscribe_events.indexOf(type)) {
if (!self._subs && self._remote._connected) {
self._subs += 1;
self._subscribe();
} else {
self._subs += 1;
}
self._subs += 1;
}
});
@@ -55,11 +57,8 @@ function OrderBook(remote, currency_gets, issuer_gets, currency_pays, issuer_pay
}
});
this._remote.on('connect', function () {
if (self._subs) {
self._subscribe();
}
});
// ST: This *should* call _prepareSubscribe.
this._remote.on('prepare_subscribe', this._subscribe.bind(this));
this._remote.on('disconnect', function () {
self._sync = false;
@@ -82,19 +81,43 @@ OrderBook.subscribe_events = ['transaction', 'model', 'trade'];
*/
OrderBook.prototype._subscribe = function () {
var self = this;
var request = self._remote.request_subscribe();
request.books([ self.to_json() ], true);
request.callback(function(err, res) {
if (err) {
// XXX What now?
} else {
if (self.is_valid() && self._subs) {
var request = this._remote.request_subscribe();
request.addBook(self.to_json(), true);
request.once('success', function(res) {
self._sync = true;
self._offers = res.offers;
self.emit('model', self._offers);
}
});
});
request.once('error', function(err) {
// XXX What now?
});
request.request();
}
};
/**
* Adds this orderbook to a subscription request.
// ST: Currently this is not working because the server cannot give snapshots
// for more than one order book in the same subscribe message.
OrderBook.prototype._prepareSubscribe = function (request) {
var self = this;
if (self.is_valid() && self._subs) {
request.addBook(self.to_json(), true);
request.once('success', function(res) {
self._sync = true;
self._offers = res.offers;
self.emit('model', self._offers);
});
request.once('error', function(err) {
// XXX What now?
});
}
};
*/
OrderBook.prototype.to_json = function () {
var json = {
taker_gets: {