Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 # Copyright 2014 The Chromium Authors. All rights reserved. | 1 # Copyright 2014 The Chromium Authors. All rights reserved. |
| 2 # Use of this source code is governed by a BSD-style license that can be | 2 # Use of this source code is governed by a BSD-style license that can be |
| 3 # found in the LICENSE file. | 3 # found in the LICENSE file. |
| 4 | 4 |
| 5 """Environment setup and teardown for remote devices.""" | 5 """Environment setup and teardown for remote devices.""" |
| 6 | 6 |
| 7 from distutils.version import LooseVersion | |
|
jbudorick
2015/01/27 17:58:55
Do we know we'll have this everywhere?
Also, if t
rnephew (Wrong account)
2015/01/27 18:46:21
I didnt' have to install it, and as far as I can f
| |
| 8 import json | |
| 7 import logging | 9 import logging |
| 8 import os | 10 import os |
| 9 import random | 11 import random |
| 10 import sys | 12 import sys |
| 11 | 13 |
| 12 from pylib import constants | 14 from pylib import constants |
| 13 from pylib.base import environment | 15 from pylib.base import environment |
| 14 from pylib.remote.device import appurify_sanitized | 16 from pylib.remote.device import appurify_sanitized |
| 15 from pylib.remote.device import remote_device_helper | 17 from pylib.remote.device import remote_device_helper |
| 16 | 18 |
| (...skipping 10 matching lines...) Expand all Loading... | |
| 27 args: Command line arguments. | 29 args: Command line arguments. |
| 28 error_func: error to show when using bad command line arguments. | 30 error_func: error to show when using bad command line arguments. |
| 29 """ | 31 """ |
| 30 super(RemoteDeviceEnvironment, self).__init__() | 32 super(RemoteDeviceEnvironment, self).__init__() |
| 31 | 33 |
| 32 if args.api_key_file: | 34 if args.api_key_file: |
| 33 with open(args.api_key_file) as api_key_file: | 35 with open(args.api_key_file) as api_key_file: |
| 34 self._api_key = api_key_file.read().strip() | 36 self._api_key = api_key_file.read().strip() |
| 35 elif args.api_key: | 37 elif args.api_key: |
| 36 self._api_key = args.api_key | 38 self._api_key = args.api_key |
| 37 else: | |
| 38 error_func('Must set api key with --api-key or --api-key-file') | |
| 39 | 39 |
| 40 if args.api_secret_file: | 40 if args.api_secret_file: |
| 41 with open(args.api_secret_file) as api_secret_file: | 41 with open(args.api_secret_file) as api_secret_file: |
| 42 self._api_secret = api_secret_file.read().strip() | 42 self._api_secret = api_secret_file.read().strip() |
| 43 elif args.api_secret: | 43 elif args.api_secret: |
| 44 self._api_secret = args.api_secret | 44 self._api_secret = args.api_secret |
| 45 else: | |
| 46 error_func('Must set api secret with --api-secret or --api-secret-file') | |
| 47 | 45 |
| 48 if not args.api_protocol: | |
| 49 error_func('Must set api protocol with --api-protocol. Example: http') | |
| 50 self._api_protocol = args.api_protocol | 46 self._api_protocol = args.api_protocol |
| 51 | |
| 52 if not args.api_address: | |
| 53 error_func('Must set api address with --api-address') | |
| 54 self._api_address = args.api_address | 47 self._api_address = args.api_address |
| 55 | |
| 56 if not args.api_port: | |
| 57 error_func('Must set api port with --api-port.') | |
| 58 self._api_port = args.api_port | 48 self._api_port = args.api_port |
| 59 | 49 |
| 60 self._access_token = '' | 50 self._access_token = '' |
| 61 self._results_path = args.results_path | 51 self._results_path = args.results_path |
| 62 self._remote_device = args.remote_device | 52 if args.remote_device: |
| 63 self._remote_device_os = args.remote_device_os | 53 self._remote_device = args.remote_device.split(',') |
|
jbudorick
2015/01/27 17:58:55
I'm not sure these should necessarily support mult
rnephew (Wrong account)
2015/01/27 18:46:21
Done.
| |
| 54 else: | |
| 55 self._remote_device = '' | |
| 56 if args.remote_device_os: | |
| 57 self._remote_device_os = args.remote_device_os.split(',') | |
|
jbudorick
2015/01/27 17:58:55
ditto
rnephew (Wrong account)
2015/01/27 18:46:21
Done.
| |
| 58 else: | |
| 59 self._remote_device_os = '' | |
| 60 self._remote_device_minimum_os = args.remote_device_minimum_os | |
| 64 self._runner_package = args.runner_package | 61 self._runner_package = args.runner_package |
| 65 self._runner_type = args.runner_type | 62 self._runner_type = args.runner_type |
| 66 self._device = '' | 63 self._device = '' |
| 67 self._verbose_count = args.verbose_count | 64 self._verbose_count = args.verbose_count |
| 68 self._device_type = args.device_type | 65 self._device_type = args.device_type |
| 69 self._timeouts = { | 66 self._timeouts = { |
| 70 'queueing': 60 * 10, | 67 'queueing': 60 * 10, |
| 71 'installing': 60 * 10, | 68 'installing': 60 * 10, |
| 72 'in-progress': 60 * 30, | 69 'in-progress': 60 * 30, |
| 73 'unknown': 60 * 5 | 70 'unknown': 60 * 5 |
| 74 } | 71 } |
| 72 if args.remote_device_file: | |
| 73 with open(args.remote_device_file) as device_file: | |
| 74 device_json = json.load(device_file) | |
| 75 if 'remote_device' in device_json: | |
| 76 self._remote_device = device_json['remote_device'].split(',') | |
|
jbudorick
2015/01/27 17:58:55
oh, it is json.
Why aren't remote_device and remo
rnephew (Wrong account)
2015/01/27 18:46:21
Done.
| |
| 77 if 'remote_device_os' in device_json: | |
| 78 self._remote_device_os = device_json['remote_device_os'].split(',') | |
| 79 if 'remote_device_minimum_os' in device_json: | |
| 80 self._remote_device_minimum_os = ( | |
| 81 device_json['remote_device_minimum_os']) | |
| 82 if 'api_address' in device_json: | |
| 83 self._api_address = device_json['api_address'] | |
| 84 if 'api_secret' in device_json: | |
| 85 self._api_secret = device_json['api_secret'] | |
| 86 if 'api_key' in device_json: | |
| 87 self._api_key = device_json['api_key'] | |
|
jbudorick
2015/01/27 17:58:55
Most of these can just be
self._blah = device_j
rnephew (Wrong account)
2015/01/27 18:46:21
I went with ..get('blah', self._blah) that way if
| |
| 88 if 'api_protocol' in device_json: | |
| 89 self._api_protocol = device_json['api_protocol'] | |
| 90 if 'api_port' in device_json: | |
| 91 self._api_port = device_json['api_port'] | |
| 92 if 'timeouts' in device_json: | |
| 93 self._timeouts = device_json['timeouts'] | |
| 94 | |
| 95 if not self._api_address: | |
| 96 error_func('Must set api address with --api-address' | |
| 97 'or in --remote-device-file.') | |
| 98 if not self._api_protocol: | |
| 99 error_func('Must set api protocol with --api-protocol' | |
| 100 ' or in --remote-device-file. Example: http') | |
| 101 if not self._api_key: | |
| 102 error_func('Must set api key with --api-key, --api-key-file' | |
| 103 'or in --remote-device-file') | |
| 104 if not self._api_secret: | |
| 105 error_func('Must set api secret with --api-secret, --api-secret-file' | |
| 106 'or in --remote-device-file') | |
| 107 if not self._api_port: | |
| 108 error_func('Must set api port with --api-port' | |
| 109 'or in --remote-device-file') | |
| 110 if not isinstance(self._timeouts, dict): | |
| 111 error_func('Timeouts must be a dictionary.') | |
| 112 if ('queueing' not in self._timeouts | |
| 113 or 'installing' not in self._timeouts | |
| 114 or 'in-progress' not in self._timeouts | |
| 115 or 'unknown' not in self._timeouts) : | |
| 116 error_func('Timeouts must contain queueing,' | |
| 117 ' installing, in-progress, and unknown.') | |
| 118 # Sanitize inputs. | |
| 119 for x in range(0,len(self._remote_device)): | |
| 120 self._remote_device[x] = self._remote_device[x].strip() | |
| 121 for y in range(0,len(self._remote_device_os)): | |
| 122 self._remote_device_os[y] = self._remote_device_os[y].strip() | |
| 75 | 123 |
| 76 if not args.trigger and not args.collect: | 124 if not args.trigger and not args.collect: |
| 77 self._trigger = True | 125 self._trigger = True |
| 78 self._collect = True | 126 self._collect = True |
| 79 else: | 127 else: |
| 80 self._trigger = args.trigger | 128 self._trigger = args.trigger |
| 81 self._collect = args.collect | 129 self._collect = args.collect |
| 82 | 130 |
| 83 def SetUp(self): | 131 def SetUp(self): |
| 84 """Set up the test environment.""" | 132 """Set up the test environment.""" |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 143 with appurify_sanitized.SanitizeLogging(self._verbose_count, | 191 with appurify_sanitized.SanitizeLogging(self._verbose_count, |
| 144 logging.WARNING): | 192 logging.WARNING): |
| 145 dev_list_res = appurify_sanitized.api.devices_list(self._access_token) | 193 dev_list_res = appurify_sanitized.api.devices_list(self._access_token) |
| 146 remote_device_helper.TestHttpResponse(dev_list_res, | 194 remote_device_helper.TestHttpResponse(dev_list_res, |
| 147 'Unable to generate access token.') | 195 'Unable to generate access token.') |
| 148 device_list = dev_list_res.json()['response'] | 196 device_list = dev_list_res.json()['response'] |
| 149 random.shuffle(device_list) | 197 random.shuffle(device_list) |
| 150 for device in device_list: | 198 for device in device_list: |
| 151 if device['os_name'] != self._device_type: | 199 if device['os_name'] != self._device_type: |
| 152 continue | 200 continue |
| 153 if self._remote_device and device['name'] != self._remote_device: | 201 if self._remote_device and device['name'] not in self._remote_device: |
| 154 continue | 202 continue |
| 155 if (self._remote_device_os | 203 if (self._remote_device_os |
| 156 and device['os_version'] != self._remote_device_os): | 204 and device['os_version'] not in self._remote_device_os): |
| 205 continue | |
| 206 if (self._remote_device_minimum_os | |
| 207 and LooseVersion(device['os_version']) | |
| 208 < LooseVersion(self._remote_device_minimum_os)): | |
| 157 continue | 209 continue |
| 158 if ((self._remote_device and self._remote_device_os) | 210 if ((self._remote_device and self._remote_device_os) |
| 159 or device['available_devices_count']): | 211 or device['available_devices_count']): |
| 160 logging.info('Found device: %s %s', | 212 logging.info('Found device: %s %s', |
| 161 device['name'], device['os_version']) | 213 device['name'], device['os_version']) |
| 162 return device | 214 return device |
| 163 self._NoDeviceFound(device_list) | 215 self._NoDeviceFound(device_list) |
| 164 | 216 |
| 165 def _PrintAvailableDevices(self, device_list): | 217 def _PrintAvailableDevices(self, device_list): |
| 166 def compare_devices(a,b): | 218 def compare_devices(a,b): |
| (...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 216 def trigger(self): | 268 def trigger(self): |
| 217 return self._trigger | 269 return self._trigger |
| 218 | 270 |
| 219 @property | 271 @property |
| 220 def verbose_count(self): | 272 def verbose_count(self): |
| 221 return self._verbose_count | 273 return self._verbose_count |
| 222 | 274 |
| 223 @property | 275 @property |
| 224 def device_type(self): | 276 def device_type(self): |
| 225 return self._device_type | 277 return self._device_type |
| OLD | NEW |