iarv/meshtastic-bridge
1
0
Fork 1
mirror of https://github.com/geoffwhittington/meshtastic-bridge.git synced 2026-05-18 07:15:41 +02:00
Code Issues Packages Projects Releases Wiki Activity

add logging

Browse Source
This commit is contained in:
Geoff Whittington
2022-08-18 23:10:40 -04:00
parent 2a84414ddc
commit 3276b8f828
1 changed files with 32 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
main.py
+32 -5
View File
@@ -1,3 +1,4 @@
import logging
import meshtastic
import meshtastic.serial_interface
import meshtastic.tcp_interface
@@ -11,19 +12,39 @@ from pubsub import pub
local_interface = None
remote_interface = None
bridge_logger = logging.getLogger(name="meshtastic.bridge")
BRIDGE_LOG = os.environ['BRIDGE_LOG'] if 'BRIDGE_LOG' in os.environ else 'INFO'
NODE_LOG = os.environ['NODE_LOG'] if 'NODE_LOG' in os.environ else 'INFO'
if BRIDGE_LOG == 'DEBUG':
bridge_logger.setLevel(logging.DEBUG)
elif BRIDGE_LOG == 'INFO':
bridge_logger.setLevel(logging.INFO)
if NODE_LOG == 'DEBUG':
logging.basicConfig(level=logging.DEBUG)
elif NODE_LOG == 'INFO':
logging.basicConfig(level=logging.INFO)
local_node_addr = os.environ['LOCAL_NODE_ADDR'] if 'LOCAL_NODE_ADDR' in os.environ else None
remote_node_addr = os.environ['REMOTE_NODE_ADDR']
if local_node_addr and '/' in local_node_addr:
bridge_logger.debug(f"Connecting to local node via serial port: {local_node_addr} ...")
local_interface = meshtastic.serial_interface.SerialInterface(devPath=local_node_addr)
elif local_node_addr and '.' in local_node_addr:
elif local_node_addr:
bridge_logger.debug(f"Connecting to local node via TCP: {local_node_addr} ...")
local_interface = meshtastic.tcp_interface.TCPInterface(hostname=local_node_addr)
else:
bridge_logger.debug(f"Connecting to local node via serial port ...")
local_interface = meshtastic.serial_interface.SerialInterface()
remote_interface = meshtastic.tcp_interface.TCPInterface(hostname=remote_node_addr)
bridge_logger.info(f"Connected to local node")
bridge_logger.debug(f"Connecting to remote node via TCP: {remote_node_addr} ...")
remote_interface = meshtastic.tcp_interface.TCPInterface(hostname=remote_node_addr)
bridge_logger.info(f"Connected to remote node")
ourNode = local_interface.getNode('^local')
SUPPORTED_MESSAGES = [
@@ -37,8 +58,10 @@ NODE_PROXY = {BROADCAST_ADDR: BROADCAST_ADDR}
def onReceive(packet, interface): # called when a packet arrives
bridge_logger.debug(f"Packet received: {packet}")
if packet['decoded']['portnum'] not in SUPPORTED_MESSAGES:
print(f"Dropping {packet['decoded']['portnum']}")
bridge_logger.debug(f"Dropping {packet['decoded']['portnum']}")
return
message_source_position = None
@@ -53,8 +76,12 @@ def onReceive(packet, interface): # called when a packet arrives
current_local_position = (nodeInfo['position']['latitude'], nodeInfo['position']['longitude'])
if message_source_position and current_local_position:
distance_km = haversine(message_source_position, current_local_position)
# message originates from too far a distance
if SUPPORTED_BRIDGE_DISTANCE_KM > 0 and haversine(message_source_position, current_local_position) > SUPPORTED_BRIDGE_DISTANCE_KM:
if SUPPORTED_BRIDGE_DISTANCE_KM > 0 and distance_km > SUPPORTED_BRIDGE_DISTANCE_KM:
bridge_logger.debug(f"Packet from too far: {distance_km} > {SUPPORTED_BRIDGE_DISTANCE_KM}")
return
if 'to' in packet:
@@ -74,7 +101,7 @@ def onReceive(packet, interface): # called when a packet arrives
meshPacket.id = remote_interface._generatePacketId()
if destinationId == BROADCAST_ADDR or destinationId in remote_interface.nodes:
print(f"Sending {meshPacket} to TCP server")
bridge_logger.debug(f"Sending packet {meshPacket.id} to TCP server")
remote_interface._sendPacket(meshPacket=meshPacket, destinationId=destinationId)
def onConnection(interface, topic=pub.AUTO_TOPIC): # called when we (re)connect to the radio