StarMirror/py-libp2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Call make_echo_proc with is_host_insecure

Browse Source 
Use the fixture, this way we can configure `is_host_insecure` to support
the test against secio.
This commit is contained in:
mhchia 2019-08-29 22:08:27 +08:00
parent b2c5371323
commit 9ceb5f55bb
No known key found for this signature in database
GPG Key ID: 389EFBEA1362589A
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tests/interop/test_echo.py
View File

@ -57,8 +57,12 @@ async def make_echo_proc(
@pytest.mark.parametrize("num_hosts", (1,)) @pytest.mark.parametrize("num_hosts", (1,))
@pytest.mark.asyncio @pytest.mark.asyncio
async def test_insecure_conn_py_to_go(hosts, proc_factory, unused_tcp_port): async def test_insecure_conn_py_to_go(
go_proc, go_pinfo = await make_echo_proc(proc_factory, unused_tcp_port, False) hosts, proc_factory, is_host_secure, unused_tcp_port
):
go_proc, go_pinfo = await make_echo_proc(
proc_factory, unused_tcp_port, is_host_secure
)
host = hosts[0] host = hosts[0]
await host.connect(go_pinfo) await host.connect(go_pinfo)
@ -76,7 +80,9 @@ async def test_insecure_conn_py_to_go(hosts, proc_factory, unused_tcp_port):
@pytest.mark.parametrize("num_hosts", (1,)) @pytest.mark.parametrize("num_hosts", (1,))
@pytest.mark.asyncio @pytest.mark.asyncio
async def test_insecure_conn_go_to_py(hosts, proc_factory, unused_tcp_port): async def test_insecure_conn_go_to_py(
hosts, proc_factory, is_host_secure, unused_tcp_port
):
host = hosts[0] host = hosts[0]
expected_data = "Hello, world!\n" expected_data = "Hello, world!\n"
reply_data = "Replyooo!\n" reply_data = "Replyooo!\n"
@ -91,7 +97,9 @@ async def test_insecure_conn_go_to_py(hosts, proc_factory, unused_tcp_port):
host.set_stream_handler(ECHO_PROTOCOL_ID, _handle_echo) host.set_stream_handler(ECHO_PROTOCOL_ID, _handle_echo)
py_maddr = host.get_addrs()[0] py_maddr = host.get_addrs()[0]
go_proc, _ = await make_echo_proc(proc_factory, unused_tcp_port, False, py_maddr) go_proc, _ = await make_echo_proc(
proc_factory, unused_tcp_port, is_host_secure, py_maddr
)
await go_proc.expect("connect with peer", async_=True) await go_proc.expect("connect with peer", async_=True)
await go_proc.expect("opened stream", async_=True) await go_proc.expect("opened stream", async_=True)
await event_handler_finished.wait() await event_handler_finished.wait()