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

support path_hash_len in send_channel_data

Browse Source
This commit is contained in:
Florent
2026-10-14 10:08:11 -04:00
parent 1e6fdd47a3
commit c379142c6b
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/meshcore/commands/messaging.py
+6 -2
View File
@@ -370,7 +370,8 @@ class MessagingCommands(CommandHandlerBase):
return await self.send(data, [EventType.OK, EventType.ERROR]) return await self.send(data, [EventType.OK, EventType.ERROR])
async def send_channel_data( async def send_channel_data(
self, chan: int, data_type: int, payload: bytes, path: Optional[bytes] = None self, chan: int, data_type: int, payload: bytes,
path: Optional[bytes] = None, path_hash_mode: Optional[int] = 0
) -> Event: ) -> Event:
"""Send a binary datagram to a channel via CMD_SEND_CHANNEL_DATA (0x3E). """Send a binary datagram to a channel via CMD_SEND_CHANNEL_DATA (0x3E).
@@ -382,6 +383,7 @@ class MessagingCommands(CommandHandlerBase):
data_type: Application identifier, 0x0001-0xFFFF (0xFFFF is the developer namespace). data_type: Application identifier, 0x0001-0xFFFF (0xFFFF is the developer namespace).
payload: Binary payload, at most 163 bytes (MAX_CHANNEL_DATA_LENGTH). payload: Binary payload, at most 163 bytes (MAX_CHANNEL_DATA_LENGTH).
path: Optional path bytes to send along (default None = flood, path_len 0xFF). path: Optional path bytes to send along (default None = flood, path_len 0xFF).
path_hash_mode: Optional path_hash_mode (size of the hash - 1)
Returns: Returns:
Event with OK or ERROR. Event with OK or ERROR.
@@ -400,7 +402,9 @@ class MessagingCommands(CommandHandlerBase):
path = bytes(path) path = bytes(path)
if len(path) >= 0xFF: if len(path) >= 0xFF:
raise ValueError("path must be shorter than 255 bytes") raise ValueError("path must be shorter than 255 bytes")
path_bytes = bytes([len(path)]) + path path_len = int(len(path) / (path_hash_mode + 1))
path_bytes = bytes([path_len | (path_hash_mode << 6)]) + path
logger.debug(f"Sending raw data {payload.hex()} through path {"Flood" if path is None else path.hex()} of len {"-1" if path is None else path_len} with mode {path_hash_mode} (raw path: {path_bytes.hex()})")
data = bytes([CommandType.SEND_CHANNEL_DATA.value, chan]) + path_bytes + data_type.to_bytes(2, "little") + bytes(payload) data = bytes([CommandType.SEND_CHANNEL_DATA.value, chan]) + path_bytes + data_type.to_bytes(2, "little") + bytes(payload)
return await self.send(data, [EventType.OK, EventType.ERROR]) return await self.send(data, [EventType.OK, EventType.ERROR])