Implement our own price indexer with historical data

backend/src/repositories/PricesRepository.ts

@@ -0,0 +1,32 @@
+import DB from '../database';
+import logger from '../logger';
+import { Prices } from '../tasks/price-updater';
+
+class PricesRepository {
+  public async $savePrices(time: number, prices: Prices): Promise<void> {
+    try {
+      await DB.query(`INSERT INTO prices(time, avg_prices) VALUE (FROM_UNIXTIME(?), ?)`, [time, JSON.stringify(prices)]);
+    } catch (e: any) {
+      logger.err(`Cannot save exchange rate into db. Reason: ` + (e instanceof Error ? e.message : e));
+      throw e;
+    }
+  }
+
+  public async $getOldestPriceTime(): Promise<number> {
+    const [oldestRow] = await DB.query(`SELECT UNIX_TIMESTAMP(time) as time from prices ORDER BY time LIMIT 1`);
+    return oldestRow[0] ? oldestRow[0].time : 0;
+  }
+
+  public async $getLatestPriceTime(): Promise<number> {
+    const [oldestRow] = await DB.query(`SELECT UNIX_TIMESTAMP(time) as time from prices ORDER BY time DESC LIMIT 1`);
+    return oldestRow[0] ? oldestRow[0].time : 0;
+  }
+
+  public async $getPricesTimes(): Promise<number[]> {
+    const [times]: any[] = await DB.query(`SELECT UNIX_TIMESTAMP(time) as time from prices`);
+    return times.map(time => time.time);
+  }
+}
+
+export default new PricesRepository();
+

backend/src/repositories/RatesRepository.ts

@@ -1,21 +0,0 @@
-import DB from '../database';
-import logger from '../logger';
-import { IConversionRates } from '../mempool.interfaces';
-
-class RatesRepository {
-  public async $saveRate(height: number, rates: IConversionRates) {
-    try {
-      await DB.query(`INSERT INTO rates(height, bisq_rates) VALUE (?, ?)`, [height, JSON.stringify(rates)]);
-    } catch (e: any) {
-      if (e.errno === 1062) { // ER_DUP_ENTRY - This scenario is possible upon node backend restart
-        logger.debug(`Rate already exists for block ${height}, ignoring`);
-      } else {
-        logger.err(`Cannot save exchange rate into db for block ${height} Reason: ` + (e instanceof Error ? e.message : e));
-        throw e;
-      }
-    }
-  }
-}
-
-export default new RatesRepository();
-