Mirrors/meshcore_py
1
0
Fork 0
mirror of https://github.com/meshcore-dev/meshcore_py.git synced 2026-06-14 21:26:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

restored commands expecting the whole pubkey

Browse Source
This commit is contained in:
Florent
2025-04-14 17:24:00 +02:00
parent 3e336652ee
commit 74cd8ad1b8
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/meshcore/commands.py
View File

@@ -183,20 +183,20 @@ class CommandHandler:
return await self.send(b"\x04", [EventType.CONTACTS, EventType.ERROR]) return await self.send(b"\x04", [EventType.CONTACTS, EventType.ERROR])
async def reset_path(self, key: DestinationType) -> Dict[str, Any]: async def reset_path(self, key: DestinationType) -> Dict[str, Any]:
key_bytes = _validate_destination(key) key_bytes = _validate_destination(key, prefix_length=32)
logger.debug(f"Resetting path for contact: {key_bytes.hex()}") logger.debug(f"Resetting path for contact: {key_bytes.hex()}")
data = b"\x0D" + key_bytes data = b"\x0D" + key_bytes
return await self.send(data, [EventType.OK, EventType.ERROR]) return await self.send(data, [EventType.OK, EventType.ERROR])
async def share_contact(self, key: DestinationType) -> Dict[str, Any]: async def share_contact(self, key: DestinationType) -> Dict[str, Any]:
key_bytes = _validate_destination(key) key_bytes = _validate_destination(key, prefix_length=32)
logger.debug(f"Sharing contact: {key_bytes.hex()}") logger.debug(f"Sharing contact: {key_bytes.hex()}")
data = b"\x10" + key_bytes data = b"\x10" + key_bytes
return await self.send(data, [EventType.CONTACT_SHARE, EventType.ERROR]) return await self.send(data, [EventType.CONTACT_SHARE, EventType.ERROR])
async def export_contact(self, key: Optional[DestinationType] = None) -> Dict[str, Any]: async def export_contact(self, key: Optional[DestinationType] = None) -> Dict[str, Any]:
if key: if key:
key_bytes = _validate_destination(key) key_bytes = _validate_destination(key, prefix_length=32)
logger.debug(f"Exporting contact: {key_bytes.hex()}") logger.debug(f"Exporting contact: {key_bytes.hex()}")
data = b"\x11" + key_bytes data = b"\x11" + key_bytes
else: else:
@@ -205,7 +205,7 @@ class CommandHandler:
return await self.send(data, [EventType.OK, EventType.ERROR]) return await self.send(data, [EventType.OK, EventType.ERROR])
async def remove_contact(self, key: DestinationType) -> Dict[str, Any]: async def remove_contact(self, key: DestinationType) -> Dict[str, Any]:
key_bytes = _validate_destination(key) key_bytes = _validate_destination(key, prefix_length=32)
logger.debug(f"Removing contact: {key_bytes.hex()}") logger.debug(f"Removing contact: {key_bytes.hex()}")
data = b"\x0f" + key_bytes data = b"\x0f" + key_bytes
return await self.send(data, [EventType.OK, EventType.ERROR]) return await self.send(data, [EventType.OK, EventType.ERROR])
@@ -215,7 +215,7 @@ class CommandHandler:
return await self.send(b"\x0A", [EventType.CONTACT_MSG_RECV, EventType.CHANNEL_MSG_RECV, EventType.ERROR], timeout) return await self.send(b"\x0A", [EventType.CONTACT_MSG_RECV, EventType.CHANNEL_MSG_RECV, EventType.ERROR], timeout)
async def send_login(self, dst: DestinationType, pwd: str) -> Dict[str, Any]: async def send_login(self, dst: DestinationType, pwd: str) -> Dict[str, Any]:
dst_bytes = _validate_destination(dst) dst_bytes = _validate_destination(dst, prefix_length=32)
logger.debug(f"Sending login request to: {dst_bytes.hex()}") logger.debug(f"Sending login request to: {dst_bytes.hex()}")
data = b"\x1a" + dst_bytes + pwd.encode("ascii") data = b"\x1a" + dst_bytes + pwd.encode("ascii")
return await self.send(data, [EventType.MSG_SENT, EventType.ERROR]) return await self.send(data, [EventType.MSG_SENT, EventType.ERROR])
@@ -227,7 +227,7 @@ class CommandHandler:
return await self.send(data, [EventType.MSG_SENT, EventType.ERROR]) return await self.send(data, [EventType.MSG_SENT, EventType.ERROR])
async def send_statusreq(self, dst: DestinationType) -> Dict[str, Any]: async def send_statusreq(self, dst: DestinationType) -> Dict[str, Any]:
dst_bytes = _validate_destination(dst) dst_bytes = _validate_destination(dst, prefix_length=32)
logger.debug(f"Sending status request to: {dst_bytes.hex()}") logger.debug(f"Sending status request to: {dst_bytes.hex()}")
data = b"\x1b" + dst_bytes data = b"\x1b" + dst_bytes
return await self.send(data, [EventType.MSG_SENT, EventType.ERROR]) return await self.send(data, [EventType.MSG_SENT, EventType.ERROR])
@@ -318,4 +318,4 @@ class CommandHandler:
logger.error(f"Unsupported path type: {type(path)}") logger.error(f"Unsupported path type: {type(path)}")
return { "success": False, "reason": "unsupported_path_type" } return { "success": False, "reason": "unsupported_path_type" }
return await self.send(cmd_data, [EventType.MSG_SENT, EventType.ERROR]) return await self.send(cmd_data, [EventType.MSG_SENT, EventType.ERROR])