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() |
+ |