|
|
|
@ -1,7 +1,6 @@ |
|
|
|
import { Activity } from '@ghostfolio/api/app/order/interfaces/activities.interface'; |
|
|
|
import { CurrentRateService } from '@ghostfolio/api/app/portfolio/current-rate.service'; |
|
|
|
import { PortfolioOrder } from '@ghostfolio/api/app/portfolio/interfaces/portfolio-order.interface'; |
|
|
|
import { PortfolioSnapshot } from '@ghostfolio/api/app/portfolio/interfaces/portfolio-snapshot.interface'; |
|
|
|
import { TransactionPointSymbol } from '@ghostfolio/api/app/portfolio/interfaces/transaction-point-symbol.interface'; |
|
|
|
import { TransactionPoint } from '@ghostfolio/api/app/portfolio/interfaces/transaction-point.interface'; |
|
|
|
import { RedisCacheService } from '@ghostfolio/api/app/redis-cache/redis-cache.service'; |
|
|
|
@ -9,6 +8,7 @@ import { |
|
|
|
getFactor, |
|
|
|
getInterval |
|
|
|
} from '@ghostfolio/api/helper/portfolio.helper'; |
|
|
|
import { ConfigurationService } from '@ghostfolio/api/services/configuration/configuration.service'; |
|
|
|
import { ExchangeRateDataService } from '@ghostfolio/api/services/exchange-rate-data/exchange-rate-data.service'; |
|
|
|
import { IDataGatheringItem } from '@ghostfolio/api/services/interfaces/interfaces'; |
|
|
|
import { MAX_CHART_ITEMS } from '@ghostfolio/common/config'; |
|
|
|
@ -26,10 +26,11 @@ import { |
|
|
|
SymbolMetrics, |
|
|
|
UniqueAsset |
|
|
|
} from '@ghostfolio/common/interfaces'; |
|
|
|
import { TimelinePosition } from '@ghostfolio/common/models'; |
|
|
|
import { PortfolioSnapshot, TimelinePosition } from '@ghostfolio/common/models'; |
|
|
|
import { DateRange, GroupBy } from '@ghostfolio/common/types'; |
|
|
|
|
|
|
|
import { Big } from 'big.js'; |
|
|
|
import { plainToClass } from 'class-transformer'; |
|
|
|
import { |
|
|
|
differenceInDays, |
|
|
|
eachDayOfInterval, |
|
|
|
@ -42,6 +43,7 @@ import { |
|
|
|
subDays |
|
|
|
} from 'date-fns'; |
|
|
|
import { first, last, uniq, uniqBy } from 'lodash'; |
|
|
|
import ms from 'ms'; |
|
|
|
|
|
|
|
export abstract class PortfolioCalculator { |
|
|
|
protected static readonly ENABLE_LOGGING = false; |
|
|
|
@ -49,53 +51,74 @@ export abstract class PortfolioCalculator { |
|
|
|
protected accountBalanceItems: HistoricalDataItem[]; |
|
|
|
protected orders: PortfolioOrder[]; |
|
|
|
|
|
|
|
private configurationService: ConfigurationService; |
|
|
|
private currency: string; |
|
|
|
private currentRateService: CurrentRateService; |
|
|
|
private dataProviderInfos: DataProviderInfo[]; |
|
|
|
private endDate: Date; |
|
|
|
private exchangeRateDataService: ExchangeRateDataService; |
|
|
|
private redisCacheService: RedisCacheService; |
|
|
|
private snapshot: PortfolioSnapshot; |
|
|
|
private snapshotPromise: Promise<void>; |
|
|
|
private startDate: Date; |
|
|
|
private transactionPoints: TransactionPoint[]; |
|
|
|
private userId: string; |
|
|
|
|
|
|
|
public constructor({ |
|
|
|
accountBalanceItems, |
|
|
|
activities, |
|
|
|
configurationService, |
|
|
|
currency, |
|
|
|
currentRateService, |
|
|
|
dateRange, |
|
|
|
exchangeRateDataService |
|
|
|
exchangeRateDataService, |
|
|
|
redisCacheService, |
|
|
|
userId |
|
|
|
}: { |
|
|
|
accountBalanceItems: HistoricalDataItem[]; |
|
|
|
activities: Activity[]; |
|
|
|
configurationService: ConfigurationService; |
|
|
|
currency: string; |
|
|
|
currentRateService: CurrentRateService; |
|
|
|
dateRange: DateRange; |
|
|
|
exchangeRateDataService: ExchangeRateDataService; |
|
|
|
redisCacheService: RedisCacheService; |
|
|
|
userId: string; |
|
|
|
}) { |
|
|
|
this.accountBalanceItems = accountBalanceItems; |
|
|
|
this.configurationService = configurationService; |
|
|
|
this.currency = currency; |
|
|
|
this.currentRateService = currentRateService; |
|
|
|
this.exchangeRateDataService = exchangeRateDataService; |
|
|
|
this.orders = activities.map( |
|
|
|
({ date, fee, quantity, SymbolProfile, tags = [], type, unitPrice }) => { |
|
|
|
return { |
|
|
|
|
|
|
|
this.orders = activities |
|
|
|
.map( |
|
|
|
({ |
|
|
|
date, |
|
|
|
fee, |
|
|
|
quantity, |
|
|
|
SymbolProfile, |
|
|
|
tags, |
|
|
|
tags = [], |
|
|
|
type, |
|
|
|
date: format(date, DATE_FORMAT), |
|
|
|
fee: new Big(fee), |
|
|
|
quantity: new Big(quantity), |
|
|
|
unitPrice: new Big(unitPrice) |
|
|
|
}; |
|
|
|
} |
|
|
|
); |
|
|
|
unitPrice |
|
|
|
}) => { |
|
|
|
return { |
|
|
|
SymbolProfile, |
|
|
|
tags, |
|
|
|
type, |
|
|
|
date: format(date, DATE_FORMAT), |
|
|
|
fee: new Big(fee), |
|
|
|
quantity: new Big(quantity), |
|
|
|
unitPrice: new Big(unitPrice) |
|
|
|
}; |
|
|
|
} |
|
|
|
) |
|
|
|
.sort((a, b) => { |
|
|
|
return a.date?.localeCompare(b.date); |
|
|
|
}); |
|
|
|
|
|
|
|
this.orders.sort((a, b) => { |
|
|
|
return a.date?.localeCompare(b.date); |
|
|
|
}); |
|
|
|
this.redisCacheService = redisCacheService; |
|
|
|
this.userId = userId; |
|
|
|
|
|
|
|
const { endDate, startDate } = getInterval(dateRange); |
|
|
|
|
|
|
|
@ -1013,6 +1036,23 @@ export abstract class PortfolioCalculator { |
|
|
|
} |
|
|
|
|
|
|
|
private async initialize() { |
|
|
|
this.snapshot = await this.computeSnapshot(this.startDate, this.endDate); |
|
|
|
const cachedSnapshot = await this.redisCacheService.get( |
|
|
|
this.redisCacheService.getPortfolioSnapshotKey(this.userId) |
|
|
|
); |
|
|
|
|
|
|
|
if (cachedSnapshot) { |
|
|
|
this.snapshot = plainToClass( |
|
|
|
PortfolioSnapshot, |
|
|
|
JSON.parse(cachedSnapshot) |
|
|
|
); |
|
|
|
} else { |
|
|
|
this.snapshot = await this.computeSnapshot(this.startDate, this.endDate); |
|
|
|
|
|
|
|
this.redisCacheService.set( |
|
|
|
this.redisCacheService.getPortfolioSnapshotKey(this.userId), |
|
|
|
JSON.stringify(this.snapshot), |
|
|
|
this.configurationService.get('CACHE_QUOTES_TTL') |
|
|
|
); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
Thomas Kaul
1 year ago