From d6f442bb86d3429ebea7dce163b82a676bf4d289 Mon Sep 17 00:00:00 2001 From: lasiar Date: Sat, 17 Jul 2021 03:22:55 +0700 Subject: [PATCH] refactor(as-a-library): replace deprecated functions and structures --- docs/examples/go-ipfs-as-a-library/main.go | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/docs/examples/go-ipfs-as-a-library/main.go b/docs/examples/go-ipfs-as-a-library/main.go index f07398c30..6b723acc7 100644 --- a/docs/examples/go-ipfs-as-a-library/main.go +++ b/docs/examples/go-ipfs-as-a-library/main.go @@ -15,7 +15,6 @@ import ( libp2p "github.com/ipfs/go-ipfs/core/node/libp2p" icore "github.com/ipfs/interface-go-ipfs-core" icorepath "github.com/ipfs/interface-go-ipfs-core/path" - peerstore "github.com/libp2p/go-libp2p-peerstore" ma "github.com/multiformats/go-multiaddr" "github.com/ipfs/go-ipfs/core" @@ -131,19 +130,19 @@ func spawnEphemeral(ctx context.Context) (icore.CoreAPI, error) { func connectToPeers(ctx context.Context, ipfs icore.CoreAPI, peers []string) error { var wg sync.WaitGroup - peerInfos := make(map[peer.ID]*peerstore.PeerInfo, len(peers)) + peerInfos := make(map[peer.ID]*peer.AddrInfo, len(peers)) for _, addrStr := range peers { addr, err := ma.NewMultiaddr(addrStr) if err != nil { return err } - pii, err := peerstore.InfoFromP2pAddr(addr) + pii, err := peer.AddrInfoFromP2pAddr(addr) if err != nil { return err } pi, ok := peerInfos[pii.ID] if !ok { - pi = &peerstore.PeerInfo{ID: pii.ID} + pi = &peer.AddrInfo{ID: pii.ID} peerInfos[pi.ID] = pi } pi.Addrs = append(pi.Addrs, pii.Addrs...) @@ -151,7 +150,7 @@ func connectToPeers(ctx context.Context, ipfs icore.CoreAPI, peers []string) err wg.Add(len(peerInfos)) for _, peerInfo := range peerInfos { - go func(peerInfo *peerstore.PeerInfo) { + go func(peerInfo *peer.AddrInfo) { defer wg.Done() err := ipfs.Swarm().Connect(ctx, *peerInfo) if err != nil {