fix: stream reseting before closing connection (#71)

Author: mpetrun5

comm/p2p/libp2p.go

@@ -188,15 +188,6 @@ func (c Libp2pCommunication) sendMessage(
 	if err != nil {
 		c.logger.Error().Str("To", to.String()).Err(err).Msg("unable to send message")
 		c.streamManager.ReleaseStreams(sessionID)
-
-		stream, err = c.streamManager.Stream(sessionID, to, c.protocolID)
-		if err != nil {
-			return err
-		}
-
-		err = WriteStream(msg, bufio.NewWriterSize(stream, defaultBufferSize))
-	}
-	if err != nil {
 		return err
 	}
 

comm/p2p/manager.go

@@ -43,13 +43,10 @@ func (sm *StreamManager) ReleaseStreams(sessionID string) {
 	}
 
 	for peer, stream := range streams {
-		if stream.Conn() != nil {
-			_ = stream.Conn().Close()
-		}
-
 		err := stream.Close()
 		if err != nil {
 			log.Debug().Msgf("Cannot close stream to peer %s, err: %s", peer.String(), err.Error())
+			_ = stream.Reset()
 		}
 	}
 

comm/p2p/manager_test.go

@@ -35,8 +35,6 @@ func (s *StreamManagerTestSuite) Test_ManagingSubscriptions_Success() {
 	streamManager := p2p.NewStreamManager(s.mockHost)
 
 	mockConn := mock_network.NewMockConn(s.mockController)
-	mockConn.EXPECT().Close().Return(nil).Times(2)
-
 	stream1 := mock_network.NewMockStream(s.mockController)
 	stream1.EXPECT().Conn().Return(mockConn).AnyTimes()
 	stream2 := mock_network.NewMockStream(s.mockController)