Merge branch 'main' into feature/add-pagination-to-platform-and-tag-management-of-admin-control-panel

CHANGELOG.md

@@ -12,6 +12,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Added pagination to the platform management of the admin control panel
 - Added pagination to the tag management of the admin control panel
 
+### Fixed
+
+- Fixed an issue with hourly market data updates not refreshing prices for asset profiles with `MANUAL` data source
+
 ## 3.15.1 - 2026-06-23
 
 ### Changed

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

@@ -662,7 +662,11 @@ export class DataProviderService implements OnModuleInit {
         );
 
         const promise = Promise.resolve(
-          dataProvider.getQuotes({ requestTimeout, symbols: symbolsChunk })
+          dataProvider.getQuotes({
+            requestTimeout,
+            useCache,
+            symbols: symbolsChunk
+          })
         );
 
         promises.push(

apps/api/src/services/data-provider/interfaces/data-provider.interface.ts

@@ -75,6 +75,7 @@ export interface GetHistoricalParams {
 export interface GetQuotesParams {
   requestTimeout?: number;
   symbols: string[];
+  useCache?: boolean;
 }
 
 export interface GetSearchParams {

apps/api/src/services/data-provider/manual/manual.service.ts

@@ -136,7 +136,8 @@ export class ManualService implements DataProviderInterface {
   }
 
   public async getQuotes({
-    symbols
+    symbols,
+    useCache = true
   }: GetQuotesParams): Promise<{ [symbol: string]: DataProviderResponse }> {
     const response: { [symbol: string]: DataProviderResponse } = {};
 
@@ -164,32 +165,32 @@ export class ManualService implements DataProviderInterface {
         }
       });
 
-      const symbolProfilesWithScraperConfigurationAndInstantMode =
+      const symbolProfilesToScrape = symbolProfiles.filter(
-        symbolProfiles.filter(({ scraperConfiguration }) => {
+        ({ scraperConfiguration }) => {
           return (
-            scraperConfiguration?.mode === 'instant' &&
+            (scraperConfiguration?.mode === 'instant' || !useCache) &&
             scraperConfiguration?.selector &&
             scraperConfiguration?.url
           );
-        });
+        }
-
+      );
-      const scraperResultPromises =
+
-        symbolProfilesWithScraperConfigurationAndInstantMode.map(
+      const scraperResultPromises = symbolProfilesToScrape.map(
-          async ({ scraperConfiguration, symbol }) => {
+        async ({ scraperConfiguration, symbol }) => {
-            try {
+          try {
-              const marketPrice = await this.scrape({
+            const marketPrice = await this.scrape({
-                scraperConfiguration,
+              scraperConfiguration,
-                symbol
+              symbol
-              });
+            });
-              return { marketPrice, symbol };
+            return { marketPrice, symbol };
-            } catch (error) {
+          } catch (error) {
-              this.logger.error(
+            this.logger.error(
-                `Could not get quote for ${symbol} (${this.getName()}): [${error.name}] ${error.message}`
+              `Could not get quote for ${symbol} (${this.getName()}): [${error.name}] ${error.message}`
-              );
+            );
-              return { symbol, marketPrice: undefined };
+            return { symbol, marketPrice: undefined };
-            }
           }
-        );
+        }
+      );
 
       // Wait for all scraping requests to complete concurrently
       const scraperResults = await Promise.all(scraperResultPromises);