mirror of
https://github.com/lightningnetwork/lnd.git
synced 2024-11-19 09:53:54 +01:00
chainntnfs: unit test disabled height hint cache behavior
This commit is contained in:
parent
47ce718d29
commit
0f7c20977b
@ -8,11 +8,22 @@ import (
|
|||||||
"github.com/btcsuite/btcd/chaincfg/chainhash"
|
"github.com/btcsuite/btcd/chaincfg/chainhash"
|
||||||
"github.com/btcsuite/btcd/wire"
|
"github.com/btcsuite/btcd/wire"
|
||||||
"github.com/lightningnetwork/lnd/channeldb"
|
"github.com/lightningnetwork/lnd/channeldb"
|
||||||
|
"github.com/stretchr/testify/require"
|
||||||
)
|
)
|
||||||
|
|
||||||
func initHintCache(t *testing.T) *HeightHintCache {
|
func initHintCache(t *testing.T) *HeightHintCache {
|
||||||
t.Helper()
|
t.Helper()
|
||||||
|
|
||||||
|
defaultCfg := CacheConfig{
|
||||||
|
QueryDisable: false,
|
||||||
|
}
|
||||||
|
|
||||||
|
return initHintCacheWithConfig(t, defaultCfg)
|
||||||
|
}
|
||||||
|
|
||||||
|
func initHintCacheWithConfig(t *testing.T, cfg CacheConfig) *HeightHintCache {
|
||||||
|
t.Helper()
|
||||||
|
|
||||||
tempDir, err := ioutil.TempDir("", "kek")
|
tempDir, err := ioutil.TempDir("", "kek")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("unable to create temp dir: %v", err)
|
t.Fatalf("unable to create temp dir: %v", err)
|
||||||
@ -21,10 +32,7 @@ func initHintCache(t *testing.T) *HeightHintCache {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("unable to create db: %v", err)
|
t.Fatalf("unable to create db: %v", err)
|
||||||
}
|
}
|
||||||
testCfg := CacheConfig{
|
hintCache, err := NewHeightHintCache(cfg, db)
|
||||||
QueryDisable: false,
|
|
||||||
}
|
|
||||||
hintCache, err := NewHeightHintCache(testCfg, db)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
t.Fatalf("unable to create hint cache: %v", err)
|
t.Fatalf("unable to create hint cache: %v", err)
|
||||||
}
|
}
|
||||||
@ -154,3 +162,42 @@ func TestHeightHintCacheSpends(t *testing.T) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// TestQueryDisable asserts querying for confirmation or spend hints always
|
||||||
|
// return height zero when QueryDisabled is set to true in the CacheConfig.
|
||||||
|
func TestQueryDisable(t *testing.T) {
|
||||||
|
cfg := CacheConfig{
|
||||||
|
QueryDisable: true,
|
||||||
|
}
|
||||||
|
|
||||||
|
hintCache := initHintCacheWithConfig(t, cfg)
|
||||||
|
|
||||||
|
// Insert a new confirmation hint with a non-zero height.
|
||||||
|
const confHeight = 100
|
||||||
|
confRequest := ConfRequest{
|
||||||
|
TxID: chainhash.Hash{0x01, 0x02, 0x03},
|
||||||
|
}
|
||||||
|
err := hintCache.CommitConfirmHint(confHeight, confRequest)
|
||||||
|
require.Nil(t, err)
|
||||||
|
|
||||||
|
// Query for the confirmation hint, which should return zero.
|
||||||
|
cachedConfHeight, err := hintCache.QueryConfirmHint(confRequest)
|
||||||
|
require.Nil(t, err)
|
||||||
|
require.Equal(t, uint32(0), cachedConfHeight)
|
||||||
|
|
||||||
|
// Insert a new spend hint with a non-zero height.
|
||||||
|
const spendHeight = 200
|
||||||
|
spendRequest := SpendRequest{
|
||||||
|
OutPoint: wire.OutPoint{
|
||||||
|
Hash: chainhash.Hash{0x4, 0x05, 0x06},
|
||||||
|
Index: 42,
|
||||||
|
},
|
||||||
|
}
|
||||||
|
err = hintCache.CommitSpendHint(spendHeight, spendRequest)
|
||||||
|
require.Nil(t, err)
|
||||||
|
|
||||||
|
// Query for the spend hint, which should return zero.
|
||||||
|
cachedSpendHeight, err := hintCache.QuerySpendHint(spendRequest)
|
||||||
|
require.Nil(t, err)
|
||||||
|
require.Equal(t, uint32(0), cachedSpendHeight)
|
||||||
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user