adam/meshing-around
1
0
Fork 0
mirror of https://github.com/SpudGunMan/meshing-around.git synced 2026-08-11 03:12:44 +02:00
Code Issues Packages Projects Releases Wiki Activity

loop detector

Browse Source
This commit is contained in:
SpudGunMan
2024-12-13 20:04:20 -08:00
parent d0dc737863
commit 1ac9f3b0d6
2 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mesh_bot.py
+5 -1
View File
@@ -985,6 +985,10 @@ def onReceive(packet, interface):
elif interface2_enabled and interface2_type == 'ble':
rxNode = 2
# check if the packet is from us
if packet['from'] == myNodeNum1 or packet['from'] == myNodeNum2:
logger.warning(f"System: Packet from self {packet['from']} loop or traffic replay deteted")
# check if the packet has a channel flag use it
if packet.get('channel'):
channel_number = packet.get('channel', 0)
@@ -1185,7 +1189,7 @@ def onReceive(packet, interface):
send_message(rMsg, channel_number, 0, 1)
else:
# Evaluate non TEXT_MESSAGE_APP packets
consumeMetadata(packet, rxNode)
consumeMetadata(packet, rxNode)
except KeyError as e:
logger.critical(f"System: Error processing packet: {e} Device:{rxNode}")
logger.debug(f"System: Error Packet = {packet}")
pong_bot.py
+5 -1
View File
@@ -206,6 +206,10 @@ def onReceive(packet, interface):
rxNode = 1
elif interface2_enabled and interface2_type == 'ble':
rxNode = 2
# check if the packet is from us
if packet['from'] == myNodeNum1 or packet['from'] == myNodeNum2:
logger.warning(f"System: Packet from self {packet['from']} loop or traffic replay deteted")
# check if the packet has a channel flag use it
if packet.get('channel'):
@@ -340,7 +344,7 @@ def onReceive(packet, interface):
send_message(rMsg, channel_number, 0, 1)
else:
# Evaluate non TEXT_MESSAGE_APP packets
consumeMetadata(packet, rxNode)
consumeMetadata(packet, rxNode)
except KeyError as e:
logger.critical(f"System: Error processing packet: {e} Device:{rxNode}")
logger.debug(f"System: Error Packet = {packet}")