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 |