commit e6974dd5bbb804a6b98d172c2eb55206f6a47a56 Author: Illia Volochii illia.volochii@gmail.com Date: Sat Mar 14 22:05:15 2020 +0200
Revert "Add temporary scripts for testing async communication with sockets"
This reverts commit 072b5e682faa6d190fa8cd4cc52651fdc10b3e01. --- test_control_port.py | 30 ------------------------------ test_control_socket_file.py | 30 ------------------------------ test_relay_socket.py | 28 ---------------------------- 3 files changed, 88 deletions(-)
diff --git a/test_control_port.py b/test_control_port.py deleted file mode 100644 index 85fe26d4..00000000 --- a/test_control_port.py +++ /dev/null @@ -1,30 +0,0 @@ -import asyncio - -from stem.async_socket import ControlPort - - -async def run_command(i, command): - async with ControlPort() as cp: - print(f'{i} Connecting') - await cp.connect() - print(f'{i} Authenticating') - await cp.send('AUTHENTICATE "password"') - print(f'{i} Receiving auth message') - await cp.recv() - print(f'{i} Sending the command') - await cp.send(command) - print(f'{i} Receiving result of the command') - result = await cp.recv() - print(f'{i} {result.content()}') - - -if __name__ == '__main__': - loop = asyncio.get_event_loop() - tasks = asyncio.gather( - run_command(1, 'PROTOCOLINFO 1'), - run_command(2, 'GETINFO traffic/read'), - ) - try: - loop.run_until_complete(tasks) - finally: - loop.close() diff --git a/test_control_socket_file.py b/test_control_socket_file.py deleted file mode 100644 index 4c6816f4..00000000 --- a/test_control_socket_file.py +++ /dev/null @@ -1,30 +0,0 @@ -import asyncio - -from stem.async_socket import ControlSocketFile - - -async def run_command(i, command): - async with ControlSocketFile() as cp: - print(f'{i} Connecting') - await cp.connect() - print(f'{i} Authenticating') - await cp.send('AUTHENTICATE "password"') - print(f'{i} Receiving auth message') - await cp.recv() - print(f'{i} Sending the command') - await cp.send(command) - print(f'{i} Receiving result of the command') - result = await cp.recv() - print(f'{i} {result.content()}') - - -if __name__ == '__main__': - loop = asyncio.get_event_loop() - tasks = asyncio.gather( - run_command(1, 'PROTOCOLINFO 1'), - run_command(2, 'GETINFO traffic/read'), - ) - try: - loop.run_until_complete(tasks) - finally: - loop.close() diff --git a/test_relay_socket.py b/test_relay_socket.py deleted file mode 100644 index 76289d46..00000000 --- a/test_relay_socket.py +++ /dev/null @@ -1,28 +0,0 @@ -import asyncio - -from stem.client import DEFAULT_LINK_PROTOCOLS -from stem.client.cell import VersionsCell -from stem.async_socket import RelaySocket - - -async def run_command(i, command): - async with RelaySocket(address='127.0.0.1', port=443) as cp: - print(f'{i} Connecting') - await cp.connect() - print(f'{i} Sending the command') - await cp.send(command) - print(f'{i} Receiving result of the command') - result = await cp.recv(2) - print(result) - - -if __name__ == '__main__': - loop = asyncio.get_event_loop() - tasks = asyncio.gather( - run_command(1, VersionsCell(DEFAULT_LINK_PROTOCOLS).pack(2)), - run_command(2, VersionsCell(DEFAULT_LINK_PROTOCOLS).pack(2)), - ) - try: - loop.run_until_complete(tasks) - finally: - loop.close()