| 
									
										
										
										
											2017-06-05 16:02:39 +03:00
										 |  |  | # Copyright (c) 2014-present PlatformIO <contact@platformio.org> | 
					
						
							| 
									
										
										
										
											2015-11-18 17:16:17 +02:00
										 |  |  | # | 
					
						
							|  |  |  | # Licensed under the Apache License, Version 2.0 (the "License"); | 
					
						
							|  |  |  | # you may not use this file except in compliance with the License. | 
					
						
							|  |  |  | # You may obtain a copy of the License at | 
					
						
							|  |  |  | # | 
					
						
							|  |  |  | #    http://www.apache.org/licenses/LICENSE-2.0 | 
					
						
							|  |  |  | # | 
					
						
							|  |  |  | # Unless required by applicable law or agreed to in writing, software | 
					
						
							|  |  |  | # distributed under the License is distributed on an "AS IS" BASIS, | 
					
						
							|  |  |  | # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
					
						
							|  |  |  | # See the License for the specific language governing permissions and | 
					
						
							|  |  |  | # limitations under the License. | 
					
						
							| 
									
										
										
										
											2014-07-27 22:29:32 +03:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2015-01-05 22:58:55 +02:00
										 |  |  | import json | 
					
						
							| 
									
										
										
										
											2014-08-09 23:13:29 +03:00
										 |  |  | import sys | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  | from os import getcwd | 
					
						
							| 
									
										
										
										
											2014-08-09 23:13:29 +03:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-12-03 20:16:50 +02:00
										 |  |  | import click | 
					
						
							| 
									
										
										
										
											2014-08-09 23:13:29 +03:00
										 |  |  | from serial.tools import miniterm | 
					
						
							| 
									
										
										
										
											2014-07-27 22:29:32 +03:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  | from platformio import exception, util | 
					
						
							| 
									
										
										
										
											2014-07-27 22:29:32 +03:00
										 |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-08-26 14:25:50 +03:00
										 |  |  | @click.group(short_help="Monitor device or list existing") | 
					
						
							| 
									
										
										
										
											2014-07-27 22:29:32 +03:00
										 |  |  | def cli(): | 
					
						
							| 
									
										
										
										
											2014-08-09 23:13:29 +03:00
										 |  |  |     pass | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-08-26 14:25:50 +03:00
										 |  |  | @cli.command("list", short_help="List devices") | 
					
						
							| 
									
										
										
										
											2017-12-18 21:31:49 +02:00
										 |  |  | @click.option("--serial", is_flag=True, help="List serial ports, default") | 
					
						
							|  |  |  | @click.option("--logical", is_flag=True, help="List logical devices") | 
					
						
							|  |  |  | @click.option("--mdns", is_flag=True, help="List multicast DNS services") | 
					
						
							| 
									
										
										
										
											2015-01-02 21:03:14 +02:00
										 |  |  | @click.option("--json-output", is_flag=True) | 
					
						
							| 
									
										
										
										
											2017-12-18 21:31:49 +02:00
										 |  |  | def device_list(  # pylint: disable=too-many-branches | 
					
						
							|  |  |  |         serial, logical, mdns, json_output): | 
					
						
							|  |  |  |     if not logical and not mdns: | 
					
						
							|  |  |  |         serial = True | 
					
						
							|  |  |  |     data = {} | 
					
						
							|  |  |  |     if serial: | 
					
						
							|  |  |  |         data['serial'] = util.get_serial_ports() | 
					
						
							|  |  |  |     if logical: | 
					
						
							|  |  |  |         data['logical'] = util.get_logical_devices() | 
					
						
							|  |  |  |     if mdns: | 
					
						
							|  |  |  |         data['mdns'] = util.get_mdns_services() | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     single_key = data.keys()[0] if len(data.keys()) == 1 else None | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2015-01-02 21:03:14 +02:00
										 |  |  |     if json_output: | 
					
						
							| 
									
										
										
										
											2017-12-18 21:31:49 +02:00
										 |  |  |         return click.echo(json.dumps(data[single_key] if single_key else data)) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     titles = { | 
					
						
							|  |  |  |         "serial": "Serial Ports", | 
					
						
							|  |  |  |         "logical": "Logical Devices", | 
					
						
							|  |  |  |         "mdns": "Multicast DNS Services" | 
					
						
							|  |  |  |     } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     for key, value in data.iteritems(): | 
					
						
							|  |  |  |         if not single_key: | 
					
						
							|  |  |  |             click.secho(titles[key], bold=True) | 
					
						
							|  |  |  |             click.echo("=" * len(titles[key])) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |         if key == "serial": | 
					
						
							|  |  |  |             for item in value: | 
					
						
							|  |  |  |                 click.secho(item['port'], fg="cyan") | 
					
						
							|  |  |  |                 click.echo("-" * len(item['port'])) | 
					
						
							|  |  |  |                 click.echo("Hardware ID: %s" % item['hwid']) | 
					
						
							|  |  |  |                 click.echo("Description: %s" % item['description']) | 
					
						
							|  |  |  |                 click.echo("") | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |         if key == "logical": | 
					
						
							|  |  |  |             for item in value: | 
					
						
							| 
									
										
										
										
											2017-12-27 16:02:36 +02:00
										 |  |  |                 click.secho(item['path'], fg="cyan") | 
					
						
							|  |  |  |                 click.echo("-" * len(item['path'])) | 
					
						
							| 
									
										
										
										
											2017-12-18 21:31:49 +02:00
										 |  |  |                 click.echo("Name: %s" % item['name']) | 
					
						
							|  |  |  |                 click.echo("") | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |         if key == "mdns": | 
					
						
							|  |  |  |             for item in value: | 
					
						
							|  |  |  |                 click.secho(item['name'], fg="cyan") | 
					
						
							|  |  |  |                 click.echo("-" * len(item['name'])) | 
					
						
							|  |  |  |                 click.echo("Type: %s" % item['type']) | 
					
						
							|  |  |  |                 click.echo("IP: %s" % item['ip']) | 
					
						
							|  |  |  |                 click.echo("Port: %s" % item['port']) | 
					
						
							|  |  |  |                 if item['properties']: | 
					
						
							|  |  |  |                     click.echo("Properties: %s" % ("; ".join([ | 
					
						
							|  |  |  |                         "%s=%s" % (k, v) | 
					
						
							|  |  |  |                         for k, v in item['properties'].iteritems() | 
					
						
							|  |  |  |                     ]))) | 
					
						
							|  |  |  |                 click.echo("") | 
					
						
							| 
									
										
										
										
											2014-07-27 22:29:32 +03:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-12-18 21:31:49 +02:00
										 |  |  |         if single_key: | 
					
						
							|  |  |  |             click.echo("") | 
					
						
							| 
									
										
										
										
											2014-08-09 23:13:29 +03:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2017-12-15 22:16:37 +02:00
										 |  |  |     return True | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2014-08-09 23:13:29 +03:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  | @cli.command("monitor", short_help="Monitor device (Serial)") | 
					
						
							|  |  |  | @click.option("--port", "-p", help="Port, a number or a device name") | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  | @click.option("--baud", "-b", type=int, help="Set baud rate, default=9600") | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  | @click.option( | 
					
						
							|  |  |  |     "--parity", | 
					
						
							|  |  |  |     default="N", | 
					
						
							|  |  |  |     type=click.Choice(["N", "E", "O", "S", "M"]), | 
					
						
							|  |  |  |     help="Set parity, default=N") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--rtscts", is_flag=True, help="Enable RTS/CTS flow control, default=Off") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--xonxoff", | 
					
						
							|  |  |  |     is_flag=True, | 
					
						
							|  |  |  |     help="Enable software flow control, default=Off") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--rts", | 
					
						
							|  |  |  |     default=None, | 
					
						
							| 
									
										
										
										
											2017-01-23 00:13:58 +02:00
										 |  |  |     type=click.IntRange(0, 1), | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  |     help="Set initial RTS line state") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--dtr", | 
					
						
							|  |  |  |     default=None, | 
					
						
							| 
									
										
										
										
											2017-01-23 00:13:58 +02:00
										 |  |  |     type=click.IntRange(0, 1), | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  |     help="Set initial DTR line state") | 
					
						
							|  |  |  | @click.option("--echo", is_flag=True, help="Enable local echo, default=Off") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--encoding", | 
					
						
							|  |  |  |     default="UTF-8", | 
					
						
							|  |  |  |     help="Set the encoding for the serial port (e.g. hexlify, " | 
					
						
							|  |  |  |     "Latin1, UTF-8), default: UTF-8") | 
					
						
							|  |  |  | @click.option("--filter", "-f", multiple=True, help="Add text transformation") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--eol", | 
					
						
							|  |  |  |     default="CRLF", | 
					
						
							|  |  |  |     type=click.Choice(["CR", "LF", "CRLF"]), | 
					
						
							|  |  |  |     help="End of line mode, default=CRLF") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--raw", is_flag=True, help="Do not apply any encodings/transformations") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--exit-char", | 
					
						
							|  |  |  |     type=int, | 
					
						
							|  |  |  |     default=3, | 
					
						
							|  |  |  |     help="ASCII code of special character that is used to exit " | 
					
						
							|  |  |  |     "the application, default=3 (Ctrl+C)") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--menu-char", | 
					
						
							|  |  |  |     type=int, | 
					
						
							|  |  |  |     default=20, | 
					
						
							|  |  |  |     help="ASCII code of special character that is used to " | 
					
						
							|  |  |  |     "control miniterm (menu), default=20 (DEC)") | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "--quiet", | 
					
						
							|  |  |  |     is_flag=True, | 
					
						
							|  |  |  |     help="Diagnostics: suppress non-error messages, default=Off") | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  | @click.option( | 
					
						
							|  |  |  |     "-d", | 
					
						
							|  |  |  |     "--project-dir", | 
					
						
							|  |  |  |     default=getcwd, | 
					
						
							|  |  |  |     type=click.Path( | 
					
						
							|  |  |  |         exists=True, file_okay=False, dir_okay=True, resolve_path=True)) | 
					
						
							|  |  |  | @click.option( | 
					
						
							|  |  |  |     "-e", | 
					
						
							|  |  |  |     "--environment", | 
					
						
							|  |  |  |     help="Load configuration from `platformio.ini` and specified environment") | 
					
						
							|  |  |  | def device_monitor(**kwargs):  # pylint: disable=too-many-branches | 
					
						
							|  |  |  |     try: | 
					
						
							|  |  |  |         project_options = get_project_options(kwargs['project_dir'], | 
					
						
							|  |  |  |                                               kwargs['environment']) | 
					
						
							|  |  |  |         monitor_options = {k: v for k, v in project_options or []} | 
					
						
							|  |  |  |         if monitor_options: | 
					
						
							|  |  |  |             for k in ("port", "baud", "rts", "dtr"): | 
					
						
							|  |  |  |                 k2 = "monitor_%s" % k | 
					
						
							|  |  |  |                 if kwargs[k] is None and k2 in monitor_options: | 
					
						
							|  |  |  |                     kwargs[k] = monitor_options[k2] | 
					
						
							|  |  |  |                     if k != "port": | 
					
						
							|  |  |  |                         kwargs[k] = int(kwargs[k]) | 
					
						
							|  |  |  |     except exception.NotPlatformIOProject: | 
					
						
							|  |  |  |         pass | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  |     if not kwargs['port']: | 
					
						
							| 
									
										
										
										
											2017-12-18 21:31:49 +02:00
										 |  |  |         ports = util.get_serial_ports(filter_hwid=True) | 
					
						
							| 
									
										
										
										
											2016-10-31 20:06:48 +02:00
										 |  |  |         if len(ports) == 1: | 
					
						
							|  |  |  |             kwargs['port'] = ports[0]['port'] | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  | 
 | 
					
						
							|  |  |  |     sys.argv = ["monitor"] | 
					
						
							|  |  |  |     for k, v in kwargs.iteritems(): | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  |         if k in ("port", "baud", "rts", "dtr", "environment", "project_dir"): | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  |             continue | 
					
						
							|  |  |  |         k = "--" + k.replace("_", "-") | 
					
						
							|  |  |  |         if isinstance(v, bool): | 
					
						
							|  |  |  |             if v: | 
					
						
							|  |  |  |                 sys.argv.append(k) | 
					
						
							|  |  |  |         elif isinstance(v, tuple): | 
					
						
							|  |  |  |             for i in v: | 
					
						
							|  |  |  |                 sys.argv.extend([k, i]) | 
					
						
							|  |  |  |         else: | 
					
						
							|  |  |  |             sys.argv.extend([k, str(v)]) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     try: | 
					
						
							| 
									
										
										
										
											2016-10-31 20:06:48 +02:00
										 |  |  |         miniterm.main( | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  |             default_port=kwargs['port'], | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  |             default_baudrate=kwargs['baud'] or 9600, | 
					
						
							| 
									
										
										
										
											2016-10-31 18:13:41 +02:00
										 |  |  |             default_rts=kwargs['rts'], | 
					
						
							|  |  |  |             default_dtr=kwargs['dtr']) | 
					
						
							| 
									
										
										
										
											2016-10-31 20:06:48 +02:00
										 |  |  |     except Exception as e: | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  |         raise exception.MinitermException(e) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | def get_project_options(project_dir, environment): | 
					
						
							|  |  |  |     config = util.load_project_config(project_dir) | 
					
						
							|  |  |  |     if not config.sections(): | 
					
						
							| 
									
										
										
										
											2017-12-15 22:16:37 +02:00
										 |  |  |         return None | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  | 
 | 
					
						
							|  |  |  |     known_envs = [s[4:] for s in config.sections() if s.startswith("env:")] | 
					
						
							|  |  |  |     if environment: | 
					
						
							|  |  |  |         if environment in known_envs: | 
					
						
							|  |  |  |             return config.items("env:%s" % environment) | 
					
						
							|  |  |  |         raise exception.UnknownEnvNames(environment, ", ".join(known_envs)) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     if not known_envs: | 
					
						
							| 
									
										
										
										
											2017-12-15 22:16:37 +02:00
										 |  |  |         return None | 
					
						
							| 
									
										
										
										
											2017-06-07 02:32:25 +03:00
										 |  |  | 
 | 
					
						
							|  |  |  |     if config.has_option("platformio", "env_default"): | 
					
						
							|  |  |  |         env_default = config.get("platformio", | 
					
						
							|  |  |  |                                  "env_default").split(", ")[0].strip() | 
					
						
							|  |  |  |         if env_default and env_default in known_envs: | 
					
						
							|  |  |  |             return config.items("env:%s" % env_default) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  |     return config.items("env:%s" % known_envs[0]) |