logsManager and txExecution

pull/5370/head
aniket-engg 4 years ago committed by Aniket
parent 73873994c7
commit 16bf96e551
  1. 22
      libs/remix-lib/src/execution/logsManager.ts
  2. 13
      libs/remix-lib/src/execution/txExecution.ts

@ -1,7 +1,13 @@
const async = require('async') import { eachOf } from 'async'
const crypto = require('crypto') import { randomBytes } from 'crypto'
class LogsManager { export class LogsManager {
notificationCallbacks
subscriptions
filters
filterTracking
oldLogs
constructor () { constructor () {
this.notificationCallbacks = [] this.notificationCallbacks = []
@ -12,7 +18,7 @@ class LogsManager {
} }
checkBlock (blockNumber, block, web3) { checkBlock (blockNumber, block, web3) {
async.eachOf(block.transactions, (tx, i, next) => { eachOf(block.transactions, (tx, i, next) => {
let txHash = '0x' + tx.hash().toString('hex') let txHash = '0x' + tx.hash().toString('hex')
web3.eth.getTransactionReceipt(txHash, (_error, receipt) => { web3.eth.getTransactionReceipt(txHash, (_error, receipt) => {
@ -97,7 +103,7 @@ class LogsManager {
} }
subscribe (params) { subscribe (params) {
let subscriptionId = '0x' + crypto.randomBytes(16).toString('hex') let subscriptionId = '0x' + randomBytes(16).toString('hex')
this.subscriptions[subscriptionId] = params this.subscriptions[subscriptionId] = params
return subscriptionId return subscriptionId
} }
@ -107,7 +113,7 @@ class LogsManager {
} }
newFilter (filterType, params) { newFilter (filterType, params) {
const filterId = '0x' + crypto.randomBytes(16).toString('hex') const filterId = '0x' + randomBytes(16).toString('hex')
if (filterType === 'block' || filterType === 'pendingTransactions') { if (filterType === 'block' || filterType === 'pendingTransactions') {
this.filters[filterId] = { filterType } this.filters[filterId] = { filterType }
} }
@ -123,7 +129,7 @@ class LogsManager {
} }
getLogsForFilter (filterId, logsOnly) { getLogsForFilter (filterId, logsOnly) {
const {filterType, params} = this.filter[filterId] const {filterType, params} = this.filters[filterId]
const tracking = this.filterTracking[filterId] const tracking = this.filterTracking[filterId]
if (logsOnly || filterType === 'filter') { if (logsOnly || filterType === 'filter') {
@ -161,5 +167,3 @@ class LogsManager {
} }
} }
module.exports = LogsManager

@ -1,7 +1,6 @@
'use strict' 'use strict'
import { ethers } from 'ethers' import { ethers } from 'ethers'
module.exports = {
/** /**
* deploy the given contract * deploy the given contract
* *
@ -16,7 +15,7 @@ module.exports = {
* [personal mode enabled, need password to continue] promptCb (okCb, cancelCb) * [personal mode enabled, need password to continue] promptCb (okCb, cancelCb)
* @param {Function} finalCallback - last callback. * @param {Function} finalCallback - last callback.
*/ */
createContract: function (from, data, value, gasLimit, txRunner, callbacks, finalCallback) { export function createContract (from, data, value, gasLimit, txRunner, callbacks, finalCallback) {
if (!callbacks.confirmationCb || !callbacks.gasEstimationForceSend || !callbacks.promptCb) { if (!callbacks.confirmationCb || !callbacks.gasEstimationForceSend || !callbacks.promptCb) {
return finalCallback('all the callbacks must have been defined') return finalCallback('all the callbacks must have been defined')
} }
@ -25,7 +24,7 @@ module.exports = {
// see universaldapp.js line 660 => 700 to check possible values of txResult (error case) // see universaldapp.js line 660 => 700 to check possible values of txResult (error case)
finalCallback(error, txResult) finalCallback(error, txResult)
}) })
}, }
/** /**
* call the current given contract ! that will create a transaction ! * call the current given contract ! that will create a transaction !
@ -42,14 +41,14 @@ module.exports = {
* [personal mode enabled, need password to continue] promptCb (okCb, cancelCb) * [personal mode enabled, need password to continue] promptCb (okCb, cancelCb)
* @param {Function} finalCallback - last callback. * @param {Function} finalCallback - last callback.
*/ */
callFunction: function (from, to, data, value, gasLimit, funAbi, txRunner, callbacks, finalCallback) { export function callFunction (from, to, data, value, gasLimit, funAbi, txRunner, callbacks, finalCallback) {
const useCall = funAbi.stateMutability === 'view' || funAbi.stateMutability === 'pure' || funAbi.constant const useCall = funAbi.stateMutability === 'view' || funAbi.stateMutability === 'pure' || funAbi.constant
const tx = { from, to, data, useCall, value, gasLimit } const tx = { from, to, data, useCall, value, gasLimit }
txRunner.rawRun(tx, callbacks.confirmationCb, callbacks.gasEstimationForceSend, callbacks.promptCb, (error, txResult) => { txRunner.rawRun(tx, callbacks.confirmationCb, callbacks.gasEstimationForceSend, callbacks.promptCb, (error, txResult) => {
// see universaldapp.js line 660 => 700 to check possible values of txResult (error case) // see universaldapp.js line 660 => 700 to check possible values of txResult (error case)
finalCallback(error, txResult) finalCallback(error, txResult)
}) })
}, }
/** /**
* check if the vm has errored * check if the vm has errored
@ -57,7 +56,7 @@ module.exports = {
* @param {Object} txResult - the value returned by the vm * @param {Object} txResult - the value returned by the vm
* @return {Object} - { error: true/false, message: DOMNode } * @return {Object} - { error: true/false, message: DOMNode }
*/ */
checkVMError: function (txResult) { export function checkVMError (txResult) {
const errorCode = { const errorCode = {
OUT_OF_GAS: 'out of gas', OUT_OF_GAS: 'out of gas',
STACK_UNDERFLOW: 'stack underflow', STACK_UNDERFLOW: 'stack underflow',
@ -105,5 +104,5 @@ module.exports = {
ret.message = `${error}${exceptionError}${msg}\tDebug the transaction to get more information.` ret.message = `${error}${exceptionError}${msg}\tDebug the transaction to get more information.`
return ret return ret
} }
}

Loading…
Cancel
Save