aboutsummaryrefslogtreecommitdiffstats
path: root/scripts/whconsole.py
diff options
context:
space:
mode:
authorKevin O'Connor <kevin@koconnor.net>2024-10-20 22:06:10 -0400
committerKevin O'Connor <kevin@koconnor.net>2024-10-21 22:16:11 -0400
commit8a530cbcce8d251a7428fabbb6b24fb65f881373 (patch)
treeaead4ba5ac9eab76edd878d861ca9cfd6b0549e6 /scripts/whconsole.py
parentb89d552387da9734292a182c7040c418996ca350 (diff)
downloadkutter-8a530cbcce8d251a7428fabbb6b24fb65f881373.tar.gz
kutter-8a530cbcce8d251a7428fabbb6b24fb65f881373.tar.xz
kutter-8a530cbcce8d251a7428fabbb6b24fb65f881373.zip
scripts: Update whconsole tool to support python3
Signed-off-by: Kevin O'Connor <kevin@koconnor.net>
Diffstat (limited to 'scripts/whconsole.py')
-rwxr-xr-xscripts/whconsole.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/scripts/whconsole.py b/scripts/whconsole.py
index ba77ae9b..5e76b3bc 100755
--- a/scripts/whconsole.py
+++ b/scripts/whconsole.py
@@ -38,25 +38,25 @@ class KeyboardReader:
self.poll = select.poll()
self.poll.register(sys.stdin, select.POLLIN | select.POLLHUP)
self.poll.register(self.webhook_socket, select.POLLIN | select.POLLHUP)
- self.kbd_data = self.socket_data = ""
+ self.kbd_data = self.socket_data = b""
def process_socket(self):
data = self.webhook_socket.recv(4096)
if not data:
sys.stderr.write("Socket closed\n")
sys.exit(0)
- parts = data.split('\x03')
+ parts = data.split(b'\x03')
parts[0] = self.socket_data + parts[0]
self.socket_data = parts.pop()
for line in parts:
sys.stdout.write("GOT: %s\n" % (line,))
def process_kbd(self):
data = os.read(self.kbd_fd, 4096)
- parts = data.split('\n')
+ parts = data.split(b'\n')
parts[0] = self.kbd_data + parts[0]
self.kbd_data = parts.pop()
for line in parts:
line = line.strip()
- if not line or line.startswith('#'):
+ if not line or line.startswith(b'#'):
continue
try:
m = json.loads(line)
@@ -65,7 +65,7 @@ class KeyboardReader:
continue
cm = json.dumps(m, separators=(',', ':'))
sys.stdout.write("SEND: %s\n" % (cm,))
- self.webhook_socket.send("%s\x03" % (cm,))
+ self.webhook_socket.send(cm.encode() + b"\x03")
def run(self):
while 1:
res = self.poll.poll(1000.)