opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-24 22:38:27 +08:00
Code Issues Projects Releases Wiki Activity

config: use PeerID in bootstrap config

Browse Source
This commit is contained in:
Juan Batiz-Benet
2014-09-19 04:58:57 -07:00
committed by Brian Tiger Chow
parent 9ea715cb10
commit 4284e8e960
2 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
config/config.go
View File

@ -25,6 +25,7 @@ type Datastore struct {
type SavedPeer struct { type SavedPeer struct {
Address string Address string
PeerID string // until multiaddr supports ipfs, use another field.
} }
// Config is used to load IPFS config files. // Config is used to load IPFS config files.

10
core/core.go
View File

@ -186,13 +186,21 @@ func initIdentity(cfg *config.Config) (*peer.Peer, error) {
func initConnections(cfg *config.Config, route *dht.IpfsDHT) { func initConnections(cfg *config.Config, route *dht.IpfsDHT) {
for _, p := range cfg.Peers { for _, p := range cfg.Peers {
if p.PeerID == "" {
u.PErr("error: peer does not include PeerID. %v\n", p)
}
maddr, err := ma.NewMultiaddr(p.Address) maddr, err := ma.NewMultiaddr(p.Address)
if err != nil { if err != nil {
u.PErr("error: %v\n", err) u.PErr("error: %v\n", err)
continue continue
} }
_, err = route.Connect(maddr) // setup peer
npeer := &peer.Peer{ID: peer.DecodePrettyID(p.PeerID)}
npeer.AddAddress(maddr)
_, err = route.Connect(npeer)
if err != nil { if err != nil {
u.PErr("Bootstrapping error: %v\n", err) u.PErr("Bootstrapping error: %v\n", err)
} }