100 lines
3.6 KiB
TypeScript
100 lines
3.6 KiB
TypeScript
import logger from '../../logger';
|
|
import PricesRepository from '../../repositories/PricesRepository';
|
|
import { query } from '../../utils/axios-query';
|
|
import priceUpdater, { PriceFeed, PriceHistory } from '../price-updater';
|
|
|
|
class KrakenApi implements PriceFeed {
|
|
public name: string = 'Kraken';
|
|
public currencies: string[] = ['USD', 'EUR', 'GBP', 'CAD', 'CHF', 'AUD', 'JPY'];
|
|
|
|
public url: string = 'https://api.kraken.com/0/public/Ticker?pair=XBT';
|
|
public urlHist: string = 'https://api.kraken.com/0/public/OHLC?interval={GRANULARITY}&pair=XBT';
|
|
|
|
constructor() {
|
|
}
|
|
|
|
private getTicker(currency) {
|
|
let ticker = `XXBTZ${currency}`;
|
|
if (['CHF', 'AUD'].includes(currency)) {
|
|
ticker = `XBT${currency}`;
|
|
}
|
|
return ticker;
|
|
}
|
|
|
|
public async $fetchPrice(currency): Promise<number> {
|
|
const response = await query(this.url + currency);
|
|
return response ? parseInt(response['result'][this.getTicker(currency)]['c'][0], 10) : -1;
|
|
}
|
|
|
|
public async $fetchRecentPrice(currencies: string[], type: 'hour' | 'day'): Promise<PriceHistory> {
|
|
const priceHistory: PriceHistory = {};
|
|
|
|
for (const currency of currencies) {
|
|
if (this.currencies.includes(currency) === false) {
|
|
continue;
|
|
}
|
|
|
|
const response = await query(this.urlHist.replace('{GRANULARITY}', '60') + currency);
|
|
const pricesRaw = response ? response['result'][this.getTicker(currency)] : [];
|
|
|
|
for (const price of pricesRaw) {
|
|
if (priceHistory[price[0]] === undefined) {
|
|
priceHistory[price[0]] = priceUpdater.getEmptyPricesObj();
|
|
}
|
|
priceHistory[price[0]][currency] = price[4];
|
|
}
|
|
}
|
|
|
|
return priceHistory;
|
|
}
|
|
|
|
/**
|
|
* Fetch weekly price and save it into the database
|
|
*/
|
|
public async $insertHistoricalPrice(): Promise<void> {
|
|
const existingPriceTimes = await PricesRepository.$getPricesTimes();
|
|
|
|
// EUR weekly price history goes back to timestamp 1378339200 (September 5, 2013)
|
|
// USD weekly price history goes back to timestamp 1380758400 (October 3, 2013)
|
|
// GBP weekly price history goes back to timestamp 1415232000 (November 6, 2014)
|
|
// JPY weekly price history goes back to timestamp 1415232000 (November 6, 2014)
|
|
// CAD weekly price history goes back to timestamp 1436400000 (July 9, 2015)
|
|
// CHF weekly price history goes back to timestamp 1575504000 (December 5, 2019)
|
|
// AUD weekly price history goes back to timestamp 1591833600 (June 11, 2020)
|
|
|
|
let priceHistory: any = {}; // map: timestamp -> Prices
|
|
|
|
for (const currency of this.currencies) {
|
|
const response = await query(this.urlHist.replace('{GRANULARITY}', '10080') + currency);
|
|
const priceHistoryRaw = response ? response['result'][this.getTicker(currency)] : [];
|
|
|
|
for (const price of priceHistoryRaw) {
|
|
if (existingPriceTimes.includes(parseInt(price[0]))) {
|
|
continue;
|
|
}
|
|
|
|
// prices[0] = kraken price timestamp
|
|
// prices[4] = closing price
|
|
if (priceHistory[price[0]] === undefined) {
|
|
priceHistory[price[0]] = priceUpdater.getEmptyPricesObj();
|
|
}
|
|
priceHistory[price[0]][currency] = price[4];
|
|
}
|
|
}
|
|
|
|
for (const time in priceHistory) {
|
|
if (priceHistory[time].USD === -1) {
|
|
delete priceHistory[time];
|
|
continue;
|
|
}
|
|
await PricesRepository.$savePrices(parseInt(time, 10), priceHistory[time]);
|
|
}
|
|
|
|
if (Object.keys(priceHistory).length > 0) {
|
|
logger.notice(`Inserted ${Object.keys(priceHistory).length} Kraken EUR, USD, GBP, JPY, CAD, CHF and AUD weekly price history into db`);
|
|
}
|
|
}
|
|
}
|
|
|
|
export default KrakenApi;
|