diff options
author | F. Eugene Aumson <feuGeneA@users.noreply.github.com> | 2019-01-15 07:21:12 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-01-15 07:21:12 +0800 |
commit | c859788fdee8d8c2af0cdc69403a61f861fec0e5 (patch) | |
tree | 11d262e2ed136dbf94e4dd105331ae6dee6e7cd3 /packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts | |
parent | 1c25d8e997456c248470d925cf6702e46d959a62 (diff) | |
download | dexon-sol-tools-c859788fdee8d8c2af0cdc69403a61f861fec0e5.tar dexon-sol-tools-c859788fdee8d8c2af0cdc69403a61f861fec0e5.tar.gz dexon-sol-tools-c859788fdee8d8c2af0cdc69403a61f861fec0e5.tar.bz2 dexon-sol-tools-c859788fdee8d8c2af0cdc69403a61f861fec0e5.tar.lz dexon-sol-tools-c859788fdee8d8c2af0cdc69403a61f861fec0e5.tar.xz dexon-sol-tools-c859788fdee8d8c2af0cdc69403a61f861fec0e5.tar.zst dexon-sol-tools-c859788fdee8d8c2af0cdc69403a61f861fec0e5.zip |
Replace console.log with logUtils.log (#1515)
Diffstat (limited to 'packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts')
-rw-r--r-- | packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts b/packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts index d44eb5cc6..caac7b9d4 100644 --- a/packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts +++ b/packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts @@ -1,6 +1,7 @@ -// tslint:disable:no-console import { Connection, ConnectionOptions, createConnection, Repository } from 'typeorm'; +import { logUtils } from '@0x/utils'; + import { CryptoCompareOHLCVSource } from '../data_sources/ohlcv_external/crypto_compare'; import { OHLCVExternal } from '../entities'; import * as ormConfig from '../ormconfig'; @@ -24,14 +25,14 @@ let connection: Connection; const jobTime = new Date().getTime(); const tradingPairs = await fetchOHLCVTradingPairsAsync(connection, SOURCE_NAME, EARLIEST_BACKFILL_TIME); - console.log(`Starting ${tradingPairs.length} job(s) to scrape Crypto Compare for OHLCV records...`); + logUtils.log(`Starting ${tradingPairs.length} job(s) to scrape Crypto Compare for OHLCV records...`); const fetchAndSavePromises = tradingPairs.map(async pair => { const pairs = source.generateBackfillIntervals(pair); return fetchAndSaveAsync(source, repository, jobTime, pairs); }); await Promise.all(fetchAndSavePromises); - console.log(`Finished scraping OHLCV records from Crypto Compare, exiting...`); + logUtils.log(`Finished scraping OHLCV records from Crypto Compare, exiting...`); process.exit(0); })().catch(handleError); @@ -60,7 +61,7 @@ async function fetchAndSaveAsync( } try { const records = await source.getHourlyOHLCVAsync(pair); - console.log(`Retrieved ${records.length} records for ${JSON.stringify(pair)}`); + logUtils.log(`Retrieved ${records.length} records for ${JSON.stringify(pair)}`); if (records.length > 0) { const metadata: OHLCVMetadata = { exchange: source.defaultExchange, @@ -75,7 +76,7 @@ async function fetchAndSaveAsync( } i++; } catch (err) { - console.log(`Error scraping OHLCVRecords, stopping task for ${JSON.stringify(pair)} [${err}]`); + logUtils.log(`Error scraping OHLCVRecords, stopping task for ${JSON.stringify(pair)} [${err}]`); break; } } @@ -90,6 +91,6 @@ async function saveRecordsAsync(repository: Repository<OHLCVExternal>, records: new Date(records[records.length - 1].endTime), ]; - console.log(`Saving ${records.length} records to ${repository.metadata.name}... ${JSON.stringify(metadata)}`); + logUtils.log(`Saving ${records.length} records to ${repository.metadata.name}... ${JSON.stringify(metadata)}`); await repository.save(records); } |