cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 1 | #!/usr/bin/env python |
Chris Liechti | fbdd8a0 | 2015-08-09 02:37:45 +0200 | [diff] [blame] | 2 | # |
cliechti | a128a70 | 2004-07-21 22:13:31 +0000 | [diff] [blame] | 3 | # Very simple serial terminal |
Chris Liechti | fbdd8a0 | 2015-08-09 02:37:45 +0200 | [diff] [blame] | 4 | # |
Chris Liechti | 68340d7 | 2015-08-03 14:15:48 +0200 | [diff] [blame] | 5 | # (C)2002-2015 Chris Liechti <cliechti@gmx.net> |
Chris Liechti | fbdd8a0 | 2015-08-09 02:37:45 +0200 | [diff] [blame] | 6 | # |
| 7 | # SPDX-License-Identifier: BSD-3-Clause |
cliechti | fc9eb38 | 2002-03-05 01:12:29 +0000 | [diff] [blame] | 8 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 9 | import codecs |
Chris Liechti | a1d5c6d | 2015-08-07 14:41:24 +0200 | [diff] [blame] | 10 | import os |
| 11 | import sys |
| 12 | import threading |
cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 13 | |
Chris Liechti | a1d5c6d | 2015-08-07 14:41:24 +0200 | [diff] [blame] | 14 | import serial |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 15 | from serial.tools.list_ports import comports |
Chris Liechti | a1d5c6d | 2015-08-07 14:41:24 +0200 | [diff] [blame] | 16 | |
Chris Liechti | 68340d7 | 2015-08-03 14:15:48 +0200 | [diff] [blame] | 17 | try: |
| 18 | raw_input |
| 19 | except NameError: |
| 20 | raw_input = input # in python3 it's "raw" |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 21 | unichr = chr |
Chris Liechti | 68340d7 | 2015-08-03 14:15:48 +0200 | [diff] [blame] | 22 | |
Chris Liechti | c0c660a | 2015-08-25 00:55:51 +0200 | [diff] [blame] | 23 | from . import hexlify_codec |
| 24 | codecs.register(lambda c: hexlify_codec.getregentry() if c == 'hexlify' else None) |
| 25 | |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 26 | |
| 27 | def key_description(character): |
| 28 | """generate a readable description for a key""" |
| 29 | ascii_code = ord(character) |
| 30 | if ascii_code < 32: |
| 31 | return 'Ctrl+%c' % (ord('@') + ascii_code) |
| 32 | else: |
| 33 | return repr(character) |
| 34 | |
cliechti | 9116553 | 2011-03-18 02:02:52 +0000 | [diff] [blame] | 35 | |
Chris Liechti | 9a72085 | 2015-08-25 00:20:38 +0200 | [diff] [blame] | 36 | # - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 37 | class ConsoleBase(object): |
| 38 | def __init__(self): |
| 39 | if sys.version_info >= (3, 0): |
| 40 | self.byte_output = sys.stdout.buffer |
| 41 | else: |
| 42 | self.byte_output = sys.stdout |
| 43 | self.output = sys.stdout |
cliechti | f467aa8 | 2013-10-13 21:36:49 +0000 | [diff] [blame] | 44 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 45 | def setup(self): |
| 46 | pass # Do nothing for 'nt' |
cliechti | f467aa8 | 2013-10-13 21:36:49 +0000 | [diff] [blame] | 47 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 48 | def cleanup(self): |
| 49 | pass # Do nothing for 'nt' |
| 50 | |
| 51 | def getkey(self): |
| 52 | return None |
| 53 | |
| 54 | def write_bytes(self, s): |
| 55 | self.byte_output.write(s) |
| 56 | self.byte_output.flush() |
| 57 | |
| 58 | def write(self, s): |
| 59 | self.output.write(s) |
| 60 | self.output.flush() |
| 61 | |
Chris Liechti | 269f77b | 2015-08-24 01:31:42 +0200 | [diff] [blame] | 62 | # - - - - - - - - - - - - - - - - - - - - - - - - |
| 63 | # context manager: |
| 64 | # switch terminal temporary to normal mode (e.g. to get user input) |
| 65 | |
| 66 | def __enter__(self): |
| 67 | self.cleanup() |
| 68 | return self |
| 69 | |
| 70 | def __exit__(self, *args, **kwargs): |
| 71 | self.setup() |
| 72 | |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 73 | |
cliechti | fc9eb38 | 2002-03-05 01:12:29 +0000 | [diff] [blame] | 74 | if os.name == 'nt': |
cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 75 | import msvcrt |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 76 | import ctypes |
| 77 | class Console(ConsoleBase): |
Chris Liechti | cbb00b2 | 2015-08-13 22:58:49 +0200 | [diff] [blame] | 78 | def __init__(self): |
| 79 | super(Console, self).__init__() |
| 80 | ctypes.windll.kernel32.SetConsoleOutputCP(65001) |
| 81 | ctypes.windll.kernel32.SetConsoleCP(65001) |
| 82 | if sys.version_info < (3, 0): |
| 83 | class Out: |
| 84 | def __init__(self): |
| 85 | self.fd = sys.stdout.fileno() |
| 86 | def flush(self): |
| 87 | pass |
| 88 | def write(self, s): |
| 89 | os.write(self.fd, s) |
| 90 | self.output = codecs.getwriter('UTF-8')(Out(), 'replace') |
| 91 | self.byte_output = Out() |
| 92 | else: |
| 93 | self.output = codecs.getwriter('UTF-8')(sys.stdout.buffer, 'replace') |
| 94 | |
cliechti | 3a8bf09 | 2008-09-17 11:26:53 +0000 | [diff] [blame] | 95 | def getkey(self): |
cliechti | 9116553 | 2011-03-18 02:02:52 +0000 | [diff] [blame] | 96 | while True: |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 97 | z = msvcrt.getwch() |
| 98 | if z == '\r': |
| 99 | return '\n' |
| 100 | elif z in '\x00\x0e': # functions keys, ignore |
| 101 | msvcrt.getwch() |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 102 | else: |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 103 | return z |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 104 | |
cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 105 | elif os.name == 'posix': |
Chris Liechti | a1d5c6d | 2015-08-07 14:41:24 +0200 | [diff] [blame] | 106 | import atexit |
| 107 | import termios |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 108 | class Console(ConsoleBase): |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 109 | def __init__(self): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 110 | super(Console, self).__init__() |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 111 | self.fd = sys.stdin.fileno() |
Chris Liechti | 4d989c2 | 2015-08-24 00:24:49 +0200 | [diff] [blame] | 112 | self.old = termios.tcgetattr(self.fd) |
Chris Liechti | 89eb247 | 2015-08-08 17:06:25 +0200 | [diff] [blame] | 113 | atexit.register(self.cleanup) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 114 | if sys.version_info < (3, 0): |
Chris Liechti | a7e7b69 | 2015-08-25 21:10:28 +0200 | [diff] [blame^] | 115 | self.enc_stdin = codecs.getreader(sys.stdin.encoding)(sys.stdin) |
| 116 | else: |
| 117 | self.enc_stdin = sys.stdin |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 118 | |
| 119 | def setup(self): |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 120 | new = termios.tcgetattr(self.fd) |
| 121 | new[3] = new[3] & ~termios.ICANON & ~termios.ECHO & ~termios.ISIG |
| 122 | new[6][termios.VMIN] = 1 |
| 123 | new[6][termios.VTIME] = 0 |
| 124 | termios.tcsetattr(self.fd, termios.TCSANOW, new) |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 125 | |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 126 | def getkey(self): |
Chris Liechti | a7e7b69 | 2015-08-25 21:10:28 +0200 | [diff] [blame^] | 127 | c = self.enc_stdin.read(1) |
Chris Liechti | 9a72085 | 2015-08-25 00:20:38 +0200 | [diff] [blame] | 128 | if c == '\x7f': |
| 129 | c = '\b' # map the BS key (which yields DEL) to backspace |
| 130 | return c |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 131 | |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 132 | def cleanup(self): |
Chris Liechti | 4d989c2 | 2015-08-24 00:24:49 +0200 | [diff] [blame] | 133 | termios.tcsetattr(self.fd, termios.TCSAFLUSH, self.old) |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 134 | |
cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 135 | else: |
cliechti | 8c2ea84 | 2011-03-18 01:51:46 +0000 | [diff] [blame] | 136 | raise NotImplementedError("Sorry no implementation for your platform (%s) available." % sys.platform) |
cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 137 | |
cliechti | 6fa76fb | 2009-07-08 23:53:39 +0000 | [diff] [blame] | 138 | |
Chris Liechti | 9a72085 | 2015-08-25 00:20:38 +0200 | [diff] [blame] | 139 | # - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 140 | |
| 141 | class Transform(object): |
Chris Liechti | cbb00b2 | 2015-08-13 22:58:49 +0200 | [diff] [blame] | 142 | """do-nothing: forward all data unchanged""" |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 143 | def rx(self, text): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 144 | """text received from serial port""" |
| 145 | return text |
| 146 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 147 | def tx(self, text): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 148 | """text to be sent to serial port""" |
| 149 | return text |
| 150 | |
| 151 | def echo(self, text): |
| 152 | """text to be sent but displayed on console""" |
| 153 | return text |
| 154 | |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 155 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 156 | class CRLF(Transform): |
| 157 | """ENTER sends CR+LF""" |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 158 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 159 | def tx(self, text): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 160 | return text.replace('\n', '\r\n') |
| 161 | |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 162 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 163 | class CR(Transform): |
| 164 | """ENTER sends CR""" |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 165 | |
| 166 | def rx(self, text): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 167 | return text.replace('\r', '\n') |
| 168 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 169 | def tx(self, text): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 170 | return text.replace('\n', '\r') |
| 171 | |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 172 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 173 | class LF(Transform): |
| 174 | """ENTER sends LF""" |
| 175 | |
| 176 | |
| 177 | class NoTerminal(Transform): |
| 178 | """remove typical terminal control codes from input""" |
Chris Liechti | 9a72085 | 2015-08-25 00:20:38 +0200 | [diff] [blame] | 179 | |
| 180 | REPLACEMENT_MAP = dict((x, 0x2400 + x) for x in range(32) if unichr(x) not in '\r\n\b\t') |
| 181 | REPLACEMENT_MAP.update({ |
| 182 | 0x7F: 0x2421, # DEL |
| 183 | 0x9B: 0x2425, # CSI |
| 184 | }) |
| 185 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 186 | def rx(self, text): |
Chris Liechti | 9a72085 | 2015-08-25 00:20:38 +0200 | [diff] [blame] | 187 | return text.translate(self.REPLACEMENT_MAP) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 188 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 189 | echo = rx |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 190 | |
| 191 | |
Chris Liechti | 9a72085 | 2015-08-25 00:20:38 +0200 | [diff] [blame] | 192 | class NoControls(NoTerminal): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 193 | """Remove all control codes, incl. CR+LF""" |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 194 | |
Chris Liechti | 9a72085 | 2015-08-25 00:20:38 +0200 | [diff] [blame] | 195 | REPLACEMENT_MAP = dict((x, 0x2400 + x) for x in range(32)) |
| 196 | REPLACEMENT_MAP.update({ |
| 197 | 32: 0x2423, # visual space |
| 198 | 0x7F: 0x2421, # DEL |
| 199 | 0x9B: 0x2425, # CSI |
| 200 | }) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 201 | |
| 202 | |
| 203 | class Printable(Transform): |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 204 | """Show decimal code for all non-ASCII characters and replace most control codes""" |
Chris Liechti | c0c660a | 2015-08-25 00:55:51 +0200 | [diff] [blame] | 205 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 206 | def rx(self, text): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 207 | r = [] |
| 208 | for t in text: |
Chris Liechti | 7e9cfd4 | 2015-08-12 15:28:19 +0200 | [diff] [blame] | 209 | if ' ' <= t < '\x7f' or t in '\r\n\b\t': |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 210 | r.append(t) |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 211 | elif t < ' ': |
| 212 | r.append(unichr(0x2400 + ord(t))) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 213 | else: |
| 214 | r.extend(unichr(0x2080 + ord(d) - 48) for d in '{:d}'.format(ord(t))) |
| 215 | r.append(' ') |
| 216 | return ''.join(r) |
| 217 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 218 | echo = rx |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 219 | |
| 220 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 221 | class Colorize(Transform): |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 222 | """Apply different colors for received and echo""" |
Chris Liechti | c0c660a | 2015-08-25 00:55:51 +0200 | [diff] [blame] | 223 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 224 | def __init__(self): |
| 225 | # XXX make it configurable, use colorama? |
| 226 | self.input_color = '\x1b[37m' |
| 227 | self.echo_color = '\x1b[31m' |
| 228 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 229 | def rx(self, text): |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 230 | return self.input_color + text |
| 231 | |
| 232 | def echo(self, text): |
| 233 | return self.echo_color + text |
| 234 | |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 235 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 236 | class DebugIO(Transform): |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 237 | """Print what is sent and received""" |
Chris Liechti | c0c660a | 2015-08-25 00:55:51 +0200 | [diff] [blame] | 238 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 239 | def rx(self, text): |
Chris Liechti | e138438 | 2015-08-15 17:06:05 +0200 | [diff] [blame] | 240 | sys.stderr.write(' [RX:{}] '.format(repr(text))) |
| 241 | sys.stderr.flush() |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 242 | return text |
| 243 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 244 | def tx(self, text): |
Chris Liechti | e138438 | 2015-08-15 17:06:05 +0200 | [diff] [blame] | 245 | sys.stderr.write(' [TX:{}] '.format(repr(text))) |
| 246 | sys.stderr.flush() |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 247 | return text |
| 248 | |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 249 | |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 250 | # other ideas: |
| 251 | # - add date/time for each newline |
| 252 | # - insert newline after: a) timeout b) packet end character |
| 253 | |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 254 | EOL_TRANSFORMATIONS = { |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 255 | 'crlf': CRLF, |
| 256 | 'cr': CR, |
| 257 | 'lf': LF, |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 258 | } |
| 259 | |
| 260 | TRANSFORMATIONS = { |
Chris Liechti | cbb00b2 | 2015-08-13 22:58:49 +0200 | [diff] [blame] | 261 | 'direct': Transform, # no transformation |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 262 | 'default': NoTerminal, |
| 263 | 'nocontrol': NoControls, |
| 264 | 'printable': Printable, |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 265 | 'colorize': Colorize, |
| 266 | 'debug': DebugIO, |
| 267 | } |
| 268 | |
Chris Liechti | 9a72085 | 2015-08-25 00:20:38 +0200 | [diff] [blame] | 269 | # - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 270 | |
cliechti | 1351dde | 2012-04-12 16:47:47 +0000 | [diff] [blame] | 271 | def dump_port_list(): |
| 272 | if comports: |
| 273 | sys.stderr.write('\n--- Available ports:\n') |
| 274 | for port, desc, hwid in sorted(comports()): |
| 275 | #~ sys.stderr.write('--- %-20s %s [%s]\n' % (port, desc, hwid)) |
| 276 | sys.stderr.write('--- %-20s %s\n' % (port, desc)) |
| 277 | |
| 278 | |
cliechti | 8c2ea84 | 2011-03-18 01:51:46 +0000 | [diff] [blame] | 279 | class Miniterm(object): |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 280 | def __init__(self, port, baudrate, parity, rtscts, xonxoff, echo=False, eol='crlf', filters=()): |
Chris Liechti | 89eb247 | 2015-08-08 17:06:25 +0200 | [diff] [blame] | 281 | self.console = Console() |
Chris Liechti | a1d5c6d | 2015-08-07 14:41:24 +0200 | [diff] [blame] | 282 | self.serial = serial.serial_for_url(port, baudrate, parity=parity, rtscts=rtscts, xonxoff=xonxoff, timeout=1) |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 283 | self.echo = echo |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 284 | self.dtr_state = True |
| 285 | self.rts_state = True |
| 286 | self.break_state = False |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 287 | self.raw = False |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 288 | self.input_encoding = 'UTF-8' |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 289 | self.output_encoding = 'UTF-8' |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 290 | self.eol = eol |
| 291 | self.filters = filters |
| 292 | self.update_transformations() |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 293 | self.exit_character = 0x1d # GS/CTRL+] |
| 294 | self.menu_character = 0x14 # Menu: CTRL+T |
cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 295 | |
cliechti | 8c2ea84 | 2011-03-18 01:51:46 +0000 | [diff] [blame] | 296 | def _start_reader(self): |
| 297 | """Start reader thread""" |
| 298 | self._reader_alive = True |
cliechti | 6fa76fb | 2009-07-08 23:53:39 +0000 | [diff] [blame] | 299 | # start serial->console thread |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 300 | self.receiver_thread = threading.Thread(target=self.reader, name='rx') |
| 301 | self.receiver_thread.daemon = True |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 302 | self.receiver_thread.start() |
cliechti | 8c2ea84 | 2011-03-18 01:51:46 +0000 | [diff] [blame] | 303 | |
| 304 | def _stop_reader(self): |
| 305 | """Stop reader thread only, wait for clean exit of thread""" |
| 306 | self._reader_alive = False |
| 307 | self.receiver_thread.join() |
| 308 | |
| 309 | |
| 310 | def start(self): |
| 311 | self.alive = True |
| 312 | self._start_reader() |
cliechti | 6fa76fb | 2009-07-08 23:53:39 +0000 | [diff] [blame] | 313 | # enter console->serial loop |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 314 | self.transmitter_thread = threading.Thread(target=self.writer, name='tx') |
| 315 | self.transmitter_thread.daemon = True |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 316 | self.transmitter_thread.start() |
Chris Liechti | 89eb247 | 2015-08-08 17:06:25 +0200 | [diff] [blame] | 317 | self.console.setup() |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 318 | |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 319 | def stop(self): |
| 320 | self.alive = False |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 321 | |
cliechti | bf6bb7d | 2006-03-30 00:28:18 +0000 | [diff] [blame] | 322 | def join(self, transmit_only=False): |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 323 | self.transmitter_thread.join() |
cliechti | bf6bb7d | 2006-03-30 00:28:18 +0000 | [diff] [blame] | 324 | if not transmit_only: |
| 325 | self.receiver_thread.join() |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 326 | |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 327 | def update_transformations(self): |
| 328 | transformations = [EOL_TRANSFORMATIONS[self.eol]] + [TRANSFORMATIONS[f] for f in self.filters] |
| 329 | self.tx_transformations = [t() for t in transformations] |
| 330 | self.rx_transformations = list(reversed(self.tx_transformations)) |
| 331 | |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 332 | def set_rx_encoding(self, encoding, errors='replace'): |
| 333 | self.input_encoding = encoding |
| 334 | self.rx_decoder = codecs.getincrementaldecoder(encoding)(errors) |
| 335 | |
| 336 | def set_tx_encoding(self, encoding, errors='replace'): |
| 337 | self.output_encoding = encoding |
| 338 | self.tx_encoder = codecs.getincrementalencoder(encoding)(errors) |
| 339 | |
| 340 | |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 341 | def dump_port_settings(self): |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 342 | sys.stderr.write("\n--- Settings: {p.name} {p.baudrate},{p.bytesize},{p.parity},{p.stopbits}\n".format( |
| 343 | p=self.serial)) |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 344 | sys.stderr.write('--- RTS: {:8} DTR: {:8} BREAK: {:8}\n'.format( |
| 345 | ('active' if self.rts_state else 'inactive'), |
| 346 | ('active' if self.dtr_state else 'inactive'), |
| 347 | ('active' if self.break_state else 'inactive'))) |
cliechti | 1011457 | 2009-08-05 23:40:50 +0000 | [diff] [blame] | 348 | try: |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 349 | sys.stderr.write('--- CTS: {:8} DSR: {:8} RI: {:8} CD: {:8}\n'.format( |
| 350 | ('active' if self.serial.getCTS() else 'inactive'), |
| 351 | ('active' if self.serial.getDSR() else 'inactive'), |
| 352 | ('active' if self.serial.getRI() else 'inactive'), |
| 353 | ('active' if self.serial.getCD() else 'inactive'))) |
cliechti | 1011457 | 2009-08-05 23:40:50 +0000 | [diff] [blame] | 354 | except serial.SerialException: |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 355 | # on RFC 2217 ports, it can happen if no modem state notification was |
cliechti | 1011457 | 2009-08-05 23:40:50 +0000 | [diff] [blame] | 356 | # yet received. ignore this error. |
| 357 | pass |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 358 | sys.stderr.write('--- software flow control: {}\n'.format('active' if self.serial.xonxoff else 'inactive')) |
| 359 | sys.stderr.write('--- hardware flow control: {}\n'.format('active' if self.serial.rtscts else 'inactive')) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 360 | #~ sys.stderr.write('--- data escaping: %s linefeed: %s\n' % ( |
| 361 | #~ REPR_MODES[self.repr_mode], |
| 362 | #~ LF_MODES[self.convert_outgoing])) |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 363 | sys.stderr.write('--- serial input encoding: {}\n'.format(self.input_encoding)) |
| 364 | sys.stderr.write('--- serial output encoding: {}\n'.format(self.output_encoding)) |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 365 | sys.stderr.write('--- EOL: {}\n'.format(self.eol.upper())) |
| 366 | sys.stderr.write('--- filters: {}\n'.format(' '.join(self.filters))) |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 367 | |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 368 | def reader(self): |
| 369 | """loop and copy serial->console""" |
cliechti | 6963b26 | 2010-01-02 03:01:21 +0000 | [diff] [blame] | 370 | try: |
cliechti | 8c2ea84 | 2011-03-18 01:51:46 +0000 | [diff] [blame] | 371 | while self.alive and self._reader_alive: |
Chris Liechti | 188cf59 | 2015-08-22 00:28:19 +0200 | [diff] [blame] | 372 | # read all that is there or wait for one byte |
| 373 | data = self.serial.read(self.serial.inWaiting() or 1) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 374 | if data: |
| 375 | if self.raw: |
| 376 | self.console.write_bytes(data) |
cliechti | 6963b26 | 2010-01-02 03:01:21 +0000 | [diff] [blame] | 377 | else: |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 378 | text = self.rx_decoder.decode(data) |
Chris Liechti | e138438 | 2015-08-15 17:06:05 +0200 | [diff] [blame] | 379 | for transformation in self.rx_transformations: |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 380 | text = transformation.rx(text) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 381 | self.console.write(text) |
Chris Liechti | 68340d7 | 2015-08-03 14:15:48 +0200 | [diff] [blame] | 382 | except serial.SerialException as e: |
cliechti | 6963b26 | 2010-01-02 03:01:21 +0000 | [diff] [blame] | 383 | self.alive = False |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 384 | # XXX would be nice if the writer could be interrupted at this |
| 385 | # point... to exit completely |
cliechti | 6963b26 | 2010-01-02 03:01:21 +0000 | [diff] [blame] | 386 | raise |
cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 387 | |
cliechti | 576de25 | 2002-02-28 23:54:44 +0000 | [diff] [blame] | 388 | |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 389 | def writer(self): |
cliechti | 8c2ea84 | 2011-03-18 01:51:46 +0000 | [diff] [blame] | 390 | """\ |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 391 | Loop and copy console->serial until self.exit_character character is |
| 392 | found. When self.menu_character is found, interpret the next key |
cliechti | 8c2ea84 | 2011-03-18 01:51:46 +0000 | [diff] [blame] | 393 | locally. |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 394 | """ |
| 395 | menu_active = False |
| 396 | try: |
| 397 | while self.alive: |
| 398 | try: |
Chris Liechti | 89eb247 | 2015-08-08 17:06:25 +0200 | [diff] [blame] | 399 | c = self.console.getkey() |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 400 | except KeyboardInterrupt: |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 401 | c = '\x03' |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 402 | if menu_active: |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 403 | self.handle_menu_key(c) |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 404 | menu_active = False |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 405 | elif c == self.menu_character: |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 406 | menu_active = True # next char will be for menu |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 407 | elif c == self.exit_character: |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 408 | self.stop() # exit app |
| 409 | break |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 410 | else: |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 411 | #~ if self.raw: |
| 412 | text = c |
| 413 | echo_text = text |
Chris Liechti | e138438 | 2015-08-15 17:06:05 +0200 | [diff] [blame] | 414 | for transformation in self.tx_transformations: |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 415 | text = transformation.tx(text) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 416 | echo_text = transformation.echo(echo_text) |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 417 | self.serial.write(self.tx_encoder.encode(text)) |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 418 | if self.echo: |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 419 | self.console.write(echo_text) |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 420 | except: |
| 421 | self.alive = False |
| 422 | raise |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 423 | |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 424 | def handle_menu_key(self, c): |
| 425 | """Implement a simple menu / settings""" |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 426 | if c == self.menu_character or c == self.exit_character: |
| 427 | # Menu/exit character again -> send itself |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 428 | self.serial.write(self.tx_encoder.encode(c)) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 429 | if self.echo: |
| 430 | self.console.write(c) |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 431 | elif c == '\x15': # CTRL+U -> upload file |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 432 | sys.stderr.write('\n--- File to upload: ') |
| 433 | sys.stderr.flush() |
Chris Liechti | 269f77b | 2015-08-24 01:31:42 +0200 | [diff] [blame] | 434 | with self.console: |
| 435 | filename = sys.stdin.readline().rstrip('\r\n') |
| 436 | if filename: |
| 437 | try: |
| 438 | with open(filename, 'rb') as f: |
| 439 | sys.stderr.write('--- Sending file {} ---\n'.format(filename)) |
| 440 | while True: |
| 441 | block = f.read(1024) |
| 442 | if not block: |
| 443 | break |
| 444 | self.serial.write(block) |
| 445 | # Wait for output buffer to drain. |
| 446 | self.serial.flush() |
| 447 | sys.stderr.write('.') # Progress indicator. |
| 448 | sys.stderr.write('\n--- File {} sent ---\n'.format(filename)) |
| 449 | except IOError as e: |
| 450 | sys.stderr.write('--- ERROR opening file {}: {} ---\n'.format(filename, e)) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 451 | elif c in '\x08hH?': # CTRL+H, h, H, ? -> Show help |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 452 | sys.stderr.write(self.get_help_text()) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 453 | elif c == '\x12': # CTRL+R -> Toggle RTS |
| 454 | self.rts_state = not self.rts_state |
| 455 | self.serial.setRTS(self.rts_state) |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 456 | sys.stderr.write('--- RTS {} ---\n'.format('active' if self.rts_state else 'inactive')) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 457 | elif c == '\x04': # CTRL+D -> Toggle DTR |
| 458 | self.dtr_state = not self.dtr_state |
| 459 | self.serial.setDTR(self.dtr_state) |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 460 | sys.stderr.write('--- DTR {} ---\n'.format('active' if self.dtr_state else 'inactive')) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 461 | elif c == '\x02': # CTRL+B -> toggle BREAK condition |
| 462 | self.break_state = not self.break_state |
| 463 | self.serial.setBreak(self.break_state) |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 464 | sys.stderr.write('--- BREAK {} ---\n'.format('active' if self.break_state else 'inactive')) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 465 | elif c == '\x05': # CTRL+E -> toggle local echo |
| 466 | self.echo = not self.echo |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 467 | sys.stderr.write('--- local echo {} ---\n'.format('active' if self.echo else 'inactive')) |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 468 | elif c == '\x06': # CTRL+F -> edit filters |
| 469 | sys.stderr.write('\n--- Available Filters:\n') |
| 470 | sys.stderr.write('\n'.join( |
| 471 | '--- {:<10} = {.__doc__}'.format(k, v) |
| 472 | for k, v in sorted(TRANSFORMATIONS.items()))) |
| 473 | sys.stderr.write('\n--- Enter new filter name(s) [{}]: '.format(' '.join(self.filters))) |
| 474 | with self.console: |
| 475 | new_filters = sys.stdin.readline().lower().split() |
| 476 | if new_filters: |
| 477 | for f in new_filters: |
| 478 | if f not in TRANSFORMATIONS: |
| 479 | sys.stderr.write('--- unknown filter: {}'.format(repr(f))) |
| 480 | break |
| 481 | else: |
| 482 | self.filters = new_filters |
| 483 | self.update_transformations() |
| 484 | sys.stderr.write('--- filters: {}\n'.format(' '.join(self.filters))) |
| 485 | elif c == '\x0c': # CTRL+L -> EOL mode |
| 486 | modes = list(EOL_TRANSFORMATIONS) # keys |
| 487 | eol = modes.index(self.eol) + 1 |
| 488 | if eol >= len(modes): |
| 489 | eol = 0 |
| 490 | self.eol = modes[eol] |
| 491 | sys.stderr.write('--- EOL: {} ---\n'.format(self.eol.upper())) |
| 492 | self.update_transformations() |
| 493 | elif c == '\x01': # CTRL+A -> set encoding |
| 494 | sys.stderr.write('\n--- Enter new encoding name [{}]: '.format(self.input_encoding)) |
| 495 | with self.console: |
| 496 | new_encoding = sys.stdin.readline().strip() |
| 497 | if new_encoding: |
| 498 | try: |
| 499 | codecs.lookup(new_encoding) |
| 500 | except LookupError: |
| 501 | sys.stderr.write('--- invalid encoding name: {}\n'.format(new_encoding)) |
| 502 | else: |
| 503 | self.set_rx_encoding(new_encoding) |
| 504 | self.set_tx_encoding(new_encoding) |
| 505 | sys.stderr.write('--- serial input encoding: {}\n'.format(self.input_encoding)) |
| 506 | sys.stderr.write('--- serial output encoding: {}\n'.format(self.output_encoding)) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 507 | elif c == '\x09': # CTRL+I -> info |
| 508 | self.dump_port_settings() |
| 509 | #~ elif c == '\x01': # CTRL+A -> cycle escape mode |
| 510 | #~ elif c == '\x0c': # CTRL+L -> cycle linefeed mode |
| 511 | elif c in 'pP': # P -> change port |
| 512 | dump_port_list() |
| 513 | sys.stderr.write('--- Enter port name: ') |
| 514 | sys.stderr.flush() |
Chris Liechti | 269f77b | 2015-08-24 01:31:42 +0200 | [diff] [blame] | 515 | with self.console: |
| 516 | try: |
| 517 | port = sys.stdin.readline().strip() |
| 518 | except KeyboardInterrupt: |
| 519 | port = None |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 520 | if port and port != self.serial.port: |
| 521 | # reader thread needs to be shut down |
| 522 | self._stop_reader() |
| 523 | # save settings |
| 524 | settings = self.serial.getSettingsDict() |
| 525 | try: |
| 526 | new_serial = serial.serial_for_url(port, do_not_open=True) |
| 527 | # restore settings and open |
| 528 | new_serial.applySettingsDict(settings) |
| 529 | new_serial.open() |
| 530 | new_serial.setRTS(self.rts_state) |
| 531 | new_serial.setDTR(self.dtr_state) |
| 532 | new_serial.setBreak(self.break_state) |
| 533 | except Exception as e: |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 534 | sys.stderr.write('--- ERROR opening new port: {} ---\n'.format(e)) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 535 | new_serial.close() |
| 536 | else: |
| 537 | self.serial.close() |
| 538 | self.serial = new_serial |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 539 | sys.stderr.write('--- Port changed to: {} ---\n'.format(self.serial.port)) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 540 | # and restart the reader thread |
| 541 | self._start_reader() |
| 542 | elif c in 'bB': # B -> change baudrate |
| 543 | sys.stderr.write('\n--- Baudrate: ') |
| 544 | sys.stderr.flush() |
Chris Liechti | 269f77b | 2015-08-24 01:31:42 +0200 | [diff] [blame] | 545 | with self.console: |
| 546 | backup = self.serial.baudrate |
| 547 | try: |
| 548 | self.serial.baudrate = int(sys.stdin.readline().strip()) |
| 549 | except ValueError as e: |
| 550 | sys.stderr.write('--- ERROR setting baudrate: %s ---\n'.format(e)) |
| 551 | self.serial.baudrate = backup |
| 552 | else: |
| 553 | self.dump_port_settings() |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 554 | elif c == '8': # 8 -> change to 8 bits |
| 555 | self.serial.bytesize = serial.EIGHTBITS |
| 556 | self.dump_port_settings() |
| 557 | elif c == '7': # 7 -> change to 8 bits |
| 558 | self.serial.bytesize = serial.SEVENBITS |
| 559 | self.dump_port_settings() |
| 560 | elif c in 'eE': # E -> change to even parity |
| 561 | self.serial.parity = serial.PARITY_EVEN |
| 562 | self.dump_port_settings() |
| 563 | elif c in 'oO': # O -> change to odd parity |
| 564 | self.serial.parity = serial.PARITY_ODD |
| 565 | self.dump_port_settings() |
| 566 | elif c in 'mM': # M -> change to mark parity |
| 567 | self.serial.parity = serial.PARITY_MARK |
| 568 | self.dump_port_settings() |
| 569 | elif c in 'sS': # S -> change to space parity |
| 570 | self.serial.parity = serial.PARITY_SPACE |
| 571 | self.dump_port_settings() |
| 572 | elif c in 'nN': # N -> change to no parity |
| 573 | self.serial.parity = serial.PARITY_NONE |
| 574 | self.dump_port_settings() |
| 575 | elif c == '1': # 1 -> change to 1 stop bits |
| 576 | self.serial.stopbits = serial.STOPBITS_ONE |
| 577 | self.dump_port_settings() |
| 578 | elif c == '2': # 2 -> change to 2 stop bits |
| 579 | self.serial.stopbits = serial.STOPBITS_TWO |
| 580 | self.dump_port_settings() |
| 581 | elif c == '3': # 3 -> change to 1.5 stop bits |
| 582 | self.serial.stopbits = serial.STOPBITS_ONE_POINT_FIVE |
| 583 | self.dump_port_settings() |
| 584 | elif c in 'xX': # X -> change software flow control |
| 585 | self.serial.xonxoff = (c == 'X') |
| 586 | self.dump_port_settings() |
| 587 | elif c in 'rR': # R -> change hardware flow control |
| 588 | self.serial.rtscts = (c == 'R') |
| 589 | self.dump_port_settings() |
| 590 | else: |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 591 | sys.stderr.write('--- unknown menu character {} --\n'.format(key_description(c))) |
| 592 | |
| 593 | def get_help_text(self): |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 594 | # help text, starts with blank line! |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 595 | return """ |
| 596 | --- pySerial ({version}) - miniterm - help |
| 597 | --- |
| 598 | --- {exit:8} Exit program |
| 599 | --- {menu:8} Menu escape key, followed by: |
| 600 | --- Menu keys: |
| 601 | --- {menu:7} Send the menu character itself to remote |
| 602 | --- {exit:7} Send the exit character itself to remote |
| 603 | --- {info:7} Show info |
| 604 | --- {upload:7} Upload file (prompt will be shown) |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 605 | --- {repr:7} encoding |
| 606 | --- {filter:7} edit filters |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 607 | --- Toggles: |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 608 | --- {rts:7} RTS {dtr:7} DTR {brk:7} BREAK |
| 609 | --- {echo:7} echo {eol:7} EOL |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 610 | --- |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 611 | --- Port settings ({menu} followed by the following): |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 612 | --- p change port |
| 613 | --- 7 8 set data bits |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 614 | --- N E O S M change parity (None, Even, Odd, Space, Mark) |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 615 | --- 1 2 3 set stop bits (1, 2, 1.5) |
| 616 | --- b change baud rate |
| 617 | --- x X disable/enable software flow control |
| 618 | --- r R disable/enable hardware flow control |
| 619 | """.format( |
| 620 | version=getattr(serial, 'VERSION', 'unknown version'), |
| 621 | exit=key_description(self.exit_character), |
| 622 | menu=key_description(self.menu_character), |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 623 | rts=key_description('\x12'), |
| 624 | dtr=key_description('\x04'), |
| 625 | brk=key_description('\x02'), |
| 626 | echo=key_description('\x05'), |
| 627 | info=key_description('\x09'), |
| 628 | upload=key_description('\x15'), |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 629 | repr=key_description('\x01'), |
| 630 | filter=key_description('\x06'), |
| 631 | eol=key_description('\x0c'), |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 632 | ) |
Chris Liechti | 7af7c75 | 2015-08-12 15:45:19 +0200 | [diff] [blame] | 633 | |
| 634 | |
| 635 | |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 636 | # - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 637 | # default args can be used to override when calling main() from an other script |
| 638 | # e.g to create a miniterm-my-device.py |
| 639 | def main(default_port=None, default_baudrate=9600, default_rts=None, default_dtr=None): |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 640 | import argparse |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 641 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 642 | parser = argparse.ArgumentParser( |
| 643 | description="Miniterm - A simple terminal program for the serial port.") |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 644 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 645 | parser.add_argument("port", |
| 646 | nargs='?', |
| 647 | help="serial port name", |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 648 | default=default_port) |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 649 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 650 | parser.add_argument("baudrate", |
| 651 | nargs='?', |
| 652 | type=int, |
| 653 | help="set baud rate, default: %(default)s", |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 654 | default=default_baudrate) |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 655 | |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 656 | group = parser.add_argument_group("port settings") |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 657 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 658 | group.add_argument("--parity", |
| 659 | choices=['N', 'E', 'O', 'S', 'M'], |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 660 | type=lambda c: c.upper(), |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 661 | help="set parity, one of {N E O S M}, default: N", |
| 662 | default='N') |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 663 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 664 | group.add_argument("--rtscts", |
| 665 | action="store_true", |
| 666 | help="enable RTS/CTS flow control (default off)", |
| 667 | default=False) |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 668 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 669 | group.add_argument("--xonxoff", |
| 670 | action="store_true", |
| 671 | help="enable software flow control (default off)", |
| 672 | default=False) |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 673 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 674 | group.add_argument("--rts", |
| 675 | type=int, |
| 676 | help="set initial RTS line state (possible values: 0, 1)", |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 677 | default=default_rts) |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 678 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 679 | group.add_argument("--dtr", |
| 680 | type=int, |
| 681 | help="set initial DTR line state (possible values: 0, 1)", |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 682 | default=default_dtr) |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 683 | |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 684 | group = parser.add_argument_group("data handling") |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 685 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 686 | group.add_argument("-e", "--echo", |
| 687 | action="store_true", |
| 688 | help="enable local echo (default off)", |
| 689 | default=False) |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 690 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 691 | group.add_argument("--encoding", |
| 692 | dest="serial_port_encoding", |
| 693 | metavar="CODEC", |
Chris Liechti | a7e7b69 | 2015-08-25 21:10:28 +0200 | [diff] [blame^] | 694 | help="set the encoding for the serial port (e.g. hexlify, Latin1, UTF-8), default: %(default)s", |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 695 | default='UTF-8') |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 696 | |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 697 | group.add_argument("-f", "--filter", |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 698 | action="append", |
| 699 | metavar="NAME", |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 700 | help="add text transformation", |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 701 | default=[]) |
Chris Liechti | 2b1b355 | 2015-08-12 15:35:33 +0200 | [diff] [blame] | 702 | |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 703 | group.add_argument("--eol", |
| 704 | choices=['CR', 'LF', 'CRLF'], |
| 705 | type=lambda c: c.upper(), |
| 706 | help="end of line mode", |
| 707 | default='CRLF') |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 708 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 709 | group.add_argument("--raw", |
| 710 | action="store_true", |
| 711 | help="Do no apply any encodings/transformations", |
| 712 | default=False) |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 713 | |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 714 | group = parser.add_argument_group("hotkeys") |
cliechti | b7d746d | 2006-03-28 22:44:30 +0000 | [diff] [blame] | 715 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 716 | group.add_argument("--exit-char", |
| 717 | type=int, |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 718 | metavar='NUM', |
| 719 | help="Unicode of special character that is used to exit the application, default: %(default)s", |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 720 | default=0x1d # GS/CTRL+] |
| 721 | ) |
cliechti | bf6bb7d | 2006-03-30 00:28:18 +0000 | [diff] [blame] | 722 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 723 | group.add_argument("--menu-char", |
| 724 | type=int, |
Chris Liechti | 55ba7d9 | 2015-08-15 16:33:51 +0200 | [diff] [blame] | 725 | metavar='NUM', |
| 726 | help="Unicode code of special character that is used to control miniterm (menu), default: %(default)s", |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 727 | default=0x14 # Menu: CTRL+T |
| 728 | ) |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 729 | |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 730 | group = parser.add_argument_group("diagnostics") |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 731 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 732 | group.add_argument("-q", "--quiet", |
| 733 | action="store_true", |
| 734 | help="suppress non-error messages", |
| 735 | default=False) |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 736 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 737 | group.add_argument("--develop", |
| 738 | action="store_true", |
| 739 | help="show Python traceback on error", |
| 740 | default=False) |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 741 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 742 | args = parser.parse_args() |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 743 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 744 | if args.menu_char == args.exit_char: |
cliechti | 6c8eb2f | 2009-07-08 02:10:46 +0000 | [diff] [blame] | 745 | parser.error('--exit-char can not be the same as --menu-char') |
| 746 | |
cliechti | 9c592b3 | 2008-06-16 22:00:14 +0000 | [diff] [blame] | 747 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 748 | # no port given on command line -> ask user now |
| 749 | if args.port is None: |
| 750 | dump_port_list() |
| 751 | args.port = raw_input('Enter port name:') |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 752 | |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 753 | if args.filter: |
| 754 | if 'help' in args.filter: |
| 755 | sys.stderr.write('Available filters:\n') |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 756 | sys.stderr.write('\n'.join( |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 757 | '{:<10} = {.__doc__}'.format(k, v) |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 758 | for k, v in sorted(TRANSFORMATIONS.items()))) |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 759 | sys.stderr.write('\n') |
| 760 | sys.exit(1) |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 761 | filters = args.filter |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 762 | else: |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 763 | filters = ['default'] |
Chris Liechti | c7a5d4c | 2015-08-11 23:32:20 +0200 | [diff] [blame] | 764 | |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 765 | |
| 766 | try: |
| 767 | miniterm = Miniterm( |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 768 | args.port, |
| 769 | args.baudrate, |
| 770 | args.parity, |
| 771 | rtscts=args.rtscts, |
| 772 | xonxoff=args.xonxoff, |
| 773 | echo=args.echo, |
Chris Liechti | b3df13e | 2015-08-25 02:20:09 +0200 | [diff] [blame] | 774 | eol=args.eol.lower(), |
| 775 | filters=filters, |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 776 | ) |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 777 | miniterm.exit_character = unichr(args.exit_char) |
| 778 | miniterm.menu_character = unichr(args.menu_char) |
| 779 | miniterm.raw = args.raw |
Chris Liechti | d698af7 | 2015-08-24 20:24:55 +0200 | [diff] [blame] | 780 | miniterm.set_rx_encoding(args.serial_port_encoding) |
| 781 | miniterm.set_tx_encoding(args.serial_port_encoding) |
Chris Liechti | 68340d7 | 2015-08-03 14:15:48 +0200 | [diff] [blame] | 782 | except serial.SerialException as e: |
Chris Liechti | accd201 | 2015-08-17 03:09:23 +0200 | [diff] [blame] | 783 | sys.stderr.write('could not open port {}: {}\n'.format(repr(args.port), e)) |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 784 | if args.develop: |
Chris Liechti | 9109091 | 2015-08-05 02:36:14 +0200 | [diff] [blame] | 785 | raise |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 786 | sys.exit(1) |
| 787 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 788 | if not args.quiet: |
Chris Liechti | 1f7ac6c | 2015-08-15 15:16:37 +0200 | [diff] [blame] | 789 | sys.stderr.write('--- Miniterm on {p.name} {p.baudrate},{p.bytesize},{p.parity},{p.stopbits} ---\n'.format( |
| 790 | p=miniterm.serial)) |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 791 | sys.stderr.write('--- Quit: {} | Menu: {} | Help: {} followed by {} ---\n'.format( |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 792 | key_description(miniterm.exit_character), |
| 793 | key_description(miniterm.menu_character), |
| 794 | key_description(miniterm.menu_character), |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 795 | key_description('\x08'), |
Chris Liechti | 442bf51 | 2015-08-15 01:42:24 +0200 | [diff] [blame] | 796 | )) |
cliechti | 6fa76fb | 2009-07-08 23:53:39 +0000 | [diff] [blame] | 797 | |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 798 | if args.dtr is not None: |
| 799 | if not args.quiet: |
| 800 | sys.stderr.write('--- forcing DTR {}\n'.format('active' if args.dtr else 'inactive')) |
| 801 | miniterm.serial.setDTR(args.dtr) |
| 802 | miniterm.dtr_state = args.dtr |
| 803 | if args.rts is not None: |
| 804 | if not args.quiet: |
| 805 | sys.stderr.write('--- forcing RTS {}\n'.format('active' if args.rts else 'inactive')) |
| 806 | miniterm.serial.setRTS(args.rts) |
| 807 | miniterm.rts_state = args.rts |
cliechti | 53edb47 | 2009-02-06 21:18:46 +0000 | [diff] [blame] | 808 | |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 809 | miniterm.start() |
cliechti | 258ab0a | 2011-03-21 23:03:45 +0000 | [diff] [blame] | 810 | try: |
| 811 | miniterm.join(True) |
| 812 | except KeyboardInterrupt: |
| 813 | pass |
Chris Liechti | b7550bd | 2015-08-15 04:09:10 +0200 | [diff] [blame] | 814 | if not args.quiet: |
cliechti | bf6bb7d | 2006-03-30 00:28:18 +0000 | [diff] [blame] | 815 | sys.stderr.write("\n--- exit ---\n") |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 816 | miniterm.join() |
cliechti | bf6bb7d | 2006-03-30 00:28:18 +0000 | [diff] [blame] | 817 | |
cliechti | 5370cee | 2013-10-13 03:08:19 +0000 | [diff] [blame] | 818 | # - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - |
cliechti | 8b3ad39 | 2002-03-03 20:12:21 +0000 | [diff] [blame] | 819 | if __name__ == '__main__': |
cliechti | 6385f2c | 2005-09-21 19:51:19 +0000 | [diff] [blame] | 820 | main() |