| 40 | self.poll.register(self.webhook_socket, select.POLLIN | select.POLLHUP) |
| 41 | self.kbd_data = self.socket_data = b"" |
| 42 | def process_socket(self): |
| 43 | data = self.webhook_socket.recv(4096) |
| 44 | if not data: |
| 45 | sys.stderr.write("Socket closed\n") |
| 46 | sys.exit(0) |
| 47 | parts = data.split(b'\x03') |
| 48 | parts[0] = self.socket_data + parts[0] |
| 49 | self.socket_data = parts.pop() |
| 50 | for line in parts: |
| 51 | sys.stdout.write("GOT: %s\n" % (line,)) |
| 52 | def process_kbd(self): |
| 53 | data = os.read(self.kbd_fd, 4096) |
| 54 | parts = data.split(b'\n') |