ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-20 02:55:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

UT: Test account subscription for nexus.

Browse Source
This commit is contained in:
Arthur Britto
2013-01-17 13:02:41 -08:00
parent a8b1b205d5
commit 1568422fb7
1 changed files with 143 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

143
test/send-test.js
View File

@@ -605,6 +605,149 @@ buster.testCase("Nexus", {
done();
});
},
"subscribe test: customer to customer with and without transfer fee" :
function (done) {
var self = this;
// self.remote.set_trace();
async.waterfall([
function (callback) {
self.what = "Create accounts.";
testutils.create_accounts(self.remote, "root", "10000.0", ["alice", "bob", "mtgox"], callback);
},
function (callback) { testutils.ledger_close(self.remote, callback); },
function (callback) {
self.what = "Set credit limits.";
testutils.credit_limits(self.remote,
{
"alice" : "100/AUD/mtgox",
"bob" : "100/AUD/mtgox",
},
callback);
},
function (callback) { testutils.ledger_close(self.remote, callback); },
function (callback) {
self.what = "Distribute funds.";
testutils.payments(self.remote,
{
"mtgox" : [ "1/AUD/alice" ],
},
callback);
},
function (callback) { testutils.ledger_close(self.remote, callback); },
function (callback) {
self.what = "Verify balances.";
testutils.verify_balances(self.remote,
{
"alice" : "1/AUD/mtgox",
"mtgox" : "-1/AUD/alice",
},
callback);
},
function (callback) {
self.what = "Alice sends Bob 1 AUD";
self.remote.transaction()
.payment("alice", "bob", "1/AUD/mtgox")
.on('proposed', function (m) {
// console.log("proposed: %s", JSON.stringify(m));
callback(m.result !== 'tesSUCCESS');
})
.submit();
},
function (callback) { testutils.ledger_close(self.remote, callback); },
function (callback) {
self.what = "Verify balances 2.";
testutils.verify_balances(self.remote,
{
"alice" : "0/AUD/mtgox",
"bob" : "1/AUD/mtgox",
"mtgox" : "-1/AUD/bob",
},
callback);
},
function (callback) {
self.what = "Set transfer rate.";
self.remote.transaction()
.account_set("mtgox")
.transfer_rate(1e9*1.1)
.once('proposed', function (m) {
// console.log("proposed: %s", JSON.stringify(m));
callback(m.result !== 'tesSUCCESS');
})
.submit();
},
function (callback) { testutils.ledger_close(self.remote, callback); },
function (callback) {
self.what = "Bob sends Alice 0.5 AUD";
self.remote.transaction()
.payment("bob", "alice", "0.5/AUD/mtgox")
.send_max("0.55/AUD/mtgox") // !!! Very important.
.on('proposed', function (m) {
// console.log("proposed: %s", JSON.stringify(m));
callback(m.result !== 'tesSUCCESS');
})
.submit();
},
function (callback) {
self.what = "Verify balances 3.";
testutils.verify_balances(self.remote,
{
"alice" : "0.5/AUD/mtgox",
"bob" : "0.45/AUD/mtgox",
"mtgox" : [ "-0.5/AUD/alice","-0.45/AUD/bob" ],
},
callback);
},
function (callback) {
self.what = "Subscribe and accept.";
self.count = 0;
self.found = 0;
self.remote.on('ledger_closed', function (m) {
// console.log("#### LEDGER_CLOSE: %s", JSON.stringify(m));
});
self.remote
.on('account', function (m) {
// console.log("ACCOUNT: %s", JSON.stringify(m));
self.found = 1;
})
.on('ledger_closed', function (m) {
// console.log("LEDGER_CLOSE: %d: %s", self.count, JSON.stringify(m));
if (self.count) {
callback(!self.found);
}
else {
self.count = 1;
self.remote.ledger_accept();
}
})
.request_subscribe().accounts("mtgox")
.request();
self.remote.ledger_accept();
},
], function (error) {
buster.refute(error, self.what);
done();
});
},
});
buster.testCase("Indirect ripple", {