adam/meshtastic-mqtt-client
1
0
Fork 0
mirror of https://github.com/arankwende/meshtastic-mqtt-client.git synced 2026-08-10 02:22:48 +02:00
Code Issues Packages Projects Releases Wiki Activity

Update meshtastic-mqtt-client.py

Browse Source 
Added node_info functionality, properties and node list window
This commit is contained in:
Carlos Alfredo Diaz
2022-07-27 20:00:37 -03:00
parent e478fbd61d
commit c98d4fa4f3
1 changed files with 184 additions and 81 deletions
Download Patch File Download Diff File Expand all files Collapse all files
meshtastic-mqtt-client.py
+184 -81
View File
@@ -24,7 +24,7 @@ from portnums_pb2 import ENVIRONMENTAL_MEASUREMENT_APP, POSITION_APP
import mesh_pb2 as mesh_pb2
import mqtt_pb2 as mqtt_pb2
import environmental_measurement_pb2 as environmental_measurement_pb2
from google.protobuf.json_format import MessageToJson
#from google.protobuf.json_format import MessageToJson
# First we define the GUI
@@ -52,6 +52,40 @@ def generate_gps_window(menu_def):
[sg.Output(size=(80,25),key='-POSITIONS-')],
[sg.Button('Export Positions',key='-EXPORT-')]]
return sg.Window('GPS Client Positions', layout, finalize=True, grab_anywhere=True)
def generate_properties_window(menu_def):
sg.theme('Reddit')
sg.set_options(element_padding=(1, 1))
layout = [
[sg.Menu(menu_def, tearoff=False, pad=(200, 1))],
[sg.Text('Configuration Properties',font = ("Arial", 16))],
[sg.Text("MQTT", font = ("Arial", 16))],
[sg.Text("Gateway IP: " + mqtt_ip, font = ("Arial", 12))],
[sg.Text("MQTT User: " + mqtt_user, font = ("Arial", 12))],
[sg.Text("MQTT Password: " + mqtt_pass, font = ("Arial", 12))],
[sg.Text("Your Meshtastic Network",font = ("Arial", 16))],
[sg.Text("Meshtastic Channel Name: " + mesh_channel_id, font = ("Arial", 12))],
[sg.Text("Meshtastic Gateway ID: " + mesh_gateway_id, font = ("Arial", 12))],
[sg.Text("Your Device Network IDs", font = ("Arial", 16))],
[sg.Text("Your client ID: " + mesh_client_id, font = ("Arial", 12))],
[sg.Text("Your full ID: " + mesh_client_full_id, font = ("Arial", 12))],
[sg.Text("Your MAC Address: " + mesh_client_macaddr, font = ("Arial", 12))],
[sg.Text("Your Device Names", font = ("Arial", 16))],
[sg.Text("Device Long Name: " + mesh_client_long_name, font = ("Arial", 12))],
[sg.Text("Short Name: " + mesh_client_short_name, font = ("Arial", 12))]]
return sg.Window('Properties Window', layout, finalize=True, keep_on_top=True, grab_anywhere=True)
def generate_nodes_window(menu_def,node_list):
try:
sg.theme('Reddit')
sg.set_options(element_padding=(1, 1))
headings_list = ["Node Wireless ID", "Node Full ID", "Node Long Name", "Node Short Name", "MacAddress"]
layout = [
[sg.Menu(menu_def, tearoff=False, pad=(200, 1))],
[sg.Text('This is a list of detected nodes and their info.', font = ("Arial", 16))],
[sg.Table(values=node_list , headings = headings_list, max_col_width=35, auto_size_columns=True)]]
return sg.Window('List of Known Nodes', layout, finalize=True, keep_on_top=True, grab_anywhere=True)
except Exception as exception:
logging.critical(f"There was a problem generating the nodes window. The exception is {exception}")
def load_config():
try:
config_dir = os.path.dirname(os.path.realpath(__file__))
@@ -95,7 +129,6 @@ def decode_message(msg):
full_message = msg.payload
#I add service envelope decoding from protobuf
se = mqtt_pb2.ServiceEnvelope()
se.ParseFromString(full_message)
#print(dir(se.ParseFromString(full_message)))
decoded_message = se.packet
@@ -112,7 +145,12 @@ def decode_message(msg):
if mesh_node_id == mesh_client_id:
pass
else:
print(mesh_node_id + ": " + text_message)
node_id=check_id(mesh_node_id)
node_full_id, node_long_name, node_short_name = get_name(node_id)
if node_long_name[0] is not None:
print(node_long_name[0] + ": " + text_message)
else:
print(mesh_node_id + ": " + text_message)
main_window.Refresh()
save_text_message(text_message, mesh_node_id)
elif decoded_message.decoded.portnum == portnums_pb2.POSITION_APP:
@@ -127,101 +165,139 @@ def decode_message(msg):
lon = decoded_packet.longitude_i * 1e-7
altitude= decoded_packet.altitude
node_time = decoded_packet.time
print(decoded_packet)
save_position(lat, lon, altitude, node_time, battery_level, mesh_node_id)
elif decoded_message.decoded.portnum == portnums_pb2.NODEINFO_APP:
#Work in progress
decoded_packet=mesh_pb2.Nodeinfo()
decoded_packet=mesh_pb2.User()
decoded_packet.ParseFromString(decoded_message.decoded.payload)
mesh_node_full_id = mesh_pb2.User()
mesh_node_id = str(getattr(decoded_message, "from"))
node_full_id = str(getattr(decoded_message, "id"))
node_long_name = str(getattr(decoded_message,"long_name"))
node_short_name = str(getattr(decoded_message,"short_name"))
node_macaddr = str(getattr(decoded_message,"macaddr"))
save_node_info(mesh_node_id,node_full_id,node_long_name,node_short_name,node_macaddr)
if mesh_node_id == mesh_client_id:
pass
else:
node_id=check_id(mesh_node_id)
node_full_id = str(getattr(decoded_packet, "id"))
node_long_name = str(getattr(decoded_packet,"long_name"))
node_short_name = str(getattr(decoded_packet,"short_name"))
node_macaddr = getattr(decoded_packet,"macaddr") #The macaddress is a Hex in bytes, so I have use the .hex() method and then make it a string to save it
node_macaddr = str(node_macaddr.hex())
node_macaddr = node_macaddr.upper() #I make it all uppercase so it looks nicer in the DB
print("Node information received for node:" + node_long_name)
main_window.Refresh()
save_node_info(mesh_node_id,node_full_id,node_long_name,node_short_name,node_macaddr)
else:
mesh_node_full_id = mesh_pb2.User()
mesh_node_id = str(getattr(decoded_message, "from"))
save_full_message(full_message,mesh_node_id)
except Exception as exception:
logging.critical(f'There was an error decoding your received message. You get the following error: {exception} ')
def encode_message(message,mesh_channel_id,mesh_gateway_id,mesh_client_id):
def encode_message(encoded_message,mesh_channel_id,mesh_gateway_id,mesh_client_id):
try:
packet = mesh_pb2.MeshPacket()
setattr(packet,"from",int(mesh_client_id))
#setattr(packet,"to",random.getrandbits(32))
setattr(packet, "to",4294967295)
setattr(packet,"id",random.getrandbits(32))
setattr(packet,"rx_time",1658889528)
setattr(packet,"hop_limit",3)
packet.decoded.CopyFrom(encoded_message)
mesh_se = mqtt_pb2.ServiceEnvelope()
mesh_se.channel_id = mesh_channel_id
mesh_se.gateway_id = mesh_client_id
mesh_se.packet.CopyFrom(packet)
mesh_se=mesh_se.SerializeToString()
return mesh_se
except Exception as exception:
logging.critical(f'There was an error encoding you message. You get the following error: {exception} ')
def encode_text_message(message):
try:
decoded_message = bytes(message,"utf-8")
encoded_message = mesh_pb2.Data()
encoded_message.portnum = portnums_pb2.TEXT_MESSAGE_APP
encoded_message.payload = decoded_message
packet = mesh_pb2.MeshPacket()
setattr(packet,"from",int(mesh_client_id))
#setattr(packet,"to",random.getrandbits(32))
setattr(packet, "to",4294967295)
setattr(packet,"id",random.getrandbits(32))
setattr(packet,"rx_time",1658889528)
setattr(packet,"hop_limit",3)
packet.decoded.CopyFrom(encoded_message)
mesh_se = mqtt_pb2.ServiceEnvelope()
mesh_se.channel_id = mesh_channel_id
mesh_se.gateway_id = mesh_client_id
mesh_se.packet.CopyFrom(packet)
mesh_se=mesh_se.SerializeToString()
return mesh_se
return encoded_message
except Exception as exception:
logging.critical(f'There was an error encoding you message. You get the following error: {exception} ')
def encode_node_info(user_short_name,user_long_name, user_id, user_macaddr):
logging.critical(f'There was an error encoding the text portion of you message. You get the following error: {exception} ')
def encode_info_message(user_short_name,user_long_name, user_id, user_macaddr):
try:
decoded_user_id = bytes(user_id,"utf-8")
decoded_user_long = bytes(user_short_name,"utf-8")
decoded_user_long = bytes(user_long_name,"utf-8")
decoded_user_short = bytes(user_short_name,"utf-8")
decoded_user_macaddr = bytes(user_macaddr,"utf-8")
decoded_user_hw_model = 255
user_macaddr = user_macaddr.lower()
decoded_user_macaddr = bytes.fromhex(user_macaddr)
user_payload = mesh_pb2.User()
setattr(packet, "id",decoded_user_id)
setattr(packet,"long_name",decoded_user_long )
setattr(packet,"short_name",decoded_user_short)
setattr(packet,"macaddr",decoded_user_macaddr)
setattr(user_payload, "id",decoded_user_id)
setattr(user_payload,"long_name",decoded_user_long )
setattr(user_payload,"short_name",decoded_user_short)
setattr(user_payload,"macaddr",decoded_user_macaddr)
setattr(user_payload,"hw_model",decoded_user_hw_model)
user_payload = user_payload.SerializeToString()
encoded_message = mesh_pb2.Data()
encoded_message.portnum = portnums_pb2.NODE_INFOAPP
encoded_message.portnum = portnums_pb2.NODEINFO_APP
encoded_message.payload = user_payload
packet = mesh_pb2.MeshPacket()
setattr(packet,"from",int(mesh_client_id))
#setattr(packet,"to",random.getrandbits(32))
setattr(packet, "to",4294967295)
setattr(packet,"id",random.getrandbits(32))
setattr(packet,"rx_time",1658889528)
setattr(packet,"hop_limit",3)
packet.decoded.CopyFrom(encoded_message)
mesh_se = mqtt_pb2.ServiceEnvelope()
mesh_se.channel_id = mesh_channel_id
mesh_se.gateway_id = mesh_client_id
mesh_se.packet.CopyFrom(packet)
mesh_se=mesh_se.SerializeToString()
return mesh_se
return encoded_message
except Exception as exception:
logging.critical(f'There was an error encoding you message. You get the following error: {exception} ')
logging.critical(f'There was an error encoding the nodeinfo portion of your message. You get the following error: {exception} ')
def check_id(mesh_node_id):
try:
con = sl.connect('config/meshtastic-mqtt-client.db')
cur = con.cursor()
cur.execute(f'''SELECT COUNT(node_id) FROM NODE WHERE nodemeshid = '{str(mesh_node_id)}';''')
cur.execute(f'''SELECT COUNT(node_id) FROM NODE WHERE node_mesh_id = '{str(mesh_node_id)}';''')
sql_id_results = int(cur.fetchone()[0] or 0)
if (sql_id_results == 0):
logging.info("The mesh id that the message contained was not registered on the database. We will create a new record.")
sqlite_query = f'''INSERT INTO NODE (nodemeshid) VALUES ('{str(mesh_node_id)}');'''
logging.info("The node mesh id was not registered on the database. We will create a new record.")
sqlite_query = f'''INSERT INTO NODE (node_mesh_id) VALUES ('{str(mesh_node_id)}');'''
cur.execute(str(sqlite_query))
con.commit()
logging.info(f"{str(mesh_node_id)} has been inserted in the NODE table.")
cur.execute(f'''SELECT node_id FROM NODE WHERE nodemeshid = '{str(mesh_node_id)}';''')
cur.execute(f'''SELECT node_id FROM NODE WHERE node_mesh_id = '{str(mesh_node_id)}';''')
node_id = str(cur.fetchone()[0])
else:
cur.execute(f'''SELECT node_id FROM NODE WHERE nodemeshid = '{mesh_node_id}';''')
cur.execute(f'''SELECT node_id FROM NODE WHERE node_mesh_id = '{mesh_node_id}';''')
node_id = int(cur.fetchone()[0])
return node_id
except Exception as exception:
logging.critical(f' There was a problem getting your node id. The exception is: {exception} ')
def get_name(node_id):
con = sl.connect('config/meshtastic-mqtt-client.db')
cur = con.cursor()
cur.execute(f'''SELECT node_full_id FROM NODE WHERE node_id = '{node_id}';''')
node_full_id = cur.fetchone()
cur.execute(f'''SELECT long_name FROM NODE WHERE node_id = '{node_id}';''')
node_long_name = cur.fetchone()
cur.execute(f'''SELECT short_name FROM NODE WHERE node_id = '{node_id}';''')
node_short_name = cur.fetchone()
return node_full_id, node_long_name, node_short_name
def get_node_list():
con = sl.connect('config/meshtastic-mqtt-client.db')
cur = con.cursor()
cur.execute(f'''SELECT node_mesh_id, node_full_id, long_name, short_name, macaddr FROM NODE;''')
node_list= cur.fetchall()
return node_list
def get_positions():
con = sl.connect('config/meshtastic-mqtt-client.db')
cur = con.cursor()
cur.execute(f'''SELECT lat, long, altitude, battery FROM POSITION;''')
position_list= cur.fetchall()
return position_list
def get_last_position(node_id):
con = sl.connect('config/meshtastic-mqtt-client.db')
cur = con.cursor()
cur.execute(f'''SELECT lat, long, altitude, battery FROM POSITION WHERE node_id = {node_id} order by Timestamp desc;''')
position_list= cur.fetchone()
return position_list
def get_text_messages():
con = sl.connect('config/meshtastic-mqtt-client.db')
cur = con.cursor()
cur.execute(f'''SELECT * FROM TEXTMESSAGE;''')
text_message_list= cur.fetchall()
return text_message_list
def get_full_messages():
con = sl.connect('config/meshtastic-mqtt-client.db')
cur = con.cursor()
cur.execute(f'''SELECT * FROM MESSAGE;''')
full_message_list= cur.fetchall()
return full_message_list
def save_full_message(full_message,mesh_node_id):
try:
node_id = check_id(mesh_node_id)
@@ -256,10 +332,11 @@ def save_node_info(mesh_node_id,node_full_id,node_long_name,node_short_name,node
node_id = check_id(mesh_node_id)
con = sl.connect('config/meshtastic-mqtt-client.db')
cur = con.cursor()
cur.execute(f''' INSERT INTO TEXTMESSAGE (node_id,textmessage) VALUES ('{node_id}','{text_message}');''')
cur.execute(f''' UPDATE NODE SET node_full_id = '{node_full_id}', long_name = '{node_long_name}', short_name = '{node_short_name}', macaddr = '{node_macaddr}' WHERE node_id = {node_id} ;''')
con.commit()
except Exception as exception:
logging.critical(f'There was an error saving your text message. The exception is: {exception} ')
logging.critical(f'There was an error saving node info. The exception is: {exception} ')
def on_publish(client, userdata, mid):
logging.debug("the published message status:" + str(int(userdata or 0)) + " (0 means published)")
@@ -273,8 +350,7 @@ def mqtt_publish_dict(mqtt_dict, client, mqtt_ip):
logging.debug("On the server with IP: " + mqtt_ip)
def mqtt_publish_message(message,mqtt_topic,client,mqtt_ip,mesh_client_id):
try:
mesh_se = encode_message(message,mesh_channel_id,mesh_gateway_id,mesh_client_id)
client.publish(str(mqtt_topic), mesh_se, qos=1, retain=True).wait_for_publish
client.publish(str(mqtt_topic), message, qos=1, retain=False).wait_for_publish
logging.debug("You have sent the following payload: " + str(message))
logging.debug("To the following topic: " + str(mqtt_topic))
logging.debug("On the server with IP: " + mqtt_ip)
@@ -300,6 +376,14 @@ def get_meshtastic_config(config):
logging.debug(f"This is your client id: {str(mesh_client_id)}")
mesh_gateway_id = str(meshtastic_dict['GATEWAY_ID'])
logging.debug(f"This is your gateway id: {str(mesh_gateway_id)}")
mesh_client_full_id = str(meshtastic_dict['CLIENT_FULL_ID'])
logging.debug(f"This is your node full id: {str(mesh_client_full_id)}")
mesh_client_long_name= str(meshtastic_dict['LONG_NAME'])
logging.debug(f"This is your node Long Name: {str(mesh_client_long_name)}")
mesh_client_short_name= str(meshtastic_dict['SHORT_NAME'])
logging.debug(f"This is your node short name: {str(mesh_client_short_name)}")
mesh_client_macaddr= str(meshtastic_dict['MACADDR'])
logging.debug(f"This is your node macaddr: {str(mesh_client_macaddr)}")
common_ports_dict = meshtastic_dict['COMMON_PORTS']
extra_ports_dict = {}
try:
@@ -317,10 +401,10 @@ def get_meshtastic_config(config):
logging.debug("You have no extra ports configured.")
except Exception as exception:
logging.critical(f'Your YAML is missing something in the ports section. You get the following error: {exception} ')
return mesh_channel_id, mesh_client_id, mesh_gateway_id, common_ports_dict, extra_ports_dict
return mesh_channel_id, mesh_client_id, mesh_gateway_id,mesh_client_full_id ,mesh_client_long_name, mesh_client_short_name,mesh_client_macaddr, common_ports_dict, extra_ports_dict
except Exception as exception:
logging.critical(f'Your YAML is missing something in the Meshtastic section. You get the following error: {exception}')
def gateway_subscribe(client, mqtt_ip, common_ports_list, extra_ports_dict, mesh_channel_id, mesh_gateway_id):
def gateway_subscribe(client, mqtt_ip, common_ports_dict, extra_ports_dict, mesh_channel_id, mesh_gateway_id):
try:
#for port in common_ports_list:
mesh_mqtt_topic = "msh/1/c/" + str(mesh_channel_id) + "/#" #+ "/" + str(mesh_gateway_id) + "/" + port[0]
@@ -336,7 +420,7 @@ def client_db():
if cur.fetchone()[0]==1 :
print('NODE table exists.')
else:
cur.execute("""CREATE TABLE NODE(node_id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, nodemeshid VARCHAR(255),Timestamp DATETIME DEFAULT CURRENT_TIMESTAMP);""")
cur.execute("""CREATE TABLE NODE(node_id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, node_mesh_id INTEGER, node_full_id VARCHAR(255), long_name VARCHAR(255), short_name VARCHAR(255), macaddr VARCHAR (255), Timestamp DATETIME DEFAULT CURRENT_TIMESTAMP);""")
print("NODE table created.")
cur.execute(''' SELECT count(name) FROM sqlite_master WHERE type='table' and name ='MESSAGE' ''')
if cur.fetchone()[0]==1 :
@@ -360,15 +444,9 @@ def client_db():
if cur.fetchone()[0]==1 :
print('GATEWAY table exists.')
else:
cur.execute("""CREATE TABLE GATEWAY(gateway_id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, node_id INTEGER, nodemeshid VARCHAR(255),Timestamp DATETIME DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (node_id) REFERENCES NODE(node_id));""")
cur.execute("""CREATE TABLE GATEWAY(gateway_id INTEGER PRIMARY KEY AUTOINCREMENT NOT NULL, node_id INTEGER, node_mesh_id VARCHAR(255),Timestamp DATETIME DEFAULT CURRENT_TIMESTAMP, FOREIGN KEY (node_id) REFERENCES NODE(node_id));""")
print("GATEWAY table created.")
cur.execute(f''' SELECT count(node_id) FROM NODE WHERE nodemeshid ='{mesh_client_id}' ''')
if cur.fetchone()[0]==1:
logging.info("Your node is already registered in the Database.")
else:
cur.execute(""" INSERT into NODE (nodemeshid) VALUES ('!7efeee00');""")
con.commit()
logging.info(f"Registering node {mesh_client_id} on your local database.")
save_node_info(mesh_client_id,mesh_client_full_id,mesh_client_long_name,mesh_client_short_name,mesh_client_macaddr)
except Exception as exception:
logging.critical(f"There was a problem starting you database. The exception is {exception}")
#def sql_db(): for future cases with external connection
@@ -387,8 +465,8 @@ def main(): # Here i have the main program
except Exception as exception:
logging.critical(f"Please check your YAML, it might be missing some parts in the MQTT configuration. The exception is {exception}")
try:
global mesh_channel_id, mesh_client_id, mesh_gateway_id, common_ports_list, extra_ports_dict
mesh_channel_id, mesh_client_id, mesh_gateway_id, common_ports_list, extra_ports_dict = get_meshtastic_config(config)
global mesh_channel_id, mesh_client_id, mesh_gateway_id,mesh_client_full_id ,mesh_client_long_name, mesh_client_short_name,mesh_client_macaddr, common_ports_dict, extra_ports_dict
mesh_channel_id, mesh_client_id, mesh_gateway_id,mesh_client_full_id ,mesh_client_long_name, mesh_client_short_name,mesh_client_macaddr, common_ports_dict, extra_ports_dict = get_meshtastic_config(config)
except Exception as exception:
logging.critical(f'Your YAML is missing something in the Meshtastic section. You get the following error: {exception} ')
# I define the ports list with all the meshtastic ports
@@ -399,7 +477,7 @@ def main(): # Here i have the main program
logging.critical(f"There was an error connecting to the Database. The exception is {exception}")
global main_window
# I define my window menu and my first window
menu_def = ['File', ['Properties','Change Language - not yet implemented', 'Exit']],['Gateway', ['Gateway Information',' - not yet implemented']],['Messages',['See Crypto Key - Not yet implemented', 'List Known Nodes - not yet implemented', 'Export Message History - not yet implemented']],['GPS',['Open GPS Tab', 'Export GPS Locations']], ['&Help',['&Help', 'About...']]
menu_def = ['File', ['Properties','Change Language - not yet implemented', 'Send node info', 'Exit']],['Nodes', ['Gateway Information','List Nodes']],['Messages',['See Crypto Key - Not yet implemented', 'Export Message History - not yet implemented']],['GPS',['Open GPS Tab - soon', 'Export GPS Locations']], ['&Help',['&Help', 'About...']]
main_window = generate_main_window(menu_def)
main_window.move(main_window.current_location()[0]-350, main_window.current_location()[1]+0)
#output_window = main_window
@@ -422,9 +500,17 @@ def main(): # Here i have the main program
try:
time.sleep(1)
#I wait 1 second and subscribe to the mqtt_broker's gateway topic from my Meshtastic Gateway
gateway_subscribe(client, mqtt_ip, common_ports_list, extra_ports_dict, mesh_channel_id, mesh_gateway_id)
gateway_subscribe(client, mqtt_ip, common_ports_dict, extra_ports_dict, mesh_channel_id, mesh_gateway_id)
except Exception as exception:
logging.critical(f"There seems to be a problem subscribing to the topics. The exception is {exception}")
try:
print("Sending Node info to all other clients.")
encoded_message = encode_info_message(mesh_client_short_name,mesh_client_long_name, mesh_client_full_id, mesh_client_macaddr)
mesh_se = encode_message(encoded_message,mesh_channel_id,mesh_gateway_id,mesh_client_id)
mqtt_topic = "msh/1/c/" + mesh_channel_id +"/" + mesh_gateway_id
mqtt_publish_message(mesh_se,mqtt_topic,client,mqtt_ip,mesh_client_id)
except Exception as exception:
logging.critical(f"There seems to be a problem sending your Node Information. The exception is {exception}")
while(True):
window, event, values = sg.read_all_windows()
if sg.WIN_CLOSED:
@@ -461,19 +547,36 @@ def main(): # Here i have the main program
print("Connecting")
client.connect(mqtt_ip, 1883, 60)
client.loop_start()
gateway_subscribe(client, mqtt_ip, common_ports_list, extra_ports_dict, mesh_channel_id, mesh_gateway_id)
gateway_subscribe(client, mqtt_ip, common_ports_dict, extra_ports_dict, mesh_channel_id, mesh_gateway_id)
print("Succesfully connected to the MQTT Broker.")
except Exception as exception:
logging.critical(f"There seems to be a problem connecting to the mqtt server. The exception is {exception}")
elif event == '-SEND-': #if user clicks send message take input and send to radio
try:
message=str(values['-MSGINPUT-'])
mqtt_topic = "msh/1/c/" + mesh_channel_id +"/" + mesh_gateway_id
print(mesh_client_id + "(You): " + message)
mqtt_publish_message(message,mqtt_topic,client,mqtt_ip,mesh_client_id)
mqtt_topic = "msh/1/c/" + mesh_channel_id +"/" + mesh_gateway_id
print(mesh_client_long_name + "(You): " + message)
encoded_message = encode_text_message(message)
mesh_se = encode_message(encoded_message,mesh_channel_id,mesh_gateway_id,mesh_client_id)
mqtt_publish_message(mesh_se,mqtt_topic,client,mqtt_ip,mesh_client_id)
except Exception as exception:
sg.popup(f'There was an error sending your message. The exception is the following: {exception}')
elif event == 'Send node info':
try:
print("Sending Node info to all other clients.")
encoded_message = encode_info_message(mesh_client_short_name,mesh_client_long_name, mesh_client_full_id, mesh_client_macaddr)
mesh_se = encode_message(encoded_message,mesh_channel_id,mesh_gateway_id,mesh_client_id)
mqtt_topic = "msh/1/c/" + mesh_channel_id +"/" + mesh_gateway_id
mqtt_publish_message(mesh_se,mqtt_topic,client,mqtt_ip,mesh_client_id)
except Exception as exception:
logging.critical(f"There seems to be a problem sending your Node Information. The exception is {exception}")
elif event == 'Properties':
#If the properties option is clicked, I generate the properties window
generate_properties_window(menu_def)
elif event == 'List Nodes':
nodes_list = get_node_list()
generate_nodes_window(menu_def, nodes_list)
#We define some arguments to be parsed as well as help messages and description for the script.
parser = argparse.ArgumentParser(description='This is a simple python GUI that connects to an MQTT server to send and receive messages sent by a Meshtastic MQTT Gateway.')
parser.add_argument('-i', action='store_true', help='Run once to only create the entities in your MQTT broker (and see them in home assistant), in a silent initialization.')