diff --git a/apps/api/src/app/endpoints/data-providers/ghostfolio/ghostfolio.service.ts b/apps/api/src/app/endpoints/data-providers/ghostfolio/ghostfolio.service.ts index d981ec1b5..b3a49638a 100644 --- a/apps/api/src/app/endpoints/data-providers/ghostfolio/ghostfolio.service.ts +++ b/apps/api/src/app/endpoints/data-providers/ghostfolio/ghostfolio.service.ts @@ -57,33 +57,34 @@ export class GhostfolioService { symbol }) .then(async (assetProfile) => { + const dataSourceOrigin = DataSource.GHOSTFOLIO; + if (assetProfile) { - await this.prismaService.dataProviderGhostfolioResolvedAssetProfile.upsert( - { - create: { - symbol, - currency: assetProfile.currency, - dataSource: assetProfile.dataSource - }, - update: { - requestCount: { - increment: 1 - } - }, - where: { - dataSource_symbol: { - symbol, - dataSource: assetProfile.dataSource - } + await this.prismaService.resolvedAssetProfile.upsert({ + create: { + dataSourceOrigin, + symbol, + currency: assetProfile.currency, + dataSourceTarget: assetProfile.dataSource + }, + update: { + requestCount: { + increment: 1 + } + }, + where: { + dataSourceOrigin_symbol: { + dataSourceOrigin, + symbol } } - ); + }); } result = { ...result, ...assetProfile, - dataSource: DataSource.GHOSTFOLIO + dataSource: dataSourceOrigin }; return assetProfile;