Introduce market data page size

apps/api/src/app/portfolio/current-rate.service.ts

@@ -21,6 +21,8 @@ import { GetValuesParams } from './interfaces/get-values-params.interface';
 
 @Injectable()
 export class CurrentRateService {
+  private static readonly MARKET_DATA_PAGE_SIZE = 50000;
+
   public constructor(
     private readonly dataProviderService: DataProviderService,
     private readonly marketDataService: MarketDataService,
@@ -41,30 +43,29 @@ export class CurrentRateService {
       (!dateQuery.gte || isBefore(dateQuery.gte, new Date())) &&
       (!dateQuery.in || this.containsToday(dateQuery.in));
 
-    const promises: Promise<GetValueObject[]>[] = [];
     const quoteErrors: ResponseError['errors'] = [];
     const today = resetHours(new Date());
+    const values: GetValueObject[] = [];
 
     if (includesToday) {
-      promises.push(
+      const quotesBySymbol = await this.dataProviderService.getQuotes({
-        this.dataProviderService
+        items: dataGatheringItems,
-          .getQuotes({ items: dataGatheringItems, user: this.request?.user })
+        user: this.request?.user
-          .then((dataResultProvider) => {
+      });
-            const result: GetValueObject[] = [];
 
       for (const { dataSource, symbol } of dataGatheringItems) {
-              if (dataResultProvider?.[symbol]?.dataProviderInfo) {
+        const quote = quotesBySymbol[symbol];
-                dataProviderInfos.push(
+
-                  dataResultProvider[symbol].dataProviderInfo
+        if (quote?.dataProviderInfo) {
-                );
+          dataProviderInfos.push(quote.dataProviderInfo);
         }
 
-              if (dataResultProvider?.[symbol]?.marketPrice) {
+        if (quote?.marketPrice) {
-                result.push({
+          values.push({
             dataSource,
             symbol,
             date: today,
-                  marketPrice: dataResultProvider?.[symbol]?.marketPrice
+            marketPrice: quote.marketPrice
           });
         } else {
           quoteErrors.push({
@@ -73,10 +74,6 @@ export class CurrentRateService {
           });
         }
       }
-
-            return result;
-          })
-      );
     }
 
     const assetProfileIdentifiers: AssetProfileIdentifier[] =
@@ -84,34 +81,42 @@ export class CurrentRateService {
         return { dataSource, symbol };
       });
 
-    promises.push(
+    const marketDataCount = await this.marketDataService.getRangeCount({
-      this.marketDataService
-        .getRange({
       assetProfileIdentifiers,
       dateQuery
-        })
+    });
-        .then((data) => {
+
-          return data.map(({ dataSource, date, marketPrice, symbol }) => {
+    for (
-            return {
+      let i = 0;
+      i < marketDataCount;
+      i += CurrentRateService.MARKET_DATA_PAGE_SIZE
+    ) {
+      // Use pageSize to limit the number of records fetched at once
+      const data = await this.marketDataService.getRange({
+        assetProfileIdentifiers,
+        dateQuery,
+        skip: i,
+        take: CurrentRateService.MARKET_DATA_PAGE_SIZE
+      });
+
+      values.push(
+        ...data.map(({ dataSource, date, marketPrice, symbol }) => ({
           dataSource,
           date,
           marketPrice,
           symbol
-            };
+        }))
-          });
-        })
       );
-
+    }
-    const values = await Promise.all(promises).then((array) => {
-      return array.flat();
-    });
 
     const response: GetValuesObject = {
       dataProviderInfos,
       errors: quoteErrors.map(({ dataSource, symbol }) => {
         return { dataSource, symbol };
       }),
-      values: uniqBy(values, ({ date, symbol }) => `${date}-${symbol}`)
+      values: uniqBy(values, ({ date, symbol }) => {
+        return `${date}-${symbol}`;
+      })
     };
 
     if (!isEmpty(quoteErrors)) {

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

@@ -60,12 +60,18 @@ export class MarketDataService {
 
   public async getRange({
     assetProfileIdentifiers,
-    dateQuery
+    dateQuery,
+    skip,
+    take
   }: {
     assetProfileIdentifiers: AssetProfileIdentifier[];
     dateQuery: DateQuery;
+    skip?: number;
+    take?: number;
   }): Promise<MarketData[]> {
     return this.prismaService.marketData.findMany({
+      skip,
+      take,
       orderBy: [
         {
           date: 'asc'
@@ -86,6 +92,26 @@ export class MarketDataService {
     });
   }
 
+  public async getRangeCount({
+    assetProfileIdentifiers,
+    dateQuery
+  }: {
+    assetProfileIdentifiers: AssetProfileIdentifier[];
+    dateQuery: DateQuery;
+  }): Promise<number> {
+    return this.prismaService.marketData.count({
+      where: {
+        date: dateQuery,
+        OR: assetProfileIdentifiers.map(({ dataSource, symbol }) => {
+          return {
+            dataSource,
+            symbol
+          };
+        })
+      }
+    });
+  }
+
   public async marketDataItems(params: {
     select?: Prisma.MarketDataSelectScalar;
     skip?: number;