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

add the ability to subscribe to LOGIN_SUCCESS event

Browse Source
This commit is contained in:
Alex Wolden
2025-05-12 22:35:53 -07:00
parent b3cf2ba7b4
commit 8d805de78d
5 changed files with 117 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/meshcore/ble_cx.py
View File

@@ -96,4 +96,4 @@ class BLEConnection:
"""Disconnect from the BLE device."""
if self.client and self.client.is_connected:
await self.client.disconnect()
logger.info("BLE Connection closed")
logger.debug("BLE Connection closed")

29
src/meshcore/reader.py
View File

@@ -251,14 +251,31 @@ class MessageReader:
await self.dispatcher.dispatch(Event(EventType.RAW_DATA, res))
elif packet_type_value == PacketType.LOGIN_SUCCESS.value:
logger.debug("Login success")
# TODO: Read login attributes
await self.dispatcher.dispatch(Event(EventType.LOGIN_SUCCESS, {}))
res = {}
if len(data) > 1:
res["permissions"] = data[1]
res["is_admin"] = (data[1] & 1) == 1 # Check if admin bit is set
if len(data) > 7:
res["pubkey_prefix"] = data[2:8].hex()
attributes = {
"pubkey_prefix": res.get("pubkey_prefix")
}
await self.dispatcher.dispatch(Event(EventType.LOGIN_SUCCESS, res, attributes))
elif packet_type_value == PacketType.LOGIN_FAILED.value:
logger.debug("Login failed")
# TODO: Read login attributes
await self.dispatcher.dispatch(Event(EventType.LOGIN_FAILED, {}))
res = {}
if len(data) > 7:
res["pubkey_prefix"] = data[2:8].hex()
attributes = {
"pubkey_prefix": res.get("pubkey_prefix")
}
await self.dispatcher.dispatch(Event(EventType.LOGIN_FAILED, res, attributes))
elif packet_type_value == PacketType.STATUS_RESPONSE.value:
res = {}

2
src/meshcore/serial_cx.py
View File

@@ -93,4 +93,4 @@ class SerialConnection:
if self.transport:
self.transport.close()
self.transport = None
logger.info("Serial Connection closed")
logger.debug("Serial Connection closed")

2
src/meshcore/tcp_cx.py
View File

@@ -91,4 +91,4 @@ class TCPConnection:
if self.transport:
self.transport.close()
self.transport = None
logger.info("TCP Connection closed")
logger.debug("TCP Connection closed")