mirror of https://github.com/Desuuuu/klipper.git
55 lines
2.2 KiB
Python
55 lines
2.2 KiB
Python
# A simple timer for executing gcode templates
|
|
#
|
|
# Copyright (C) 2019 Eric Callahan <arksine.code@gmail.com>
|
|
#
|
|
# This file may be distributed under the terms of the GNU GPLv3 license.
|
|
|
|
import logging
|
|
|
|
class DelayedGcode:
|
|
def __init__(self, config):
|
|
self.printer = config.get_printer()
|
|
self.reactor = self.printer.get_reactor()
|
|
self.name = config.get_name().split()[1]
|
|
self.gcode = self.printer.lookup_object('gcode')
|
|
gcode_macro = self.printer.try_load_module(config, 'gcode_macro')
|
|
self.timer_gcode = gcode_macro.load_template(config, 'gcode')
|
|
self.duration = config.getfloat('initial_duration', 0., minval=0.)
|
|
self.timer_handler = None
|
|
self.inside_timer = self.repeat = False
|
|
self.printer.register_event_handler("klippy:ready", self._handle_ready)
|
|
self.gcode.register_mux_command(
|
|
"UPDATE_DELAYED_GCODE", "ID", self.name,
|
|
self.cmd_UPDATE_DELAYED_GCODE,
|
|
desc=self.cmd_UPDATE_DELAYED_GCODE)
|
|
def _handle_ready(self):
|
|
waketime = self.reactor.NEVER
|
|
if self.duration:
|
|
waketime = self.reactor.monotonic() + self.duration
|
|
self.timer_handler = self.reactor.register_timer(
|
|
self._gcode_timer_event, waketime)
|
|
def _gcode_timer_event(self, eventtime):
|
|
self.inside_timer = True
|
|
try:
|
|
self.gcode.run_script(self.timer_gcode.render())
|
|
except Exception:
|
|
logging.exception("Script running error")
|
|
nextwake = self.reactor.NEVER
|
|
if self.repeat:
|
|
nextwake = eventtime + self.duration
|
|
self.inside_timer = self.repeat = False
|
|
return nextwake
|
|
cmd_UPDATE_DELAYED_GCODE_help = "Update the duration of a delayed_gcode"
|
|
def cmd_UPDATE_DELAYED_GCODE(self, params):
|
|
self.duration = self.gcode.get_float('DURATION', params, minval=0.)
|
|
if self.inside_timer:
|
|
self.repeat = (self.duration != 0.)
|
|
else:
|
|
waketime = self.reactor.NEVER
|
|
if self.duration:
|
|
waketime = self.reactor.monotonic() + self.duration
|
|
self.reactor.update_timer(self.timer_handler, waketime)
|
|
|
|
def load_config_prefix(config):
|
|
return DelayedGcode(config)
|