-
Notifications
You must be signed in to change notification settings - Fork 1
/
bootstrap.go
executable file
·101 lines (91 loc) · 4.63 KB
/
bootstrap.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
package p2p
import (
"context"
"sync"
"time"
"github.com/libp2p/go-libp2p-core/host"
"github.com/libp2p/go-libp2p-core/peer"
"github.com/libp2p/go-libp2p-core/protocol"
ma "github.com/multiformats/go-multiaddr"
log "github.com/sirupsen/logrus"
)
const DHTProtocolID = protocol.ID("/0x-mesh-dht/version/1")
// DefaultBootstrapList is a list of addresses to use by default for
// bootstrapping the DHT.
var DefaultBootstrapList = []string{
// bootstrap nodes
"/ip4/34.136.24.16/tcp/4002/ws/p2p/16Uiu2HAmFxhJFSefdVYzDwDcGLj5RvH6ZaMnmZx7dXFFprVUz7fP",
//"/ip4/192.41.136.236/tcp/4002/ws/p2p/16Uiu2HAmHXUhNrUZ7aywg3x8os6D7XiLaVSDszou9UiHBZHjsqtN",
// "/ip4/3.214.190.67/tcp/60559/ws/ipfs/16Uiu2HAmGx8Z6gdq5T5AQE54GMtqDhDFhizywTy1o28NJbAMMumF",
// "/dns4/bootstrap-0.mesh.0x.org/tcp/60558/ipfs/16Uiu2HAmGx8Z6gdq5T5AQE54GMtqDhDFhizywTy1o28NJbAMMumF",
// "/dns4/bootstrap-0.mesh.0x.org/tcp/60559/ws/ipfs/16Uiu2HAmGx8Z6gdq5T5AQE54GMtqDhDFhizywTy1o28NJbAMMumF",
// "/dns4/bootstrap-0.mesh.0x.org/tcp/443/wss/ipfs/16Uiu2HAmGx8Z6gdq5T5AQE54GMtqDhDFhizywTy1o28NJbAMMumF",
// "/ip4/18.200.96.60/tcp/60558/ipfs/16Uiu2HAkwsDZk4LzXy2rnWANRsyBjB4fhjnsNeJmjgsBqxPGTL32",
// "/ip4/18.200.96.60/tcp/60559/ws/ipfs/16Uiu2HAkwsDZk4LzXy2rnWANRsyBjB4fhjnsNeJmjgsBqxPGTL32",
// "/dns4/bootstrap-1.mesh.0x.org/tcp/60558/ipfs/16Uiu2HAkwsDZk4LzXy2rnWANRsyBjB4fhjnsNeJmjgsBqxPGTL32",
// "/dns4/bootstrap-1.mesh.0x.org/tcp/60559/ws/ipfs/16Uiu2HAkwsDZk4LzXy2rnWANRsyBjB4fhjnsNeJmjgsBqxPGTL32",
// "/dns4/bootstrap-1.mesh.0x.org/tcp/443/wss/ipfs/16Uiu2HAkwsDZk4LzXy2rnWANRsyBjB4fhjnsNeJmjgsBqxPGTL32",
// "/ip4/13.232.193.142/tcp/60558/ipfs/16Uiu2HAkykwoBxwyvoEbaEkuKMeKrmJDPZ2uKFPUKtqd2JbGHUNH",
// "/ip4/13.232.193.142/tcp/60559/ws/ipfs/16Uiu2HAkykwoBxwyvoEbaEkuKMeKrmJDPZ2uKFPUKtqd2JbGHUNH",
// "/dns4/bootstrap-2.mesh.0x.org/tcp/60558/ipfs/16Uiu2HAkykwoBxwyvoEbaEkuKMeKrmJDPZ2uKFPUKtqd2JbGHUNH",
// "/dns4/bootstrap-2.mesh.0x.org/tcp/60559/ws/ipfs/16Uiu2HAkykwoBxwyvoEbaEkuKMeKrmJDPZ2uKFPUKtqd2JbGHUNH",
// "/dns4/bootstrap-2.mesh.0x.org/tcp/443/wss/ipfs/16Uiu2HAkykwoBxwyvoEbaEkuKMeKrmJDPZ2uKFPUKtqd2JbGHUNH",
// // relay nodes
// // We could consider hard-coding these at the circuit-relay level. See
// // https://github.com/libp2p/go-libp2p/pull/705. Hard-coding them in the
// // bootstrap list is likely good enough for now.
// "/ip4/167.172.201.142/tcp/60558/ipfs/16Uiu2HAkzuS8DfyZ2CPzZbxGCXLSHvvbvh8nvGCHjY6wEXe2jhAm",
// "/dns4/fra1.relayer.mesh.0x.org/tcp/443/wss/ipfs/16Uiu2HAkzuS8DfyZ2CPzZbxGCXLSHvvbvh8nvGCHjY6wEXe2jhAm",
// "/ip4/167.172.201.142/tcp/60558/ipfs/16Uiu2HAmM1dkXwZK5HsnknGFxzPBLuCw4EboiC2sdwKrPJZ6kcio",
// "/dns4/sfo2.relayer.mesh.0x.org/tcp/443/wss/ipfs/16Uiu2HAmM1dkXwZK5HsnknGFxzPBLuCw4EboiC2sdwKrPJZ6kcio",
// "/ip4/159.65.4.82/tcp/60558/ipfs/16Uiu2HAm9brLYhoM1wCTRtGRR7ZqXhk8kfEt6a2rSFSZpeV8eB7L",
// "/dns4/sgp1.relayer.mesh.0x.org/tcp/443/wss/ipfs/16Uiu2HAm9brLYhoM1wCTRtGRR7ZqXhk8kfEt6a2rSFSZpeV8eB7L",
// // These nodes are provided by the libp2p community on a best-effort basis.
// // We're using them as a backup for increased redundancy.
// "/ip4/34.201.54.78/tcp/4001/ipfs/12D3KooWHwJDdbx73qiBpSCJfg4RuYyzqnLUwfLBqzn77TSy7kRX",
// "/ip4/18.204.221.103/tcp/4001/ipfs/12D3KooWQS6Gsr2kLZvF7DVtoRFtj24aar5jvz88LvJePrawM3EM",
}
func BootstrapListToAddrInfos(bootstrapList []string) ([]peer.AddrInfo, error) {
maddrs := make([]ma.Multiaddr, len(bootstrapList))
for i, addrString := range bootstrapList {
maddr, err := ma.NewMultiaddr(addrString)
if err != nil {
return nil, err
}
maddrs[i] = maddr
}
return peer.AddrInfosFromP2pAddrs(maddrs...)
}
func ConnectToBootstrapList(ctx context.Context, host host.Host, bootstrapList []string) error {
log.WithField("bootstrapList", bootstrapList).Info("connecting to bootstrap peers")
bootstrapAddrInfos, err := BootstrapListToAddrInfos(bootstrapList)
if err != nil {
return err
}
connectCtx, cancel := context.WithTimeout(ctx, defaultNetworkTimeout)
defer cancel()
wg := sync.WaitGroup{}
for _, peerInfo := range bootstrapAddrInfos {
if peerInfo.ID == host.ID() {
// Don't connect to self.
continue
}
wg.Add(1)
go func(peerInfo peer.AddrInfo) {
defer wg.Done()
if err := host.Connect(connectCtx, peerInfo); err != nil {
log.WithFields(map[string]interface{}{
"error": err.Error(),
"peerInfo": peerInfo,
}).Warn("failed to connect to bootstrap peer")
}
}(peerInfo)
}
wg.Wait()
// It is recommended to wait for 2 seconds after connecting to all the
// bootstrap peers to give time for the relevant notifees to trigger and the
// DHT to fully initialize.
// See: https://github.com/0xProject/0x-mesh/pull/69#discussion_r286849679
time.Sleep(2 * time.Second)
return nil
}