net.corda.node.services.vault / NodeVaultService

NodeVaultService

class NodeVaultService : SingletonSerializeAsToken, VaultService

Currently, the node vault service is a very simple RDBMS backed implementation. It will change significantly when we add further functionality as the design for the vault and vault service matures.

This class needs database transactions to be in-flight during method calls and init, and will throw exceptions if this is not the case.

TODO: move query / filter criteria into the database query. TODO: keep an audit trail with time stamps of previously unconsumed states "as of" a particular point in time. TODO: have transaction storage do some caching.





Constructors

<init> NodeVaultService(services: ServiceHub)

Currently, the node vault service is a very simple RDBMS backed implementation. It will change significantly when we add further functionality as the design for the vault and vault service matures.

Properties

currentVault val currentVault: Vault

Returns a read-only snapshot of the vault at the time the call is made. Note that if you consume states or keys in this vault, you must inform the vault service so it can update its internal state.

linearHeads val linearHeads: Map<UniqueIdentifier, StateAndRef<LinearState>>

Returns a snapshot of the heads of LinearStates.

updates val updates: <ERROR CLASS><Update>

Get a synchronous Observable of updates. When observations are pushed to the Observer, the Vault will already incorporate the update.

Inherited Properties

cashBalances open val cashBalances: Map<Currency, Amount<Currency>>

Returns a map of how much cash we have in each currency, ignoring details like issuer. Note: currencies for which we have no cash evaluate to null (not present in map), not 0.

Functions

addNoteToTransaction fun addNoteToTransaction(txnId: SecureHash, noteText: String): Unit

Add a note to an existing LedgerTransaction given by its unique SecureHash id Multiple notes may be attached to the same LedgerTransaction. These are additively and immutably persisted within the node local vault database in a single textual field using a semi-colon separator

generateSpend fun generateSpend(tx: TransactionBuilder, amount: Amount<Currency>, to: PublicKey, onlyFromParties: Set<Party>?): <ERROR CLASS><TransactionBuilder, List<PublicKey>>

Generate a transaction that moves an amount of currency to the given pubkey.

getTransactionNotes fun getTransactionNotes(txnId: SecureHash): Iterable<String>
notifyAll fun notifyAll(txns: Iterable<WireTransaction>): Vault

Possibly update the vault by marking as spent states that these transactions consume, and adding any relevant new states that they create. You should only insert transactions that have been successfully verified here

track fun track(): <ERROR CLASS><Vault, <ERROR CLASS><Update>>

Atomically get the current vault and a stream of updates. Note that the Observable buffers updates until the first subscriber is registered so as to avoid racing with early updates.

Inherited Functions

linearHeadsOfType_ open fun <T : LinearState> linearHeadsOfType_(stateType: Class<T>): Map<UniqueIdentifier, StateAndRef<T>>

Returns the linearHeads only when the type of the state would be considered an instanceof the given type.

notify open fun notify(tx: WireTransaction): Vault

Same as notifyAll but with a single transaction.

statesForRefs open fun statesForRefs(refs: List<StateRef>): Map<StateRef, TransactionState<*>?>
toToken open fun toToken(context: SerializeAsTokenContext): SerializationToken
whenConsumed open fun whenConsumed(ref: StateRef): <ERROR CLASS><Update>

Provide a Future for when a StateRef is consumed, which can be very useful in building tests.

Companion Object Properties

log val log: <ERROR CLASS>

Extension Functions

dealsWith fun <T : DealState> VaultService.dealsWith(party: Party): <ERROR CLASS>
linearHeadsOfType fun <T : LinearState> VaultService.linearHeadsOfType(): <ERROR CLASS>