mirror of
https://github.com/XRPLF/rippled.git
synced 2025-12-06 17:27:55 +00:00
Integration test to subscribe to offer books.
This commit is contained in:
Edward Hennis
committed by
Vinnie Falco
Vinnie Falco
parent
b2ba6a0c85
commit
8ab1e7d432
653
test/subscribe-book-test.js
Normal file
653
test/subscribe-book-test.js
Normal file
@@ -0,0 +1,653 @@
|
||||
var async = require("async");
|
||||
var assert = require('assert');
|
||||
var Amount = require("ripple-lib").Amount;
|
||||
var Remote = require("ripple-lib").Remote;
|
||||
var Transaction = require("ripple-lib").Transaction;
|
||||
var Server = require("./server").Server;
|
||||
var testutils = require("./testutils");
|
||||
var config = testutils.init_config();
|
||||
|
||||
function makeOffer($, account, takerpays, takergets, callback) {
|
||||
$.remote.transaction()
|
||||
.offer_create(account, takerpays, takergets)
|
||||
.on('submitted', function (m) {
|
||||
// console.log("PROPOSED: offer_create: %s", JSON.stringify(m));
|
||||
// console.log("PROPOSED: offer_create: Result %s. TakerGets %s. TakerPays %s.", m.engine_result, JSON.stringify(m.tx_json.TakerGets), JSON.stringify(m.tx_json.TakerPays));
|
||||
assert.strictEqual('tesSUCCESS', m.engine_result);
|
||||
$.remote
|
||||
.once('ledger_closed', function (message) {
|
||||
// console.log("LEDGER_CLOSED: %d: %s", message.ledger_index, message.ledger_hash);
|
||||
assert(message);
|
||||
})
|
||||
.ledger_accept();
|
||||
})
|
||||
.on('final', function (m) {
|
||||
// console.log("FINAL: offer_create: %s", JSON.stringify(m));
|
||||
// console.log("FINAL: offer_create: Result %s. Validated %s. TakerGets %s. TakerPays %s.", m.engine_result, m.validated, JSON.stringify(m.tx_json.TakerGets), JSON.stringify(m.tx_json.TakerPays));
|
||||
|
||||
callback(m.metadata.TransactionResult !== 'tesSUCCESS');
|
||||
})
|
||||
.submit();
|
||||
}
|
||||
|
||||
function makeOfferWithEvent($, account, takerpays, takergets, callback) {
|
||||
$.remote.once('transaction', function(m) {
|
||||
// console.log("TRANSACTION: %s", JSON.stringify(m));
|
||||
// console.log("TRANSACTION: meta: %s, takerpays: %s, takergets: %s", m.meta.AffectedNodes.length, Amount.from_json(m.transaction.TakerPays).to_human_full(), Amount.from_json(m.transaction.TakerGets).to_human_full());
|
||||
|
||||
assert.strictEqual(Amount.from_json(takergets).to_human_full(),
|
||||
Amount.from_json(m.transaction.TakerGets).to_human_full());
|
||||
assert.strictEqual(Amount.from_json(takerpays).to_human_full(),
|
||||
Amount.from_json(m.transaction.TakerPays).to_human_full());
|
||||
assert.strictEqual("OfferCreate", m.transaction.TransactionType);
|
||||
// We don't get quality from the event
|
||||
var foundOffer = false;
|
||||
var foundRoot = false;
|
||||
for(var n = m.meta.AffectedNodes.length-1; n >= 0; --n) {
|
||||
var node = m.meta.AffectedNodes[n];
|
||||
// console.log(node);
|
||||
if(node.CreatedNode &&
|
||||
node.CreatedNode.LedgerEntryType === "Offer") {
|
||||
foundOffer = true;
|
||||
var fields = node.CreatedNode.NewFields;
|
||||
assert.strictEqual(Amount.from_json(takergets).to_human_full(),
|
||||
Amount.from_json(fields.TakerGets).to_human_full());
|
||||
assert.strictEqual(Amount.from_json(takerpays).to_human_full(),
|
||||
Amount.from_json(fields.TakerPays).to_human_full());
|
||||
} else if (node.ModifiedNode) {
|
||||
assert(node.ModifiedNode.LedgerEntryType != "Offer");
|
||||
if(node.ModifiedNode.LedgerEntryType === "AccountRoot") {
|
||||
foundRoot = true;
|
||||
var mod = node.ModifiedNode;
|
||||
assert(mod.FinalFields.OwnerCount ==
|
||||
mod.PreviousFields.OwnerCount + 1);
|
||||
}
|
||||
}
|
||||
}
|
||||
assert(foundOffer);
|
||||
assert(foundRoot);
|
||||
|
||||
callback(m.engine_result !== 'tesSUCCESS');
|
||||
});
|
||||
makeOffer($, account, takerpays, takergets, function () {});
|
||||
}
|
||||
|
||||
function matchOffers(expected, actual) {
|
||||
assert.strictEqual(expected.length, actual.length);
|
||||
var found = [];
|
||||
for(var i = 0; i < actual.length; ++i) {
|
||||
var offer = actual[i];
|
||||
// console.log("Got: ", offer);
|
||||
for(var j = 0; j < expected.length; ++j) {
|
||||
var expectedOffer = expected[j];
|
||||
// console.log("checking: ", expectedOffer);
|
||||
if(Amount.from_json(expectedOffer.takerGets).to_human_full() ===
|
||||
Amount.from_json(offer.TakerGets).to_human_full()
|
||||
&& Amount.from_json(expectedOffer.takerPays).to_human_full() ===
|
||||
Amount.from_json(offer.TakerPays).to_human_full()
|
||||
&& expectedOffer.quality === offer.quality) {
|
||||
// console.log("FOUND");
|
||||
found.push(expectedOffer);
|
||||
expected.splice(j, 1);
|
||||
break;
|
||||
}
|
||||
}
|
||||
}
|
||||
if(expected.length != 0 || actual.length != found.length) {
|
||||
console.log("Received: ", actual.length);
|
||||
for(i = 0; i < actual.length; ++i) {
|
||||
var offer = actual[i];
|
||||
console.log(" TakerGets: %s, TakerPays %s",
|
||||
Amount.from_json(offer.TakerGets).to_human_full(),
|
||||
Amount.from_json(offer.TakerPays).to_human_full());
|
||||
}
|
||||
console.log("Found: ", found.length);
|
||||
for(i = 0; i < found.length; ++i) {
|
||||
var offer = found[i];
|
||||
console.log(" TakerGets: %s, TakerPays %s", offer.takerGets,
|
||||
offer.takerPays);
|
||||
}
|
||||
console.log("Not found: ", expected.length);
|
||||
for(i = 0; i < expected.length; ++i) {
|
||||
var offer = expected[i];
|
||||
console.log(" TakerGets: %s, TakerPays %s", offer.takerGets,
|
||||
offer.takerPays);
|
||||
}
|
||||
}
|
||||
assert.strictEqual(0, expected.length);
|
||||
assert.strictEqual(actual.length, found.length);
|
||||
}
|
||||
|
||||
function buildOfferFunctions($, offers) {
|
||||
functions = [];
|
||||
for(var i = 0; i < offers.length; ++i) {
|
||||
var offer = offers[i];
|
||||
functions.push(function(offer) {
|
||||
// console.log("Offer pre: ", offer);
|
||||
return function(callback) {
|
||||
// console.log("Offer in: ", offer);
|
||||
makeOffer($, "root", offer.takerPays, offer.takerGets, callback);
|
||||
}
|
||||
}(offer));
|
||||
}
|
||||
return functions;
|
||||
}
|
||||
|
||||
suite("Subscribe book tests", function() {
|
||||
var $ = { };
|
||||
|
||||
setup(function(done) {
|
||||
testutils.build_setup().call($, done);
|
||||
});
|
||||
|
||||
teardown(function(done) {
|
||||
testutils.build_teardown().call($, done);
|
||||
});
|
||||
|
||||
test("One side: Empty book", function (done) {
|
||||
var self = this;
|
||||
|
||||
async.waterfall([
|
||||
function (callback) {
|
||||
var request = $.remote.requestSubscribe(null);
|
||||
request.addBook({
|
||||
"taker_gets" : {
|
||||
"currency" : "XRP"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "USD", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.once('success', function(res) {
|
||||
// console.log("SUBSCRIBE: %s", JSON.stringify(res));
|
||||
|
||||
assert.strictEqual(0, res.offers.length);
|
||||
assert(!res.asks);
|
||||
assert(!res.bids);
|
||||
|
||||
callback(null);
|
||||
});
|
||||
request.once('error', function(err) {
|
||||
// console.log(err);
|
||||
callback(err);
|
||||
});
|
||||
request.request();
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700", "100/USD/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/USD/root", "75", callback);
|
||||
}
|
||||
], function (error) {
|
||||
// console.log("result: error=%s", error);
|
||||
assert(!error, self.what || "Unspecified Error");
|
||||
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
test("One side: Offers in book", function (done) {
|
||||
var self = this;
|
||||
var askTakerPays = "500";
|
||||
var askTakerGets = "100/usd/root";
|
||||
var askQuality = "5";
|
||||
var bidTakerPays = askTakerGets;
|
||||
var bidTakerGets = "200";
|
||||
var bidQuality = "0.5";
|
||||
|
||||
async.waterfall([
|
||||
function(callback) {
|
||||
// Create an ask: TakerPays 500, TakerGets 100/USD
|
||||
makeOffer($, "root", askTakerPays, askTakerGets, callback);
|
||||
},
|
||||
function(callback) {
|
||||
// Create an bid: TakerPays 100/USD, TakerGets 1200
|
||||
makeOffer($, "root", bidTakerPays, bidTakerGets, callback);
|
||||
},
|
||||
function (callback) {
|
||||
var request = $.remote.requestSubscribe(null);
|
||||
request.addBook({
|
||||
"taker_gets" : {
|
||||
"currency" : "XRP"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "USD", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.once('success', function(res) {
|
||||
// console.log("SUBSCRIBE: %s", JSON.stringify(res));
|
||||
|
||||
assert.strictEqual(1, res.offers.length);
|
||||
var bid = res.offers[0];
|
||||
assert.strictEqual(Amount.from_json(bidTakerGets).to_human_full(),
|
||||
Amount.from_json(bid.TakerGets).to_human_full());
|
||||
assert.strictEqual(Amount.from_json(bidTakerPays).to_human_full(),
|
||||
Amount.from_json(bid.TakerPays).to_human_full());
|
||||
assert.strictEqual(bidQuality, bid.quality);
|
||||
|
||||
assert(!res.asks);
|
||||
assert(!res.bids);
|
||||
|
||||
callback(null);
|
||||
});
|
||||
request.once('error', function(err) {
|
||||
// console.log(err);
|
||||
callback(err);
|
||||
});
|
||||
request.request();
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700", "100/USD/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/USD/root", "75", callback);
|
||||
}
|
||||
], function (error) {
|
||||
// console.log("result: error=%s", error);
|
||||
assert(!error, self.what || "Unspecified Error");
|
||||
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
test("Both sides: Empty book", function (done) {
|
||||
var self = this;
|
||||
|
||||
async.waterfall([
|
||||
function (callback) {
|
||||
var request = $.remote.requestSubscribe(null);
|
||||
request.addBook({
|
||||
"both" : true,
|
||||
"taker_gets" : {
|
||||
"currency" : "XRP"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "USD", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.once('success', function(res) {
|
||||
// console.log("SUBSCRIBE: %s", JSON.stringify(res));
|
||||
|
||||
assert.strictEqual(0, res.asks.length);
|
||||
assert.strictEqual(0, res.bids.length);
|
||||
assert(!res.offers);
|
||||
|
||||
callback(null);
|
||||
});
|
||||
request.once('error', function(err) {
|
||||
// console.log(err);
|
||||
callback(err);
|
||||
});
|
||||
request.request();
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700", "100/USD/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/USD/root", "75", callback);
|
||||
}
|
||||
], function (error) {
|
||||
// console.log("result: error=%s", error);
|
||||
assert(!error, self.what || "Unspecified Error");
|
||||
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
test("Both sides: Offers in book", function (done) {
|
||||
var self = this;
|
||||
var askTakerPays = "500";
|
||||
var askTakerGets = "100/USD/root";
|
||||
var askQuality = "5";
|
||||
var bidTakerPays = askTakerGets;
|
||||
var bidTakerGets = "200";
|
||||
var bidQuality = "0.5";
|
||||
|
||||
async.waterfall([
|
||||
function(callback) {
|
||||
// Create an ask: TakerPays 500, TakerGets 100/USD
|
||||
makeOffer($, "root", askTakerPays, askTakerGets, callback);
|
||||
},
|
||||
function(callback) {
|
||||
// Create an bid: TakerPays 100/USD, TakerGets 1200
|
||||
makeOffer($, "root", bidTakerPays, bidTakerGets, callback);
|
||||
},
|
||||
function (callback) {
|
||||
var request = $.remote.requestSubscribe(null);
|
||||
request.addBook({
|
||||
"both" : true,
|
||||
"taker_gets" : {
|
||||
"currency" : "XRP"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "USD", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.once('success', function(res) {
|
||||
// console.log("SUBSCRIBE: %s", JSON.stringify(res));
|
||||
|
||||
assert.strictEqual(1, res.asks.length);
|
||||
var ask = res.asks[0];
|
||||
assert.strictEqual(Amount.from_json(askTakerGets).to_human_full(),
|
||||
Amount.from_json(ask.TakerGets).to_human_full());
|
||||
assert.strictEqual(Amount.from_json(askTakerPays).to_human_full(),
|
||||
Amount.from_json(ask.TakerPays).to_human_full());
|
||||
assert.strictEqual(askQuality, ask.quality);
|
||||
|
||||
assert.strictEqual(1, res.bids.length);
|
||||
var bid = res.bids[0];
|
||||
assert.strictEqual(Amount.from_json(bidTakerGets).to_human_full(),
|
||||
Amount.from_json(bid.TakerGets).to_human_full());
|
||||
assert.strictEqual(Amount.from_json(bidTakerPays).to_human_full(),
|
||||
Amount.from_json(bid.TakerPays).to_human_full());
|
||||
assert.strictEqual(bidQuality, bid.quality);
|
||||
|
||||
assert(!res.offers);
|
||||
|
||||
callback(null);
|
||||
});
|
||||
request.once('error', function(err) {
|
||||
// console.log(err);
|
||||
callback(err);
|
||||
});
|
||||
request.request();
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700", "100/USD/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/USD/root", "75", callback);
|
||||
}
|
||||
], function (error) {
|
||||
// console.log("result: error=%s", error);
|
||||
assert(!error, self.what || "Unspecified Error");
|
||||
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
test("Multiple books: One side: Empty book", function (done) {
|
||||
var self = this;
|
||||
|
||||
async.waterfall([
|
||||
function (callback) {
|
||||
var request = $.remote.requestSubscribe(null);
|
||||
request.addBook({
|
||||
"taker_gets" : {
|
||||
"currency" : "XRP"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "USD", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.addBook({
|
||||
"taker_gets" : {
|
||||
"currency" : "CNY", "issuer" : "root"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "JPY", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.once('success', function(res) {
|
||||
// console.log("SUBSCRIBE: %s", JSON.stringify(res));
|
||||
|
||||
assert.strictEqual(0, res.offers.length);
|
||||
assert(!res.asks);
|
||||
assert(!res.bids);
|
||||
|
||||
callback(null);
|
||||
});
|
||||
request.once('error', function(err) {
|
||||
// console.log(err);
|
||||
callback(err);
|
||||
});
|
||||
request.request();
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700", "100/USD/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/USD/root", "75", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700/CNY/root", "100/JPY/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/JPY/root", "75/CNY/root", callback);
|
||||
}
|
||||
], function (error) {
|
||||
// console.log("result: error=%s", error);
|
||||
assert(!error, self.what || "Unspecified Error");
|
||||
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
test("Multiple books: One side: Offers in book", function (done) {
|
||||
var self = this;
|
||||
var asks = [
|
||||
{ takerPays: "500", takerGets: "100/usd/root", quality: "5" },
|
||||
{ takerPays: "500/cny/root", takerGets: "100/jpy/root", quality: "5" },
|
||||
];
|
||||
var bids = [
|
||||
{ takerPays: "100/usd/root", takerGets: "200", quality: "0.5" },
|
||||
{ takerPays: "100/jpy/root", takerGets: "200/cny/root", quality: "0.5" },
|
||||
];
|
||||
|
||||
var functions = buildOfferFunctions($, asks)
|
||||
.concat(buildOfferFunctions($, bids));
|
||||
|
||||
async.waterfall(
|
||||
functions.concat([
|
||||
function (callback) {
|
||||
var request = $.remote.requestSubscribe(null);
|
||||
request.addBook({
|
||||
"taker_gets" : {
|
||||
"currency" : "XRP"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "USD", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.addBook({
|
||||
"taker_gets" : {
|
||||
"currency" : "CNY", "issuer" : "root"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "JPY", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.once('success', function(res) {
|
||||
// console.log("SUBSCRIBE: %s", JSON.stringify(res));
|
||||
|
||||
matchOffers(bids, res.offers);
|
||||
|
||||
assert(!res.asks);
|
||||
assert(!res.bids);
|
||||
|
||||
callback(null);
|
||||
});
|
||||
request.once('error', function(err) {
|
||||
// console.log(err);
|
||||
callback(err);
|
||||
});
|
||||
request.request();
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700", "100/USD/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/USD/root", "75", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700/CNY/root", "100/JPY/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/JPY/root", "75/CNY/root", callback);
|
||||
}
|
||||
]), function (error) {
|
||||
// console.log("result: error=%s", error);
|
||||
assert(!error, self.what || "Unspecified Error");
|
||||
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
test("Multiple books: Both sides: Empty book", function (done) {
|
||||
var self = this;
|
||||
|
||||
async.waterfall([
|
||||
function (callback) {
|
||||
var request = $.remote.requestSubscribe(null);
|
||||
request.addBook({
|
||||
"both" : true,
|
||||
"taker_gets" : {
|
||||
"currency" : "XRP"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "USD", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.addBook({
|
||||
"both" : true,
|
||||
"taker_gets" : {
|
||||
"currency" : "CNY", "issuer" : "root"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "JPY", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.once('success', function(res) {
|
||||
// console.log("SUBSCRIBE: %s", JSON.stringify(res));
|
||||
|
||||
assert.strictEqual(0, res.asks.length);
|
||||
assert.strictEqual(0, res.bids.length);
|
||||
assert(!res.offers);
|
||||
|
||||
callback(null);
|
||||
});
|
||||
request.once('error', function(err) {
|
||||
// console.log(err);
|
||||
callback(err);
|
||||
});
|
||||
request.request();
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700", "100/USD/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/USD/root", "75", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700/CNY/root", "100/JPY/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/JPY/root", "75/CNY/root", callback);
|
||||
}
|
||||
], function (error) {
|
||||
// console.log("result: error=%s", error);
|
||||
assert(!error, self.what || "Unspecified Error");
|
||||
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
test("Multiple books: Both sides: Offers in book", function (done) {
|
||||
var self = this;
|
||||
var asks = [
|
||||
{ takerPays: "500", takerGets: "100/usd/root", quality: "5" },
|
||||
{ takerPays: "500/cny/root", takerGets: "100/jpy/root", quality: "5" },
|
||||
];
|
||||
var bids = [
|
||||
{ takerPays: "100/usd/root", takerGets: "200", quality: "0.5" },
|
||||
{ takerPays: "100/jpy/root", takerGets: "200/cny/root", quality: "0.5" },
|
||||
];
|
||||
|
||||
var functions = buildOfferFunctions($, asks)
|
||||
.concat(buildOfferFunctions($, bids));
|
||||
|
||||
async.waterfall(
|
||||
functions.concat([
|
||||
function (callback) {
|
||||
var request = $.remote.requestSubscribe(null);
|
||||
request.addBook({
|
||||
"both" : true,
|
||||
"taker_gets" : {
|
||||
"currency" : "XRP"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "USD", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.addBook({
|
||||
"both" : true,
|
||||
"taker_gets" : {
|
||||
"currency" : "CNY", "issuer" : "root"
|
||||
},
|
||||
"taker_pays" : {
|
||||
"currency" : "JPY", "issuer" : "root"
|
||||
}
|
||||
}, true);
|
||||
request.once('success', function(res) {
|
||||
// console.log("SUBSCRIBE: %s", JSON.stringify(res));
|
||||
|
||||
matchOffers(asks, res.asks);
|
||||
matchOffers(bids, res.bids);
|
||||
|
||||
assert(!res.offers);
|
||||
|
||||
callback(null);
|
||||
});
|
||||
request.once('error', function(err) {
|
||||
// console.log(err);
|
||||
callback(err);
|
||||
});
|
||||
request.request();
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700", "100/USD/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/USD/root", "75", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another ask. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "700/CNY/root", "100/JPY/root", callback);
|
||||
},
|
||||
function (callback) {
|
||||
// Make another bid. Make sure we get notified
|
||||
makeOfferWithEvent($, "root", "100/JPY/root", "75/CNY/root", callback);
|
||||
}
|
||||
]), function (error) {
|
||||
// console.log("result: error=%s", error);
|
||||
assert(!error, self.what || "Unspecified Error");
|
||||
|
||||
done();
|
||||
});
|
||||
});
|
||||
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user