Mirrors/meshcore_py
1
0
Fork 0
mirror of https://github.com/meshcore-dev/meshcore_py.git synced 2026-07-26 18:08:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #86 from JohannesFriedrich/main

Browse Source 
Sending and receiving raw_data not working as expected
This commit is contained in:
fdlamotte
2026-06-14 10:45:59 -04:00
committed by GitHub
parent 4d0be8788a 44b21be20e
commit febd03e00b
2 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/meshcore/commands/messaging.py
View File

@@ -307,21 +307,28 @@ class MessagingCommands(CommandHandlerBase):
return await self.send(cmd_data, [EventType.MSG_SENT, EventType.ERROR])
async def send_raw_data(self, payload: bytes) -> Event:
async def send_raw_data(self, payload: bytes, path: bytes = b"") -> Event:
"""N09: Send raw data via CMD_SEND_RAW_DATA (25).
Sends an arbitrary payload through the mesh network.
Sends an arbitrary raw-data payload directly (no flood support yet).
Command format:
0x19 | path_len(1) | path(path_len bytes) | payload(>=4 bytes)
Args:
payload: Raw bytes to send.
payload: Raw bytes to send (minimum 4 bytes).
path: Optional path bytes for intermediate hops (default: empty = zero-hop direct).
Returns:
Event with MSG_SENT or ERROR.
Event with OK or ERROR.
"""
if not isinstance(payload, (bytes, bytearray)):
raise TypeError("payload must be bytes-like")
data = b"\x19" + bytes(payload)
return await self.send(data, [EventType.MSG_SENT, EventType.ERROR])
if len(payload) < 4:
raise ValueError("payload must be at least 4 bytes")
path = bytes(path)
data = bytes([0x19, len(path)]) + path + bytes(payload)
return await self.send(data, [EventType.OK, EventType.ERROR])
async def set_flood_scope(self, scope):
if scope is None:

3
src/meshcore/reader.py
View File

@@ -546,7 +546,8 @@ class MessageReader:
res = {}
res["SNR"] = int.from_bytes(dbuf.read(1), byteorder="little", signed=True) / 4
res["RSSI"] = int.from_bytes(dbuf.read(1), byteorder="little", signed=True)
res["payload"] = dbuf.read(4).hex()
dbuf.read(1) # skip reserved byte (0xFF, possibly path_len in future)
res["payload"] = dbuf.read().hex() # read all remaining payload bytes
logger.debug("Received raw data")
logger.debug(res)
await self.dispatcher.dispatch(Event(EventType.RAW_DATA, res))