TornadoCash/classic-ui
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

Revert "minor fixes"

Browse source 
This reverts commit 7f8f7c2aa1.
This commit is contained in:
FreezyEx 2022-10-13 16:03:54 +02:00
parent 7f8f7c2aa1
commit b32527e057
352 changed files with 49537 additions and 49537 deletions
Download patch file Download diff file Expand all files Collapse all files

202
scripts/helpers/download.js
View file

@ -1,101 +1,101 @@
import fs from 'fs'
import Jszip from 'jszip'
import Web3 from 'web3'
import networkConfig from '../../networkConfig'
const jszip = new Jszip()
export async function download({ name, directory, contentType }) {
const path = `${directory}${name}.zip`.toLowerCase()
const data = fs.readFileSync(path)
const zip = await jszip.loadAsync(data)
const file = zip.file(
path
.replace(directory, '')
.slice(0, -4)
.toLowerCase()
)
const content = await file.async(contentType)
return content
}
export async function loadCachedEvents({ name, directory, deployedBlock }) {
try {
const module = await download({ contentType: 'string', directory, name })
if (module) {
const events = JSON.parse(module)
return {
events,
lastBlock: events[events.length - 1].blockNumber
}
}
} catch (err) {
console.error(`Method loadCachedEvents has error: ${err.message}`)
return {
events: [],
lastBlock: deployedBlock
}
}
}
export async function getPastEvents({ type, fromBlock, netId, events, contractAttrs }) {
let downloadedEvents = events
let [{ url: rpcUrl }] = Object.values(networkConfig[`netId${netId}`].rpcUrls)
if (netId === '5') {
rpcUrl = 'https://goerli.infura.io/v3/9aa3d95b3bc440fa88ea12eaa4456161'
}
const provider = new Web3.providers.HttpProvider(rpcUrl)
const web3 = new Web3(provider)
const contract = new web3.eth.Contract(...contractAttrs)
const currentBlockNumber = await web3.eth.getBlockNumber()
// PoS networks index blocks too fast, so a buffer is needed
const blockNumberBuffer = currentBlockNumber - 3
const blockDifference = Math.ceil(blockNumberBuffer - fromBlock)
// eth_logs and eth_filter are restricted > 10,000 block queries
const blockRange = 10000
let chunksCount = blockDifference === 0 ? 1 : Math.ceil(blockDifference / blockRange)
const chunkSize = Math.ceil(blockDifference / chunksCount)
let toBlock = fromBlock + chunkSize
if (fromBlock < currentBlockNumber) {
if (toBlock >= currentBlockNumber) {
toBlock = currentBlockNumber
chunksCount = 1
}
console.log(`Fetching ${type}, chainId - ${netId}`, `chunksCount - ${chunksCount}`)
for (let i = 0; i < chunksCount; i++)
try {
await new Promise((resolve) => setTimeout(resolve, 200))
console.log(`fromBlock - ${fromBlock}`)
console.log(`toBlock - ${toBlock}`)
const eventsChunk = await contract.getPastEvents(type, { fromBlock, toBlock })
if (eventsChunk) {
downloadedEvents = downloadedEvents.concat(eventsChunk)
console.log('downloaded events count - ', eventsChunk.length)
console.log('____________________________________________')
}
fromBlock = toBlock
toBlock += chunkSize
} catch (err) {
console.log('getPastEvents events', `chunk number - ${i}, has error: ${err.message}`)
}
}
return downloadedEvents
}
import fs from 'fs'
import Jszip from 'jszip'
import Web3 from 'web3'
import networkConfig from '../../networkConfig'
const jszip = new Jszip()
export async function download({ name, directory, contentType }) {
const path = `${directory}${name}.zip`.toLowerCase()
const data = fs.readFileSync(path)
const zip = await jszip.loadAsync(data)
const file = zip.file(
path
.replace(directory, '')
.slice(0, -4)
.toLowerCase()
)
const content = await file.async(contentType)
return content
}
export async function loadCachedEvents({ name, directory, deployedBlock }) {
try {
const module = await download({ contentType: 'string', directory, name })
if (module) {
const events = JSON.parse(module)
return {
events,
lastBlock: events[events.length - 1].blockNumber
}
}
} catch (err) {
console.error(`Method loadCachedEvents has error: ${err.message}`)
return {
events: [],
lastBlock: deployedBlock
}
}
}
export async function getPastEvents({ type, fromBlock, netId, events, contractAttrs }) {
let downloadedEvents = events
let [{ url: rpcUrl }] = Object.values(networkConfig[`netId${netId}`].rpcUrls)
if (netId === '5') {
rpcUrl = 'https://goerli.infura.io/v3/9aa3d95b3bc440fa88ea12eaa4456161'
}
const provider = new Web3.providers.HttpProvider(rpcUrl)
const web3 = new Web3(provider)
const contract = new web3.eth.Contract(...contractAttrs)
const currentBlockNumber = await web3.eth.getBlockNumber()
// PoS networks index blocks too fast, so a buffer is needed
const blockNumberBuffer = currentBlockNumber - 3
const blockDifference = Math.ceil(blockNumberBuffer - fromBlock)
// eth_logs and eth_filter are restricted > 10,000 block queries
const blockRange = 10000
let chunksCount = blockDifference === 0 ? 1 : Math.ceil(blockDifference / blockRange)
const chunkSize = Math.ceil(blockDifference / chunksCount)
let toBlock = fromBlock + chunkSize
if (fromBlock < currentBlockNumber) {
if (toBlock >= currentBlockNumber) {
toBlock = currentBlockNumber
chunksCount = 1
}
console.log(`Fetching ${type}, chainId - ${netId}`, `chunksCount - ${chunksCount}`)
for (let i = 0; i < chunksCount; i++)
try {
await new Promise((resolve) => setTimeout(resolve, 200))
console.log(`fromBlock - ${fromBlock}`)
console.log(`toBlock - ${toBlock}`)
const eventsChunk = await contract.getPastEvents(type, { fromBlock, toBlock })
if (eventsChunk) {
downloadedEvents = downloadedEvents.concat(eventsChunk)
console.log('downloaded events count - ', eventsChunk.length)
console.log('____________________________________________')
}
fromBlock = toBlock
toBlock += chunkSize
} catch (err) {
console.log('getPastEvents events', `chunk number - ${i}, has error: ${err.message}`)
}
}
return downloadedEvents
}