diff --git a/docs/release-notes/release-notes-0.20.0.md b/docs/release-notes/release-notes-0.20.0.md index da32397a7..4fa3688d2 100644 --- a/docs/release-notes/release-notes-0.20.0.md +++ b/docs/release-notes/release-notes-0.20.0.md @@ -91,6 +91,7 @@ circuit. The indices are only available for forwarding events saved after v0.20. * [8](https://github.com/lightningnetwork/lnd/pull/9938) * [9](https://github.com/lightningnetwork/lnd/pull/9939) * [10](https://github.com/lightningnetwork/lnd/pull/9971) + * [11](https://github.com/lightningnetwork/lnd/pull/9972) ## RPC Updates diff --git a/graph/db/sql_store.go b/graph/db/sql_store.go index 42a5d8126..c8f222b29 100644 --- a/graph/db/sql_store.go +++ b/graph/db/sql_store.go @@ -175,10 +175,6 @@ type SQLStore struct { srcNodes map[ProtocolVersion]*srcNodeInfo srcNodeMu sync.Mutex - - // Temporary fall-back to the KVStore so that we can implement the - // interface incrementally. - *KVStore } // A compile-time assertion to ensure that SQLStore implements the V1Store @@ -194,7 +190,7 @@ type SQLStoreConfig struct { // NewSQLStore creates a new SQLStore instance given an open BatchedSQLQueries // storage backend. -func NewSQLStore(cfg *SQLStoreConfig, db BatchedSQLQueries, kvStore *KVStore, +func NewSQLStore(cfg *SQLStoreConfig, db BatchedSQLQueries, options ...StoreOptionModifier) (*SQLStore, error) { opts := DefaultOptions() @@ -210,7 +206,6 @@ func NewSQLStore(cfg *SQLStoreConfig, db BatchedSQLQueries, kvStore *KVStore, s := &SQLStore{ cfg: cfg, db: db, - KVStore: kvStore, rejectCache: newRejectCache(opts.RejectCacheSize), chanCache: newChannelCache(opts.ChannelCacheSize), srcNodes: make(map[ProtocolVersion]*srcNodeInfo), diff --git a/graph/db/test_postgres.go b/graph/db/test_postgres.go index d5cd1f8ff..11144eb3b 100644 --- a/graph/db/test_postgres.go +++ b/graph/db/test_postgres.go @@ -7,7 +7,6 @@ import ( "testing" "github.com/btcsuite/btcd/chaincfg" - "github.com/lightningnetwork/lnd/kvdb" "github.com/lightningnetwork/lnd/sqldb" "github.com/stretchr/testify/require" ) @@ -16,14 +15,6 @@ import ( // database for testing. At the moment, it embeds a KVStore but once the // SQLStore fully implements the V1Store interface, the KVStore will be removed. func NewTestDB(t testing.TB) V1Store { - backend, backendCleanup, err := kvdb.GetTestBackend(t.TempDir(), "cgr") - require.NoError(t, err) - - t.Cleanup(backendCleanup) - - graphStore, err := NewKVStore(backend) - require.NoError(t, err) - pgFixture := sqldb.NewTestPgFixture( t, sqldb.DefaultPostgresFixtureLifetime, ) @@ -42,7 +33,7 @@ func NewTestDB(t testing.TB) V1Store { store, err := NewSQLStore( &SQLStoreConfig{ ChainHash: *chaincfg.MainNetParams.GenesisHash, - }, executor, graphStore, + }, executor, ) require.NoError(t, err) diff --git a/graph/db/test_sqlite.go b/graph/db/test_sqlite.go index c19300ce2..f9cb5a46d 100644 --- a/graph/db/test_sqlite.go +++ b/graph/db/test_sqlite.go @@ -7,7 +7,6 @@ import ( "testing" "github.com/btcsuite/btcd/chaincfg" - "github.com/lightningnetwork/lnd/kvdb" "github.com/lightningnetwork/lnd/sqldb" "github.com/stretchr/testify/require" ) @@ -16,14 +15,6 @@ import ( // database for testing. At the moment, it embeds a KVStore but once the // SQLStore fully implements the V1Store interface, the KVStore will be removed. func NewTestDB(t testing.TB) V1Store { - backend, backendCleanup, err := kvdb.GetTestBackend(t.TempDir(), "cgr") - require.NoError(t, err) - - t.Cleanup(backendCleanup) - - graphStore, err := NewKVStore(backend) - require.NoError(t, err) - db := sqldb.NewTestSqliteDB(t).BaseDB executor := sqldb.NewTransactionExecutor( @@ -35,7 +26,7 @@ func NewTestDB(t testing.TB) V1Store { store, err := NewSQLStore( &SQLStoreConfig{ ChainHash: *chaincfg.MainNetParams.GenesisHash, - }, executor, graphStore, + }, executor, ) require.NoError(t, err)