.
Kim committed
Oct 21, 2025 at 18:27 UTC
7d43bde447ae0604fff2397a455177d23f5f0a45
1 file changed
+35
-35
relaydns/host.go
+35
-35
@@ -1,15 +1,15 @@
1
package relaydns
2
3
import (
4
- "context"
5
- "fmt"
4
+ "context"
5
+ "fmt"
6
7
- "github.com/libp2p/go-libp2p"
8
- "github.com/libp2p/go-libp2p/core/host"
9
- "github.com/libp2p/go-libp2p/core/network"
10
- "github.com/libp2p/go-libp2p/core/peer"
11
- ma "github.com/multiformats/go-multiaddr"
12
- "github.com/rs/zerolog/log"
7
+ "github.com/libp2p/go-libp2p"
8
+ "github.com/libp2p/go-libp2p/core/host"
9
+ "github.com/libp2p/go-libp2p/core/network"
10
+ "github.com/libp2p/go-libp2p/core/peer"
11
+ ma "github.com/multiformats/go-multiaddr"
12
+ "github.com/rs/zerolog/log"
13
)
14
15
func MakeHost(ctx context.Context, port int, enableRelay bool) (host.Host, error) {
@@ -40,32 +40,32 @@ func MakeHost(ctx context.Context, port int, enableRelay bool) (host.Host, error
40
}
41
42
func ConnectBootstraps(ctx context.Context, h host.Host, addrs []string) {
43
- // Connect once per unique peer ID; skip already-connected peers to avoid noisy logs.
44
- seen := make(map[string]struct{}, len(addrs))
45
- for _, s := range addrs {
46
- m, err := ma.NewMultiaddr(s)
47
- if err != nil {
48
- log.Warn().Err(err).Msgf("bootstrap bad multiaddr %q", s)
49
- continue
50
- }
51
- ai, err := peer.AddrInfoFromP2pAddr(m)
52
- if err != nil {
53
- log.Warn().Err(err).Msgf("bootstrap missing /p2p/ in %q", s)
54
- continue
55
- }
56
- pid := ai.ID.String()
57
- if _, ok := seen[pid]; ok {
58
- continue
59
- }
60
- seen[pid] = struct{}{}
43
+ // Connect once per unique peer ID; skip already-connected peers to avoid noisy logs.
44
+ seen := make(map[string]struct{}, len(addrs))
45
+ for _, s := range addrs {
46
+ m, err := ma.NewMultiaddr(s)
47
+ if err != nil {
48
+ log.Warn().Err(err).Msgf("bootstrap bad multiaddr %q", s)
49
+ continue
50
+ }
51
+ ai, err := peer.AddrInfoFromP2pAddr(m)
52
+ if err != nil {
53
+ log.Warn().Err(err).Msgf("bootstrap missing /p2p/ in %q", s)
54
+ continue
55
+ }
56
+ pid := ai.ID.String()
57
+ if _, ok := seen[pid]; ok {
58
+ continue
59
+ }
60
+ seen[pid] = struct{}{}
61
62
- if h.Network().Connectedness(ai.ID) == network.Connected {
63
- // Already connected: skip loudly logging.
64
- continue
65
- }
66
- if err := h.Connect(ctx, *ai); err != nil {
67
- // Only warn on errors
68
- log.Warn().Err(err).Msgf("bootstrap connect %s", ai.ID)
69
- }
70
- }
62
+ if h.Network().Connectedness(ai.ID) == network.Connected {
63
+ // Already connected: skip loudly logging.
64
+ continue
65
+ }
66
+ if err := h.Connect(ctx, *ai); err != nil {
67
+ // Only warn on errors
68
+ log.Warn().Err(err).Msgf("bootstrap connect %s", ai.ID)
69
+ }
70
+ }
71
}