Records a new reconciliation

GetReconciliation fetches a reconciliation record from the database based on its ID. Parameters: - ctx: Context for managing request and tracing. - id

GetSourceDestination retrieves balances for both the source and destination by their IDs. It queries the database using a stored procedure `ledgerforg

GetTransaction retrieves a transaction by its ID from the database. It logs the transaction retrieval using OpenTelemetry tracing. Parameters: - ctx:

GetTransactionByRef retrieves a transaction by its reference from the datasource. It starts a tracing span, fetches the transaction by reference, and

GetTransactionFromQueue retrieves a transaction from the queue by its ID. Parameters: - transactionID string: The ID of the transaction to retrieve.

GetTransactionsByCriteria retrieves transactions based on specified criteria (amount range, currency, date range). It supports pagination via limit an

GetTransactionsPaginated retrieves a batch of transactions from the database with pagination support and caches the result. If the data is found in ca

GroupTransactions retrieves and groups transactions from the database based on a specified column (groupCriteria). It supports pagination and caches t

HasPermission checks if a set of scopes has permission for a given resource and HTTP method

ListAPIKeys retrieves all API keys for a specific owner Parameters: - ctx: The context for the operation - ownerID: ID of the key owner Returns: - [

Revokes an API key

ListHooks retrieves all hooks of a specific type or all hooks if type is empty. If hookType is provided, it fetches hooks from that specific set. If h

MetricsHandler returns the Prometheus HTTP handler for serving the /metrics endpoint. Returns nil if SetupOTelSDK has not been called or metrics are n

NewAPI creates a new Api instance with the provided LedgerForge service and sets up the router. Parameters: - b: The LedgerForge service used to inte

NewAPIKey creates a new API key instance

NewAuthMiddleware creates a new instance of AuthMiddleware. Parameters: - ledgerforge: The LedgerForge service used to validate API keys. Returns: -

NewCacheWithClient creates a new RedisCache using an existing Redis client. No error is returned because no I/O occurs — the client is already validat

NewRedisClient creates a new Redis client connection based on the provided list of addresses. It automatically detects if the connection is for a sing

NewReindexService creates a new ReindexService instance.

ParseScope parses a scope string into resource and action

PrepareLineageOutbox creates a LineageOutbox entry for atomic insertion with the transaction. This ensures lineage processing intent is captured in th

RecordExternalTransaction inserts a new external transaction into the database. It associates the transaction with an upload ID and records its detail

RecordMatch inserts a single match into the database. It is used to record the match between external and internal transactions during reconciliation.

RecordMatches batches the saving of match records associated with a specific reconciliation ID. It uses a database transaction to ensure atomicity and

RecordMatchingRule saves a new matching rule to the database. Parameters: - ctx: Context for managing the request and tracing. - rule: A pointer to th

RecordReconciliation saves a reconciliation record to the database. Parameters: - ctx: Context for managing request and tracing. - rec: The reconcilia

RecordTransaction records a new transaction in the database. It logs the transaction details using OpenTelemetry tracing. Parameters: - ctx: Context f

RecordTransactionsWithBalanceSetAndOutboxes atomically records multiple transactions, updates all changed balances, and inserts any lineage outbox ent

RecordUnmatched batches the saving of unmatched external transactions related to a specific reconciliation. It uses a database transaction to ensure a

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

RevokeAPIKey revokes an API key if it belongs to the specified owner Parameters: - ctx: The context for the operation - id: ID of the API key to revo

RollbackInflightCredit rolls back (decreases) the inflight credit balance by the specified amount.

RollbackInflightDebit rolls back (decreases) the inflight debit balance by the specified amount.

Router sets up the routes for the API and returns the router instance. Responses: - 200 OK: When the router is successfully set up.

SaveReconciliationProgress saves the progress of a reconciliation process to the database. If a record with the given reconciliation ID already exists

SetPrimary sets the primary item to be indexed after all dependencies.

Function to integrate the new CalculateDistributionsPrecise into SplitTransaction

StartReindex performs a complete reindex of all data. It drops all collections, recreates them, and indexes data in order: ledgers -> identities -> ba

StartTestAsynqWorker sets up and starts an Asynq server for testing purposes. It takes the testing object, configuration, LedgerForge instance, and th

Stop shuts down the background recovery loop and waits for the worker goroutine to exit.

Retrieves balances between source and destination

TakeBalanceSnapshots creates daily snapshots of balances in batches. It uses the PostgreSQL function to process balances in chunks to avoid memory iss

Retrieves a transaction by reference

TransactionExistsByRef checks if a transaction with a given reference exists in the database. It uses OpenTelemetry to trace the operation and returns

UpdateAccount updates a specific account in the database. It updates the account's name, number, bank name, and metadata based on the account ID. Para

Retrieves a balance at a specific time

UpdateIdentity updates an existing identity in the database. Parameters: - identity *model.Identity: A pointer to the Identity model to be updated.

Retrieves identities with pagination (legacy)

UpdateLastUsed updates the last used timestamp of an API key Parameters: - ctx: The context for the operation - id: ID of the API key to update Retu

Lists all API keys for a specific owner

UpdateLastUsed updates the last_used_at timestamp for an API key to the current time. This function is typically called during authentication to track

UpdateLedger updates an existing ledger's name. It calls postLedgerActions after a successful update to handle indexing and webhooks. Parameters: - i

Retrieves a ledger by ID

Retrieves a matching rule by ID

UpdateMatchingRule updates a specific matching rule in the database. Parameters: - ctx: Context for managing the request and tracing. - rule: The matc

Retrieves monitors for a specific balance

UpdateMonitor updates an existing balance monitor in the database. It updates fields such as `balance_id`, `field`, `operator`, `value`, `description`

UpdateTransactionStatus updates the status of a transaction by its ID in the datasource. It starts a tracing span, updates the transaction status, and

VoidWorker processes void transactions from the jobs channel and sends the results to the results channel. It starts a tracing span, processes each tr

WaitLock tries to acquire all locks within a specified waiting period. It will attempt to acquire locks with exponential backoff if any lock is held.

acquireLineageLocks acquires distributed locks for multiple shadow balances using MultiLocker. MultiLocker handles sorting (prevents deadlock) and ded

addCredit adds the specified amount to the credit balances (either inflight or regular). inflight indicates whether the credit is inflight or not.

addDebit adds the specified amount to the debit balances (either inflight or regular). inflight indicates whether the debit is inflight or not.

applyPrecisionLogic contains the core logic for converting amounts based on precision. It assumes transaction.Precision has been set appropriately bef

buildGroupMap creates a map for tracking unprocessed transaction groups. Parameters: - groupedTxns: The grouped transactions. Returns: - map[string]bo

buildTransactionExecutionWork converts an in-memory-applied transaction into the shared persistence and post-commit work shape used by both single and

calculateRemainingAmount calculates the remaining amount for an inflight transaction by subtracting the committed amount from the precise amount. It s

categorizeRejectionReason maps a free-text rejection reason to a bounded set of metric labels to keep Prometheus cardinality under control.

commitShadowTransactions commits all inflight shadow transactions for a parent transaction. It attempts to commit all shadows and returns an error if

convertPreciseToDecimal converts the precise integer amount to a decimal value by dividing by precision, storing the exact string representation

enqueueTransactions enqueues the original transaction or its split transactions into the provided queue. It starts by determining which transactions t

executeHook performs the actual HTTP request for the webhook. It handles marshalling the payload, creating the request, and processing the response. R

executeTransactionPlan runs the selected internal execution mode and fails open from queued batching back to the single-transaction path when batching