Skip to content

Commit 584cc72

Browse files
committed
feat: hadshake send peer remote address from connection as a fallback
1 parent 3f89af0 commit 584cc72

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

pkg/p2p/libp2p/libp2p.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -425,6 +425,10 @@ func (s *Service) handleIncoming(stream network.Stream) {
425425
return
426426
}
427427

428+
if len(peerMultiaddrs) == 0 {
429+
peerMultiaddrs = append(peerMultiaddrs, stream.Conn().RemoteMultiaddr())
430+
}
431+
428432
s.logger.Info("INVESTIGATION libp2p handle incoming connection", "peer", peerID, "peer multiaddrs", peerMultiaddrs)
429433

430434
i, err := s.handshakeService.Handle(
@@ -796,6 +800,10 @@ func (s *Service) Connect(ctx context.Context, addrs []ma.Multiaddr) (address *b
796800
return nil, fmt.Errorf("build peer multiaddrs: %w", err)
797801
}
798802

803+
if len(peerMultiaddrs) == 0 {
804+
peerMultiaddrs = append(peerMultiaddrs, stream.Conn().RemoteMultiaddr())
805+
}
806+
799807
s.logger.Info("INVESTIGATION libp2p connect", "peer", connectionPeer, "connect addrs", addrs, "peer multiaddrs", peerMultiaddrs)
800808

801809
i, err := s.handshakeService.Handshake(

0 commit comments

Comments
 (0)