udb

package
v4.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 28, 2024 License: ISC Imports: 36 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	// MaxAccountNum is the maximum allowed account number.  This value was
	// chosen because accounts are hardened children and therefore must
	// not exceed the hardened child range of extended keys and it provides
	// a reserved account at the top of the range for supporting imported
	// addresses.
	MaxAccountNum = hdkeychain.HardenedKeyStart - 2 // 2^31 - 2

	// MaxAddressesPerAccount is the maximum allowed number of addresses
	// per account number.  This value is based on the limitation of
	// the underlying hierarchical deterministic key derivation.
	MaxAddressesPerAccount = hdkeychain.HardenedKeyStart - 1

	// ImportedAddrAccount is the account number to use for all imported
	// addresses.  This is useful since normal accounts are derived from the
	// root hierarchical deterministic key and imported addresses do not
	// fit into that model.
	ImportedAddrAccount = MaxAccountNum + 1 // 2^31 - 1

	// ImportedAddrAccountName is the name of the imported account.
	ImportedAddrAccountName = "imported"

	// DefaultAccountNum is the number of the default account.
	DefaultAccountNum = 0

	// ExternalBranch is the child number to use when performing BIP0044
	// style hierarchical deterministic key derivation for the external
	// branch.
	ExternalBranch uint32 = 0

	// InternalBranch is the child number to use when performing BIP0044
	// style hierarchical deterministic key derivation for the internal
	// branch.
	InternalBranch uint32 = 1
)
View Source 
const (
	// TSImmatureOrLive indicates that the ticket is either
	// live or immature.
	TSImmatureOrLive = iota

	// TSVoted indicates that the ticket was spent as a vote.
	TSVoted

	// TSMissed indicates that the ticket was spent as a
	// revocation.
	TSMissed
)
View Source 
const (

	// DBVersion is the latest version of the database that is understood by the
	// program.  Databases with recorded versions higher than this will fail to
	// open (meaning any upgrades prevent reverting to older software).
	DBVersion = birthBlockVersion
)

Variables

This section is empty.

Functions

func CoinTypes 

func CoinTypes(params *chaincfg.Params) (legacyCoinType, slip0044CoinType uint32)

CoinTypes returns the legacy and SLIP0044 coin types for the chain parameters. At the moment, the parameters have not been upgraded for the new coin types.

func DefaultAgendaPreference 

func DefaultAgendaPreference(dbtx walletdb.ReadTx, version uint32, agendaID string) (choiceID string)

DefaultAgendaPreference returns the saved default choice ID, if any, for an agenda ID and deployment version. If no choice has been saved, this returns the empty string.

func ExtractBlockHeaderHeight 

func ExtractBlockHeaderHeight(header []byte) int32

ExtractBlockHeaderHeight returns the height field that is encoded in the header. Must only be called on known good input.

TODO: This really should not be exported by this package.

func ExtractBlockHeaderParentHash 

func ExtractBlockHeaderParentHash(header []byte) []byte

ExtractBlockHeaderParentHash subslices the header to return the bytes of the parent block's hash. Must only be called on known good input.

TODO: This really should not be exported by this package.

func ExtractBlockHeaderTime 

func ExtractBlockHeaderTime(header []byte) int64

ExtractBlockHeaderTime returns the unix timestamp that is encoded in the header. Must only be called on known good input. Header timestamps are only 4 bytes and this value is actually limited to a maximum unix time of 2^32-1.

TODO: This really should not be exported by this package.

func GetVSPTicketsByFeeStatus 

func GetVSPTicketsByFeeStatus(dbtx walletdb.ReadTx, feeStatus int) (map[chainhash.Hash]*VSPTicket, error)

GetVSPTicketsByFeeStatus gets all vsp tickets which have FeeTxStatus == feeStatus.

func HDKeysFromSeed 

func HDKeysFromSeed(seed []byte, params *chaincfg.Params) (coinTypeLegacyKeyPriv, coinTypeSLIP0044KeyPriv, acctKeyLegacyPriv, acctKeySLIP0044Priv *hdkeychain.ExtendedKey, err error)

HDKeysFromSeed creates legacy and slip0044 coin keys and accout zero keys from seed. Keys are zeroed upon any error.

func Initialize 

func Initialize(ctx context.Context, db walletdb.DB, params *chaincfg.Params, seed, pubPass, privPass []byte) error

Initialize prepares an empty database for usage by initializing all buckets and key/value pairs. The database is initialized with the latest version and does not require any upgrades to use.

func InitializeWatchOnly 

func InitializeWatchOnly(ctx context.Context, db walletdb.DB, params *chaincfg.Params, hdPubKey string, pubPass []byte) error

InitializeWatchOnly prepares an empty database for watching-only wallet usage by initializing all buckets and key/value pairs. The database is initialized with the latest version and does not require any upgrades to use.

func IsImportedVoting 

func IsImportedVoting(acctType uint8) bool

IsImportedVoting compares a uint8 to the internal importedVoting type and returns if the value represents an imported voting account.

func Migrate 

func Migrate(ctx context.Context, db walletdb.DB, params *chaincfg.Params) error

Migrate converts a database to the first version of the unified database format. If any old upgrades are necessary, they are performed first. Upgrades added after the migration was implemented may still need to be performed.

func NeedsMigration 

func NeedsMigration(ctx context.Context, db walletdb.DB) (bool, error)

NeedsMigration checks whether the database needs to be converted to the unified database format.

func Open 

func Open(ctx context.Context, db walletdb.DB, params *chaincfg.Params, pubPass []byte) (addrMgr *Manager, txStore *Store, stakeStore *StakeStore, err error)

Open opens the database and returns various "manager" types that must be used to access and modify data in the database.

A NotExist error will be returned if the database has not been initialized. The recorded database version must match exactly with DBVersion. If the version does not match, an Invalid error is returned.

func SetBirthState 

func SetBirthState(dbtx walletdb.ReadWriteTx, bs *BirthdayState) error

SetBirthState sets the birthday state in the database.

[0:1] Options (1 byte) [1:33] Birthblock block header hash (32 bytes) [33:37] Birthblock block height (4 bytes) [37:45] Birthday time (8 bytes)

func SetDefaultAgendaPreference 

func SetDefaultAgendaPreference(dbtx walletdb.ReadWriteTx, version uint32, agendaID, choiceID string) error

SetDefaultAgendaPreference saves a default agenda choice ID for an agenda ID and deployment version.

func SetTSpendPolicy 

func SetTSpendPolicy(dbtx walletdb.ReadWriteTx, hash *chainhash.Hash,
	policy stake.TreasuryVoteT) error

SetTSpendPolicy sets a tspend vote policy for a specific tspend transaction hash.

func SetTicketAgendaPreference 

func SetTicketAgendaPreference(dbtx walletdb.ReadWriteTx, txHash *chainhash.Hash, version uint32, agendaID, choiceID string) error

SetTicketAgendaPreference saves a ticket-specific agenda choice ID for an agenda ID and deployment version.

func SetTreasuryKeyPolicy 

func SetTreasuryKeyPolicy(dbtx walletdb.ReadWriteTx, pikey []byte,
	policy stake.TreasuryVoteT) error

SetTreasuryKeyPolicy sets a tspend vote policy for a specific Politeia instance key.

func SetVSPHost 

func SetVSPHost(dbtx walletdb.ReadWriteTx, id uint32, record *VSPHost) error

SetVSPHost sets a VSPHost record into the db.

func SetVSPPubKey 

func SetVSPPubKey(dbtx walletdb.ReadWriteTx, host []byte, record *VSPPubKey) error

SetVSPPubKey sets a VSPPubKey record into the db.

func SetVSPTSpendPolicy 

func SetVSPTSpendPolicy(dbtx walletdb.ReadWriteTx, ticketHash, tspendHash *chainhash.Hash,
	policy stake.TreasuryVoteT) error

SetVSPTSpendPolicy sets a tspend vote policy for a specific tspend transaction hash for a VSP customer's ticket hash.

func SetVSPTicket 

func SetVSPTicket(dbtx walletdb.ReadWriteTx, ticketHash *chainhash.Hash, record *VSPTicket) error

SetVSPTicket sets a VSPTicket record into the db.

func SetVSPTreasuryKeyPolicy 

func SetVSPTreasuryKeyPolicy(dbtx walletdb.ReadWriteTx, ticket *chainhash.Hash,
	pikey []byte, policy stake.TreasuryVoteT) error

SetVSPTreasuryKeyPolicy sets a tspend vote policy for a specific Politeia instance key for a VSP customer's ticket.

func TSpendPolicies 

func TSpendPolicies(dbtx walletdb.ReadTx) (map[chainhash.Hash]stake.TreasuryVoteT, error)

TSpendPolicies returns all tspend vote policies keyed by a tspend hash. Abstaining policies are excluded.

func TSpendPolicy 

func TSpendPolicy(dbtx walletdb.ReadTx, hash *chainhash.Hash) (stake.TreasuryVoteT, error)

TSpendPolicy returns the tspend vote policy for a specific tspend transaction hash.

func TicketAgendaPreference 

func TicketAgendaPreference(dbtx walletdb.ReadTx, ticketHash *chainhash.Hash, version uint32, agendaID string) (choiceID string)

TicketAgendaPreference returns a ticket's saved choice ID, if any, for an agenda ID and deployment version. If no choice has been saved, this returns the empty string.

func TreasuryKeyPolicies 

func TreasuryKeyPolicies(dbtx walletdb.ReadTx) (map[string]stake.TreasuryVoteT, error)

TreasuryKeyPolicies returns all tspend vote policies keyed by a Politeia instance key. Abstaining policies are excluded.

func TreasuryKeyPolicy 

func TreasuryKeyPolicy(dbtx walletdb.ReadTx, pikey []byte) (stake.TreasuryVoteT, error)

TreasuryKeyPolicy returns the tspend vote policy for a specific Politeia instance key.

func Upgrade 

func Upgrade(ctx context.Context, db walletdb.DB, publicPassphrase []byte, params *chaincfg.Params) error

Upgrade checks whether the any upgrades are necessary before the database is ready for application usage. If any are, they are performed.

func UseLogger 

func UseLogger(logger slog.Logger)

UseLogger uses a specified Logger to output package logging info. This should be used in preference to SetLogWriter if the caller is also using slog.

func VSPTSpendPolicies 

func VSPTSpendPolicies(dbtx walletdb.ReadTx) (map[VSPTSpend]stake.TreasuryVoteT, error)

VSPTSpendPolicies returns all tspend vote policies keyed by a tspend hash and a VSP customer's ticket hash. Abstaining policies are excluded.

func VSPTSpendPolicy 

func VSPTSpendPolicy(dbtx walletdb.ReadTx, ticketHash,
	tspendHash *chainhash.Hash) (stake.TreasuryVoteT, error)

VSPTSpendPolicy returns the tspend vote policy for a specific tspend transaction hash for a VSP customer's ticket hash.

func VSPTreasuryKeyPolicies 

func VSPTreasuryKeyPolicies(dbtx walletdb.ReadTx) (map[VSPTreasuryKey]stake.TreasuryVoteT, error)

VSPTreasuryKeyPolicies returns all tspend vote policies keyed by a Politeia instance key for a VSP customer's ticket. Abstaining policies are excluded.

func VSPTreasuryKeyPolicy 

func VSPTreasuryKeyPolicy(dbtx walletdb.ReadTx, ticket *chainhash.Hash,
	pikey []byte) (stake.TreasuryVoteT, error)

VSPTreasuryKeyPolicy returns the tspend vote policy for a specific Politeia instance key for a VSP customer's ticket.

func ValidateAccountName 

func ValidateAccountName(name string) error

ValidateAccountName validates the given account name and returns an error, if any.

Types

type AccountProperties 

type AccountProperties = struct {
	AccountNumber             uint32
	AccountName               string
	AccountType               uint8
	LastUsedExternalIndex     uint32
	LastUsedInternalIndex     uint32
	LastReturnedExternalIndex uint32
	LastReturnedInternalIndex uint32
	ImportedKeyCount          uint32
	AccountEncrypted          bool
	AccountUnlocked           bool
}

AccountProperties contains properties associated with each account, such as the account name, number, and the nubmer of derived and imported keys. If no address usage has been recorded on any of the external or internal branches, the child index is ^uint32(0).

type Balances 

type Balances = struct {
	Account                 uint32
	ImmatureCoinbaseRewards dcrutil.Amount
	ImmatureStakeGeneration dcrutil.Amount
	LockedByTickets         dcrutil.Amount
	Spendable               dcrutil.Amount
	Total                   dcrutil.Amount
	VotingAuthority         dcrutil.Amount
	Unconfirmed             dcrutil.Amount
}

Balances is an convenience type.

type BirthdayState 

type BirthdayState struct {
	Hash                       chainhash.Hash
	Height                     uint32
	Time                       time.Time
	SetFromHeight, SetFromTime bool
}

BirthdayState holds fields for setting and reading the birthday block. SetFromHeight and SetFromTime indicate that the birthday block should be set from those respective fields. Upon setting the hash and height are filled in and SetFrom fields set to false.

func BirthState 

func BirthState(dbtx walletdb.ReadTx) *BirthdayState

BirthState returns the current birthday state.

type Block 

type Block struct {
	Hash   chainhash.Hash
	Height int32
}

Block contains the minimum amount of data to uniquely identify any block on either the best or side chain.

type BlockCFilter 

type BlockCFilter struct {
	BlockHash chainhash.Hash
	FilterV2  *gcs2.FilterV2
	Key       [gcs2.KeySize]byte
}

BlockCFilter is a compact filter for a Decred block.

type BlockHeaderData 

type BlockHeaderData struct {
	BlockHash        chainhash.Hash
	SerializedHeader RawBlockHeader
}

BlockHeaderData contains the block hashes and serialized blocks headers that are inserted into the database. At time of writing this only supports wire protocol version 0 blocks and changes will need to be made if the block header size changes.

type BlockMeta 

type BlockMeta struct {
	Block
	Time     time.Time
	VoteBits uint16
}

BlockMeta contains the unique identification for a block and any metadata pertaining to the block. At the moment, this additional metadata only includes the block time from the block header.

type Credit 

type Credit struct {
	wire.OutPoint
	BlockMeta
	Amount       dcrutil.Amount
	PkScript     []byte // TODO: script version
	Received     time.Time
	FromCoinBase bool
	HasExpiry    bool
}

Credit is the type representing a transaction output which was spent or is still spendable by wallet. A UTXO is an unspent Credit, but not all Credits are UTXOs.

type CreditRecord 

type CreditRecord struct {
	Index      uint32
	Amount     dcrutil.Amount
	Spent      bool
	Change     bool
	OpCode     uint8
	IsCoinbase bool
	HasExpiry  bool
}

CreditRecord contains metadata regarding a transaction credit for a known transaction. Further details may be looked up by indexing a wire.MsgTx.TxOut with the Index field.

type CryptoKeyType 

type CryptoKeyType byte

CryptoKeyType is used to differentiate between different kinds of crypto keys. 

const (
	// CKTPrivate specifies the key that is used for encryption of private
	// key material such as derived extended private keys and imported
	// private keys.
	CKTPrivate CryptoKeyType = iota

	// CKTPublic specifies the key that is used for encryption of public
	// key material such as dervied extended public keys and imported public
	// keys.
	CKTPublic
)

Crypto key types.

type DebitRecord 

type DebitRecord struct {
	Amount dcrutil.Amount
	Index  uint32
}

DebitRecord contains metadata regarding a transaction debit for a known transaction. Further details may be looked up by indexing a wire.MsgTx.TxIn with the Index field.

type EncryptorDecryptor 

type EncryptorDecryptor interface {
	Encrypt(in []byte) ([]byte, error)
	Decrypt(in []byte) ([]byte, error)
	Bytes() []byte
	CopyBytes([]byte)
	Zero()
}

EncryptorDecryptor provides an abstraction on top of snacl.CryptoKey so that our tests can use dependency injection to force the behaviour they need.

type FeeStatus 

type FeeStatus int

FeeStatus represents the current fee status of a ticket. 

const (
	// VSPFeeProcessStarted represents the state which process has being
	// called but fee still not paid.
	VSPFeeProcessStarted FeeStatus = iota
	// VSPFeeProcessPaid represents the state where the process has being
	// paid, but not published.
	VSPFeeProcessPaid
	VSPFeeProcessErrored
	// VSPFeeProcessConfirmed represents the state where the fee has been
	// confirmed by the VSP.
	VSPFeeProcessConfirmed
)

FeeStatus types

type InputSource 

type InputSource struct {
	// contains filtered or unexported fields
}

InputSource provides a method (SelectInputs) to incrementally select unspent outputs to use as transaction inputs.

func (*InputSource) SelectInputs 

func (s *InputSource) SelectInputs(target dcrutil.Amount) (*txauthor.InputDetail, error)

SelectInputs selects transaction inputs to redeem unspent outputs stored in the database. It may be called multiple times with increasing target amounts to return additional inputs for a higher target amount. It returns the total input amount referenced by the previous transaction outputs, a slice of transaction inputs referencing these outputs, and a slice of previous output scripts from each previous output referenced by the corresponding input.

type ManagedAddress 

type ManagedAddress interface {
	// Account returns the account the address is associated with.
	Account() uint32

	// Address returns a stdaddr.Address for the backing address.
	Address() stdaddr.Address

	// AddrHash returns the key or script hash related to the address
	AddrHash() []byte

	// Imported returns true if the backing address was imported instead
	// of being part of an address chain.
	Imported() bool

	// Internal returns true if the backing address was created for internal
	// use such as a change output of a transaction.
	Internal() bool

	// Multisig returns true if the backing address was created for multisig
	// use.
	Multisig() bool
}

ManagedAddress is an interface that provides acces to information regarding an address managed by an address manager. Concrete implementations of this type may provide further fields to provide information specific to that type of address.

type ManagedPubKeyAddress 

type ManagedPubKeyAddress interface {
	ManagedAddress

	// PubKey returns the public key associated with the address.
	PubKey() []byte

	// Index returns the child number used to derive this public key address
	Index() uint32
}

ManagedPubKeyAddress extends ManagedAddress and additionally provides the public and private keys for pubkey-based addresses.

type ManagedScriptAddress 

type ManagedScriptAddress interface {
	ManagedAddress

	// RedeemScript returns the redeem script and script version.
	RedeemScript() (uint16, []byte)
}

ManagedScriptAddress extends ManagedAddress and represents a pay-to-script-hash style of addresses.

type Manager 

type Manager struct {
	// contains filtered or unexported fields
}

Manager represents a concurrency safe crypto currency address manager and key store.

func (*Manager) AccountBranchExtendedPubKey 

func (m *Manager) AccountBranchExtendedPubKey(dbtx walletdb.ReadTx, account, branch uint32) (*hdkeychain.ExtendedKey, error)

AccountBranchExtendedPubKey returns the extended public key of an account's branch, which then can be used to derive addresses belonging to the account.

func (*Manager) AccountExtendedPrivKey 

func (m *Manager) AccountExtendedPrivKey(dbtx walletdb.ReadTx, account uint32) (*hdkeychain.ExtendedKey, error)

AccountExtendedPrivKey returns the extended private key for the given account. The account must already exist and the address manager must be unlocked for this operation to complete.

func (*Manager) AccountExtendedPubKey 

func (m *Manager) AccountExtendedPubKey(dbtx walletdb.ReadTx, account uint32) (*hdkeychain.ExtendedKey, error)

AccountExtendedPubKey returns the extended public key for an account, which can then be used to derive BIP0044 branch keys.

func (*Manager) AccountHasPassphrase 

func (m *Manager) AccountHasPassphrase(dbtx walletdb.ReadTx, account uint32) (hasPassphrase, unlocked bool)

AccountHasPassphrase returns whether an account's keys are currently protected by a per-account passphrase, and if so, whether the account is currently locked or unlocked.

func (*Manager) AccountName 

func (m *Manager) AccountName(ns walletdb.ReadBucket, account uint32) (string, error)

AccountName returns the account name for the given account number stored in the manager.

func (*Manager) AccountProperties 

func (m *Manager) AccountProperties(ns walletdb.ReadBucket, account uint32) (*AccountProperties, error)

AccountProperties returns properties associated with the account, such as the account number, name, and the number of derived and imported keys.

TODO: Instead of opening a second read transaction after making a change, and then fetching the account properties with a new read tx, this can be made more performant by simply returning the new account properties during the change.

func (*Manager) AddrAccount 

func (m *Manager) AddrAccount(ns walletdb.ReadBucket, address stdaddr.Address) (uint32, error)

AddrAccount returns the account to which the given address belongs.

func (*Manager) Address 

func (m *Manager) Address(ns walletdb.ReadBucket, address stdaddr.Address) (ManagedAddress, error)

Address returns a managed address given the passed address if it is known to the address manager. A managed address differs from the passed address in that it also potentially contains extra information needed to sign transactions such as the associated private key for pay-to-pubkey and pay-to-pubkey-hash addresses and the script associated with pay-to-script-hash addresses.

func (*Manager) ChainParams 

func (m *Manager) ChainParams() *chaincfg.Params

ChainParams returns the chain parameters for this address manager.

func (*Manager) ChangePassphrase 

func (m *Manager) ChangePassphrase(ns walletdb.ReadWriteBucket, oldPassphrase, newPassphrase []byte, private bool) error

ChangePassphrase changes either the public or private passphrase to the provided value depending on the private flag. In order to change the private password, the address manager must not be watching-only. The new passphrase keys are derived using the scrypt parameters in the options, so changing the passphrase may be used to bump the computational difficulty needed to brute force the passphrase.

func (*Manager) Close 

func (m *Manager) Close() error

Close cleanly shuts down the manager. It makes a best try effort to remove and zero all private key and sensitive public key material associated with the address manager from memory.

func (*Manager) CoinType 

func (m *Manager) CoinType(dbtx walletdb.ReadTx) (uint32, error)

CoinType returns the BIP0044 coin type currently in use. Early versions of the wallet used coin types that conflicted with other coins, preventing use of the same seed in multicurrency wallets. New (not restored) wallets are now created using the coin types assigned to Decred in SLIP0044: 

https://github.com/satoshilabs/slips/blob/master/slip-0044.md

The address manager should be upgraded to the SLIP0044 coin type if it is currently using the legacy coin type and there are no used accounts or addresses. This procedure must be performed for seed restored wallets which save both coin types and, for backwards compatibility reasons, default to the legacy coin type. Both coin types for a network may be queried using the CoinTypes func and upgrades are performed using the UpgradeToSLIP0044CoinType method.

Watching-only wallets that are created using an account xpub do not save the coin type keys and this method will return an error with code WatchingOnly on these wallets.

func (*Manager) CoinTypePrivKey 

func (m *Manager) CoinTypePrivKey(dbtx walletdb.ReadTx) (*hdkeychain.ExtendedKey, error)

CoinTypePrivKey returns the coin type private key at the BIP0044 path m/44'/<coin type>' (coin type child indexes differ by the network). The key and all derived private keys should be cleared by the caller when finished. This method requires the wallet to be unlocked.

func (*Manager) ConvertToWatchingOnly 

func (m *Manager) ConvertToWatchingOnly(ns walletdb.ReadWriteBucket) error

ConvertToWatchingOnly converts the current address manager to a locked watching-only address manager.

WARNING: This function removes private keys from the existing address manager which means they will no longer be available. Typically the caller will make a copy of the existing wallet database and modify the copy since otherwise it would mean permanent loss of any imported private keys.

Executing this function on a manager that is already watching-only will have no effect.

func (*Manager) Decrypt 

func (m *Manager) Decrypt(keyType CryptoKeyType, in []byte) ([]byte, error)

Decrypt in using the crypto key type specified by keyType.

func (*Manager) Encrypt 

func (m *Manager) Encrypt(keyType CryptoKeyType, in []byte) ([]byte, error)

Encrypt in using the crypto key type specified by keyType.

func (*Manager) ExistsHash160 

func (m *Manager) ExistsHash160(ns walletdb.ReadBucket, hash160 []byte) bool

ExistsHash160 returns whether or not the 20 byte P2PKH or P2SH HASH160 is known to the address manager.

func (*Manager) ForEachAccount 

func (m *Manager) ForEachAccount(ns walletdb.ReadBucket, fn func(account uint32) error) error

ForEachAccount calls the given function with each account stored in the manager, breaking early on error.

func (*Manager) ForEachAccountAddress 

func (m *Manager) ForEachAccountAddress(ns walletdb.ReadBucket, account uint32, fn func(maddr ManagedAddress) error) error

ForEachAccountAddress calls the given function with each address of the given account stored in the manager, breaking early on error.

func (*Manager) ForEachActiveAccountAddress 

func (m *Manager) ForEachActiveAccountAddress(ns walletdb.ReadBucket, account uint32, fn func(maddr ManagedAddress) error) error

ForEachActiveAccountAddress calls the given function with each active address of the given account stored in the manager, breaking early on error. TODO(tuxcanfly): actually return only active addresses

func (*Manager) ForEachActiveAddress 

func (m *Manager) ForEachActiveAddress(ns walletdb.ReadBucket, fn func(addr stdaddr.Address) error) error

ForEachActiveAddress calls the given function with each active address stored in the manager, breaking early on error.

func (*Manager) HavePrivateKey 

func (m *Manager) HavePrivateKey(ns walletdb.ReadBucket, addr stdaddr.Address) (bool, error)

HavePrivateKey returns whether the private key for a P2PK or P2PKH address is available when the wallet or account is unlocked.

func (*Manager) ImportPrivateKey 

func (m *Manager) ImportPrivateKey(ns walletdb.ReadWriteBucket, wif *dcrutil.WIF) (ManagedPubKeyAddress, error)

ImportPrivateKey imports a WIF private key into the address manager. The imported address is created using either a compressed or uncompressed serialized public key, depending on the CompressPubKey bool of the WIF.

All imported addresses will be part of the account defined by the ImportedAddrAccount constant.

NOTE: When the address manager is watching-only, the private key itself will not be stored or available since it is private data. Instead, only the public key will be stored. This means it is paramount the private key is kept elsewhere as the watching-only address manager will NOT ever have access to it.

This function will return an error if the address manager is locked and not watching-only, or not for the same network as the key trying to be imported. It will also return an error if the address already exists. Any other errors returned are generally unexpected.

func (*Manager) ImportPublicKey 

func (m *Manager) ImportPublicKey(ns walletdb.ReadWriteBucket, pubkey []byte) (ManagedPubKeyAddress, error)

ImportPubKey imports a compressed 33-byte serialized secp256k1 public key and the derived P2PKH address. This method may only be used by watching-only wallets.

func (*Manager) ImportScript 

func (m *Manager) ImportScript(ns walletdb.ReadWriteBucket, script []byte) (ManagedScriptAddress, error)

ImportScript imports a user-provided script into the address manager. The imported script will act as a pay-to-script-hash address.

All imported script addresses will be part of the account defined by the ImportedAddrAccount constant.

func (*Manager) ImportVotingAccount 

func (m *Manager) ImportVotingAccount(dbtx walletdb.ReadWriteTx, acctKeyPriv *hdkeychain.ExtendedKey,
	passphrase []byte, name string) (uint32, error)

ImportVotingAccount imports an account for use with voting into the manager based on the given account name. If an account with the same name already exists, ErrDuplicateAccount will be returned. A password must be supplied. The acctKeyPriv must be for the current network.

func (*Manager) ImportXpubAccount 

func (m *Manager) ImportXpubAccount(ns walletdb.ReadWriteBucket, name string, xpub *hdkeychain.ExtendedKey) error

func (*Manager) IsLocked 

func (m *Manager) IsLocked() bool

IsLocked returns whether or not the address managed is locked. When it is unlocked, the decryption key needed to decrypt private keys used for signing is in memory.

func (*Manager) LastAccount 

func (m *Manager) LastAccount(ns walletdb.ReadBucket) (uint32, error)

LastAccount returns the last account stored in the manager.

func (*Manager) LastImportedAccount 

func (m *Manager) LastImportedAccount(dbtx walletdb.ReadTx) (uint32, error)

LastImportedAccount returns the acocunt number of the last imported account. This is the reserved imported account unless an account has been created by an imported xpub.

func (*Manager) Lock 

func (m *Manager) Lock() error

Lock performs a best try effort to remove and zero all secret keys associated with the address manager.

This function will return an error if invoked on a watching-only address manager.

func (*Manager) LockAccount 

func (m *Manager) LockAccount(dbtx walletdb.ReadTx, account uint32) error

LockAccount locks an individually-encrypted account by removing private key access until unlocked again.

func (*Manager) LookupAccount 

func (m *Manager) LookupAccount(ns walletdb.ReadBucket, name string) (uint32, error)

LookupAccount loads account number stored in the manager for the given account name

func (*Manager) MarkReturnedChildIndex 

func (m *Manager) MarkReturnedChildIndex(dbtx walletdb.ReadWriteTx, account, branch, child uint32) error

MarkReturnedChildIndex marks a BIP0044 account branch child as returned to a caller. This method will write returned child indexes that are lower than the currently-recorded last returned indexes, but these indexes will never be lower than the last used index.

func (*Manager) MarkUsed 

func (m *Manager) MarkUsed(tx walletdb.ReadWriteTx, address stdaddr.Address) error

MarkUsed updates usage statistics of a BIP0044 account address so that the last used address index can be tracked. There is no effect when called on P2SH addresses or any imported addresses.

func (*Manager) MarkUsedChildIndex 

func (m *Manager) MarkUsedChildIndex(tx walletdb.ReadWriteTx, account, branch, child uint32) error

MarkUsedChildIndex marks a BIP0044 account branch child as used.

func (*Manager) NewAccount 

func (m *Manager) NewAccount(ns walletdb.ReadWriteBucket, name string) (uint32, error)

NewAccount creates and returns a new account stored in the manager based on the given account name. If an account with the same name already exists, ErrDuplicateAccount will be returned. Since creating a new account requires access to the cointype keys (from which extended account keys are derived), it requires the manager to be unlocked.

func (*Manager) PrivateKey 

func (m *Manager) PrivateKey(ns walletdb.ReadBucket, addr stdaddr.Address) (key *secp256k1.PrivateKey, done func(), err error)

PrivateKey retreives the private key for a P2PK or P2PKH address. The retured 'done' function should be called after the key is no longer needed to overwrite the key with zeros.

func (*Manager) RecordDerivedAddress 

func (m *Manager) RecordDerivedAddress(dbtx walletdb.ReadWriteTx, account, branch, child uint32, pubkey []byte) error

RecordDerivedAddress adds an address derived from an account key to the wallet's database. The branch and child parameters should not have any hardened offset applied.

This method will not update the currently-recorded last returned address for the account; see MarkReturnedChildIndex to perform this step after recording addresses using this method.

This method is limited to P2PKH addresses for BIP0044 and hardened purpose accounts only.

func (*Manager) RedeemScript 

func (m *Manager) RedeemScript(ns walletdb.ReadBucket, addr stdaddr.Address) ([]byte, error)

RedeemScript retreives the redeem script to redeem an output paid to a P2SH address.

func (*Manager) RenameAccount 

func (m *Manager) RenameAccount(ns walletdb.ReadWriteBucket, account uint32, name string) error

RenameAccount renames an account stored in the manager based on the given account number with the given name. If an account with the same name already exists, ErrDuplicateAccount will be returned.

func (*Manager) SetAccountPassphrase 

func (m *Manager) SetAccountPassphrase(dbtx walletdb.ReadWriteTx, account uint32,
	passphrase []byte) error

SetAccountPassphrase individually-encrypts or changes the passphrase for account private keys.

If the passphrase has zero length, the private keys are re-encrypted with the manager's global passphrase. Cannot be zero length for watching-only wallets.

func (*Manager) SyncAccountToAddrIndex 

func (m *Manager) SyncAccountToAddrIndex(ns walletdb.ReadWriteBucket, account uint32, syncToIndex uint32, branch uint32) error

SyncAccountToAddrIndex records address records for an account branch up to syncToIndex. It does not modify the last used or last returned properties of the account branch.

func (*Manager) Unlock 

func (m *Manager) Unlock(ns walletdb.ReadBucket, passphrase []byte) error

Unlock derives the master private key from the specified passphrase. An invalid passphrase will return an error. Otherwise, the derived secret key is stored in memory until the address manager is locked. Any failures that occur during this function will result in the address manager being locked, even if it was already unlocked prior to calling this function.

This function will return an error if invoked on a watching-only address manager.

func (*Manager) UnlockAccount 

func (m *Manager) UnlockAccount(dbtx walletdb.ReadTx, account uint32,
	passphrase []byte) error

UnlockAccount decrypts a uniquely-encrypted account's private keys.

func (*Manager) UnlockedWithPassphrase 

func (m *Manager) UnlockedWithPassphrase(passphrase []byte) error

UnlockedWithPassphrase returns nil when the wallet is currently unlocked with a matching passphrase and errors with the following codes otherwise: 

WatchingOnly: The wallet is watching-only and can never be unlocked
Locked: The wallet is currently locked
Passphrase: The wallet is unlocked but the provided passphrase is incorrect

func (*Manager) UpgradeToSLIP0044CoinType 

func (m *Manager) UpgradeToSLIP0044CoinType(dbtx walletdb.ReadWriteTx) error

UpgradeToSLIP0044CoinType upgrades a wallet from using the legacy coin type to the coin type registered to Decred as per SLIP0044. On mainnet, this upgrades the coin type from 20 to 42. On testnet and simnet, the coin type is upgraded to 1. This upgrade is only possible if the SLIP0044 coin type private key is saved and there is no address use for keys derived by the legacy coin type.

func (*Manager) WatchingOnly 

func (m *Manager) WatchingOnly() bool

WatchingOnly returns whether or not the wallet is in watching only mode.

type MultisigCredit 

type MultisigCredit struct {
	OutPoint   *wire.OutPoint
	ScriptHash [ripemd160.Size]byte
	MSScript   []byte
	M          uint8
	N          uint8
	Amount     dcrutil.Amount
}

MultisigCredit is a redeemable P2SH multisignature credit.

type MultisigOut 

type MultisigOut struct {
	OutPoint     *wire.OutPoint
	Tree         int8
	ScriptHash   [ripemd160.Size]byte
	M            uint8
	N            uint8
	TxHash       chainhash.Hash
	BlockHash    chainhash.Hash
	BlockHeight  uint32
	Amount       dcrutil.Amount
	Spent        bool
	SpentBy      chainhash.Hash
	SpentByIndex uint32
}

MultisigOut represents a spendable multisignature outpoint contain a script hash.

type ObtainUserInputFunc 

type ObtainUserInputFunc func() ([]byte, error)

ObtainUserInputFunc is a function that reads a user input and returns it as a byte stream. It is used to accept data required during upgrades, for e.g. wallet seed and private passphrase.

type PoolTicket 

type PoolTicket struct {
	Ticket       chainhash.Hash
	HeightTicket uint32 // Not used or guaranteed to be correct
	Status       TicketStatus
	HeightSpent  uint32
	SpentBy      chainhash.Hash
}

PoolTicket is a 73-byte struct that is used to preserve user's ticket information when they have an account at the stake pool.

type RawBlockHeader 

type RawBlockHeader [180]byte

RawBlockHeader is a 180 byte block header (always true for version 0 blocks).

func (*RawBlockHeader) Height 

func (h *RawBlockHeader) Height() int32

Height extracts the height encoded in a block header.

type StakePoolUser 

type StakePoolUser struct {
	Tickets        []*PoolTicket
	InvalidTickets []*chainhash.Hash
}

StakePoolUser is a list of tickets for a given user (P2SH address) in the stake pool.

type StakeStore 

type StakeStore struct {
	Params  *chaincfg.Params
	Manager *Manager
	// contains filtered or unexported fields
}

StakeStore represents a safely accessible database of stake transactions.

func (*StakeStore) DumpSStxHashes 

func (s *StakeStore) DumpSStxHashes() []chainhash.Hash

DumpSStxHashes returns the hashes of all wallet ticket purchase transactions.

func (*StakeStore) DumpSStxHashesForAddress 

func (s *StakeStore) DumpSStxHashesForAddress(ns walletdb.ReadBucket, addr stdaddr.Address) ([]chainhash.Hash, error)

DumpSStxHashesForAddress returns the hashes of all wallet ticket purchase transactions for an address.

func (*StakeStore) InsertSStx 

func (s *StakeStore) InsertSStx(ns walletdb.ReadWriteBucket, sstx *dcrutil.Tx) error

InsertSStx is the exported version of insertSStx that is safe for concurrent access.

func (*StakeStore) OwnTicket 

func (s *StakeStore) OwnTicket(hash *chainhash.Hash) bool

OwnTicket returns whether the ticket is tracked by the stake manager.

func (*StakeStore) RemoveStakePoolUserInvalTickets 

func (s *StakeStore) RemoveStakePoolUserInvalTickets(ns walletdb.ReadWriteBucket, user stdaddr.Address, ticket *chainhash.Hash) error

RemoveStakePoolUserInvalTickets is the exported and concurrency safe form of removetStakePoolUserInvalTickets.

func (*StakeStore) SStxAddress 

func (s *StakeStore) SStxAddress(ns walletdb.ReadBucket, hash *chainhash.Hash) (stdaddr.Address, error)

SStxAddress is the exported, concurrency safe version of sstxAddress.

func (*StakeStore) StakePoolUserInfo 

func (s *StakeStore) StakePoolUserInfo(ns walletdb.ReadBucket, user stdaddr.Address) (*StakePoolUser, error)

StakePoolUserInfo returns the stake pool user information for a given stake pool user, keyed to their P2SH voting address.

func (*StakeStore) TicketPurchase 

func (s *StakeStore) TicketPurchase(dbtx walletdb.ReadTx, hash *chainhash.Hash) (*wire.MsgTx, error)

TicketPurchase returns the ticket purchase transaction recorded in the "stake manager" portion of the DB.

TODO: This is redundant and should be looked up in from the transaction manager. Left for now for compatibility.

func (*StakeStore) UpdateStakePoolUserInvalTickets 

func (s *StakeStore) UpdateStakePoolUserInvalTickets(ns walletdb.ReadWriteBucket, user stdaddr.Address, ticket *chainhash.Hash) error

UpdateStakePoolUserInvalTickets is the exported and concurrency safe form of updateStakePoolUserInvalTickets.

func (*StakeStore) UpdateStakePoolUserTickets 

func (s *StakeStore) UpdateStakePoolUserTickets(ns walletdb.ReadWriteBucket, user stdaddr.Address, ticket *PoolTicket) error

UpdateStakePoolUserTickets is the exported and concurrency safe form of updateStakePoolUserTickets.

type Store 

type Store struct {
	// contains filtered or unexported fields
}

Store implements a transaction store for storing and managing wallet transactions.

func (*Store) AccountBalance 

func (s *Store) AccountBalance(dbtx walletdb.ReadTx, minConf int32, account uint32) (Balances, error)

AccountBalance returns a Balances struct for some given account at syncHeight block height with all UTXOS that have minConf manyn confirms.

func (*Store) AccountBalances 

func (s *Store) AccountBalances(dbtx walletdb.ReadTx, minConf int32) (map[uint32]*Balances, error)

AccountBalances returns a map of all account balances at syncHeight block height with all UTXOs that have minConf many confirms.

func (*Store) AddCredit 

func (s *Store) AddCredit(dbtx walletdb.ReadWriteTx, rec *TxRecord, block *BlockMeta,
	index uint32, change bool, account uint32) error

AddCredit marks a transaction record as containing a transaction output spendable by wallet. The output is added unspent, and is marked spent when a new transaction spending the output is inserted into the store.

TODO(jrick): This should not be necessary. Instead, pass the indexes that are known to contain credits when a transaction or merkleblock is inserted into the store.

func (*Store) AddMultisigOut 

func (s *Store) AddMultisigOut(dbtx walletdb.ReadWriteTx, rec *TxRecord, block *BlockMeta, index uint32) error

AddMultisigOut adds a P2SH multisignature spendable output into the transaction manager. In the event that the output already existed but was not mined, the output is updated so its value reflects the block it was included in.

func (*Store) AddTicketCommitment 

func (s *Store) AddTicketCommitment(ns walletdb.ReadWriteBucket, rec *TxRecord,
	index, account uint32) error

AddTicketCommitment adds the given output of a transaction as a ticket commitment originating from a wallet account.

The transaction record MUST correspond to a ticket (sstx) transaction, the index MUST be from a commitment output and the account MUST be from a wallet-controlled account, otherwise the database will be put in an undefined state.

func (*Store) BlockInMainChain 

func (s *Store) BlockInMainChain(dbtx walletdb.ReadTx, blockHash *chainhash.Hash) (inMainChain bool, invalidated bool)

BlockInMainChain returns whether a block identified by its hash is in the current main chain and if so, whether it has been stake invalidated by the next main chain block.

func (*Store) CFilterV2 

func (s *Store) CFilterV2(dbtx walletdb.ReadTx, blockHash *chainhash.Hash) ([gcs2.KeySize]byte, *gcs2.FilterV2, error)

CFilterV2 returns the saved regular compact filter v2 for a block along with the key necessary to query it for matches.

func (*Store) ExistsTx 

func (s *Store) ExistsTx(ns walletdb.ReadBucket, txHash *chainhash.Hash) bool

ExistsTx checks to see if a transaction exists in the database.

func (*Store) ExistsTxMinedOrUnmined 

func (s *Store) ExistsTxMinedOrUnmined(ns walletdb.ReadBucket, txHash *chainhash.Hash) (mined, unmined bool)

ExistsTxMinedOrUnmined checks if a transaction is recorded as a mined or unmined transaction.

func (*Store) ExistsUTXO 

func (s *Store) ExistsUTXO(dbtx walletdb.ReadTx, op *wire.OutPoint) bool

ExistsUTXO checks to see if op refers to an unspent transaction output or a credit spent by an unmined transaction. This check is sufficient to determine whether a transaction input is relevant to the wallet by spending a UTXO or conflicting with another mempool transaction that double spends the output.

func (*Store) ExtendMainChain 

func (s *Store) ExtendMainChain(ns walletdb.ReadWriteBucket, header *wire.BlockHeader, blockHash *chainhash.Hash, f *gcs2.FilterV2) error

ExtendMainChain inserts a block header and compact filter into the database. It must connect to the existing tip block.

If the block is already inserted and part of the main chain, an errors.Exist error is returned.

The main chain tip may not be extended unless compact filters have been saved for all existing main chain blocks.

func (*Store) ForEachUnspentOutpoint 

func (s *Store) ForEachUnspentOutpoint(dbtx walletdb.ReadTx, f func(*wire.OutPoint) error) error

ForEachUnspentOutpoint calls f on each UTXO outpoint. The order is undefined.

func (*Store) GetBlockHeader 

func (s *Store) GetBlockHeader(dbtx walletdb.ReadTx, blockHash *chainhash.Hash) (*wire.BlockHeader, error)

GetBlockHeader returns the block header for the block specified by its hash.

func (*Store) GetBlockHeaderTime 

func (s *Store) GetBlockHeaderTime(dbtx walletdb.ReadTx, blockHash *chainhash.Hash) (int64, error)

GetBlockHeaderTime returns the timestamp field of the header for the block identified by its hash.

func (*Store) GetBlockMetaForHash 

func (s *Store) GetBlockMetaForHash(ns walletdb.ReadBucket, blockHash *chainhash.Hash) (BlockMeta, error)

GetBlockMetaForHash returns the BlockMeta for a block specified by its hash.

TODO: This is legacy code now that headers are saved. BlockMeta can be removed.

func (*Store) GetMainChainBlockHashForHeight 

func (s *Store) GetMainChainBlockHashForHeight(ns walletdb.ReadBucket, height int32) (chainhash.Hash, error)

GetMainChainBlockHashForHeight returns the block hash of the block on the main chain at a given height.

func (*Store) GetMainChainBlockHashes 

func (s *Store) GetMainChainBlockHashes(ns walletdb.ReadBucket, startHash *chainhash.Hash,
	inclusive bool, storage []chainhash.Hash) ([]chainhash.Hash, error)

GetMainChainBlockHashes returns block hashes from the main chain, starting at startHash, copying as many as possible into the storage slice and returning a subslice for the total number of results. If the start hash is not in the main chain, this function errors. If inclusive is true, the startHash is included in the results, otherwise only blocks after the startHash are included.

func (*Store) GetMainChainCFilters 

func (s *Store) GetMainChainCFilters(dbtx walletdb.ReadTx, startHash *chainhash.Hash, inclusive bool, storage []*BlockCFilter) ([]*BlockCFilter, error)

GetMainChainCFilters returns compact filters from the main chain, starting at startHash, copying as many as possible into the storage slice and returning a subslice for the total number of results. If the start hash is not in the main chain, this function errors. If inclusive is true, the startHash is included in the results, otherwise only blocks after the startHash are included.

func (*Store) GetMultisigOutput 

func (s *Store) GetMultisigOutput(ns walletdb.ReadBucket, op *wire.OutPoint) (*MultisigOut, error)

GetMultisigOutput takes an outpoint and returns multisignature credit data stored about it.

func (*Store) GetSerializedBlockHeader 

func (s *Store) GetSerializedBlockHeader(ns walletdb.ReadBucket, blockHash *chainhash.Hash) ([]byte, error)

GetSerializedBlockHeader returns the bytes of the serialized header for the block specified by its hash. These bytes are a copy of the value returned from the DB and are usable outside of the transaction.

func (*Store) ImportCFiltersV2 

func (s *Store) ImportCFiltersV2(dbtx walletdb.ReadWriteTx, startHeight int32, filterData [][]byte) error

ImportCFiltersV2 imports the given list of cfilters into the wallet, starting at the provided block height.

func (*Store) InsertMemPoolTx 

func (s *Store) InsertMemPoolTx(dbtx walletdb.ReadWriteTx, rec *TxRecord) error

InsertMemPoolTx inserts a memory pool transaction record. It also marks previous outputs referenced by its inputs as spent. Errors with the DoubleSpend code if another unmined transaction is a double spend of this transaction.

func (*Store) InsertMinedTx 

func (s *Store) InsertMinedTx(dbtx walletdb.ReadWriteTx, rec *TxRecord, blockHash *chainhash.Hash) error

InsertMinedTx inserts a new transaction record for a mined transaction into the database. The block header must have been previously saved. If the exact transaction is already saved as an unmined transaction, it is moved to a block. Other unmined transactions which become double spends are removed.

func (*Store) InsertMissingCFilters 

func (s *Store) InsertMissingCFilters(dbtx walletdb.ReadWriteTx, blockHashes []*chainhash.Hash, filters []*gcs2.FilterV2) error

InsertMissingCFilters records compact filters for each main chain block specified by blockHashes. This is used to add the additional required cfilters after upgrading a database to version TODO as recording cfilters becomes a required part of extending the main chain. This method may be called incrementally to record all main chain block cfilters. When all cfilters of the main chain are recorded, extending the main chain becomes possible again.

func (*Store) IsMissingMainChainCFilters 

func (s *Store) IsMissingMainChainCFilters(dbtx walletdb.ReadTx) bool

IsMissingMainChainCFilters returns whether all compact filters for main chain blocks have been recorded to the database after the upgrade which began to require them to extend the main chain. If compact filters are missing, they must be added using InsertMissingCFilters.

func (*Store) IsUnspentOutpoint 

func (s *Store) IsUnspentOutpoint(dbtx walletdb.ReadTx, op *wire.OutPoint) bool

IsUnspentOutpoint returns whether the outpoint is recorded as a wallet UTXO.

func (*Store) IterateTickets 

func (s *Store) IterateTickets(dbtx walletdb.ReadTx) *TicketIterator

IterateTickets returns an object used to iterate over all ticket purchase transactions.

func (*Store) MainChainTip 

func (s *Store) MainChainTip(dbtx walletdb.ReadTx) (chainhash.Hash, int32)

MainChainTip returns the hash and height of the currently marked tip-most block of the main chain.

func (*Store) MakeInputSource 

func (s *Store) MakeInputSource(dbtx walletdb.ReadTx, account uint32, minConf,
	syncHeight int32, ignore func(*wire.OutPoint) bool) InputSource

MakeInputSource creates an InputSource to redeem unspent outputs from an account. The minConf and syncHeight parameters are used to filter outputs based on some spendable policy. An ignore func is called to determine whether an output must be excluded from the source, and may be nil to ignore nothing.

func (*Store) MissingCFiltersHeight 

func (s *Store) MissingCFiltersHeight(dbtx walletdb.ReadTx) (int32, error)

MissingCFiltersHeight returns the first main chain block height with a missing cfilter. Errors with NotExist when all main chain blocks record cfilters.

func (*Store) OwnTicket 

func (s *Store) OwnTicket(dbtx walletdb.ReadTx, ticketHash *chainhash.Hash) bool

OwnTicket returns whether ticketHash is the hash of a ticket purchase transaction managed by the wallet.

func (*Store) PreviousPkScripts 

func (s *Store) PreviousPkScripts(ns walletdb.ReadBucket, rec *TxRecord, block *Block) ([][]byte, error)

PreviousPkScripts returns a slice of previous output scripts for each credit output this transaction record debits from.

func (*Store) ProcessedTxsBlockMarker 

func (s *Store) ProcessedTxsBlockMarker(dbtx walletdb.ReadTx) *chainhash.Hash

ProcessedTxsBlockMarker returns the hash of the block which records the last block after the genesis block which has been recorded as being processed for relevant transactions.

func (*Store) PruneUnmined 

func (s *Store) PruneUnmined(dbtx walletdb.ReadWriteTx, stakeDiff int64) ([]*chainhash.Hash, error)

PruneUnmined removes unmined transactions that no longer belong in the unmined tx set. This includes:

  • Any transactions past a set expiry
  • Ticket purchases with a different ticket price than the passed stake difficulty
  • Votes that do not vote on the tip block

func (*Store) RandomUTXO 

func (s *Store) RandomUTXO(dbtx walletdb.ReadTx, minConf, syncHeight int32) (*Credit, error)

RandomUTXO returns a random unspent Credit, or nil if none matching are found.

As an optimization to avoid reading all unspent outputs, this method is limited only to mined outputs, and minConf may not be zero.

func (*Store) RangeBlocks 

func (s *Store) RangeBlocks(ns walletdb.ReadBucket, begin, end int32,
	f func(*Block) (bool, error)) error

RangeBlocks execute function `f` for all blocks within the given range of blocks in the main chain.

func (*Store) RangeTransactions 

func (s *Store) RangeTransactions(ctx context.Context, ns walletdb.ReadBucket, begin, end int32,
	f func([]TxDetails) (bool, error)) error

RangeTransactions runs the function f on all transaction details between blocks on the best chain over the height range [begin,end]. The special height -1 may be used to also include unmined transactions. If the end height comes before the begin height, blocks are iterated in reverse order and unmined transactions (if any) are processed first.

The function f may return an error which, if non-nil, is propagated to the caller. Additionally, a boolean return value allows exiting the function early without reading any additional transactions early when true.

All calls to f are guaranteed to be passed a slice with more than zero elements. The slice may be reused for multiple blocks, so it is not safe to use it after the loop iteration it was acquired.

func (*Store) RedeemTicketCommitments 

func (s *Store) RedeemTicketCommitments(ns walletdb.ReadWriteBucket, rec *TxRecord,
	block *BlockMeta) error

RedeemTicketCommitments redeems the commitments of the given vote or revocation transaction by marking the commitments unminedSpent or removing them altogether.

rec MUST be either a vote (ssgen) or revocation (ssrtx) or this method fails.

func (*Store) RemoveUnconfirmed 

func (s *Store) RemoveUnconfirmed(ns walletdb.ReadWriteBucket, tx *wire.MsgTx, txHash *chainhash.Hash) error

RemoveUnconfirmed removes an unmined transaction record and all spend chains deriving from it from the store. This is designed to remove transactions that would otherwise result in double spend conflicts if left in the store, and to remove transactions that spend coinbase transactions on reorgs. It can also be used to remove old tickets that do not meet the network difficulty and expired transactions.

func (*Store) Rollback 

func (s *Store) Rollback(dbtx walletdb.ReadWriteTx, height int32) error

Rollback removes all blocks at height onwards, moving any transactions within each block to the unconfirmed pool.

func (*Store) SetPublished 

func (s *Store) SetPublished(dbtx walletdb.ReadWriteTx, txHash *chainhash.Hash, published bool) error

SetPublished modifies the published state of an unmined transaction.

func (*Store) SpendMultisigOut 

func (s *Store) SpendMultisigOut(ns walletdb.ReadWriteBucket, op *wire.OutPoint, spendHash chainhash.Hash, spendIndex uint32) error

SpendMultisigOut spends a multisignature output by making it spent in the general bucket and removing it from the unspent bucket.

func (*Store) Spender 

func (s *Store) Spender(dbtx walletdb.ReadTx, out *wire.OutPoint) (*wire.MsgTx, uint32, error)

Spender queries for the transaction and input index which spends a Credit. If the output is not a Credit, an error with code ErrInput is returned. If the output is unspent, the ErrNoExist code is used.

func (*Store) TicketDetails 

func (s *Store) TicketDetails(ns walletdb.ReadBucket, txDetails *TxDetails) (*TicketDetails, error)

TicketDetails looks up all recorded details regarding a ticket with some hash.

Not finding a ticket with this hash is not an error. In this case, a nil TicketDetails is returned.

func (*Store) Tx 

func (s *Store) Tx(ns walletdb.ReadBucket, txHash *chainhash.Hash) (*wire.MsgTx, error)

Tx looks up all the stored wire.MsgTx for a transaction with some hash. In case of a hash collision, the most recent transaction with a matching hash is returned.

func (*Store) TxBlockHeight 

func (s *Store) TxBlockHeight(dbtx walletdb.ReadTx, txHash *chainhash.Hash) (int32, error)

TxBlockHeight returns the block height of a mined transaction, or -1 for any unmined transactions.

func (*Store) TxDetails 

func (s *Store) TxDetails(ns walletdb.ReadBucket, txHash *chainhash.Hash) (*TxDetails, error)

TxDetails looks up all recorded details regarding a transaction with some hash. In case of a hash collision, the most recent transaction with a matching hash is returned.

func (*Store) UniqueTxDetails 

func (s *Store) UniqueTxDetails(ns walletdb.ReadBucket, txHash *chainhash.Hash,
	block *Block) (*TxDetails, error)

UniqueTxDetails looks up all recorded details for a transaction recorded mined in some particular block, or an unmined transaction if block is nil.

Not finding a transaction with this hash from this block is not an error. In this case, a nil TxDetails is returned.

func (*Store) UnminedTxHashes 

func (s *Store) UnminedTxHashes(ns walletdb.ReadBucket) ([]*chainhash.Hash, error)

UnminedTxHashes returns the hashes of all transactions not known to have been mined in a block.

func (*Store) UnminedTxs 

func (s *Store) UnminedTxs(dbtx walletdb.ReadTx) ([]*TxRecord, error)

UnminedTxs returns the transaction records for all unmined transactions which are not known to have been mined in a block. Transactions are guaranteed to be sorted by their dependency order.

func (*Store) UnspentMultisigCreditsForAddress 

func (s *Store) UnspentMultisigCreditsForAddress(dbtx walletdb.ReadTx, addr stdaddr.Address) ([]*MultisigCredit, error)

UnspentMultisigCreditsForAddress returns all unspent multisignature P2SH credits in the wallet for some specified address.

func (*Store) UnspentOutput 

func (s *Store) UnspentOutput(ns walletdb.ReadBucket, op wire.OutPoint, includeMempool bool) (*Credit, error)

UnspentOutput returns details for an unspent received transaction output. Returns error NotExist if the specified outpoint cannot be found or has been spent by a mined transaction. Mined transactions that are spent by a mempool transaction are not affected by this.

func (*Store) UnspentOutputCount 

func (s *Store) UnspentOutputCount(dbtx walletdb.ReadTx) int

UnspentOutputCount returns the number of mined unspent Credits (including those spent by unmined transactions).

func (*Store) UnspentOutputs 

func (s *Store) UnspentOutputs(dbtx walletdb.ReadTx) ([]*Credit, error)

UnspentOutputs returns all unspent received transaction outputs. The order is undefined.

func (*Store) UnspentTickets 

func (s *Store) UnspentTickets(dbtx walletdb.ReadTx, syncHeight int32, includeImmature bool) ([]chainhash.Hash, error)

UnspentTickets returns all unspent tickets that are known for this wallet. Tickets that have been spent by an unmined vote that is not a vote on the tip block are also considered unspent and are returned. The order of the hashes is undefined.

func (*Store) UpdateProcessedTxsBlockMarker 

func (s *Store) UpdateProcessedTxsBlockMarker(dbtx walletdb.ReadWriteTx, hash *chainhash.Hash) error

UpdateProcessedTxsBlockMarker updates the hash of the block recording the final block since the genesis block for which all transactions have been processed. Hash must describe a main chain block. This does not modify the database if hash has a lower block height than the main chain fork point of the existing marker.

type Ticket 

type Ticket struct {
	TxRecord
	Block       Block          // Height -1 if unmined
	SpenderHash chainhash.Hash // Zero value if unspent
}

Ticket embeds a TxRecord for a ticket purchase transaction, the block it is mined in (if any), and the transaction hash of the vote or revocation transaction that spends the ticket (if any).

type TicketDetails 

type TicketDetails struct {
	Ticket  *TxDetails
	Spender *TxDetails
}

TicketDetails is intended to provide callers with access to rich details regarding a relevant transaction and which inputs and outputs are credit or debits.

type TicketIterator 

type TicketIterator struct {
	Ticket
	// contains filtered or unexported fields
}

TicketIterator is used to iterate over all ticket purchase transactions.

func (*TicketIterator) Close 

func (it *TicketIterator) Close()

func (*TicketIterator) Err 

func (it *TicketIterator) Err() error

Err returns the final error state of the iterator. It should be checked after iteration completes when Next returns false.

func (*TicketIterator) Next 

func (it *TicketIterator) Next() bool

Next reads the next Ticket from the database, writing it to the iterator's embedded Ticket member. Returns false after all tickets have been iterated over or an error occurs.

type TicketStatus 

type TicketStatus uint8

TicketStatus is the current status of a stake pool ticket.

type TxDetails 

type TxDetails struct {
	TxRecord
	Block   BlockMeta
	Credits []CreditRecord
	Debits  []DebitRecord
}

TxDetails is intended to provide callers with access to rich details regarding a relevant transaction and which inputs and outputs are credit or debits.

func (*TxDetails) Height 

func (t *TxDetails) Height() int32

Height returns the height of a transaction according to the BlockMeta.

type TxRecord 

type TxRecord struct {
	MsgTx        wire.MsgTx
	Hash         chainhash.Hash
	Received     time.Time
	SerializedTx []byte // Optional: may be nil
	TxType       stake.TxType
	Unpublished  bool
}

TxRecord represents a transaction managed by the Store.

func NewTxRecord 

func NewTxRecord(serializedTx []byte, received time.Time) (*TxRecord, error)

NewTxRecord creates a new transaction record that may be inserted into the store. It uses memoization to save the transaction hash and the serialized transaction.

func NewTxRecordFromMsgTx 

func NewTxRecordFromMsgTx(msgTx *wire.MsgTx, received time.Time) (*TxRecord, error)

NewTxRecordFromMsgTx creates a new transaction record that may be inserted into the store.

type VSPHost 

type VSPHost struct {
	Host []byte
}

func GetVSPHost 

func GetVSPHost(dbtx walletdb.ReadTx, id uint32) (*VSPHost, error)

GetVSPHost gets a specific ticket by the id.

type VSPPubKey 

type VSPPubKey struct {
	ID     uint32
	PubKey []byte
}

func GetVSPPubKey 

func GetVSPPubKey(dbtx walletdb.ReadTx, host []byte) (*VSPPubKey, error)

GetVSPPubKey gets a specific ticket by the host.

type VSPTSpend 

type VSPTSpend struct {
	Ticket, TSpend chainhash.Hash
}

type VSPTicket 

type VSPTicket struct {
	FeeHash     chainhash.Hash
	FeeTxStatus uint32
	VSPHostID   uint32
	Host        string
	PubKey      []byte
}

func GetVSPTicket 

func GetVSPTicket(dbtx walletdb.ReadTx, tickethash chainhash.Hash) (*VSPTicket, error)

GetVSPTicket gets a specific ticket by its hash.

type VSPTreasuryKey 

type VSPTreasuryKey struct {
	Ticket      chainhash.Hash
	TreasuryKey string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.