You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
360 lines
13 KiB
360 lines
13 KiB
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 { UdappApi } from 'remix-plugin'
|
|
import { EventEmitter } from 'events'
|
|
|
|
const profile = {
|
|
name: 'udapp',
|
|
displayName: 'universal dapp',
|
|
description: 'service - run transaction and access account',
|
|
permission: true
|
|
}
|
|
|
|
module.exports = class UniversalDApp extends UdappApi {
|
|
|
|
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 this._deps.config.get('settings/personal-mode')
|
|
}
|
|
}
|
|
this.txRunner = new TxRunner({}, this._txRunnerAPI)
|
|
this.accounts = {}
|
|
this.resetEnvironment()
|
|
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')
|
|
executionContext.vm().stateManager.cache.flush(function () {})
|
|
}
|
|
// 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 this.config.get('settings/personal-mode')
|
|
}
|
|
})
|
|
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
|
|
}
|
|
|
|
createVMAccount (privateKey, balance, cb) {
|
|
return new Promise((resolve, reject) => {
|
|
if (executionContext.getProvider() !== 'vm') return reject('plugin API does not allow creating a new account through web3 connection. Only vm mode is allowed')
|
|
this._addAccount(privateKey, balance)
|
|
executionContext.vm().stateManager.cache.flush(function () {})
|
|
privateKey = Buffer.from(privateKey, 'hex')
|
|
resolve('0x' + ethJSUtil.privateToAddress(privateKey).toString('hex'))
|
|
})
|
|
}
|
|
|
|
newAccount (password, passwordPromptCb, cb) {
|
|
if (!executionContext.isVM()) {
|
|
if (!this.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')
|
|
executionContext.vm().stateManager.cache.flush(function () {})
|
|
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
|
|
executionContext.vm().stateManager.putAccountBalance(address, balance || '0xf00000000000000001', function cb () {})
|
|
this.accounts['0x' + address.toString('hex')] = { privateKey, nonce: 0 }
|
|
}
|
|
}
|
|
|
|
getAccounts (cb) {
|
|
return new Promise((resolve, reject) => {
|
|
if (!executionContext.isVM()) {
|
|
// Weirdness of web3: listAccounts() is sync, `getListAccounts()` is async
|
|
// See: https://github.com/ethereum/web3.js/issues/442
|
|
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)
|
|
})
|
|
}
|
|
} else {
|
|
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))
|
|
}
|
|
})
|
|
}
|
|
|
|
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.getAccountBalance(Buffer.from(address, 'hex'), (err, res) => {
|
|
if (err) {
|
|
cb('Account not found')
|
|
} else {
|
|
cb(null, new BN(res).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)
|
|
}
|
|
}
|
|
|