Chromium Code Reviews| Index: tools/perf/profile_creators/extension_profile_extender.py |
| diff --git a/tools/perf/profile_creators/extension_profile_extender.py b/tools/perf/profile_creators/extension_profile_extender.py |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..ff9429d07e14d33015448bfab4a7b82ae86f4cdc |
| --- /dev/null |
| +++ b/tools/perf/profile_creators/extension_profile_extender.py |
| @@ -0,0 +1,134 @@ |
| +# Copyright 2015 The Chromium Authors. All rights reserved. |
| +# Use of this source code is governed by a BSD-style license that can be |
| +# found in the LICENSE file. |
| + |
| +import json |
| +import os |
| +import platform |
| +import zipfile |
| + |
| +from catapult_base import cloud_storage |
| +import page_sets |
| +from profile_creators import fast_navigation_profile_extender |
| +from telemetry.core import exceptions |
| + |
| + |
| +# Remote target upload directory in cloud storage for extensions. |
| +REMOTE_DIR = 'extension_set' |
| + |
| +# Target zip file. |
| +ZIP_NAME = 'extensions.zip' |
| + |
| + |
| +class InvalidExtensionArchiveError(exceptions.Error): |
| + """Exception thrown when remote archive is invalid or malformed. |
| + |
| + Remote archive should be located at REMOTE_DIR/ZIP_NAME. Upon failure, |
| + prompts user to update remote archive using update_remote_extensions |
| + script. |
| + """ |
| + |
| + def __init__(self, msg=''): |
| + msg += ('\nTry running\n' |
| + '\tpython update_remote_extensions.py -e extension_set.csv\n' |
| + 'in src/tools/perf/profile_creator subdirectory.') |
| + super(InvalidExtensionArchiveError, self).__init__(msg) |
| + |
| + |
| +class ExtensionProfileExtender( |
| + fast_navigation_profile_extender.FastNavigationProfileExtender): |
| + """Creates a profile with many extensions.""" |
| + |
| + def __init__(self, finder_options): |
| + super(ExtensionProfileExtender, self).__init__(finder_options, |
| + maximum_batch_size=1) |
| + self._page_set = page_sets.BlankPageSet() |
| + urls = [story.url for story in self._page_set.stories] |
| + self._navigation_urls = urls |
| + finder_options.browser_options.disable_default_apps = False |
| + |
| + def _DownloadRemoteExtensions(self, remote_bucket, local_extensions_dir): |
| + """Downloads and unzips archive of common extensions to disk. |
| + |
| + Args: |
| + remote_bucket: bucket to download remote archive from. |
| + local_extensions_dir: destination extensions directory. |
| + |
| + Raises: |
| + InvalidExtensionArchiveError if remote archive is not found. |
| + """ |
| + remote_zip_path = os.path.join(REMOTE_DIR, ZIP_NAME) |
| + local_zip_path = os.path.join(local_extensions_dir, ZIP_NAME) |
| + try: |
| + cloud_storage.Get(remote_bucket, remote_zip_path, local_zip_path) |
| + except: |
| + raise InvalidExtensionArchiveError('Can\'t find archive at gs://%s/%s..' |
| + % (remote_bucket, remote_zip_path)) |
| + try: |
| + with zipfile.ZipFile(local_zip_path, 'r') as extensions_zip: |
| + extensions_zip.extractall(local_extensions_dir) |
| + finally: |
| + os.remove(local_zip_path) |
| + |
| + def _GetExtensionInfoFromCrx(self, crxfile): |
| + """Retrieves version + name of extension from CRX archive.""" |
| + crx_zip = zipfile.ZipFile(crxfile) |
| + manifest_contents = crx_zip.read('manifest.json') |
| + decoded_manifest = json.loads(manifest_contents) |
| + crx_version = decoded_manifest['version'] |
| + extension_name = decoded_manifest['name'] |
| + return (crx_version, extension_name) |
| + |
| + def _LoadExtensions(self, local_extensions_dir, profile_dir): |
| + """Loads extensions in _local_extensions_dir into user profile. |
| + |
| + Extensions are loaded according to platform specifications at |
| + https://developer.chrome.com/extensions/external_extensions.html |
| + |
| + Args: |
| + local_extensions_dir: directory containing CRX files. |
| + profile_dir: target profile directory for the extensions. |
| + |
| + Raises: |
| + InvalidExtensionArchiveError if archive contains a non-CRX file. |
| + """ |
| + ext_files = os.listdir(local_extensions_dir) |
| + external_ext_dir = os.path.join(profile_dir, 'External Extensions') |
| + os.makedirs(external_ext_dir) |
| + for ext_file in ext_files: |
| + ext_path = os.path.join(local_extensions_dir, ext_file) |
| + if not ext_file.endswith('.crx'): |
| + raise InvalidExtensionArchiveError('Archive contains non-crx file %s.' |
| + % ext_file) |
| + (version, name) = self._GetExtensionInfoFromCrx(ext_path) |
| + extension_info = { |
| + 'external_crx': ext_path, |
| + 'external_version': version, |
| + '_comment': name |
| + } |
| + ext_id = os.path.splitext(os.path.basename(ext_path))[0] |
| + extension_json_path = os.path.join(external_ext_dir, '%s.json' % ext_id) |
| + with open(extension_json_path, 'w') as f: |
| + f.write(json.dumps(extension_info)) |
| + |
| + def GetUrlIterator(self): |
| + """Superclass override.""" |
| + return iter(self._navigation_urls) |
| + |
| + def ShouldExitAfterBatchNavigation(self): |
| + """Superclass override.""" |
| + return False |
| + |
| + def Run(self): |
| + # Download extensions from cloud & force-install extensions into profile. |
| + if platform.system() != 'Darwin': |
|
nednguyen
2015/07/17 21:48:07
This part is not correct, the platform telemetry i
sydli
2015/07/17 22:29:27
Would this be the correct query?
https://code.goog
nednguyen
2015/07/17 22:49:08
Yeah, but you need to get the pointer to platform.
erikchen
2015/07/17 22:50:33
Yeah, you want to use the platform of the possible
sydli
2015/07/20 21:33:41
done; additions to profile extender to restrict th
|
| + raise NotImplementedError( |
| + 'Extension profile generator on %s is not yet supported' |
| + % platform.system()) |
| + local_extensions_dir = os.path.join(self.profile_path, |
| + 'external_extensions_crx') |
| + self._DownloadRemoteExtensions(cloud_storage.PARTNER_BUCKET, |
| + local_extensions_dir) |
| + self._LoadExtensions(local_extensions_dir, self.profile_path) |
| + super(ExtensionProfileExtender, self).Run() |
| + |