CheckCondition checks if a balance meets the condition specified by a BalanceMonitor. It compares various balance fields (e.g., debit balance, credit

Client returns the Redis universal client. It can be used directly for Redis operations like Get, Set, or Publish. Returns: - redis.UniversalClient:

GetDBConnection ensures a single database connection instance.

HandleNotification processes incoming notifications and updates Typesense collections based on the table and data. It ensures the required fields exis

NewIndexBatch creates a new IndexBatch with the given ID.

contains checks whether a slice contains a specific string. Parameters: - slice: The slice to check. - item: The item to look for in the slice. Return

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

GetBalanceLineage retrieves the fund lineage for a balance. It returns a breakdown of funds by provider, showing how much was received and spent from

HasFilters checks if the request contains any filter parameters. It returns true if filters were provided, false otherwise.

HashTxn generates a SHA-256 hash of a transaction's relevant fields. This ensures the integrity of the transaction by creating a unique hash from its

NewQueuedTransactionRecoveryProcessor creates the stuck queued-transaction recovery loop with conservative single-worker defaults to avoid recovery-in

RefundTransaction processes a refund for a given transaction by its ID. It starts a tracing span, retrieves the original transaction, validates its st

RegisterWebhookSender registers a function to handle webhook sending.

RejectTransaction rejects a transaction by updating its status and recording the rejection reason. It starts a tracing span, updates the transaction s

Tokenize converts a PII value to a token using the default standard mode. Parameters: - value string: The original PII value to be tokenized. Return

UpdateBalances updates the balances for both the source and destination based on the transaction details. It ensures precision is applied and checks f

createTestBalance creates a test balance with the given ID and amount

injectAPIKeyToMetadata modifies the request body to include the API key ID in the meta_data. This function reads the request body, adds or updates the

normalizeTimeFields converts time fields to Unix timestamps

setTransactionMetadata initializes and sets the required metadata for a transaction. calculates the transaction hash, and sets the precise amount base

setupBenchmarkConfig creates and stores a test configuration

updateBalance updates a balance entry in the database. This function handles the logic of updating all balance-related fields while ensuring data cons

BackupToDisk creates a backup of the PostgreSQL database and stores it locally on disk. It creates a directory based on the current date and stores th

Call makes an HTTP request using the provided request object and decodes the response into the specified structure. It automatically sets the request

CreateBulkTransactions handles the creation of multiple transactions in a batch. If atomic is true: Any failure will cause all transactions to be roll

GetBalanceByID retrieves a balance by its ID. It starts a tracing span, fetches the balance, and records relevant events. Parameters: - ctx context.C

GetBalanceByID retrieves a balance by its ID from the database, along with optional related data such as identity or ledger, based on the `include` pa

Creates a new identity

GetQueuedAmounts retrieves the total queued debit and credit amounts for a given balance ID. It only includes transactions with status 'QUEUED' that d

GetTransaction retrieves a transaction by its ID from the datasource. It starts a tracing span, fetches the transaction, and records relevant events a

Lock attempts to acquire all locks in deterministic order. If any lock acquisition fails, all previously acquired locks are released (rollback). Param

MockConfig sets a mock configuration for testing purposes.

NewQueue initializes a new Queue instance with the provided configuration. Parameters: - conf *config.Configuration: The configuration for the queue.

ParseFiltersFromContext parses query parameters into a QueryFilterSet using the filter package. It handles all filter parameters in the format: field_

TokenizeIdentityField tokenizes a specific field in an identity. Parameters: - identityID string: The ID of the identity. - fieldName string: The nam

UpdateBalances updates both the source and destination balances in a single transaction. The function begins a database transaction, updates the balan

UpdateMetadata updates the metadata for a given entity ID. It first determines the entity type, retrieves current metadata, merges it with new metadat

Retrieves a reconciliation by ID

ValidateSortField validates that the sort field is allowed for the table.

compareSchemas compares the old schema with the new schema and returns: - newFields: fields present in new schema but not in old schema - removedField

getIdentityIdentifier generates a unique identifier string for an identity. It uses the identity's name (first/last or organization) combined with a p

getKeyPrefix extracts the first 16 characters of the key for efficient lookup.

getTypeKey returns the Redis key for a specific hook type set. Parameters: - hookType: The type of hook. Returns: - string: The Redis key for the ho

pollForTransactionStatus polls for a transaction until it reaches the expected status or a timeout occurs.

updateEntityMetadata updates the metadata for a specific entity. It routes the update operation to the appropriate datasource method based on the enti

DetokenizeWithMode converts a token back to the original PII value using the specified mode. Parameters: - token string: The token to be converted ba

EnsureCollectionsExist ensures that all the necessary collections exist in the Typesense schema. If a collection doesn't exist, it will create the col

Retrieves multiple balances by IDs with minimal data (batch query)

Creates a new ledger

GetAllLedgers retrieves a paginated list of ledger records from the database, unmarshaling their metadata from JSON format. This method supports pagin

Updates the status of a transaction

GetBalanceAtTime retrieves the balance state at a specific point in time. It finds the most recent snapshot before the target time and applies any sub

Updates a balance

GetLedgerByID retrieves a ledger record from the database by its ID. It handles cases where the ledger is not found and unmarshals the metadata from J

Creates a new balance monitor

GetTransactionLineage retrieves the lineage information for a transaction. It returns the fund allocation details and any shadow transactions created

HasScope checks if the API key has the required scope

IsInflightTransaction checks whether a transaction is considered "inflight" based on its status and metadata. A transaction is considered inflight if:

ListAPIKeys retrieves all API keys belonging to a specific owner from the database. The results are ordered by creation date in descending order (newe

NewCache creates a new instance of RedisCache by establishing a connection to Redis. It fetches the configuration, initializes Redis, and returns a Ca

NewTypesenseClient initializes and returns a new Typesense client instance.

RecordTransactionWithBalances atomically records a transaction and updates both source and destination balances within a single database transaction.

TryRecordQueuedTransactionBatch opportunistically coalesces multiple QUEUED transactions that share the same contention shape into a single balance co

UpdateBalanceIdentity updates only the identity_id associated with a balance. It validates that both the balance and the identity exist before applyin

UpdateIdentity updates a specific identity record in the database. It marshals the identity metadata, constructs an SQL update query, and checks the r

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