| 1 |
1 |
#!/usr/bin/env python
|
| 2 |
2 |
|
|
3 |
# Copyright 2011 GRNET S.A. All rights reserved.
|
|
4 |
#
|
|
5 |
# Redistribution and use in source and binary forms, with or
|
|
6 |
# without modification, are permitted provided that the following
|
|
7 |
# conditions are met:
|
|
8 |
#
|
|
9 |
# 1. Redistributions of source code must retain the above
|
|
10 |
# copyright notice, this list of conditions and the following
|
|
11 |
# disclaimer.
|
|
12 |
#
|
|
13 |
# 2. Redistributions in binary form must reproduce the above
|
|
14 |
# copyright notice, this list of conditions and the following
|
|
15 |
# disclaimer in the documentation and/or other materials
|
|
16 |
# provided with the distribution.
|
|
17 |
#
|
|
18 |
# THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
|
|
19 |
# OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
|
|
20 |
# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
|
|
21 |
# PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
|
|
22 |
# CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
|
23 |
# SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
|
24 |
# LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
|
|
25 |
# USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
|
|
26 |
# AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
|
|
27 |
# LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
|
|
28 |
# ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
|
29 |
# POSSIBILITY OF SUCH DAMAGE.
|
|
30 |
#
|
|
31 |
# The views and conclusions contained in the software and
|
|
32 |
# documentation are those of the authors and should not be
|
|
33 |
# interpreted as representing official policies, either expressed
|
|
34 |
# or implied, of GRNET S.A.
|
|
35 |
|
| 3 |
36 |
from getpass import getuser
|
| 4 |
37 |
from optparse import OptionParser
|
| 5 |
38 |
from os.path import basename
|
| ... | ... | |
| 132 |
165 |
t = _time.strptime(self.until, self.format)
|
| 133 |
166 |
params['until'] = int(_time.mktime(t))
|
| 134 |
167 |
|
| 135 |
|
l = self.client.list_objects(container, self.detail, params, headers)
|
| 136 |
|
print_list(l)
|
|
168 |
detail = 'json'
|
|
169 |
l = self.client.list_objects(container, detail, params, headers)
|
|
170 |
print_list(l, detail=self.detail)
|
| 137 |
171 |
|
| 138 |
172 |
@cli_command('meta')
|
| 139 |
173 |
class Meta(Command):
|
| ... | ... | |
| 294 |
328 |
headers = {}
|
| 295 |
329 |
if self.manifest:
|
| 296 |
330 |
headers['X_OBJECT_MANIFEST'] = self.manifest
|
| 297 |
|
|
| 298 |
|
attrs = ['etag', 'content-encoding', 'content-disposition']
|
| 299 |
331 |
|
| 300 |
332 |
attrs = ['etag', 'content-encoding', 'content-disposition',
|
| 301 |
333 |
'content-type']
|
| ... | ... | |
| 425 |
457 |
syntax = '<src container>/<src object> [<dst container>/]<dst object>'
|
| 426 |
458 |
description = 'moves an object to a different location'
|
| 427 |
459 |
|
| 428 |
|
def add_options(self, parser):
|
| 429 |
|
parser.add_option('--version', action='store',
|
| 430 |
|
dest='version', default=False,
|
| 431 |
|
help='move specific version')
|
| 432 |
|
|
| 433 |
460 |
def execute(self, src, dst):
|
| 434 |
461 |
src_container, sep, src_object = src.partition('/')
|
| 435 |
462 |
dst_container, sep, dst_object = dst.partition('/')
|
| ... | ... | |
| 437 |
464 |
dst_container = src_container
|
| 438 |
465 |
dst_object = dst
|
| 439 |
466 |
|
| 440 |
|
version = getattr(self, 'version')
|
| 441 |
|
if version:
|
| 442 |
|
headers = {}
|
| 443 |
|
headers['X_SOURCE_VERSION'] = version
|
| 444 |
467 |
self.client.move_object(src_container, src_object, dst_container,
|
| 445 |
468 |
dst_object, headers)
|
| 446 |
469 |
|
| ... | ... | |
| 500 |
523 |
commands.append(' %s %s' % (name.ljust(12), description))
|
| 501 |
524 |
print '\nCommands:\n' + '\n'.join(sorted(commands))
|
| 502 |
525 |
|
| 503 |
|
def print_dict(d, header='name', f=stdout):
|
|
526 |
def print_dict(d, header='name', f=stdout, detail=True):
|
| 504 |
527 |
header = header in d and header or 'subdir'
|
| 505 |
528 |
if header and header in d:
|
| 506 |
529 |
f.write('%s\n' %d.pop(header))
|
| 507 |
|
patterns = ['^x_(account|container|object)_meta_(\w+)$']
|
| 508 |
|
patterns.append(patterns[0].replace('_', '-'))
|
| 509 |
|
for key, val in sorted(d.items()):
|
| 510 |
|
for p in patterns:
|
| 511 |
|
p = re.compile(p)
|
| 512 |
|
m = p.match(key)
|
| 513 |
|
if m:
|
| 514 |
|
key = m.group(2)
|
| 515 |
|
f.write('%s: %s\n' % (key.rjust(30), val))
|
|
530 |
if detail:
|
|
531 |
patterns = ['^x_(account|container|object)_meta_(\w+)$']
|
|
532 |
patterns.append(patterns[0].replace('_', '-'))
|
|
533 |
for key, val in sorted(d.items()):
|
|
534 |
for p in patterns:
|
|
535 |
p = re.compile(p)
|
|
536 |
m = p.match(key)
|
|
537 |
if m:
|
|
538 |
key = m.group(2)
|
|
539 |
f.write('%s: %s\n' % (key.rjust(30), val))
|
| 516 |
540 |
|
| 517 |
|
def print_list(l, verbose=False, f=stdout):
|
|
541 |
def print_list(l, verbose=False, f=stdout, detail=True):
|
| 518 |
542 |
for elem in l:
|
| 519 |
543 |
#if it's empty string continue
|
| 520 |
544 |
if not elem:
|
| 521 |
545 |
continue
|
| 522 |
546 |
if type(elem) == types.DictionaryType:
|
| 523 |
|
print_dict(elem, f=f)
|
|
547 |
print_dict(elem, f=f, detail=detail)
|
| 524 |
548 |
elif type(elem) == types.StringType:
|
| 525 |
549 |
if not verbose:
|
| 526 |
550 |
elem = elem.split('Traceback')[0]
|