ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix testutils.create_accounts

Browse Source 
* Don't call ledger_wait inside parallel async loop
This commit is contained in:
Nicholas Dudfield
2015-03-11 12:19:24 +07:00
committed by Nik Bougalis
parent 70c2854f7c
commit ed66b951c6
1 changed files with 26 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

44
test/testutils.js
View File

@@ -213,7 +213,7 @@ function account_dump(remote, account, callback) {
// get closed ledger hash
// get account root
// construct a json result
};
}
function set_account_flag(remote, account, options, callback) {
if (typeof options === 'number') {
@@ -224,7 +224,9 @@ function set_account_flag(remote, account, options, callback) {
account: account
}, options));
submit_transaction(tx, callback);
// submit_transaction(tx, callback);
tx.submit();
tx.once('proposed', function(){callback();});
}
exports.fund_account =
@@ -259,7 +261,6 @@ function(remote, src, account, amount, options, callback) {
options = {};
}
options = extend({default_rippling: true}, options);
// Before creating the account, check if it exists in the ledger.
// If it does, regardless of the balance, fail the test, because
@@ -272,28 +273,19 @@ function(remote, src, account, amount, options, callback) {
});
info.once('error', function(result) {
var isNotFoundError = result.error === 'remoteError'
&& result.remote.error === 'actNotFound';
var isNotFoundError = result.error === 'remoteError' &&
result.remote.error === 'actNotFound';
if (!isNotFoundError) {
return callback(result);
}
// rippled indicated the account does not exist. Create it by funding it.
fund_account(remote, src, account, amount, function(err) {
if (err) {
callback(err);
} else if (!options.default_rippling) {
callback();
} else {
// Set default rippling on trustlines for account
set_account_flag(remote, account, 8, callback);
}
});
fund_account(remote, src, account, amount, callback);
});
info.request();
}
};
function create_accounts(remote, src, amount, accounts, options, callback) {
if (typeof options === 'function') {
@@ -305,8 +297,24 @@ function create_accounts(remote, src, amount, accounts, options, callback) {
async.forEach(accounts, function (account, callback) {
create_account(remote, src, account, amount, options, callback);
}, callback);
};
}, function(){
options = extend({default_rippling: true}, options);
// If we don't want to set default rippling, then bail, otherwise
if (!options.default_rippling) {
return callback();
}
// close the ledger, so all the accounts always exist, then
remote.ledger_accept(function(){
// set the default rippling flag, on all the accounts
async.forEach(accounts, function(account, callback){
set_account_flag(remote, account, 8, callback);
}, function(){
remote.ledger_accept(function(){callback();});
});
});
});
}
function credit_limit(remote, src, amount, callback) {
assert.strictEqual(arguments.length, 4);