aboutsummaryrefslogtreecommitdiffstats
path: root/packages/pipeline
diff options
context:
space:
mode:
authorxianny <xianny@gmail.com>2018-12-11 02:57:36 +0800
committerxianny <xianny@gmail.com>2018-12-11 02:57:36 +0800
commit096c4c8f2b20b4ca909d4ba950e219c22a5f8882 (patch)
tree4a4a0e01b76300f0bbe706880a25ac5c1cfe2e7c /packages/pipeline
parent5febb595e929d736f4f0d72ef43a840109e9863a (diff)
downloaddexon-sol-tools-096c4c8f2b20b4ca909d4ba950e219c22a5f8882.tar
dexon-sol-tools-096c4c8f2b20b4ca909d4ba950e219c22a5f8882.tar.gz
dexon-sol-tools-096c4c8f2b20b4ca909d4ba950e219c22a5f8882.tar.bz2
dexon-sol-tools-096c4c8f2b20b4ca909d4ba950e219c22a5f8882.tar.lz
dexon-sol-tools-096c4c8f2b20b4ca909d4ba950e219c22a5f8882.tar.xz
dexon-sol-tools-096c4c8f2b20b4ca909d4ba950e219c22a5f8882.tar.zst
dexon-sol-tools-096c4c8f2b20b4ca909d4ba950e219c22a5f8882.zip
change to camelCase
Diffstat (limited to 'packages/pipeline')
-rw-r--r--packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts4
-rw-r--r--packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts2
2 files changed, 3 insertions, 3 deletions
diff --git a/packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts b/packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts
index 44448d241..85042501b 100644
--- a/packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts
+++ b/packages/pipeline/src/data_sources/ohlcv_external/crypto_compare.ts
@@ -42,7 +42,7 @@ const MAX_PAGE_SIZE = 2000;
export class CryptoCompareOHLCVSource {
public readonly intervalBetweenRecords = ONE_HOUR;
- public readonly default_exchange = 'CCCAGG';
+ public readonly defaultExchange = 'CCCAGG';
public readonly interval = this.intervalBetweenRecords * MAX_PAGE_SIZE; // the hourly API returns data for one interval at a time
private readonly _url: string = 'https://min-api.cryptocompare.com/data/histohour?';
@@ -60,7 +60,7 @@ export class CryptoCompareOHLCVSource {
// gets OHLCV records starting from pair.latest
public async getHourlyOHLCVAsync(pair: TradingPair): Promise<CryptoCompareOHLCVRecord[]> {
const params = {
- e: this.default_exchange,
+ e: this.defaultExchange,
fsym: pair.fromSymbol,
tsym: pair.toSymbol,
limit: MAX_PAGE_SIZE,
diff --git a/packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts b/packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts
index a29a13bfc..d44eb5cc6 100644
--- a/packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts
+++ b/packages/pipeline/src/scripts/pull_ohlcv_cryptocompare.ts
@@ -63,7 +63,7 @@ async function fetchAndSaveAsync(
console.log(`Retrieved ${records.length} records for ${JSON.stringify(pair)}`);
if (records.length > 0) {
const metadata: OHLCVMetadata = {
- exchange: source.default_exchange,
+ exchange: source.defaultExchange,
fromSymbol: pair.fromSymbol,
toSymbol: pair.toSymbol,
source: SOURCE_NAME,