From 8b45fdce5db087e2502a4344b9ad8b6ac9c3db6e Mon Sep 17 00:00:00 2001 From: Rose Jethani <101273941+rose2221@users.noreply.github.com> Date: Sat, 17 Aug 2024 05:11:48 +0530 Subject: [PATCH] Update NoiseProtocolTests.cs --- .../NoiseProtocolTests.cs | 18 ++---------------- 1 file changed, 2 insertions(+), 16 deletions(-) diff --git a/src/libp2p/Libp2p.Protocols.Noise.Tests/NoiseProtocolTests.cs b/src/libp2p/Libp2p.Protocols.Noise.Tests/NoiseProtocolTests.cs index 4deeaead..3bb31af5 100644 --- a/src/libp2p/Libp2p.Protocols.Noise.Tests/NoiseProtocolTests.cs +++ b/src/libp2p/Libp2p.Protocols.Noise.Tests/NoiseProtocolTests.cs @@ -35,15 +35,12 @@ public async Task Test_ConnectionEstablished_AfterHandshake() [Test] public async Task Test_ConnectionEstablished_With_PreSelectedMuxer() { - IChannel downChannel = new TestChannel(); IChannel downChannelFromProtocolPov = ((TestChannel)downChannel).Reverse(); IChannelFactory channelFactory = Substitute.For(); IPeerContext peerContext = Substitute.For(); IPeerContext listenerContext = Substitute.For(); - IProtocol? proto1 = Substitute.For(); - proto1.Id.Returns("proto1"); channelFactory.SubProtocols.Returns(new[] { proto1 }); IChannel upChannel = new TestChannel(); @@ -54,9 +51,6 @@ public async Task Test_ConnectionEstablished_With_PreSelectedMuxer() var multiplexerSettings = new MultiplexerSettings(); multiplexerSettings.Add(proto1); NoiseProtocol proto = new(multiplexerSettings); - - - peerContext.LocalPeer.Identity.Returns(new Identity()); listenerContext.LocalPeer.Identity.Returns(new Identity()); string peerId = peerContext.LocalPeer.Identity.PeerId.ToString(); // Get the PeerId as a string @@ -65,23 +59,15 @@ public async Task Test_ConnectionEstablished_With_PreSelectedMuxer() string listenerPeerId = listenerContext.LocalPeer.Identity.PeerId.ToString(); Multiaddress listenerAddr = $"/ip4/0.0.0.0/tcp/0/p2p/{listenerPeerId}"; listenerContext.RemotePeer.Address.Returns(listenerAddr); - Task ListenTask = proto.ListenAsync(downChannel, channelFactory, listenerContext); Task DialTask = proto.DialAsync(downChannelFromProtocolPov, channelFactory, peerContext); - await DialTask; await ListenTask; Assert.That(peerContext.SpecificProtocolRequest.SubProtocol, Is.EqualTo(proto1)); - - - await downChannel.CloseAsync(); - await upChannel.CloseAsync(); - - } - - [Test] +} +[Test] public async Task Test_ConnectionClosed_ForBrokenHandshake() { // IChannel downChannel = new TestChannel();