21
from cStringIO import StringIO
23
24
from bzrlib.trace import mutter, note
24
from bzrlib.errors import BzrError
25
from bzrlib.errors import BzrError, BzrCheckError
25
26
from bzrlib.inventory import Inventory
26
from bzrlib.osutils import pumpfile, appendpath, fingerprint_file
27
from bzrlib.osutils import appendpath, fingerprint_file
92
95
"store is probably damaged/corrupt"])
95
def print_file(self, fileid):
96
"""Print file with id `fileid` to stdout."""
98
def print_file(self, file_id):
99
"""Print file with id `file_id` to stdout."""
98
pumpfile(self.get_file(fileid), sys.stdout)
101
sys.stdout.write(self.get_file_text(file_id))
101
104
def export(self, dest, format='dir', root=None):
119
122
or at least passing a description to the constructor.
122
def __init__(self, store, inv):
125
def __init__(self, weave_store, inv, revision_id):
126
self._weave_store = weave_store
124
127
self._inventory = inv
128
self._revision_id = revision_id
130
def get_weave(self, file_id):
131
# FIXME: RevisionTree should be given a branch
132
# not a store, or the store should know the branch.
133
import bzrlib.transactions as transactions
134
return self._weave_store.get_weave(file_id,
135
transactions.PassThroughTransaction())
138
def get_file_lines(self, file_id):
139
ie = self._inventory[file_id]
140
weave = self.get_weave(file_id)
141
return weave.get(ie.revision)
144
def get_file_text(self, file_id):
145
return ''.join(self.get_file_lines(file_id))
126
148
def get_file(self, file_id):
127
ie = self._inventory[file_id]
128
f = self._store[ie.text_id]
129
mutter(" get fileid{%s} from %r" % (file_id, self))
130
self._check_retrieved(ie, f)
149
return StringIO(self.get_file_text(file_id))
133
151
def get_file_size(self, file_id):
134
152
return self._inventory[file_id].text_size
138
156
if ie.kind == "file":
139
157
return ie.text_sha1
159
def is_executable(self, file_id):
160
return self._inventory[file_id].executable
141
162
def has_filename(self, filename):
142
163
return bool(self.inventory.path2id(filename))
144
165
def list_files(self):
145
166
# The only files returned by this are those from the version
146
167
for path, entry in self.inventory.iter_entries():
147
yield path, 'V', entry.kind, entry.file_id
168
yield path, 'V', entry.kind, entry.file_id, entry
170
def get_symlink_target(self, file_id):
171
ie = self._inventory[file_id]
172
return ie.symlink_target;
150
175
class EmptyTree(Tree):
151
176
def __init__(self):
152
177
self._inventory = Inventory()
179
def get_symlink_target(self, file_id):
154
182
def has_filename(self, filename):
157
185
def list_files(self):
158
if False: # just to make it a generator
161
188
def __contains__(self, file_id):
162
189
return file_id in self._inventory
254
279
mutter('export version %r' % tree)
255
280
inv = tree.inventory
256
281
for dp, ie in inv.iter_entries():
258
fullpath = appendpath(dest, dp)
259
if kind == 'directory':
262
pumpfile(tree.get_file(ie.file_id), file(fullpath, 'wb'))
264
raise BzrError("don't know how to export {%s} of kind %r" % (ie.file_id, kind))
265
mutter(" export {%s} kind %s to %s" % (ie.file_id, kind, fullpath))
282
ie.put_on_disk(dest, dp, tree)
266
284
exporters['dir'] = dir_exporter
311
329
inv = tree.inventory
312
330
for dp, ie in inv.iter_entries():
313
331
mutter(" export {%s} kind %s to %s" % (ie.file_id, ie.kind, dest))
314
item = tarfile.TarInfo(os.path.join(root, dp))
315
# TODO: would be cool to actually set it to the timestamp of the
316
# revision it was last changed
318
if ie.kind == 'directory':
319
item.type = tarfile.DIRTYPE
324
elif ie.kind == 'file':
325
item.type = tarfile.REGTYPE
326
fileobj = tree.get_file(ie.file_id)
327
item.size = _find_file_size(fileobj)
330
raise BzrError("don't know how to export {%s} of kind %r" %
331
(ie.file_id, ie.kind))
332
item, fileobj = ie.get_tar_item(root, dp, now, tree)
333
333
ball.addfile(item, fileobj)
335
336
exporters['tar'] = tar_exporter
337
338
def tgz_exporter(tree, dest, root):
341
342
def tbz_exporter(tree, dest, root):
342
343
tar_exporter(tree, dest, root, compression='bz2')
343
344
exporters['tbz2'] = tbz_exporter
346
def _find_file_size(fileobj):
347
offset = fileobj.tell()
350
size = fileobj.tell()
352
# gzip doesn't accept second argument to seek()
356
nread = len(fileobj.read())