Function updateBalanceSet

database/balance.go:915–949

(ctx context.Context, tx *sql.Tx, balances []*model.Balance)

}

func updateBalanceSet(ctx context.Context, tx *sql.Tx, balances []*model.Balance) error {
	seen := make(map[string]struct{}, len(balances))
	uniqueBalances := make([]*model.Balance, 0, len(balances))
	for _, balance := range balances {
		if balance == nil || balance.BalanceID == "" {
			continue
		}
		if _, ok := seen[balance.BalanceID]; ok {
			continue
		}
		seen[balance.BalanceID] = struct{}{}
		uniqueBalances = append(uniqueBalances, balance)
	}

	if len(uniqueBalances) == 0 {
		return nil
	}

	for start := 0; start < len(uniqueBalances); start += maxBalancesPerUpdateChunk {
		end := start + maxBalancesPerUpdateChunk
		if end > len(uniqueBalances) {
			end = len(uniqueBalances)
		}

		if err := updateBalanceChunk(ctx, tx, uniqueBalances[start:end]); err != nil {
			return err
		}
	}

	for _, balance := range uniqueBalances {
		balance.Version++
	}

	return nil
}

func updateBalanceChunk(ctx context.Context, tx *sql.Tx, balances []*model.Balance) error {
	if len(balances) == 0 {