mirror of
https://github.com/maybe-finance/maybe.git
synced 2025-07-23 15:19:38 +02:00
7ae25dd6df
* Implement Synth as an exchange rate provider * Add assertions to provider interface test * Assert the correct provider error is raised * Remove unnecessary parens
71 lines
2.8 KiB
Ruby
71 lines
2.8 KiB
Ruby
module Account::Syncable
|
|
extend ActiveSupport::Concern
|
|
|
|
def sync_later
|
|
AccountSyncJob.perform_later self
|
|
end
|
|
|
|
def sync
|
|
update!(status: "syncing")
|
|
|
|
sync_exchange_rates
|
|
|
|
calculator = Account::Balance::Calculator.new(self)
|
|
calculator.calculate
|
|
self.balances.upsert_all(calculator.daily_balances, unique_by: :index_account_balances_on_account_id_date_currency_unique)
|
|
self.balances.where("date < ?", effective_start_date).delete_all
|
|
update!(status: "ok")
|
|
rescue => e
|
|
update!(status: "error")
|
|
Rails.logger.error("Failed to sync account #{id}: #{e.message}")
|
|
end
|
|
|
|
# The earliest date we can calculate a balance for
|
|
def effective_start_date
|
|
first_valuation_date = self.valuations.order(:date).pluck(:date).first
|
|
first_transaction_date = self.transactions.order(:date).pluck(:date).first
|
|
|
|
[ first_valuation_date, first_transaction_date&.prev_day ].compact.min || Date.current
|
|
end
|
|
|
|
# Finds all the rate pairs that are required to calculate balances for an account and syncs them
|
|
def sync_exchange_rates
|
|
rate_candidates = []
|
|
|
|
if multi_currency?
|
|
transactions_in_foreign_currency = self.transactions.where.not(currency: self.currency).pluck(:currency, :date).uniq
|
|
transactions_in_foreign_currency.each do |currency, date|
|
|
rate_candidates << { date: date, from_currency: currency, to_currency: self.currency }
|
|
end
|
|
end
|
|
|
|
if foreign_currency?
|
|
(effective_start_date..Date.current).each do |date|
|
|
rate_candidates << { date: date, from_currency: self.currency, to_currency: self.family.currency }
|
|
end
|
|
end
|
|
|
|
existing_rates = ExchangeRate.where(
|
|
base_currency: rate_candidates.map { |rc| rc[:from_currency] },
|
|
converted_currency: rate_candidates.map { |rc| rc[:to_currency] },
|
|
date: rate_candidates.map { |rc| rc[:date] }
|
|
).pluck(:base_currency, :converted_currency, :date)
|
|
|
|
# Convert to a set for faster lookup
|
|
existing_rates_set = existing_rates.map { |er| [ er[0], er[1], er[2].to_s ] }.to_set
|
|
|
|
rate_candidates.each do |rate_candidate|
|
|
rc_from = rate_candidate[:from_currency]
|
|
rc_to = rate_candidate[:to_currency]
|
|
rc_date = rate_candidate[:date]
|
|
|
|
next if existing_rates_set.include?([ rc_from, rc_to, rc_date.to_s ])
|
|
|
|
logger.info "Fetching exchange rate from provider for account #{self.name}: #{self.id} (#{rc_from} to #{rc_to} on #{rc_date})"
|
|
rate = ExchangeRate.find_rate_or_fetch from: rc_from, to: rc_to, date: rc_date
|
|
ExchangeRate.create! base_currency: rc_from, converted_currency: rc_to, date: rc_date, rate: rate if rate
|
|
end
|
|
|
|
nil
|
|
end
|
|
end
|