mirror of
https://github.com/maybe-finance/maybe.git
synced 2025-08-07 06:25:19 +02:00
da2045dbd8
* Initial schema iteration * Add new balance components * Add existing data migrator to backfill components * Update calculator test assertions for new balance components * Update flow assertions for forward calculator * Update reverse calculator flows assumptions * Forward calculator tests passing * Get all calculator tests passing * Assert flows factor
82 lines
3.6 KiB
Ruby
82 lines
3.6 KiB
Ruby
class Balance::ReverseCalculator < Balance::BaseCalculator
|
|
def calculate
|
|
Rails.logger.tagged("Balance::ReverseCalculator") do
|
|
# Since it's a reverse sync, we're starting with the "end of day" balance components and
|
|
# calculating backwards to derive the "start of day" balance components.
|
|
end_cash_balance = derive_cash_balance_on_date_from_total(
|
|
total_balance: account.current_anchor_balance,
|
|
date: account.current_anchor_date
|
|
)
|
|
end_non_cash_balance = account.current_anchor_balance - end_cash_balance
|
|
|
|
# Calculates in reverse-chronological order (End of day -> Start of day)
|
|
account.current_anchor_date.downto(account.opening_anchor_date).map do |date|
|
|
flows = flows_for_date(date)
|
|
|
|
if use_opening_anchor_for_date?(date)
|
|
end_cash_balance = derive_cash_balance_on_date_from_total(
|
|
total_balance: account.opening_anchor_balance,
|
|
date: date
|
|
)
|
|
end_non_cash_balance = account.opening_anchor_balance - end_cash_balance
|
|
|
|
start_cash_balance = end_cash_balance
|
|
start_non_cash_balance = end_non_cash_balance
|
|
market_value_change = 0
|
|
else
|
|
start_cash_balance = derive_start_cash_balance(end_cash_balance: end_cash_balance, date: date)
|
|
start_non_cash_balance = derive_start_non_cash_balance(end_non_cash_balance: end_non_cash_balance, date: date)
|
|
market_value_change = market_value_change_on_date(date, flows)
|
|
end
|
|
|
|
output_balance = build_balance(
|
|
date: date,
|
|
balance: end_cash_balance + end_non_cash_balance,
|
|
cash_balance: end_cash_balance,
|
|
start_cash_balance: start_cash_balance,
|
|
start_non_cash_balance: start_non_cash_balance,
|
|
cash_inflows: flows[:cash_inflows],
|
|
cash_outflows: flows[:cash_outflows],
|
|
non_cash_inflows: flows[:non_cash_inflows],
|
|
non_cash_outflows: flows[:non_cash_outflows],
|
|
net_market_flows: market_value_change
|
|
)
|
|
|
|
end_cash_balance = start_cash_balance
|
|
end_non_cash_balance = start_non_cash_balance
|
|
|
|
output_balance
|
|
end
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
# Negative entries amount on an "asset" account means, "account value has increased"
|
|
# Negative entries amount on a "liability" account means, "account debt has decreased"
|
|
# Positive entries amount on an "asset" account means, "account value has decreased"
|
|
# Positive entries amount on a "liability" account means, "account debt has increased"
|
|
def signed_entry_flows(entries)
|
|
entry_flows = entries.sum(&:amount)
|
|
account.asset? ? entry_flows : -entry_flows
|
|
end
|
|
|
|
# Alias method, for algorithmic clarity
|
|
# Derives cash balance, starting from the end-of-day, applying entries in reverse to get the start-of-day balance
|
|
def derive_start_cash_balance(end_cash_balance:, date:)
|
|
derive_cash_balance(end_cash_balance, date)
|
|
end
|
|
|
|
# Alias method, for algorithmic clarity
|
|
# Derives non-cash balance, starting from the end-of-day, applying entries in reverse to get the start-of-day balance
|
|
def derive_start_non_cash_balance(end_non_cash_balance:, date:)
|
|
derive_non_cash_balance(end_non_cash_balance, date, direction: :reverse)
|
|
end
|
|
|
|
# Reverse syncs are a bit different than forward syncs because we do not allow "reconciliation" valuations
|
|
# to be used at all. This is primarily to keep the code and the UI easy to understand. For a more detailed
|
|
# explanation, see the test suite.
|
|
def use_opening_anchor_for_date?(date)
|
|
account.has_opening_anchor? && date == account.opening_anchor_date
|
|
end
|
|
end
|