sweepremoteclosed: add command for sweeping closed channels

Author: guggero

README.md

@@ -316,6 +316,7 @@ Quick access:
 + [showrootkey](doc/chantools_showrootkey.md)
 + [signrescuefunding](doc/chantools_signrescuefunding.md)
 + [summary](doc/chantools_summary.md)
++ [sweepremoteclosed](doc/chantools_sweepremoteclosed.md)
 + [sweeptimelock](doc/chantools_sweeptimelock.md)
 + [sweeptimelockmanual](doc/chantools_sweeptimelockmanual.md)
 + [vanitygen](doc/chantools_vanitygen.md)

btc/bitcoind.go

@@ -6,7 +6,6 @@ import (
 	"time"
 
 	"github.com/btcsuite/btcd/chaincfg"
-	"github.com/btcsuite/btcd/txscript"
 	"github.com/btcsuite/btcd/wire"
 	"github.com/btcsuite/btcutil"
 	"github.com/btcsuite/btcutil/hdkeychain"
@@ -193,24 +192,15 @@ func (i *ImportWallet) Format(hdKey *hdkeychain.ExtendedKey,
 	if err != nil {
 		return "", fmt.Errorf("could not encode WIF: %v", err)
 	}
-	pubKey, err := hdKey.ECPubKey()
-	if err != nil {
-		return "", fmt.Errorf("could not derive private key: %v", err)
-	}
-	hash160 := btcutil.Hash160(pubKey.SerializeCompressed())
-	addrP2PKH, err := btcutil.NewAddressPubKeyHash(hash160, params)
+	addrP2PKH, err := lnd.P2PKHAddr(privKey.PubKey(), params)
 	if err != nil {
 		return "", fmt.Errorf("could not create address: %v", err)
 	}
-	addrP2WKH, err := btcutil.NewAddressWitnessPubKeyHash(hash160, params)
+	addrP2WKH, err := lnd.P2WKHAddr(privKey.PubKey(), params)
 	if err != nil {
 		return "", fmt.Errorf("could not create address: %v", err)
 	}
-	script, err := txscript.PayToAddrScript(addrP2WKH)
-	if err != nil {
-		return "", fmt.Errorf("could not create script: %v", err)
-	}
-	addrNP2WKH, err := btcutil.NewAddressScriptHash(script, params)
+	addrNP2WKH, err := lnd.NP2WKHAddr(privKey.PubKey(), params)
 	if err != nil {
 		return "", fmt.Errorf("could not create address: %v", err)
 	}

btc/explorer_api.go

@@ -53,6 +53,20 @@ type Status struct {
 	BlockHash   string `json:"block_hash"`
 }
 
+type Stats struct {
+	FundedTXOCount uint32 `json:"funded_txo_count"`
+	FundedTXOSum   uint64 `json:"funded_txo_sum"`
+	SpentTXOCount  uint32 `json:"spent_txo_count"`
+	SpentTXOSum    uint64 `json:"spent_txo_sum"`
+	TXCount        uint32 `json:"tx_count"`
+}
+
+type AddressStats struct {
+	Address      string `json:"address"`
+	ChainStats   *Stats `json:"chain_stats"`
+	MempoolStats *Stats `json:"mempool_stats"`
+}
+
 func (a *ExplorerAPI) Transaction(txid string) (*TX, error) {
 	tx := &TX{}
 	err := fetchJSON(fmt.Sprintf("%s/tx/%s", a.BaseURL, txid), tx)
@@ -90,6 +104,46 @@ func (a *ExplorerAPI) Outpoint(addr string) (*TX, int, error) {
 	return nil, 0, fmt.Errorf("no tx found")
 }
 
+func (a *ExplorerAPI) Unspent(addr string) ([]*Vout, error) {
+	var (
+		stats   = &AddressStats{}
+		outputs []*Vout
+		txs     []*TX
+		err     error
+	)
+	err = fetchJSON(fmt.Sprintf("%s/address/%s", a.BaseURL, addr), &stats)
+	if err != nil {
+		return nil, err
+	}
+
+	confirmedUnspent := stats.ChainStats.FundedTXOSum -
+		stats.ChainStats.SpentTXOSum
+	unconfirmedUnspent := stats.MempoolStats.FundedTXOSum -
+		stats.MempoolStats.SpentTXOSum
+
+	if confirmedUnspent+unconfirmedUnspent == 0 {
+		return nil, nil
+	}
+
+	err = fetchJSON(fmt.Sprintf("%s/address/%s/txs", a.BaseURL, addr), &txs)
+	if err != nil {
+		return nil, err
+	}
+	for _, tx := range txs {
+		for voutIdx, vout := range tx.Vout {
+			if vout.ScriptPubkeyAddr == addr {
+				vout.Outspend = &Outspend{
+					Txid: tx.TXID,
+					Vin:  voutIdx,
+				}
+				outputs = append(outputs, vout)
+			}
+		}
+	}
+
+	return outputs, nil
+}
+
 func (a *ExplorerAPI) Address(outpoint string) (string, error) {
 	parts := strings.Split(outpoint, ":")
 

cmd/chantools/root.go

@@ -101,6 +101,7 @@ func main() {
 		newSummaryCommand(),
 		newSweepTimeLockCommand(),
 		newSweepTimeLockManualCommand(),
+		newSweepRemoteClosedCommand(),
 		newVanityGenCommand(),
 		newWalletInfoCommand(),
 		newZombieRecoveryCommand(),