highperfocused/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-08-28 14:40:51 +02:00
Code Issues Packages Projects Releases Wiki Activity

chainntnfs: patch debug logs and fix StartHeight

Browse Source 
Make sure we patch the `StartHeight` for btcd notifier.
This commit is contained in:
yyforyongyu
2025-06-09 08:31:18 +08:00
committed by Olaoluwa Osuntokun
parent 270981eef0
commit a806323035
2 changed files with 14 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
chainntnfs/bitcoindnotify/bitcoind.go
View File

@@ -833,8 +833,12 @@ func (b *BitcoindNotifier) RegisterSpendNtfn(outpoint *wire.OutPoint,
return nil, err return nil, err
} }
if uint32(blockHeight) > ntfn.HistoricalDispatch.StartHeight { spentHeight := uint32(blockHeight)
ntfn.HistoricalDispatch.StartHeight = uint32(blockHeight) chainntnfs.Log.Debugf("Outpoint(%v) has spent at height %v",
outpoint, spentHeight)
if spentHeight > ntfn.HistoricalDispatch.StartHeight {
ntfn.HistoricalDispatch.StartHeight = spentHeight
} }
} }

10
chainntnfs/btcdnotify/btcd.go
View File

@@ -933,15 +933,21 @@ func (b *BtcdNotifier) RegisterSpendNtfn(outpoint *wire.OutPoint,
"block %v: %v", blockHash, err) "block %v: %v", blockHash, err)
} }
if uint32(blockHeader.Height) > ntfn.HistoricalDispatch.StartHeight { spentHeight := uint32(blockHeader.Height)
chainntnfs.Log.Debugf("Outpoint(%v) has spent at height %v",
outpoint, spentHeight)
if spentHeight > ntfn.HistoricalDispatch.StartHeight {
startHash, err = b.chainConn.GetBlockHash( startHash, err = b.chainConn.GetBlockHash(
int64(blockHeader.Height), int64(spentHeight),
) )
if err != nil { if err != nil {
return nil, fmt.Errorf("unable to get block "+ return nil, fmt.Errorf("unable to get block "+
"hash for height %d: %v", "hash for height %d: %v",
blockHeader.Height, err) blockHeader.Height, err)
} }
ntfn.HistoricalDispatch.StartHeight = spentHeight
} }
} }