sync: Add birth state.

asset/dcr/config.go

@@ -1,7 +1,7 @@
 package dcr
 
 import (
-	"decred.org/dcrwallet/v3/wallet"
+	"decred.org/dcrwallet/v4/wallet"
 	"github.com/decred/dcrd/chaincfg/v3"
 )
 

asset/dcr/loader.go

@@ -7,8 +7,9 @@ import (
 	"path/filepath"
 	"time"
 
-	"decred.org/dcrwallet/v3/wallet"
-	_ "decred.org/dcrwallet/v3/wallet/drivers/bdb"
+	"decred.org/dcrwallet/v4/wallet"
+	_ "decred.org/dcrwallet/v4/wallet/drivers/bdb"
+	"decred.org/dcrwallet/v4/wallet/udb"
 	"github.com/decred/dcrd/hdkeychain/v3"
 	"github.com/decred/libwallet/asset"
 )
@@ -100,6 +101,15 @@ func CreateWallet(ctx context.Context, params asset.CreateWalletParams, recovery
 		return nil, fmt.Errorf("wallet.Open error: %w", err)
 	}
 
+	birthState := &udb.BirthdayState{
+		Time:        birthday.Add(time.Hour * -24),
+		SetFromTime: true,
+	}
+
+	if err := w.SetBirthState(ctx, birthState); err != nil {
+		return nil, fmt.Errorf("wallet.SetBirthState error: %w", err)
+	}
+
 	// Upgrade the coin type if this is not a wallet recovery. If it's a
 	// recovery, extend the internal and external address indices.
 	if recovery == nil {

asset/dcr/log.go

@@ -4,11 +4,11 @@ import (
 	"fmt"
 	"sync/atomic"
 
-	"decred.org/dcrwallet/v3/chain"
-	"decred.org/dcrwallet/v3/p2p"
-	"decred.org/dcrwallet/v3/spv"
-	"decred.org/dcrwallet/v3/wallet"
-	"decred.org/dcrwallet/v3/wallet/udb"
+	"decred.org/dcrwallet/v4/chain"
+	"decred.org/dcrwallet/v4/p2p"
+	"decred.org/dcrwallet/v4/spv"
+	"decred.org/dcrwallet/v4/wallet"
+	"decred.org/dcrwallet/v4/wallet/udb"
 	"github.com/decred/dcrd/connmgr/v3"
 	"github.com/decred/libwallet/assetlog"
 	"github.com/decred/slog"

asset/dcr/sync.go

@@ -5,9 +5,9 @@ import (
 	"net"
 	"time"
 
-	"decred.org/dcrwallet/v3/p2p"
-	"decred.org/dcrwallet/v3/spv"
-	dcrwallet "decred.org/dcrwallet/v3/wallet"
+	"decred.org/dcrwallet/v4/p2p"
+	"decred.org/dcrwallet/v4/spv"
+	dcrwallet "decred.org/dcrwallet/v4/wallet"
 	"github.com/decred/dcrd/addrmgr/v2"
 )
 
@@ -66,18 +66,19 @@ func (w *Wallet) StartSync(ctx context.Context, ntfns *spv.Notifications, connec
 
 // IsSyncing returns true if the wallet is catching up to the mainchain's best
 // block.
-func (w *Wallet) IsSyncing() bool {
-	if w.IsSynced() {
+func (w *Wallet) IsSyncing(ctx context.Context) bool {
+	if w.IsSynced(ctx) {
 		return false
 	}
 	return w.IsSyncingOrSynced()
 }
 
 // IsSynced returns true if the wallet has synced up to the best block on the
 // mainchain.
-func (w *Wallet) IsSynced() bool {
+func (w *Wallet) IsSynced(ctx context.Context) bool {
 	if w.syncer != nil {
-		return w.syncer.Synced()
+		synced, _ := w.syncer.Synced(ctx)
+		return synced
 	}
 	return false
 }

asset/dcr/transactions.go

@@ -8,10 +8,10 @@ import (
 	"math"
 	"math/rand"
 
-	wallettypes "decred.org/dcrwallet/v3/rpc/jsonrpc/types"
-	"decred.org/dcrwallet/v3/wallet"
-	"decred.org/dcrwallet/v3/wallet/txauthor"
-	"decred.org/dcrwallet/v3/wallet/txsizes"
+	wallettypes "decred.org/dcrwallet/v4/rpc/jsonrpc/types"
+	"decred.org/dcrwallet/v4/wallet"
+	"decred.org/dcrwallet/v4/wallet/txauthor"
+	"decred.org/dcrwallet/v4/wallet/txsizes"
 	"github.com/decred/dcrd/chaincfg/chainhash"
 	"github.com/decred/dcrd/dcrutil/v4"
 	"github.com/decred/dcrd/txscript/v4"

asset/dcr/utils.go

@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"os"
 
-	"decred.org/dcrwallet/v3/wallet"
-	"decred.org/dcrwallet/v3/wallet/udb"
+	"decred.org/dcrwallet/v4/wallet"
+	"decred.org/dcrwallet/v4/wallet/udb"
 	"github.com/decred/dcrd/chaincfg/v3"
 	"github.com/decred/libwallet/asset"
 )

asset/dcr/wallet.go

@@ -5,8 +5,8 @@ import (
 	"fmt"
 	"path/filepath"
 
-	"decred.org/dcrwallet/v3/spv"
-	"decred.org/dcrwallet/v3/wallet"
+	"decred.org/dcrwallet/v4/spv"
+	"decred.org/dcrwallet/v4/wallet"
 	"github.com/decred/dcrd/chaincfg/v3"
 	"github.com/decred/libwallet/asset"
 	"github.com/decred/slog"

cgo/addresses.go

@@ -5,7 +5,7 @@ import (
 	"encoding/base64"
 	"encoding/json"
 
-	"decred.org/dcrwallet/v3/wallet/udb"
+	"decred.org/dcrwallet/v4/wallet/udb"
 	"github.com/decred/dcrd/txscript/v4/stdaddr"
 )
 
@@ -17,7 +17,7 @@ func currentReceiveAddress(cName *C.char) *C.char {
 	}
 
 	// Don't return an address if not synced!
-	if !w.IsSynced() {
+	if !w.IsSynced(w.ctx) {
 		return errCResponseWithCode(ErrCodeNotSynced, "currentReceiveAddress requested on an unsynced wallet")
 	}
 
@@ -37,7 +37,7 @@ func newExternalAddress(cName *C.char) *C.char {
 	}
 
 	// Don't return an address if not synced!
-	if !w.IsSynced() {
+	if !w.IsSynced(w.ctx) {
 		return errCResponseWithCode(ErrCodeNotSynced, "newExternalAddress requested on an unsynced wallet")
 	}
 
@@ -95,7 +95,7 @@ func addresses(cName *C.char) *C.char {
 	}
 
 	// w.AddressesByAccount does not include the current address.
-	if w.IsSynced() {
+	if w.IsSynced(w.ctx) {
 		addr, err := w.CurrentAddress(udb.DefaultAccountNum)
 		if err != nil {
 			return errCResponse("w.CurrentAddress error: %v", err)

cgo/cgo.go

@@ -19,9 +19,9 @@ import (
 )
 
 var (
-	ctx       context.Context
-	cancelCtx context.CancelFunc
-	wg        sync.WaitGroup
+	mainCtx       context.Context
+	cancelMainCtx context.CancelFunc
+	wg            sync.WaitGroup
 
 	logBackend *parentLogger
 	logMtx     sync.RWMutex
@@ -58,7 +58,7 @@ func initialize(cLogDir *C.char) *C.char {
 	log.SetLevel(slog.LevelTrace)
 	logMtx.Unlock()
 
-	ctx, cancelCtx = context.WithCancel(context.Background())
+	mainCtx, cancelMainCtx = context.WithCancel(context.Background())
 
 	initialized = true
 	return successCResponse("libwallet cgo initialized")
@@ -82,7 +82,7 @@ func shutdown() *C.char {
 	wallets = make(map[string]*wallet)
 
 	// Stop all remaining background processes and wait for them to stop.
-	cancelCtx()
+	cancelMainCtx()
 	wg.Wait()
 
 	// Close the logger backend as the last step.

cgo/sync.go

@@ -6,8 +6,8 @@ import (
 	"strconv"
 	"strings"
 
-	"decred.org/dcrwallet/v3/spv"
-	dcrwallet "decred.org/dcrwallet/v3/wallet"
+	"decred.org/dcrwallet/v4/spv"
+	dcrwallet "decred.org/dcrwallet/v4/wallet"
 )
 
 //export syncWallet
@@ -129,22 +129,14 @@ func syncWalletStatus(cName *C.char) *C.char {
 	var ssc, cfh, hh, rh, np = w.syncStatusCode, w.cfiltersHeight, w.headersHeight, w.rescanHeight, w.numPeers
 	w.syncStatusMtx.RUnlock()
 
-	nb, err := w.NetworkBackend()
-	if err != nil {
-		return errCResponse("unable to get network backend: %v", err)
-	}
-	spvSyncer, is := nb.(*spv.Syncer)
-	if !is {
-		return errCResponse("backend is not an spv syncer")
-	}
-	targetHeight := spvSyncer.EstimateMainChainTip(w.ctx)
+	_, targetHeight := w.MainWallet().MainChainTip(w.ctx)
 
 	// Sometimes it appears we miss a notification during start up. This is
 	// a bandaid to put us as synced in that case.
 	//
 	// TODO: Figure out why we would miss a notification.
 	w.syncStatusMtx.Lock()
-	if ssc != SSCComplete && w.IsSynced() && !w.rescanning {
+	if ssc != SSCComplete && w.IsSynced(w.ctx) && !w.rescanning {
 		ssc = SSCComplete
 		w.syncStatusCode = ssc
 	}
@@ -182,7 +174,7 @@ func rescanFromHeight(cName, cHeight *C.char) *C.char {
 	if !exists {
 		return errCResponse("wallet with name %q does not exist", name)
 	}
-	if !w.IsSynced() {
+	if !w.IsSynced(w.ctx) {
 		return errCResponseWithCode(ErrCodeNotSynced, "rescanFromHeight requested on an unsynced wallet")
 	}
 	w.syncStatusMtx.Lock()
@@ -227,3 +219,29 @@ func rescanFromHeight(cName, cHeight *C.char) *C.char {
 	}()
 	return successCResponse("rescan from height %d for wallet %q started", height, name)
 }
+
+//export birthState
+func birthState(cName *C.char) *C.char {
+	w, ok := loadedWallet(cName)
+	if !ok {
+		return errCResponse("wallet with name %q is not loaded", goString(cName))
+	}
+
+	bs, err := w.MainWallet().BirthState(w.ctx)
+	if err != nil {
+		return errCResponse("wallet.BirthState error: %v", err)
+	}
+
+	bsRes := &BirthdayState{
+		Hash:          bs.Hash.String(),
+		Height:        bs.Height,
+		Time:          bs.Time,
+		SetFromHeight: bs.SetFromHeight,
+		SetFromTime:   bs.SetFromTime,
+	}
+	b, err := json.Marshal(bsRes)
+	if err != nil {
+		return errCResponse("unable to marshal birth state result: %v", err)
+	}
+	return successCResponse(string(b))
+}

cgo/transactions.go

@@ -8,7 +8,7 @@ import (
 	"math"
 	"strconv"
 
-	dcrwallet "decred.org/dcrwallet/v3/wallet"
+	dcrwallet "decred.org/dcrwallet/v4/wallet"
 	"github.com/decred/dcrd/txscript/v4/stdaddr"
 	"github.com/decred/libwallet/asset/dcr"
 )

cgo/types.go

@@ -4,8 +4,9 @@ import "C"
 import (
 	"encoding/json"
 	"fmt"
+	"time"
 
-	wallettypes "decred.org/dcrwallet/v3/rpc/jsonrpc/types"
+	wallettypes "decred.org/dcrwallet/v4/rpc/jsonrpc/types"
 )
 
 const (
@@ -137,3 +138,11 @@ type ListTransactionRes struct {
 	Time          int64    `json:"time"`
 	TxID          string   `json:"txid"`
 }
+
+type BirthdayState struct {
+	Hash          string    `json:"hash"`
+	Height        uint32    `json:"height"`
+	Time          time.Time `json:"time"`
+	SetFromHeight bool      `json:"setfromheight"`
+	SetFromTime   bool      `json:"setfromtime"`
+}

cgo/walletloader.go

@@ -71,7 +71,7 @@ func createWallet(cName, cDataDir, cNet, cPass, cMnemonic *C.char) *C.char {
 			Birthday: birthday,
 		}
 	}
-	walletCtx, cancel := context.WithCancel(ctx)
+	walletCtx, cancel := context.WithCancel(mainCtx)
 
 	w, err := dcr.CreateWallet(walletCtx, params, recoveryConfig)
 	if err != nil {
@@ -117,7 +117,7 @@ func createWatchOnlyWallet(cName, cDataDir, cNet, cPub *C.char) *C.char {
 		},
 	}
 
-	walletCtx, cancel := context.WithCancel(ctx)
+	walletCtx, cancel := context.WithCancel(mainCtx)
 
 	w, err := dcr.CreateWatchOnlyWallet(walletCtx, goString(cPub), params)
 	if err != nil {
@@ -161,7 +161,7 @@ func loadWallet(cName, cDataDir, cNet *C.char) *C.char {
 		Logger:   logger,
 	}
 
-	walletCtx, cancel := context.WithCancel(ctx)
+	walletCtx, cancel := context.WithCancel(mainCtx)
 
 	w, err := dcr.LoadWallet(walletCtx, params)
 	if err != nil {