Commit 0071cd2d authored by aniket-engg's avatar aniket-engg Committed by Aniket

srcinTs

parent 8dc31f40
'use strict' 'use strict'
const ethers = require('ethers') import { ethers } from 'ethers'
const txHelper = require('./txHelper') const txHelper = require('./txHelper')
/** /**
...@@ -7,6 +7,8 @@ const txHelper = require('./txHelper') ...@@ -7,6 +7,8 @@ const txHelper = require('./txHelper')
* *
*/ */
class EventsDecoder { class EventsDecoder {
resolveReceipt
constructor ({resolveReceipt}) { constructor ({resolveReceipt}) {
this.resolveReceipt = resolveReceipt this.resolveReceipt = resolveReceipt
} }
......
/* global ethereum */ /* global ethereum */
'use strict' 'use strict'
const Web3 = require('web3') import Web3 from 'web3'
const EventManager = require('../eventManager') const EventManager = require('../eventManager')
const EthJSVM = require('ethereumjs-vm').default const EthJSVM = require('ethereumjs-vm').default
const ethUtil = require('ethereumjs-util') const ethUtil = require('ethereumjs-util')
...@@ -12,8 +12,8 @@ const LogsManager = require('./logsManager.js') ...@@ -12,8 +12,8 @@ const LogsManager = require('./logsManager.js')
const rlp = ethUtil.rlp const rlp = ethUtil.rlp
let web3 let web3
if (typeof window !== 'undefined' && typeof window.ethereum !== 'undefined') { if (typeof window !== 'undefined' && typeof window['ethereum'] !== 'undefined') {
var injectedProvider = window.ethereum var injectedProvider = window['ethereum']
web3 = new Web3(injectedProvider) web3 = new Web3(injectedProvider)
} else { } else {
web3 = new Web3(new Web3.providers.HttpProvider('http://localhost:8545')) web3 = new Web3(new Web3.providers.HttpProvider('http://localhost:8545'))
......
'use strict' 'use strict'
const ethers = require('ethers') import { ethers } from 'ethers'
module.exports = { module.exports = {
/** /**
......
'use strict' 'use strict'
const ethers = require('ethers') import { ethers } from 'ethers'
module.exports = { module.exports = {
makeFullTypeDefinition: function (typeDef) { makeFullTypeDefinition: function (typeDef) {
...@@ -76,7 +76,7 @@ module.exports = { ...@@ -76,7 +76,7 @@ module.exports = {
if (abi[i].type === 'constructor') { if (abi[i].type === 'constructor') {
funABI.inputs = abi[i].inputs || [] funABI.inputs = abi[i].inputs || []
funABI.payable = abi[i].payable funABI.payable = abi[i].payable
funABI.stateMutability = abi[i].stateMutability funABI['stateMutability'] = abi[i].stateMutability
break break
} }
} }
......
'use strict' 'use strict'
const async = require('async') import async from 'async'
const ethers = require('ethers') import { ethers } from 'ethers'
const ethJSUtil = require('ethereumjs-util') const ethJSUtil = require('ethereumjs-util')
const EventManager = require('../eventManager') const EventManager = require('../eventManager')
const codeUtil = require('../util') const codeUtil = require('../util')
...@@ -28,6 +28,17 @@ function addExecutionCosts(txResult, tx) { ...@@ -28,6 +28,17 @@ function addExecutionCosts(txResult, tx) {
*/ */
class TxListener { class TxListener {
event
executionContext
_resolvedTransactions
_api
_resolvedContracts
_isListening: boolean
_listenOnNetwork:boolean
_loopId
blocks
lastBlock
constructor (opt, executionContext) { constructor (opt, executionContext) {
this.event = new EventManager() this.event = new EventManager()
// has a default for now for backwards compatability // has a default for now for backwards compatability
......
'use strict' 'use strict'
const EthJSTX = require('ethereumjs-tx').Transaction const EthJSTX = require('ethereumjs-tx').Transaction
const EthJSBlock = require('ethereumjs-block') const EthJSBlock = require('ethereumjs-block')
const ethJSUtil = require('ethereumjs-util') import { BN } from 'ethereumjs-util'
const BN = ethJSUtil.BN
const defaultExecutionContext = require('./execution-context') const defaultExecutionContext = require('./execution-context')
const EventManager = require('../eventManager') const EventManager = require('../eventManager')
class TxRunner { class TxRunner {
event
executionContext
_api
blockNumber
runAsync
pendingTxs
vmaccounts
queusTxs
blocks
constructor (vmaccounts, api, executionContext) { constructor (vmaccounts, api, executionContext) {
this.event = new EventManager() this.event = new EventManager()
// has a default for now for backwards compatability // has a default for now for backwards compatability
...@@ -63,7 +73,7 @@ class TxRunner { ...@@ -63,7 +73,7 @@ class TxRunner {
resolve({ resolve({
result, result,
tx, tx,
transactionHash: result ? result.transactionHash : null transactionHash: result ? result['transactionHash'] : null
}) })
}) })
} }
...@@ -167,7 +177,7 @@ class TxRunner { ...@@ -167,7 +177,7 @@ class TxRunner {
const tx = { from: from, to: to, data: data, value: value } const tx = { from: from, to: to, data: data, value: value }
if (useCall) { if (useCall) {
tx.gas = gasLimit tx['gas'] = gasLimit
return this.executionContext.web3().eth.call(tx, function (error, result) { return this.executionContext.web3().eth.call(tx, function (error, result) {
callback(error, { callback(error, {
result: result, result: result,
...@@ -182,7 +192,7 @@ class TxRunner { ...@@ -182,7 +192,7 @@ class TxRunner {
} }
gasEstimationForceSend(err, () => { gasEstimationForceSend(err, () => {
// callback is called whenever no error // callback is called whenever no error
tx.gas = !gasEstimation ? gasLimit : gasEstimation tx['gas'] = !gasEstimation ? gasLimit : gasEstimation
if (this._api.config.getUnpersistedProperty('doNotShowTransactionConfirmationAgain')) { if (this._api.config.getUnpersistedProperty('doNotShowTransactionConfirmationAgain')) {
return this._executeTx(tx, null, this._api, promptCb, callback) return this._executeTx(tx, null, this._api, promptCb, callback)
...@@ -194,7 +204,7 @@ class TxRunner { ...@@ -194,7 +204,7 @@ class TxRunner {
return return
} }
confirmCb(network, tx, tx.gas, (gasPrice) => { confirmCb(network, tx, tx['gas'], (gasPrice) => {
return this._executeTx(tx, gasPrice, this._api, promptCb, callback) return this._executeTx(tx, gasPrice, this._api, promptCb, callback)
}, (error) => { }, (error) => {
callback(error) callback(error)
...@@ -248,7 +258,7 @@ async function tryTillTxAvailable (txhash, executionContext) { ...@@ -248,7 +258,7 @@ async function tryTillTxAvailable (txhash, executionContext) {
async function pause () { return new Promise((resolve, reject) => { setTimeout(resolve, 500) }) } async function pause () { return new Promise((resolve, reject) => { setTimeout(resolve, 500) }) }
function run(self, tx, stamp, confirmationCb, gasEstimationForceSend, promptCb, callback) { function run(self, tx, stamp, confirmationCb, gasEstimationForceSend = null, promptCb = null, callback = null) {
if (!self.runAsync && Object.keys(self.pendingTxs).length) { if (!self.runAsync && Object.keys(self.pendingTxs).length) {
return self.queusTxs.push({ tx, stamp, callback }) return self.queusTxs.push({ tx, stamp, callback })
} }
......
'use strict' 'use strict'
const ethutil = require('ethereumjs-util') import { BN, bufferToHex, keccak, setLengthLeft } from 'ethereumjs-util'
/* /*
contains misc util: @TODO should be splitted contains misc util: @TODO should be splitted
...@@ -48,10 +48,10 @@ module.exports = { ...@@ -48,10 +48,10 @@ module.exports = {
const ret = [] const ret = []
for (let k in bnList) { for (let k in bnList) {
const v = bnList[k] const v = bnList[k]
if (ethutil.BN.isBN(v)) { if (BN.isBN(v)) {
ret.push('0x' + v.toString('hex', 64)) ret.push('0x' + v.toString('hex', 64))
} else { } else {
ret.push('0x' + (new ethutil.BN(v)).toString('hex', 64)) // TEMP FIX TO REMOVE ONCE https://github.com/ethereumjs/ethereumjs-vm/pull/293 is released ret.push('0x' + (new BN(v)).toString('hex', 64)) // TEMP FIX TO REMOVE ONCE https://github.com/ethereumjs/ethereumjs-vm/pull/293 is released
} }
} }
return ret return ret
...@@ -161,9 +161,9 @@ module.exports = { ...@@ -161,9 +161,9 @@ module.exports = {
if (typeof value === 'string' && value.indexOf('0x') !== 0) { if (typeof value === 'string' && value.indexOf('0x') !== 0) {
value = '0x' + value value = '0x' + value
} }
let ret = ethutil.bufferToHex(ethutil.setLengthLeft(value, 32)) let ret: any = bufferToHex(setLengthLeft(value, 32))
ret = ethutil.keccak(ret) ret = keccak(ret)
return ethutil.bufferToHex(ret) return bufferToHex(ret)
}, },
/** /**
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment