2025-06-10 18:20:06 -04:00
|
|
|
class BalanceSheet::SyncStatusMonitor
|
|
|
|
def initialize(family)
|
|
|
|
@family = family
|
|
|
|
end
|
|
|
|
|
|
|
|
def syncing?
|
|
|
|
syncing_account_ids.any?
|
|
|
|
end
|
|
|
|
|
|
|
|
def account_syncing?(account)
|
|
|
|
syncing_account_ids.include?(account.id)
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
attr_reader :family
|
|
|
|
|
|
|
|
def syncing_account_ids
|
|
|
|
Rails.cache.fetch(cache_key) do
|
|
|
|
Sync.visible
|
2025-07-03 09:33:07 -04:00
|
|
|
.where(syncable_type: "Account", syncable_id: family.accounts.visible.pluck(:id))
|
2025-06-10 18:20:06 -04:00
|
|
|
.pluck(:syncable_id)
|
|
|
|
.to_set
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
# We re-fetch the set of syncing IDs any time a sync that belongs to the family is started or completed.
|
|
|
|
# This ensures we're always fetching the latest sync statuses without re-querying on every page load in idle times (no syncs happening).
|
|
|
|
def cache_key
|
|
|
|
[
|
|
|
|
"balance_sheet_sync_status",
|
|
|
|
family.id,
|
|
|
|
family.latest_sync_activity_at
|
|
|
|
].join("_")
|
|
|
|
end
|
|
|
|
end
|