1
# Copyright (C) 2005, 2006 Canonical Ltd
3
# This program is free software; you can redistribute it and/or modify
4
# it under the terms of the GNU General Public License as published by
5
# the Free Software Foundation; either version 2 of the License, or
6
# (at your option) any later version.
8
# This program is distributed in the hope that it will be useful,
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11
# GNU General Public License for more details.
13
# You should have received a copy of the GNU General Public License
14
# along with this program; if not, write to the Free Software
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17
from StringIO import StringIO
19
from bzrlib.lazy_import import lazy_import
20
lazy_import(globals(), """
25
from bzrlib.bundle import serializer as _serializer
26
from bzrlib.transport import get_transport as _get_transport
30
def read_bundle_from_url(url):
31
return read_bundle_or_directive_from_url(url, _do_directive=False)[0]
33
def read_mergeable_from_url(url, _do_directive=True):
34
"""Read mergable object from a given URL.
36
:return: An object supporting get_target_revision. Raises NotABundle if
37
the target is not a mergeable type.
39
from bzrlib.merge_directive import MergeDirective
40
url = urlutils.normalize_url(url)
41
url, filename = urlutils.split(url, exclude_trailing_slash=False)
43
# A path to a directory was passed in
44
# definitely not a bundle
45
raise errors.NotABundle('A directory cannot be a bundle')
47
# All of this must be in the try/except
48
# Some transports cannot detect that we are trying to read a
49
# directory until we actually issue read() on the handle.
51
t = _get_transport(url)
54
directive = MergeDirective.from_lines(f.readlines())
57
return _serializer.read_bundle(f)
58
except (errors.TransportError, errors.PathError), e:
59
raise errors.NotABundle(str(e))
62
# Abstraction leakage, SFTPTransport.get('directory')
63
# doesn't always fail at get() time. Sometimes it fails
64
# during read. And that raises a generic IOError with
65
# just the string 'Failure'
66
# StubSFTPServer does fail during get() (because of prefetch)
67
# so it has an opportunity to translate the error.
68
raise errors.NotABundle(str(e))
69
except errors.NotAMergeDirective:
71
return _serializer.read_bundle(f), None