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

fix timeout in send_msg

Browse source
This commit is contained in:
Florent 2025-10-03 18:53:30 +02:00
parent bf2f95a63a
commit 62d4f67f63
1 changed files with 3 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/meshcore_cli/meshcore_cli.py
View file

@ -863,10 +863,12 @@ async def send_msg (mc, contact, msg) :
return res return res
async def msg_ack (mc, contact, msg) : async def msg_ack (mc, contact, msg) :
timeout = 0 if not 'timeout' in contact else contact['timeout']
res = await mc.commands.send_msg_with_retry(contact, msg, res = await mc.commands.send_msg_with_retry(contact, msg,
max_attempts=msg_ack.max_attempts, max_attempts=msg_ack.max_attempts,
flood_after=msg_ack.flood_after, flood_after=msg_ack.flood_after,
max_flood_attempts=msg_ack.max_flood_attempts) max_flood_attempts=msg_ack.max_flood_attempts,
timeout=timeout)
if not res is None and not res.type == EventType.ERROR: if not res is None and not res.type == EventType.ERROR:
res.payload["expected_ack"] = res.payload["expected_ack"].hex() res.payload["expected_ack"] = res.payload["expected_ack"].hex()
sent = res.payload.copy() sent = res.payload.copy()