Method getSourceAggregateBalance

lineage.go:533–548

getSourceAggregateBalance retrieves or creates the aggregate balance for the source identity. Parameters: - ctx context.Context: The context for the operation. - sourceBalance *model.Balance: The source balance. Returns: - *model.Balance: The aggregate balance. - error: An error if the balance cou

(ctx context.Context, sourceBalance *model.Balance)

// - *model.Balance: The aggregate balance.
// - error: An error if the balance could not be retrieved or created.
func (l *LedgerForge) getSourceAggregateBalance(ctx context.Context, sourceBalance *model.Balance) (*model.Balance, error) {
	sourceIdentity, err := l.datasource.GetIdentityByID(sourceBalance.IdentityID)
	if err != nil {
		return nil, fmt.Errorf("failed to get source identity: %w", err)
	}

	sourceIdentifier := l.getIdentityIdentifier(sourceIdentity)
	sourceAggIndicator := fmt.Sprintf("@%s_lineage", sourceIdentifier)

	sourceAggBalance, err := l.getOrCreateBalanceByIndicator(ctx, sourceAggIndicator, sourceBalance.Currency)
	if err != nil {
		return nil, fmt.Errorf("failed to get source aggregate balance: %w", err)
	}

	return sourceAggBalance, nil
}

// processAllocations processes fund allocations by queuing release and receive transactions.
//