24
24
from __future__ import absolute_import
26
from ..lazy_import import lazy_import
26
from cStringIO import StringIO
28
from bzrlib.lazy_import import lazy_import
27
29
lazy_import(globals(), """
52
50
encoding_type = 'exact'
54
52
def run(self, location, verbose=False):
55
from breezy.bundle.serializer import read_bundle
56
from breezy.mergeable import read_mergeable_from_url
57
from breezy import osutils
53
from bzrlib.bundle.serializer import read_bundle
54
from bzrlib.bundle import read_mergeable_from_url
55
from bzrlib import osutils
58
56
term_encoding = osutils.get_terminal_encoding()
59
57
bundle_info = read_mergeable_from_url(location)
60
58
if isinstance(bundle_info, merge_directive.BaseMergeDirective):
61
bundle_file = BytesIO(bundle_info.get_raw_bundle())
59
bundle_file = StringIO(bundle_info.get_raw_bundle())
62
60
bundle_info = read_bundle(bundle_file)
65
63
raise errors.BzrCommandError(gettext(
66
'--verbose requires a merge directive'))
64
'--verbose requires a merge directive'))
67
65
reader_method = getattr(bundle_info, 'get_bundle_reader', None)
68
66
if reader_method is None:
69
raise errors.BzrCommandError(
70
gettext('Bundle format not supported'))
67
raise errors.BzrCommandError(gettext('Bundle format not supported'))
74
71
for bytes, parents, repo_kind, revision_id, file_id\
75
in reader_method().iter_records():
72
in reader_method().iter_records():
76
73
by_kind.setdefault(repo_kind, []).append(
77
74
(bytes, parents, repo_kind, revision_id, file_id))
78
75
if file_id is not None:
79
76
file_ids.add(file_id)
80
77
self.outf.write(gettext('Records\n'))
81
for kind, records in sorted(viewitems(by_kind)):
78
for kind, records in sorted(by_kind.iteritems()):
82
79
multiparent = sum(1 for b, m, k, r, f in records if
83
80
len(m.get('parents', [])) > 1)
84
81
self.outf.write(gettext('{0}: {1} ({2} multiparent)\n').format(
95
92
self.outf.write(gettext('Revisions\n'))
96
93
self.outf.write((gettext('nicks: %s\n')
97
% ', '.join(sorted(nicks))).encode(term_encoding, 'replace'))
94
% ', '.join(sorted(nicks))).encode(term_encoding, 'replace'))
98
95
self.outf.write((gettext('committers: \n%s\n') %
99
'\n'.join(sorted(committers)).encode(term_encoding, 'replace')))
96
'\n'.join(sorted(committers)).encode(term_encoding, 'replace')))
101
98
self.outf.write('\n')
102
99
bundle_file.seek(0)
103
100
line = bundle_file.readline()
104
101
line = bundle_file.readline()
106
content = bz2.decompress(bundle_file.read())
102
content = bundle_file.read().decode('bz2')
107
103
self.outf.write(gettext("Decoded contents\n"))
108
104
self.outf.write(content)
109
105
self.outf.write('\n')