diff options
author | Kevin O'Connor <kevin@koconnor.net> | 2020-08-11 16:26:07 -0400 |
---|---|---|
committer | Kevin O'Connor <kevin@koconnor.net> | 2020-08-16 13:20:25 -0400 |
commit | 0aad2437c516c6c7e506179760c8b5e6556be8b1 (patch) | |
tree | fdc9c71230c94407426acda875fdeb75389dac93 /klippy/webhooks.py | |
parent | ebc79a1ee867afa0bba703802ed9f9f57e5ab3b7 (diff) | |
download | kutter-0aad2437c516c6c7e506179760c8b5e6556be8b1.tar.gz kutter-0aad2437c516c6c7e506179760c8b5e6556be8b1.tar.xz kutter-0aad2437c516c6c7e506179760c8b5e6556be8b1.zip |
webhooks: Specify server_address on klippy command-line
Don't default to "/tmp/klippy_uds" for the webhooks unix domain socket
filename. Instead, require the filename to be specified on the
command-line (via a new "-a" parameter).
Signed-off-by: Kevin O'Connor <kevin@koconnor.net>
Diffstat (limited to 'klippy/webhooks.py')
-rw-r--r-- | klippy/webhooks.py | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/klippy/webhooks.py b/klippy/webhooks.py index fa7f073a..de480d27 100644 --- a/klippy/webhooks.py +++ b/klippy/webhooks.py @@ -11,8 +11,6 @@ import errno import json import homing -SERVER_ADDRESS = "/tmp/klippy_uds" - # Json decodes strings as unicode types in Python 2.x. This doesn't # play well with some parts of Klipper (particuarly displays), so we # need to create an object hook. This solution borrowed from: @@ -98,15 +96,16 @@ class ServerSocket: self.reactor = printer.get_reactor() self.sock = self.fd_handle = None self.clients = {} - is_fileinput = (printer.get_start_args().get('debuginput') - is not None) - if is_fileinput: - # Do not enable server in batch mode + start_args = printer.get_start_args() + server_address = start_args.get('apiserver') + is_fileinput = (start_args.get('debuginput') is not None) + if not server_address or is_fileinput: + # Do not enable server return - self._remove_socket_file(SERVER_ADDRESS) + self._remove_socket_file(server_address) self.sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM) self.sock.setblocking(0) - self.sock.bind(SERVER_ADDRESS) + self.sock.bind(server_address) self.sock.listen(1) self.fd_handle = self.reactor.register_fd( self.sock.fileno(), self._handle_accept) |