applyTransactionToBalances applies a transaction to the provided balances. It starts a tracing span, calculates new balances, and updates the balances

balanceDistributions ensures the sum of all distributions equals the total amount

Helper function for big.Int map comparisons

buildFundAllocationList builds a list of fund allocations for metadata storage. Parameters: - allocations []Allocation: The calculated allocations. -

calculateMatchingBounds calculates the query bounds (amount, date) for matching external transactions against internal ones. It iterates through match

calculateProviderBreakdown calculates the fund breakdown for a provider. Parameters: - mapping model.LineageMapping: The lineage mapping for the prov

checkBalanceMonitors checks the balance monitors for a given updated balance. It starts a tracing span, fetches the monitors, and checks each monitor'

checkTransactionCommitStatus checks if a transaction can be committed based on its remaining amount. Parameters: - amountLeft *big.Int: The remaining

combineDistributions merges fixed and percentage amounts into the result

convertDecimalToPrecise converts a decimal amount to precise integer by multiplying by precision

convertLargeNumbers converts big.Int values to strings for Typesense compatibility

createReconciler creates a reconciler function based on the specified strategy, group criteria, and matching rules. Parameters: - strategy: The reconc

createTransactionProcessor creates a new transaction processor for the reconciliation. Parameters: - reconciliation: The reconciliation object represe

dominantCurrency returns the dominant currency in a group of transactions. If there is only one currency, it returns that currency, otherwise, it retu

EnsureDefaultGeneralLedger ensures that the default general ledger exists in Typesense.

ensureSchemaFields ensures all required schema fields are present with default values

executeCLI runs the root command, handling any errors that occur during execution. It serves as the main entry point for the CLI application.

executeWithLock executes a function with distributed locks to ensure exclusive access to both source and destination balances. It resolves balance IDs

extractFundAllocation extracts fund allocation data from transaction metadata. Parameters: - metadata map[string]interface{}: The transaction metadat

fetchTransactionPrecisionFromDB is a placeholder for fetching precision from the database. In a real application, this would query your database. It r

finalizeReconciliation finalizes the reconciliation process by updating its status and recording the final match/unmatch counts. Parameters: - ctx: Th

finalizeVoidTransaction finalizes the voiding of a transaction by updating its status and generating new identifiers. It starts a tracing span, update

findMatchingInternalTransaction attempts to find an internal transaction that matches the given external transaction. It processes the transactions in

Helper to convert map of float64 to map of *big.Int with precision applied

formatPreservingTokenize tokenizes a value while preserving its format. It uses a deterministic approach to generate a token with the same format. Pa

geTask generates a task for a transaction and assigns it to a specific queue based on the balance ID. It ensures that transactions are evenly distribu

getBalanceInfo retrieves basic information about a balance

getBalanceMonitorsCached retrieves balance monitors with caching. It first checks the cache for monitors, and if not found, fetches from the database

getBalanceSchema returns the schema for the "balances" collection.

getEventFromStatus maps a transaction status to a corresponding event string. Parameters: - status string: The status of the transaction. Returns: -

getIdentitySchema returns the schema for the "identities" collection.

getLedgerSchema returns the schema for the "ledgers" collection.

getMatchingRules retrieves a list of matching rules by their IDs. Parameters: - ctx: The context for managing the request. - matchingRuleIDs: The list

getOrCreateDestinationLineageBalances retrieves or creates shadow and aggregate balances for the destination. Parameters: - ctx context.Context: The

getOrCreateLineageBalances retrieves or creates the shadow and aggregate balances for lineage tracking. Parameters: - ctx context.Context: The contex

getOriginalTransactionForRefund retrieves the original transaction to be refunded, checking both the database and the queue if necessary.

getReconciliationSchema returns the schema for the "reconciliations" collection.

getResults returns the total counts of matched and unmatched transactions processed during reconciliation. Returns: - int: The count of matched transa

getSourceAggregateBalance retrieves or creates the aggregate balance for the source identity. Parameters: - ctx context.Context: The context for the

groupExternalTransactions retrieves and groups external transactions based on the specified criteria. This is used in many-to-one reconciliation. Para

groupInternalTransactions groups internal transactions based on the specified criteria for reconciliation. Parameters are the same as `groupExternalTr

handleSmallAmount assigns entire amount to first distribution for very small amounts

handleSplitTransactions attempts to split a transaction into multiple transactions if needed. It starts a tracing span, attempts to split the transact