Skip to content

M
mybee
Commit 34c81c30 authored by Petar Radovic's avatar Petar Radovic
Browse files
Options

very simple handshake disconnect 

todo
parent cac82c0d
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
pkg/p2p/libp2p/libp2p.go
View file @ 34c81c30
...@@ -217,10 +217,14 @@ func New(ctx context.Context, o Options) (*Service, error) { ...@@ -217,10 +217,14 @@ func New(ctx context.Context, o Options) (*Service, error) {
i, err := s.handshakeService.Handle(stream) i, err := s.handshakeService.Handle(stream)
if err != nil { if err != nil {
s.logger.Errorf("handshake with peer %s: %w", peerID, err) s.logger.Errorf("handshake with peer %s: %w", peerID, err)
// todo: test connection close and refactor
stream.Conn().Close()
return return
} }
if i.NetworkID != s.networkID { if i.NetworkID != s.networkID {
s.logger.Errorf("handshake with peer %s: invalid network id %v", peerID, i.NetworkID) s.logger.Errorf("handshake with peer %s: invalid network id %v", peerID, i.NetworkID)
// todo: test connection close and refactor
stream.Conn().Close()
return return
} }
s.peers.add(peerID, i.Address) s.peers.add(peerID, i.Address)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment