-
-
Notifications
You must be signed in to change notification settings - Fork 5.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
0114d72
commit 16f2597
Showing
15 changed files
with
553 additions
and
6 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,52 @@ | ||
from . import fan | ||
|
||
PIN_MIN_TIME = 0.100 | ||
|
||
class ChamberFan: | ||
def __init__(self, config): | ||
self.printer = config.get_printer() | ||
self.printer.register_event_handler("klippy:ready", self.handle_ready) | ||
self.printer.register_event_handler("klippy:connect", | ||
self.handle_connect) | ||
self.printer.load_object(config, 'heaters') | ||
self.heaters = [] | ||
self.fan = fan.Fan(config) | ||
self.fan_speed = config.getfloat('fan_speed', default=1., | ||
minval=0., maxval=1.) | ||
self.idle_speed = config.getfloat( | ||
'idle_speed', default=self.fan_speed, minval=0., maxval=1.) | ||
self.idle_timeout = config.getint("idle_timeout", default=30, minval=0) | ||
self.heater_names = config.getlist("heater", ()) | ||
self.last_on = self.idle_timeout | ||
self.last_speed = 0. | ||
def handle_connect(self): | ||
# Heater lookup | ||
pheaters = self.printer.lookup_object('heaters') | ||
self.heaters = [pheaters.lookup_heater(n) for n in self.heater_names] | ||
def handle_ready(self): | ||
reactor = self.printer.get_reactor() | ||
reactor.register_timer(self.callback, reactor.monotonic()+PIN_MIN_TIME) | ||
def get_status(self, eventtime): | ||
return self.fan.get_status(eventtime) | ||
def callback(self, eventtime): | ||
speed = 0. | ||
active = False | ||
for heater in self.heaters: | ||
_, target_temp = heater.get_temp(eventtime) | ||
if target_temp: | ||
active = True | ||
if active: | ||
self.last_on = 0 | ||
speed = self.fan_speed | ||
elif self.last_on < self.idle_timeout: | ||
speed = self.idle_speed | ||
self.last_on += 1 | ||
if speed != self.last_speed: | ||
self.last_speed = speed | ||
curtime = self.printer.get_reactor().monotonic() | ||
print_time = self.fan.get_mcu().estimated_print_time(curtime) | ||
self.fan.set_speed(print_time + PIN_MIN_TIME, speed) | ||
return eventtime + 1. | ||
|
||
def load_config_prefix(config): | ||
return ChamberFan(config) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,15 @@ | ||
class GCodeMacroBreaker: | ||
def __init__(self, config): | ||
# Gcode macro interupt | ||
self.printer = config.get_printer() | ||
webhooks = self.printer.lookup_object('webhooks') | ||
webhooks.register_endpoint("breakmacro", self._handle_breakmacro) | ||
webhooks.register_endpoint("resumemacro", self._handle_resumemacro) | ||
self.gcode = self.printer.lookup_object('gcode') | ||
def _handle_breakmacro(self, web_request): | ||
self.gcode.break_flag = True | ||
def _handle_resumemacro(self, web_request): | ||
self.gcode.break_flag = False | ||
|
||
def load_config(config): | ||
return GCodeMacroBreaker(config) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,87 @@ | ||
# Run a shell command via gcode | ||
# | ||
# Copyright (C) 2019 Eric Callahan <arksine.code@gmail.com> | ||
# | ||
# This file may be distributed under the terms of the GNU GPLv3 license. | ||
import os | ||
import shlex | ||
import subprocess | ||
import logging | ||
|
||
class ShellCommand: | ||
def __init__(self, config): | ||
self.name = config.get_name().split()[-1] | ||
self.printer = config.get_printer() | ||
self.gcode = self.printer.lookup_object('gcode') | ||
cmd = config.get('command') | ||
cmd = os.path.expanduser(cmd) | ||
self.command = shlex.split(cmd) | ||
self.timeout = config.getfloat('timeout', 2., above=0.) | ||
self.verbose = config.getboolean('verbose', True) | ||
self.proc_fd = None | ||
self.partial_output = "" | ||
self.gcode.register_mux_command( | ||
"RUN_SHELL_COMMAND", "CMD", self.name, | ||
self.cmd_RUN_SHELL_COMMAND, | ||
desc=self.cmd_RUN_SHELL_COMMAND_help) | ||
|
||
def _process_output(self, eventime): | ||
if self.proc_fd is None: | ||
return | ||
try: | ||
data = os.read(self.proc_fd, 4096) | ||
except Exception: | ||
pass | ||
data = self.partial_output + data.decode() | ||
if '\n' not in data: | ||
self.partial_output = data | ||
return | ||
elif data[-1] != '\n': | ||
split = data.rfind('\n') + 1 | ||
self.partial_output = data[split:] | ||
data = data[:split] | ||
else: | ||
self.partial_output = "" | ||
self.gcode.respond_info(data) | ||
|
||
cmd_RUN_SHELL_COMMAND_help = "Run a linux shell command" | ||
def cmd_RUN_SHELL_COMMAND(self, params): | ||
gcode_params = params.get('PARAMS','') | ||
gcode_params = shlex.split(gcode_params) | ||
reactor = self.printer.get_reactor() | ||
try: | ||
proc = subprocess.Popen( | ||
self.command + gcode_params, stdout=subprocess.PIPE, stderr=subprocess.STDOUT) | ||
except Exception: | ||
logging.exception( | ||
"shell_command: Command {%s} failed" % (self.name)) | ||
raise self.gcode.error("Error running command {%s}" % (self.name)) | ||
if self.verbose: | ||
self.proc_fd = proc.stdout.fileno() | ||
self.gcode.respond_info("Running Command {%s}...:" % (self.name)) | ||
hdl = reactor.register_fd(self.proc_fd, self._process_output) | ||
eventtime = reactor.monotonic() | ||
endtime = eventtime + self.timeout | ||
complete = False | ||
while eventtime < endtime: | ||
eventtime = reactor.pause(eventtime + .05) | ||
if proc.poll() is not None: | ||
complete = True | ||
break | ||
if not complete: | ||
proc.terminate() | ||
if self.verbose: | ||
if self.partial_output: | ||
self.gcode.respond_info(self.partial_output) | ||
self.partial_output = "" | ||
if complete: | ||
msg = "Command {%s} finished\n" % (self.name) | ||
else: | ||
msg = "Command {%s} timed out" % (self.name) | ||
self.gcode.respond_info(msg) | ||
reactor.unregister_fd(hdl) | ||
self.proc_fd = None | ||
|
||
|
||
def load_config_prefix(config): | ||
return ShellCommand(config) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.