diff --git a/tests/examples/test_chat.py b/tests/examples/test_chat.py index 18a172c8..e2aa71de 100644 --- a/tests/examples/test_chat.py +++ b/tests/examples/test_chat.py @@ -2,8 +2,8 @@ import asyncio import pytest +from libp2p.network.exceptions import SwarmException from libp2p.peer.peerinfo import info_from_p2p_addr -from libp2p.protocol_muxer.exceptions import MultiselectClientError from tests.utils import set_up_nodes_by_transport_opt PROTOCOL_ID = "/chat/1.0.0" @@ -84,7 +84,7 @@ async def no_common_protocol(host_a, host_b): host_a.set_stream_handler(PROTOCOL_ID, stream_handler) # try to creates a new new with a procotol not known by the other host - with pytest.raises(MultiselectClientError): + with pytest.raises(SwarmException): await host_b.new_stream(host_a.get_id(), ["/fakeproto/0.0.1"]) diff --git a/tests/protocol_muxer/test_protocol_muxer.py b/tests/protocol_muxer/test_protocol_muxer.py index d7523ac2..4e58e5b6 100644 --- a/tests/protocol_muxer/test_protocol_muxer.py +++ b/tests/protocol_muxer/test_protocol_muxer.py @@ -1,6 +1,6 @@ import pytest -from libp2p.protocol_muxer.exceptions import MultiselectClientError +from libp2p.network.exceptions import SwarmException from tests.utils import echo_stream_handler, set_up_nodes_by_transport_opt # TODO: Add tests for multiple streams being opened on different @@ -47,7 +47,7 @@ async def test_single_protocol_succeeds(): @pytest.mark.asyncio async def test_single_protocol_fails(): - with pytest.raises(MultiselectClientError): + with pytest.raises(SwarmException): await perform_simple_test("", ["/echo/1.0.0"], ["/potato/1.0.0"]) # Cleanup not reached on error @@ -77,7 +77,7 @@ async def test_multiple_protocol_second_is_valid_succeeds(): async def test_multiple_protocol_fails(): protocols_for_client = ["/rock/1.0.0", "/foo/1.0.0", "/bar/1.0.0"] protocols_for_listener = ["/aspyn/1.0.0", "/rob/1.0.0", "/zx/1.0.0", "/alex/1.0.0"] - with pytest.raises(MultiselectClientError): + with pytest.raises(SwarmException): await perform_simple_test("", protocols_for_client, protocols_for_listener) # Cleanup not reached on error