Merge pull request #1224 from doronz88/refactor/make-coredeviceproxy-…

…pure-asyncio

tunnel_service: reactor `CoreDeviceTunnelProxy` into pure asyncio

pymobiledevice3/remote/tunnel_service.py

@@ -47,7 +47,6 @@
 
 from pymobiledevice3.lockdown_service_provider import LockdownServiceProvider
 from pymobiledevice3.osu.os_utils import get_os_utils
-from pymobiledevice3.services.lockdown_service import LockdownService
 
 try:
     from sslpsk_pmd3.sslpsk import SSLPSKContext
@@ -907,28 +906,19 @@ async def connect(self, autopair: bool = True) -> None:
         await RemotePairingProtocol.connect(self, autopair=autopair)
 
 
-class CoreDeviceTunnelProxy(StartTcpTunnel, LockdownService):
+class CoreDeviceTunnelProxy(StartTcpTunnel):
     SERVICE_NAME = 'com.apple.internal.devicecompute.CoreDeviceProxy'
 
     def __init__(self, lockdown: LockdownServiceProvider) -> None:
-        LockdownService.__init__(self, lockdown, self.SERVICE_NAME)
         self._lockdown = lockdown
         self._service: Optional[ServiceConnection] = None
 
-        try:
-            loop = asyncio.get_running_loop()
-        except RuntimeError:
-            loop = asyncio.new_event_loop()
-            asyncio.set_event_loop(loop)
-        self._loop = loop
-
     @property
     def remote_identifier(self) -> str:
         return self._lockdown.udid
 
     @asynccontextmanager
     async def start_tcp_tunnel(self) -> AsyncGenerator['TunnelResult', None]:
-        self.service.close()
         self._service = await self._lockdown.aio_start_lockdown_service(self.SERVICE_NAME)
         tunnel = RemotePairingTcpTunnel(self._service.reader, self._service.writer)
         handshake_response = await tunnel.request_tunnel_establish()