335 lines
12 KiB
JavaScript
335 lines
12 KiB
JavaScript
let async = require('async');
|
|
//require("../utils/debug_util.js")(__filename, async);
|
|
let utils = require('../utils/utils.js');
|
|
|
|
class Deploy {
|
|
constructor(options) {
|
|
this.blockchain = options.blockchain;
|
|
this.logger = options.logger;
|
|
this.events = options.events;
|
|
this.plugins = options.plugins;
|
|
this.gasLimit = options.gasLimit;
|
|
}
|
|
|
|
// TODO: determining the arguments could also be in a module since it's not
|
|
// part of ta 'normal' contract deployment
|
|
determineArguments(suppliedArgs, contract, callback) {
|
|
const self = this;
|
|
|
|
let args = suppliedArgs;
|
|
if (!Array.isArray(args)) {
|
|
args = [];
|
|
let abi = contract.abiDefinition.find((abi) => abi.type === 'constructor');
|
|
|
|
for (let input of abi.inputs) {
|
|
let inputValue = suppliedArgs[input.name];
|
|
if (!inputValue) {
|
|
this.logger.error(__("{{inputName}} has not been defined for {{className}} constructor", {inputName: input.name, className: contract.className}));
|
|
}
|
|
args.push(inputValue || "");
|
|
}
|
|
}
|
|
|
|
let realArgs = [];
|
|
async.eachLimit(args, 1, (arg, nextEachCb) => {
|
|
if (arg[0] === "$") {
|
|
let contractName = arg.substr(1);
|
|
self.events.request('contracts:contract', contractName, (referedContract) => {
|
|
realArgs.push(referedContract.deployedAddress);
|
|
nextEachCb();
|
|
});
|
|
} else if (Array.isArray(arg)) {
|
|
let subRealArgs = [];
|
|
|
|
async.eachLimit(arg, 1, (sub_arg, nextSubEachCb) => {
|
|
if (sub_arg[0] === "$") {
|
|
let contractName = sub_arg.substr(1);
|
|
|
|
self.events.request('contracts:contract', contractName, (referedContract) => {
|
|
subRealArgs.push(referedContract.deployedAddress);
|
|
nextSubEachCb();
|
|
});
|
|
} else {
|
|
subRealArgs.push(sub_arg);
|
|
nextSubEachCb();
|
|
}
|
|
}, () => {
|
|
realArgs.push(subRealArgs);
|
|
nextEachCb();
|
|
});
|
|
} else {
|
|
realArgs.push(arg);
|
|
nextEachCb();
|
|
}
|
|
}, () => {
|
|
callback(realArgs);
|
|
});
|
|
}
|
|
|
|
checkAndDeployContract(contract, params, callback) {
|
|
let self = this;
|
|
contract.error = false;
|
|
|
|
if (contract.deploy === false) {
|
|
self.events.emit("deploy:contract:undeployed", contract);
|
|
return callback();
|
|
}
|
|
|
|
async.waterfall([
|
|
function _determineArguments(next) {
|
|
self.determineArguments(params || contract.args, contract, (realArgs) => {
|
|
contract.realArgs = realArgs;
|
|
next();
|
|
});
|
|
},
|
|
function deployIt(next) {
|
|
if (contract.address !== undefined) {
|
|
try {
|
|
utils.toChecksumAddress(contract.address);
|
|
} catch(e) {
|
|
self.logger.error(__("error deploying %s", contract.className));
|
|
self.logger.error(e.message);
|
|
contract.error = e.message;
|
|
self.events.emit("deploy:contract:error", contract);
|
|
return next(e.message);
|
|
}
|
|
contract.deployedAddress = contract.address;
|
|
self.logger.info(contract.className.bold.cyan + __(" already deployed at ").green + contract.address.bold.cyan);
|
|
self.events.emit("deploy:contract:deployed", contract);
|
|
return next();
|
|
}
|
|
|
|
// TODO: this should be a plugin API instead, if not existing, it should by default deploy the contract
|
|
self.events.request("deploy:contract:shouldDeploy", contract, function(trackedContract) {
|
|
if (!trackedContract) {
|
|
return self.contractToDeploy(contract, params, next);
|
|
}
|
|
|
|
self.blockchain.getCode(trackedContract.address, function(_getCodeErr, codeInChain) {
|
|
if (codeInChain !== "0x") {
|
|
self.contractAlreadyDeployed(contract, trackedContract, next);
|
|
} else {
|
|
self.contractToDeploy(contract, params, next);
|
|
}
|
|
});
|
|
});
|
|
}
|
|
], callback);
|
|
}
|
|
|
|
contractAlreadyDeployed(contract, trackedContract, callback) {
|
|
const self = this;
|
|
self.logger.info(contract.className.bold.cyan + __(" already deployed at ").green + trackedContract.address.bold.cyan);
|
|
contract.deployedAddress = trackedContract.address;
|
|
self.events.emit("deploy:contract:deployed", contract);
|
|
|
|
// TODO: can be moved into a afterDeploy event
|
|
// just need to figure out the gasLimit coupling issue
|
|
self.events.request('code-generator:contract:vanilla', contract, self.gasLimit, (contractCode) => {
|
|
self.events.request('runcode:eval', contractCode);
|
|
return callback();
|
|
});
|
|
}
|
|
|
|
contractToDeploy(contract, params, callback) {
|
|
const self = this;
|
|
|
|
// TODO: refactor to async
|
|
self.determineArguments(params || contract.args, contract, (realArgs) => {
|
|
contract.realArgs = realArgs;
|
|
|
|
this.deployContract(contract, contract.realArgs, function (err, address) {
|
|
if (err) {
|
|
self.events.emit("deploy:contract:error", contract);
|
|
return callback(new Error(err));
|
|
}
|
|
contract.address = address;
|
|
self.events.emit("deploy:contract:deployed", contract);
|
|
|
|
// TODO: can be moved into a afterDeploy event
|
|
// just need to figure out the gasLimit coupling issue
|
|
self.events.request('code-generator:contract:vanilla', contract, self.gasLimit, (contractCode) => {
|
|
self.events.request('runcode:eval', contractCode);
|
|
|
|
let onDeployPlugins = self.plugins.getPluginsProperty('onDeployActions', 'onDeployActions');
|
|
|
|
async.eachLimit(onDeployPlugins, 1, function(plugin, nextEach) {
|
|
plugin.call(plugin, contract, nextEach);
|
|
}, () => {
|
|
callback();
|
|
});
|
|
});
|
|
|
|
});
|
|
});
|
|
}
|
|
|
|
deployContract(contract, params, callback) {
|
|
let self = this;
|
|
let accounts = [];
|
|
let contractParams = (params || contract.args).slice();
|
|
let contractCode = contract.code;
|
|
let deploymentAccount = self.blockchain.defaultAccount();
|
|
let deployObject;
|
|
|
|
async.waterfall([
|
|
// TODO: can potentially go to a beforeDeploy plugin
|
|
function getAccounts(next) {
|
|
self.blockchain.getAccounts(function (err, _accounts) {
|
|
if (err) {
|
|
return next(new Error(err));
|
|
}
|
|
accounts = _accounts;
|
|
|
|
// applying deployer account configuration, if any
|
|
if (typeof contract.fromIndex == 'number') {
|
|
deploymentAccount = accounts[contract.fromIndex];
|
|
if (deploymentAccount === undefined) {
|
|
return next(__("error deploying") + " " + contract.className + ": " + __("no account found at index") + " " + contract.fromIndex + __(" check the config"));
|
|
}
|
|
}
|
|
if (typeof contract.from == 'string' && typeof contract.fromIndex != 'undefined') {
|
|
self.logger.warn(__('Both "from" and "fromIndex" are defined for contract') + ' "' + contract.className + '". ' + __('Using "from" as deployer account.'));
|
|
}
|
|
if (typeof contract.from == 'string') {
|
|
deploymentAccount = contract.from;
|
|
}
|
|
|
|
deploymentAccount = deploymentAccount || accounts[0];
|
|
next();
|
|
});
|
|
},
|
|
function doLinking(next) {
|
|
self.events.request('contracts:list', (contracts) => {
|
|
for (let contractObj of contracts) {
|
|
let filename = contractObj.filename;
|
|
let deployedAddress = contractObj.deployedAddress;
|
|
if (deployedAddress) {
|
|
deployedAddress = deployedAddress.substr(2);
|
|
}
|
|
let linkReference = '__' + filename + ":" + contractObj.className;
|
|
if (contractCode.indexOf(linkReference) < 0) {
|
|
continue;
|
|
}
|
|
if (linkReference.length > 40) {
|
|
return next(new Error(__("{{linkReference}} is too long, try reducing the path of the contract ({{filename}}) and/or its name {{contractName}}", {linkReference: linkReference, filename: filename, contractName: contractObj.className})));
|
|
}
|
|
let toReplace = linkReference + "_".repeat(40 - linkReference.length);
|
|
if (deployedAddress === undefined) {
|
|
let libraryName = contractObj.className;
|
|
return next(new Error(__("{{contractName}} needs {{libraryName}} but an address was not found, did you deploy it or configured an address?", {contractName: contract.className, libraryName: libraryName})));
|
|
}
|
|
contractCode = contractCode.replace(new RegExp(toReplace, "g"), deployedAddress);
|
|
}
|
|
// saving code changes back to contract object
|
|
contract.code = contractCode;
|
|
next();
|
|
});
|
|
},
|
|
function applyBeforeDeploy(next) {
|
|
let beforeDeployPlugins = self.plugins.getPluginsFor('beforeDeploy');
|
|
|
|
//self.logger.info("applying beforeDeploy plugins...", beforeDeployPlugins.length);
|
|
async.eachSeries(beforeDeployPlugins, (plugin, eachPluginCb) => {
|
|
self.logger.info(__("running beforeDeploy plugin %s .", plugin.name));
|
|
|
|
// calling each beforeDeploy handler declared by the plugin
|
|
async.eachSeries(plugin.beforeDeploy, (beforeDeployFn, eachCb) => {
|
|
function beforeDeployCb(resObj){
|
|
contract.code = resObj.contractCode;
|
|
eachCb();
|
|
}
|
|
beforeDeployFn({
|
|
embarkDeploy: self,
|
|
pluginConfig: plugin.pluginConfig,
|
|
deploymentAccount: deploymentAccount,
|
|
contract: contract,
|
|
callback: beforeDeployCb
|
|
}, beforeDeployCb);
|
|
}, () => {
|
|
//self.logger.info('All beforeDeploy handlers of the plugin has processed.');
|
|
eachPluginCb();
|
|
});
|
|
}, () => {
|
|
//self.logger.info('All beforeDeploy plugins has been processed.');
|
|
contractCode = contract.code;
|
|
next();
|
|
});
|
|
},
|
|
function createDeployObject(next) {
|
|
let contractObject = self.blockchain.ContractObject({abi: contract.abiDefinition});
|
|
|
|
try {
|
|
const dataCode = contractCode.startsWith('0x') ? contractCode : "0x" + contractCode;
|
|
deployObject = self.blockchain.deployContractObject(contractObject, {arguments: contractParams, data: dataCode});
|
|
} catch(e) {
|
|
if (e.message.indexOf('Invalid number of parameters for "undefined"') >= 0) {
|
|
return next(new Error(__("attempted to deploy %s without specifying parameters", contract.className)));
|
|
} else {
|
|
return next(new Error(e));
|
|
}
|
|
}
|
|
next();
|
|
},
|
|
function estimateCorrectGas(next) {
|
|
if (contract.gas === 'auto') {
|
|
return deployObject.estimateGas().then((gasValue) => {
|
|
contract.gas = gasValue;
|
|
next();
|
|
}).catch(next);
|
|
}
|
|
next();
|
|
},
|
|
function deployTheContract(next) {
|
|
self.logger.info(__("deploying") + " " + contract.className.bold.cyan + " " + __("with").green + " " + contract.gas + " " + __("gas").green);
|
|
|
|
self.blockchain.deployContractFromObject(deployObject, {
|
|
from: deploymentAccount,
|
|
gas: contract.gas,
|
|
gasPrice: contract.gasPrice
|
|
}, function(error, receipt) {
|
|
if (error) {
|
|
return next(new Error("error deploying =" + contract.className + "= due to error: " + error.message));
|
|
}
|
|
self.logger.info(contract.className.bold.cyan + " " + __("deployed at").green + " " + receipt.contractAddress.bold.cyan);
|
|
contract.deployedAddress = receipt.contractAddress;
|
|
contract.transactionHash = receipt.transactionHash;
|
|
return next(null, receipt.contractAddress);
|
|
});
|
|
}
|
|
], callback);
|
|
}
|
|
|
|
deployAll(done) {
|
|
let self = this;
|
|
this.logger.info(__("deploying contracts"));
|
|
this.events.emit("deploy:beforeAll");
|
|
|
|
self.events.request('contracts:list', (contracts) => {
|
|
async.eachOfSeries(contracts,
|
|
function (contract, key, callback) {
|
|
self.logger.trace(arguments);
|
|
self.checkAndDeployContract(contract, null, callback);
|
|
},
|
|
function (err, _results) {
|
|
if (err) {
|
|
self.logger.error(__("error deploying contracts"));
|
|
self.logger.error(err.message);
|
|
self.logger.debug(err.stack);
|
|
}
|
|
if (contracts.length === 0) {
|
|
self.logger.info(__("no contracts found"));
|
|
return done();
|
|
}
|
|
self.logger.info(__("finished deploying contracts"));
|
|
self.logger.trace(arguments);
|
|
done(err);
|
|
}
|
|
);
|
|
});
|
|
|
|
}
|
|
}
|
|
|
|
module.exports = Deploy;
|