fetch rates min

roadmanjs · Mar 28, 2024 · 062cc7c · 062cc7c
1 parent 7fedfae
commit 062cc7c
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 7 deletions.
diff --git a/src/processors/kraken/rates/index.ts b/src/processors/kraken/rates/index.ts
@@ -4,7 +4,7 @@ import {PairRate, RatesCache} from '../../shared';
 // [cron] getAllTransactions -> settle
 import axios from 'axios';
 import {isEmpty} from 'lodash';
-import {verbose} from 'roadman';
+import {log} from '@roadmanjs/logs';
 
 interface PublicTickerResponse {
     error: any[];
@@ -34,7 +34,11 @@ export const fetchRates = async (pairs: string, cache = false): Promise<PairRate
             const rates = await Promise.all(
                 pairs.split(',').map((pair) => ratesCache.getPair(pair))
             );
-            return rates as any;
+
+            if (!rates.some((rate) => !rate) && !rates.some((rate) => Number.isNaN(rate.rate))) {
+                log('rates cache', rates);
+                return rates as any;
+            }
         }
 
         const getRates = async (pairrr: string) => {
@@ -74,6 +78,8 @@ export const fetchRates = async (pairs: string, cache = false): Promise<PairRate
 
         const rates = await Promise.all(pairs.split(',').map(getRates));
 
+        log('rates', rates);
+
         return rates;
     } catch (error) {
         console.log('Error getting store rates:', error);
@@ -87,7 +93,7 @@ export const fetchRatesSaveToCache = async (pairs: string): Promise<any> => {
         const rates = await fetchRates(pairs);
         if (!isEmpty(rates)) {
             const savedPairs = await rates.map(async (rate) => cache.savePair(rate.pair, rate));
-            verbose('savedPairs', savedPairs.length);
+            log('savedPairs', savedPairs.length);
         }
     } catch (error) {
         console.log('error fetchRatesSaveToCache', error);

diff --git a/src/processors/shared.ts b/src/processors/shared.ts
@@ -1,6 +1,9 @@
 import {REDIS_URL} from 'roadman';
 import Redis from 'ioredis';
 
+const ratesExpireMin = !Number.isNaN(+process.env.RATES_EXPIRE_MIN)
+    ? +process.env.RATES_EXPIRE_MIN
+    : 5;
 export interface PairRate {
     pair: string;
     rate: number;
@@ -12,19 +15,27 @@ export class RatesCache {
         this.redis = new Redis(REDIS_URL);
     }
 
-    async getPair(pair) {
+    async getPair(pair: string): Promise<PairRate> {
         return new Promise((resolve) => {
             this.redis.get(pair, (err, result) => {
                 if (err) {
                     resolve(null);
                 } else {
-                    resolve(JSON.parse(result));
+                    resolve(JSON.parse(result) as PairRate);
                 }
             });
         });
     }
 
-    async savePair(pair, value: any) {
-        return this.redis.set(pair, JSON.stringify(value));
+    async savePair(pair: string, value: PairRate): Promise<boolean> {
+        try {
+            if (!value || !value.pair || !value.rate) {
+                return false;
+            }
+            await this.redis.set(pair, JSON.stringify(value), 'EX', 60 * ratesExpireMin);
+            return true;
+        } catch (error) {
+            return false;
+        }
     }
 }