diff --git a/htlcswitch/circuit_test.go b/htlcswitch/circuit_test.go index 42653dd3..d908a935 100644 --- a/htlcswitch/circuit_test.go +++ b/htlcswitch/circuit_test.go @@ -82,15 +82,8 @@ func initTestExtracter() { // newOnionProcessor creates starts a new htlcswitch.OnionProcessor using a temp // db and no garbage collection. func newOnionProcessor(t *testing.T) *htlcswitch.OnionProcessor { - sharedSecretFile, err := ioutil.TempFile("", "sphinxreplay.db") - if err != nil { - t.Fatalf("unable to create temp path: %v", err) - } - - sharedSecretPath := sharedSecretFile.Name() - sphinxRouter := sphinx.NewRouter( - sharedSecretPath, sphinxPrivKey, &bitcoinCfg.SimNetParams, nil, + sphinxPrivKey, &bitcoinCfg.SimNetParams, sphinx.NewMemoryReplayLog(), ) if err := sphinxRouter.Start(); err != nil { diff --git a/server.go b/server.go index c0b6ea4f..6bce1304 100644 --- a/server.go +++ b/server.go @@ -16,12 +16,14 @@ import ( "time" "github.com/coreos/bbolt" + "github.com/go-errors/errors" "github.com/lightningnetwork/lightning-onion" "github.com/lightningnetwork/lnd/autopilot" "github.com/lightningnetwork/lnd/brontide" "github.com/lightningnetwork/lnd/channeldb" "github.com/lightningnetwork/lnd/contractcourt" "github.com/lightningnetwork/lnd/discovery" + "github.com/lightningnetwork/lnd/htlcswitch" "github.com/lightningnetwork/lnd/lnrpc" "github.com/lightningnetwork/lnd/lnwallet" "github.com/lightningnetwork/lnd/lnwire" @@ -31,9 +33,6 @@ import ( "github.com/roasbeef/btcd/connmgr" "github.com/roasbeef/btcd/wire" "github.com/roasbeef/btcutil" - - "github.com/go-errors/errors" - "github.com/lightningnetwork/lnd/htlcswitch" ) var ( @@ -159,9 +158,8 @@ func newServer(listenAddrs []string, chanDB *channeldb.DB, cc *chainControl, // the same directory as the channel graph database. graphDir := chanDB.Path() sharedSecretPath := filepath.Join(graphDir, "sphinxreplay.db") - sphinxRouter := sphinx.NewRouter( - sharedSecretPath, privKey, activeNetParams.Params, cc.chainNotifier, - ) + replayLog := htlcswitch.NewDecayedLog(sharedSecretPath, cc.chainNotifier) + sphinxRouter := sphinx.NewRouter(privKey, activeNetParams.Params, replayLog) s := &server{ chanDB: chanDB,