From c976a550cbfc91c303ff094b5b56f6fd6a4ba7f3 Mon Sep 17 00:00:00 2001 From: Conner Fromknecht Date: Wed, 28 Feb 2018 00:14:03 -0800 Subject: [PATCH] server: initialize switch with circuit db --- server.go | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/server.go b/server.go index 68aa04cf..65fb1cc0 100644 --- a/server.go +++ b/server.go @@ -206,7 +206,8 @@ func newServer(listenAddrs []string, chanDB *channeldb.DB, cc *chainControl, debugPre[:], debugHash[:]) } - s.htlcSwitch = htlcswitch.New(htlcswitch.Config{ + htlcSwitch, err := htlcswitch.New(htlcswitch.Config{ + DB: chanDB, SelfKey: s.identityPriv.PubKey(), LocalChannelClose: func(pubKey []byte, request *htlcswitch.ChanClose) { @@ -230,8 +231,13 @@ func newServer(listenAddrs []string, chanDB *channeldb.DB, cc *chainControl, pubKey[:], err) } }, - FwdingLog: chanDB.ForwardingLog(), + FwdingLog: chanDB.ForwardingLog(), + SwitchPackager: channeldb.NewSwitchPackager(), }) + if err != nil { + return nil, err + } + s.htlcSwitch = htlcSwitch // If external IP addresses have been specified, add those to the list // of this server's addresses. We need to use the cfg.net.ResolveTCPAddr