Grandschtroumpf
6 years ago
committed by
François
parent
f5d42bb7ea
commit
9cfccd6336
File diff suppressed because it is too large
Load Diff
@ -0,0 +1,2 @@ |
|||||||
|
export * from './run-tab' |
||||||
|
export * from './make-udapp' |
||||||
@ -1,15 +1,13 @@ |
|||||||
var UniversalDApp = require('./universal-dapp.js') |
var registry = require('../../global/registry') |
||||||
var registry = require('./global/registry') |
|
||||||
var remixLib = require('remix-lib') |
var remixLib = require('remix-lib') |
||||||
var yo = require('yo-yo') |
var yo = require('yo-yo') |
||||||
var executionContext = remixLib.execution.executionContext |
var executionContext = remixLib.execution.executionContext |
||||||
var Txlistener = remixLib.execution.txListener |
var Txlistener = remixLib.execution.txListener |
||||||
var EventsDecoder = remixLib.execution.EventsDecoder |
var EventsDecoder = remixLib.execution.EventsDecoder |
||||||
var TransactionReceiptResolver = require('./lib/transactionReceiptResolver') |
var TransactionReceiptResolver = require('../../lib/transactionReceiptResolver') |
||||||
|
|
||||||
module.exports = (compilersArtefacts, logHtmlCallback) => { |
export function makeUdapp(udapp, compilersArtefacts, logHtmlCallback) { |
||||||
// ----------------- UniversalDApp -----------------
|
// ----------------- UniversalDApp -----------------
|
||||||
const udapp = new UniversalDApp(registry) |
|
||||||
// TODO: to remove when possible
|
// TODO: to remove when possible
|
||||||
udapp.event.register('transactionBroadcasted', (txhash, networkName) => { |
udapp.event.register('transactionBroadcasted', (txhash, networkName) => { |
||||||
var txLink = executionContext.txDetailsLink(networkName, txhash) |
var txLink = executionContext.txDetailsLink(networkName, txhash) |
||||||
@ -1,383 +0,0 @@ |
|||||||
var async = require('async') |
|
||||||
var ethJSUtil = require('ethereumjs-util') |
|
||||||
var BN = ethJSUtil.BN |
|
||||||
var remixLib = require('remix-lib') |
|
||||||
var crypto = require('crypto') |
|
||||||
var TxRunner = remixLib.execution.txRunner |
|
||||||
var txHelper = remixLib.execution.txHelper |
|
||||||
var EventManager = remixLib.EventManager |
|
||||||
var executionContext = remixLib.execution.executionContext |
|
||||||
import { Plugin } from '@remixproject/engine' |
|
||||||
import { EventEmitter } from 'events' |
|
||||||
import * as packageJson from '../package.json' |
|
||||||
|
|
||||||
const profile = { |
|
||||||
name: 'udapp', |
|
||||||
displayName: 'universal dapp', |
|
||||||
description: 'service - run transaction and access account', |
|
||||||
permission: true, |
|
||||||
version: packageJson.version, |
|
||||||
methods: ['createVMAccount', 'newTransaction', 'sendTransaction', 'getAccounts', 'pendingTransactionsCount'] |
|
||||||
} |
|
||||||
|
|
||||||
module.exports = class UniversalDApp extends Plugin { |
|
||||||
|
|
||||||
constructor (registry) { |
|
||||||
super(profile) |
|
||||||
this.events = new EventEmitter() |
|
||||||
this.event = new EventManager() |
|
||||||
this._deps = { |
|
||||||
config: registry.get('config').api |
|
||||||
} |
|
||||||
|
|
||||||
this._txRunnerAPI = { |
|
||||||
config: this._deps.config, |
|
||||||
detectNetwork: (cb) => { |
|
||||||
executionContext.detectNetwork(cb) |
|
||||||
}, |
|
||||||
personalMode: () => { |
|
||||||
return executionContext.getProvider() === 'web3' ? this._deps.config.get('settings/personal-mode') : false |
|
||||||
} |
|
||||||
} |
|
||||||
this.txRunner = new TxRunner({}, this._txRunnerAPI) |
|
||||||
this.accounts = {} |
|
||||||
executionContext.event.register('contextChanged', this.resetEnvironment.bind(this)) |
|
||||||
} |
|
||||||
|
|
||||||
// TODO : event should be triggered by Udapp instead of TxListener
|
|
||||||
/** Listen on New Transaction. (Cannot be done inside constructor because txlistener doesn't exist yet) */ |
|
||||||
startListening (txlistener) { |
|
||||||
txlistener.event.register('newTransaction', (tx) => { |
|
||||||
this.events.emit('newTransaction', tx) |
|
||||||
}) |
|
||||||
} |
|
||||||
|
|
||||||
resetEnvironment () { |
|
||||||
this.accounts = {} |
|
||||||
if (executionContext.isVM()) { |
|
||||||
this._addAccount('3cd7232cd6f3fc66a57a6bedc1a8ed6c228fff0a327e169c2bcc5e869ed49511', '0x56BC75E2D63100000') |
|
||||||
this._addAccount('2ac6c190b09897cd8987869cc7b918cfea07ee82038d492abce033c75c1b1d0c', '0x56BC75E2D63100000') |
|
||||||
this._addAccount('dae9801649ba2d95a21e688b56f77905e5667c44ce868ec83f82e838712a2c7a', '0x56BC75E2D63100000') |
|
||||||
this._addAccount('d74aa6d18aa79a05f3473dd030a97d3305737cbc8337d940344345c1f6b72eea', '0x56BC75E2D63100000') |
|
||||||
this._addAccount('71975fbf7fe448e004ac7ae54cad0a383c3906055a65468714156a07385e96ce', '0x56BC75E2D63100000') |
|
||||||
} |
|
||||||
// TODO: most params here can be refactored away in txRunner
|
|
||||||
this.txRunner = new TxRunner(this.accounts, { |
|
||||||
// TODO: only used to check value of doNotShowTransactionConfirmationAgain property
|
|
||||||
config: this._deps.config, |
|
||||||
// TODO: to refactor, TxRunner already has access to executionContext
|
|
||||||
detectNetwork: (cb) => { |
|
||||||
executionContext.detectNetwork(cb) |
|
||||||
}, |
|
||||||
personalMode: () => { |
|
||||||
return executionContext.getProvider() === 'web3' ? this._deps.config.get('settings/personal-mode') : false |
|
||||||
} |
|
||||||
}) |
|
||||||
this.txRunner.event.register('transactionBroadcasted', (txhash) => { |
|
||||||
executionContext.detectNetwork((error, network) => { |
|
||||||
if (error || !network) return |
|
||||||
this.event.trigger('transactionBroadcasted', [txhash, network.name]) |
|
||||||
}) |
|
||||||
}) |
|
||||||
} |
|
||||||
|
|
||||||
resetAPI (transactionContextAPI) { |
|
||||||
this.transactionContextAPI = transactionContextAPI |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* Create a VM Account |
|
||||||
* @param {{privateKey: string, balance: string}} newAccount The new account to create |
|
||||||
*/ |
|
||||||
createVMAccount (newAccount) { |
|
||||||
const { privateKey, balance } = newAccount |
|
||||||
if (executionContext.getProvider() !== 'vm') { |
|
||||||
throw new Error('plugin API does not allow creating a new account through web3 connection. Only vm mode is allowed') |
|
||||||
} |
|
||||||
this._addAccount(privateKey, balance) |
|
||||||
const privKey = Buffer.from(privateKey, 'hex') |
|
||||||
return '0x' + ethJSUtil.privateToAddress(privKey).toString('hex') |
|
||||||
} |
|
||||||
|
|
||||||
newAccount (password, passwordPromptCb, cb) { |
|
||||||
if (!executionContext.isVM()) { |
|
||||||
if (!this._deps.config.get('settings/personal-mode')) { |
|
||||||
return cb('Not running in personal mode') |
|
||||||
} |
|
||||||
passwordPromptCb((passphrase) => { |
|
||||||
executionContext.web3().personal.newAccount(passphrase, cb) |
|
||||||
}) |
|
||||||
} else { |
|
||||||
var privateKey |
|
||||||
do { |
|
||||||
privateKey = crypto.randomBytes(32) |
|
||||||
} while (!ethJSUtil.isValidPrivate(privateKey)) |
|
||||||
this._addAccount(privateKey, '0x56BC75E2D63100000') |
|
||||||
cb(null, '0x' + ethJSUtil.privateToAddress(privateKey).toString('hex')) |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
_addAccount (privateKey, balance) { |
|
||||||
if (!executionContext.isVM()) { |
|
||||||
throw new Error('_addAccount() cannot be called in non-VM mode') |
|
||||||
} |
|
||||||
|
|
||||||
if (this.accounts) { |
|
||||||
privateKey = Buffer.from(privateKey, 'hex') |
|
||||||
const address = ethJSUtil.privateToAddress(privateKey) |
|
||||||
|
|
||||||
// FIXME: we don't care about the callback, but we should still make this proper
|
|
||||||
let stateManager = executionContext.vm().stateManager |
|
||||||
stateManager.getAccount(address, (error, account) => { |
|
||||||
if (error) return console.log(error) |
|
||||||
account.balance = balance || '0xf00000000000000001' |
|
||||||
stateManager.putAccount(address, account, function cb (error) { |
|
||||||
if (error) console.log(error) |
|
||||||
}) |
|
||||||
}) |
|
||||||
|
|
||||||
this.accounts['0x' + address.toString('hex')] = { privateKey, nonce: 0 } |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
getAccounts (cb) { |
|
||||||
return new Promise((resolve, reject) => { |
|
||||||
const provider = executionContext.getProvider() |
|
||||||
switch (provider) { |
|
||||||
case 'vm': { |
|
||||||
if (!this.accounts) { |
|
||||||
if (cb) cb('No accounts?') |
|
||||||
reject('No accounts?') |
|
||||||
return |
|
||||||
} |
|
||||||
if (cb) cb(null, Object.keys(this.accounts)) |
|
||||||
resolve(Object.keys(this.accounts)) |
|
||||||
} |
|
||||||
break |
|
||||||
case 'web3': { |
|
||||||
if (this._deps.config.get('settings/personal-mode')) { |
|
||||||
return executionContext.web3().personal.getListAccounts((error, accounts) => { |
|
||||||
if (cb) cb(error, accounts) |
|
||||||
if (error) return reject(error) |
|
||||||
resolve(accounts) |
|
||||||
}) |
|
||||||
} else { |
|
||||||
executionContext.web3().eth.getAccounts((error, accounts) => { |
|
||||||
if (cb) cb(error, accounts) |
|
||||||
if (error) return reject(error) |
|
||||||
resolve(accounts) |
|
||||||
}) |
|
||||||
} |
|
||||||
} |
|
||||||
break |
|
||||||
case 'injected': { |
|
||||||
executionContext.web3().eth.getAccounts((error, accounts) => { |
|
||||||
if (cb) cb(error, accounts) |
|
||||||
if (error) return reject(error) |
|
||||||
resolve(accounts) |
|
||||||
}) |
|
||||||
} |
|
||||||
} |
|
||||||
}) |
|
||||||
} |
|
||||||
|
|
||||||
getBalance (address, cb) { |
|
||||||
address = ethJSUtil.stripHexPrefix(address) |
|
||||||
|
|
||||||
if (!executionContext.isVM()) { |
|
||||||
executionContext.web3().eth.getBalance(address, (err, res) => { |
|
||||||
if (err) { |
|
||||||
cb(err) |
|
||||||
} else { |
|
||||||
cb(null, res.toString(10)) |
|
||||||
} |
|
||||||
}) |
|
||||||
} else { |
|
||||||
if (!this.accounts) { |
|
||||||
return cb('No accounts?') |
|
||||||
} |
|
||||||
|
|
||||||
executionContext.vm().stateManager.getAccount(Buffer.from(address, 'hex'), (err, res) => { |
|
||||||
if (err) { |
|
||||||
cb('Account not found') |
|
||||||
} else { |
|
||||||
cb(null, new BN(res.balance).toString(10)) |
|
||||||
} |
|
||||||
}) |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
getBalanceInEther (address, callback) { |
|
||||||
this.getBalance(address, (error, balance) => { |
|
||||||
if (error) { |
|
||||||
callback(error) |
|
||||||
} else { |
|
||||||
callback(null, executionContext.web3().fromWei(balance, 'ether')) |
|
||||||
} |
|
||||||
}) |
|
||||||
} |
|
||||||
|
|
||||||
pendingTransactionsCount () { |
|
||||||
return Object.keys(this.txRunner.pendingTxs).length |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* deploy the given contract |
|
||||||
* |
|
||||||
* @param {String} data - data to send with the transaction ( return of txFormat.buildData(...) ). |
|
||||||
* @param {Function} callback - callback. |
|
||||||
*/ |
|
||||||
createContract (data, confirmationCb, continueCb, promptCb, callback) { |
|
||||||
this.runTx({data: data, useCall: false}, confirmationCb, continueCb, promptCb, (error, txResult) => { |
|
||||||
// see universaldapp.js line 660 => 700 to check possible values of txResult (error case)
|
|
||||||
callback(error, txResult) |
|
||||||
}) |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* call the current given contract |
|
||||||
* |
|
||||||
* @param {String} to - address of the contract to call. |
|
||||||
* @param {String} data - data to send with the transaction ( return of txFormat.buildData(...) ). |
|
||||||
* @param {Object} funAbi - abi definition of the function to call. |
|
||||||
* @param {Function} callback - callback. |
|
||||||
*/ |
|
||||||
callFunction (to, data, funAbi, confirmationCb, continueCb, promptCb, callback) { |
|
||||||
this.runTx({to: to, data: data, useCall: funAbi.constant}, confirmationCb, continueCb, promptCb, (error, txResult) => { |
|
||||||
// see universaldapp.js line 660 => 700 to check possible values of txResult (error case)
|
|
||||||
callback(error, txResult) |
|
||||||
}) |
|
||||||
} |
|
||||||
|
|
||||||
context () { |
|
||||||
return (executionContext.isVM() ? 'memory' : 'blockchain') |
|
||||||
} |
|
||||||
|
|
||||||
getABI (contract) { |
|
||||||
return txHelper.sortAbiFunction(contract.abi) |
|
||||||
} |
|
||||||
|
|
||||||
getFallbackInterface (contractABI) { |
|
||||||
return txHelper.getFallbackInterface(contractABI) |
|
||||||
} |
|
||||||
|
|
||||||
getInputs (funABI) { |
|
||||||
if (!funABI.inputs) { |
|
||||||
return '' |
|
||||||
} |
|
||||||
return txHelper.inputParametersDeclarationToString(funABI.inputs) |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* This function send a tx only to javascript VM or testnet, will return an error for the mainnet |
|
||||||
* SHOULD BE TAKEN CAREFULLY! |
|
||||||
* |
|
||||||
* @param {Object} tx - transaction. |
|
||||||
*/ |
|
||||||
sendTransaction (tx) { |
|
||||||
return new Promise((resolve, reject) => { |
|
||||||
executionContext.detectNetwork((error, network) => { |
|
||||||
if (error) return reject(error) |
|
||||||
if (network.name === 'Main' && network.id === '1') { |
|
||||||
return reject(new Error('It is not allowed to make this action against mainnet')) |
|
||||||
} |
|
||||||
this.silentRunTx(tx, (error, result) => { |
|
||||||
if (error) return reject(error) |
|
||||||
resolve({ |
|
||||||
transactionHash: result.transactionHash, |
|
||||||
status: result.result.status, |
|
||||||
gasUsed: '0x' + result.result.gasUsed.toString('hex'), |
|
||||||
error: result.result.vm.exceptionError, |
|
||||||
return: result.result.vm.return ? '0x' + result.result.vm.return.toString('hex') : '0x', |
|
||||||
createdAddress: result.result.createdAddress ? '0x' + result.result.createdAddress.toString('hex') : undefined |
|
||||||
}) |
|
||||||
}) |
|
||||||
}) |
|
||||||
}) |
|
||||||
} |
|
||||||
|
|
||||||
/** |
|
||||||
* This function send a tx without alerting the user (if mainnet or if gas estimation too high). |
|
||||||
* SHOULD BE TAKEN CAREFULLY! |
|
||||||
* |
|
||||||
* @param {Object} tx - transaction. |
|
||||||
* @param {Function} callback - callback. |
|
||||||
*/ |
|
||||||
silentRunTx (tx, cb) { |
|
||||||
if (!executionContext.isVM()) return cb('Cannot silently send transaction through a web3 provider') |
|
||||||
this.txRunner.rawRun( |
|
||||||
tx, |
|
||||||
(network, tx, gasEstimation, continueTxExecution, cancelCb) => { continueTxExecution() }, |
|
||||||
(error, continueTxExecution, cancelCb) => { if (error) { cb(error) } else { continueTxExecution() } }, |
|
||||||
(okCb, cancelCb) => { okCb() }, |
|
||||||
cb |
|
||||||
) |
|
||||||
} |
|
||||||
|
|
||||||
runTx (args, confirmationCb, continueCb, promptCb, cb) { |
|
||||||
const self = this |
|
||||||
async.waterfall([ |
|
||||||
function getGasLimit (next) { |
|
||||||
if (self.transactionContextAPI.getGasLimit) { |
|
||||||
return self.transactionContextAPI.getGasLimit(next) |
|
||||||
} |
|
||||||
next(null, 3000000) |
|
||||||
}, |
|
||||||
function queryValue (gasLimit, next) { |
|
||||||
if (args.value) { |
|
||||||
return next(null, args.value, gasLimit) |
|
||||||
} |
|
||||||
if (args.useCall || !self.transactionContextAPI.getValue) { |
|
||||||
return next(null, 0, gasLimit) |
|
||||||
} |
|
||||||
self.transactionContextAPI.getValue(function (err, value) { |
|
||||||
next(err, value, gasLimit) |
|
||||||
}) |
|
||||||
}, |
|
||||||
function getAccount (value, gasLimit, next) { |
|
||||||
if (args.from) { |
|
||||||
return next(null, args.from, value, gasLimit) |
|
||||||
} |
|
||||||
if (self.transactionContextAPI.getAddress) { |
|
||||||
return self.transactionContextAPI.getAddress(function (err, address) { |
|
||||||
next(err, address, value, gasLimit) |
|
||||||
}) |
|
||||||
} |
|
||||||
self.getAccounts(function (err, accounts) { |
|
||||||
let address = accounts[0] |
|
||||||
|
|
||||||
if (err) return next(err) |
|
||||||
if (!address) return next('No accounts available') |
|
||||||
if (executionContext.isVM() && !self.accounts[address]) { |
|
||||||
return next('Invalid account selected') |
|
||||||
} |
|
||||||
next(null, address, value, gasLimit) |
|
||||||
}) |
|
||||||
}, |
|
||||||
function runTransaction (fromAddress, value, gasLimit, next) { |
|
||||||
var tx = { to: args.to, data: args.data.dataHex, useCall: args.useCall, from: fromAddress, value: value, gasLimit: gasLimit, timestamp: args.data.timestamp } |
|
||||||
var payLoad = { funAbi: args.data.funAbi, funArgs: args.data.funArgs, contractBytecode: args.data.contractBytecode, contractName: args.data.contractName, contractABI: args.data.contractABI, linkReferences: args.data.linkReferences } |
|
||||||
var timestamp = Date.now() |
|
||||||
if (tx.timestamp) { |
|
||||||
timestamp = tx.timestamp |
|
||||||
} |
|
||||||
|
|
||||||
self.event.trigger('initiatingTransaction', [timestamp, tx, payLoad]) |
|
||||||
self.txRunner.rawRun(tx, confirmationCb, continueCb, promptCb, |
|
||||||
function (error, result) { |
|
||||||
let eventName = (tx.useCall ? 'callExecuted' : 'transactionExecuted') |
|
||||||
self.event.trigger(eventName, [error, tx.from, tx.to, tx.data, tx.useCall, result, timestamp, payLoad]) |
|
||||||
|
|
||||||
if (error && (typeof (error) !== 'string')) { |
|
||||||
if (error.message) error = error.message |
|
||||||
else { |
|
||||||
try { error = 'error: ' + JSON.stringify(error) } catch (e) {} |
|
||||||
} |
|
||||||
} |
|
||||||
next(error, result) |
|
||||||
} |
|
||||||
) |
|
||||||
} |
|
||||||
], cb) |
|
||||||
} |
|
||||||
} |
|
||||||
Loading…
Reference in new issue