|
|
@@ -1,12 +1,8 @@
|
|
|
|
from flask import Flask, render_template, request, jsonify
|
|
|
|
from flask import Flask, render_template, request, jsonify
|
|
|
|
import meshtastic
|
|
|
|
import meshtastic
|
|
|
|
from MeshtasticLogger import MeshtasticLogger
|
|
|
|
from MeshtasticLogger import MeshtasticLogger
|
|
|
|
from CommandHandler import CommandHandler
|
|
|
|
|
|
|
|
import os
|
|
|
|
import os
|
|
|
|
|
|
|
|
|
|
|
|
# -------------------------------
|
|
|
|
|
|
|
|
# Initialize data and objects
|
|
|
|
|
|
|
|
# -------------------------------
|
|
|
|
|
|
|
|
messages = []
|
|
|
|
messages = []
|
|
|
|
app = Flask(__name__)
|
|
|
|
app = Flask(__name__)
|
|
|
|
interface = meshtastic.serial_interface.SerialInterface()
|
|
|
|
interface = meshtastic.serial_interface.SerialInterface()
|
|
|
@@ -26,57 +22,54 @@ def web_print(message: str):
|
|
|
|
print(message)
|
|
|
|
print(message)
|
|
|
|
messages.append(message)
|
|
|
|
messages.append(message)
|
|
|
|
get_messages()
|
|
|
|
get_messages()
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def callback(message: str):
|
|
|
|
|
|
|
|
web_print(message)
|
|
|
|
|
|
|
|
|
|
|
|
command_handler: CommandHandler = CommandHandler(web_print)
|
|
|
|
def help_response():
|
|
|
|
logger = MeshtasticLogger(interface, "logs/mesh_logs.log", channel=1, message_received_callback=web_print)
|
|
|
|
help_message: str = "Commands:\nhelp - show this message\clear - clear the text log\nsend <text> - sends text to all channels\nchannel <number> - sets the current channel (0-7)\n"
|
|
|
|
|
|
|
|
web_print(help_message)
|
|
|
|
|
|
|
|
|
|
|
|
# -------------------------
|
|
|
|
logger = MeshtasticLogger(interface, "logs/mesh_logs.log", channel=1, message_received_callback=callback)
|
|
|
|
# Command Callback Handlers
|
|
|
|
|
|
|
|
# -------------------------
|
|
|
|
|
|
|
|
def help_response(args: list[str]):
|
|
|
|
|
|
|
|
return "Commands:\nhelp - show this message\clear - clear the text log\nsend <text> - sends text to all channels\nchannel <number> - sets the current channel (0-7)\n"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def channel_response(args: list[str]):
|
|
|
|
def channel_response(args: list[str]):
|
|
|
|
if len(args) < 1:
|
|
|
|
if(len(args) < 2):
|
|
|
|
return f"Current channel number: {logger.channel}"
|
|
|
|
web_print(f"Current channel number: {logger.channel}")
|
|
|
|
channel: int = int(args[0])
|
|
|
|
return
|
|
|
|
|
|
|
|
channel: int = int(args[1])
|
|
|
|
if channel > 7 or channel < 0:
|
|
|
|
if channel > 7 or channel < 0:
|
|
|
|
return "Channel must be between 0 and 7"
|
|
|
|
web_print("Channel must be between 0 and 7")
|
|
|
|
|
|
|
|
else:
|
|
|
|
|
|
|
|
try:
|
|
|
|
|
|
|
|
logger.channel = channel
|
|
|
|
|
|
|
|
except Exception as e:
|
|
|
|
|
|
|
|
web_print(e)
|
|
|
|
|
|
|
|
else:
|
|
|
|
|
|
|
|
web_print(f"Channel set to {channel}")
|
|
|
|
|
|
|
|
|
|
|
|
try:
|
|
|
|
def send_response(args: list[str], command: str):
|
|
|
|
logger.channel = channel
|
|
|
|
if len(args) < 2:
|
|
|
|
except Exception as e:
|
|
|
|
web_print("Please provide text to send")
|
|
|
|
return e
|
|
|
|
else:
|
|
|
|
|
|
|
|
logger.send(command[5:])
|
|
|
|
|
|
|
|
web_print(f"Sent: {command[5:]}")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def parse_command(command):
|
|
|
|
|
|
|
|
args = command.split(" ")
|
|
|
|
|
|
|
|
if len(args) < 1:
|
|
|
|
|
|
|
|
return True
|
|
|
|
|
|
|
|
|
|
|
|
return f"Channel set to {channel}"
|
|
|
|
if args[0] == "clear":
|
|
|
|
|
|
|
|
messages.clear()
|
|
|
|
|
|
|
|
elif args[0] == "help":
|
|
|
|
|
|
|
|
help_response()
|
|
|
|
|
|
|
|
elif args[0] == "channel":
|
|
|
|
|
|
|
|
channel_response(args)
|
|
|
|
|
|
|
|
elif args[0] == "send":
|
|
|
|
|
|
|
|
send_response(args, command)
|
|
|
|
|
|
|
|
else:
|
|
|
|
|
|
|
|
web_print("Command not recognized. Type \'help\' for a list of commands.")
|
|
|
|
|
|
|
|
|
|
|
|
def send_response(args: list[str]):
|
|
|
|
|
|
|
|
if len(args) == 0:
|
|
|
|
|
|
|
|
return "Please provide text to send"
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
command = ""
|
|
|
|
|
|
|
|
for arg in args:
|
|
|
|
|
|
|
|
command += arg + " "
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
command = command[:-1] # remove the trailing space
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
logger.send(command)
|
|
|
|
|
|
|
|
return_message = f"Sent: {command}"
|
|
|
|
|
|
|
|
return return_message
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def clear_response(args):
|
|
|
|
|
|
|
|
messages.clear()
|
|
|
|
|
|
|
|
return None
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# register callbacks
|
|
|
|
|
|
|
|
command_handler.register_callback("clear", clear_response)
|
|
|
|
|
|
|
|
command_handler.register_callback("help", help_response)
|
|
|
|
|
|
|
|
command_handler.register_callback("channel", channel_response)
|
|
|
|
|
|
|
|
command_handler.register_callback("send", send_response)
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
# -----------------------
|
|
|
|
|
|
|
|
# Flask Callback Handlers
|
|
|
|
|
|
|
|
# -----------------------
|
|
|
|
|
|
|
|
@app.route('/')
|
|
|
|
@app.route('/')
|
|
|
|
def index():
|
|
|
|
def index():
|
|
|
|
return render_template('index.html')
|
|
|
|
return render_template('index.html')
|
|
|
@@ -85,10 +78,12 @@ def index():
|
|
|
|
def send():
|
|
|
|
def send():
|
|
|
|
data = request.json
|
|
|
|
data = request.json
|
|
|
|
message = data.get("message", "")
|
|
|
|
message = data.get("message", "")
|
|
|
|
command_handler.parse_command(message)
|
|
|
|
parse_command(message)
|
|
|
|
return jsonify({"messages": messages})
|
|
|
|
return jsonify({"messages": messages})
|
|
|
|
|
|
|
|
|
|
|
|
@app.route('/messages', methods=['GET'])
|
|
|
|
@app.route('/messages', methods=['GET'])
|
|
|
|
def get_messages():
|
|
|
|
def get_messages():
|
|
|
|
return jsonify({"messages": messages})
|
|
|
|
return jsonify({"messages": messages})
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
|
|
|
|
|
|
app.run(host="0.0.0.0", port=80, debug=True)
|