let utils = require('../../utils/utils.js'); let fs = require('../../core/fs.js'); class DeployTracker { constructor(embark, options) { this.logger = embark.logger; this.events = embark.events; // TODO: unclear where it comes from this.env = options.env; //this.chainConfig = options.chainConfig; this.chainConfig = embark.config.chainTracker; this.registerEvents(); } registerEvents() { const self = this; this.events.on("deploy:beforeAll", this.setCurrentChain.bind(this)); this.events.on("deploy:contract:deployed", (contract) => { self.trackContract(contract.className, contract.realRuntimeBytecode, contract.realArgs, contract.address); self.save(); }); this.events.setCommandHandler("deploy:contract:shouldDeploy", (contract, cb) => { let trackedContract = self.getContract(contract.className, contract.realRuntimeBytecode, contract.realArgs); cb(trackedContract); }); } // TODO: just an event might not be enought to the async nature // it needs to be a plugin api before deploy, that makes the deployment wait setCurrentChain() { const self = this; if (this.chainConfig === false) { this.currentChain = {contracts: []}; //return cb(); } this.events.request("blockchain:block:byNumber", 0, function(_err, block) { let chainId = block.hash; if (self.chainConfig[chainId] === undefined) { self.chainConfig[chainId] = {contracts: {}}; } self.currentChain = self.chainConfig[chainId]; self.currentChain.name = self.env; //cb(); }); } loadConfig(config) { this.chainConfig = config; return this; } trackContract(contractName, code, args, address) { this.currentChain.contracts[utils.sha3(code + contractName + args.join(','))] = { name: contractName, address: address }; } getContract(contractName, code, args) { let contract = this.currentChain.contracts[utils.sha3(code + contractName + args.join(','))]; if (contract && contract.address === undefined) { return false; } return contract; } // TODO: abstract this // chainConfig can be an abstract PersistentObject save() { if (this.chainConfig === false) { return; } fs.writeJSONSync("./chains.json", this.chainConfig, {spaces: 2}); } } module.exports = DeployTracker;