Asyncio coroutine to create more than 1 tunnel simultaneously

[morellexf13]

async def tunnel_task(
        service, secrets: Optional[TextIO] = None,
        script_mode: bool = True, max_idle_timeout: float = MAX_IDLE_TIMEOUT,
        protocol: TunnelProtocol = TunnelProtocol.QUIC, tunnels_addresses_file: str = '',
        creating_tunnels_signal_file: str = '',
        close_tunnels_signal_file: str = '') -> None:

        ---------------more code -------------


async def start_tunnel_task(
        connection_type: ConnectionType,
        secrets: TextIO = None, udid: Optional[str] = None, script_mode: bool = False,
        max_idle_timeout: float = MAX_IDLE_TIMEOUT, protocol: TunnelProtocol = TunnelProtocol.QUIC,
        tunnels_addresses_file: str = '',
        creating_tunnels_signal_file: str = '',
        close_tunnels_signal_file: str = '') -> None:

    if start_tunnel is None:
        raise NotImplementedError('failed to start the tunnel on your platform')

    get_tunnel_services = {
        connection_type.USB: get_core_device_tunnel_services,
        connection_type.WIFI: get_remote_pairing_tunnel_services,
    }
    tunnel_services = await get_tunnel_services[connection_type](udid=udid)
    ---------------more code -------------
    

async def tunnel_task_concurrently(udid, tunnels_to_create, tunnels_addresses_file, creating_tunnels_signal_file,
                                   close_tunnels_signal_file):
    tasks = [start_tunnel_task(ConnectionType(ConnectionType.USB.value), udid=udid, tunnels_addresses_file=tunnels_addresses_file,
                               creating_tunnels_signal_file=creating_tunnels_signal_file,
                               close_tunnels_signal_file=close_tunnels_signal_file)
             for _ in range(tunnels_to_create)]
    await asyncio.gather(*tasks)
    if close_tunnels_signal_file and os.path.exists(close_tunnels_signal_file):
        logger.info('Removing close tunnels signal file...')
        os.remove(close_tunnels_signal_file)

I've been working with some code where I'm attempting to create 6 tunnels simultaneously using the latest version of pymobiledevice3. This setup was functional previously, but it seems to have stopped working. I suspect that one of the recent refactors might have caused it to break. I'm encountering an issue when trying to create more than 1 tunnel.

Traceback (most recent call last):
  File "/Users/juan/Documents/GitHub/ios-remote-xpc-tunnel-creator/remote-xpc-tunnel.py", line 84, in <module>
    main()
  File "/Users/juan/Documents/GitHub/ios-remote-xpc-tunnel-creator/remote-xpc-tunnel.py", line 80, in main
    tunnel_creator.create()
  File "/Users/juan/Documents/GitHub/ios-remote-xpc-tunnel-creator/remote-xpc-tunnel.py", line 39, in create
    asyncio.run(tunnel_task_concurrently(udid=self.device_udid, tunnels_to_create=self.tunnels_to_create,
  File "/Library/Frameworks/Python.framework/Versions/3.10/lib/python3.10/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "/Library/Frameworks/Python.framework/Versions/3.10/lib/python3.10/asyncio/base_events.py", line 641, in run_until_complete
    return future.result()
  File "/Users/juan/Documents/GitHub/ios-remote-xpc-tunnel-creator/venv/lib/python3.10/site-packages/pymobiledevice3/cli/remote.py", line 240, in tunnel_task_concurrently
    await asyncio.gather(*tasks)
  File "/Users/juan/Documents/GitHub/ios-remote-xpc-tunnel-creator/venv/lib/python3.10/site-packages/pymobiledevice3/cli/remote.py", line 215, in start_tunnel_task
    raise NoDeviceConnectedError()
pymobiledevice3.exceptions.NoDeviceConnectedError

Any ideas on how to address this? Maybe something about routines and asyncio? I don't know

[doronz88]

This is a LOT if code. Please provide a clear and concise description of your issue instead of just printing your code as big BLOB.

[morellexf13]

I've modified the code, is shorter now

[doronz88]

Sounds like no devices were discovered over bonjour. Maybe its timeout issues.
Anyhow, I don't see why not using tunneld instead