bchwallet: github.com/gcash/bchwallet/wallet Index | Files | Directories

package wallet

import "github.com/gcash/bchwallet/wallet"

Package wallet provides ... TODO: Flesh out this section



Package Files

chainntfns.go common.go createtx.go disksync.go doc.go loader.go log.go mock.go multisig.go notifications.go recovery.go rescan.go unstable.go utxos.go wallet.go


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"


var (
    // ErrLoaded describes the error condition of attempting to load or
    // create a wallet when the loader has already done so.
    ErrLoaded = errors.New("wallet already loaded")

    // ErrNotLoaded describes the error condition of attempting to close a
    // loaded wallet when a wallet has not been loaded.
    ErrNotLoaded = errors.New("wallet is not loaded")

    // ErrExists describes the error condition of attempting to create a new
    // wallet when one exists already.
    ErrExists = errors.New("wallet already exists")
var (
    // ErrNotSynced describes an error where an operation cannot complete
    // due wallet being out of sync (and perhaps currently syncing with)
    // the remote chain server.
    ErrNotSynced = errors.New("wallet is not synchronized with the chain server")

    // ErrWalletShuttingDown is an error returned when we attempt to make a
    // request to the wallet but it is in the process of or has already shut
    // down.
    ErrWalletShuttingDown = errors.New("wallet shutting down")

func Create Uses

func Create(db walletdb.DB, pubPass, privPass, seed []byte, params *chaincfg.Params,
    birthday time.Time) error

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 DisableLog Uses

func DisableLog()

DisableLog disables all library log output. Logging output is disabled by default until either UseLogger or SetLogWriter are called.

func UseLogger Uses

func UseLogger(logger bchlog.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 bchlog.

type AccountBalance Uses

type AccountBalance struct {
    Account      uint32
    TotalBalance bchutil.Amount

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 AccountBalanceResult Uses

type AccountBalanceResult struct {
    AccountNumber  uint32
    AccountName    string
    AccountBalance bchutil.Amount

AccountBalanceResult is a single result for the Wallet.AccountBalances method.

type AccountNotification Uses

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 Uses

type AccountNotificationsClient struct {
    C chan *AccountNotification
    // contains filtered or unexported fields

AccountNotificationsClient receives AccountNotifications over the channel C.

func (*AccountNotificationsClient) Done Uses

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 Uses

type AccountResult struct {
    TotalBalance bchutil.Amount

AccountResult is a single account result for the AccountsResult type.

type AccountTotalReceivedResult Uses

type AccountTotalReceivedResult struct {
    AccountNumber    uint32
    AccountName      string
    TotalReceived    bchutil.Amount
    LastConfirmation int32

AccountTotalReceivedResult is a single result for the Wallet.TotalReceivedForAccounts method.

type AccountsResult Uses

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 Balances Uses

type Balances struct {
    Total          bchutil.Amount
    Spendable      bchutil.Amount
    ImmatureReward bchutil.Amount

Balances records total, spendable (by policy), and immature coinbase reward balance amounts.

type Block Uses

type Block struct {
    Hash         *chainhash.Hash
    Height       int32
    Timestamp    int64
    Transactions []TransactionSummary

Block contains the properties and all relevant transactions of an attached block.

type BlockIdentifier Uses

type BlockIdentifier struct {
    // contains filtered or unexported fields

BlockIdentifier identifies a block by either a height or a hash.

func NewBlockIdentifierFromHash Uses

func NewBlockIdentifierFromHash(hash *chainhash.Hash) *BlockIdentifier

NewBlockIdentifierFromHash constructs a BlockIdentifier for a block hash.

func NewBlockIdentifierFromHeight Uses

func NewBlockIdentifierFromHeight(height int32) *BlockIdentifier

NewBlockIdentifierFromHeight constructs a BlockIdentifier for a block height.

type BlockIdentity Uses

type BlockIdentity struct {
    Hash   chainhash.Hash
    Height int32

BlockIdentity identifies a block, or the lack of one (used to describe an unmined transaction).

func (*BlockIdentity) None Uses

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 BranchRecoveryState Uses

type BranchRecoveryState struct {
    // contains filtered or unexported fields

BranchRecoveryState maintains the required state in-order to properly recover addresses derived from a particular account's internal or external derivation branch.

A branch recovery state supports operations for:

- Expanding the look-ahead horizon based on which indexes have been found.
- Registering derived addresses with indexes within the horizon.
- Reporting an invalid child index that falls into the horizon.
- Reporting that an address has been found.
- Retrieving all currently derived addresses for the branch.
- Looking up a particular address by its child index.

func NewBranchRecoveryState Uses

func NewBranchRecoveryState(recoveryWindow uint32) *BranchRecoveryState

NewBranchRecoveryState creates a new BranchRecoveryState that can be used to track either the external or internal branch of an account's derivation path.

func (*BranchRecoveryState) AddAddr Uses

func (brs *BranchRecoveryState) AddAddr(index uint32, addr bchutil.Address)

AddAddr adds a freshly derived address from our lookahead into the map of known addresses for this branch.

func (*BranchRecoveryState) Addrs Uses

func (brs *BranchRecoveryState) Addrs() map[uint32]bchutil.Address

Addrs returns a map of all currently derived child indexes to the their corresponding addresses.

func (*BranchRecoveryState) ExtendHorizon Uses

func (brs *BranchRecoveryState) ExtendHorizon() (uint32, uint32)

ExtendHorizon returns the current horizon and the number of addresses that must be derived in order to maintain the desired recovery window.

func (*BranchRecoveryState) GetAddr Uses

func (brs *BranchRecoveryState) GetAddr(index uint32) bchutil.Address

GetAddr returns the address derived from a given child index.

func (*BranchRecoveryState) MarkInvalidChild Uses

func (brs *BranchRecoveryState) MarkInvalidChild(index uint32)

MarkInvalidChild records that a particular child index results in deriving an invalid address. In addition, the branch's horizon is increment, as we expect the caller to perform an additional derivation to replace the invalid child. This is used to ensure that we are always have the proper lookahead when an invalid child is encountered.

func (*BranchRecoveryState) NextUnfound Uses

func (brs *BranchRecoveryState) NextUnfound() uint32

NextUnfound returns the child index of the successor to the highest found child index.

func (*BranchRecoveryState) NumInvalidInHorizon Uses

func (brs *BranchRecoveryState) NumInvalidInHorizon() uint32

NumInvalidInHorizon computes the number of invalid child indexes that lie between the last found and current horizon. This informs how many additional indexes to derive in order to maintain the proper number of valid addresses within our horizon.

func (*BranchRecoveryState) ReportFound Uses

func (brs *BranchRecoveryState) ReportFound(index uint32)

ReportFound updates the last found index if the reported index exceeds the current value.

type CreditCategory Uses

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

These constants define the possible credit categories.

func RecvCategory Uses

func RecvCategory(details *wtxmgr.TxDetails, syncHeight int32, net *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 Uses

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 GetTransactionsResult Uses

type GetTransactionsResult struct {
    MinedTransactions   []Block
    UnminedTransactions []TransactionSummary

GetTransactionsResult is the result of the wallet's GetTransactions method. See GetTransactions for more details.

type Loader Uses

type Loader struct {
    // contains filtered or unexported fields

Loader implements the creating of new and opening of existing wallets, while providing a callback system for other subsystems to handle the loading of a wallet. This is primarily intended for use by the RPC servers, to enable methods and services which require the wallet when the wallet is loaded by another subsystem.

Loader is safe for concurrent access.

func NewLoader Uses

func NewLoader(chainParams *chaincfg.Params, dbDirPath string,
    recoveryWindow uint32) *Loader

NewLoader constructs a Loader with an optional recovery window. If the recovery window is non-zero, the wallet will attempt to recovery addresses starting from the last SyncedTo height.

func (*Loader) CreateNewWallet Uses

func (l *Loader) CreateNewWallet(pubPassphrase, privPassphrase, seed []byte,
    bday time.Time) (*Wallet, error)

CreateNewWallet creates a new wallet using the provided public and private passphrases. The seed is optional. If non-nil, addresses are derived from this seed. If nil, a secure random seed is generated.

func (*Loader) LoadedWallet Uses

func (l *Loader) LoadedWallet() (*Wallet, bool)

LoadedWallet returns the loaded wallet, if any, and a bool for whether the wallet has been loaded or not. If true, the wallet pointer should be safe to dereference.

func (*Loader) OpenExistingWallet Uses

func (l *Loader) OpenExistingWallet(pubPassphrase []byte, canConsolePrompt bool) (*Wallet, error)

OpenExistingWallet opens the wallet from the loader's wallet database path and the public passphrase. If the loader is being called by a context where standard input prompts may be used during wallet upgrades, setting canConsolePrompt will enables these prompts.

func (*Loader) RunAfterLoad Uses

func (l *Loader) RunAfterLoad(fn func(*Wallet))

RunAfterLoad adds a function to be executed when the loader creates or opens a wallet. Functions are executed in a single goroutine in the order they are added.

func (*Loader) UnloadWallet Uses

func (l *Loader) UnloadWallet() error

UnloadWallet stops the loaded wallet, if any, and closes the wallet database. This returns ErrNotLoaded if the wallet has not been loaded with CreateNewWallet or LoadExistingWallet. The Loader may be reused if this function returns without error.

func (*Loader) WalletExists Uses

func (l *Loader) WalletExists() (bool, error)

WalletExists returns whether a file exists at the loader's database path. This may return an error for unexpected I/O failures.

type NotificationServer Uses

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 Uses

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) AccountSpentnessNotifications Uses

func (s *NotificationServer) AccountSpentnessNotifications(account uint32) SpentnessNotificationsClient

AccountSpentnessNotifications registers a client for spentness changes of outputs controlled by the account.

func (*NotificationServer) RescanNotifications Uses

func (s *NotificationServer) RescanNotifications() RescanNotificationsClient

RescanNotifications returns a client for receiving RescanNotifications 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 Uses

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 OutputKind Uses

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

Defined OutputKind constants

type OutputRedeemer Uses

type OutputRedeemer struct {
    TxHash     chainhash.Hash
    InputIndex uint32

OutputRedeemer identifies the transaction input which redeems an output.

type OutputSelectionPolicy Uses

type OutputSelectionPolicy struct {
    Account               uint32
    RequiredConfirmations int32

OutputSelectionPolicy describes the rules for selecting an output from the wallet.

type P2SHMultiSigOutput Uses

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    bchutil.Amount
    ContainingBlock BlockIdentity

    P2SHAddress  *bchutil.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 RecoveryManager Uses

type RecoveryManager struct {
    // contains filtered or unexported fields

RecoveryManager maintains the state required to recover previously used addresses, and coordinates batched processing of the blocks to search.

func NewRecoveryManager Uses

func NewRecoveryManager(recoveryWindow, batchSize uint32,
    chainParams *chaincfg.Params) *RecoveryManager

NewRecoveryManager initializes a new RecoveryManager with a derivation look-ahead of `recoveryWindow` child indexes, and pre-allocates a backing array for `batchSize` blocks to scan at once.

func (*RecoveryManager) AddToBlockBatch Uses

func (rm *RecoveryManager) AddToBlockBatch(hash *chainhash.Hash, height int32,
    timestamp time.Time)

AddToBlockBatch appends the block information, consisting of hash and height, to the batch of blocks to be searched.

func (*RecoveryManager) BlockBatch Uses

func (rm *RecoveryManager) BlockBatch() []wtxmgr.BlockMeta

BlockBatch returns a buffer of blocks that have not yet been searched.

func (*RecoveryManager) ResetBlockBatch Uses

func (rm *RecoveryManager) ResetBlockBatch()

ResetBlockBatch resets the internal block buffer to conserve memory.

func (*RecoveryManager) Resurrect Uses

func (rm *RecoveryManager) Resurrect(ns walletdb.ReadBucket,
    scopedMgrs map[waddrmgr.KeyScope]*waddrmgr.ScopedKeyManager,
    credits []wtxmgr.Credit) error

Resurrect restores all known addresses for the provided scopes that can be found in the walletdb namespace, in addition to restoring all outpoints that have been previously found. This method ensures that the recovery state's horizons properly start from the last found address of a prior recovery attempt.

func (*RecoveryManager) State Uses

func (rm *RecoveryManager) State() *RecoveryState

State returns the current RecoveryState.

type RecoveryProgessMsg Uses

type RecoveryProgessMsg struct {
    Notification *chain.RecoveryProgress

RecoveryProgessMsg reports the current progress made by a recovery.

type RecoveryState Uses

type RecoveryState struct {
    // contains filtered or unexported fields

RecoveryState manages the initialization and lookup of ScopeRecoveryStates for any actively used key scopes.

In order to ensure that all addresses are properly recovered, the window should be sized as the sum of maximum possible inter-block and intra-block gap between used addresses of a particular branch.

These are defined as:

- Inter-Block Gap: The maximum difference between the derived child indexes
    of the last addresses used in any block and the next address consumed
    by a later block.
- Intra-Block Gap: The maximum difference between the derived child indexes
    of the first address used in any block and the last address used in the
    same block.

func NewRecoveryState Uses

func NewRecoveryState(recoveryWindow uint32) *RecoveryState

NewRecoveryState creates a new RecoveryState using the provided recoveryWindow. Each RecoveryState that is subsequently initialized for a particular key scope will receive the same recoveryWindow.

func (*RecoveryState) AddWatchedOutPoint Uses

func (rs *RecoveryState) AddWatchedOutPoint(outPoint *wire.OutPoint,
    addr bchutil.Address)

AddWatchedOutPoint updates the recovery state's set of known outpoints that we will monitor for spends during recovery.

func (*RecoveryState) StateForScope Uses

func (rs *RecoveryState) StateForScope(
    keyScope waddrmgr.KeyScope) *ScopeRecoveryState

StateForScope returns a ScopeRecoveryState for the provided key scope. If one does not already exist, a new one will be generated with the RecoveryState's recoveryWindow.

func (*RecoveryState) WatchedOutPoints Uses

func (rs *RecoveryState) WatchedOutPoints() map[wire.OutPoint]bchutil.Address

WatchedOutPoints returns the global set of outpoints that are known to belong to the wallet during recovery.

type RescanFinishedMsg Uses

type RescanFinishedMsg struct {
    Addresses    []bchutil.Address
    Notification *chain.RescanFinished

RescanFinishedMsg reports the addresses that were rescanned when a rescanfinished message was received rescanning a batch of addresses.

type RescanJob Uses

type RescanJob struct {
    InitialSync bool
    Addrs       []bchutil.Address
    OutPoints   map[wire.OutPoint]bchutil.Address
    BlockStamp  waddrmgr.BlockStamp
    // contains filtered or unexported fields

RescanJob is a job to be processed by the RescanManager. The job includes a set of wallet addresses, a starting height to begin the rescan, and outpoints spendable by the addresses thought to be unspent. After the rescan completes, the error result of the rescan RPC is sent on the Err channel.

type RescanNotification Uses

type RescanNotification struct {
    Hash     *chainhash.Hash
    Height   int32
    Finished bool

RescanNotification is a notification which contains the rescan progress. It provides the hash and height the rescan is up to as well as a bool signifying if the rescan is finished.

type RescanNotificationsClient Uses

type RescanNotificationsClient struct {
    C chan *RescanNotification
    // contains filtered or unexported fields

RescanNotificationsClient receives RescanNotifications over the channel C.

func (*RescanNotificationsClient) Done Uses

func (c *RescanNotificationsClient) 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 RescanProgressMsg Uses

type RescanProgressMsg struct {
    Addresses    []bchutil.Address
    Notification *chain.RescanProgress

RescanProgressMsg reports the current progress made by a rescan for a set of wallet addresses.

type ScopeRecoveryState Uses

type ScopeRecoveryState struct {
    // ExternalBranch is the recovery state of addresses generated for
    // external use, i.e. receiving addresses.
    ExternalBranch *BranchRecoveryState

    // InternalBranch is the recovery state of addresses generated for
    // internal use, i.e. change addresses.
    InternalBranch *BranchRecoveryState

ScopeRecoveryState is used to manage the recovery of addresses generated under a particular BIP32 account. Each account tracks both an external and internal branch recovery state, both of which use the same recovery window.

func NewScopeRecoveryState Uses

func NewScopeRecoveryState(recoveryWindow uint32) *ScopeRecoveryState

NewScopeRecoveryState initializes an ScopeRecoveryState with the chosen recovery window.

type SignatureError Uses

type SignatureError struct {
    InputIndex uint32
    Error      error

SignatureError records the underlying error when validating a transaction input signature.

type SpentnessNotifications Uses

type SpentnessNotifications struct {
    // contains filtered or unexported fields

SpentnessNotifications is a notification that is fired for transaction outputs controlled by some account's keys. The notification may be about a newly added unspent transaction output or that a previously unspent output is now spent. When spent, the notification includes the spending transaction's hash and input index.

func (*SpentnessNotifications) Hash Uses

func (n *SpentnessNotifications) Hash() *chainhash.Hash

Hash returns the transaction hash of the spent output.

func (*SpentnessNotifications) Index Uses

func (n *SpentnessNotifications) Index() uint32

Index returns the transaction output index of the spent output.

func (*SpentnessNotifications) Spender Uses

func (n *SpentnessNotifications) Spender() (*chainhash.Hash, uint32, bool)

Spender returns the spending transction's hash and input index, if any. If the output is unspent, the final bool return is false.

type SpentnessNotificationsClient Uses

type SpentnessNotificationsClient struct {
    C <-chan *SpentnessNotifications
    // contains filtered or unexported fields

SpentnessNotificationsClient receives SpentnessNotifications from the NotificationServer over the channel C.

func (*SpentnessNotificationsClient) Done Uses

func (c *SpentnessNotificationsClient) 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 TransactionNotifications Uses

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 Uses

type TransactionNotificationsClient struct {
    C <-chan *TransactionNotifications
    // contains filtered or unexported fields

TransactionNotificationsClient receives TransactionNotifications from the NotificationServer over the channel C.

func (*TransactionNotificationsClient) Done Uses

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 Uses

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 Uses

type TransactionSummary struct {
    Hash        *chainhash.Hash
    Transaction []byte
    MyInputs    []TransactionSummaryInput
    MyOutputs   []TransactionSummaryOutput
    Fee         bchutil.Amount
    Timestamp   int64

TransactionSummary contains a transaction relevant to the wallet and marks which inputs and outputs were relevant.

type TransactionSummaryInput Uses

type TransactionSummaryInput struct {
    Index           uint32
    PreviousAccount uint32
    PreviousAmount  bchutil.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 Uses

type TransactionSummaryOutput struct {
    Index    uint32
    Account  uint32
    Internal bool
    Address  bchutil.Address
    Amount   bchutil.Amount

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 UnstableAPIWallet Uses

type UnstableAPIWallet struct {
    // contains filtered or unexported fields

UnstableAPIWallet wraps the wallet with a couple additional API calls.

func UnstableAPI Uses

func UnstableAPI(w *Wallet) UnstableAPIWallet

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.

func (UnstableAPIWallet) RangeTransactions Uses

func (u UnstableAPIWallet) RangeTransactions(begin, end int32, f func([]wtxmgr.TxDetails) (bool, error)) error

RangeTransactions calls wtxmgr.Store.RangeTransactions under a single database view tranasction.

func (UnstableAPIWallet) TxDetails Uses

func (u UnstableAPIWallet) TxDetails(txHash *chainhash.Hash) (*wtxmgr.TxDetails, error)

TxDetails calls wtxmgr.Store.TxDetails under a single database view transaction.

type Wallet Uses

type Wallet struct {
    Manager *waddrmgr.Manager
    TxStore *wtxmgr.Store

    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 Uses

func Open(db walletdb.DB, pubPass []byte, cbs *waddrmgr.OpenCallbacks,
    params *chaincfg.Params, recoveryWindow uint32) (*Wallet, error)

Open loads an already-created wallet from the passed database and namespaces.

func (*Wallet) AccountAddresses Uses

func (w *Wallet) AccountAddresses(account uint32) (addrs []bchutil.Address, err error)

AccountAddresses returns the addresses for every created address for an account.

func (*Wallet) AccountBalances Uses

func (w *Wallet) AccountBalances(scope waddrmgr.KeyScope,
    requiredConfs int32) ([]AccountBalanceResult, error)

AccountBalances returns all accounts in the wallet and their balances. Balances are determined by excluding transactions that have not met requiredConfs confirmations.

func (*Wallet) AccountName Uses

func (w *Wallet) AccountName(scope waddrmgr.KeyScope, accountNumber uint32) (string, error)

AccountName returns the name of an account.

func (*Wallet) AccountNumber Uses

func (w *Wallet) AccountNumber(scope waddrmgr.KeyScope, accountName string) (uint32, error)

AccountNumber returns the account number for an account name under a particular key scope.

func (*Wallet) AccountOfAddress Uses

func (w *Wallet) AccountOfAddress(a bchutil.Address) (uint32, error)

AccountOfAddress finds the account that an address is associated with.

func (*Wallet) AccountProperties Uses

func (w *Wallet) AccountProperties(scope waddrmgr.KeyScope, acct uint32) (*waddrmgr.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 Uses

func (w *Wallet) Accounts(scope waddrmgr.KeyScope) (*AccountsResult, error)

Accounts returns the current names, numbers, and total balances of all accounts in the wallet restricted to a particular key scope. 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) AddressInfo Uses

func (w *Wallet) AddressInfo(a bchutil.Address) (waddrmgr.ManagedAddress, error)

AddressInfo returns detailed information regarding a wallet address.

func (*Wallet) CalculateAccountBalances Uses

func (w *Wallet) CalculateAccountBalances(account uint32, confirms int32) (Balances, error)

CalculateAccountBalances sums the amounts of all unspent transaction outputs to the given account of a wallet and returns the balance.

This function is much slower than it needs to be since transactions outputs are not indexed by the accounts they credit to, and all unspent transaction outputs must be iterated.

func (*Wallet) CalculateBalance Uses

func (w *Wallet) CalculateBalance(confirms int32) (bchutil.Amount, error)

CalculateBalance sums the amounts of all unspent transaction outputs to addresses of a wallet and returns the balance.

If confirmations is 0, all UTXOs, even those not present in a block (height -1), will be used to get the balance. Otherwise, a UTXO must be in a block. If confirmations is 1 or greater, the balance will be calculated based on how many how many blocks include a UTXO.

func (*Wallet) ChainClient Uses

func (w *Wallet) ChainClient() chain.Interface

ChainClient returns the optional consensus RPC client associated with the wallet.

This function is unstable and will be removed once sync logic is moved out of the wallet.

func (*Wallet) ChainParams Uses

func (w *Wallet) ChainParams() *chaincfg.Params

ChainParams returns the network parameters for the blockchain the wallet belongs to.

func (*Wallet) ChainSynced Uses

func (w *Wallet) ChainSynced() bool

ChainSynced returns whether the wallet has been attached to a chain server and synced up to the best block on the main chain.

func (*Wallet) ChangePassphrases Uses

func (w *Wallet) ChangePassphrases(publicOld, publicNew, privateOld,
    privateNew []byte) error

ChangePassphrases modifies the public and private passphrase of the wallet atomically.

func (*Wallet) ChangePrivatePassphrase Uses

func (w *Wallet) ChangePrivatePassphrase(old, new []byte) error

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 Uses

func (w *Wallet) ChangePublicPassphrase(old, new []byte) error

ChangePublicPassphrase modifies the public passphrase of the wallet.

func (*Wallet) CreateSimpleTx Uses

func (w *Wallet) CreateSimpleTx(account uint32, outputs []*wire.TxOut,
    minconf int32, satPerKb bchutil.Amount, dryRun bool) (
    *txauthor.AuthoredTx, error)

CreateSimpleTx creates a new signed transaction spending unspent P2PKH outputs with at least minconf confirmations spending to any number of address/amount pairs. Change and an appropriate transaction fee are automatically included, if necessary. All transaction creation through this function is serialized to prevent the creation of many transactions which spend the same outputs.

NOTE: The dryRun argument can be set true to create a tx that doesn't alter the database. A tx created with this set to true SHOULD NOT be broadcasted.

func (*Wallet) CreateUnsignedTx Uses

func (w *Wallet) CreateUnsignedTx(account uint32, outputs []*wire.TxOut,
    minconf int32, satPerKb bchutil.Amount) (*txauthor.AuthoredTx, error)

CreateUnsignedTx creates a new unsigned transaction spending unspent P2PKH outputs with at laest minconf confirmations spending to any number of address/amount pairs. Change and an appropriate transaction fee are automatically included, if necessary. All transaction creation through this function is serialized to prevent the creation of many transactions which spend the same outputs.

func (*Wallet) CurrentAddress Uses

func (w *Wallet) CurrentAddress(account uint32, scope waddrmgr.KeyScope) (bchutil.Address, error)

CurrentAddress gets the most recently requested Bitcoin payment address from a wallet for a particular key-chain scope. This should never return a used address because we maintain a buffer of unused addresses.

func (*Wallet) CurrentChangeAddress Uses

func (w *Wallet) CurrentChangeAddress(account uint32, scope waddrmgr.KeyScope) (bchutil.Address, error)

CurrentChangeAddress gets the most recently requested Bitcoin change address from a wallet for a particular key-chain scope. This should never return a used address because we maintain a buffer of unused addresses.

func (*Wallet) Database Uses

func (w *Wallet) Database() walletdb.DB

Database returns the underlying walletdb database. This method is provided in order to allow applications wrapping bchwallet to store app-specific data with the wallet's database.

func (*Wallet) DumpPrivKeys Uses

func (w *Wallet) DumpPrivKeys() ([]string, error)

DumpPrivKeys returns the WIF-encoded private keys for all addresses with private keys in a wallet.

func (*Wallet) DumpWIFPrivateKey Uses

func (w *Wallet) DumpWIFPrivateKey(addr bchutil.Address) (string, error)

DumpWIFPrivateKey returns the WIF encoded private key for a single wallet address.

func (*Wallet) GetProxyDialer Uses

func (w *Wallet) GetProxyDialer() proxy.Dialer

GetProxyDialer returns the proxy dialer. It may be nil if the dialer was never set.

func (*Wallet) GetTransactions Uses

func (w *Wallet) GetTransactions(startBlock, endBlock *BlockIdentifier, cancel <-chan struct{}) (*GetTransactionsResult, error)

GetTransactions returns transaction results between a starting and ending block. Blocks in the block range may be specified by either a height or a hash.

Because this is a possibly lenghtly operation, a cancel channel is provided to cancel the task. If this channel unblocks, the results created thus far will be returned.

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.

func (*Wallet) HaveAddress Uses

func (w *Wallet) HaveAddress(a bchutil.Address) (bool, error)

HaveAddress returns whether the wallet is the owner of the address a.

func (*Wallet) ImportP2SHRedeemScript Uses

func (w *Wallet) ImportP2SHRedeemScript(script []byte) (*bchutil.AddressScriptHash, error)

ImportP2SHRedeemScript adds a P2SH redeem script to the wallet.

func (*Wallet) ImportPrivateKey Uses

func (w *Wallet) ImportPrivateKey(scope waddrmgr.KeyScope, wif *bchutil.WIF,
    bs *waddrmgr.BlockStamp, rescan bool) (string, error)

ImportPrivateKey imports a private key to the wallet and writes the new wallet to disk.

NOTE: If a block stamp is not provided, then the wallet's birthday will be set to the genesis block of the corresponding chain.

func (*Wallet) ListAddressTransactions Uses

func (w *Wallet) ListAddressTransactions(pkHashes map[string]struct{}) ([]btcjson.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 Uses

func (w *Wallet) ListAllTransactions() ([]btcjson.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 Uses

func (w *Wallet) ListSinceBlock(start, end, syncHeight int32) ([]btcjson.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) ListTransactions Uses

func (w *Wallet) ListTransactions(from, count int) ([]btcjson.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 Uses

func (w *Wallet) ListUnspent(minconf, maxconf int32,
    addresses map[string]struct{}) ([]*btcjson.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) Lock Uses

func (w *Wallet) Lock()

Lock locks the wallet's address manager.

func (*Wallet) LockOutpoint Uses

func (w *Wallet) LockOutpoint(op wire.OutPoint)

LockOutpoint marks an outpoint as locked, that is, it should not be used as an input for newly created transactions.

func (*Wallet) Locked Uses

func (w *Wallet) Locked() bool

Locked returns whether the account manager for a wallet is locked.

func (*Wallet) LockedOutpoint Uses

func (w *Wallet) LockedOutpoint(op wire.OutPoint) bool

LockedOutpoint returns whether an outpoint has been marked as locked and should not be used as an input for created transactions.

func (*Wallet) LockedOutpoints Uses

func (w *Wallet) LockedOutpoints() []btcjson.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) MakeMultiSigScript Uses

func (w *Wallet) MakeMultiSigScript(addrs []bchutil.Address, nRequired int) ([]byte, error)

MakeMultiSigScript 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 pubkeys and P2PKH addresses derived from them.

func (*Wallet) NewAddress Uses

func (w *Wallet) NewAddress(account uint32,
    scope waddrmgr.KeyScope) (bchutil.Address, error)

NewAddress returns the next external chained address for a wallet.

func (*Wallet) NewChangeAddress Uses

func (w *Wallet) NewChangeAddress(account uint32,
    scope waddrmgr.KeyScope) (bchutil.Address, error)

NewChangeAddress returns a new change address for a wallet.

func (*Wallet) NewRescanJob Uses

func (w *Wallet) NewRescanJob() (*RescanJob, error)

NewRescanJob creates a new RescanJob using the active data in the wallet. This can then be passed into SubmitRescan to do a rescan from the wallet's birthday.

func (*Wallet) NextAccount Uses

func (w *Wallet) NextAccount(scope waddrmgr.KeyScope, name string) (uint32, error)

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) PrivKeyForAddress Uses

func (w *Wallet) PrivKeyForAddress(a bchutil.Address) (*bchec.PrivateKey, error)

PrivKeyForAddress looks up the associated private key for a P2PKH or P2PK address.

func (*Wallet) PubKeyForAddress Uses

func (w *Wallet) PubKeyForAddress(a bchutil.Address) (*bchec.PublicKey, error)

PubKeyForAddress looks up the associated public key for a P2PKH address.

func (*Wallet) PublishTransaction Uses

func (w *Wallet) PublishTransaction(tx *wire.MsgTx) error

PublishTransaction sends the transaction to the consensus RPC server so it can be propagated to other nodes and eventually mined.

This function is unstable and will be removed once syncing code is moved out of the wallet.

func (*Wallet) RenameAccount Uses

func (w *Wallet) RenameAccount(scope waddrmgr.KeyScope, account uint32, newName string) error

RenameAccount sets the name for an account number to newName.

func (*Wallet) Rescan Uses

func (w *Wallet) Rescan(addrs []bchutil.Address, unspent []wtxmgr.Credit) error

Rescan begins a rescan for all active addresses and unspent outputs of a wallet. This is intended to be used to sync a wallet back up to the current best block in the main chain, and is considered an initial sync rescan.

func (*Wallet) ResetLockedOutpoints Uses

func (w *Wallet) ResetLockedOutpoints()

ResetLockedOutpoints resets the set of locked outpoints so all may be used as inputs for new transactions.

func (*Wallet) SendOutputs Uses

func (w *Wallet) SendOutputs(outputs []*wire.TxOut, account uint32,
    minconf int32, satPerKb bchutil.Amount) (*wire.MsgTx, error)

SendOutputs creates and sends payment transactions. It returns the transaction upon success.

func (*Wallet) SetChainSynced Uses

func (w *Wallet) SetChainSynced(synced bool)

SetChainSynced marks whether the wallet is connected to and currently in sync with the latest block notified by the chain server.

NOTE: Due to an API limitation with rpcclient, this may return true after the client disconnected (and is attempting a reconnect). This will be unknown until the reconnect notification is received, at which point the wallet can be marked out of sync again until after the next rescan completes.

func (*Wallet) SetProxyDialer Uses

func (w *Wallet) SetProxyDialer(dialer proxy.Dialer)

SetProxyDialer sets a proxy dialer object which can be used by any functions that need access to the proxy.

func (*Wallet) ShuttingDown Uses

func (w *Wallet) ShuttingDown() bool

ShuttingDown returns whether the wallet is currently in the process of shutting down or not.

func (*Wallet) SignTransaction Uses

func (w *Wallet) SignTransaction(tx *wire.MsgTx, inputValues []int64, hashType txscript.SigHashType,
    additionalPrevScripts map[wire.OutPoint][]byte,
    additionalKeysByAddress map[string]*bchutil.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 Uses

func (w *Wallet) SortedActivePaymentAddresses() ([]string, error)

SortedActivePaymentAddresses returns a slice of all active payment addresses in a wallet.

func (*Wallet) Start Uses

func (w *Wallet) Start()

Start starts the goroutines necessary to manage a wallet.

func (*Wallet) Stop Uses

func (w *Wallet) Stop()

Stop signals all wallet goroutines to shutdown.

func (*Wallet) SubmitRescan Uses

func (w *Wallet) SubmitRescan(job *RescanJob) <-chan error

SubmitRescan submits a RescanJob to the RescanManager. A channel is returned with the final error of the rescan. The channel is buffered and does not need to be read to prevent a deadlock.

func (*Wallet) SynchronizeRPC Uses

func (w *Wallet) SynchronizeRPC(chainClient chain.Interface)

SynchronizeRPC associates the wallet with the consensus RPC client, synchronizes the wallet with the latest changes to the blockchain, and continuously updates the wallet through RPC notifications.

This method is unstable and will be removed when all syncing logic is moved outside of the wallet package.

func (*Wallet) SynchronizingToNetwork Uses

func (w *Wallet) SynchronizingToNetwork() bool

SynchronizingToNetwork returns whether the wallet is currently synchronizing with the Bitcoin network.

func (*Wallet) TotalReceivedForAccounts Uses

func (w *Wallet) TotalReceivedForAccounts(scope waddrmgr.KeyScope,
    minConf int32) ([]AccountTotalReceivedResult, error)

TotalReceivedForAccounts iterates through a wallet's transaction history, returning the total amount of Bitcoin received for all accounts.

func (*Wallet) TotalReceivedForAddr Uses

func (w *Wallet) TotalReceivedForAddr(addr bchutil.Address, minConf int32) (bchutil.Amount, error)

TotalReceivedForAddr iterates through a wallet's transaction history, returning the total amount of bitcoins received for a single wallet address.

func (*Wallet) Unlock Uses

func (w *Wallet) Unlock(passphrase []byte, lock <-chan time.Time) error

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 Uses

func (w *Wallet) UnlockOutpoint(op wire.OutPoint)

UnlockOutpoint marks an outpoint as unlocked, that is, it may be used as an input for newly created transactions.

func (*Wallet) UnspentOutputs Uses

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) WaitForShutdown Uses

func (w *Wallet) WaitForShutdown()

WaitForShutdown blocks until all wallet goroutines have finished executing.


txauthorPackage txauthor provides transaction creation code for wallets.
txrulesPackage txrules provides transaction rules that should be followed by transaction authors for wide mempool acceptance and quick mining.

Package wallet imports 31 packages (graph) and is imported by 4 packages. Updated 2019-09-12. Refresh now. Tools for package owners.