From a4b05a56ee7e746263068e82a12ff2e6074f4351 Mon Sep 17 00:00:00 2001 From: derrandz Date: Wed, 26 Apr 2023 16:05:46 +0100 Subject: [PATCH 1/4] wip --- go.mod | 2 + go.sum | 4 +- nodebuilder/header/constructors.go | 15 +++++- nodebuilder/header/module.go | 5 ++ nodebuilder/header/peerstore/peerstore.go | 64 +++++++++++++++++++++++ 5 files changed, 86 insertions(+), 4 deletions(-) create mode 100644 nodebuilder/header/peerstore/peerstore.go diff --git a/go.mod b/go.mod index 27500f3dc4..f2b7f0ca45 100644 --- a/go.mod +++ b/go.mod @@ -4,6 +4,8 @@ go 1.20 replace github.com/ipfs/go-verifcid => github.com/celestiaorg/go-verifcid v0.0.1-lazypatch +replace github.com/celestiaorg/go-header => github.com/derrandz/go-header v0.0.0-20230426152902-919e3a027ef0 + require ( cosmossdk.io/math v1.0.0-beta.3 github.com/BurntSushi/toml v1.2.1 diff --git a/go.sum b/go.sum index 5d7dcd43e0..740170bb82 100644 --- a/go.sum +++ b/go.sum @@ -350,8 +350,6 @@ github.com/celestiaorg/dagstore v0.0.0-20230413141458-735ab09a15d6 h1:/yCwMCoOPc github.com/celestiaorg/dagstore v0.0.0-20230413141458-735ab09a15d6/go.mod h1:ta/DlqIH10bvhwqJIw51Nq3QU4XVMp6pz3f0Deve9fM= github.com/celestiaorg/go-fraud v0.1.0 h1:v6mZvlmf2J5ELZfPnrtmmOvKbaYIUs/erDWPO8NbZyY= github.com/celestiaorg/go-fraud v0.1.0/go.mod h1:yoNM35cKMAkt5Mi/Qx3Wi9bnPilLi8n6RpHZVglTUDs= -github.com/celestiaorg/go-header v0.2.6 h1:f1Mlyu+EfDpkuzO3SWU5dow+ga2vLQ7hNuvsOe//z64= -github.com/celestiaorg/go-header v0.2.6/go.mod h1:i9OpY70+PJ1xPw1IgMfF0Pk6vBD6VWPmjY3bgubJBcU= github.com/celestiaorg/go-libp2p-messenger v0.2.0 h1:/0MuPDcFamQMbw9xTZ73yImqgTO3jHV7wKHvWD/Irao= github.com/celestiaorg/go-libp2p-messenger v0.2.0/go.mod h1:s9PIhMi7ApOauIsfBcQwbr7m+HBzmVfDIS+QLdgzDSo= github.com/celestiaorg/go-verifcid v0.0.1-lazypatch h1:9TSe3w1cmJmbWlweCwCTIZkan7jV8M+KwglXpdD+UG8= @@ -492,6 +490,8 @@ github.com/decred/dcrd/dcrec/secp256k1/v4 v4.1.0/go.mod h1:DZGJHZMqrU4JJqFAWUS2U github.com/decred/dcrd/lru v1.0.0/go.mod h1:mxKOwFd7lFjN2GZYsiz/ecgqR6kkYAl+0pz0tEMk218= github.com/deepmap/oapi-codegen v1.6.0/go.mod h1:ryDa9AgbELGeB+YEXE1dR53yAjHwFvE9iAUlWl9Al3M= github.com/deepmap/oapi-codegen v1.8.2/go.mod h1:YLgSKSDv/bZQB7N4ws6luhozi3cEdRktEqrX88CvjIw= +github.com/derrandz/go-header v0.0.0-20230426152902-919e3a027ef0 h1:X5ir2bPOUDRes1qGYcXb9RaxF6584NcZCjfA/VHYHvo= +github.com/derrandz/go-header v0.0.0-20230426152902-919e3a027ef0/go.mod h1:i9OpY70+PJ1xPw1IgMfF0Pk6vBD6VWPmjY3bgubJBcU= github.com/desertbit/timer v0.0.0-20180107155436-c41aec40b27f h1:U5y3Y5UE0w7amNe7Z5G/twsBW0KEalRQXZzf8ufSh9I= github.com/desertbit/timer v0.0.0-20180107155436-c41aec40b27f/go.mod h1:xH/i4TFMt8koVQZ6WFms69WAsDWr2XsYL3Hkl7jkoLE= github.com/dgraph-io/badger v1.5.5-0.20190226225317-8115aed38f8f/go.mod h1:VZxzAIRPHRVNRKRo6AXrX9BJegn6il06VMTZVJYCIjQ= diff --git a/nodebuilder/header/constructors.go b/nodebuilder/header/constructors.go index 7d70f0f5a8..c4dec7fc2c 100644 --- a/nodebuilder/header/constructors.go +++ b/nodebuilder/header/constructors.go @@ -5,13 +5,13 @@ import ( "github.com/libp2p/go-libp2p/core/host" "github.com/libp2p/go-libp2p/core/peer" - "github.com/libp2p/go-libp2p/core/peerstore" "github.com/libp2p/go-libp2p/p2p/net/conngater" "go.uber.org/fx" libfraud "github.com/celestiaorg/go-fraud" libhead "github.com/celestiaorg/go-header" "github.com/celestiaorg/go-header/p2p" + "github.com/celestiaorg/go-header/p2p/peerstore" "github.com/celestiaorg/go-header/store" "github.com/celestiaorg/go-header/sync" @@ -19,6 +19,8 @@ import ( modfraud "github.com/celestiaorg/celestia-node/nodebuilder/fraud" modp2p "github.com/celestiaorg/celestia-node/nodebuilder/p2p" "github.com/celestiaorg/celestia-node/share/eds/byzantine" + + p2p_peerstore "github.com/libp2p/go-libp2p/core/peerstore" ) // newP2PExchange constructs a new Exchange for headers. @@ -29,6 +31,7 @@ func newP2PExchange( host host.Host, conngater *conngater.BasicConnectionGater, cfg Config, + peerstore peerstore.Peerstore, ) (libhead.Exchange[*header.ExtendedHeader], error) { peers, err := cfg.trustedPeers(bpeers) if err != nil { @@ -37,12 +40,20 @@ func newP2PExchange( ids := make([]peer.ID, len(peers)) for index, peer := range peers { ids[index] = peer.ID - host.Peerstore().AddAddrs(peer.ID, peer.Addrs, peerstore.PermanentAddrTTL) + host.Peerstore().AddAddrs(peer.ID, peer.Addrs, p2p_peerstore.PermanentAddrTTL) + } + peerlist, err := peerstore.Load(context.Background()) + if err != nil { + log.Info("Error loading peerlist from disk", "err", err) + } else { + log.Info("Loaded peerlist from disk", peerlist) } + exchange, err := p2p.NewExchange[*header.ExtendedHeader](host, ids, conngater, p2p.WithParams(cfg.Client), p2p.WithNetworkID[p2p.ClientParameters](network.String()), p2p.WithChainID(network.String()), + p2p.WithPeerPersistence[p2p.ClientParameters](peerstore), ) if err != nil { return nil, err diff --git a/nodebuilder/header/module.go b/nodebuilder/header/module.go index 77e7c5eb99..454274f736 100644 --- a/nodebuilder/header/module.go +++ b/nodebuilder/header/module.go @@ -3,6 +3,7 @@ package header import ( "context" + "github.com/celestiaorg/go-header/p2p/peerstore" "github.com/ipfs/go-datastore" logging "github.com/ipfs/go-log/v2" pubsub "github.com/libp2p/go-libp2p-pubsub" @@ -16,6 +17,7 @@ import ( "github.com/celestiaorg/celestia-node/header" modfraud "github.com/celestiaorg/celestia-node/nodebuilder/fraud" + pstore "github.com/celestiaorg/celestia-node/nodebuilder/header/peerstore" "github.com/celestiaorg/celestia-node/nodebuilder/node" modp2p "github.com/celestiaorg/celestia-node/nodebuilder/p2p" ) @@ -89,6 +91,9 @@ func ConstructModule(tp node.Type, cfg *Config) fx.Option { return server.Stop(ctx) }), )), + fx.Provide(func(ds datastore.Batching) peerstore.Peerstore { + return pstore.NewPeerStore(ds) + }), ) switch tp { diff --git a/nodebuilder/header/peerstore/peerstore.go b/nodebuilder/header/peerstore/peerstore.go new file mode 100644 index 0000000000..b94b9a430e --- /dev/null +++ b/nodebuilder/header/peerstore/peerstore.go @@ -0,0 +1,64 @@ +package peerstore + +import ( + "context" + "encoding/json" + "fmt" + + "github.com/celestiaorg/go-header/p2p/peerstore" + "github.com/ipfs/go-datastore" + "github.com/ipfs/go-datastore/namespace" + "github.com/libp2p/go-libp2p/core/peer" + + logging "github.com/ipfs/go-log/v2" +) + +var ( + storePrefix = datastore.NewKey("p2p") + peersKey = datastore.NewKey("good_peers") + + log = logging.Logger("module/header/peerstore") +) + +var _ peerstore.Peerstore = (*peerStore)(nil) + +type peerStore struct { + ds datastore.Datastore +} + +// newPeerStore wraps the given datastore.Datastore with the `p2p` prefix. +func NewPeerStore(ds datastore.Datastore) peerstore.Peerstore { + return &peerStore{ds: namespace.Wrap(ds, storePrefix)} +} + +func (s *peerStore) Load(ctx context.Context) ([]peer.AddrInfo, error) { + log.Info("Loading peerlist") + bs, err := s.ds.Get(ctx, peersKey) + if err != nil { + return make([]peer.AddrInfo, 0), err + } + + peerlist := make([]peer.AddrInfo, 0) + err = json.Unmarshal(bs, &peerlist) + if err != nil { + return make([]peer.AddrInfo, 0), fmt.Errorf("error unmarshalling peerlist: %w", err) + } + + log.Info("Loaded peerlist", peerlist) + return peerlist, err +} + +func (s *peerStore) Put(ctx context.Context, peerlist []peer.AddrInfo) error { + log.Info("Storing peerlist", peerlist) + + bs, err := json.Marshal(peerlist) + if err != nil { + return fmt.Errorf("marshal checkpoint: %w", err) + } + + if err = s.ds.Put(ctx, peersKey, bs); err != nil { + return err + } + + return nil +} From 278ed095b04553b85041832249bb608d549b4b37 Mon Sep 17 00:00:00 2001 From: derrandz Date: Thu, 27 Apr 2023 13:44:23 +0100 Subject: [PATCH 2/4] wip: provide store --- go.mod | 2 +- go.sum | 4 ++-- nodebuilder/header/constructors.go | 6 ++++++ nodebuilder/header/module.go | 2 ++ 4 files changed, 11 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index f2b7f0ca45..24ec20a426 100644 --- a/go.mod +++ b/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/ipfs/go-verifcid => github.com/celestiaorg/go-verifcid v0.0.1-lazypatch -replace github.com/celestiaorg/go-header => github.com/derrandz/go-header v0.0.0-20230426152902-919e3a027ef0 +replace github.com/celestiaorg/go-header => github.com/derrandz/go-header v0.0.0-20230426190948-cc4d2b0d8b29 require ( cosmossdk.io/math v1.0.0-beta.3 diff --git a/go.sum b/go.sum index 740170bb82..6d35b3f1bd 100644 --- a/go.sum +++ b/go.sum @@ -490,8 +490,8 @@ github.com/decred/dcrd/dcrec/secp256k1/v4 v4.1.0/go.mod h1:DZGJHZMqrU4JJqFAWUS2U github.com/decred/dcrd/lru v1.0.0/go.mod h1:mxKOwFd7lFjN2GZYsiz/ecgqR6kkYAl+0pz0tEMk218= github.com/deepmap/oapi-codegen v1.6.0/go.mod h1:ryDa9AgbELGeB+YEXE1dR53yAjHwFvE9iAUlWl9Al3M= github.com/deepmap/oapi-codegen v1.8.2/go.mod h1:YLgSKSDv/bZQB7N4ws6luhozi3cEdRktEqrX88CvjIw= -github.com/derrandz/go-header v0.0.0-20230426152902-919e3a027ef0 h1:X5ir2bPOUDRes1qGYcXb9RaxF6584NcZCjfA/VHYHvo= -github.com/derrandz/go-header v0.0.0-20230426152902-919e3a027ef0/go.mod h1:i9OpY70+PJ1xPw1IgMfF0Pk6vBD6VWPmjY3bgubJBcU= +github.com/derrandz/go-header v0.0.0-20230426190948-cc4d2b0d8b29 h1:eCUiuyc6NKAyAaxLf0TJZAUD9yBrWlWorIyrrlLb0+Y= +github.com/derrandz/go-header v0.0.0-20230426190948-cc4d2b0d8b29/go.mod h1:i9OpY70+PJ1xPw1IgMfF0Pk6vBD6VWPmjY3bgubJBcU= github.com/desertbit/timer v0.0.0-20180107155436-c41aec40b27f h1:U5y3Y5UE0w7amNe7Z5G/twsBW0KEalRQXZzf8ufSh9I= github.com/desertbit/timer v0.0.0-20180107155436-c41aec40b27f/go.mod h1:xH/i4TFMt8koVQZ6WFms69WAsDWr2XsYL3Hkl7jkoLE= github.com/dgraph-io/badger v1.5.5-0.20190226225317-8115aed38f8f/go.mod h1:VZxzAIRPHRVNRKRo6AXrX9BJegn6il06VMTZVJYCIjQ= diff --git a/nodebuilder/header/constructors.go b/nodebuilder/header/constructors.go index c4dec7fc2c..3761c62ef4 100644 --- a/nodebuilder/header/constructors.go +++ b/nodebuilder/header/constructors.go @@ -26,6 +26,7 @@ import ( // newP2PExchange constructs a new Exchange for headers. func newP2PExchange( lc fx.Lifecycle, + storeChainHead *header.ExtendedHeader, bpeers modp2p.Bootstrappers, network modp2p.Network, host host.Host, @@ -54,6 +55,7 @@ func newP2PExchange( p2p.WithNetworkID[p2p.ClientParameters](network.String()), p2p.WithChainID(network.String()), p2p.WithPeerPersistence[p2p.ClientParameters](peerstore), + p2p.WithSubjectiveInitialization[p2p.ClientParameters](sync.IsExpired(storeChainHead, cfg.Syncer.TrustingPeriod)), ) if err != nil { return nil, err @@ -118,3 +120,7 @@ func newInitStore( return s, nil } + +func localChainHead(ctx context.Context, s *store.Store[*header.ExtendedHeader]) (*header.ExtendedHeader, error) { + return s.Head(ctx) +} diff --git a/nodebuilder/header/module.go b/nodebuilder/header/module.go index 454274f736..4c70a23f60 100644 --- a/nodebuilder/header/module.go +++ b/nodebuilder/header/module.go @@ -94,6 +94,8 @@ func ConstructModule(tp node.Type, cfg *Config) fx.Option { fx.Provide(func(ds datastore.Batching) peerstore.Peerstore { return pstore.NewPeerStore(ds) }), + fx.Provide(store.NewStore[*header.ExtendedHeader]), + fx.Provide(localChainHead), ) switch tp { From 6a68df925ef99d31f807606f796a2ec1ff7cdcd4 Mon Sep 17 00:00:00 2001 From: derrandz Date: Fri, 28 Apr 2023 16:23:32 +0100 Subject: [PATCH 3/4] feat: add p2p exchange option to bootstrap use persistent peerstore / bootstrap from previously seen peers --- das/daser_test.go | 4 ++-- go.mod | 2 ++ go.sum | 4 ++-- nodebuilder/header/constructors.go | 14 ++++++++++++-- nodebuilder/header/module.go | 4 ++++ state/integration_test.go | 3 ++- 6 files changed, 24 insertions(+), 7 deletions(-) diff --git a/das/daser_test.go b/das/daser_test.go index 2f1c494309..d0a99d5df3 100644 --- a/das/daser_test.go +++ b/das/daser_test.go @@ -313,7 +313,7 @@ func (m *mockGetter) generateHeaders(t *testing.T, bServ blockservice.BlockServi m.head = int64(startHeight + endHeight) } -func (m *mockGetter) Head(context.Context) (*header.ExtendedHeader, error) { +func (m *mockGetter) Head(context.Context, ...libhead.Option) (*header.ExtendedHeader, error) { return m.headers[m.head], nil } @@ -354,7 +354,7 @@ func (m benchGetterStub) GetByHeight(context.Context, uint64) (*header.ExtendedH type getterStub struct{} -func (m getterStub) Head(context.Context) (*header.ExtendedHeader, error) { +func (m getterStub) Head(context.Context, ...libhead.Option) (*header.ExtendedHeader, error) { return &header.ExtendedHeader{RawHeader: header.RawHeader{Height: 1}}, nil } diff --git a/go.mod b/go.mod index 27500f3dc4..fa20c34519 100644 --- a/go.mod +++ b/go.mod @@ -4,6 +4,8 @@ go 1.20 replace github.com/ipfs/go-verifcid => github.com/celestiaorg/go-verifcid v0.0.1-lazypatch +replace github.com/celestiaorg/go-header => github.com/derrandz/go-header v0.0.0-20230428151923-2da10fd92f76 + require ( cosmossdk.io/math v1.0.0-beta.3 github.com/BurntSushi/toml v1.2.1 diff --git a/go.sum b/go.sum index 5d7dcd43e0..c2b48e8466 100644 --- a/go.sum +++ b/go.sum @@ -350,8 +350,6 @@ github.com/celestiaorg/dagstore v0.0.0-20230413141458-735ab09a15d6 h1:/yCwMCoOPc github.com/celestiaorg/dagstore v0.0.0-20230413141458-735ab09a15d6/go.mod h1:ta/DlqIH10bvhwqJIw51Nq3QU4XVMp6pz3f0Deve9fM= github.com/celestiaorg/go-fraud v0.1.0 h1:v6mZvlmf2J5ELZfPnrtmmOvKbaYIUs/erDWPO8NbZyY= github.com/celestiaorg/go-fraud v0.1.0/go.mod h1:yoNM35cKMAkt5Mi/Qx3Wi9bnPilLi8n6RpHZVglTUDs= -github.com/celestiaorg/go-header v0.2.6 h1:f1Mlyu+EfDpkuzO3SWU5dow+ga2vLQ7hNuvsOe//z64= -github.com/celestiaorg/go-header v0.2.6/go.mod h1:i9OpY70+PJ1xPw1IgMfF0Pk6vBD6VWPmjY3bgubJBcU= github.com/celestiaorg/go-libp2p-messenger v0.2.0 h1:/0MuPDcFamQMbw9xTZ73yImqgTO3jHV7wKHvWD/Irao= github.com/celestiaorg/go-libp2p-messenger v0.2.0/go.mod h1:s9PIhMi7ApOauIsfBcQwbr7m+HBzmVfDIS+QLdgzDSo= github.com/celestiaorg/go-verifcid v0.0.1-lazypatch h1:9TSe3w1cmJmbWlweCwCTIZkan7jV8M+KwglXpdD+UG8= @@ -492,6 +490,8 @@ github.com/decred/dcrd/dcrec/secp256k1/v4 v4.1.0/go.mod h1:DZGJHZMqrU4JJqFAWUS2U github.com/decred/dcrd/lru v1.0.0/go.mod h1:mxKOwFd7lFjN2GZYsiz/ecgqR6kkYAl+0pz0tEMk218= github.com/deepmap/oapi-codegen v1.6.0/go.mod h1:ryDa9AgbELGeB+YEXE1dR53yAjHwFvE9iAUlWl9Al3M= github.com/deepmap/oapi-codegen v1.8.2/go.mod h1:YLgSKSDv/bZQB7N4ws6luhozi3cEdRktEqrX88CvjIw= +github.com/derrandz/go-header v0.0.0-20230428151923-2da10fd92f76 h1:R35DAv5yMA8gk3Nplb/FwrIUycTL/uP782u8njbJXiQ= +github.com/derrandz/go-header v0.0.0-20230428151923-2da10fd92f76/go.mod h1:i9OpY70+PJ1xPw1IgMfF0Pk6vBD6VWPmjY3bgubJBcU= github.com/desertbit/timer v0.0.0-20180107155436-c41aec40b27f h1:U5y3Y5UE0w7amNe7Z5G/twsBW0KEalRQXZzf8ufSh9I= github.com/desertbit/timer v0.0.0-20180107155436-c41aec40b27f/go.mod h1:xH/i4TFMt8koVQZ6WFms69WAsDWr2XsYL3Hkl7jkoLE= github.com/dgraph-io/badger v1.5.5-0.20190226225317-8115aed38f8f/go.mod h1:VZxzAIRPHRVNRKRo6AXrX9BJegn6il06VMTZVJYCIjQ= diff --git a/nodebuilder/header/constructors.go b/nodebuilder/header/constructors.go index 7d70f0f5a8..82c82c5eef 100644 --- a/nodebuilder/header/constructors.go +++ b/nodebuilder/header/constructors.go @@ -5,13 +5,14 @@ import ( "github.com/libp2p/go-libp2p/core/host" "github.com/libp2p/go-libp2p/core/peer" - "github.com/libp2p/go-libp2p/core/peerstore" + p2p_peerstore "github.com/libp2p/go-libp2p/core/peerstore" "github.com/libp2p/go-libp2p/p2p/net/conngater" "go.uber.org/fx" libfraud "github.com/celestiaorg/go-fraud" libhead "github.com/celestiaorg/go-header" "github.com/celestiaorg/go-header/p2p" + "github.com/celestiaorg/go-header/p2p/peerstore" "github.com/celestiaorg/go-header/store" "github.com/celestiaorg/go-header/sync" @@ -29,6 +30,7 @@ func newP2PExchange( host host.Host, conngater *conngater.BasicConnectionGater, cfg Config, + peerstore peerstore.Peerstore, ) (libhead.Exchange[*header.ExtendedHeader], error) { peers, err := cfg.trustedPeers(bpeers) if err != nil { @@ -37,12 +39,20 @@ func newP2PExchange( ids := make([]peer.ID, len(peers)) for index, peer := range peers { ids[index] = peer.ID - host.Peerstore().AddAddrs(peer.ID, peer.Addrs, peerstore.PermanentAddrTTL) + host.Peerstore().AddAddrs(peer.ID, peer.Addrs, p2p_peerstore.PermanentAddrTTL) } + peerlist, err := peerstore.Load(context.Background()) + if err != nil { + log.Info("Error loading peerlist from disk", "err", err) + } else { + log.Info("Loaded peerlist from disk", peerlist) + } + exchange, err := p2p.NewExchange[*header.ExtendedHeader](host, ids, conngater, p2p.WithParams(cfg.Client), p2p.WithNetworkID[p2p.ClientParameters](network.String()), p2p.WithChainID(network.String()), + p2p.WithPeerPersistence[p2p.ClientParameters](peerstore), ) if err != nil { return nil, err diff --git a/nodebuilder/header/module.go b/nodebuilder/header/module.go index 77e7c5eb99..75cab2bc28 100644 --- a/nodebuilder/header/module.go +++ b/nodebuilder/header/module.go @@ -11,6 +11,7 @@ import ( libhead "github.com/celestiaorg/go-header" "github.com/celestiaorg/go-header/p2p" + "github.com/celestiaorg/go-header/p2p/peerstore" "github.com/celestiaorg/go-header/store" "github.com/celestiaorg/go-header/sync" @@ -89,6 +90,9 @@ func ConstructModule(tp node.Type, cfg *Config) fx.Option { return server.Stop(ctx) }), )), + fx.Provide(func(ds datastore.Batching) peerstore.Peerstore { + return peerstore.NewPeerStore(ds) + }), ) switch tp { diff --git a/state/integration_test.go b/state/integration_test.go index 25b8e00a2d..f26b6cffab 100644 --- a/state/integration_test.go +++ b/state/integration_test.go @@ -20,6 +20,7 @@ import ( "github.com/celestiaorg/celestia-app/testutil/testfactory" "github.com/celestiaorg/celestia-app/testutil/testnode" blobtypes "github.com/celestiaorg/celestia-app/x/blob/types" + libhead "github.com/celestiaorg/go-header" "github.com/celestiaorg/celestia-node/core" "github.com/celestiaorg/celestia-node/header" @@ -95,7 +96,7 @@ type localHeader struct { client rpcclient.Client } -func (l localHeader) Head(ctx context.Context) (*header.ExtendedHeader, error) { +func (l localHeader) Head(ctx context.Context, _ ...libhead.Option) (*header.ExtendedHeader, error) { latest, err := l.client.Block(ctx, nil) if err != nil { return nil, err From 88439f0a46aa47277f6609fffd3029343bcb8fa8 Mon Sep 17 00:00:00 2001 From: derrandz Date: Tue, 9 May 2023 16:10:45 +0100 Subject: [PATCH 4/4] chore: remove relic --- go.mod | 2 +- go.sum | 4 ++-- nodebuilder/header/constructors.go | 7 ------- 3 files changed, 3 insertions(+), 10 deletions(-) diff --git a/go.mod b/go.mod index 35091a53ea..aab9baf96f 100644 --- a/go.mod +++ b/go.mod @@ -4,7 +4,7 @@ go 1.20 replace github.com/ipfs/go-verifcid => github.com/celestiaorg/go-verifcid v0.0.1-lazypatch -replace github.com/celestiaorg/go-header => github.com/derrandz/go-header v0.0.0-20230428151923-2da10fd92f76 +replace github.com/celestiaorg/go-header => github.com/derrandz/go-header v0.0.0-20230509145636-1c6870281abc require ( cosmossdk.io/math v1.0.0-beta.3 diff --git a/go.sum b/go.sum index 8e898c52d5..59d4cfcd8c 100644 --- a/go.sum +++ b/go.sum @@ -490,8 +490,8 @@ github.com/decred/dcrd/dcrec/secp256k1/v4 v4.1.0/go.mod h1:DZGJHZMqrU4JJqFAWUS2U github.com/decred/dcrd/lru v1.0.0/go.mod h1:mxKOwFd7lFjN2GZYsiz/ecgqR6kkYAl+0pz0tEMk218= github.com/deepmap/oapi-codegen v1.6.0/go.mod h1:ryDa9AgbELGeB+YEXE1dR53yAjHwFvE9iAUlWl9Al3M= github.com/deepmap/oapi-codegen v1.8.2/go.mod h1:YLgSKSDv/bZQB7N4ws6luhozi3cEdRktEqrX88CvjIw= -github.com/derrandz/go-header v0.0.0-20230428151923-2da10fd92f76 h1:R35DAv5yMA8gk3Nplb/FwrIUycTL/uP782u8njbJXiQ= -github.com/derrandz/go-header v0.0.0-20230428151923-2da10fd92f76/go.mod h1:i9OpY70+PJ1xPw1IgMfF0Pk6vBD6VWPmjY3bgubJBcU= +github.com/derrandz/go-header v0.0.0-20230509145636-1c6870281abc h1:nQ/hcdXzbe3gTDyUJMT2ToSi106Gi763ZzTX8d/hnMM= +github.com/derrandz/go-header v0.0.0-20230509145636-1c6870281abc/go.mod h1:IRBlsa3L97x2CQKyPCiKlayXJleq+fcIN8VDHX4zYpU= github.com/desertbit/timer v0.0.0-20180107155436-c41aec40b27f h1:U5y3Y5UE0w7amNe7Z5G/twsBW0KEalRQXZzf8ufSh9I= github.com/desertbit/timer v0.0.0-20180107155436-c41aec40b27f/go.mod h1:xH/i4TFMt8koVQZ6WFms69WAsDWr2XsYL3Hkl7jkoLE= github.com/dgraph-io/badger v1.5.5-0.20190226225317-8115aed38f8f/go.mod h1:VZxzAIRPHRVNRKRo6AXrX9BJegn6il06VMTZVJYCIjQ= diff --git a/nodebuilder/header/constructors.go b/nodebuilder/header/constructors.go index 82c82c5eef..2da2e83d1f 100644 --- a/nodebuilder/header/constructors.go +++ b/nodebuilder/header/constructors.go @@ -41,13 +41,6 @@ func newP2PExchange( ids[index] = peer.ID host.Peerstore().AddAddrs(peer.ID, peer.Addrs, p2p_peerstore.PermanentAddrTTL) } - peerlist, err := peerstore.Load(context.Background()) - if err != nil { - log.Info("Error loading peerlist from disk", "err", err) - } else { - log.Info("Loaded peerlist from disk", peerlist) - } - exchange, err := p2p.NewExchange[*header.ExtendedHeader](host, ids, conngater, p2p.WithParams(cfg.Client), p2p.WithNetworkID[p2p.ClientParameters](network.String()),