meshcore-dev/meshcore_py
1
0
Fork 0
mirror of https://github.com/meshcore-dev/meshcore_py.git synced 2026-04-20 22:13:49 +00:00
Code Issues Projects Releases Packages Wiki Activity

disconnect as soon as we have no response to appstart

Browse source
This commit is contained in:
Florent 2026-02-16 14:09:14 -04:00
parent 38f3656c24
commit 6254440a2f
1 changed files with 20 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

24
src/meshcore/meshcore.py
View file

@ -93,7 +93,11 @@ class MeshCore:
auto_reconnect=auto_reconnect, auto_reconnect=auto_reconnect,
max_reconnect_attempts=max_reconnect_attempts, max_reconnect_attempts=max_reconnect_attempts,
) )
await mc.connect() res = await mc.connect()
if res is None:
logger.error("No response from meshcore node, disconnecting")
await mc.disconnect()
return None
return mc return mc
@classmethod @classmethod
@ -119,7 +123,12 @@ class MeshCore:
auto_reconnect=auto_reconnect, auto_reconnect=auto_reconnect,
max_reconnect_attempts=max_reconnect_attempts, max_reconnect_attempts=max_reconnect_attempts,
) )
await mc.connect() res = await mc.connect()
if res is None:
logger.error("No response from meshcore node, disconnecting")
logger.error("Are you sure your node is a serial companion ?")
await mc.disconnect()
return None
return mc return mc
@classmethod @classmethod
@ -158,7 +167,11 @@ class MeshCore:
max_reconnect_attempts=max_reconnect_attempts, max_reconnect_attempts=max_reconnect_attempts,
) )
await mc.connect() res = await mc.connect()
if res is None:
logger.error("No response from meshcore node, disconnecting")
await mc.disconnect()
return None
return mc return mc
async def connect(self): async def connect(self):
@ -167,7 +180,10 @@ class MeshCore:
if result is None: if result is None:
await self.dispatcher.stop() await self.dispatcher.stop()
raise ConnectionError("Failed to connect to device") raise ConnectionError("Failed to connect to device")
return await self.commands.send_appstart() res = await self.commands.send_appstart()
if res is None or res.type == EventType.ERROR:
return None
return res
async def disconnect(self): async def disconnect(self):
"""Disconnect from the device and clean up resources.""" """Disconnect from the device and clean up resources."""