Skip to content
Snippets Groups Projects
Select Git revision
  • 49cc8d03b80bcee3e848f3dad6bd6bc39fe5b19c
  • master default protected
  • spilo-wale-removal
  • dependabot/go_modules/golang.org/x/oauth2-0.27.0
  • bug-upgrade
  • gh-pages
  • patroni-4-integration
  • remove-zappr
  • ignore-auto-upgrade
  • arm-pooler
  • update-go-and-deps
  • pluralsh-liveness-probe
  • silenium-dev-master
  • bump-v1.9.1
  • enable-query-logging
  • bump-v1.7.1
  • resize-mixed-mode
  • instance-annotation
  • bump-v1.8.2
  • clone-bucket-prefix
  • bump-v1.8.1
  • v1.14.0
  • v1.13.0
  • v1.12.2
  • v1.12.1
  • v1.12.0
  • v1.11.0
  • v1.10.1
  • v1.10.0
  • v1.9.0
  • v1.8.2
  • v1.8.1
  • v1.8.0
  • v1.7.1
  • v1.7.0
  • v1.6.3
  • v1.6.2
  • v1.6.1
  • v1.6.0
  • v1.5.0
  • v1.4.0
41 results

cluster_manifest.md

Blame
  • bootstrap_peers.go 2.69 KiB
    package config
    
    import (
    	"errors"
    	"fmt"
    
    	peer "github.com/libp2p/go-libp2p/core/peer"
    	ma "github.com/multiformats/go-multiaddr"
    )
    
    // DefaultBootstrapAddresses are the hardcoded bootstrap addresses
    // for IPFS. they are nodes run by the IPFS team. docs on these later.
    // As with all p2p networks, bootstrap is an important security concern.
    //
    // NOTE: This is here -- and not inside cmd/ipfs/init.go -- because of an
    // import dependency issue. TODO: move this into a config/default/ package.
    var DefaultBootstrapAddresses = []string{
    	"/dnsaddr/bootstrap.libp2p.io/p2p/QmNnooDu7bfjPFoTZYxMNLWUQJyrVwtbZg5gBMjTezGAJN",
    	"/dnsaddr/bootstrap.libp2p.io/p2p/QmQCU2EcMqAqQPR2i9bChDtGNJchTbq5TbXJJ16u19uLTa",
    	"/dnsaddr/bootstrap.libp2p.io/p2p/QmbLHAnMoJPWSCR5Zhtx6BHJX9KiKNN6tpvbUcqanj75Nb",
    	"/dnsaddr/bootstrap.libp2p.io/p2p/QmcZf59bWwK5XFi76CZX8cbJ4BhTzzA3gU1ZjYZcYW3dwt",
    	"/ip4/104.131.131.82/tcp/4001/p2p/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ",      // mars.i.ipfs.io
    	"/ip4/104.131.131.82/udp/4001/quic/p2p/QmaCpDMGvV2BGHeYERUEnRQAwe3N8SzbUtfsmvsqQLuvuJ", // mars.i.ipfs.io
    }
    
    // ErrInvalidPeerAddr signals an address is not a valid peer address.
    var ErrInvalidPeerAddr = errors.New("invalid peer address")
    
    func (c *Config) BootstrapPeers() ([]peer.AddrInfo, error) {
    	return ParseBootstrapPeers(c.Bootstrap)
    }
    
    // DefaultBootstrapPeers returns the (parsed) set of default bootstrap peers.
    // if it fails, it returns a meaningful error for the user.
    // This is here (and not inside cmd/ipfs/init) because of module dependency problems.
    func DefaultBootstrapPeers() ([]peer.AddrInfo, error) {
    	ps, err := ParseBootstrapPeers(DefaultBootstrapAddresses)
    	if err != nil {
    		return nil, fmt.Errorf(`failed to parse hardcoded bootstrap peers: %s
    This is a problem with the ipfs codebase. Please report it to the dev team`, err)
    	}
    	return ps, nil
    }
    
    func (c *Config) SetBootstrapPeers(bps []peer.AddrInfo) {
    	c.Bootstrap = BootstrapPeerStrings(bps)
    }
    
    // ParseBootstrapPeer parses a bootstrap list into a list of AddrInfos.
    func ParseBootstrapPeers(addrs []string) ([]peer.AddrInfo, error) {
    	maddrs := make([]ma.Multiaddr, len(addrs))
    	for i, addr := range addrs {
    		var err error
    		maddrs[i], err = ma.NewMultiaddr(addr)
    		if err != nil {
    			return nil, err
    		}
    	}
    	return peer.AddrInfosFromP2pAddrs(maddrs...)
    }
    
    // BootstrapPeerStrings formats a list of AddrInfos as a bootstrap peer list
    // suitable for serialization.
    func BootstrapPeerStrings(bps []peer.AddrInfo) []string {
    	bpss := make([]string, 0, len(bps))
    	for _, pi := range bps {
    		addrs, err := peer.AddrInfoToP2pAddrs(&pi)
    		if err != nil {
    			// programmer error.
    			panic(err)
    		}
    		for _, addr := range addrs {
    			bpss = append(bpss, addr.String())
    		}
    	}
    	return bpss
    }