apply feedback

apps/api/src/app/import/import.service.ts

@@ -609,15 +609,16 @@ export class ImportService {
         priority: DATA_GATHERING_QUEUE_PRIORITY_HIGH
       });
 
-      uniqueActivities.forEach(({ SymbolProfile }) => {
+      for (const { SymbolProfile } of uniqueActivities) {
         this.eventEmitter.emit(
           AssetProfileChangedEvent.getName(),
-          new AssetProfileChangedEvent(
-            SymbolProfile.currency,
-            SymbolProfile.symbol
-          )
+          new AssetProfileChangedEvent({
+            currency: SymbolProfile.currency,
+            dataSource: SymbolProfile.dataSource,
+            symbol: SymbolProfile.symbol
+          })
         );
-      });
+      }
     }
 
     return activities;

apps/api/src/app/order/order.service.ts

@@ -227,18 +227,19 @@ export class OrderService {
     }
 
     this.eventEmitter.emit(
-      PortfolioChangedEvent.getName(),
-      new PortfolioChangedEvent({
-        userId: order.userId
+      AssetProfileChangedEvent.getName(),
+      new AssetProfileChangedEvent({
+        currency: order.SymbolProfile.currency,
+        dataSource: order.SymbolProfile.dataSource,
+        symbol: order.SymbolProfile.symbol
       })
     );
 
     this.eventEmitter.emit(
-      AssetProfileChangedEvent.getName(),
-      new AssetProfileChangedEvent(
-        order.SymbolProfile.currency,
-        order.SymbolProfile.symbol
-      )
+      PortfolioChangedEvent.getName(),
+      new PortfolioChangedEvent({
+        userId: order.userId
+      })
     );
 
     return order;

apps/api/src/events/asset-profile-changed.event.ts

@@ -1,12 +1,11 @@
-export class AssetProfileChangedEvent {
-  private static readonly eventName = 'asset-profile.changed';
+import { AssetProfileIdentifier } from '@ghostfolio/common/interfaces';
 
+export class AssetProfileChangedEvent {
   public constructor(
-    public readonly currency: string,
-    public readonly symbol: string
+    public readonly data: AssetProfileIdentifier & { currency: string }
   ) {}
 
   public static getName(): string {
-    return AssetProfileChangedEvent.eventName;
+    return 'assetProfile.changed';
   }
 }

apps/api/src/events/asset-profile-changed.listener.ts

@@ -1,7 +1,7 @@
+import { OrderService } from '@ghostfolio/api/app/order/order.service';
 import { ConfigurationService } from '@ghostfolio/api/services/configuration/configuration.service';
 import { DataProviderService } from '@ghostfolio/api/services/data-provider/data-provider.service';
 import { ExchangeRateDataService } from '@ghostfolio/api/services/exchange-rate-data/exchange-rate-data.service';
-import { PrismaService } from '@ghostfolio/api/services/prisma/prisma.service';
 import { DataGatheringService } from '@ghostfolio/api/services/queues/data-gathering/data-gathering.service';
 import { DEFAULT_CURRENCY } from '@ghostfolio/common/config';
 
@@ -17,7 +17,7 @@ export class AssetProfileChangedListener {
     private readonly dataGatheringService: DataGatheringService,
     private readonly dataProviderService: DataProviderService,
     private readonly exchangeRateDataService: ExchangeRateDataService,
-    private readonly prismaService: PrismaService
+    private readonly orderService: OrderService
   ) {}
 
   @OnEvent(AssetProfileChangedEvent.getName())
@@ -30,62 +30,44 @@ export class AssetProfileChangedListener {
       return;
     }
 
-    if (event.currency === DEFAULT_CURRENCY) {
+    if (event.data.currency === DEFAULT_CURRENCY) {
       return;
     }
 
     Logger.log(
-      `Asset profile changed: ${event.symbol} (${event.currency}). Checking if exchange rate gathering is needed.`,
+      `Asset profile changed: ${event.data.symbol} (${event.data.currency})`,
       'AssetProfileChangedListener'
     );
 
     const existingCurrencies = this.exchangeRateDataService.getCurrencies();
-    const currencyAlreadyExists = existingCurrencies.includes(event.currency);
+    const currencyAlreadyExists = existingCurrencies.includes(
+      event.data.currency
+    );
 
     if (currencyAlreadyExists) {
       return;
     }
 
     Logger.log(
-      `New currency detected: ${event.currency}. Initializing exchange rate data service.`,
+      `New currency detected: ${event.data.currency}`,
       'AssetProfileChangedListener'
     );
 
     await this.exchangeRateDataService.initialize();
 
-    if (
-      !this.exchangeRateDataService.hasCurrencyPair(
-        DEFAULT_CURRENCY,
-        event.currency
-      )
-    ) {
-      Logger.warn(
-        `Currency pair ${DEFAULT_CURRENCY}${event.currency} was not added after initialization.`,
-        'AssetProfileChangedListener'
-      );
-      return;
-    }
-
-    const firstOrderWithCurrency = await this.prismaService.order.findFirst({
-      orderBy: [{ date: 'asc' }],
-      select: { date: true },
-      where: {
-        SymbolProfile: {
-          currency: event.currency
-        }
-      }
-    });
+    const { dateOfFirstActivity } =
+      await this.orderService.getStatisticsByCurrency(event.data.currency);
 
-    const startDate = firstOrderWithCurrency.date ?? new Date();
+    const startDate = dateOfFirstActivity ?? new Date();
 
     Logger.log(
-      `Triggering exchange rate data gathering for ${DEFAULT_CURRENCY}${event.currency} from ${startDate.toISOString()}.`,
+      `Triggering exchange rate data gathering for ${DEFAULT_CURRENCY}${event.data.currency} from ${startDate.toISOString()}.`,
       'AssetProfileChangedListener'
     );
 
     await this.dataGatheringService.gatherSymbol({
       dataSource: this.dataProviderService.getDataSourceForExchangeRates(),
-      symbol: `${DEFAULT_CURRENCY}${event.currency}`,
+      symbol: `${DEFAULT_CURRENCY}${event.data.currency}`,
       date: startDate
     });
   }

apps/api/src/events/events.module.ts

@@ -1,8 +1,8 @@
+import { OrderModule } from '@ghostfolio/api/app/order/order.module';
 import { RedisCacheModule } from '@ghostfolio/api/app/redis-cache/redis-cache.module';
 import { ConfigurationModule } from '@ghostfolio/api/services/configuration/configuration.module';
 import { DataProviderModule } from '@ghostfolio/api/services/data-provider/data-provider.module';
 import { ExchangeRateDataModule } from '@ghostfolio/api/services/exchange-rate-data/exchange-rate-data.module';
-import { PrismaModule } from '@ghostfolio/api/services/prisma/prisma.module';
 import { DataGatheringModule } from '@ghostfolio/api/services/queues/data-gathering/data-gathering.module';
 
 import { Module } from '@nestjs/common';
@@ -16,7 +16,7 @@ import { PortfolioChangedListener } from './portfolio-changed.listener';
     DataGatheringModule,
     DataProviderModule,
     ExchangeRateDataModule,
-    PrismaModule,
+    OrderModule,
     RedisCacheModule
   ],
   providers: [AssetProfileChangedListener, PortfolioChangedListener]