Documentation ¶
Overview ¶
Package wallet provides ... TODO: Flesh out this section
Overview
Index ¶
- Constants
- Variables
- func Create(db DB, pubPass, privPass, seed []byte, params *chaincfg.Params) error
- func CreateWatchOnly(db DB, extendedPubKey string, pubPass []byte, params *chaincfg.Params) error
- func CurrentAgendas(params *chaincfg.Params) (version uint32, agendas []chaincfg.ConsensusDeployment)
- func DisableLog()
- func UnstableAPI(w *Wallet) unstableAPI
- func UseLogger(logger slog.Logger)
- func VerifyMessage(msg string, addr dcrutil.Address, sig []byte) (bool, error)
- type AccountBalance
- type AccountNotification
- type AccountNotificationsClient
- type AccountResult
- type AccountTotalReceivedResult
- type AccountsResult
- type AgendaChoice
- type Block
- type BlockIdentifier
- type BlockIdentity
- type BlockInfo
- type BlockNode
- type Config
- type ConfirmationNotification
- type ConfirmationNotificationsClient
- type CreatedTx
- type CreditCategory
- type DB
- type GetTicketsResult
- type GetTransactionsResult
- type MainTipChangedNotification
- type MainTipChangedNotificationsClient
- type MissingCFilterProgress
- type NetworkBackend
- type NextAddressCallOption
- type NotificationServer
- func (s *NotificationServer) AccountNotifications() AccountNotificationsClient
- func (s *NotificationServer) ConfirmationNotifications(ctx context.Context) *ConfirmationNotificationsClient
- func (s *NotificationServer) MainTipChangedNotifications() MainTipChangedNotificationsClient
- func (s *NotificationServer) TransactionNotifications() TransactionNotificationsClient
- type OutputInfo
- type OutputKind
- type OutputRedeemer
- type OutputSelectionAlgorithm
- type OutputSelectionPolicy
- type P2SHMultiSigOutput
- type Peer
- type RescanFilter
- func (f *RescanFilter) AddAddress(a dcrutil.Address)
- func (f *RescanFilter) AddUnspentOutPoint(op *wire.OutPoint)
- func (f *RescanFilter) ExistsAddress(a dcrutil.Address) (ok bool)
- func (f *RescanFilter) ExistsUnspentOutPoint(op *wire.OutPoint) bool
- func (f *RescanFilter) RemoveAddress(a dcrutil.Address)
- func (f *RescanFilter) RemoveUnspentOutPoint(op *wire.OutPoint)
- type RescanProgress
- type RescanSaver
- type SidechainForest
- type SignatureError
- type StakeDifficultyInfo
- type StakeInfoData
- type TicketStatus
- type TicketSummary
- type TransactionNotifications
- type TransactionNotificationsClient
- type TransactionOutput
- type TransactionSummary
- type TransactionSummaryInput
- type TransactionSummaryOutput
- type TransactionType
- type Wallet
- func (w *Wallet) AcceptMempoolTx(tx *wire.MsgTx) error
- func (w *Wallet) AccountBranchAddressRange(account, branch, start, end uint32) ([]dcrutil.Address, error)
- func (w *Wallet) AccountName(accountNumber uint32) (string, error)
- func (w *Wallet) AccountNumber(accountName string) (uint32, error)
- func (w *Wallet) AccountOfAddress(a dcrutil.Address) (uint32, error)
- func (w *Wallet) AccountProperties(acct uint32) (*udb.AccountProperties, error)
- func (w *Wallet) Accounts() (*AccountsResult, error)
- func (w *Wallet) AddTicket(ticket *wire.MsgTx) error
- func (w *Wallet) AddressInfo(a dcrutil.Address) (udb.ManagedAddress, error)
- func (w *Wallet) AgendaChoices() (choices []AgendaChoice, voteBits uint16, err error)
- func (w *Wallet) BIP0044BranchNextIndexes(account uint32) (extChild, intChild uint32, err error)
- func (w *Wallet) BalanceToMaintain() dcrutil.Amount
- func (w *Wallet) BlockHeader(blockHash *chainhash.Hash) (*wire.BlockHeader, error)
- func (w *Wallet) BlockInMainChain(hash *chainhash.Hash) (haveBlock, invalidated bool, err error)
- func (w *Wallet) BlockInfo(blockID *BlockIdentifier) (*BlockInfo, error)
- func (w *Wallet) BlockLocators(sidechain []*BlockNode) ([]*chainhash.Hash, error)
- func (w *Wallet) CFilter(blockHash *chainhash.Hash) (*gcs.Filter, error)
- func (w *Wallet) CalculateAccountBalance(account uint32, confirms int32) (udb.Balances, error)
- func (w *Wallet) CalculateAccountBalances(confirms int32) (map[uint32]*udb.Balances, error)
- func (w *Wallet) ChainParams() *chaincfg.Params
- func (w *Wallet) ChainSwitch(forest *SidechainForest, chain []*BlockNode, ...) ([]*BlockNode, error)
- func (w *Wallet) ChangePrivatePassphrase(old, new []byte) error
- func (w *Wallet) ChangePublicPassphrase(old, new []byte) error
- func (w *Wallet) CoinType() (uint32, error)
- func (w *Wallet) CommittedTickets(tickets []*chainhash.Hash) ([]*chainhash.Hash, []dcrutil.Address, error)
- func (w *Wallet) Consolidate(inputs int, account uint32, address dcrutil.Address) (*chainhash.Hash, error)
- func (w *Wallet) CreateMultisigTx(account uint32, amount dcrutil.Amount, pubkeys []*dcrutil.AddressSecpPubKey, ...) (*CreatedTx, dcrutil.Address, []byte, error)
- func (w *Wallet) CreateSignature(tx *wire.MsgTx, idx uint32, addr dcrutil.Address, ...) (sig, pubkey []byte, err error)
- func (w *Wallet) CurrentAddress(account uint32) (dcrutil.Address, error)
- func (w *Wallet) DiscoverActiveAddresses(ctx context.Context, p Peer, startBlock *chainhash.Hash, discoverAccts bool) error
- func (w *Wallet) DumpWIFPrivateKey(addr dcrutil.Address) (string, error)
- func (w *Wallet) EvaluateBestChain(f *SidechainForest) ([]*BlockNode, error)
- func (w *Wallet) ExtendWatchedAddresses(account, branch, child uint32) error
- func (w *Wallet) FetchAllRedeemScripts() ([][]byte, error)
- func (w *Wallet) FetchHeaders(ctx context.Context, p Peer) (count int, rescanFrom chainhash.Hash, rescanFromHeight int32, ...)
- func (w *Wallet) FetchMissingCFilters(ctx context.Context, p Peer) error
- func (w *Wallet) FetchMissingCFiltersWithProgress(ctx context.Context, p Peer, progress chan<- MissingCFilterProgress)
- func (w *Wallet) FetchOutput(outPoint *wire.OutPoint) (*wire.TxOut, error)
- func (w *Wallet) FetchP2SHMultiSigOutput(outPoint *wire.OutPoint) (*P2SHMultiSigOutput, error)
- func (w *Wallet) FindEligibleOutputs(account uint32, minconf int32, currentHeight int32) ([]udb.Credit, error)
- func (w *Wallet) GenerateVoteTx(blockHash *chainhash.Hash, height int32, ticketHash *chainhash.Hash, ...) (*wire.MsgTx, error)
- func (w *Wallet) GetTicketInfo(hash *chainhash.Hash) (*TicketSummary, *wire.BlockHeader, error)
- func (w *Wallet) GetTicketInfoPrecise(chainClient *dcrrpcclient.Client, hash *chainhash.Hash) (*TicketSummary, *wire.BlockHeader, error)
- func (w *Wallet) GetTickets(f func([]*TicketSummary, *wire.BlockHeader) (bool, error), ...) error
- func (w *Wallet) GetTicketsPrecise(f func([]*TicketSummary, *wire.BlockHeader) (bool, error), ...) error
- func (w *Wallet) GetTransactions(f func(*Block) (bool, error), startBlock, endBlock *BlockIdentifier) error
- func (w *Wallet) GetTransactionsByHashes(txHashes []*chainhash.Hash) (txs []*wire.MsgTx, notFound []*wire.InvVect, err error)
- func (w *Wallet) HaveAddress(a dcrutil.Address) (bool, error)
- func (w *Wallet) ImportP2SHRedeemScript(script []byte) (*dcrutil.AddressScriptHash, error)
- func (w *Wallet) ImportPrivateKey(wif *dcrutil.WIF) (string, error)
- func (w *Wallet) ImportScript(rs []byte) error
- func (w *Wallet) ListAddressTransactions(pkHashes map[string]struct{}) ([]dcrjson.ListTransactionsResult, error)
- func (w *Wallet) ListAllTransactions() ([]dcrjson.ListTransactionsResult, error)
- func (w *Wallet) ListSinceBlock(start, end, syncHeight int32) ([]dcrjson.ListTransactionsResult, error)
- func (w *Wallet) ListTransactionDetails(txHash *chainhash.Hash) ([]dcrjson.ListTransactionsResult, error)
- func (w *Wallet) ListTransactions(from, count int) ([]dcrjson.ListTransactionsResult, error)
- func (w *Wallet) ListUnspent(minconf, maxconf int32, addresses map[string]struct{}) ([]*dcrjson.ListUnspentResult, error)
- func (w *Wallet) LiveTicketHashes(chainClient *dcrrpcclient.Client, includeImmature bool) ([]chainhash.Hash, error)
- func (w *Wallet) LoadActiveDataFilters(ctx context.Context, n NetworkBackend, reload bool) error
- func (w *Wallet) Lock()
- func (w *Wallet) LockOutpoint(op wire.OutPoint)
- func (w *Wallet) Locked() bool
- func (w *Wallet) LockedOutpoint(op wire.OutPoint) bool
- func (w *Wallet) LockedOutpoints() []dcrjson.TransactionInput
- func (w *Wallet) MainChainTip() (hash chainhash.Hash, height int32)
- func (w *Wallet) MakeSecp256k1MultiSigScript(secp256k1Addrs []dcrutil.Address, nRequired int) ([]byte, error)
- func (w *Wallet) MasterPubKey(account uint32) (*hdkeychain.ExtendedKey, error)
- func (w *Wallet) NeedsAccountsSync() (bool, error)
- func (w *Wallet) NetworkBackend() (NetworkBackend, error)
- func (w *Wallet) NewChangeAddress(account uint32) (dcrutil.Address, error)
- func (w *Wallet) NewExternalAddress(account uint32, callOpts ...NextAddressCallOption) (dcrutil.Address, error)
- func (w *Wallet) NewInternalAddress(account uint32, callOpts ...NextAddressCallOption) (dcrutil.Address, error)
- func (w *Wallet) NewUnsignedTransaction(outputs []*wire.TxOut, relayFeePerKb dcrutil.Amount, account uint32, ...) (*txauthor.AuthoredTx, error)
- func (w *Wallet) NextAccount(name string) (uint32, error)
- func (w *Wallet) NextStakeDifficulty() (dcrutil.Amount, error)
- func (w *Wallet) NextStakeDifficultyAfterHeader(h *wire.BlockHeader) (dcrutil.Amount, error)
- func (w *Wallet) OutputInfo(out *wire.OutPoint) (OutputInfo, error)
- func (w *Wallet) PoolAddress() dcrutil.Address
- func (w *Wallet) PoolFees() float64
- func (w *Wallet) PrepareRedeemMultiSigOutTxOutput(msgTx *wire.MsgTx, p2shOutput *P2SHMultiSigOutput, pkScript *[]byte) error
- func (w *Wallet) PubKeyForAddress(a dcrutil.Address) (chainec.PublicKey, error)
- func (w *Wallet) PublishTransaction(tx *wire.MsgTx, serializedTx []byte, n NetworkBackend) (*chainhash.Hash, error)
- func (w *Wallet) PublishUnminedTransactions(ctx context.Context, p Peer) error
- func (w *Wallet) PurchaseTickets(minBalance, spendLimit dcrutil.Amount, minConf int32, ...) ([]*chainhash.Hash, error)
- func (w *Wallet) PurgeUnminedTransaction(hash *chainhash.Hash) error
- func (w *Wallet) RedeemScriptCopy(addr dcrutil.Address) ([]byte, error)
- func (w *Wallet) RelayFee() dcrutil.Amount
- func (w *Wallet) RenameAccount(account uint32, newName string) error
- func (w *Wallet) Rescan(ctx context.Context, n NetworkBackend, startHash *chainhash.Hash) error
- func (w *Wallet) RescanFromHeight(ctx context.Context, n NetworkBackend, startHeight int32) error
- func (w *Wallet) RescanPoint() (*chainhash.Hash, error)
- func (w *Wallet) RescanProgressFromHeight(ctx context.Context, n NetworkBackend, startHeight int32, ...)
- func (w *Wallet) ResetLockedOutpoints()
- func (w *Wallet) RevokeExpiredTickets(ctx context.Context, p Peer) (err error)
- func (w *Wallet) RevokeOwnedTickets(missedTicketHashes []*chainhash.Hash) error
- func (w *Wallet) RevokeTickets(chainClient *dcrrpcclient.Client) error
- func (w *Wallet) SaveRescanned(hash *chainhash.Hash, txs []*wire.MsgTx) error
- func (w *Wallet) SelectInputs(targetAmount dcrutil.Amount, policy OutputSelectionPolicy) (inputDetail *txauthor.InputDetail, err error)
- func (w *Wallet) SendOutputs(outputs []*wire.TxOut, account uint32, minconf int32) (*chainhash.Hash, error)
- func (w *Wallet) SetAgendaChoices(choices ...AgendaChoice) (voteBits uint16, err error)
- func (w *Wallet) SetBalanceToMaintain(balance dcrutil.Amount)
- func (w *Wallet) SetNetworkBackend(n NetworkBackend)
- func (w *Wallet) SetRelayFee(relayFee dcrutil.Amount)
- func (w *Wallet) SetTicketFeeIncrement(fee dcrutil.Amount)
- func (w *Wallet) SignMessage(msg string, addr dcrutil.Address) (sig []byte, err error)
- func (w *Wallet) SignTransaction(tx *wire.MsgTx, hashType txscript.SigHashType, ...) ([]SignatureError, error)
- func (w *Wallet) SortedActivePaymentAddresses() ([]string, error)
- func (w *Wallet) StakeInfo() (*StakeInfoData, error)
- func (w *Wallet) StakeInfoPrecise(chainClient *dcrrpcclient.Client) (*StakeInfoData, error)
- func (w *Wallet) StakePoolUserInfo(userAddress dcrutil.Address) (*udb.StakePoolUser, error)
- func (w *Wallet) Start()
- func (w *Wallet) Stop()
- func (w *Wallet) TicketAddress() dcrutil.Address
- func (w *Wallet) TicketFeeIncrement() dcrutil.Amount
- func (w *Wallet) TicketHashesForVotingAddress(votingAddr dcrutil.Address) ([]chainhash.Hash, error)
- func (w *Wallet) TotalReceivedForAccounts(minConf int32) ([]AccountTotalReceivedResult, error)
- func (w *Wallet) TotalReceivedForAddr(addr dcrutil.Address, minConf int32) (dcrutil.Amount, error)
- func (w *Wallet) TransactionSummary(txHash *chainhash.Hash) (txSummary *TransactionSummary, confs int32, blockHash *chainhash.Hash, ...)
- func (w *Wallet) Unlock(passphrase []byte, lock <-chan time.Time) error
- func (w *Wallet) UnlockOutpoint(op wire.OutPoint)
- func (w *Wallet) UnminedTransactions() ([]*wire.MsgTx, error)
- func (w *Wallet) UnspentOutputs(policy OutputSelectionPolicy) ([]*TransactionOutput, error)
- func (w *Wallet) UpgradeToSLIP0044CoinType() error
- func (w *Wallet) ValidateHeaderChainDifficulties(chain []*BlockNode, idx int) ([]*BlockNode, error)
- func (w *Wallet) VoteBits() stake.VoteBits
- func (w *Wallet) VoteOnOwnedTickets(winningTicketHashes []*chainhash.Hash, blockHash *chainhash.Hash, ...) error
- func (w *Wallet) VotingEnabled() bool
- func (w *Wallet) WaitForShutdown()
Constants ¶
const ( // OutputSelectionAlgorithmDefault describes the default output selection // algorithm. It is not optimized for any particular use case. OutputSelectionAlgorithmDefault = iota // OutputSelectionAlgorithmAll describes the output selection algorithm of // picking every possible availble output. This is useful for sweeping. OutputSelectionAlgorithmAll )
const DefaultAccountGapLimit = 10
DefaultAccountGapLimit is the default number of accounts that can be created in a row without using any of them
const DefaultGapLimit = 20
DefaultGapLimit is the default unused address gap limit defined by BIP0044.
const ( // InsecurePubPassphrase is the default outer encryption passphrase used // for public data (everything but private keys). Using a non-default // public passphrase can prevent an attacker without the public // passphrase from discovering all past and future wallet addresses if // they gain access to the wallet database. // // NOTE: at time of writing, public encryption only applies to public // data in the waddrmgr namespace. Transactions are not yet encrypted. InsecurePubPassphrase = "public" )
Variables ¶
var ( // SimulationPassphrase is the password for a wallet created for simnet // with --createtemp. SimulationPassphrase = []byte("password") )
Functions ¶
func Create ¶
Create creates an new wallet, writing it to an empty database. If the passed seed is non-nil, it is used. Otherwise, a secure random seed of the recommended length is generated.
func CreateWatchOnly ¶
CreateWatchOnly creates a watchonly wallet on the provided db.
func CurrentAgendas ¶
func CurrentAgendas(params *chaincfg.Params) (version uint32, agendas []chaincfg.ConsensusDeployment)
CurrentAgendas returns the current stake version for the active network and this version of the software, and all agendas defined by it.
func DisableLog ¶
func DisableLog()
DisableLog disables all library log output. Logging output is disabled by default until either UseLogger or SetLogWriter are called.
func UnstableAPI ¶
func UnstableAPI(w *Wallet) unstableAPI
UnstableAPI exposes additional unstable public APIs for a Wallet. These APIs may be changed or removed at any time. Currently this type exists to ease the transation (particularly for the legacy JSON-RPC server) from using exported manager packages to a unified wallet package that exposes all functionality by itself. New code should not be written using this API.
Types ¶
type AccountBalance ¶
AccountBalance associates a total (zero confirmation) balance with an account. Balances for other minimum confirmation counts require more expensive logic and it is not clear which minimums a client is interested in, so they are not included.
type AccountNotification ¶
type AccountNotification struct { AccountNumber uint32 AccountName string ExternalKeyCount uint32 InternalKeyCount uint32 ImportedKeyCount uint32 }
AccountNotification contains properties regarding an account, such as its name and the number of derived and imported keys. When any of these properties change, the notification is fired.
type AccountNotificationsClient ¶
type AccountNotificationsClient struct { C chan *AccountNotification // contains filtered or unexported fields }
AccountNotificationsClient receives AccountNotifications over the channel C.
func (*AccountNotificationsClient) Done ¶
func (c *AccountNotificationsClient) Done()
Done deregisters the client from the server and drains any remaining messages. It must be called exactly once when the client is finished receiving notifications.
type AccountResult ¶
type AccountResult struct { udb.AccountProperties TotalBalance dcrutil.Amount }
AccountResult is a single account result for the AccountsResult type.
type AccountTotalReceivedResult ¶
type AccountTotalReceivedResult struct { AccountNumber uint32 AccountName string TotalReceived dcrutil.Amount LastConfirmation int32 }
AccountTotalReceivedResult is a single result for the Wallet.TotalReceivedForAccounts method.
type AccountsResult ¶
type AccountsResult struct { Accounts []AccountResult CurrentBlockHash *chainhash.Hash CurrentBlockHeight int32 }
AccountsResult is the resutl of the wallet's Accounts method. See that method for more details.
type AgendaChoice ¶
AgendaChoice describes a user's choice for a consensus deployment agenda.
type Block ¶
type Block struct { Header *wire.BlockHeader // Nil if referring to mempool Transactions []TransactionSummary }
Block contains the properties and all relevant transactions of an attached block.
type BlockIdentifier ¶
type BlockIdentifier struct {
// contains filtered or unexported fields
}
BlockIdentifier identifies a block by either a height in the main chain or a hash.
func NewBlockIdentifierFromHash ¶
func NewBlockIdentifierFromHash(hash *chainhash.Hash) *BlockIdentifier
NewBlockIdentifierFromHash constructs a BlockIdentifier for a block hash.
func NewBlockIdentifierFromHeight ¶
func NewBlockIdentifierFromHeight(height int32) *BlockIdentifier
NewBlockIdentifierFromHeight constructs a BlockIdentifier for a block height.
type BlockIdentity ¶
BlockIdentity identifies a block, or the lack of one (used to describe an unmined transaction).
func (*BlockIdentity) None ¶
func (b *BlockIdentity) None() bool
None returns whether there is no block described by the instance. When associated with a transaction, this indicates the transaction is unmined.
type BlockInfo ¶
type BlockInfo struct { Hash chainhash.Hash Height int32 Confirmations int32 Header []byte Timestamp int64 StakeInvalidated bool }
BlockInfo records info pertaining to a block. It does not include any information about wallet transactions contained in the block.
type BlockNode ¶
type BlockNode struct { Header *wire.BlockHeader Hash *chainhash.Hash Filter *gcs.Filter // contains filtered or unexported fields }
BlockNode represents a block node for a SidechainForest. BlockNodes are not safe for concurrent access, and all exported fields must be treated as immutable.
func NewBlockNode ¶
NewBlockNode creates a block node for usage with a SidechainForest.
type Config ¶
type Config struct { DB DB PubPassphrase []byte VotingEnabled bool AddressReuse bool VotingAddress dcrutil.Address PoolAddress dcrutil.Address PoolFees float64 TicketFee float64 GapLimit int AccountGapLimit int DisableCoinTypeUpgrades bool StakePoolColdExtKey string AllowHighFees bool RelayFee float64 Params *chaincfg.Params }
Config represents the configuration options needed to initialize a wallet.
type ConfirmationNotification ¶
type ConfirmationNotification struct { TxHash *chainhash.Hash Confirmations int32 BlockHash *chainhash.Hash // nil when unmined BlockHeight int32 // -1 when unmined }
ConfirmationNotification describes the number of confirmations of a single transaction, or -1 if the transaction is unknown or removed from the wallet. If the transaction is mined (Confirmations >= 1), the block hash and height is included. Otherwise the block hash is nil and the block height is set to -1.
type ConfirmationNotificationsClient ¶
type ConfirmationNotificationsClient struct {
// contains filtered or unexported fields
}
ConfirmationNotificationsClient provides confirmation notifications of watched transactions until the caller's context signals done. Callers register for notifications using Watch and receive notifications by calling Recv.
func (*ConfirmationNotificationsClient) Recv ¶
func (c *ConfirmationNotificationsClient) Recv() ([]ConfirmationNotification, error)
Recv waits for the next notification. Returns context.Canceled when the context is canceled.
func (*ConfirmationNotificationsClient) Watch ¶
func (c *ConfirmationNotificationsClient) Watch(txHashes []*chainhash.Hash, stopAfter int32)
Watch adds additional transactions to watch and create confirmation results for. Results are immediately created with the current number of confirmations and are watched until stopAfter confirmations is met or the transaction is unknown or removed from the wallet.
type CreatedTx ¶
type CreatedTx struct { MsgTx *wire.MsgTx ChangeAddr dcrutil.Address ChangeIndex int // negative if no change Fee dcrutil.Amount }
CreatedTx holds the state of a newly-created transaction and the change output (if one was added).
type CreditCategory ¶
type CreditCategory byte
CreditCategory describes the type of wallet transaction output. The category of "sent transactions" (debits) is always "send", and is not expressed by this type.
TODO: This is a requirement of the RPC server and should be moved.
const ( CreditReceive CreditCategory = iota CreditGenerate CreditImmature )
These constants define the possible credit categories.
func RecvCategory ¶
func RecvCategory(details *udb.TxDetails, syncHeight int32, chainParams *chaincfg.Params) CreditCategory
RecvCategory returns the category of received credit outputs from a transaction record. The passed block chain height is used to distinguish immature from mature coinbase outputs.
TODO: This is intended for use by the RPC server and should be moved out of this package at a later time.
func (CreditCategory) String ¶
func (c CreditCategory) String() string
String returns the category as a string. This string may be used as the JSON string for categories as part of listtransactions and gettransaction RPC responses.
type DB ¶
DB represents an ACID database for a wallet.
type GetTicketsResult ¶
type GetTicketsResult struct {
Tickets []*TicketSummary
}
GetTicketsResult response struct for gettickets rpc request
type GetTransactionsResult ¶
type GetTransactionsResult struct { MinedTransactions []Block UnminedTransactions []TransactionSummary }
GetTransactionsResult is the result of the wallet's GetTransactions method. See GetTransactions for more details.
type MainTipChangedNotification ¶
type MainTipChangedNotification struct { AttachedBlocks []*chainhash.Hash DetachedBlocks []*chainhash.Hash NewHeight int32 }
MainTipChangedNotification describes processed changes to the main chain tip block. Attached and detached blocks are sorted by increasing heights.
This is intended to be a lightweight alternative to TransactionNotifications when only info regarding the main chain tip block changing is needed.
type MainTipChangedNotificationsClient ¶
type MainTipChangedNotificationsClient struct { C chan *MainTipChangedNotification // contains filtered or unexported fields }
MainTipChangedNotificationsClient receives MainTipChangedNotifications over the channel C.
func (*MainTipChangedNotificationsClient) Done ¶
func (c *MainTipChangedNotificationsClient) Done()
Done deregisters the client from the server and drains any remaining messages. It must be called exactly once when the client is finished receiving notifications.
type MissingCFilterProgress ¶ added in v1.1.0
MissingCFilterProgress records the first and last height of the progress that was received and any errors that were received during the fetching.
type NetworkBackend ¶
type NetworkBackend interface { Peer LoadTxFilter(ctx context.Context, reload bool, addrs []dcrutil.Address, outpoints []wire.OutPoint) error Rescan(ctx context.Context, blocks []chainhash.Hash, r RescanSaver) error // This is impossible to determine over the wire protocol, and will always // error. Use Wallet.NextStakeDifficulty to calculate the next ticket price // when the DCP0001 deployment is known to be active. StakeDifficulty(ctx context.Context) (dcrutil.Amount, error) }
NetworkBackend provides wallets with Decred network functionality. Some wallet operations require the wallet to be associated with a network backend to complete.
NetworkBackend expands on the Peer interface to provide additional functionality for rescanning and filtering.
type NextAddressCallOption ¶
type NextAddressCallOption func(*nextAddressCallOptions)
NextAddressCallOption defines a call option for the NextAddress family of wallet methods.
func WithGapPolicyError ¶
func WithGapPolicyError() NextAddressCallOption
WithGapPolicyError configures the NextAddress family of methods to error whenever the gap limit would be exceeded. When this default policy is used, callers should check errors against the GapLimit error code and let users specify whether to ignore the gap limit or wrap around to a previously returned address.
func WithGapPolicyIgnore ¶
func WithGapPolicyIgnore() NextAddressCallOption
WithGapPolicyIgnore configures the NextAddress family of methods to ignore the gap limit entirely when generating addresses. Exceeding the gap limit may result in unsynced address child indexes when seed restoring the wallet, unless the restoring gap limit is increased, as well as breaking automatic address synchronization of multiple running wallets.
This is a good policy to use when addresses must never be reused, but be aware of the issues noted above.
func WithGapPolicyWrap ¶
func WithGapPolicyWrap() NextAddressCallOption
WithGapPolicyWrap configures the NextAddress family of methods to wrap around to a previously returned address instead of erroring or ignoring the gap limit and returning a new unused address.
This is a good policy to use for most individual users' wallets where funds are segmented by accounts and not the addresses that control each output.
type NotificationServer ¶
type NotificationServer struct {
// contains filtered or unexported fields
}
NotificationServer is a server that interested clients may hook into to receive notifications of changes in a wallet. A client is created for each registered notification. Clients are guaranteed to receive messages in the order wallet created them, but there is no guaranteed synchronization between different clients.
func (*NotificationServer) AccountNotifications ¶
func (s *NotificationServer) AccountNotifications() AccountNotificationsClient
AccountNotifications returns a client for receiving AccountNotifications over a channel. The channel is unbuffered. When finished, the client's Done method should be called to disassociate the client from the server.
func (*NotificationServer) ConfirmationNotifications ¶
func (s *NotificationServer) ConfirmationNotifications(ctx context.Context) *ConfirmationNotificationsClient
ConfirmationNotifications registers a client for confirmation notifications from the notification server.
func (*NotificationServer) MainTipChangedNotifications ¶
func (s *NotificationServer) MainTipChangedNotifications() MainTipChangedNotificationsClient
MainTipChangedNotifications returns a client for receiving MainTipChangedNotification over a channel. The channel is unbuffered. When finished, the client's Done method should be called to disassociate the client from the server.
func (*NotificationServer) TransactionNotifications ¶
func (s *NotificationServer) TransactionNotifications() TransactionNotificationsClient
TransactionNotifications returns a client for receiving TransactionNotifiations notifications over a channel. The channel is unbuffered.
When finished, the Done method should be called on the client to disassociate it from the server.
type OutputInfo ¶
OutputInfo describes additional info about an output which can be queried using an outpoint.
type OutputKind ¶
type OutputKind byte
OutputKind describes a kind of transaction output. This is used to differentiate between coinbase, stakebase, and normal outputs.
const ( OutputKindNormal OutputKind = iota OutputKindCoinbase OutputKindStakebase // not returned by all APIs yet )
Defined OutputKind constants
type OutputRedeemer ¶
OutputRedeemer identifies the transaction input which redeems an output.
type OutputSelectionAlgorithm ¶
type OutputSelectionAlgorithm uint
OutputSelectionAlgorithm specifies the algorithm to use when selecting outputs to construct a transaction.
type OutputSelectionPolicy ¶
OutputSelectionPolicy describes the rules for selecting an output from the wallet.
type P2SHMultiSigOutput ¶
type P2SHMultiSigOutput struct { // TODO: Add a TransactionOutput member to this struct and remove these // fields which are duplicated by it. This improves consistency. Only // not done now because wtxmgr APIs don't support an efficient way of // fetching other Transactionoutput data together with the rest of the // multisig info. OutPoint wire.OutPoint OutputAmount dcrutil.Amount ContainingBlock BlockIdentity P2SHAddress *dcrutil.AddressScriptHash RedeemScript []byte M, N uint8 // M of N signatures required to redeem Redeemer *OutputRedeemer // nil unless spent }
P2SHMultiSigOutput describes a transaction output with a pay-to-script-hash output script and an imported redemption script. Along with common details of the output, this structure also includes the P2SH address the script was created from and the number of signatures required to redeem it.
TODO: Could be useful to return how many of the required signatures can be created by this wallet.
type Peer ¶
type Peer interface { GetBlocks(ctx context.Context, blockHashes []*chainhash.Hash) ([]*wire.MsgBlock, error) GetCFilters(ctx context.Context, blockHashes []*chainhash.Hash) ([]*gcs.Filter, error) GetHeaders(ctx context.Context, blockLocators []*chainhash.Hash, hashStop *chainhash.Hash) ([]*wire.BlockHeader, error) PublishTransactions(ctx context.Context, txs ...*wire.MsgTx) error }
Peer provides wallets with a subset of Decred network functionality available to a single peer.
type RescanFilter ¶
type RescanFilter struct {
// contains filtered or unexported fields
}
RescanFilter implements a precise filter intended to hold all watched wallet data in memory such as addresses and unspent outputs. The zero value is not valid, and filters must be created using NewRescanFilter. RescanFilter is not safe for concurrent access.
func NewRescanFilter ¶
func NewRescanFilter(addresses []dcrutil.Address, unspentOutPoints []*wire.OutPoint) *RescanFilter
NewRescanFilter creates and initializes a RescanFilter containing each passed address and outpoint.
func (*RescanFilter) AddAddress ¶
func (f *RescanFilter) AddAddress(a dcrutil.Address)
AddAddress adds an address to the filter if it does not already exist.
func (*RescanFilter) AddUnspentOutPoint ¶
func (f *RescanFilter) AddUnspentOutPoint(op *wire.OutPoint)
AddUnspentOutPoint adds an outpoint to the filter if it does not already exist.
func (*RescanFilter) ExistsAddress ¶
func (f *RescanFilter) ExistsAddress(a dcrutil.Address) (ok bool)
ExistsAddress returns whether an address is contained in the filter.
func (*RescanFilter) ExistsUnspentOutPoint ¶
func (f *RescanFilter) ExistsUnspentOutPoint(op *wire.OutPoint) bool
ExistsUnspentOutPoint returns whether an outpoint is contained in the filter.
func (*RescanFilter) RemoveAddress ¶
func (f *RescanFilter) RemoveAddress(a dcrutil.Address)
RemoveAddress removes an address from the filter if it exists.
func (*RescanFilter) RemoveUnspentOutPoint ¶
func (f *RescanFilter) RemoveUnspentOutPoint(op *wire.OutPoint)
RemoveUnspentOutPoint removes an outpoint from the filter if it exists.
type RescanProgress ¶
RescanProgress records the height the rescan has completed through and any errors during processing of the rescan.
type RescanSaver ¶
RescanSaver records transactions from a rescaned block.
type SidechainForest ¶
type SidechainForest struct {
// contains filtered or unexported fields
}
SidechainForest provides in-memory management of sidechain and orphan blocks. It implements a forest of disjoint rooted trees, each tree containing sidechains stemming from a different fork point in the main chain, or orphans.
SidechainForest is not safe for concurrent access.
func (*SidechainForest) AddBlockNode ¶
func (f *SidechainForest) AddBlockNode(n *BlockNode) bool
AddBlockNode adds a sidechain block node to the forest. The node may either begin a new sidechain, extend an existing sidechain, or start or extend a tree of orphan blocks. Adding the parent node of a previously-saved orphan block will restructure the forest by re-rooting the previous orphan tree onto the tree containing the added node. Returns true iff the node if the node was not a duplicate.
func (*SidechainForest) Prune ¶
func (f *SidechainForest) Prune(mainChainHeight int32, params *chaincfg.Params)
Prune removes any sidechain trees which contain a root that is significantly behind the current main chain tip block.
func (*SidechainForest) PruneTree ¶
func (f *SidechainForest) PruneTree(root *chainhash.Hash)
PruneTree removes the tree beginning with root from the forest.
type SignatureError ¶
SignatureError records the underlying error when validating a transaction input signature.
type StakeDifficultyInfo ¶
type StakeDifficultyInfo struct { BlockHash *chainhash.Hash BlockHeight int64 StakeDifficulty int64 }
StakeDifficultyInfo is a container for stake difficulty information updates.
type StakeInfoData ¶
type StakeInfoData struct { BlockHeight int64 TotalSubsidy dcrutil.Amount Sdiff dcrutil.Amount OwnMempoolTix uint32 Unspent uint32 Voted uint32 Revoked uint32 UnspentExpired uint32 PoolSize uint32 AllMempoolTix uint32 Immature uint32 Live uint32 Missed uint32 Expired uint32 }
StakeInfoData carries counts of ticket states and other various stake data.
type TicketStatus ¶
type TicketStatus int8
TicketStatus describes the current status a ticket can be observed to be.
const ( // TicketStatusUnknown any ticket that its status was unable to be determined. TicketStatusUnknown TicketStatus = iota // TicketStatusUnmined any not yet mined ticket. TicketStatusUnmined // TicketStatusImmature any so to be live ticket. TicketStatusImmature // TicketStatusLive any currently live ticket. TicketStatusLive // TicketStatusVoted any ticket that was seen to have voted. TicketStatusVoted // TicketStatusRevoked any ticket that has been previously revoked. TicketStatusRevoked // TicketStatusMissed any ticket that has yet to be revoked, and was missed. TicketStatusMissed // TicketStatusExpired any ticket that has yet to be revoked, and was expired. TicketStatusExpired )
type TicketSummary ¶
type TicketSummary struct { Ticket *TransactionSummary Spender *TransactionSummary Status TicketStatus }
TicketSummary contains the properties to describe a ticket's current status
type TransactionNotifications ¶
type TransactionNotifications struct { AttachedBlocks []Block DetachedBlocks []*chainhash.Hash UnminedTransactions []TransactionSummary UnminedTransactionHashes []*chainhash.Hash NewBalances []AccountBalance }
TransactionNotifications is a notification of changes to the wallet's transaction set and the current chain tip that wallet is considered to be synced with. All transactions added to the blockchain are organized by the block they were mined in.
During a chain switch, all removed block hashes are included. Detached blocks are sorted in the reverse order they were mined. Attached blocks are sorted in the order mined.
All newly added unmined transactions are included. Removed unmined transactions are not explicitly included. Instead, the hashes of all transactions still unmined are included.
If any transactions were involved, each affected account's new total balance is included.
TODO: Because this includes stuff about blocks and can be fired without any changes to transactions, it needs a better name.
type TransactionNotificationsClient ¶
type TransactionNotificationsClient struct { C <-chan *TransactionNotifications // contains filtered or unexported fields }
TransactionNotificationsClient receives TransactionNotifications from the NotificationServer over the channel C.
func (*TransactionNotificationsClient) Done ¶
func (c *TransactionNotificationsClient) Done()
Done deregisters the client from the server and drains any remaining messages. It must be called exactly once when the client is finished receiving notifications.
type TransactionOutput ¶
type TransactionOutput struct { OutPoint wire.OutPoint Output wire.TxOut OutputKind OutputKind // These should be added later when the DB can return them more // efficiently: //TxLockTime uint32 //TxExpiry uint32 ContainingBlock BlockIdentity ReceiveTime time.Time }
TransactionOutput describes an output that was or is at least partially controlled by the wallet. Depending on context, this could refer to an unspent output, or a spent one.
type TransactionSummary ¶
type TransactionSummary struct { Hash *chainhash.Hash Transaction []byte MyInputs []TransactionSummaryInput MyOutputs []TransactionSummaryOutput Fee dcrutil.Amount Timestamp int64 Type TransactionType }
TransactionSummary contains a transaction relevant to the wallet and marks which inputs and outputs were relevant.
type TransactionSummaryInput ¶
type TransactionSummaryInput struct { Index uint32 PreviousAccount uint32 PreviousAmount dcrutil.Amount }
TransactionSummaryInput describes a transaction input that is relevant to the wallet. The Index field marks the transaction input index of the transaction (not included here). The PreviousAccount and PreviousAmount fields describe how much this input debits from a wallet account.
type TransactionSummaryOutput ¶
type TransactionSummaryOutput struct { Index uint32 Account uint32 Internal bool Amount dcrutil.Amount Address dcrutil.Address OutputScript []byte }
TransactionSummaryOutput describes wallet properties of a transaction output controlled by the wallet. The Index field marks the transaction output index of the transaction (not included here).
type TransactionType ¶
type TransactionType int8
TransactionType describes the which type of transaction is has been observed to be. For instance, if it has a ticket as an input and a stake base reward as an ouput, it is known to be a vote.
const ( // TransactionTypeRegular transaction type for all regular transactions. TransactionTypeRegular TransactionType = iota // TransactionTypeCoinbase is the transaction type for all coinbase transactions. TransactionTypeCoinbase // TransactionTypeTicketPurchase transaction type for all transactions that // consume regular transactions as inputs and have commitments for future votes // as outputs. TransactionTypeTicketPurchase // TransactionTypeVote transaction type for all transactions that consume a ticket // and also offer a stake base reward output. TransactionTypeVote // TransactionTypeRevocation transaction type for all transactions that consume a // ticket, but offer no stake base reward. TransactionTypeRevocation )
func TxTransactionType ¶
func TxTransactionType(tx *wire.MsgTx) TransactionType
TxTransactionType returns the correct TransactionType given a wire transaction
type Wallet ¶
type Wallet struct { Manager *udb.Manager TxStore *udb.Store StakeMgr *udb.StakeStore DisallowFree bool AllowHighFees bool NtfnServer *NotificationServer // contains filtered or unexported fields }
Wallet is a structure containing all the components for a complete wallet. It contains the Armory-style key store addresses and keys),
func Open ¶
Open loads an already-created wallet from the passed database and namespaces configuration options and sets it up it according to the rest of options.
func (*Wallet) AcceptMempoolTx ¶
AcceptMempoolTx adds a relevant unmined transaction to the wallet. If a network backend is associated with the wallet, it is updated with new addresses and unspent outpoints to watch.
func (*Wallet) AccountBranchAddressRange ¶
func (w *Wallet) AccountBranchAddressRange(account, branch, start, end uint32) ([]dcrutil.Address, error)
AccountBranchAddressRange returns all addresses in the range [start, end) belonging to the BIP0044 account and address branch.
func (*Wallet) AccountName ¶
AccountName returns the name of an account.
func (*Wallet) AccountNumber ¶
AccountNumber returns the account number for an account name.
func (*Wallet) AccountOfAddress ¶
AccountOfAddress finds the account that an address is associated with.
func (*Wallet) AccountProperties ¶
func (w *Wallet) AccountProperties(acct uint32) (*udb.AccountProperties, error)
AccountProperties returns the properties of an account, including address indexes and name. It first fetches the desynced information from the address manager, then updates the indexes based on the address pools.
func (*Wallet) Accounts ¶
func (w *Wallet) Accounts() (*AccountsResult, error)
Accounts returns the current names, numbers, and total balances of all accounts in the wallet. The current chain tip is included in the result for atomicity reasons.
TODO(jrick): Is the chain tip really needed, since only the total balances are included?
func (*Wallet) AddTicket ¶
AddTicket adds a ticket transaction to the stake manager. It is not added to the transaction manager because it is unknown where the transaction belongs on the blockchain. It will be used to create votes.
func (*Wallet) AddressInfo ¶
AddressInfo returns detailed information regarding a wallet address.
func (*Wallet) AgendaChoices ¶
func (w *Wallet) AgendaChoices() (choices []AgendaChoice, voteBits uint16, err error)
AgendaChoices returns the choice IDs for every agenda of the supported stake version. Abstains are included.
func (*Wallet) BIP0044BranchNextIndexes ¶
BIP0044BranchNextIndexes returns the next external and internal branch child indexes of an account.
func (*Wallet) BalanceToMaintain ¶
BalanceToMaintain is used to get the current balancetomaintain for the wallet.
func (*Wallet) BlockHeader ¶
BlockHeader returns the block header for a block by it's identifying hash, if it is recorded by the wallet.
func (*Wallet) BlockInMainChain ¶
BlockInMainChain returns whether hash is a block hash of any block in the wallet's main chain. If the block is in the main chain, invalidated reports whether a child block in the main chain stake invalidates the queried block.
func (*Wallet) BlockInfo ¶
func (w *Wallet) BlockInfo(blockID *BlockIdentifier) (*BlockInfo, error)
BlockInfo returns info regarding a block recorded by the wallet.
func (*Wallet) BlockLocators ¶
BlockLocators returns block locators, suitable for use in a getheaders wire message or dcrd JSON-RPC request, for the blocks in sidechain and saved in the wallet's main chain. For memory and lookup efficiency, many older hashes are skipped, with increasing gaps between included hashes.
When sidechain has zero length, locators for only main chain blocks starting from the tip are returned. Otherwise, locators are created starting with the best (last) block of sidechain and sidechain[0] must be a child of a main chain block (sidechain may not contain orphan blocks).
func (*Wallet) CalculateAccountBalance ¶
CalculateAccountBalance sums the amounts of all unspent transaction outputs to the given account of a wallet and returns the balance.
func (*Wallet) CalculateAccountBalances ¶
CalculateAccountBalances calculates the values for the wtxmgr struct Balance, which includes the total balance, the spendable balance, and the balance which has yet to mature.
func (*Wallet) ChainParams ¶
ChainParams returns the network parameters for the blockchain the wallet belongs to.
func (*Wallet) ChainSwitch ¶
func (w *Wallet) ChainSwitch(forest *SidechainForest, chain []*BlockNode, relevantTxs map[chainhash.Hash][]*wire.MsgTx) ([]*BlockNode, error)
ChainSwitch updates the wallet's main chain, either by extending the chain with new blocks, or switching to a better sidechain. A sidechain for removed blocks (if any) is returned. If relevantTxs is non-nil, the block marker for the latest block with processed transactions is updated for the new tip block.
func (*Wallet) ChangePrivatePassphrase ¶
ChangePrivatePassphrase attempts to change the passphrase for a wallet from old to new. Changing the passphrase is synchronized with all other address manager locking and unlocking. The lock state will be the same as it was before the password change.
func (*Wallet) ChangePublicPassphrase ¶
ChangePublicPassphrase modifies the public passphrase of the wallet.
func (*Wallet) CoinType ¶ added in v1.3.0
CoinType returns the active BIP0044 coin type. For watching-only wallets, which do not save the coin type keys, this method will return an error with code errors.WatchingOnly.
func (*Wallet) CommittedTickets ¶
func (w *Wallet) CommittedTickets(tickets []*chainhash.Hash) ([]*chainhash.Hash, []dcrutil.Address, error)
CommittedTickets takes a list of tickets and returns a filtered list of tickets that are controlled by this wallet.
func (*Wallet) Consolidate ¶
func (w *Wallet) Consolidate(inputs int, account uint32, address dcrutil.Address) (*chainhash.Hash, error)
Consolidate consolidates as many UTXOs as are passed in the inputs argument. If that many UTXOs can not be found, it will use the maximum it finds. This will only compress UTXOs in the default account
func (*Wallet) CreateMultisigTx ¶
func (w *Wallet) CreateMultisigTx(account uint32, amount dcrutil.Amount, pubkeys []*dcrutil.AddressSecpPubKey, nrequired int8, minconf int32) (*CreatedTx, dcrutil.Address, []byte, error)
CreateMultisigTx receives a request from the RPC and ships it to txCreator to generate a new multisigtx.
func (*Wallet) CreateSignature ¶
func (w *Wallet) CreateSignature(tx *wire.MsgTx, idx uint32, addr dcrutil.Address, hashType txscript.SigHashType, prevPkScript []byte) (sig, pubkey []byte, err error)
CreateSignature returns the raw signature created by the private key of addr for tx's idx'th input script and the serialized compressed pubkey for the address.
func (*Wallet) CurrentAddress ¶
CurrentAddress gets the most recently requested payment address from a wallet. If the address has already been used (there is at least one transaction spending to it in the blockchain or dcrd mempool), the next chained address is returned.
func (*Wallet) DiscoverActiveAddresses ¶
func (w *Wallet) DiscoverActiveAddresses(ctx context.Context, p Peer, startBlock *chainhash.Hash, discoverAccts bool) error
DiscoverActiveAddresses searches for future wallet address usage in all blocks starting from startBlock. If discoverAccts is true, used accounts will be discovered as well. This feature requires the wallet to be unlocked in order to derive hardened account extended pubkeys.
If the wallet is currently on the legacy coin type and no address or account usage is observed and coin type upgrades are not disabled, the wallet will be upgraded to the SLIP0044 coin type and the address discovery will occur again.
func (*Wallet) DumpWIFPrivateKey ¶
DumpWIFPrivateKey returns the WIF encoded private key for a single wallet address.
func (*Wallet) EvaluateBestChain ¶
func (w *Wallet) EvaluateBestChain(f *SidechainForest) ([]*BlockNode, error)
EvaluateBestChain returns block nodes to create the best main chain. These may extend the main chain or require a reorg. An empty slice indicates there is no better chain.
func (*Wallet) ExtendWatchedAddresses ¶
ExtendWatchedAddresses derives and watches additional addresses for an account branch they have not yet been derived. This does not modify the next generated address for the branch.
func (*Wallet) FetchAllRedeemScripts ¶
FetchAllRedeemScripts returns all P2SH redeem scripts saved by the wallet.
func (*Wallet) FetchHeaders ¶
func (w *Wallet) FetchHeaders(ctx context.Context, p Peer) (count int, rescanFrom chainhash.Hash, rescanFromHeight int32, mainChainTipBlockHash chainhash.Hash, mainChainTipBlockHeight int32, err error)
FetchHeaders fetches headers from a Peer and updates the main chain tip with the latest block. The number of new headers fetched is returned, along with the hash of the first previously-unseen block hash now in the main chain. This is the block a rescan should begin at (inclusive), and is only relevant when the number of fetched headers is not zero.
func (*Wallet) FetchMissingCFilters ¶
FetchMissingCFilters records any missing compact filters for main chain blocks. A database upgrade requires all compact filters to be recorded for the main chain before any more blocks may be attached, but this information must be fetched at runtime after the upgrade as it is not already known at the time of upgrade.
func (*Wallet) FetchMissingCFiltersWithProgress ¶ added in v1.1.0
func (w *Wallet) FetchMissingCFiltersWithProgress(ctx context.Context, p Peer, progress chan<- MissingCFilterProgress)
FetchMissingCFiltersWithProgress records any missing compact filters for main chain blocks. A database upgrade requires all compact filters to be recorded for the main chain before any more blocks may be attached, but this information must be fetched at runtime after the upgrade as it is not already known at the time of upgrade. This function reports to a channel with any progress that may have seen.
func (*Wallet) FetchOutput ¶
FetchOutput fetches the associated transaction output given an outpoint. It cannot be used to fetch multi-signature outputs.
func (*Wallet) FetchP2SHMultiSigOutput ¶
func (w *Wallet) FetchP2SHMultiSigOutput(outPoint *wire.OutPoint) (*P2SHMultiSigOutput, error)
FetchP2SHMultiSigOutput fetches information regarding a wallet's P2SH multi-signature output.
func (*Wallet) FindEligibleOutputs ¶
func (w *Wallet) FindEligibleOutputs(account uint32, minconf int32, currentHeight int32) ([]udb.Credit, error)
FindEligibleOutputs is the exported version of findEligibleOutputs (which tried to find unspent outputs that pass a maturity check).
func (*Wallet) GenerateVoteTx ¶
func (w *Wallet) GenerateVoteTx(blockHash *chainhash.Hash, height int32, ticketHash *chainhash.Hash, voteBits stake.VoteBits) (*wire.MsgTx, error)
GenerateVoteTx creates a vote transaction for a chosen ticket purchase hash using the provided votebits. The ticket purchase transaction must be stored by the wallet.
func (*Wallet) GetTicketInfo ¶ added in v1.1.0
func (w *Wallet) GetTicketInfo(hash *chainhash.Hash) (*TicketSummary, *wire.BlockHeader, error)
GetTicketInfo returns the ticket summary and the corresponding block header for the provided ticket. The ticket summary is comprised of the transaction summmary for the ticket, the spender (if already spent) and the ticket's current status.
If the ticket is unmined, then the returned block header will be nil.
func (*Wallet) GetTicketInfoPrecise ¶ added in v1.1.0
func (w *Wallet) GetTicketInfoPrecise(chainClient *dcrrpcclient.Client, hash *chainhash.Hash) (*TicketSummary, *wire.BlockHeader, error)
GetTicketInfoPrecise returns the ticket summary and the corresponding block header for the provided ticket. The ticket summary is comprised of the transaction summmary for the ticket, the spender (if already spent) and the ticket's current status.
If the ticket is unmined, then the returned block header will be nil.
The argument chainClient is always expected to be not nil in this case, otherwise one should use the alternative GetTicketInfo instead. With the ability to use the rpc chain client, this function is able to determine whether a ticket has been missed or not. Otherwise, it is just known to be unspent (possibly live or missed).
func (*Wallet) GetTickets ¶
func (w *Wallet) GetTickets(f func([]*TicketSummary, *wire.BlockHeader) (bool, error), startBlock, endBlock *BlockIdentifier) error
GetTickets calls function f for all tickets located in between the given startBlock and endBlock. TicketSummary includes TransactionSummmary for the ticket and the spender (if already spent) and the ticket's current status. The function f also receives block header of the ticket. All tickets on a given call belong to the same block and at least one ticket is present when f is called. If the ticket is unmined, the block header will be nil.
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 when true.
The arguments to f may be reused and should not be kept by the caller.
Because this function does not have any chain client argument, tickets are unable to be determined whether or not they have been missed, simply unspent.
func (*Wallet) GetTicketsPrecise ¶
func (w *Wallet) GetTicketsPrecise(f func([]*TicketSummary, *wire.BlockHeader) (bool, error), chainClient *dcrrpcclient.Client, startBlock, endBlock *BlockIdentifier) error
GetTicketsPrecise calls function f for all tickets located in between the given startBlock and endBlock. TicketSummary includes TransactionSummmary for the ticket and the spender (if already spent) and the ticket's current status. The function f also receives block header of the ticket. All tickets on a given call belong to the same block and at least one ticket is present when f is called. If the ticket is unmined, the block header will be nil.
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 when true.
The arguments to f may be reused and should not be kept by the caller.
The argument chainClient is always expected to be not nil in this case, otherwise one should use the alternative GetTickets instead. With the ability to use the rpc chain client, this function is able to determine whether tickets have been missed or not. Otherwise, tickets are just known to be unspent (possibly live or missed).
func (*Wallet) GetTransactions ¶
func (w *Wallet) GetTransactions(f func(*Block) (bool, error), startBlock, endBlock *BlockIdentifier) error
GetTransactions runs the function f on all transactions between a starting and ending block. Blocks in the block range may be specified by either a height or a hash.
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 when true.
Transaction results are organized by blocks in ascending order and unmined transactions in an unspecified order. Mined transactions are saved in a Block structure which records properties about the block. Unmined transactions are returned on a Block structure with height == -1.
Internally this function uses the udb store RangeTransactions function, therefore the notes and restrictions of that function also apply here.
func (*Wallet) GetTransactionsByHashes ¶
func (w *Wallet) GetTransactionsByHashes(txHashes []*chainhash.Hash) (txs []*wire.MsgTx, notFound []*wire.InvVect, err error)
GetTransactionsByHashes returns all known transactions identified by a slice of transaction hashes. It is possible that not all transactions are found, and in this case the known results will be returned along with an inventory vector of all missing transactions and an error with code NotExist.
func (*Wallet) HaveAddress ¶
HaveAddress returns whether the wallet is the owner of the address a.
func (*Wallet) ImportP2SHRedeemScript ¶
func (w *Wallet) ImportP2SHRedeemScript(script []byte) (*dcrutil.AddressScriptHash, error)
ImportP2SHRedeemScript adds a P2SH redeem script to the wallet.
func (*Wallet) ImportPrivateKey ¶
ImportPrivateKey imports a private key to the wallet and writes the new wallet to disk.
func (*Wallet) ImportScript ¶
ImportScript imports a redeemscript to the wallet. If it also allows the user to specify whether or not they want the redeemscript to be rescanned, and how far back they wish to rescan.
func (*Wallet) ListAddressTransactions ¶
func (w *Wallet) ListAddressTransactions(pkHashes map[string]struct{}) ([]dcrjson.ListTransactionsResult, error)
ListAddressTransactions returns a slice of objects with details about recorded transactions to or from any address belonging to a set. This is intended to be used for listaddresstransactions RPC replies.
func (*Wallet) ListAllTransactions ¶
func (w *Wallet) ListAllTransactions() ([]dcrjson.ListTransactionsResult, error)
ListAllTransactions returns a slice of objects with details about a recorded transaction. This is intended to be used for listalltransactions RPC replies.
func (*Wallet) ListSinceBlock ¶
func (w *Wallet) ListSinceBlock(start, end, syncHeight int32) ([]dcrjson.ListTransactionsResult, error)
ListSinceBlock returns a slice of objects with details about transactions since the given block. If the block is -1 then all transactions are included. This is intended to be used for listsinceblock RPC replies.
func (*Wallet) ListTransactionDetails ¶
func (w *Wallet) ListTransactionDetails(txHash *chainhash.Hash) ([]dcrjson.ListTransactionsResult, error)
ListTransactionDetails returns the listtransaction results for a single transaction.
func (*Wallet) ListTransactions ¶
func (w *Wallet) ListTransactions(from, count int) ([]dcrjson.ListTransactionsResult, error)
ListTransactions returns a slice of objects with details about a recorded transaction. This is intended to be used for listtransactions RPC replies.
func (*Wallet) ListUnspent ¶
func (w *Wallet) ListUnspent(minconf, maxconf int32, addresses map[string]struct{}) ([]*dcrjson.ListUnspentResult, error)
ListUnspent returns a slice of objects representing the unspent wallet transactions fitting the given criteria. The confirmations will be more than minconf, less than maxconf and if addresses is populated only the addresses contained within it will be considered. If we know nothing about a transaction an empty array will be returned.
func (*Wallet) LiveTicketHashes ¶
func (w *Wallet) LiveTicketHashes(chainClient *dcrrpcclient.Client, includeImmature bool) ([]chainhash.Hash, error)
LiveTicketHashes returns the hashes of live tickets that the wallet has purchased or has voting authority for.
func (*Wallet) LoadActiveDataFilters ¶
LoadActiveDataFilters loads filters for all active addresses and unspent outpoints for this wallet.
func (*Wallet) LockOutpoint ¶
LockOutpoint marks an outpoint as locked, that is, it should not be used as an input for newly created transactions.
func (*Wallet) LockedOutpoint ¶
LockedOutpoint returns whether an outpoint has been marked as locked and should not be used as an input for created transactions.
func (*Wallet) LockedOutpoints ¶
func (w *Wallet) LockedOutpoints() []dcrjson.TransactionInput
LockedOutpoints returns a slice of currently locked outpoints. This is intended to be used by marshaling the result as a JSON array for listlockunspent RPC results.
func (*Wallet) MainChainTip ¶
MainChainTip returns the hash and height of the tip-most block in the main chain that the wallet is synchronized to.
func (*Wallet) MakeSecp256k1MultiSigScript ¶
func (w *Wallet) MakeSecp256k1MultiSigScript(secp256k1Addrs []dcrutil.Address, nRequired int) ([]byte, error)
MakeSecp256k1MultiSigScript creates a multi-signature script that can be redeemed with nRequired signatures of the passed keys and addresses. If the address is a P2PKH address, the associated pubkey is looked up by the wallet if possible, otherwise an error is returned for a missing pubkey.
This function only works with secp256k1 pubkeys and P2PKH addresses derived from them.
func (*Wallet) MasterPubKey ¶
func (w *Wallet) MasterPubKey(account uint32) (*hdkeychain.ExtendedKey, error)
MasterPubKey returns the BIP0044 master public key for the passed account.
func (*Wallet) NeedsAccountsSync ¶
NeedsAccountsSync returns whether or not the wallet is void of any generated keys and accounts (other than the default account), and records the genesis block as the main chain tip. When these are both true, an accounts sync should be performed to restore, per BIP0044, any generated accounts and addresses from a restored seed.
func (*Wallet) NetworkBackend ¶
func (w *Wallet) NetworkBackend() (NetworkBackend, error)
NetworkBackend returns the currently associated network backend of the wallet, or an error if the no backend is currently set.
func (*Wallet) NewChangeAddress ¶
NewChangeAddress returns an internal address. This is identical to NewInternalAddress but handles the imported account (which can't create addresses) by using account 0 instead, and always uses the wrapping gap limit policy.
func (*Wallet) NewExternalAddress ¶
func (w *Wallet) NewExternalAddress(account uint32, callOpts ...NextAddressCallOption) (dcrutil.Address, error)
NewExternalAddress returns an external address.
func (*Wallet) NewInternalAddress ¶
func (w *Wallet) NewInternalAddress(account uint32, callOpts ...NextAddressCallOption) (dcrutil.Address, error)
NewInternalAddress returns an internal address.
func (*Wallet) NewUnsignedTransaction ¶
func (w *Wallet) NewUnsignedTransaction(outputs []*wire.TxOut, relayFeePerKb dcrutil.Amount, account uint32, minConf int32, algo OutputSelectionAlgorithm, changeSource txauthor.ChangeSource) (*txauthor.AuthoredTx, error)
NewUnsignedTransaction constructs an unsigned transaction using unspent account outputs.
The changeSource parameter is optional and can be nil. When nil, and if a change output should be added, an internal change address is created for the account.
func (*Wallet) NextAccount ¶
NextAccount creates the next account and returns its account number. The name must be unique to the account. In order to support automatic seed restoring, new accounts may not be created when all of the previous 100 accounts have no transaction history (this is a deviation from the BIP0044 spec, which allows no unused account gaps).
func (*Wallet) NextStakeDifficulty ¶
NextStakeDifficulty returns the ticket price for the next block after the current main chain tip block. This function only suceeds when DCP0001 is known to be active. As a fallback, the StakeDifficulty method of wallet.NetworkBackend may be used to query the next ticket price from a trusted full node.
func (*Wallet) NextStakeDifficultyAfterHeader ¶
NextStakeDifficultyAfterHeader returns the ticket price for the child of h. All headers of ancestor blocks of h must be recorded by the wallet. This function only suceeds when DCP0001 is known to be active.
func (*Wallet) OutputInfo ¶
func (w *Wallet) OutputInfo(out *wire.OutPoint) (OutputInfo, error)
OutputInfo queries the wallet for additional transaction output info regarding an outpoint.
func (*Wallet) PoolAddress ¶
PoolAddress gets the pool address for the wallet to give ticket fees to.
func (*Wallet) PrepareRedeemMultiSigOutTxOutput ¶
func (w *Wallet) PrepareRedeemMultiSigOutTxOutput(msgTx *wire.MsgTx, p2shOutput *P2SHMultiSigOutput, pkScript *[]byte) error
PrepareRedeemMultiSigOutTxOutput estimates the tx value for a MultiSigOutTx output and adds it to msgTx.
func (*Wallet) PubKeyForAddress ¶
PubKeyForAddress looks up the associated public key for a P2PKH address.
func (*Wallet) PublishTransaction ¶
func (w *Wallet) PublishTransaction(tx *wire.MsgTx, serializedTx []byte, n NetworkBackend) (*chainhash.Hash, error)
PublishTransaction saves (if relevant) and sends the transaction to the consensus RPC server so it can be propagated to other nodes and eventually mined. If the send fails, the transaction is not added to the wallet.
func (*Wallet) PublishUnminedTransactions ¶
PublishUnminedTransactions rebroadcasts all unmined transactions to the consensus RPC server so it can be propagated to other nodes and eventually mined.
func (*Wallet) PurchaseTickets ¶
func (w *Wallet) PurchaseTickets(minBalance, spendLimit dcrutil.Amount, minConf int32, ticketAddr dcrutil.Address, account uint32, numTickets int, poolAddress dcrutil.Address, poolFees float64, expiry int32, txFee dcrutil.Amount, ticketFee dcrutil.Amount) ([]*chainhash.Hash, error)
PurchaseTickets receives a request from the RPC and ships it to txCreator to purchase a new ticket. It returns a slice of the hashes of the purchased tickets.
func (*Wallet) PurgeUnminedTransaction ¶
PurgeUnminedTransaction removes a transaction, identified by its hash, from the wallet if present. All transaction spend chains deriving from the transaction's outputs are also removed. Does not error if the transaction doesn't already exist unmined, but will if the transaction is marked mined in a block on the main chain.
Purged transactions may have already been published to the network and may still appear in future blocks, and new transactions spending the same inputs as purged transations may be rejected by full nodes due to being double spends. In turn, this can cause the purged transaction to be mined later and replace other transactions authored by the wallet.
func (*Wallet) RedeemScriptCopy ¶
RedeemScriptCopy returns a copy of a redeem script to redeem outputs payed to a P2SH address.
func (*Wallet) RelayFee ¶
RelayFee returns the current minimum relay fee (per kB of serialized transaction) used when constructing transactions.
func (*Wallet) RenameAccount ¶
RenameAccount sets the name for an account number to newName.
func (*Wallet) Rescan ¶
Rescan starts a rescan of the wallet for all blocks on the main chain beginning at startHash. This function blocks until the rescan completes.
func (*Wallet) RescanFromHeight ¶
RescanFromHeight is an alternative to Rescan that takes a block height instead of a hash. See Rescan for more details.
func (*Wallet) RescanPoint ¶
RescanPoint returns the block hash at which a rescan should begin (inclusive), or nil when no rescan is necessary.
func (*Wallet) RescanProgressFromHeight ¶
func (w *Wallet) RescanProgressFromHeight(ctx context.Context, n NetworkBackend, startHeight int32, p chan<- RescanProgress)
RescanProgressFromHeight rescans for relevant transactions in all blocks in the main chain starting at startHeight. Progress notifications and any errors are sent to the channel p. This function blocks until the rescan completes or ends in an error. p is closed before returning.
func (*Wallet) ResetLockedOutpoints ¶
func (w *Wallet) ResetLockedOutpoints()
ResetLockedOutpoints resets the set of locked outpoints so all may be used as inputs for new transactions.
func (*Wallet) RevokeExpiredTickets ¶
RevokeExpiredTickets revokes any unspent tickets that cannot be live due to being past expiry. It is similar to RevokeTickets but is able to be used with any Peer implementation as it will not query the consensus RPC server for missed tickets.
func (*Wallet) RevokeOwnedTickets ¶
RevokeOwnedTickets revokes any owned tickets specified in the missedTicketHashes slice. When a network backend is associated with the wallet, relevant commitment outputs are loaded as watched data.
func (*Wallet) RevokeTickets ¶
func (w *Wallet) RevokeTickets(chainClient *dcrrpcclient.Client) error
RevokeTickets creates and sends revocation transactions for any unrevoked missed and expired tickets. The wallet must be unlocked to generate any revocations.
func (*Wallet) SaveRescanned ¶
SaveRescanned records transactions from a rescanned block. This does not update the network backend with data to watch for future relevant transactions as the rescanner is assumed to handle this task.
func (*Wallet) SelectInputs ¶
func (w *Wallet) SelectInputs(targetAmount dcrutil.Amount, policy OutputSelectionPolicy) (inputDetail *txauthor.InputDetail, err error)
SelectInputs selects transaction inputs to redeem unspent outputs stored in the wallet. It returns an input detail summary.
func (*Wallet) SendOutputs ¶
func (w *Wallet) SendOutputs(outputs []*wire.TxOut, account uint32, minconf int32) (*chainhash.Hash, error)
SendOutputs creates and sends payment transactions. It returns the transaction hash upon success
func (*Wallet) SetAgendaChoices ¶
func (w *Wallet) SetAgendaChoices(choices ...AgendaChoice) (voteBits uint16, err error)
SetAgendaChoices sets the choices for agendas defined by the supported stake version. If a choice is set multiple times, the last takes preference. The new votebits after each change is made are returned.
func (*Wallet) SetBalanceToMaintain ¶
SetBalanceToMaintain is used to set the current w.balancetomaintain for the wallet.
func (*Wallet) SetNetworkBackend ¶
func (w *Wallet) SetNetworkBackend(n NetworkBackend)
SetNetworkBackend sets the network backend used by various functions of the wallet.
func (*Wallet) SetRelayFee ¶
SetRelayFee sets a new minimum relay fee (per kB of serialized transaction) used when constructing transactions.
func (*Wallet) SetTicketFeeIncrement ¶
SetTicketFeeIncrement is used to set the current w.ticketFeeIncrement for the wallet.
func (*Wallet) SignMessage ¶
SignMessage returns the signature of a signed message using an address' associated private key.
func (*Wallet) SignTransaction ¶
func (w *Wallet) SignTransaction(tx *wire.MsgTx, hashType txscript.SigHashType, additionalPrevScripts map[wire.OutPoint][]byte, additionalKeysByAddress map[string]*dcrutil.WIF, p2shRedeemScriptsByAddress map[string][]byte) ([]SignatureError, error)
SignTransaction uses secrets of the wallet, as well as additional secrets passed in by the caller, to create and add input signatures to a transaction.
Transaction input script validation is used to confirm that all signatures are valid. For any invalid input, a SignatureError is added to the returns. The final error return is reserved for unexpected or fatal errors, such as being unable to determine a previous output script to redeem.
The transaction pointed to by tx is modified by this function.
func (*Wallet) SortedActivePaymentAddresses ¶
SortedActivePaymentAddresses returns a slice of all active payment addresses in a wallet.
func (*Wallet) StakeInfo ¶
func (w *Wallet) StakeInfo() (*StakeInfoData, error)
StakeInfo collects and returns staking statistics for this wallet.
func (*Wallet) StakeInfoPrecise ¶
func (w *Wallet) StakeInfoPrecise(chainClient *dcrrpcclient.Client) (*StakeInfoData, error)
StakeInfoPrecise collects and returns staking statistics for this wallet. It uses RPC to query futher information than StakeInfo.
func (*Wallet) StakePoolUserInfo ¶
StakePoolUserInfo returns the stake pool user information for a user identified by their P2SH voting address.
func (*Wallet) Start ¶
func (w *Wallet) Start()
Start starts the goroutines necessary to manage a wallet.
func (*Wallet) TicketAddress ¶
TicketAddress gets the ticket address for the wallet to give the ticket voting rights to.
func (*Wallet) TicketFeeIncrement ¶
TicketFeeIncrement is used to get the current feeIncrement for the wallet.
func (*Wallet) TicketHashesForVotingAddress ¶
TicketHashesForVotingAddress returns the hashes of all tickets with voting rights delegated to votingAddr. This function does not return the hashes of pruned tickets.
func (*Wallet) TotalReceivedForAccounts ¶
func (w *Wallet) TotalReceivedForAccounts(minConf int32) ([]AccountTotalReceivedResult, error)
TotalReceivedForAccounts iterates through a wallet's transaction history, returning the total amount of decred received for all accounts.
func (*Wallet) TotalReceivedForAddr ¶
TotalReceivedForAddr iterates through a wallet's transaction history, returning the total amount of decred received for a single wallet address.
func (*Wallet) TransactionSummary ¶
func (w *Wallet) TransactionSummary(txHash *chainhash.Hash) (txSummary *TransactionSummary, confs int32, blockHash *chainhash.Hash, err error)
TransactionSummary returns details about a recorded transaction that is relevant to the wallet in some way.
func (*Wallet) Unlock ¶
Unlock unlocks the wallet's address manager and relocks it after timeout has expired. If the wallet is already unlocked and the new passphrase is correct, the current timeout is replaced with the new one. The wallet will be locked if the passphrase is incorrect or any other error occurs during the unlock.
func (*Wallet) UnlockOutpoint ¶
UnlockOutpoint marks an outpoint as unlocked, that is, it may be used as an input for newly created transactions.
func (*Wallet) UnminedTransactions ¶
UnminedTransactions returns all unmined transactions from the wallet. Transactions are sorted in dependency order making it suitable to range them in order to broadcast at wallet startup.
func (*Wallet) UnspentOutputs ¶
func (w *Wallet) UnspentOutputs(policy OutputSelectionPolicy) ([]*TransactionOutput, error)
UnspentOutputs fetches all unspent outputs from the wallet that match rules described in the passed policy.
func (*Wallet) UpgradeToSLIP0044CoinType ¶
UpgradeToSLIP0044CoinType upgrades the wallet from the legacy BIP0044 coin type to one of the coin types assigned to Decred in SLIP0044. This should be called after a new wallet is created with a random (not imported) seed.
This function does not register addresses from the new account 0 with the wallet's network backend. This is intentional as it allows offline activities, such as wallet creation, to perform this upgrade.
func (*Wallet) ValidateHeaderChainDifficulties ¶
ValidateHeaderChainDifficulties validates the PoW and PoS difficulties of all blocks in chain[idx:]. The parent of chain[0] must be recorded as wallet main chain block. If a consensus violation is caught, a subslice of chain beginning with the invalid block is returned.
func (*Wallet) VoteBits ¶
VoteBits returns the vote bits that are described by the currently set agenda preferences. The previous block valid bit is always set, and must be unset elsewhere if the previous block's regular transactions should be voted against.
func (*Wallet) VoteOnOwnedTickets ¶
func (w *Wallet) VoteOnOwnedTickets(winningTicketHashes []*chainhash.Hash, blockHash *chainhash.Hash, blockHeight int32) error
VoteOnOwnedTickets creates and publishes vote transactions for all owned tickets in the winningTicketHashes slice if wallet voting is enabled. The vote is only valid when voting on the block described by the passed block hash and height. When a network backend is associated with the wallet, relevant commitment outputs are loaded as watched data.
func (*Wallet) VotingEnabled ¶
VotingEnabled returns whether the wallet is configured to vote tickets.
func (*Wallet) WaitForShutdown ¶
func (w *Wallet) WaitForShutdown()
WaitForShutdown blocks until all wallet goroutines have finished executing.
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
drivers
|
|
bdb
Package bdb registers the bdb driver at init time.
|
Package bdb registers the bdb driver at init time. |
internal
|
|
bdb
Package bdb implements an instance of walletdb that uses boltdb for the backing datastore.
|
Package bdb implements an instance of walletdb that uses boltdb for the backing datastore. |
Package txauthor provides transaction creation code for wallets.
|
Package txauthor provides transaction creation code for wallets. |
Package txrules provides functions that are help establish whether or not a transaction abides by non-consensus rules for things like the daemon and stake pool.
|
Package txrules provides functions that are help establish whether or not a transaction abides by non-consensus rules for things like the daemon and stake pool. |
Package walletdb provides a namespaced database interface for dcrwallet.
|
Package walletdb provides a namespaced database interface for dcrwallet. |