extractKey retrieves the authentication key from the X-LedgerForge-Key header. Parameters: - c: The Gin context containing the request headers. Retu

fetchTransactions fetches transactions in batches and sends them to the jobs channel. It starts a tracing span, iterates through the transactions, and

finalizeCommitment finalizes the commitment of a transaction by updating its status and generating new identifiers. It starts a tracing span, updates

Helper function for float64 comparisons

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

formatPreservingDetokenize detokenizes a format-preserving token. Parameters: - token string: The token to detokenize. Returns: - string: The origin

getAPIKeyCacheKey generates a cache key for an API key lookup Uses the hashed key to ensure consistent cache keys

getDefaultValue returns the default value for a given field type in Typesense.

getEntityTypeFromID determines the entity type from the ID prefix. It analyzes the prefix of the provided ID and returns the corresponding entity type

getIDField returns the primary ID field name for a given table

getLineageSources retrieves the available fund sources from shadow balances for allocation. Uses a single batch query to fetch all shadow balances ins

getResourceFromPath determines the resource type from the URL path. Parameters: - path: The URL path to analyze. Returns: - Resource: The determined

getSourceAndDestination retrieves the source and destination balances for a transaction. It checks if the source or destination starts with "@", indic

hashAPIKey creates a bcrypt hash of the API key for secure storage. bcrypt includes salt and is resistant to brute-force attacks.

Renamed from initializeObservability to better reflect its purpose

isPercentageDistribution checks if a distribution is a percentage type

listHooksForExecution returns the current hook set for the requested type, or nil when hook execution is not configured for the current LedgerForge in

manyToOneReconciliation performs a many-to-one reconciliation, where multiple internal transactions are grouped and matched against a single external

parseOTLPEndpoint extracts the host:port from an OTLP endpoint string and determines whether to use an insecure (non-TLS) connection. Handles all comm

postLedgerActions performs some actions after a ledger has been created. It sends the newly created ledger to the search index queue, which indexes th

postTransactionActions performs post-processing actions for a transaction. It starts a tracing span, queues the transaction and balance data for index

prepareTransactionForQueue prepares a transaction for queueing by setting status, metadata, and resolving source/destination balances.

processBalances processes the source and destination balances by applying the transaction in-memory. It starts a tracing span, applies the transaction

processBulkTransactions prepares and queues all transactions in a batch with the given batch ID

processGroupedTransactions handles the matching of transactions for both one-to-many and many-to-one reconciliations. It processes each transaction gr

processQueuedTransaction routes queued work through the shared executor so the planner can choose between normal queued batching, hot-lane batching, a

processReconciliation manages the full reconciliation process by executing each step: updating the status, fetching rules, processing transactions, an

processTxns handles the processing of transactions based on whether they are split or single. It delegates to the appropriate processing function base

proportionalAllocation allocates funds proportionally across all sources. Parameters: - sources []LineageSource: The available fund sources. - amount

recordTransactionInTx inserts a transaction record within an existing database transaction. This is a helper function used by RecordTransactionWithBal

recordTransactionSingle preserves the existing direct transaction-processing semantics by running the single-transaction flow under the balance lock.

recoverWithThreshold loads currently stuck queued transactions and reprocesses them serially.

rollbackBatchTransactions performs a rollback of transactions in a batch Returns the action performed (voided/refunded) and any error that occurred

runTransactionPostCommitWork executes monitor checks, post-hooks, and post-transaction actions for already-persisted work items outside the locked per

runTransactionPostCommitWorkWithHooks executes monitor checks, post-hooks, and post-transaction actions for persisted work items, optionally reusing a

safeColumnForTableAndField maps a field name to a safe column name using only string literals. Returns empty string for unknown fields to break the ta

sendBulkTransactionWebhook sends a webhook notification for a bulk transaction result

setTransactionStatus determines and sets the appropriate status for a transaction. It evaluates the transaction's scheduled time and current status to

storeExternalTransaction stores an external transaction in the datasource. Parameters: - ctx: The context for controlling execution. - uploadID: The u

tryRecordQueuedTransactionBatch builds and persists a coalesced queued batch when it is safe and useful, otherwise it returns handled=false so callers

updateTransactionDetails updates the details of a transaction, including source and destination balances and status. It starts a tracing span, creates

upsertDocument handles the final upsert operation to Typesense

validateAndUpdateAmount validates the amount to be committed for a transaction and updates the transaction's amount. It orchestrates the validation an

validateLineageProvider checks if the specified provider exists on the source balance. If the source tracks fund lineage but doesn't have the specifie

validateRule validates a matching rule, including checking its basic structure and criteria. Parameters: - rule: The rule to validate. Returns an erro

verifyAPIKey compares a plaintext key with a bcrypt hash.

voidShadowTransactions voids all inflight shadow transactions for a parent transaction. It attempts to void all shadows and returns an error if any fa

ApplyPrecisionWithDBLookup attempts to fetch precision from the database and then applies it to the transaction. Falls back to transaction-defined pre

BasicAuth generates a basic HTTP authentication string by encoding the provided username and password. The string is base64-encoded in the format "use

BuildScope creates a scope string from resource and action

Inserts outbox entry directly (for shadow work)

CommitWorker processes commit transactions from the jobs channel and sends the results to the results channel. It starts a tracing span, processes eac

CreateCollection creates a collection in Typesense based on the provided schema. If the collection already exists, it will return without error.

CreateIdentity creates a new identity in the database. Parameters: - identity model.Identity: The Identity model to be created. Returns: - model.Ide

CreateLedger creates a new ledger. It calls postLedgerActions after a successful creation. Parameters: - ledger: A Ledger model representing the ledg

CreateMonitor creates a new balance monitor. It starts a tracing span, applies precision to the monitor's condition value, and creates the monitor. It

DeleteIdentity deletes an identity by its ID. Parameters: - id string: The ID of the identity to delete. Returns: - error: An error if the identity

DeleteMonitor deletes a balance monitor by its ID. It starts a tracing span, deletes the monitor, and records relevant events and errors. Parameters:

DetokenizeIdentity detokenizes and returns all tokenized fields in an identity. Parameters: - identityID string: The ID of the identity. Returns: -

DetokenizeIdentityField detokenizes a specific field in an identity. It extracts the identity ID and field name from the route parameters, detokenizes

DropAllCollections drops all known collections from Typesense.

DropCollection deletes a collection from Typesense.

Records unmatched results for a reconciliation