conflict in deployManager

This commit is contained in:
Jonathan Rainville 2018-06-01 13:42:05 -04:00
parent b97c85d5f4
commit d0a289a450
4 changed files with 72 additions and 25 deletions

View File

@ -50,7 +50,11 @@ class DeployManager {
});
}
deployContracts(done) {
deployContracts(compileOnlyIfNeeded, done) {
if (typeof compileOnlyIfNeeded === 'function') {
done = compileOnlyIfNeeded;
compileOnlyIfNeeded = false;
}
let self = this;
if (self.blockchainConfig === {} || self.blockchainConfig.enabled === false) {

View File

@ -26,9 +26,6 @@ module.exports = {
if (!filePath) {
filePath = 'test/';
}
let configOptions = {
gasPrice: 1
};
async.waterfall([
function getFiles(next) {
@ -48,8 +45,6 @@ module.exports = {
});
},
function setupGlobalNamespace(next) {
global.assert = require('assert');
// TODO put default config
const test = new Test();
global.embark = test;
@ -69,7 +64,7 @@ module.exports = {
process.exit(1);
}
// Run the tests.
let runner = mocha.run(function(failures) {
mocha.run(function(failures) {
// Clean contracts folder for next test run
fs.remove('.embark/contracts', (_err) => {
process.on('exit', function () {
@ -78,12 +73,6 @@ module.exports = {
process.exit();
});
});
runner.on('suite', function() {
global.assert = require('assert');
global.EmbarkSpec = new Test({simulatorOptions: configOptions});
global.web3 = global.EmbarkSpec.web3;
});
});
}
};

View File

@ -1,7 +1,9 @@
const async = require('async');
const Engine = require('../core/engine.js');
const TestLogger = require('./test_logger.js');
const Web3 = require('web3');
const utils = require('../utils/utils');
const constants = require('../constants');
function getSimulator() {
try {
@ -32,15 +34,10 @@ class Test {
this.sim = getSimulator();
this.web3.setProvider(this.sim.provider(this.simOptions));
}
}
config(options) {
this.options = utils.recursiveMerge(this.options, options);
this.simOptions = this.options.simulatorOptions || {};
this.engine = new Engine({
env: this.options.env || 'test',
// TODO: confi will need to detect if this is a obj
// TODO: config will need to detect if this is a obj
embarkConfig: this.options.embarkConfig || 'embark.json',
interceptLogs: false
});
@ -49,12 +46,69 @@ class Test {
logger: new TestLogger({logLevel: 'debug'})
});
if (this.simOptions.node) {
this.web3.setProvider(new this.web3.providers.HttpProvider(this.simOptions.node));
} else {
this.sim = getSimulator();
this.web3.setProvider(this.sim.provider(this.simOptions));
}
this.engine.startService("libraryManager");
this.engine.startService("codeRunner");
this.engine.startService("web3", {
web3: this.web3
});
this.engine.startService("deployment", {
trackContracts: false
});
this.engine.startService("codeGenerator");
}
config(options, callback) {
this.options = utils.recursiveMerge(this.options, options);
this.simOptions = this.options.simulatorOptions || {};
this._deploy(options, (err, accounts) => {
if (err) {
console.error(err);
return callback(err);
}
callback(null, accounts);
});
}
_deploy(config, cb) {
const self = this;
async.waterfall([
function getConfig(callback) {
let _versions_default = self.engine.config.contractsConfig.versions;
self.engine.config.contractsConfig = {contracts: config.contracts, versions: _versions_default};
callback();
},
function reloadConfig(callback) {
self.engine.events.emit(constants.events.contractConfigChanged, self.engine.config.contractsConfig);
callback();
},
function deploy(callback) {
self.engine.deployManager.gasLimit = 6000000;
self.engine.contractsManager.gasLimit = 6000000;
self.engine.deployManager.fatalErrors = true;
self.engine.deployManager.deployOnlyOnConfig = true;
self.engine.deployManager.deployContracts(true, function(err, _result) {
if (err) {
callback(err);
}
callback();
});
}
], function(err) {
if (err) {
console.log(__('terminating due to error'));
cb(err);
}
// this should be part of the waterfall and not just something done at the
// end
self.web3.eth.getAccounts(function(err, accounts) {
if (err) {
throw new Error(err);
}
self.web3.eth.defaultAccount = accounts[0];
cb(null, accounts);
});
});
}
}