Converted Android Chromedriver buildbot scripts to recipes.

scripts/slave/recipe_modules/gsutil/api.py

 # Copyright 2013 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 re
 
 from recipe_engine import recipe_api
 
 class GSUtilApi(recipe_api.RecipeApi):
   def __call__(self, cmd, name=None, use_retry_wrapper=True, version='3.25',
@@ skipping 70 matching lines @@
     args = args or []
     url = self._normalize_url(url)
     cmd = ['cp'] + args + [url, dest]
     name = kwargs.pop('name', 'download')
     self(cmd, name, **kwargs)
 
   def cat(self, url, args=None, **kwargs):
     args = args or []
     url = self._normalize_url(url)
     cmd = ['cat'] + args + [url]
-    name = kwargs.pop('name', 'download')
+    name = kwargs.pop('name', 'cat')
     return self(cmd, name, **kwargs)
 
   def copy(self, source_bucket, source, dest_bucket, dest, args=None,
            link_name='gsutil.copy', metadata=None, unauthenticated_url=False,
            **kwargs):
     args = args or []
     args += self._generate_metadata_args(metadata)
     full_source = 'gs://%s/%s' % (source_bucket, source)
     full_dest = 'gs://%s/%s' % (dest_bucket, dest)
     cmd = ['cp'] + args + [full_source, full_dest]
     name = kwargs.pop('name', 'copy')
 
     result = self(cmd, name, **kwargs)
 
     if link_name:
       result.presentation.links[link_name] = self._http_url(
           dest_bucket, dest, unauthenticated_url=unauthenticated_url)
 
+  def list(self, url, args=None, **kwargs):
+    args = args or []
+    url = self._normalize_url(url)
+    cmd = ['ls'] + args + [url]
+    name = kwargs.pop('name', 'list')
+    return self(cmd, name, **kwargs)
+
   def signurl(self, private_key_file, bucket, dest, args=None,
               **kwargs):
     args = args or []
     full_source = 'gs://%s/%s' % (bucket, dest)
     cmd = ['signurl'] + args + [private_key_file, full_source]
     name = kwargs.pop('name', 'signurl')
     return self(cmd, name, **kwargs)
 
   def remove_url(self, url, args=None, **kwargs):
     args = args or []
@@ skipping 21 matching lines @@
     args = ['--poll',
             '--url', url,
             '--dst', destination,
             '--poll-interval', str(poll_interval),
             '--timeout', str(timeout)]
     return self.m.python(name,
                          gsutil_download_path,
                          args,
                          cwd=self.m.path['slave_build'])
 
+  def download_latest_file(self, base_url, partial_name, destination,
+                           name='Download latest file from GS'):
+    """Get the latest archived object with the given base url and partial name.
+
+    Args:
+      base_url: Base Google Storage archive URL (gs://...) containing the build.
+      partial_name: Partial name of the archive file to download.
+      destination: Destination file/directory where the file will be downloaded.
+      name: The name of the step.
+    """
+    gsutil_download_path = self.m.path['build'].join(
+        'scripts', 'slave', 'gsutil_download.py')
+    args = ['--url', base_url,
+            '--dst', destination,
+            '--partial-name', partial_name]
+    return self.m.python(name,
+                         gsutil_download_path,
+                         args,
+                         cwd=self.m.path['slave_build'])
+
   def _generate_metadata_args(self, metadata):
     result = []
     if metadata:
       for k, v in sorted(metadata.iteritems(), key=lambda (k, _): k):
         field = self._get_metadata_field(k)
         param = (field) if v is None else ('%s:%s' % (field, v))
         result += ['-h', param]
     return result
 
   def _normalize_url(self, url):
@@ skipping 35 matching lines @@
         'Content-Language',
         'Content-MD5',
         'Content-Type',
     ):
       return name
 
     # Add provider prefix
     if not provider_prefix:
       provider_prefix = 'x-goog-meta'
     return '%s-%s' % (provider_prefix, name)