Stream reset initial implementation (#407)

* stream reset

pkg/p2p/libp2p/internal/handshake/mock/stream.go

@@ -63,3 +63,7 @@ func (s *Stream) Close() error {
 func (s *Stream) FullClose() error {
 	return nil
 }
+
+func (s *Stream) Reset() error {
+	return nil
+}

pkg/p2p/libp2p/libp2p.go

@@ -216,7 +216,7 @@ func New(ctx context.Context, signer beecrypto.Signer, networkID uint64, overlay
 		if err != nil {
 			s.logger.Debugf("handshake: handle %s: %v", peerID, err)
 			s.logger.Errorf("unable to handshake with peer %v", peerID)
-			_ = stream.Reset()
+			_ = handshakeStream.Reset()
 			_ = s.disconnect(peerID)
 			return
 		}
@@ -376,7 +376,7 @@ func (s *Service) Connect(ctx context.Context, addr ma.Multiaddr) (address *bzz.
 	handshakeStream := NewStream(stream)
 	i, err := s.handshakeService.Handshake(handshakeStream, stream.Conn().RemoteMultiaddr(), stream.Conn().RemotePeer())
 	if err != nil {
-		_ = stream.Reset()
+		_ = handshakeStream.Reset()
 		_ = s.disconnect(info.ID)
 		return nil, fmt.Errorf("handshake: %w", err)
 	}

pkg/p2p/p2p.go

@@ -35,6 +35,7 @@ type Stream interface {
 	io.Closer
 	Headers() Headers
 	FullClose() error
+	Reset() error
 }
 
 // ProtocolSpec defines a collection of Stream specifications with handlers.

pkg/p2p/protobuf/protobuf_test.go

@@ -387,6 +387,10 @@ func (noopWriteCloser) FullClose() error {
 	return nil
 }
 
+func (noopWriteCloser) Reset() error {
+	return nil
+}
+
 type noopReadCloser struct {
 	io.Writer
 }
@@ -410,3 +414,7 @@ func (noopReadCloser) Close() error {
 func (noopReadCloser) FullClose() error {
 	return nil
 }
+
+func (noopReadCloser) Reset() error {
+	return nil
+}

pkg/p2p/streamtest/streamtest.go

@@ -235,6 +235,11 @@ func (s *stream) FullClose() error {
 	return nil
 }
 
+func (s *stream) Reset() error {
+	//todo: :implement appropriately after all protocols are migrated and tested
+	return s.Close()
+}
+
 type record struct {
 	b      []byte
 	c      int