Method loadBalancesForQueuedBatch

transaction.go:1454–1485

(ctx context.Context, balanceIDs []string)

}

func (l *LedgerForge) loadBalancesForQueuedBatch(ctx context.Context, balanceIDs []string) (map[string]*model.Balance, []*model.Balance, error) {
	balancesByID := make(map[string]*model.Balance, len(balanceIDs))

	if l.Config().Transaction.EnableQueuedChecks {
		for _, balanceID := range balanceIDs {
			balance, err := l.datasource.GetBalanceByID(balanceID, nil, true)
			if err != nil {
				return nil, nil, err
			}
			balancesByID[balanceID] = balance
		}
	} else {
		loaded, err := l.datasource.GetBalancesByIDsLite(ctx, balanceIDs)
		if err != nil {
			return nil, nil, err
		}
		for balanceID, balance := range loaded {
			balancesByID[balanceID] = balance
		}
	}

	orderedBalances := make([]*model.Balance, 0, len(balanceIDs))
	for _, balanceID := range balanceIDs {
		balance, ok := balancesByID[balanceID]
		if !ok || balance == nil {
			return nil, nil, fmt.Errorf("failed to load balance %s for coalesced batch", balanceID)
		}
		orderedBalances = append(orderedBalances, balance)
	}

	return balancesByID, orderedBalances, nil
}

func coalescingBalancesForTransaction(balancesByID map[string]*model.Balance, txn *model.Transaction) (*model.Balance, *model.Balance, error) {
	sourceBalance, ok := balancesByID[txn.Source]