LBRYFoundation/lbcwallet
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/lbcwallet.git synced 2025-08-23 17:47:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

chain: update neutrino interface impl to use new InputWithScript

Browse source
This commit is contained in:
Olaoluwa Osuntokun 2018-06-14 22:02:40 -07:00
parent 87d91316cd
commit b24714270a
1 changed files with 23 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
chain/neutrino.go
View file

@ -286,10 +286,13 @@ func buildFilterBlocksWatchList(req *FilterBlocksRequest) ([][]byte, error) {
watchList = append(watchList, p2shAddr) watchList = append(watchList, p2shAddr)
} }
for outPoint := range req.WatchedOutPoints { for _, addr := range req.WatchedOutPoints {
watchList = append(watchList, addr, err := txscript.PayToAddrScript(addr)
builder.OutPointToFilterEntry(outPoint), if err != nil {
) return nil, err
}
watchList = append(watchList, addr)
} }
return watchList, nil return watchList, nil
@ -325,7 +328,8 @@ func (s *NeutrinoClient) pollCFilter(hash *chainhash.Hash) (*gcs.Filter, error)
// Rescan replicates the RPC client's Rescan command. // Rescan replicates the RPC client's Rescan command.
func (s *NeutrinoClient) Rescan(startHash *chainhash.Hash, addrs []btcutil.Address, func (s *NeutrinoClient) Rescan(startHash *chainhash.Hash, addrs []btcutil.Address,
outPoints []*wire.OutPoint) error { outPoints map[wire.OutPoint]btcutil.Address) error {
s.clientMtx.Lock() s.clientMtx.Lock()
defer s.clientMtx.Unlock() defer s.clientMtx.Unlock()
if !s.started { if !s.started {
@ -346,10 +350,7 @@ func (s *NeutrinoClient) Rescan(startHash *chainhash.Hash, addrs []btcutil.Addre
s.finished = false s.finished = false
s.lastProgressSent = false s.lastProgressSent = false
s.isRescan = true s.isRescan = true
watchOutPoints := make([]wire.OutPoint, 0, len(outPoints))
for _, op := range outPoints {
watchOutPoints = append(watchOutPoints, *op)
}
header, height, err := s.CS.BlockHeaders.ChainTip() header, height, err := s.CS.BlockHeaders.ChainTip()
if err != nil { if err != nil {
return fmt.Errorf("Can't get chain service's best block: %s", err) return fmt.Errorf("Can't get chain service's best block: %s", err)
@ -373,6 +374,18 @@ func (s *NeutrinoClient) Rescan(startHash *chainhash.Hash, addrs []btcutil.Addre
} }
} }
var inputsToWatch []neutrino.InputWithScript
for op, addr := range outPoints {
addrScript, err := txscript.PayToAddrScript(addr)
if err != nil {
}
inputsToWatch = append(inputsToWatch, neutrino.InputWithScript{
OutPoint: op,
PkScript: addrScript,
})
}
newRescan := s.CS.NewRescan( newRescan := s.CS.NewRescan(
neutrino.NotificationHandlers(rpcclient.NotificationHandlers{ neutrino.NotificationHandlers(rpcclient.NotificationHandlers{
OnBlockConnected: s.onBlockConnected, OnBlockConnected: s.onBlockConnected,
@ -383,7 +396,7 @@ func (s *NeutrinoClient) Rescan(startHash *chainhash.Hash, addrs []btcutil.Addre
neutrino.StartTime(s.startTime), neutrino.StartTime(s.startTime),
neutrino.QuitChan(s.rescanQuit), neutrino.QuitChan(s.rescanQuit),
neutrino.WatchAddrs(addrs...), neutrino.WatchAddrs(addrs...),
neutrino.WatchOutPoints(watchOutPoints...), neutrino.WatchInputs(inputsToWatch...),
) )
s.rescan = newRescan s.rescan = newRescan
s.rescanErr = s.rescan.Start() s.rescanErr = s.rescan.Start()