| OLD | NEW |
| 1 # Copyright 2013 The Chromium Authors. All rights reserved. | 1 # Copyright 2013 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 import re | 5 import re |
| 6 | 6 |
| 7 from recipe_engine import recipe_api | 7 from recipe_engine import recipe_api |
| 8 | 8 |
| 9 class GSUtilApi(recipe_api.RecipeApi): | 9 class GSUtilApi(recipe_api.RecipeApi): |
| 10 def __call__(self, cmd, name=None, use_retry_wrapper=True, version=None, | 10 def __call__(self, cmd, name=None, use_retry_wrapper=True, version=None, |
| (...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 86 name = kwargs.pop('name', 'download') | 86 name = kwargs.pop('name', 'download') |
| 87 return self(cmd, name, **kwargs) | 87 return self(cmd, name, **kwargs) |
| 88 | 88 |
| 89 def download_url(self, url, dest, args=None, **kwargs): | 89 def download_url(self, url, dest, args=None, **kwargs): |
| 90 args = args or [] | 90 args = args or [] |
| 91 url = self._normalize_url(url) | 91 url = self._normalize_url(url) |
| 92 cmd = ['cp'] + args + [url, dest] | 92 cmd = ['cp'] + args + [url, dest] |
| 93 name = kwargs.pop('name', 'download_url') | 93 name = kwargs.pop('name', 'download_url') |
| 94 self(cmd, name, **kwargs) | 94 self(cmd, name, **kwargs) |
| 95 | 95 |
| 96 def ls(self, bucket, path, args=None, **kwargs): | |
| 97 args = args or [] | |
| 98 full_path = 'gs://%s/%s' % (bucket, path) | |
| 99 cmd = ['ls'] + args + [full_path] | |
| 100 name = kwargs.pop('name', 'ls %s' % full_path) | |
| 101 return self(cmd, name, **kwargs) | |
| 102 | |
| 103 def cat(self, url, args=None, **kwargs): | 96 def cat(self, url, args=None, **kwargs): |
| 104 args = args or [] | 97 args = args or [] |
| 105 url = self._normalize_url(url) | 98 url = self._normalize_url(url) |
| 106 cmd = ['cat'] + args + [url] | 99 cmd = ['cat'] + args + [url] |
| 107 name = kwargs.pop('name', 'cat') | 100 name = kwargs.pop('name', 'cat') |
| 108 return self(cmd, name, **kwargs) | 101 return self(cmd, name, **kwargs) |
| 109 | 102 |
| 110 def copy(self, source_bucket, source, dest_bucket, dest, args=None, | 103 def copy(self, source_bucket, source, dest_bucket, dest, args=None, |
| 111 link_name='gsutil.copy', metadata=None, unauthenticated_url=False, | 104 link_name='gsutil.copy', metadata=None, unauthenticated_url=False, |
| 112 **kwargs): | 105 **kwargs): |
| (...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 211 'Content-Language', | 204 'Content-Language', |
| 212 'Content-MD5', | 205 'Content-MD5', |
| 213 'Content-Type', | 206 'Content-Type', |
| 214 ): | 207 ): |
| 215 return name | 208 return name |
| 216 | 209 |
| 217 # Add provider prefix | 210 # Add provider prefix |
| 218 if not provider_prefix: | 211 if not provider_prefix: |
| 219 provider_prefix = 'x-goog-meta' | 212 provider_prefix = 'x-goog-meta' |
| 220 return '%s-%s' % (provider_prefix, name) | 213 return '%s-%s' % (provider_prefix, name) |
| OLD | NEW |