tornadocash/tornado-cli
3
0
Fork 1
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

Remove duplicate function updateCache

Browse Source
This commit is contained in:
Theodike 2023-04-14 20:06:39 +03:00
parent 85c5bdc13f
commit bbdf0fbea3
1 changed files with 12 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
cli.js
View File

@ -931,6 +931,17 @@ async function fetchEvents({ type, currency, amount }) {
console.log('Loaded cached', amount, currency.toUpperCase(), type, 'events for', startBlock, 'block');
console.log('Fetching', amount, currency.toUpperCase(), type, 'events for', netName, 'network');
async function updateCache(fetchedEvents) {
try {
const fileName = `./cache/${netName.toLowerCase()}/${type}s_${currency}_${amount}.json`;
const localEvents = await initJson(fileName);
const events = localEvents.concat(fetchedEvents);
await fs.writeFileSync(fileName, JSON.stringify(events, null, 2), 'utf8');
} catch (error) {
throw new Error('Writing cache file failed:', error);
}
}
async function syncEvents() {
try {
let targetBlock = await web3.eth.getBlockNumber();
@ -1005,18 +1016,8 @@ async function fetchEvents({ type, currency, amount }) {
}
}
async function updateCache() {
try {
const fileName = `./cache/${netName.toLowerCase()}/${type}s_${currency}_${amount}.json`;
const localEvents = await initJson(fileName);
const events = localEvents.concat(fetchedEvents);
await fs.writeFileSync(fileName, JSON.stringify(events, null, 2), 'utf8');
} catch (error) {
throw new Error('Writing cache file failed:', error);
}
}
await fetchWeb3Events(i);
await updateCache();
await updateCache(fetchedEvents);
}
} catch (error) {
console.log(error);
@ -1143,17 +1144,6 @@ async function fetchEvents({ type, currency, amount }) {
}
}
async function updateCache(fetchedEvents) {
try {
const fileName = `./cache/${netName.toLowerCase()}/${type}s_${currency}_${amount}.json`;
const localEvents = await initJson(fileName);
const events = localEvents.concat(fetchedEvents);
await fs.writeFileSync(fileName, JSON.stringify(events, null, 2), 'utf8');
} catch (error) {
throw new Error('Writing cache file failed:', error);
}
}
async function fetchGraphEvents() {
console.log('Querying latest events from TheGraph');
const latestTimestamp = await queryLatestTimestamp();