Feature/improve data gathering for currencies (#581)

* Improve data gathering for currencies, add warning if it fails

* Update changelog

CHANGELOG.md

@@ -7,9 +7,14 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## Unreleased
 
+### Added
+
+- Added a warning to the log if the data gathering fails
+
 ### Fixed
 
 - Filtered potential `null` currencies
+- Improved the 7d data gathering optimization for currencies
 
 ## 1.94.0 - 25.12.2021
 

apps/api/src/services/data-gathering.service.ts

@@ -334,16 +334,25 @@ export class DataGatheringService {
                 ?.marketPrice;
           }
 
-          try {
+          if (lastMarketPrice) {
-            await this.prismaService.marketData.create({
+            try {
-              data: {
+              await this.prismaService.marketData.create({
-                dataSource,
+                data: {
-                symbol,
+                  dataSource,
-                date: currentDate,
+                  symbol,
-                marketPrice: lastMarketPrice
+                  date: currentDate,
-              }
+                  marketPrice: lastMarketPrice
-            });
+                }
-          } catch {}
+              });
+            } catch {}
+          } else {
+            Logger.warn(
+              `Failed to gather data for symbol ${symbol} at ${format(
+                currentDate,
+                DATE_FORMAT
+              )}.`
+            );
+          }
 
           // Count month one up for iteration
           currentDate = new Date(
@@ -492,8 +501,8 @@ export class DataGatheringService {
         }
       })
     )
-      .filter((symbolProfile) => {
+      .filter(({ symbol }) => {
-        return symbolsToGather.includes(symbolProfile.symbol);
+        return symbolsToGather.includes(symbol);
       })
       .map((symbolProfile) => {
         return {
@@ -504,6 +513,9 @@ export class DataGatheringService {
 
     const currencyPairsToGather = this.exchangeRateDataService
       .getCurrencyPairs()
+      .filter(({ symbol }) => {
+        return symbolsToGather.includes(symbol);
+      })
       .map(({ dataSource, symbol }) => {
         return {
           dataSource,