diff options
| author | Alex Browne <stephenalexbrowne@gmail.com> | 2018-09-20 01:51:12 +0800 |
|---|---|---|
| committer | Fred Carlsen <fred@sjelfull.no> | 2018-12-13 01:11:52 +0800 |
| commit | c46d2f8f9d4e632352637376b2556101bccad748 (patch) | |
| tree | 9a5dbfd6df21ac523aa9cbb9e0a9a2d0242cd64c /packages/pipeline/src/run_jobs.ts | |
| parent | eb1317a59abec368f3855eb3690e40d8db2a8984 (diff) | |
| download | dexon-sol-tools-c46d2f8f9d4e632352637376b2556101bccad748.tar dexon-sol-tools-c46d2f8f9d4e632352637376b2556101bccad748.tar.gz dexon-sol-tools-c46d2f8f9d4e632352637376b2556101bccad748.tar.bz2 dexon-sol-tools-c46d2f8f9d4e632352637376b2556101bccad748.tar.lz dexon-sol-tools-c46d2f8f9d4e632352637376b2556101bccad748.tar.xz dexon-sol-tools-c46d2f8f9d4e632352637376b2556101bccad748.tar.zst dexon-sol-tools-c46d2f8f9d4e632352637376b2556101bccad748.zip | |
Remove old code. Create function for getting contract events via etherscan
Diffstat (limited to 'packages/pipeline/src/run_jobs.ts')
| -rw-r--r-- | packages/pipeline/src/run_jobs.ts | 87 |
1 files changed, 0 insertions, 87 deletions
diff --git a/packages/pipeline/src/run_jobs.ts b/packages/pipeline/src/run_jobs.ts deleted file mode 100644 index 4d82d4e2d..000000000 --- a/packages/pipeline/src/run_jobs.ts +++ /dev/null @@ -1,87 +0,0 @@ -import { exec } from 'child_process'; - -import { postgresClient } from './postgres.js'; -import { dataFetchingQueries } from './scripts/query_data.js'; -import { web3, zrx } from './zrx.js'; -const CUR_BLOCK_OFFSET = 20; -postgresClient.query(dataFetchingQueries.get_max_block, []).then((data: any) => { - const maxBlockNumber = data.rows[0].max; - const safeCurBlockNumber = web3.eth.blockNumber - CUR_BLOCK_OFFSET; - console.log('Scraping ' + maxBlockNumber + ' to ' + safeCurBlockNumber); - exec( - 'node ./lib/scripts/scrape_data --type events --from ' + maxBlockNumber + ' --to ' + safeCurBlockNumber, - (error, stdout, stderr) => { - if (error) { - console.log(error); - return; - } - console.log('Scraped events'); - console.log('Scraping blocks'); - exec( - 'node ./lib/scripts/scrape_data --type blocks --from ' + maxBlockNumber + ' --to ' + safeCurBlockNumber, - (error, stdout, stderr) => { - if (error) { - console.log(error); - return; - } - console.log('Scraped blocks'); - console.log('Scraping transactions'); - exec( - 'node ./lib/scripts/scrape_data --type transactions --from ' + - maxBlockNumber + - ' --to ' + - safeCurBlockNumber, - (error, stdout, stderr) => { - if (error) { - console.log(error); - return; - } - console.log('Scraped transactions'); - console.log('Joining events_staging'); - exec( - 'node ./lib/scripts/join_tables --name events_staging --from ' + - maxBlockNumber + - ' --to ' + - safeCurBlockNumber, - (error, stdout, stderr) => { - if (error) { - console.log(error); - return; - } - console.log('Joined events_staging'); - console.log('Joining events'); - exec( - 'node ./lib/scripts/join_tables --name events --from ' + - maxBlockNumber + - ' --to ' + - safeCurBlockNumber, - (error, stdout, stderr) => { - if (error) { - console.log(error); - return; - } - console.log('Joined events'); - console.log('Joining events_full'); - exec( - 'node ./lib/scripts/join_tables --name events_full --from ' + - maxBlockNumber + - ' --to ' + - safeCurBlockNumber, - (error, stdout, stderr) => { - if (error) { - console.log(error); - return; - } - }, - ); - }, - ); - }, - ); - }, - ); - }, - ); - }, - ); -}); |