diff options
| -rw-r--r-- | klippy/extras/delayed_gcode.py | 54 |
1 files changed, 54 insertions, 0 deletions
diff --git a/klippy/extras/delayed_gcode.py b/klippy/extras/delayed_gcode.py new file mode 100644 index 00000000..71c093c5 --- /dev/null +++ b/klippy/extras/delayed_gcode.py @@ -0,0 +1,54 @@ +# 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) |