mirror of https://github.com/Desuuuu/klipper.git
webhooks: Remove register_static_path()
Use the "info" webhook to pass critical process information back to the caller. The remaining users of register_static_path() can get the required information via get_status() calls. Signed-off-by: Kevin O'Connor <kevin@koconnor.net>
This commit is contained in:
parent
0aad2437c5
commit
b74a5c5217
|
@ -35,9 +35,6 @@ class VirtualSD:
|
||||||
self.gcode.register_command(
|
self.gcode.register_command(
|
||||||
"SDCARD_PRINT_FILE", self.cmd_SDCARD_PRINT_FILE,
|
"SDCARD_PRINT_FILE", self.cmd_SDCARD_PRINT_FILE,
|
||||||
desc=self.cmd_SDCARD_PRINT_FILE_help)
|
desc=self.cmd_SDCARD_PRINT_FILE_help)
|
||||||
# Register sd path
|
|
||||||
webhooks = printer.lookup_object('webhooks')
|
|
||||||
webhooks.register_static_path("sd_path", self.sdcard_dirname)
|
|
||||||
def handle_shutdown(self):
|
def handle_shutdown(self):
|
||||||
if self.work_timer is not None:
|
if self.work_timer is not None:
|
||||||
self.must_pause_work = True
|
self.must_pause_work = True
|
||||||
|
|
|
@ -255,19 +255,8 @@ class WebHooks:
|
||||||
def __init__(self, printer):
|
def __init__(self, printer):
|
||||||
self.printer = printer
|
self.printer = printer
|
||||||
self._endpoints = {"list_endpoints": self._handle_list_endpoints}
|
self._endpoints = {"list_endpoints": self._handle_list_endpoints}
|
||||||
self._static_paths = []
|
|
||||||
self.register_endpoint("info", self._handle_info_request)
|
self.register_endpoint("info", self._handle_info_request)
|
||||||
self.register_endpoint("emergency_stop", self._handle_estop_request)
|
self.register_endpoint("emergency_stop", self._handle_estop_request)
|
||||||
start_args = printer.get_start_args()
|
|
||||||
log_file = start_args.get('log_file')
|
|
||||||
cfg_file = start_args.get('config_file')
|
|
||||||
klipper_path = os.path.normpath(os.path.join(
|
|
||||||
os.path.dirname(__file__), ".."))
|
|
||||||
if log_file is not None:
|
|
||||||
self.register_static_path("klippy.log", log_file)
|
|
||||||
self.register_static_path("printer.cfg", cfg_file)
|
|
||||||
self.register_static_path("klippy_env", sys.executable)
|
|
||||||
self.register_static_path("klipper_path", klipper_path)
|
|
||||||
self.sconn = ServerSocket(self, printer)
|
self.sconn = ServerSocket(self, printer)
|
||||||
StatusHandler(self)
|
StatusHandler(self)
|
||||||
|
|
||||||
|
@ -293,30 +282,22 @@ class WebHooks:
|
||||||
raise WebRequestError("Path already registered to an endpoint")
|
raise WebRequestError("Path already registered to an endpoint")
|
||||||
self._endpoints[path] = callback
|
self._endpoints[path] = callback
|
||||||
|
|
||||||
def register_static_path(self, resource_id, file_path):
|
|
||||||
static_path_info = {
|
|
||||||
'resource_id': resource_id, 'file_path': file_path}
|
|
||||||
self._static_paths.append(static_path_info)
|
|
||||||
|
|
||||||
def _handle_list_endpoints(self, web_request):
|
def _handle_list_endpoints(self, web_request):
|
||||||
web_request.send({
|
web_request.send({'endpoints': self._endpoints.keys()})
|
||||||
'hooks': self._endpoints.keys(),
|
|
||||||
'static_paths': self._static_paths})
|
|
||||||
|
|
||||||
def _handle_info_request(self, web_request):
|
def _handle_info_request(self, web_request):
|
||||||
if web_request.get_method() != 'GET':
|
if web_request.get_method() != 'GET':
|
||||||
raise web_request.error("Invalid Request Method")
|
raise web_request.error("Invalid Request Method")
|
||||||
|
state_message, state = self.printer.get_state_message()
|
||||||
|
klipper_path = os.path.normpath(os.path.join(
|
||||||
|
os.path.dirname(__file__), ".."))
|
||||||
|
response = {'state': state, 'state_message': state_message,
|
||||||
|
'hostname': socket.gethostname(),
|
||||||
|
'klipper_path': klipper_path, 'python_path': sys.executable}
|
||||||
start_args = self.printer.get_start_args()
|
start_args = self.printer.get_start_args()
|
||||||
state_message, msg_type = self.printer.get_state_message()
|
for sa in ['log_file', 'config_file', 'software_version', 'cpu_info']:
|
||||||
version = start_args['software_version']
|
response[sa] = start_args.get(sa)
|
||||||
cpu_info = start_args['cpu_info']
|
web_request.send(response)
|
||||||
error = msg_type == "error"
|
|
||||||
web_request.send(
|
|
||||||
{'cpu': cpu_info, 'version': version,
|
|
||||||
'hostname': socket.gethostname(),
|
|
||||||
'is_ready': msg_type == "ready",
|
|
||||||
'error_detected': error,
|
|
||||||
'message': state_message})
|
|
||||||
|
|
||||||
def _handle_estop_request(self, web_request):
|
def _handle_estop_request(self, web_request):
|
||||||
if web_request.get_method() != 'POST':
|
if web_request.get_method() != 'POST':
|
||||||
|
|
Loading…
Reference in New Issue