mirrors/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2025-02-23 06:35:07 +01:00
Code Issues Projects Releases Wiki Activity

sweep: use bbolt DB directly instead of channeldb

Browse source
This commit is contained in:
Oliver Gugger 2019-10-07 13:20:09 +02:00
parent 4190146066
commit b6dda143d0
No known key found for this signature in database
GPG key ID: 8E4256593F177720
3 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server.go
View file

@ -764,7 +764,7 @@ func newServer(listenAddrs []net.Addr, chanDB *channeldb.DB,
sweep.DefaultBatchWindowDuration) sweep.DefaultBatchWindowDuration)
sweeperStore, err := sweep.NewSweeperStore( sweeperStore, err := sweep.NewSweeperStore(
chanDB, activeNetParams.GenesisHash, chanDB.DB, activeNetParams.GenesisHash,
) )
if err != nil { if err != nil {
srvrLog.Errorf("unable to create sweeper store: %v", err) srvrLog.Errorf("unable to create sweeper store: %v", err)

5
sweep/store.go
View file

@ -9,7 +9,6 @@ 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/coreos/bbolt" "github.com/coreos/bbolt"
"github.com/lightningnetwork/lnd/channeldb"
) )
var ( var (
@ -57,11 +56,11 @@ type SweeperStore interface {
} }
type sweeperStore struct { type sweeperStore struct {
db *channeldb.DB db *bbolt.DB
} }
// NewSweeperStore returns a new store instance. // NewSweeperStore returns a new store instance.
func NewSweeperStore(db *channeldb.DB, chainHash *chainhash.Hash) ( func NewSweeperStore(db *bbolt.DB, chainHash *chainhash.Hash) (
SweeperStore, error) { SweeperStore, error) {
err := db.Update(func(tx *bbolt.Tx) error { err := db.Update(func(tx *bbolt.Tx) error {

2
sweep/store_test.go
View file

@ -53,7 +53,7 @@ func TestStore(t *testing.T) {
testStore(t, func() (SweeperStore, error) { testStore(t, func() (SweeperStore, error) {
var chain chainhash.Hash var chain chainhash.Hash
return NewSweeperStore(cdb, &chain) return NewSweeperStore(cdb.DB, &chain)
}) })
}) })
t.Run("mock", func(t *testing.T) { t.Run("mock", func(t *testing.T) {