package rpcclient

import (
	js "encoding/json"
	"github.com/p9c/p9/pkg/amt"
	"github.com/p9c/p9/pkg/btcaddr"
	"github.com/p9c/p9/pkg/chaincfg"
	"strconv"
	
	"github.com/p9c/p9/pkg/btcjson"
	"github.com/p9c/p9/pkg/chainhash"
	"github.com/p9c/p9/pkg/util"
	"github.com/p9c/p9/pkg/wire"
)

// *****************************
// Transaction Listing Functions
// *****************************

// FutureGetTransactionResult is a future promise to deliver the result of a GetTransactionAsync RPC invocation (or an
// applicable error).
type FutureGetTransactionResult chan *response

// Receive waits for the response promised by the future and returns detailed information about a wallet transaction.
func (r FutureGetTransactionResult) Receive() (*btcjson.GetTransactionResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a gettransaction result object
	var getTx btcjson.GetTransactionResult
	e = js.Unmarshal(res, &getTx)
	if e != nil {
		return nil, e
	}
	return &getTx, nil
}

// GetTransactionAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See GetTransaction for the blocking version and more details.
func (c *Client) GetTransactionAsync(txHash *chainhash.Hash) FutureGetTransactionResult {
	hash := ""
	if txHash != nil {
		hash = txHash.String()
	}
	cmd := btcjson.NewGetTransactionCmd(hash, nil)
	return c.sendCmd(cmd)
}

// GetTransaction returns detailed information about a wallet transaction.
//
// See GetRawTransaction to return the raw transaction instead.
func (c *Client) GetTransaction(txHash *chainhash.Hash) (*btcjson.GetTransactionResult, error) {
	return c.GetTransactionAsync(txHash).Receive()
}

// FutureListTransactionsResult is a future promise to deliver the result of a ListTransactionsAsync,
// ListTransactionsCountAsync, or ListTransactionsCountFromAsync RPC invocation (or an applicable error).
type FutureListTransactionsResult chan *response

// Receive waits for the response promised by the future and returns a list of the most recent transactions.
func (r FutureListTransactionsResult) Receive() ([]btcjson.ListTransactionsResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as an array of listtransaction result objects.
	var transactions []btcjson.ListTransactionsResult
	e = js.Unmarshal(res, &transactions)
	if e != nil {
		return nil, e
	}
	return transactions, nil
}

// ListTransactionsAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See ListTransactions for the blocking version and more details.
func (c *Client) ListTransactionsAsync(account string) FutureListTransactionsResult {
	cmd := btcjson.NewListTransactionsCmd(&account, nil, nil, nil)
	D.S(cmd)
	return c.sendCmd(cmd)
}

// ListTransactions returns a list of the most recent transactions.
//
// See the ListTransactionsCount and ListTransactionsCountFrom to control the number of transactions returned and
// starting point, respectively.
func (c *Client) ListTransactions(account string) ([]btcjson.ListTransactionsResult, error) {
	return c.ListTransactionsAsync(account).Receive()
}

// ListTransactionsCountAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ListTransactionsCount for the blocking version and more details.
func (c *Client) ListTransactionsCountAsync(account string, count int) FutureListTransactionsResult {
	cmd := btcjson.NewListTransactionsCmd(&account, &count, nil, nil)
	return c.sendCmd(cmd)
}

// ListTransactionsCount returns a list of the most recent transactions up to the passed count.
//
// See the ListTransactions and ListTransactionsCountFrom functions for different options.
func (c *Client) ListTransactionsCount(account string, count int) ([]btcjson.ListTransactionsResult, error) {
	return c.ListTransactionsCountAsync(account, count).Receive()
}

// ListTransactionsCountFromAsync returns an instance of a type that can be used to get the result of the RPC at some
// future time by invoking the Receive function on the returned instance.
//
// See ListTransactionsCountFrom for the blocking version and more details.
func (c *Client) ListTransactionsCountFromAsync(account string, count, from int) FutureListTransactionsResult {
	cmd := btcjson.NewListTransactionsCmd(&account, &count, &from, nil)
	return c.sendCmd(cmd)
}

// ListTransactionsCountFrom returns a list of the most recent transactions up to the passed count while skipping the
// first 'from' transactions.
//
// See the ListTransactions and ListTransactionsCount functions to use defaults.
func (c *Client) ListTransactionsCountFrom(account string, count, from int) ([]btcjson.ListTransactionsResult, error) {
	return c.ListTransactionsCountFromAsync(account, count, from).Receive()
}

// FutureListUnspentResult is a future promise to deliver the result of a ListUnspentAsync, ListUnspentMinAsync,
// ListUnspentMinMaxAsync, or ListUnspentMinMaxAddressesAsync RPC invocation (or an applicable error).
type FutureListUnspentResult chan *response

// Receive waits for the response promised by the future and returns all unspent wallet transaction outputs returned by
// the RPC call.
//
// If the future wac returned by a call to ListUnspentMinAsync, ListUnspentMinMaxAsync, or
// ListUnspentMinMaxAddressesAsync, the range may be limited by the parameters of the RPC invocation.
func (r FutureListUnspentResult) Receive() ([]btcjson.ListUnspentResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as an array of listunspent results.
	var unspent []btcjson.ListUnspentResult
	e = js.Unmarshal(res, &unspent)
	if e != nil {
		return nil, e
	}
	return unspent, nil
}

// ListUnspentAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See ListUnspent for the blocking version and more details.
func (c *Client) ListUnspentAsync() FutureListUnspentResult {
	cmd := btcjson.NewListUnspentCmd(nil, nil, nil)
	return c.sendCmd(cmd)
}

// ListUnspentMinAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See ListUnspentMin for the blocking version and more details.
func (c *Client) ListUnspentMinAsync(minConf int) FutureListUnspentResult {
	cmd := btcjson.NewListUnspentCmd(&minConf, nil, nil)
	return c.sendCmd(cmd)
}

// ListUnspentMinMaxAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ListUnspentMinMax for the blocking version and more details.
func (c *Client) ListUnspentMinMaxAsync(minConf, maxConf int) FutureListUnspentResult {
	cmd := btcjson.NewListUnspentCmd(&minConf, &maxConf, nil)
	return c.sendCmd(cmd)
}

// ListUnspentMinMaxAddressesAsync returns an instance of a type that can be used to get the result of the RPC at some
// future time by invoking the Receive function on the returned instance.
//
// See ListUnspentMinMaxAddresses for the blocking version and more details.
func (c *Client) ListUnspentMinMaxAddressesAsync(minConf, maxConf int, addrs []btcaddr.Address,
) FutureListUnspentResult {
	addrStrs := make([]string, 0, len(addrs))
	for _, a := range addrs {
		addrStrs = append(addrStrs, a.EncodeAddress())
	}
	cmd := btcjson.NewListUnspentCmd(&minConf, &maxConf, &addrStrs)
	return c.sendCmd(cmd)
}

// ListUnspent returns all unspent transaction outputs known to a wallet, using the default number of minimum and
// maximum number of confirmations as a filter (1 and 999999, respectively).
func (c *Client) ListUnspent() ([]btcjson.ListUnspentResult, error) {
	return c.ListUnspentAsync().Receive()
}

// ListUnspentMin returns all unspent transaction outputs known to a wallet, using the specified number of minimum
// conformations and default number of maximum confiramtions (999999) as a filter.
func (c *Client) ListUnspentMin(minConf int) ([]btcjson.ListUnspentResult, error) {
	return c.ListUnspentMinAsync(minConf).Receive()
}

// ListUnspentMinMax returns all unspent transaction outputs known to a wallet, using the specified number of minimum
// and maximum number of confirmations as a filter.
func (c *Client) ListUnspentMinMax(minConf, maxConf int) ([]btcjson.ListUnspentResult, error) {
	return c.ListUnspentMinMaxAsync(minConf, maxConf).Receive()
}

// ListUnspentMinMaxAddresses returns all unspent transaction outputs that pay to any of specified addresses in a wallet
// using the specified number of minimum and maximum number of confirmations as a filter.
func (c *Client) ListUnspentMinMaxAddresses(minConf, maxConf int, addrs []btcaddr.Address) (
	[]btcjson.ListUnspentResult,
	error,
) {
	return c.ListUnspentMinMaxAddressesAsync(minConf, maxConf, addrs).Receive()
}

// FutureListSinceBlockResult is a future promise to deliver the result of a ListSinceBlockAsync or
// ListSinceBlockMinConfAsync RPC invocation (or an applicable error).
type FutureListSinceBlockResult chan *response

// Receive waits for the response promised by the future and returns all transactions added in blocks since the
// specified block hash, or all transactions if it is nil.
func (r FutureListSinceBlockResult) Receive() (*btcjson.ListSinceBlockResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a listsinceblock result object.
	var listResult btcjson.ListSinceBlockResult
	e = js.Unmarshal(res, &listResult)
	if e != nil {
		return nil, e
	}
	return &listResult, nil
}

// ListSinceBlockAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See ListSinceBlock for the blocking version and more details.
func (c *Client) ListSinceBlockAsync(blockHash *chainhash.Hash) FutureListSinceBlockResult {
	var hash *string
	if blockHash != nil {
		hash = btcjson.String(blockHash.String())
	}
	cmd := btcjson.NewListSinceBlockCmd(hash, nil, nil)
	return c.sendCmd(cmd)
}

// ListSinceBlock returns all transactions added in blocks since the specified block hash, or all transactions if it is
// nil, using the default number of minimum confirmations as a filter.
//
// See ListSinceBlockMinConf to override the minimum number of confirmations.
func (c *Client) ListSinceBlock(blockHash *chainhash.Hash) (*btcjson.ListSinceBlockResult, error) {
	return c.ListSinceBlockAsync(blockHash).Receive()
}

// ListSinceBlockMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ListSinceBlockMinConf for the blocking version and more details.
func (c *Client) ListSinceBlockMinConfAsync(blockHash *chainhash.Hash, minConfirms int) FutureListSinceBlockResult {
	var hash *string
	if blockHash != nil {
		hash = btcjson.String(blockHash.String())
	}
	cmd := btcjson.NewListSinceBlockCmd(hash, &minConfirms, nil)
	return c.sendCmd(cmd)
}

// ListSinceBlockMinConf returns all transactions added in blocks since the specified block hash, or all transactions if
// it is nil, using the specified number of minimum confirmations as a filter.
//
// See ListSinceBlock to use the default minimum number of confirmations.
func (c *Client) ListSinceBlockMinConf(blockHash *chainhash.Hash, minConfirms int) (
	*btcjson.ListSinceBlockResult,
	error,
) {
	return c.ListSinceBlockMinConfAsync(blockHash, minConfirms).Receive()
}

// **************************
// Transaction Send Functions
// **************************

// FutureLockUnspentResult is a future promise to deliver the error result of a LockUnspentAsync RPC invocation.
type FutureLockUnspentResult chan *response

// Receive waits for the response promised by the future and returns the result of locking or unlocking the unspent
// output(s).
func (r FutureLockUnspentResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// LockUnspentAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See LockUnspent for the blocking version and more details.
func (c *Client) LockUnspentAsync(unlock bool, ops []*wire.OutPoint) FutureLockUnspentResult {
	outputs := make([]btcjson.TransactionInput, len(ops))
	for i, op := range ops {
		outputs[i] = btcjson.TransactionInput{
			Txid: op.Hash.String(),
			Vout: op.Index,
		}
	}
	cmd := btcjson.NewLockUnspentCmd(unlock, outputs)
	return c.sendCmd(cmd)
}

// LockUnspent marks outputs as locked or unlocked, depending on the value of the unlock bool. When locked, the unspent
// output will not be selected as input for newly created, non-raw transactions, and will not be returned in future
// ListUnspent results, until the output is marked unlocked again.
//
// If unlock is false, each outpoint in ops will be marked locked. If unlocked is true and specific outputs are
// specified in ops (len != 0), exactly those outputs will be marked unlocked. If unlocked is true and no outpoints are
// specified, all previous locked outputs are marked unlocked.
//
// The locked or unlocked state of outputs are not written to disk and after restarting a wallet process, this data will
// be reset (every output unlocked).
//
// NOTE: While this method would be a bit more readable if the unlock bool was reversed (that is, LockUnspent(true, ...)
// locked the outputs), it has been left as unlock to keep compatibility with the reference client API and to avoid
// confusion for those who are already familiar with the lockunspent RPC.
func (c *Client) LockUnspent(unlock bool, ops []*wire.OutPoint) (e error) {
	return c.LockUnspentAsync(unlock, ops).Receive()
}

// FutureListLockUnspentResult is a future promise to deliver the result of a ListLockUnspentAsync RPC invocation (or an
// applicable error).
type FutureListLockUnspentResult chan *response

// Receive waits for the response promised by the future and returns the result of all currently locked unspent outputs.
func (r FutureListLockUnspentResult) Receive() ([]*wire.OutPoint, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal as an array of transaction inputs.
	var inputs []btcjson.TransactionInput
	e = js.Unmarshal(res, &inputs)
	if e != nil {
		return nil, e
	}
	// Create a slice of outpoints from the transaction input structs.
	ops := make([]*wire.OutPoint, len(inputs))
	for i, input := range inputs {
		sha, e := chainhash.NewHashFromStr(input.Txid)
		if e != nil {
			return nil, e
		}
		ops[i] = wire.NewOutPoint(sha, input.Vout)
	}
	return ops, nil
}

// ListLockUnspentAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See ListLockUnspent for the blocking version and more details.
func (c *Client) ListLockUnspentAsync() FutureListLockUnspentResult {
	cmd := btcjson.NewListLockUnspentCmd()
	return c.sendCmd(cmd)
}

// ListLockUnspent returns a slice of outpoints for all unspent outputs marked as locked by a wallet. Unspent outputs
// may be marked locked using LockOutput.
func (c *Client) ListLockUnspent() ([]*wire.OutPoint, error) {
	return c.ListLockUnspentAsync().Receive()
}

// FutureSetTxFeeResult is a future promise to deliver the result of a SetTxFeeAsync RPC invocation (or an applicable
// error).
type FutureSetTxFeeResult chan *response

// Receive waits for the response promised by the future and returns the result of setting an optional transaction fee
// per KB that helps ensure transactions are processed quickly. Most transaction are 1KB.
func (r FutureSetTxFeeResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// SetTxFeeAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See SetTxFee for the blocking version and more details.
func (c *Client) SetTxFeeAsync(fee amt.Amount) FutureSetTxFeeResult {
	cmd := btcjson.NewSetTxFeeCmd(fee.ToDUO())
	return c.sendCmd(cmd)
}

// SetTxFee sets an optional transaction fee per KB that helps ensure transactions are processed quickly. Most
// transaction are 1KB.
func (c *Client) SetTxFee(fee amt.Amount) (e error) {
	return c.SetTxFeeAsync(fee).Receive()
}

// FutureSendToAddressResult is a future promise to deliver the result of a SendToAddressAsync RPC invocation (or an
// applicable error).
type FutureSendToAddressResult chan *response

// Receive waits for the response promised by the future and returns the hash of the transaction sending the passed
// amount to the given address.
func (r FutureSendToAddressResult) Receive() (*chainhash.Hash, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a string.
	var txHash string
	e = js.Unmarshal(res, &txHash)
	if e != nil {
		return nil, e
	}
	return chainhash.NewHashFromStr(txHash)
}

// SendToAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See SendToAddress for the blocking version and more details.
func (c *Client) SendToAddressAsync(address btcaddr.Address, amount amt.Amount) FutureSendToAddressResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewSendToAddressCmd(addr, amount.ToDUO(), nil, nil)
	return c.sendCmd(cmd)
}

// SendToAddress sends the passed amount to the given address.
//
// See SendToAddressComment to associate comments with the transaction in the wallet. The comments are not part of the
// transaction and are only internal to the wallet.
//
// NOTE: This function requires to the wallet to be unlocked.
//
// See the WalletPassphrase function for more details.
func (c *Client) SendToAddress(address btcaddr.Address, amount amt.Amount) (*chainhash.Hash, error) {
	return c.SendToAddressAsync(address, amount).Receive()
}

// SendToAddressCommentAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See SendToAddressComment for the blocking version and more details.
func (c *Client) SendToAddressCommentAsync(
	address btcaddr.Address,
	amount amt.Amount, comment,
	commentTo string,
) FutureSendToAddressResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewSendToAddressCmd(
		addr, amount.ToDUO(), &comment,
		&commentTo,
	)
	return c.sendCmd(cmd)
}

// SendToAddressComment sends the passed amount to the given address and stores the provided comment and comment to in
// the wallet. The comment parameter is intended to be used for the purpose of the transaction while the commentTo
// parameter is indended to be used for who the transaction is being sent to.
//
// The comments are not part of the transaction and are only internal to the wallet.
//
// See SendToAddress to avoid using comments.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) SendToAddressComment(
	address btcaddr.Address,
	amount amt.Amount,
	comment, commentTo string,
) (*chainhash.Hash, error) {
	return c.SendToAddressCommentAsync(
		address, amount, comment,
		commentTo,
	).Receive()
}

// FutureSendFromResult is a future promise to deliver the result of a SendFromAsync, SendFromMinConfAsync, or
// SendFromCommentAsync RPC invocation (or an applicable error).
type FutureSendFromResult chan *response

// Receive waits for the response promised by the future and returns the hash of the transaction sending amount to the
// given address using the provided account as a source of funds.
func (r FutureSendFromResult) Receive() (*chainhash.Hash, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a string.
	var txHash string
	e = js.Unmarshal(res, &txHash)
	if e != nil {
		return nil, e
	}
	return chainhash.NewHashFromStr(txHash)
}

// SendFromAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See SendFrom for the blocking version and more details.
func (c *Client) SendFromAsync(fromAccount string, toAddress btcaddr.Address, amount amt.Amount) FutureSendFromResult {
	addr := toAddress.EncodeAddress()
	cmd := btcjson.NewSendFromCmd(
		fromAccount, addr, amount.ToDUO(), nil,
		nil, nil,
	)
	return c.sendCmd(cmd)
}

// SendFrom sends the passed amount to the given address using the provided account as a source of funds. Only funds
// with the default number of minimum confirmations will be used.
//
// See SendFromMinConf and SendFromComment for different options.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) SendFrom(fromAccount string, toAddress btcaddr.Address, amount amt.Amount) (*chainhash.Hash, error) {
	return c.SendFromAsync(fromAccount, toAddress, amount).Receive()
}

// SendFromMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See SendFromMinConf for the blocking version and more details.
func (c *Client) SendFromMinConfAsync(
	fromAccount string,
	toAddress btcaddr.Address,
	amount amt.Amount,
	minConfirms int,
) FutureSendFromResult {
	addr := toAddress.EncodeAddress()
	cmd := btcjson.NewSendFromCmd(
		fromAccount, addr, amount.ToDUO(),
		&minConfirms, nil, nil,
	)
	return c.sendCmd(cmd)
}

// SendFromMinConf sends the passed amount to the given address using the provided account as a source of funds. Only
// funds with the passed number of minimum confirmations will be used.
//
// See SendFrom to use the default number of minimum confirmations and SendFromComment for additional options.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) SendFromMinConf(
	fromAccount string,
	toAddress btcaddr.Address,
	amount amt.Amount,
	minConfirms int,
) (*chainhash.Hash, error) {
	return c.SendFromMinConfAsync(
		fromAccount, toAddress, amount,
		minConfirms,
	).Receive()
}

// SendFromCommentAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See SendFromComment for the blocking version and more details.
func (c *Client) SendFromCommentAsync(
	fromAccount string,
	toAddress btcaddr.Address, amount amt.Amount, minConfirms int,
	comment, commentTo string,
) FutureSendFromResult {
	addr := toAddress.EncodeAddress()
	cmd := btcjson.NewSendFromCmd(
		fromAccount, addr, amount.ToDUO(),
		&minConfirms, &comment, &commentTo,
	)
	return c.sendCmd(cmd)
}

// SendFromComment sends the passed amount to the given address using the provided account as a source of funds and
// stores the provided comment and comment to in the wallet. The comment parameter is intended to be used for the
// purpose of the transaction while the commentTo parameter is intended to be used for who the transaction is being sent
// to. Only funds with the passed number of minimum confirmations will be used.
//
// See SendFrom and SendFromMinConf to use defaults.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) SendFromComment(
	fromAccount string, toAddress btcaddr.Address,
	amount amt.Amount, minConfirms int,
	comment, commentTo string,
) (*chainhash.Hash, error) {
	return c.SendFromCommentAsync(
		fromAccount, toAddress, amount,
		minConfirms, comment, commentTo,
	).Receive()
}

// FutureSendManyResult is a future promise to deliver the result of a SendManyAsync, SendManyMinConfAsync, or
// SendManyCommentAsync RPC invocation (or an applicable error).
type FutureSendManyResult chan *response

// Receive waits for the response promised by the future and returns the hash of the transaction sending multiple
// amounts to multiple addresses using the provided account as a source of funds.
func (r FutureSendManyResult) Receive() (*chainhash.Hash, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmashal result as a string.
	var txHash string
	e = js.Unmarshal(res, &txHash)
	if e != nil {
		return nil, e
	}
	return chainhash.NewHashFromStr(txHash)
}

// SendManyAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See SendMany for the blocking version and more details.
func (c *Client) SendManyAsync(fromAccount string, amounts map[btcaddr.Address]amt.Amount) FutureSendManyResult {
	convertedAmounts := make(map[string]float64, len(amounts))
	for addr, amount := range amounts {
		convertedAmounts[addr.EncodeAddress()] = amount.ToDUO()
	}
	cmd := btcjson.NewSendManyCmd(fromAccount, convertedAmounts, nil, nil)
	return c.sendCmd(cmd)
}

// SendMany sends multiple amounts to multiple addresses using the provided account as a source of funds in a single
// transaction. Only funds with the default number of minimum confirmations will be used.
//
// See SendManyMinConf and SendManyComment for different options.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) SendMany(fromAccount string, amounts map[btcaddr.Address]amt.Amount) (*chainhash.Hash, error) {
	return c.SendManyAsync(fromAccount, amounts).Receive()
}

// SendManyMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See SendManyMinConf for the blocking version and more details.
func (c *Client) SendManyMinConfAsync(
	fromAccount string,
	amounts map[btcaddr.Address]amt.Amount,
	minConfirms int,
) FutureSendManyResult {
	convertedAmounts := make(map[string]float64, len(amounts))
	for addr, amount := range amounts {
		convertedAmounts[addr.EncodeAddress()] = amount.ToDUO()
	}
	cmd := btcjson.NewSendManyCmd(
		fromAccount, convertedAmounts,
		&minConfirms, nil,
	)
	return c.sendCmd(cmd)
}

// SendManyMinConf sends multiple amounts to multiple addresses using the provided account as a source of funds in a
// single transaction. Only funds with the passed number of minimum confirmations will be used.
//
// See SendMany to use the default number of minimum confirmations and SendManyComment for additional options.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) SendManyMinConf(
	fromAccount string,
	amounts map[btcaddr.Address]amt.Amount,
	minConfirms int,
) (*chainhash.Hash, error) {
	return c.SendManyMinConfAsync(fromAccount, amounts, minConfirms).Receive()
}

// SendManyCommentAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See SendManyComment for the blocking version and more details.
func (c *Client) SendManyCommentAsync(
	fromAccount string,
	amounts map[btcaddr.Address]amt.Amount, minConfirms int,
	comment string,
) FutureSendManyResult {
	convertedAmounts := make(map[string]float64, len(amounts))
	for addr, amount := range amounts {
		convertedAmounts[addr.EncodeAddress()] = amount.ToDUO()
	}
	cmd := btcjson.NewSendManyCmd(
		fromAccount, convertedAmounts,
		&minConfirms, &comment,
	)
	return c.sendCmd(cmd)
}

// SendManyComment sends multiple amounts to multiple addresses using the provided account as a source of funds in a
// single transaction and stores the provided comment in the wallet. The comment parameter is intended to be used for
// the purpose of the transaction Only funds with the passed number of minimum confirmations will be used.
//
// See SendMany and SendManyMinConf to use defaults.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) SendManyComment(
	fromAccount string,
	amounts map[btcaddr.Address]amt.Amount, minConfirms int,
	comment string,
) (*chainhash.Hash, error) {
	return c.SendManyCommentAsync(
		fromAccount, amounts, minConfirms,
		comment,
	).Receive()
}

// *************************
// Address/Account Functions
// *************************

// FutureAddMultisigAddressResult is a future promise to deliver the result of a AddMultisigAddressAsync RPC invocation
// (or an applicable error).
type FutureAddMultisigAddressResult chan *response

// Receive waits for the response promised by the future and returns the multisignature address that requires the
// specified number of signatures for the provided addresses.
func (r FutureAddMultisigAddressResult) Receive() (btcaddr.Address, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a string.
	var addr string
	e = js.Unmarshal(res, &addr)
	if e != nil {
		return nil, e
	}
	return btcaddr.Decode(addr, &chaincfg.MainNetParams)
}

// AddMultisigAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See AddMultisigAddress for the blocking version and more details.
func (c *Client) AddMultisigAddressAsync(
	requiredSigs int,
	addresses []btcaddr.Address,
	account string,
) FutureAddMultisigAddressResult {
	addrs := make([]string, 0, len(addresses))
	for _, addr := range addresses {
		addrs = append(addrs, addr.String())
	}
	cmd := btcjson.NewAddMultisigAddressCmd(requiredSigs, addrs, &account)
	return c.sendCmd(cmd)
}

// AddMultisigAddress adds a multisignature address that requires the specified number of signatures for the provided
// addresses to the wallet.
func (c *Client) AddMultisigAddress(requiredSigs int, addresses []btcaddr.Address, account string) (btcaddr.Address,
	error,
) {
	return c.AddMultisigAddressAsync(
		requiredSigs, addresses,
		account,
	).Receive()
}

// FutureCreateMultisigResult is a future promise to deliver the result of a CreateMultisigAsync RPC invocation (or an
// applicable error).
type FutureCreateMultisigResult chan *response

// Receive waits for the response promised by the future and returns the multisignature address and script needed to
// redeem it.
func (r FutureCreateMultisigResult) Receive() (*btcjson.CreateMultiSigResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a createmultisig result object.
	var multisigRes btcjson.CreateMultiSigResult
	e = js.Unmarshal(res, &multisigRes)
	if e != nil {
		return nil, e
	}
	return &multisigRes, nil
}

// CreateMultisigAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See CreateMultisig for the blocking version and more details.
func (c *Client) CreateMultisigAsync(requiredSigs int, addresses []btcaddr.Address) FutureCreateMultisigResult {
	addrs := make([]string, 0, len(addresses))
	for _, addr := range addresses {
		addrs = append(addrs, addr.String())
	}
	cmd := btcjson.NewCreateMultisigCmd(requiredSigs, addrs)
	return c.sendCmd(cmd)
}

// CreateMultisig creates a multisignature address that requires the specified number of signatures for the provided
// addresses and returns the multisignature address and script needed to redeem it.
func (c *Client) CreateMultisig(requiredSigs int, addresses []btcaddr.Address) (*btcjson.CreateMultiSigResult, error) {
	return c.CreateMultisigAsync(requiredSigs, addresses).Receive()
}

// FutureCreateNewAccountResult is a future promise to deliver the result of a CreateNewAccountAsync RPC invocation (or
// an applicable error).
type FutureCreateNewAccountResult chan *response

// Receive waits for the response promised by the future and returns the result of creating new account.
func (r FutureCreateNewAccountResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// CreateNewAccountAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See CreateNewAccount for the blocking version and more details.
func (c *Client) CreateNewAccountAsync(account string) FutureCreateNewAccountResult {
	cmd := btcjson.NewCreateNewAccountCmd(account)
	return c.sendCmd(cmd)
}

// CreateNewAccount creates a new wallet account.
func (c *Client) CreateNewAccount(account string) (e error) {
	return c.CreateNewAccountAsync(account).Receive()
}

// FutureGetNewAddressResult is a future promise to deliver the result of a GetNewAddressAsync RPC invocation (or an
// applicable error).
type FutureGetNewAddressResult chan *response

// Receive waits for the response promised by the future and returns a new address.
func (r FutureGetNewAddressResult) Receive() (btcaddr.Address, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a string.
	var addr string
	e = js.Unmarshal(res, &addr)
	if e != nil {
		return nil, e
	}
	return btcaddr.Decode(addr, &chaincfg.MainNetParams)
}

// GetNewAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See GetNewAddress for the blocking version and more details.
func (c *Client) GetNewAddressAsync(account string) FutureGetNewAddressResult {
	T.Ln("### GetNewAddressAsync")
	cmd := btcjson.NewGetNewAddressCmd(&account)
	// D.S(cmd)
	return c.sendCmd(cmd)
}

// GetNewAddress returns a new address.
func (c *Client) GetNewAddress(account string) (btcaddr.Address, error) {
	T.Ln("### GetNewAddress")
	return c.GetNewAddressAsync(account).Receive()
}

// FutureGetRawChangeAddressResult is a future promise to deliver the result of a GetRawChangeAddressAsync RPC
// invocation (or an applicable error).
type FutureGetRawChangeAddressResult chan *response

// Receive waits for the response promised by the future and returns a new address for receiving change that will be
// associated with the provided account. Note that this is only for raw transactions and NOT for normal use.
func (r FutureGetRawChangeAddressResult) Receive() (btcaddr.Address, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a string.
	var addr string
	e = js.Unmarshal(res, &addr)
	if e != nil {
		return nil, e
	}
	return btcaddr.Decode(addr, &chaincfg.MainNetParams)
}

// GetRawChangeAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See GetRawChangeAddress for the blocking version and more details.
func (c *Client) GetRawChangeAddressAsync(account string) FutureGetRawChangeAddressResult {
	cmd := btcjson.NewGetRawChangeAddressCmd(&account)
	return c.sendCmd(cmd)
}

// GetRawChangeAddress returns a new address for receiving change that will be associated with the provided account.
//
// Note that this is only for raw transactions and NOT for normal use.
func (c *Client) GetRawChangeAddress(account string) (btcaddr.Address, error) {
	return c.GetRawChangeAddressAsync(account).Receive()
}

// FutureAddWitnessAddressResult is a future promise to deliver the result of a
// AddWitnessAddressAsync RPC invocation (or an applicable error).
type FutureAddWitnessAddressResult chan *response

// Receive waits for the response promised by the future and returns the new address.
func (r FutureAddWitnessAddressResult) Receive() (btcaddr.Address, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a string.
	var addr string
	e = js.Unmarshal(res, &addr)
	if e != nil {
		return nil, e
	}
	return btcaddr.Decode(addr, &chaincfg.MainNetParams)
}

// AddWitnessAddressAsync returns an instance of a type that can be used to get
// the result of the RPC at some future time by invoking the Receive function on
// the returned instance.
//
// See AddWitnessAddress for the blocking version and more details.
func (c *Client) AddWitnessAddressAsync(address string) FutureAddWitnessAddressResult {
	cmd := btcjson.NewAddWitnessAddressCmd(address)
	return c.sendCmd(cmd)
}

// AddWitnessAddress adds a witness address for a script and returns the new
// address (P2SH of the witness script).
func (c *Client) AddWitnessAddress(address string) (btcaddr.Address, error) {
	return c.AddWitnessAddressAsync(address).Receive()
}

// FutureGetAccountAddressResult is a future promise to deliver the result of a GetAccountAddressAsync RPC invocation
// (or an applicable error).
type FutureGetAccountAddressResult chan *response

// Receive waits for the response promised by the future and returns the current Bitcoin address for receiving payments
// to the specified account.
func (r FutureGetAccountAddressResult) Receive() (btcaddr.Address, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a string.
	var addr string
	e = js.Unmarshal(res, &addr)
	if e != nil {
		return nil, e
	}
	return btcaddr.Decode(addr, &chaincfg.MainNetParams)
}

// GetAccountAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See GetAccountAddress for the blocking version and more details.
func (c *Client) GetAccountAddressAsync(account string) FutureGetAccountAddressResult {
	cmd := btcjson.NewGetAccountAddressCmd(account)
	return c.sendCmd(cmd)
}

// GetAccountAddress returns the current Bitcoin address for receiving payments to the specified account.
func (c *Client) GetAccountAddress(account string) (btcaddr.Address, error) {
	return c.GetAccountAddressAsync(account).Receive()
}

// FutureGetAccountResult is a future promise to deliver the result of a GetAccountAsync RPC invocation (or an
// applicable error).
type FutureGetAccountResult chan *response

// Receive waits for the response promised by the future and returns the account associated with the passed address.
func (r FutureGetAccountResult) Receive() (string, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return "", e
	}
	// Unmarshal result as a string.
	var account string
	e = js.Unmarshal(res, &account)
	if e != nil {
		return "", e
	}
	return account, nil
}

// GetAccountAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See GetAccount for the blocking version and more details.
func (c *Client) GetAccountAsync(address btcaddr.Address) FutureGetAccountResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewGetAccountCmd(addr)
	return c.sendCmd(cmd)
}

// GetAccount returns the account associated with the passed address.
func (c *Client) GetAccount(address btcaddr.Address) (string, error) {
	return c.GetAccountAsync(address).Receive()
}

// FutureSetAccountResult is a future promise to deliver the result of a SetAccountAsync RPC invocation (or an
// applicable error).
type FutureSetAccountResult chan *response

// Receive waits for the response promised by the future and returns the result of setting the account to be associated
// with the passed address.
func (r FutureSetAccountResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// SetAccountAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See SetAccount for the blocking version and more details.
func (c *Client) SetAccountAsync(address btcaddr.Address, account string) FutureSetAccountResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewSetAccountCmd(addr, account)
	return c.sendCmd(cmd)
}

// SetAccount sets the account associated with the passed address.
func (c *Client) SetAccount(address btcaddr.Address, account string) (e error) {
	return c.SetAccountAsync(address, account).Receive()
}

// FutureGetAddressesByAccountResult is a future promise to deliver the result of a GetAddressesByAccountAsync RPC
// invocation (or an applicable error).
type FutureGetAddressesByAccountResult chan *response

// Receive waits for the response promised by the future and returns the list of addresses associated with the passed
// account.
func (r FutureGetAddressesByAccountResult) Receive() ([]btcaddr.Address, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as an array of string.
	var addrStrings []string
	e = js.Unmarshal(res, &addrStrings)
	if e != nil {
		return nil, e
	}
	addrs := make([]btcaddr.Address, 0, len(addrStrings))
	for _, addrStr := range addrStrings {
		addr, e := btcaddr.Decode(
			addrStr,
			&chaincfg.MainNetParams,
		)
		if e != nil {
			return nil, e
		}
		addrs = append(addrs, addr)
	}
	return addrs, nil
}

// GetAddressesByAccountAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See GetAddressesByAccount for the blocking version and more details.
func (c *Client) GetAddressesByAccountAsync(account string) FutureGetAddressesByAccountResult {
	cmd := btcjson.NewGetAddressesByAccountCmd(account)
	return c.sendCmd(cmd)
}

// GetAddressesByAccount returns the list of addresses associated with the passed account.
func (c *Client) GetAddressesByAccount(account string) ([]btcaddr.Address, error) {
	return c.GetAddressesByAccountAsync(account).Receive()
}

// FutureMoveResult is a future promise to deliver the result of a MoveAsync, MoveMinConfAsync, or MoveCommentAsync RPC
// invocation (or an applicable error).
type FutureMoveResult chan *response

// Receive waits for the response promised by the future and returns the result of the move operation.
func (r FutureMoveResult) Receive() (bool, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return false, e
	}
	// Unmarshal result as a boolean.
	var moveResult bool
	e = js.Unmarshal(res, &moveResult)
	if e != nil {
		return false, e
	}
	return moveResult, nil
}

// MoveAsync returns an instance of a type that can be used to get the result of the RPC at some future time by invoking
// the Receive function on the returned instance.
//
// See Move for the blocking version and more details.
func (c *Client) MoveAsync(fromAccount, toAccount string, amount amt.Amount) FutureMoveResult {
	cmd := btcjson.NewMoveCmd(
		fromAccount, toAccount, amount.ToDUO(), nil,
		nil,
	)
	return c.sendCmd(cmd)
}

// Move moves specified amount from one account in your wallet to another. Only funds with the default number of minimum
// confirmations will be used.
//
// See MoveMinConf and MoveComment for different options.
func (c *Client) Move(fromAccount, toAccount string, amount amt.Amount) (bool, error) {
	return c.MoveAsync(fromAccount, toAccount, amount).Receive()
}

// MoveMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See MoveMinConf for the blocking version and more details.
func (c *Client) MoveMinConfAsync(
	fromAccount, toAccount string,
	amount amt.Amount, minConfirms int,
) FutureMoveResult {
	cmd := btcjson.NewMoveCmd(
		fromAccount, toAccount, amount.ToDUO(),
		&minConfirms, nil,
	)
	return c.sendCmd(cmd)
}

// MoveMinConf moves specified amount from one account in your wallet to another. Only funds with the passed number of
// minimum confirmations will be used.
//
// See Move to use the default number of minimum confirmations and MoveComment for additional options.
func (c *Client) MoveMinConf(fromAccount, toAccount string, amount amt.Amount, minConf int) (bool, error) {
	return c.MoveMinConfAsync(fromAccount, toAccount, amount, minConf).Receive()
}

// MoveCommentAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See MoveComment for the blocking version and more details.
func (c *Client) MoveCommentAsync(
	fromAccount, toAccount string,
	amount amt.Amount, minConfirms int, comment string,
) FutureMoveResult {
	cmd := btcjson.NewMoveCmd(
		fromAccount, toAccount, amount.ToDUO(),
		&minConfirms, &comment,
	)
	return c.sendCmd(cmd)
}

// MoveComment moves specified amount from one account in your wallet to another and stores the provided comment in the
// wallet. The comment parameter is only available in the wallet. Only funds with the passed number of minimum
// confirmations will be used.
//
// See Move and MoveMinConf to use defaults.
func (c *Client) MoveComment(
	fromAccount, toAccount string, amount amt.Amount,
	minConf int, comment string,
) (bool, error) {
	return c.MoveCommentAsync(
		fromAccount, toAccount, amount, minConf,
		comment,
	).Receive()
}

// FutureRenameAccountResult is a future promise to deliver the result of a RenameAccountAsync RPC invocation (or an
// applicable error).
type FutureRenameAccountResult chan *response

// Receive waits for the response promised by the future and returns the result of creating new account.
func (r FutureRenameAccountResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// RenameAccountAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See RenameAccount for the blocking version and more details.
func (c *Client) RenameAccountAsync(oldAccount, newAccount string) FutureRenameAccountResult {
	cmd := btcjson.NewRenameAccountCmd(oldAccount, newAccount)
	return c.sendCmd(cmd)
}

// RenameAccount creates a new wallet account.
func (c *Client) RenameAccount(oldAccount, newAccount string) (e error) {
	return c.RenameAccountAsync(oldAccount, newAccount).Receive()
}

// FutureValidateAddressResult is a future promise to deliver the result of a ValidateAddressAsync RPC invocation (or an
// applicable error).
type FutureValidateAddressResult chan *response

// Receive waits for the response promised by the future and returns information about the given bitcoin address.
func (r FutureValidateAddressResult) Receive() (*btcjson.ValidateAddressWalletResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a validateaddress result object.
	var addrResult btcjson.ValidateAddressWalletResult
	e = js.Unmarshal(res, &addrResult)
	if e != nil {
		return nil, e
	}
	return &addrResult, nil
}

// ValidateAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future time
// by invoking the Receive function on the returned instance.
//
// See ValidateAddress for the blocking version and more details.
func (c *Client) ValidateAddressAsync(address btcaddr.Address) FutureValidateAddressResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewValidateAddressCmd(addr)
	return c.sendCmd(cmd)
}

// ValidateAddress returns information about the given bitcoin address.
func (c *Client) ValidateAddress(address btcaddr.Address) (*btcjson.ValidateAddressWalletResult, error) {
	return c.ValidateAddressAsync(address).Receive()
}

// FutureKeyPoolRefillResult is a future promise to deliver the result of a KeyPoolRefillAsync RPC invocation (or an
// applicable error).
type FutureKeyPoolRefillResult chan *response

// Receive waits for the response promised by the future and returns the result of refilling the key pool.
func (r FutureKeyPoolRefillResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// KeyPoolRefillAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See KeyPoolRefill for the blocking version and more details.
func (c *Client) KeyPoolRefillAsync() FutureKeyPoolRefillResult {
	cmd := btcjson.NewKeyPoolRefillCmd(nil)
	return c.sendCmd(cmd)
}

// KeyPoolRefill fills the key pool as necessary to reach the default size. See KeyPoolRefillSize to override the size
// of the key pool.
func (c *Client) KeyPoolRefill() (e error) {
	return c.KeyPoolRefillAsync().Receive()
}

// KeyPoolRefillSizeAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See KeyPoolRefillSize for the blocking version and more details.
func (c *Client) KeyPoolRefillSizeAsync(newSize uint) FutureKeyPoolRefillResult {
	cmd := btcjson.NewKeyPoolRefillCmd(&newSize)
	return c.sendCmd(cmd)
}

// KeyPoolRefillSize fills the key pool as necessary to reach the specified size.
func (c *Client) KeyPoolRefillSize(newSize uint) (e error) {
	return c.KeyPoolRefillSizeAsync(newSize).Receive()
}

// ************************
// Amount/Balance Functions
// ************************

// FutureListAccountsResult is a future promise to deliver the result of a ListAccountsAsync or ListAccountsMinConfAsync
// RPC invocation (or an applicable error).
type FutureListAccountsResult chan *response

// Receive waits for the response promised by the future and returns returns a map of account names and their associated
// balances.
func (r FutureListAccountsResult) Receive() (map[string]amt.Amount, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a json object.
	var accounts map[string]float64
	e = js.Unmarshal(res, &accounts)
	if e != nil {
		return nil, e
	}
	accountsMap := make(map[string]amt.Amount)
	for k, v := range accounts {
		amount, e := amt.NewAmount(v)
		if e != nil {
			return nil, e
		}
		accountsMap[k] = amount
	}
	return accountsMap, nil
}

// ListAccountsAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See ListAccounts for the blocking version and more details.
func (c *Client) ListAccountsAsync() FutureListAccountsResult {
	cmd := btcjson.NewListAccountsCmd(nil)
	return c.sendCmd(cmd)
}

// ListAccounts returns a map of account names and their associated balances using the default number of minimum
// confirmations.
//
// See ListAccountsMinConf to override the minimum number of confirmations.
func (c *Client) ListAccounts() (map[string]amt.Amount, error) {
	return c.ListAccountsAsync().Receive()
}

// ListAccountsMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ListAccountsMinConf for the blocking version and more details.
func (c *Client) ListAccountsMinConfAsync(minConfirms int) FutureListAccountsResult {
	cmd := btcjson.NewListAccountsCmd(&minConfirms)
	return c.sendCmd(cmd)
}

// ListAccountsMinConf returns a map of account names and their associated balances using the specified number of
// minimum confirmations.
//
// See ListAccounts to use the default minimum number of confirmations.
func (c *Client) ListAccountsMinConf(minConfirms int) (map[string]amt.Amount, error) {
	return c.ListAccountsMinConfAsync(minConfirms).Receive()
}

// FutureGetBalanceResult is a future promise to deliver the result of a GetBalanceAsync or GetBalanceMinConfAsync RPC
// invocation (or an applicable error).
type FutureGetBalanceResult chan *response

// Receive waits for the response promised by the future and returns the available balance from the server for the
// specified account.
func (r FutureGetBalanceResult) Receive() (amt.Amount, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return 0, e
	}
	// Unmarshal result as a floating point number.
	var balance float64
	e = js.Unmarshal(res, &balance)
	if e != nil {
		return 0, e
	}
	amount, e := amt.NewAmount(balance)
	if e != nil {
		return 0, e
	}
	return amount, nil
}

// FutureGetBalanceParseResult is same as FutureGetBalanceResult except that the result is expected to be a string which
// is then parsed into a float64 value
//
// This is required for compatibility with servers like blockchain.info
type FutureGetBalanceParseResult chan *response

// Receive waits for the response promised by the future and returns the available balance from the server for the
// specified account.
func (r FutureGetBalanceParseResult) Receive() (amt.Amount, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return 0, e
	}
	// Unmarshal result as a string
	var balanceString string
	e = js.Unmarshal(res, &balanceString)
	if e != nil {
		return 0, e
	}
	balance, e := strconv.ParseFloat(balanceString, 64)
	if e != nil {
		return 0, e
	}
	amount, e := amt.NewAmount(balance)
	if e != nil {
		return 0, e
	}
	return amount, nil
}

// GetBalanceAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See GetBalance for the blocking version and more details.
func (c *Client) GetBalanceAsync(account string) FutureGetBalanceResult {
	cmd := btcjson.NewGetBalanceCmd(&account, nil)
	return c.sendCmd(cmd)
}

// GetBalance returns the available balance from the server for the specified account using the default number of
// minimum confirmations. The account may be "*" for all accounts.
//
// See GetBalanceMinConf to override the minimum number of confirmations.
func (c *Client) GetBalance(account string) (amt.Amount, error) {
	return c.GetBalanceAsync(account).Receive()
}

// GetBalanceMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See GetBalanceMinConf for the blocking version and more details.
func (c *Client) GetBalanceMinConfAsync(account string, minConfirms int) FutureGetBalanceResult {
	cmd := btcjson.NewGetBalanceCmd(&account, &minConfirms)
	return c.sendCmd(cmd)
}

// GetBalanceMinConf returns the available balance from the server for the specified account using the specified number
// of minimum confirmations. The account may be "*" for all accounts.
//
// See GetBalance to use the default minimum number of confirmations.
func (c *Client) GetBalanceMinConf(account string, minConfirms int) (amt.Amount, error) {
	if c.config.EnableBCInfoHacks {
		response := c.GetBalanceMinConfAsync(account, minConfirms)
		return FutureGetBalanceParseResult(response).Receive()
	}
	return c.GetBalanceMinConfAsync(account, minConfirms).Receive()
}

// FutureGetReceivedByAccountResult is a future promise to deliver the result of a GetReceivedByAccountAsync or
// GetReceivedByAccountMinConfAsync RPC invocation (or an applicable error).
type FutureGetReceivedByAccountResult chan *response

// Receive waits for the response promised by the future and returns the total amount received with the specified
// account.
func (r FutureGetReceivedByAccountResult) Receive() (amt.Amount, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return 0, e
	}
	// Unmarshal result as a floating point number.
	var balance float64
	e = js.Unmarshal(res, &balance)
	if e != nil {
		return 0, e
	}
	amount, e := amt.NewAmount(balance)
	if e != nil {
		return 0, e
	}
	return amount, nil
}

// GetReceivedByAccountAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See GetReceivedByAccount for the blocking version and more details.
func (c *Client) GetReceivedByAccountAsync(account string) FutureGetReceivedByAccountResult {
	cmd := btcjson.NewGetReceivedByAccountCmd(account, nil)
	return c.sendCmd(cmd)
}

// GetReceivedByAccount returns the total amount received with the specified account with at least the default number of
// minimum confirmations.
//
// See GetReceivedByAccountMinConf to override the minimum number of confirmations.
func (c *Client) GetReceivedByAccount(account string) (amt.Amount, error) {
	return c.GetReceivedByAccountAsync(account).Receive()
}

// GetReceivedByAccountMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some
// future time by invoking the Receive function on the returned instance.
//
// See GetReceivedByAccountMinConf for the blocking version and more details.
func (c *Client) GetReceivedByAccountMinConfAsync(account string, minConfirms int) FutureGetReceivedByAccountResult {
	cmd := btcjson.NewGetReceivedByAccountCmd(account, &minConfirms)
	return c.sendCmd(cmd)
}

// GetReceivedByAccountMinConf returns the total amount received with the specified account with at least the specified
// number of minimum confirmations.
//
// See GetReceivedByAccount to use the default minimum number of confirmations.
func (c *Client) GetReceivedByAccountMinConf(account string, minConfirms int) (amt.Amount, error) {
	return c.GetReceivedByAccountMinConfAsync(account, minConfirms).Receive()
}

// FutureGetUnconfirmedBalanceResult is a future promise to deliver the result of a GetUnconfirmedBalanceAsync RPC
// invocation (or an applicable error).
type FutureGetUnconfirmedBalanceResult chan *response

// Receive waits for the response promised by the future and returns returns the unconfirmed balance from the server for
// the specified account.
func (r FutureGetUnconfirmedBalanceResult) Receive() (amt.Amount, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return 0, e
	}
	// Unmarshal result as a floating point number.
	var balance float64
	e = js.Unmarshal(res, &balance)
	if e != nil {
		return 0, e
	}
	amount, e := amt.NewAmount(balance)
	if e != nil {
		return 0, e
	}
	return amount, nil
}

// GetUnconfirmedBalanceAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See GetUnconfirmedBalance for the blocking version and more details.
func (c *Client) GetUnconfirmedBalanceAsync(account string) FutureGetUnconfirmedBalanceResult {
	cmd := btcjson.NewGetUnconfirmedBalanceCmd(&account)
	return c.sendCmd(cmd)
}

// GetUnconfirmedBalance returns the unconfirmed balance from the server for the specified account.
func (c *Client) GetUnconfirmedBalance(account string) (amt.Amount, error) {
	return c.GetUnconfirmedBalanceAsync(account).Receive()
}

// FutureGetReceivedByAddressResult is a future promise to deliver the result of a GetReceivedByAddressAsync or
// GetReceivedByAddressMinConfAsync RPC invocation (or an applicable error).
type FutureGetReceivedByAddressResult chan *response

// Receive waits for the response promised by the future and returns the total amount received by the specified address.
func (r FutureGetReceivedByAddressResult) Receive() (amt.Amount, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return 0, e
	}
	// Unmarshal result as a floating point number.
	var balance float64
	e = js.Unmarshal(res, &balance)
	if e != nil {
		return 0, e
	}
	amount, e := amt.NewAmount(balance)
	if e != nil {
		return 0, e
	}
	return amount, nil
}

// GetReceivedByAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See GetReceivedByAddress for the blocking version and more details.
func (c *Client) GetReceivedByAddressAsync(address btcaddr.Address) FutureGetReceivedByAddressResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewGetReceivedByAddressCmd(addr, nil)
	return c.sendCmd(cmd)
}

// GetReceivedByAddress returns the total amount received by the specified address with at least the default number of
// minimum confirmations.
//
// See GetReceivedByAddressMinConf to override the minimum number of confirmations.
func (c *Client) GetReceivedByAddress(address btcaddr.Address) (amt.Amount, error) {
	return c.GetReceivedByAddressAsync(address).Receive()
}

// GetReceivedByAddressMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some
// future time by invoking the Receive function on the returned instance.
//
// See GetReceivedByAddressMinConf for the blocking version and more details.
func (c *Client) GetReceivedByAddressMinConfAsync(
	address btcaddr.Address,
	minConfirms int,
) FutureGetReceivedByAddressResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewGetReceivedByAddressCmd(addr, &minConfirms)
	return c.sendCmd(cmd)
}

// GetReceivedByAddressMinConf returns the total amount received by the specified address with at least the specified
// number of minimum confirmations.
//
// See GetReceivedByAddress to use the default minimum number of confirmations.
func (c *Client) GetReceivedByAddressMinConf(address btcaddr.Address, minConfirms int) (amt.Amount, error) {
	return c.GetReceivedByAddressMinConfAsync(address, minConfirms).Receive()
}

// FutureListReceivedByAccountResult is a future promise to deliver the result of a ListReceivedByAccountAsync,
// ListReceivedByAccountMinConfAsync, or ListReceivedByAccountIncludeEmptyAsync RPC invocation (or an applicable error).
type FutureListReceivedByAccountResult chan *response

// Receive waits for the response promised by the future and returns a list of balances by account.
func (r FutureListReceivedByAccountResult) Receive() ([]btcjson.ListReceivedByAccountResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal as an array of listreceivedbyaccount result objects.
	var received []btcjson.ListReceivedByAccountResult
	e = js.Unmarshal(res, &received)
	if e != nil {
		return nil, e
	}
	return received, nil
}

// ListReceivedByAccountAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ListReceivedByAccount for the blocking version and more details.
func (c *Client) ListReceivedByAccountAsync() FutureListReceivedByAccountResult {
	cmd := btcjson.NewListReceivedByAccountCmd(nil, nil, nil)
	return c.sendCmd(cmd)
}

// ListReceivedByAccount lists balances by account using the default number of minimum confirmations and including
// accounts that haven't received any payments.
//
// See ListReceivedByAccountMinConf to override the minimum number of confirmations and
// ListReceivedByAccountIncludeEmpty to filter accounts that haven't received any payments from the results.
func (c *Client) ListReceivedByAccount() ([]btcjson.ListReceivedByAccountResult, error) {
	return c.ListReceivedByAccountAsync().Receive()
}

// ListReceivedByAccountMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some
// future time by invoking the Receive function on the returned instance.
//
// See ListReceivedByAccountMinConf for the blocking version and more details.
func (c *Client) ListReceivedByAccountMinConfAsync(minConfirms int) FutureListReceivedByAccountResult {
	cmd := btcjson.NewListReceivedByAccountCmd(&minConfirms, nil, nil)
	return c.sendCmd(cmd)
}

// ListReceivedByAccountMinConf lists balances by account using the specified number of minimum confirmations not
// including accounts that haven't received any payments.
//
// See ListReceivedByAccount to use the default minimum number of confirmations and ListReceivedByAccountIncludeEmpty to
// also include accounts that haven't received any payments in the results.
func (c *Client) ListReceivedByAccountMinConf(minConfirms int) ([]btcjson.ListReceivedByAccountResult, error) {
	return c.ListReceivedByAccountMinConfAsync(minConfirms).Receive()
}

// ListReceivedByAccountIncludeEmptyAsync returns an instance of a type that can be used to get the result of the RPC at
// some future time by invoking the Receive function on the returned instance.
//
// See ListReceivedByAccountIncludeEmpty for the blocking version and more details.
func (c *Client) ListReceivedByAccountIncludeEmptyAsync(
	minConfirms int,
	includeEmpty bool,
) FutureListReceivedByAccountResult {
	cmd := btcjson.NewListReceivedByAccountCmd(
		&minConfirms, &includeEmpty,
		nil,
	)
	return c.sendCmd(cmd)
}

// ListReceivedByAccountIncludeEmpty lists balances by account using the specified number of minimum confirmations and
// including accounts that haven't received any payments depending on specified flag.
//
// See ListReceivedByAccount and ListReceivedByAccountMinConf to use defaults.
func (c *Client) ListReceivedByAccountIncludeEmpty(
	minConfirms int,
	includeEmpty bool,
) ([]btcjson.ListReceivedByAccountResult, error) {
	return c.ListReceivedByAccountIncludeEmptyAsync(
		minConfirms,
		includeEmpty,
	).Receive()
}

// FutureListReceivedByAddressResult is a future promise to deliver the result of a ListReceivedByAddressAsync,
// ListReceivedByAddressMinConfAsync, or ListReceivedByAddressIncludeEmptyAsync RPC invocation (or an applicable error).
type FutureListReceivedByAddressResult chan *response

// Receive waits for the response promised by the future and returns a list of balances by address.
func (r FutureListReceivedByAddressResult) Receive() ([]btcjson.ListReceivedByAddressResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal as an array of listreceivedbyaddress result objects.
	var received []btcjson.ListReceivedByAddressResult
	e = js.Unmarshal(res, &received)
	if e != nil {
		return nil, e
	}
	return received, nil
}

// ListReceivedByAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ListReceivedByAddress for the blocking version and more details.
func (c *Client) ListReceivedByAddressAsync() FutureListReceivedByAddressResult {
	cmd := btcjson.NewListReceivedByAddressCmd(nil, nil, nil)
	return c.sendCmd(cmd)
}

// ListReceivedByAddress lists balances by address using the default number of minimum confirmations not including
// addresses that haven't received any payments or watching only addresses.
//
// See ListReceivedByAddressMinConf to override the minimum number of confirmations and
// ListReceivedByAddressIncludeEmpty to also include addresses that haven't received any payments in the results.
func (c *Client) ListReceivedByAddress() ([]btcjson.ListReceivedByAddressResult, error) {
	return c.ListReceivedByAddressAsync().Receive()
}

// ListReceivedByAddressMinConfAsync returns an instance of a type that can be used to get the result of the RPC at some
// future time by invoking the Receive function on the returned instance.
//
// See ListReceivedByAddressMinConf for the blocking version and more details.
func (c *Client) ListReceivedByAddressMinConfAsync(minConfirms int) FutureListReceivedByAddressResult {
	cmd := btcjson.NewListReceivedByAddressCmd(&minConfirms, nil, nil)
	return c.sendCmd(cmd)
}

// ListReceivedByAddressMinConf lists balances by address using the specified number of minimum confirmations not
// including addresses that haven't received any payments.
//
// See ListReceivedByAddress to use the default minimum number of confirmations and ListReceivedByAddressIncludeEmpty to
// also include addresses that haven't received any payments in the results.
func (c *Client) ListReceivedByAddressMinConf(minConfirms int) ([]btcjson.ListReceivedByAddressResult, error) {
	return c.ListReceivedByAddressMinConfAsync(minConfirms).Receive()
}

// ListReceivedByAddressIncludeEmptyAsync returns an instance of a type that can be used to get the result of the RPC at
// some future time by invoking the Receive function on the returned instance.
//
// See ListReceivedByAccountIncludeEmpty for the blocking version and more details.
func (c *Client) ListReceivedByAddressIncludeEmptyAsync(
	minConfirms int,
	includeEmpty bool,
) FutureListReceivedByAddressResult {
	cmd := btcjson.NewListReceivedByAddressCmd(
		&minConfirms, &includeEmpty,
		nil,
	)
	return c.sendCmd(cmd)
}

// ListReceivedByAddressIncludeEmpty lists balances by address using the specified number of minimum confirmations and
// including addresses that haven't received any payments depending on specified flag.
//
// See ListReceivedByAddress and ListReceivedByAddressMinConf to use defaults.
func (c *Client) ListReceivedByAddressIncludeEmpty(
	minConfirms int,
	includeEmpty bool,
) ([]btcjson.ListReceivedByAddressResult, error) {
	return c.ListReceivedByAddressIncludeEmptyAsync(
		minConfirms,
		includeEmpty,
	).Receive()
}

// ************************
// Wallet Locking Functions
// ************************

// FutureWalletLockResult is a future promise to deliver the result of a WalletLockAsync RPC invocation (or an
// applicable error).
type FutureWalletLockResult chan *response

// Receive waits for the response promised by the future and returns the result of locking the wallet.
func (r FutureWalletLockResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// WalletLockAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See WalletLock for the blocking version and more details.
func (c *Client) WalletLockAsync() FutureWalletLockResult {
	cmd := btcjson.NewWalletLockCmd()
	return c.sendCmd(cmd)
}

// WalletLock locks the wallet by removing the encryption key from memory.
//
// After calling this function, the WalletPassphrase function must be used to unlock the wallet prior to calling any
// other function which requires the wallet to be unlocked.
func (c *Client) WalletLock() (e error) {
	return c.WalletLockAsync().Receive()
}

// WalletPassphrase unlocks the wallet by using the passphrase to derive the decryption key which is then stored in
// memory for the specified timeout (in seconds).
func (c *Client) WalletPassphrase(passphrase string, timeoutSecs int64) (e error) {
	cmd := btcjson.NewWalletPassphraseCmd(passphrase, timeoutSecs)
	_, e = c.sendCmdAndWait(cmd)
	return e
}

// FutureWalletPassphraseChangeResult is a future promise to deliver the result of a WalletPassphraseChangeAsync RPC
// invocation (or an applicable error).
type FutureWalletPassphraseChangeResult chan *response

// Receive waits for the response promised by the future and returns the result of changing the wallet passphrase.
func (r FutureWalletPassphraseChangeResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// WalletPassphraseChangeAsync returns an instance of a type that can be used to get the result of the RPC at some
// future time by invoking the Receive function on the returned instance.
//
// See WalletPassphraseChange for the blocking version and more details.
func (c *Client) WalletPassphraseChangeAsync(old, new string) FutureWalletPassphraseChangeResult {
	cmd := btcjson.NewWalletPassphraseChangeCmd(old, new)
	return c.sendCmd(cmd)
}

// WalletPassphraseChange changes the wallet passphrase from the specified old to new passphrase.
func (c *Client) WalletPassphraseChange(old, new string) (e error) {
	return c.WalletPassphraseChangeAsync(old, new).Receive()
}

// *************************
// Message Signing Functions
// *************************

// FutureSignMessageResult is a future promise to deliver the result of a SignMessageAsync RPC invocation (or an
// applicable error).
type FutureSignMessageResult chan *response

// Receive waits for the response promised by the future and returns the message signed with the private key of the
// specified address.
func (r FutureSignMessageResult) Receive() (string, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return "", e
	}
	// Unmarshal result as a string.
	var b64 string
	e = js.Unmarshal(res, &b64)
	if e != nil {
		return "", e
	}
	return b64, nil
}

// SignMessageAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance. See SignMessage for the blocking version and more details.
func (c *Client) SignMessageAsync(address btcaddr.Address, message string) FutureSignMessageResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewSignMessageCmd(addr, message)
	return c.sendCmd(cmd)
}

// SignMessage signs a message with the private key of the specified address.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) SignMessage(address btcaddr.Address, message string) (string, error) {
	return c.SignMessageAsync(address, message).Receive()
}

// FutureVerifyMessageResult is a future promise to deliver the result of a VerifyMessageAsync RPC invocation (or an
// applicable error).
type FutureVerifyMessageResult chan *response

// Receive waits for the response promised by the future and returns whether or not the message was successfully
// verified.
func (r FutureVerifyMessageResult) Receive() (bool, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return false, e
	}
	// Unmarshal result as a boolean.
	var verified bool
	e = js.Unmarshal(res, &verified)
	if e != nil {
		return false, e
	}
	return verified, nil
}

// VerifyMessageAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See VerifyMessage for the blocking version and more details.
func (c *Client) VerifyMessageAsync(address btcaddr.Address, signature, message string) FutureVerifyMessageResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewVerifyMessageCmd(addr, signature, message)
	return c.sendCmd(cmd)
}

// VerifyMessage verifies a signed message.
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) VerifyMessage(address btcaddr.Address, signature, message string) (bool, error) {
	return c.VerifyMessageAsync(address, signature, message).Receive()
}

// *********************
// Dump/Import Functions
// *********************

// FutureDumpPrivKeyResult is a future promise to deliver the result of a DumpPrivKeyAsync RPC invocation (or an
// applicable error).
type FutureDumpPrivKeyResult chan *response

// Receive waits for the response promised by the future and returns the private key corresponding to the passed address
// encoded in the wallet import format (WIF)
func (r FutureDumpPrivKeyResult) Receive() (*util.WIF, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a string.
	var privKeyWIF string
	e = js.Unmarshal(res, &privKeyWIF)
	if e != nil {
		return nil, e
	}
	return util.DecodeWIF(privKeyWIF)
}

// DumpPrivKeyAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See DumpPrivKey for the blocking version and more details.
func (c *Client) DumpPrivKeyAsync(address btcaddr.Address) FutureDumpPrivKeyResult {
	addr := address.EncodeAddress()
	cmd := btcjson.NewDumpPrivKeyCmd(addr)
	return c.sendCmd(cmd)
}

// DumpPrivKey gets the private key corresponding to the passed address encoded in the wallet import format (WIF).
//
// NOTE: This function requires to the wallet to be unlocked. See the WalletPassphrase function for more details.
func (c *Client) DumpPrivKey(address btcaddr.Address) (*util.WIF, error) {
	return c.DumpPrivKeyAsync(address).Receive()
}

// FutureImportAddressResult is a future promise to deliver the result of an ImportAddressAsync RPC invocation (or an
// applicable error).
type FutureImportAddressResult chan *response

// Receive waits for the response promised by the future and returns the result of importing the passed public address.
func (r FutureImportAddressResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// ImportAddressAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See ImportAddress for the blocking version and more details.
func (c *Client) ImportAddressAsync(address string) FutureImportAddressResult {
	cmd := btcjson.NewImportAddressCmd(address, "", nil)
	return c.sendCmd(cmd)
}

// ImportAddress imports the passed public address.
func (c *Client) ImportAddress(address string) (e error) {
	return c.ImportAddressAsync(address).Receive()
}

// ImportAddressRescanAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ImportAddress for the blocking version and more details.
func (c *Client) ImportAddressRescanAsync(address string, account string, rescan bool) FutureImportAddressResult {
	cmd := btcjson.NewImportAddressCmd(address, account, &rescan)
	return c.sendCmd(cmd)
}

// ImportAddressRescan imports the passed public address. When rescan is true, the block history is scanned for
// transactions addressed to provided address.
func (c *Client) ImportAddressRescan(address string, account string, rescan bool) (e error) {
	return c.ImportAddressRescanAsync(address, account, rescan).Receive()
}

// FutureImportPrivKeyResult is a future promise to deliver the result of an ImportPrivKeyAsync RPC invocation (or an
// applicable error).
type FutureImportPrivKeyResult chan *response

// Receive waits for the response promised by the future and returns the result of importing the passed private key
// which must be the wallet import format (WIF).
func (r FutureImportPrivKeyResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// ImportPrivKeyAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See ImportPrivKey for the blocking version and more details.
func (c *Client) ImportPrivKeyAsync(privKeyWIF *util.WIF) FutureImportPrivKeyResult {
	wif := ""
	if privKeyWIF != nil {
		wif = privKeyWIF.String()
	}
	cmd := btcjson.NewImportPrivKeyCmd(wif, nil, nil)
	return c.sendCmd(cmd)
}

// ImportPrivKey imports the passed private key which must be the wallet import format (WIF).
func (c *Client) ImportPrivKey(privKeyWIF *util.WIF) (e error) {
	return c.ImportPrivKeyAsync(privKeyWIF).Receive()
}

// ImportPrivKeyLabelAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ImportPrivKey for the blocking version and more details.
func (c *Client) ImportPrivKeyLabelAsync(privKeyWIF *util.WIF, label string) FutureImportPrivKeyResult {
	wif := ""
	if privKeyWIF != nil {
		wif = privKeyWIF.String()
	}
	cmd := btcjson.NewImportPrivKeyCmd(wif, &label, nil)
	return c.sendCmd(cmd)
}

// ImportPrivKeyLabel imports the passed private key which must be the wallet import format (WIF). It sets the account
// label to the one provided.
func (c *Client) ImportPrivKeyLabel(privKeyWIF *util.WIF, label string) (e error) {
	return c.ImportPrivKeyLabelAsync(privKeyWIF, label).Receive()
}

// ImportPrivKeyRescanAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ImportPrivKey for the blocking version and more details.
func (c *Client) ImportPrivKeyRescanAsync(privKeyWIF *util.WIF, label string, rescan bool) FutureImportPrivKeyResult {
	wif := ""
	if privKeyWIF != nil {
		wif = privKeyWIF.String()
	}
	cmd := btcjson.NewImportPrivKeyCmd(wif, &label, &rescan)
	return c.sendCmd(cmd)
}

// ImportPrivKeyRescan imports the passed private key which must be the wallet import format (WIF). It sets the account
// label to the one provided. When rescan is true, the block history is scanned for transactions addressed to provided
// privKey.
func (c *Client) ImportPrivKeyRescan(privKeyWIF *util.WIF, label string, rescan bool) (e error) {
	return c.ImportPrivKeyRescanAsync(privKeyWIF, label, rescan).Receive()
}

// FutureImportPubKeyResult is a future promise to deliver the result of an ImportPubKeyAsync RPC invocation (or an
// applicable error).
type FutureImportPubKeyResult chan *response

// Receive waits for the response promised by the future and returns the result of importing the passed public key.
func (r FutureImportPubKeyResult) Receive() (e error) {
	_, e = receiveFuture(r)
	return e
}

// ImportPubKeyAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See ImportPubKey for the blocking version and more details.
func (c *Client) ImportPubKeyAsync(pubKey string) FutureImportPubKeyResult {
	cmd := btcjson.NewImportPubKeyCmd(pubKey, nil)
	return c.sendCmd(cmd)
}

// ImportPubKey imports the passed public key.
func (c *Client) ImportPubKey(pubKey string) (e error) {
	return c.ImportPubKeyAsync(pubKey).Receive()
}

// ImportPubKeyRescanAsync returns an instance of a type that can be used to get the result of the RPC at some future
// time by invoking the Receive function on the returned instance.
//
// See ImportPubKey for the blocking version and more details.
func (c *Client) ImportPubKeyRescanAsync(pubKey string, rescan bool) FutureImportPubKeyResult {
	cmd := btcjson.NewImportPubKeyCmd(pubKey, &rescan)
	return c.sendCmd(cmd)
}

// ImportPubKeyRescan imports the passed public key. When rescan is true, the block history is scanned for transactions
// addressed to provided pubkey.
func (c *Client) ImportPubKeyRescan(pubKey string, rescan bool) (e error) {
	return c.ImportPubKeyRescanAsync(pubKey, rescan).Receive()
}

// ***********************
// Miscellaneous Functions
// ***********************

// NOTE: While getinfo is implemented here (in wallet.go), a pod chain server will respond to getinfo requests as well,
// excluding any wallet information.

// FutureGetInfoResult is a future promise to deliver the result of a GetInfoAsync RPC invocation (or an applicable
// error).
type FutureGetInfoResult chan *response

// Receive waits for the response promised by the future and returns the info provided by the server.
func (r FutureGetInfoResult) Receive() (*btcjson.InfoWalletResult, error) {
	res, e := receiveFuture(r)
	if e != nil {
		return nil, e
	}
	// Unmarshal result as a getinfo result object.
	var infoRes btcjson.InfoWalletResult
	e = js.Unmarshal(res, &infoRes)
	if e != nil {
		return nil, e
	}
	return &infoRes, nil
}

// GetInfoAsync returns an instance of a type that can be used to get the result of the RPC at some future time by
// invoking the Receive function on the returned instance.
//
// See GetInfo for the blocking version and more details.
func (c *Client) GetInfoAsync() FutureGetInfoResult {
	cmd := btcjson.NewGetInfoCmd()
	return c.sendCmd(cmd)
}

// GetInfo returns miscellaneous info regarding the RPC server. The returned info object may be void of wallet
// information if the remote server does not include wallet functionality.
func (c *Client) GetInfo() (*btcjson.InfoWalletResult, error) {
	return c.GetInfoAsync().Receive()
}

// TODO(davec): Implement
//  backupwallet (NYI in btcwallet)
//  encryptwallet (Won't be supported by btcwallet since it's always encrypted)
//  getwalletinfo (NYI in btcwallet or json)
//  listaddressgroupings (NYI in btcwallet)
//  listreceivedbyaccount (NYI in btcwallet)
//  DUMP
//  importwallet (NYI in btcwallet)
//  dumpwallet (NYI in btcwallet)