@ -7,349 +7,345 @@ var TxRunner = remixLib.execution.txRunner
var txHelper = remixLib . execution . txHelper var txHelper = remixLib . execution . txHelper
var EventManager = remixLib . EventManager var EventManager = remixLib . EventManager
var executionContext = remixLib . execution . executionContext var executionContext = remixLib . execution . executionContext
import { ApiFactory } from 'remix-plugin'
function UniversalDApp ( registry ) { module . exports = class UniversalDApp extends ApiFactory {
this . event = new EventManager ( )
var self = this constructor ( registry ) {
self . _deps = { super ( )
config : registry . get ( 'config' ) . api this . event = new EventManager ( )
} this . _deps = {
self . _txRunnerAPI = { config : registry . get ( 'config' ) . api
config : self . _deps . config , }
detectNetwork : ( cb ) => { this . _txRunnerAPI = {
executionContext . detectNetwork ( cb ) config : this . _deps . config ,
} , detectNetwork : ( cb ) => {
personalMode : ( ) => { executionContext . detectNetwork ( cb )
return self . _deps . config . get ( 'settings/personal-mode' ) } ,
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 ) )
} }
self . txRunner = new TxRunner ( { } , self . _txRunnerAPI )
self . accounts = { }
self . resetEnvironment ( )
executionContext . event . register ( 'contextChanged' , this . resetEnvironment . bind ( this ) )
}
UniversalDApp . prototype . profile = function ( ) { get profile ( ) {
return { return {
name : 'udapp' , name : 'udapp' ,
displayName : 'universal dapp' , displayName : 'universal dapp' ,
methods : [ 'runTestTx' , 'getAccounts' , 'createVMAccount' ] , methods : [ 'runTestTx' , 'getAccounts' , 'createVMAccount' ] ,
description : 'service - run transaction and access account' description : 'service - run transaction and access account'
}
} }
}
UniversalDApp . prototype . resetEnvironment = function ( ) { resetEnvironment ( ) {
this . accounts = { } this . accounts = { }
if ( executionContext . isVM ( ) ) { if ( executionContext . isVM ( ) ) {
this . _addAccount ( '3cd7232cd6f3fc66a57a6bedc1a8ed6c228fff0a327e169c2bcc5e869ed49511' , '0x56BC75E2D63100000' ) this . _addAccount ( '3cd7232cd6f3fc66a57a6bedc1a8ed6c228fff0a327e169c2bcc5e869ed49511' , '0x56BC75E2D63100000' )
this . _addAccount ( '2ac6c190b09897cd8987869cc7b918cfea07ee82038d492abce033c75c1b1d0c' , '0x56BC75E2D63100000' ) this . _addAccount ( '2ac6c190b09897cd8987869cc7b918cfea07ee82038d492abce033c75c1b1d0c' , '0x56BC75E2D63100000' )
this . _addAccount ( 'dae9801649ba2d95a21e688b56f77905e5667c44ce868ec83f82e838712a2c7a' , '0x56BC75E2D63100000' ) this . _addAccount ( 'dae9801649ba2d95a21e688b56f77905e5667c44ce868ec83f82e838712a2c7a' , '0x56BC75E2D63100000' )
this . _addAccount ( 'd74aa6d18aa79a05f3473dd030a97d3305737cbc8337d940344345c1f6b72eea' , '0x56BC75E2D63100000' ) this . _addAccount ( 'd74aa6d18aa79a05f3473dd030a97d3305737cbc8337d940344345c1f6b72eea' , '0x56BC75E2D63100000' )
this . _addAccount ( '71975fbf7fe448e004ac7ae54cad0a383c3906055a65468714156a07385e96ce' , '0x56BC75E2D63100000' ) this . _addAccount ( '71975fbf7fe448e004ac7ae54cad0a383c3906055a65468714156a07385e96ce' , '0x56BC75E2D63100000' )
executionContext . vm ( ) . stateManager . cache . flush ( function ( ) { } ) 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 . config ,
// TODO: to refactor, TxRunner already has access to executionContext
detectNetwork : ( cb ) => {
executionContext . detectNetwork ( cb )
} ,
personalMode : ( ) => {
return this . config . get ( 'settings/personal-mode' )
} }
} ) // TODO: most params here can be refactored away in txRunner
this . txRunner . event . register ( 'transactionBroadcasted' , ( txhash ) => { this . txRunner = new TxRunner ( this . accounts , {
executionContext . detectNetwork ( ( error , network ) => { // TODO: only used to check value of doNotShowTransactionConfirmationAgain property
if ( error || ! network ) return config : this . config ,
this . event . trigger ( 'transactionBroadcasted' , [ txhash , network . name ] ) // 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
UniversalDApp . prototype . resetAPI = function ( transactionContextAPI ) { this . event . trigger ( 'transactionBroadcasted' , [ txhash , network . name ] )
this . transactionContextAPI = transactionContextAPI } )
}
UniversalDApp . prototype . createVMAccount = function ( 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' ) )
} )
}
UniversalDApp . prototype . newAccount = function ( 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' ) )
} }
}
UniversalDApp . prototype . _addAccount = function ( privateKey , balance ) {
var self = this
if ( ! executionContext . isVM ( ) ) { resetAPI ( transactionContextAPI ) {
throw new Error ( '_addAccount() cannot be called in non-VM mode' ) this . transactionContextAPI = transactionContextAPI
} }
if ( self . accounts ) { createVMAccount ( privateKey , balance , cb ) {
privateKey = Buffer . from ( privateKey , 'hex' ) return new Promise ( ( resolve , reject ) => {
var address = ethJSUtil . privateToAddress ( privateKey ) 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 )
// FIXME: we don't care about the callback, but we should still make this proper
executionContext . vm ( ) . stateManager . cache . flush ( function ( ) { } )
executionContext . vm ( ) . stateManager . putAccountBalance ( address , balance || '0xf00000000000000001' , function cb ( ) { } ) privateKey = Buffer . from ( privateKey , 'hex' )
self . accounts [ '0x' + address . toString ( 'hex' ) ] = { privateKey : privateKey , nonce : 0 } resolve ( '0x' + ethJSUtil . privateToAddress ( privateKey ) . toString ( 'hex' ) )
} )
} }
}
// TODO should remove this cb
newAccount ( password , passwordPromptCb , cb ) {
UniversalDApp . prototype . getAccounts = function ( cb ) {
var self = this
return new Promise ( ( resolve , reject ) => {
if ( ! executionContext . isVM ( ) ) { if ( ! executionContext . isVM ( ) ) {
// Weirdness of web3: listAccounts() is sync, `getListAccounts()` is async
if ( ! this . config . get ( 'settings/personal-mode' ) ) {
// See: https://github.com/ethereum/web3.js/issues/442
return cb ( 'Not running in personal mode' )
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 )
} )
} }
passwordPromptCb ( ( passphrase ) => {
executionContext . web3 ( ) . personal . newAccount ( passphrase , cb )
} )
} else { } else {
if ( ! self . accounts ) { var privateKey
if ( cb ) cb ( 'No accounts?' ) do {
reject ( 'No accounts?' ) privateKey = crypto . randomBytes ( 32 )
return } while ( ! ethJSUtil . isValidPrivate ( privateKey ) )
} this . _addAccount ( privateKey , '0x56BC75E2D63100000' )
if ( cb ) cb ( null , Object . keys ( self . accounts ) ) executionContext . vm ( ) . stateManager . cache . flush ( function ( ) { } )
resolve ( Object . keys ( self . accounts ) ) cb ( null , '0x' + ethJSUtil . privateToAddress ( privateKey ) . toString ( 'hex' ) )
} }
} ) }
}
UniversalDApp . prototype . getBalance = function ( address , cb ) { _addAccount ( privateKey , balance ) {
var self = this if ( ! executionContext . isVM ( ) ) {
throw new Error ( '_addAccount() cannot be called in non-VM mode' )
}
address = ethJSUtil . stripHexPrefix ( address ) if ( this . accounts ) {
privateKey = Buffer . from ( privateKey , 'hex' )
const address = ethJSUtil . privateToAddress ( privateKey )
if ( ! executionContext . isVM ( ) ) { // FIXME: we don't care about the callback, but we should still make this proper
executionContext . web3 ( ) . eth . getBalance ( address , function ( err , res ) { executionContext . vm ( ) . stateManager . putAccountBalance ( address , balance || '0xf00000000000000001' , function cb ( ) { } )
if ( err ) { this . accounts [ '0x' + address . toString ( 'hex' ) ] = { privateKey , nonce : 0 }
cb ( err )
} else {
cb ( null , res . toString ( 10 ) )
}
} )
} else {
if ( ! self . accounts ) {
return cb ( 'No accounts?' )
} }
}
executionContext . vm ( ) . stateManager . getAccountBalance ( Buffer . from ( address , 'hex' ) , function ( err , res ) { getAccounts ( cb ) {
if ( err ) { return new Promise ( ( resolve , reject ) => {
cb ( 'Account not found' ) 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 { } else {
cb ( null , new BN ( res ) . toString ( 10 ) ) 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 ) )
} }
} ) } )
} }
}
UniversalDApp . prototype . getBalanceInEther = function ( address , callback ) { getBalance ( address , cb ) {
var self = this address = ethJSUtil . stripHexPrefix ( address )
self . getBalance ( address , ( error , balance ) => {
if ( error ) { if ( ! executionContext . isVM ( ) ) {
callback ( error ) executionContext . web3 ( ) . eth . getBalance ( address , ( err , res ) => {
if ( err ) {
cb ( err )
} else {
cb ( null , res . toString ( 10 ) )
}
} )
} else { } else {
callback ( null , executionContext . web3 ( ) . fromWei ( balance , 'ether' ) ) 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 ) )
}
} )
} }
} ) }
}
UniversalDApp . prototype . pendingTransactionsCount = function ( ) { getBalanceInEther ( address , callback ) {
return Object . keys ( this . txRunner . pendingTxs ) . length this . getBalance ( address , ( error , balance ) => {
} if ( error ) {
callback ( error )
} else {
callback ( null , executionContext . web3 ( ) . fromWei ( balance , 'ether' ) )
}
} )
}
/ * * pendingTransactionsCount ( ) {
* deploy the given contract return Object . keys ( this . txRunner . pendingTxs ) . length
* }
* @ param { String } data - data to send with the transaction ( return of txFormat . buildData ( ... ) ) .
* @ param { Function } callback - callback .
* /
UniversalDApp . prototype . createContract = function ( 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 * deploy the 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 { String } data - data to send with the transaction ( return of txFormat . buildData ( ... ) ) . * @ param { Function } callback - callback .
* @ param { Object } funAbi - abi definition of the function to call . * /
* @ param { Function } callback - callback . createContract ( data , confirmationCb , continueCb , promptCb , callback ) {
* / this . runTx ( { data : data , useCall : false } , confirmationCb , continueCb , promptCb , ( error , txResult ) => {
UniversalDApp . prototype . callFunction = function ( to , data , funAbi , confirmationCb , continueCb , promptCb , callback ) { // see universaldapp.js line 660 => 700 to check possible values of txResult (error case)
this . runTx ( { to : to , data : data , useCall : funAbi . constant } , confirmationCb , continueCb , promptCb , ( error , txResult ) => { callback ( error , txResult )
// see universaldapp.js line 660 => 700 to check possible values of txResult (error case)
} )
callback ( error , txResult ) }
} )
}
UniversalDApp . prototype . context = function ( ) { / * *
return ( executionContext . isVM ( ) ? 'memory' : 'blockchain' ) * 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 )
} )
}
UniversalDApp . prototype . getABI = function ( contract ) { context ( ) {
return txHelper . sortAbiFunction ( contract . abi ) return ( executionContext . isVM ( ) ? 'memory' : 'blockchain' )
} }
UniversalDApp . prototype . getFallbackInterface = function ( contractABI ) { getABI ( contract ) {
return txHelper . getFallbackInterface ( contractABI ) return txHelper . sortAbiFunction ( contract . abi )
} }
UniversalDApp . prototype . getInputs = function ( funABI ) { getFallbackInterface ( contractABI ) {
if ( ! funABI . inputs ) { return txHelper . getFallbackInterface ( contractABI )
return ''
} }
return txHelper . inputParametersDeclarationToString ( funABI . inputs )
}
/ * * getInputs ( funABI ) {
* This function send a tx only to javascript VM or testnet , will return an error for the mainnet if ( ! funABI . inputs ) {
* SHOULD BE TAKEN CAREFULLY ! return ''
* }
* @ param { Object } tx - transaction . return txHelper . inputParametersDeclarationToString ( funABI . inputs )
* / }
UniversalDApp . prototype . runTestTx = function ( tx ) {
return new Promise ( ( resolve , reject ) => { / * *
executionContext . detectNetwork ( ( error , network ) => { * This function send a tx only to javascript VM or testnet , will return an error for the mainnet
if ( error ) return reject ( error ) * SHOULD BE TAKEN CAREFULLY !
if ( network . name === 'Main' && network . id === '1' ) { *
return reject ( new Error ( 'It is not allowed to make this action against mainnet' ) ) * @ param { Object } tx - transaction .
} * /
this . silentRunTx ( tx , ( error , result ) => { runTestTx ( tx ) {
return new Promise ( ( resolve , reject ) => {
executionContext . detectNetwork ( ( error , network ) => {
if ( error ) return reject ( error ) if ( error ) return reject ( error )
resolve ( { if ( network . name === 'Main' && network . id === '1' ) {
transactionHash : result . transactionHash , return reject ( new Error ( 'It is not allowed to make this action against mainnet' ) )
status : result . result . status , }
gasUsed : '0x' + result . result . gasUsed . toString ( 'hex' ) , this . silentRunTx ( tx , ( error , result ) => {
error : result . result . vm . exceptionError , if ( error ) return reject ( error )
return : result . result . vm . return ? '0x' + result . result . vm . return . toString ( 'hex' ) : '0x' , resolve ( {
createdAddress : result . result . createdAddress ? '0x' + result . result . createdAddress . toString ( 'hex' ) : undefined 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 ) . * This function send a tx without alerting the user ( if mainnet or if gas estimation too high ) .
* SHOULD BE TAKEN CAREFULLY ! * SHOULD BE TAKEN CAREFULLY !
* *
* @ param { Object } tx - transaction . * @ param { Object } tx - transaction .
* @ param { Function } callback - callback . * @ param { Function } callback - callback .
* / * /
UniversalDApp . prototype . silentRunTx = function ( tx , cb ) { silentRunTx ( tx , cb ) {
if ( ! executionContext . isVM ( ) ) return cb ( 'Cannot silently send transaction through a web3 provider' ) if ( ! executionContext . isVM ( ) ) return cb ( 'Cannot silently send transaction through a web3 provider' )
this . txRunner . rawRun ( this . txRunner . rawRun (
tx , tx ,
( network , tx , gasEstimation , continueTxExecution , cancelCb ) => { continueTxExecution ( ) } , ( network , tx , gasEstimation , continueTxExecution , cancelCb ) => { continueTxExecution ( ) } ,
( error , continueTxExecution , cancelCb ) => { if ( error ) { cb ( error ) } else { continueTxExecution ( ) } } , ( error , continueTxExecution , cancelCb ) => { if ( error ) { cb ( error ) } else { continueTxExecution ( ) } } ,
( okCb , cancelCb ) => { okCb ( ) } , ( okCb , cancelCb ) => { okCb ( ) } ,
cb ) cb
} )
}
UniversalDApp . prototype . runTx = function ( args , confirmationCb , continueCb , promptCb , cb ) { runTx ( args , confirmationCb , continueCb , promptCb , cb ) {
const self = this const self = this
async . waterfall ( [ async . waterfall ( [
function getGasLimit ( next ) { function getGasLimit ( next ) {
if ( self . transactionContextAPI . getGasLimit ) { if ( self . transactionContextAPI . getGasLimit ) {
return self . transactionContextAPI . getGasLimit ( next ) return self . transactionContextAPI . getGasLimit ( next )
} }
next ( null , 3000000 ) next ( null , 3000000 )
} , } ,
function queryValue ( gasLimit , next ) { function queryValue ( gasLimit , next ) {
if ( args . value ) { if ( args . value ) {
return next ( null , args . value , gasLimit ) return next ( null , args . value , gasLimit )
} }
if ( args . useCall || ! self . transactionContextAPI . getValue ) { if ( args . useCall || ! self . transactionContextAPI . getValue ) {
return next ( null , 0 , gasLimit ) return next ( null , 0 , gasLimit )
} }
self . transactionContextAPI . getValue ( function ( err , value ) { self . transactionContextAPI . getValue ( function ( err , value ) {
next ( err , value , gasLimit ) 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 ) { function getAccount ( value , gasLimit , next ) {
let address = accounts [ 0 ] 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 ( err ) return next ( err )
if ( ! address ) return next ( 'No accounts available' ) if ( ! address ) return next ( 'No accounts available' )
if ( executionContext . isVM ( ) && ! self . accounts [ address ] ) { if ( executionContext . isVM ( ) && ! self . accounts [ address ] ) {
return next ( 'Invalid account selected' ) 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
} }
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 . event . trigger ( 'initiatingTransaction' , [ timestamp , tx , payLoad ] )
self . txRunner . rawRun ( tx , confirmationCb , continueCb , promptCb , self . txRunner . rawRun ( tx , confirmationCb , continueCb , promptCb ,
function ( error , result ) { function ( error , result ) {
let eventName = ( tx . useCall ? 'callExecuted' : 'transactionExecuted' ) let eventName = ( tx . useCall ? 'callExecuted' : 'transactionExecuted' )
self . event . trigger ( eventName , [ error , tx . from , tx . to , tx . data , tx . useCall , result , timestamp , payLoad ] ) self . event . trigger ( eventName , [ error , tx . from , tx . to , tx . data , tx . useCall , result , timestamp , payLoad ] )
if ( error && ( typeof ( error ) !== 'string' ) ) { if ( error && ( typeof ( error ) !== 'string' ) ) {
if ( error . message ) error = error . message if ( error . message ) error = error . message
else { else {
try { error = 'error: ' + JSON . stringify ( error ) } catch ( e ) { } try { error = 'error: ' + JSON . stringify ( error ) } catch ( e ) { }
}
} }
next ( error , result )
} }
next ( error , result ) )
} }
) ] , cb )
} }
] , cb )
} }
module . exports = UniversalDApp
yann300
6 years ago
committed by
GitHub