← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transport/__init__.py

  • Committer: Martin Pool
  • Date: 2006-06-20 03:30:14 UTC
  • mfrom: (1793 +trunk)
  • mto: This revision was merged to the branch mainline in revision 1797.
  • Revision ID: mbp@sourcefrog.net-20060620033014-e19ce470e2ce6561
[merge] bzr.dev

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/transport/__init__.py
29
29
import errno
30
30
from collections import deque
31
31
from copy import deepcopy
 
32
import re
32
33
from stat import *
33
34
import sys
34
35
from unittest import TestSuite
35
36
import urllib
36
37
import urlparse
37
38
 
38
 
from bzrlib.trace import mutter, warning
 
39
import bzrlib
39
40
import bzrlib.errors as errors
40
41
from bzrlib.errors import DependencyNotPresent
 
42
import bzrlib.osutils as osutils
 
43
from bzrlib.osutils import pumpfile
41
44
from bzrlib.symbol_versioning import *
 
45
from bzrlib.trace import mutter, warning
 
46
import bzrlib.urlutils as urlutils
42
47
 
43
48
# {prefix: [transport_classes]}
44
49
# Transports are inserted onto the list LIFO and tried in order; as a result
127
132
 
128
133
 
129
134
def split_url(url):
 
135
    # TODO: jam 20060606 urls should only be ascii, or they should raise InvalidURL
130
136
    if isinstance(url, unicode):
131
137
        url = url.encode('utf-8')
132
138
    (scheme, netloc, path, params,
216
222
        if isinstance(from_file, basestring):
217
223
            to_file.write(from_file)
218
224
        else:
219
 
            from bzrlib.osutils import pumpfile
220
225
            pumpfile(from_file, to_file)
221
226
 
222
227
    def _get_total(self, multi):
284
289
        pl = len(self.base)
285
290
        return abspath[pl:].strip('/')
286
291
 
 
292
    def local_abspath(self, relpath):
 
293
        """Return the absolute path on the local filesystem.
 
294
 
 
295
        This function will only be defined for Transports which have a
 
296
        physical local filesystem representation.
 
297
        """
 
298
        # TODO: jam 20060426 Should this raise NotLocalUrl instead?
 
299
        raise errors.TransportNotPossible('This is not a LocalTransport,'
 
300
            ' so there is no local representation for a path')
 
301
 
287
302
    def has(self, relpath):
288
303
        """Does the file relpath exist?
289
304
        
662
677
        return False
663
678
 
664
679
 
 
680
# jam 20060426 For compatibility we copy the functions here
 
681
# TODO: The should be marked as deprecated
 
682
urlescape = urlutils.escape
 
683
urlunescape = urlutils.unescape
 
684
_urlRE = re.compile(r'^(?P<proto>[^:/\\]+)://(?P<path>.*)$')
 
685
 
 
686
 
665
687
def get_transport(base):
666
688
    """Open a transport to access a URL or directory.
667
689
 
671
693
    # handler for the scheme?
672
694
    global _protocol_handlers
673
695
    if base is None:
674
 
        base = u'.'
675
 
    else:
676
 
        base = unicode(base)
 
696
        base = '.'
 
697
 
 
698
    def convert_path_to_url(base, error_str):
 
699
        m = _urlRE.match(base)
 
700
        if m:
 
701
            # This looks like a URL, but we weren't able to 
 
702
            # instantiate it as such raise an appropriate error
 
703
            raise errors.InvalidURL(base, error_str % m.group('proto'))
 
704
        # This doesn't look like a protocol, consider it a local path
 
705
        new_base = urlutils.local_path_to_url(base)
 
706
        mutter('converting os path %r => url %s' , base, new_base)
 
707
        return new_base
 
708
 
 
709
    # Catch any URLs which are passing Unicode rather than ASCII
 
710
    try:
 
711
        base = base.encode('ascii')
 
712
    except UnicodeError:
 
713
        # Only local paths can be Unicode
 
714
        base = convert_path_to_url(base,
 
715
            'URLs must be properly escaped (protocol: %s)')
 
716
    
677
717
    for proto, factory_list in _protocol_handlers.iteritems():
678
718
        if proto is not None and base.startswith(proto):
679
719
            t = _try_transport_factories(base, factory_list)
680
720
            if t:
681
721
                return t
 
722
 
 
723
    # We tried all the different protocols, now try one last time
 
724
    # as a local protocol
 
725
    base = convert_path_to_url(base, 'Unsupported protocol: %s')
 
726
 
682
727
    # The default handler is the filesystem handler, stored as protocol None
683
728
    return _try_transport_factories(base, _protocol_handlers[None])
684
729
 
694
739
    return None
695
740
 
696
741
 
697
 
def urlescape(relpath):
698
 
    """Escape relpath to be a valid url."""
699
 
    if isinstance(relpath, unicode):
700
 
        relpath = relpath.encode('utf-8')
701
 
    return urllib.quote(relpath)
702
 
 
703
 
 
704
 
def urlunescape(relpath):
705
 
    """Unescape relpath from url format."""
706
 
    return urllib.unquote(relpath)
707
 
    # TODO de-utf8 it last. relpath = utf8relpath.decode('utf8')
708
 
 
709
 
 
710
742
class Server(object):
711
743
    """A Transport Server.
712
744
    
831
863
register_lazy_transport('https://', 'bzrlib.transport.http._pycurl', 'PyCurlTransport')
832
864
register_lazy_transport('ftp://', 'bzrlib.transport.ftp', 'FtpTransport')
833
865
register_lazy_transport('aftp://', 'bzrlib.transport.ftp', 'FtpTransport')
834
 
register_lazy_transport('memory:/', 'bzrlib.transport.memory', 'MemoryTransport')
 
866
register_lazy_transport('memory://', 'bzrlib.transport.memory', 'MemoryTransport')
835
867
register_lazy_transport('readonly+', 'bzrlib.transport.readonly', 'ReadonlyTransportDecorator')
836
868
register_lazy_transport('fakenfs+', 'bzrlib.transport.fakenfs', 'FakeNFSTransportDecorator')
837
869
register_lazy_transport('vfat+',