From 53e6bac8f11ca98f7d755652f6d7c67edbfcdeea Mon Sep 17 00:00:00 2001 From: Marten Seemann Date: Sat, 23 Oct 2021 14:34:58 +0200 Subject: [PATCH] remove leftover peerstore implementation in the root package --- p2p/host/peerstore/peerstore.go | 58 --------------------------------- 1 file changed, 58 deletions(-) diff --git a/p2p/host/peerstore/peerstore.go b/p2p/host/peerstore/peerstore.go index e168710f9e..9f5eda8f49 100644 --- a/p2p/host/peerstore/peerstore.go +++ b/p2p/host/peerstore/peerstore.go @@ -1,68 +1,10 @@ package peerstore import ( - "fmt" - "io" - "github.com/libp2p/go-libp2p-core/peer" pstore "github.com/libp2p/go-libp2p-core/peerstore" ) -var _ pstore.Peerstore = (*peerstore)(nil) - -type peerstore struct { - pstore.Metrics - - pstore.KeyBook - pstore.AddrBook - pstore.ProtoBook - pstore.PeerMetadata -} - -func (ps *peerstore) Close() (err error) { - var errs []error - weakClose := func(name string, c interface{}) { - if cl, ok := c.(io.Closer); ok { - if err = cl.Close(); err != nil { - errs = append(errs, fmt.Errorf("%s error: %s", name, err)) - } - } - } - - weakClose("keybook", ps.KeyBook) - weakClose("addressbook", ps.AddrBook) - weakClose("protobook", ps.ProtoBook) - weakClose("peermetadata", ps.PeerMetadata) - - if len(errs) > 0 { - return fmt.Errorf("failed while closing peerstore; err(s): %q", errs) - } - return nil -} - -func (ps *peerstore) Peers() peer.IDSlice { - set := map[peer.ID]struct{}{} - for _, p := range ps.PeersWithKeys() { - set[p] = struct{}{} - } - for _, p := range ps.PeersWithAddrs() { - set[p] = struct{}{} - } - - pps := make(peer.IDSlice, 0, len(set)) - for p := range set { - pps = append(pps, p) - } - return pps -} - -func (ps *peerstore) PeerInfo(p peer.ID) peer.AddrInfo { - return peer.AddrInfo{ - ID: p, - Addrs: ps.AddrBook.Addrs(p), - } -} - func PeerInfos(ps pstore.Peerstore, peers peer.IDSlice) []peer.AddrInfo { pi := make([]peer.AddrInfo, len(peers)) for i, p := range peers {