initializeHTTPClient creates and configures the HTTP client for webhook requests

initializeReconciliationProgress initializes or retrieves the progress of a reconciliation. If no progress exists, it creates a new progress entry. Pa

initializeRedisClients sets up both the Redis client and Asynq client

initializeTokenizationService creates and configures the tokenization service

Helper function

loadReconciliationProgress retrieves the progress of a reconciliation process. Parameters: - ctx: The context controlling the request. - reconciliatio

manyToOne handles the core logic of many-to-one reconciliation. It groups external transactions and processes them in batches, comparing them to inter

matchSingleTransaction attempts to match a single transaction with a group of transactions based on matching rules. If a match is found, it sends the

matchesCurrency compares currency values, handling special cases like "MIXED" for group transactions. Parameters: - externalValue: The currency value

matchesGroup compares a group of internal transactions with a single external transaction using matching rules. If a match is found, it returns true;

matchesGroupAmount compares the amount of a single external transaction with the total amount of a grouped set of internal transactions. Parameters: -

matchesGroupDate compares the date of a single external transaction with the earliest date in a group of internal transactions. Parameters: - external

migrateCommands creates the root command for migration-related operations.

migrateDownCommands creates the command for rolling back migrations.

* migrateTypeSenseSchema ensures that the necessary TypeSense schema is migrated for all required collections. It takes a TypesenseClient and a contex

migrateUpCommands creates the command for applying migrations.

newRedisCache sets up a Redis-backed cache with local caching (TinyLFU). Parameters: - addresses: The Redis server addresses to connect to. Returns a

newResource creates a shared OTel resource with the service name.

oneToMany performs the core logic for one-to-many reconciliation. Parameters are similar to `manyToOne`, but it processes transactions in reverse (one

overrideLedgerAndIdentity overrides the ledger and identity details of the given account based on the balance information. It fetches the balance by i

parseFixedAmount parses a fixed amount from a distribution

partialMatch compares two strings and checks if they match within a certain allowable drift, using Levenshtein distance. Parameters: - str1, str2: The

persistQueuedTransactionBatch acquires the balance-set lock, prepares the batch in memory, commits the final state atomically, and dispatches post-com

persistQueuedTransactionBatchLocked prepares every transaction against the shared in-memory balance set and persists the final balance and transaction

persistSingleTransactionExecutionWork atomically persists one prepared transaction, its updated balances, and any lineage outbox using the shared exec

pollForAggregateDebitBalance polls until the aggregate balance's DebitBalance reaches the expected value

pollForShadowCreditBalance polls until the shadow balance's CreditBalance reaches the expected value

populateLineageProviders populates the provider breakdown in a balance lineage. Parameters: - lineage *BalanceLineage: The lineage to populate. - map

postBalanceActions performs some actions after a balance has been created. It starts a tracing span, sends the balance to the search index queue, and

postIdentityActions performs actions after an identity has been created. It sends the newly created identity to the search index queue and sends a web

postReconciliationActions queues the indexing of reconciliation data in the background. This allows the reconciliation to be indexed without blocking

preRun sets up the configuration and initializes the LedgerForge instance before running any command. It ensures that the configuration is loaded, and

prepareAccountQueries constructs an SQL query for retrieving accounts, including optional related entities such as balance, identity, and ledger if sp

prepareDestinationLineageBalances pre-creates destination shadow and aggregate balances for all providers. This is called BEFORE acquiring locks to av

Prepares a dynamic SQL query based on the fields to be included. This query fetches balance details, including optional joins for identity and ledger.

prepareQueuedBatchTransaction performs the per-transaction work inside a coalesced batch: hooks, reference validation, in-memory balance application,

prepareRefundTransaction creates and configures a new transaction object for the refund.

process handles individual transaction processing, applying the reconciliation logic and recording results. It also updates internal transaction metad

processAllocations processes fund allocations by queuing release and receive transactions. Parameters: - ctx context.Context: The context for the ope

processBatch performs one periodic stuck-queue recovery pass using the configured threshold.

processBatch claims and processes a batch of pending outbox entries.

Parallel CSV processing with worker pool

processDestinationLineage processes lineage tracking for the destination balance when it also tracks fund lineage. Uses pre-created destination balanc

processEntry processes a single outbox entry.

processFixedDistributions handles the first pass: fixed amount distributions

processLeftDistribution handles the "left" distribution type

processLineage handles fund lineage tracking for a transaction. It processes both credit (incoming funds with provider tracking) and debit (fund alloc

processLineageCredit processes a credit transaction for fund lineage tracking. It creates shadow balances and queues a shadow transaction to track the