~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transport/sftp.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2008-10-31 04:39:04 UTC
  • mfrom: (3565.6.16 switch_nick)
  • Revision ID: pqm@pqm.ubuntu.com-20081031043904-52fnbfrloojemvcc
(mbp) branch nickname documentation

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005 Robey Pointer <robey@lag.net>, Canonical Ltd
2
 
 
 
1
# Copyright (C) 2005 Robey Pointer <robey@lag.net>
 
2
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
 
3
#
3
4
# This program is free software; you can redistribute it and/or modify
4
5
# it under the terms of the GNU General Public License as published by
5
6
# the Free Software Foundation; either version 2 of the License, or
6
7
# (at your option) any later version.
7
 
 
 
8
#
8
9
# This program is distributed in the hope that it will be useful,
9
10
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
11
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
12
# GNU General Public License for more details.
12
 
 
 
13
#
13
14
# You should have received a copy of the GNU General Public License
14
15
# along with this program; if not, write to the Free Software
15
16
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
17
 
17
18
"""Implementation of Transport over SFTP, using paramiko."""
18
19
 
 
20
# TODO: Remove the transport-based lock_read and lock_write methods.  They'll
 
21
# then raise TransportNotPossible, which will break remote access to any
 
22
# formats which rely on OS-level locks.  That should be fine as those formats
 
23
# are pretty old, but these combinations may have to be removed from the test
 
24
# suite.  Those formats all date back to 0.7; so we should be able to remove
 
25
# these methods when we officially drop support for those formats.
 
26
 
 
27
import bisect
19
28
import errno
20
 
import getpass
 
29
import itertools
21
30
import os
22
 
import re
 
31
import random
 
32
import select
 
33
import socket
23
34
import stat
24
35
import sys
 
36
import time
25
37
import urllib
26
38
import urlparse
27
 
import time
28
 
import random
29
 
import subprocess
30
 
import weakref
 
39
import warnings
31
40
 
32
 
from bzrlib.errors import (FileExists, 
33
 
                           TransportNotPossible, NoSuchFile, PathNotChild,
 
41
from bzrlib import (
 
42
    config,
 
43
    errors,
 
44
    urlutils,
 
45
    )
 
46
from bzrlib.errors import (FileExists,
 
47
                           NoSuchFile, PathNotChild,
34
48
                           TransportError,
35
 
                           LockError)
36
 
from bzrlib.config import config_dir
37
 
from bzrlib.trace import mutter, warning, error
38
 
from bzrlib.transport import Transport, register_transport
39
 
import bzrlib.ui
 
49
                           LockError,
 
50
                           PathError,
 
51
                           ParamikoNotPresent,
 
52
                           )
 
53
from bzrlib.osutils import pathjoin, fancy_rename, getcwd
 
54
from bzrlib.symbol_versioning import (
 
55
        deprecated_function,
 
56
        )
 
57
from bzrlib.trace import mutter, warning
 
58
from bzrlib.transport import (
 
59
    FileFileStream,
 
60
    _file_streams,
 
61
    local,
 
62
    Server,
 
63
    ssh,
 
64
    ConnectedTransport,
 
65
    )
 
66
 
 
67
# Disable one particular warning that comes from paramiko in Python2.5; if
 
68
# this is emitted at the wrong time it tends to cause spurious test failures
 
69
# or at least noise in the test case::
 
70
#
 
71
# [1770/7639 in 86s, 1 known failures, 50 skipped, 2 missing features]
 
72
# test_permissions.TestSftpPermissions.test_new_files
 
73
# /var/lib/python-support/python2.5/paramiko/message.py:226: DeprecationWarning: integer argument expected, got float
 
74
#  self.packet.write(struct.pack('>I', n))
 
75
warnings.filterwarnings('ignore',
 
76
        'integer argument expected, got float',
 
77
        category=DeprecationWarning,
 
78
        module='paramiko.message')
40
79
 
41
80
try:
42
81
    import paramiko
43
 
except ImportError:
44
 
    error('The SFTP transport requires paramiko.')
45
 
    raise
 
82
except ImportError, e:
 
83
    raise ParamikoNotPresent(e)
46
84
else:
47
85
    from paramiko.sftp import (SFTP_FLAG_WRITE, SFTP_FLAG_CREATE,
48
86
                               SFTP_FLAG_EXCL, SFTP_FLAG_TRUNC,
49
87
                               CMD_HANDLE, CMD_OPEN)
50
88
    from paramiko.sftp_attr import SFTPAttributes
51
89
    from paramiko.sftp_file import SFTPFile
52
 
    from paramiko.sftp_client import SFTPClient
53
 
 
54
 
if 'sftp' not in urlparse.uses_netloc: urlparse.uses_netloc.append('sftp')
55
 
 
56
 
 
57
 
_close_fds = True
58
 
if sys.platform == 'win32':
59
 
    # close_fds not supported on win32
60
 
    _close_fds = False
61
 
 
62
 
_ssh_vendor = None
63
 
def _get_ssh_vendor():
64
 
    """Find out what version of SSH is on the system."""
65
 
    global _ssh_vendor
66
 
    if _ssh_vendor is not None:
67
 
        return _ssh_vendor
68
 
 
69
 
    _ssh_vendor = 'none'
70
 
 
71
 
    try:
72
 
        p = subprocess.Popen(['ssh', '-V'],
73
 
                             close_fds=_close_fds,
74
 
                             stdin=subprocess.PIPE,
75
 
                             stdout=subprocess.PIPE,
76
 
                             stderr=subprocess.PIPE)
77
 
        returncode = p.returncode
78
 
        stdout, stderr = p.communicate()
79
 
    except OSError:
80
 
        returncode = -1
81
 
        stdout = stderr = ''
82
 
    if 'OpenSSH' in stderr:
83
 
        mutter('ssh implementation is OpenSSH')
84
 
        _ssh_vendor = 'openssh'
85
 
    elif 'SSH Secure Shell' in stderr:
86
 
        mutter('ssh implementation is SSH Corp.')
87
 
        _ssh_vendor = 'ssh'
88
 
 
89
 
    if _ssh_vendor != 'none':
90
 
        return _ssh_vendor
91
 
 
92
 
    # XXX: 20051123 jamesh
93
 
    # A check for putty's plink or lsh would go here.
94
 
 
95
 
    mutter('falling back to paramiko implementation')
96
 
    return _ssh_vendor
97
 
 
98
 
 
99
 
class SFTPSubprocess:
100
 
    """A socket-like object that talks to an ssh subprocess via pipes."""
101
 
    def __init__(self, hostname, port=None, user=None):
102
 
        vendor = _get_ssh_vendor()
103
 
        assert vendor in ['openssh', 'ssh']
104
 
        if vendor == 'openssh':
105
 
            args = ['ssh',
106
 
                    '-oForwardX11=no', '-oForwardAgent=no',
107
 
                    '-oClearAllForwardings=yes', '-oProtocol=2',
108
 
                    '-oNoHostAuthenticationForLocalhost=yes']
109
 
            if port is not None:
110
 
                args.extend(['-p', str(port)])
111
 
            if user is not None:
112
 
                args.extend(['-l', user])
113
 
            args.extend(['-s', hostname, 'sftp'])
114
 
        elif vendor == 'ssh':
115
 
            args = ['ssh', '-x']
116
 
            if port is not None:
117
 
                args.extend(['-p', str(port)])
118
 
            if user is not None:
119
 
                args.extend(['-l', user])
120
 
            args.extend(['-s', 'sftp', hostname])
121
 
 
122
 
        self.proc = subprocess.Popen(args, close_fds=_close_fds,
123
 
                                     stdin=subprocess.PIPE,
124
 
                                     stdout=subprocess.PIPE)
125
 
 
126
 
    def send(self, data):
127
 
        return os.write(self.proc.stdin.fileno(), data)
128
 
 
129
 
    def recv(self, count):
130
 
        return os.read(self.proc.stdout.fileno(), count)
131
 
 
132
 
    def close(self):
133
 
        self.proc.stdin.close()
134
 
        self.proc.stdout.close()
135
 
        self.proc.wait()
136
 
 
137
 
 
138
 
SYSTEM_HOSTKEYS = {}
139
 
BZR_HOSTKEYS = {}
140
 
 
141
 
# This is a weakref dictionary, so that we can reuse connections
142
 
# that are still active. Long term, it might be nice to have some
143
 
# sort of expiration policy, such as disconnect if inactive for
144
 
# X seconds. But that requires a lot more fanciness.
145
 
_connected_hosts = weakref.WeakValueDictionary()
146
 
 
147
 
def load_host_keys():
148
 
    """
149
 
    Load system host keys (probably doesn't work on windows) and any
150
 
    "discovered" keys from previous sessions.
151
 
    """
152
 
    global SYSTEM_HOSTKEYS, BZR_HOSTKEYS
153
 
    try:
154
 
        SYSTEM_HOSTKEYS = paramiko.util.load_host_keys(os.path.expanduser('~/.ssh/known_hosts'))
155
 
    except Exception, e:
156
 
        mutter('failed to load system host keys: ' + str(e))
157
 
    bzr_hostkey_path = os.path.join(config_dir(), 'ssh_host_keys')
158
 
    try:
159
 
        BZR_HOSTKEYS = paramiko.util.load_host_keys(bzr_hostkey_path)
160
 
    except Exception, e:
161
 
        mutter('failed to load bzr host keys: ' + str(e))
162
 
        save_host_keys()
163
 
 
164
 
def save_host_keys():
165
 
    """
166
 
    Save "discovered" host keys in $(config)/ssh_host_keys/.
167
 
    """
168
 
    global SYSTEM_HOSTKEYS, BZR_HOSTKEYS
169
 
    bzr_hostkey_path = os.path.join(config_dir(), 'ssh_host_keys')
170
 
    if not os.path.isdir(config_dir()):
171
 
        os.mkdir(config_dir())
172
 
    try:
173
 
        f = open(bzr_hostkey_path, 'w')
174
 
        f.write('# SSH host keys collected by bzr\n')
175
 
        for hostname, keys in BZR_HOSTKEYS.iteritems():
176
 
            for keytype, key in keys.iteritems():
177
 
                f.write('%s %s %s\n' % (hostname, keytype, key.get_base64()))
178
 
        f.close()
179
 
    except IOError, e:
180
 
        mutter('failed to save bzr host keys: ' + str(e))
 
90
 
 
91
 
 
92
_paramiko_version = getattr(paramiko, '__version_info__', (0, 0, 0))
 
93
# don't use prefetch unless paramiko version >= 1.5.5 (there were bugs earlier)
 
94
_default_do_prefetch = (_paramiko_version >= (1, 5, 5))
181
95
 
182
96
 
183
97
class SFTPLock(object):
184
 
    """This fakes a lock in a remote location."""
 
98
    """This fakes a lock in a remote location.
 
99
    
 
100
    A present lock is indicated just by the existence of a file.  This
 
101
    doesn't work well on all transports and they are only used in 
 
102
    deprecated storage formats.
 
103
    """
 
104
    
185
105
    __slots__ = ['path', 'lock_path', 'lock_file', 'transport']
 
106
 
186
107
    def __init__(self, path, transport):
187
 
        assert isinstance(transport, SFTPTransport)
188
 
 
189
108
        self.lock_file = None
190
109
        self.path = path
191
110
        self.lock_path = path + '.write-lock'
192
111
        self.transport = transport
193
112
        try:
194
 
            self.lock_file = transport._sftp_open_exclusive(self.lock_path)
 
113
            # RBC 20060103 FIXME should we be using private methods here ?
 
114
            abspath = transport._remote_path(self.lock_path)
 
115
            self.lock_file = transport._sftp_open_exclusive(abspath)
195
116
        except FileExists:
196
117
            raise LockError('File %r already locked' % (self.path,))
197
118
 
198
119
    def __del__(self):
199
120
        """Should this warn, or actually try to cleanup?"""
200
121
        if self.lock_file:
201
 
            warn("SFTPLock %r not explicitly unlocked" % (self.path,))
 
122
            warning("SFTPLock %r not explicitly unlocked" % (self.path,))
202
123
            self.unlock()
203
124
 
204
125
    def unlock(self):
212
133
            # What specific errors should we catch here?
213
134
            pass
214
135
 
215
 
class SFTPTransport (Transport):
216
 
    """
217
 
    Transport implementation for SFTP access.
218
 
    """
219
 
    _do_prefetch = False # Right now Paramiko's prefetch support causes things to hang
220
 
 
221
 
    def __init__(self, base, clone_from=None):
222
 
        assert base.startswith('sftp://')
223
 
        self._parse_url(base)
224
 
        base = self._unparse_url()
225
 
        super(SFTPTransport, self).__init__(base)
226
 
        if clone_from is None:
227
 
            self._sftp_connect()
228
 
        else:
229
 
            # use the same ssh connection, etc
230
 
            self._sftp = clone_from._sftp
231
 
        # super saves 'self.base'
232
 
    
233
 
    def should_cache(self):
234
 
        """
235
 
        Return True if the data pulled across should be cached locally.
236
 
        """
237
 
        return True
238
 
 
239
 
    def clone(self, offset=None):
240
 
        """
241
 
        Return a new SFTPTransport with root at self.base + offset.
242
 
        We share the same SFTP session between such transports, because it's
243
 
        fairly expensive to set them up.
244
 
        """
245
 
        if offset is None:
246
 
            return SFTPTransport(self.base, self)
247
 
        else:
248
 
            return SFTPTransport(self.abspath(offset), self)
249
 
 
250
 
    def abspath(self, relpath):
251
 
        """
252
 
        Return the full url to the given relative path.
 
136
 
 
137
class _SFTPReadvHelper(object):
 
138
    """A class to help with managing the state of a readv request."""
 
139
 
 
140
    # See _get_requests for an explanation.
 
141
    _max_request_size = 32768
 
142
 
 
143
    def __init__(self, original_offsets, relpath):
 
144
        """Create a new readv helper.
 
145
 
 
146
        :param original_offsets: The original requests given by the caller of
 
147
            readv()
 
148
        :param relpath: The name of the file (if known)
 
149
        """
 
150
        self.original_offsets = list(original_offsets)
 
151
        self.relpath = relpath
 
152
 
 
153
    def _get_requests(self):
 
154
        """Break up the offsets into individual requests over sftp.
 
155
 
 
156
        The SFTP spec only requires implementers to support 32kB requests. We
 
157
        could try something larger (openssh supports 64kB), but then we have to
 
158
        handle requests that fail.
 
159
        So instead, we just break up our maximum chunks into 32kB chunks, and
 
160
        asyncronously requests them.
 
161
        Newer versions of paramiko would do the chunking for us, but we want to
 
162
        start processing results right away, so we do it ourselves.
 
163
        """
 
164
        # TODO: Because we issue async requests, we don't 'fudge' any extra
 
165
        #       data.  I'm not 100% sure that is the best choice.
 
166
 
 
167
        # The first thing we do, is to collapse the individual requests as much
 
168
        # as possible, so we don't issues requests <32kB
 
169
        sorted_offsets = sorted(self.original_offsets)
 
170
        coalesced = list(ConnectedTransport._coalesce_offsets(sorted_offsets,
 
171
                                                        limit=0, fudge_factor=0))
 
172
        requests = []
 
173
        for c_offset in coalesced:
 
174
            start = c_offset.start
 
175
            size = c_offset.length
 
176
 
 
177
            # Break this up into 32kB requests
 
178
            while size > 0:
 
179
                next_size = min(size, self._max_request_size)
 
180
                requests.append((start, next_size))
 
181
                size -= next_size
 
182
                start += next_size
 
183
        mutter('SFTP.readv(%s) %s offsets => %s coalesced => %s requests',
 
184
               self.relpath, len(sorted_offsets), len(coalesced),
 
185
               len(requests))
 
186
        return requests
 
187
 
 
188
    def request_and_yield_offsets(self, fp):
 
189
        """Request the data from the remote machine, yielding the results.
 
190
 
 
191
        :param fp: A Paramiko SFTPFile object that supports readv.
 
192
        :return: Yield the data requested by the original readv caller, one by
 
193
            one.
 
194
        """
 
195
        requests = self._get_requests()
 
196
        offset_iter = iter(self.original_offsets)
 
197
        cur_offset, cur_size = offset_iter.next()
 
198
        # paramiko .readv() yields strings that are in the order of the requests
 
199
        # So we track the current request to know where the next data is
 
200
        # being returned from.
 
201
        input_start = None
 
202
        last_end = None
 
203
        buffered_data = []
 
204
        buffered_len = 0
 
205
 
 
206
        # This is used to buffer chunks which we couldn't process yet
 
207
        # It is (start, end, data) tuples.
 
208
        data_chunks = []
 
209
        # Create an 'unlimited' data stream, so we stop based on requests,
 
210
        # rather than just because the data stream ended. This lets us detect
 
211
        # short readv.
 
212
        data_stream = itertools.chain(fp.readv(requests),
 
213
                                      itertools.repeat(None))
 
214
        for (start, length), data in itertools.izip(requests, data_stream):
 
215
            if data is None:
 
216
                if cur_coalesced is not None:
 
217
                    raise errors.ShortReadvError(self.relpath,
 
218
                        start, length, len(data))
 
219
            if len(data) != length:
 
220
                raise errors.ShortReadvError(self.relpath,
 
221
                    start, length, len(data))
 
222
            if last_end is None:
 
223
                # This is the first request, just buffer it
 
224
                buffered_data = [data]
 
225
                buffered_len = length
 
226
                input_start = start
 
227
            elif start == last_end:
 
228
                # The data we are reading fits neatly on the previous
 
229
                # buffer, so this is all part of a larger coalesced range.
 
230
                buffered_data.append(data)
 
231
                buffered_len += length
 
232
            else:
 
233
                # We have an 'interrupt' in the data stream. So we know we are
 
234
                # at a request boundary.
 
235
                if buffered_len > 0:
 
236
                    # We haven't consumed the buffer so far, so put it into
 
237
                    # data_chunks, and continue.
 
238
                    buffered = ''.join(buffered_data)
 
239
                    data_chunks.append((input_start, buffered))
 
240
                input_start = start
 
241
                buffered_data = [data]
 
242
                buffered_len = length
 
243
            last_end = start + length
 
244
            if input_start == cur_offset and cur_size <= buffered_len:
 
245
                # Simplify the next steps a bit by transforming buffered_data
 
246
                # into a single string. We also have the nice property that
 
247
                # when there is only one string ''.join([x]) == x, so there is
 
248
                # no data copying.
 
249
                buffered = ''.join(buffered_data)
 
250
                # Clean out buffered data so that we keep memory
 
251
                # consumption low
 
252
                del buffered_data[:]
 
253
                buffered_offset = 0
 
254
                # TODO: We *could* also consider the case where cur_offset is in
 
255
                #       in the buffered range, even though it doesn't *start*
 
256
                #       the buffered range. But for packs we pretty much always
 
257
                #       read in order, so you won't get any extra data in the
 
258
                #       middle.
 
259
                while (input_start == cur_offset
 
260
                       and (buffered_offset + cur_size) <= buffered_len):
 
261
                    # We've buffered enough data to process this request, spit it
 
262
                    # out
 
263
                    cur_data = buffered[buffered_offset:buffered_offset + cur_size]
 
264
                    # move the direct pointer into our buffered data
 
265
                    buffered_offset += cur_size
 
266
                    # Move the start-of-buffer pointer
 
267
                    input_start += cur_size
 
268
                    # Yield the requested data
 
269
                    yield cur_offset, cur_data
 
270
                    cur_offset, cur_size = offset_iter.next()
 
271
                # at this point, we've consumed as much of buffered as we can,
 
272
                # so break off the portion that we consumed
 
273
                if buffered_offset == len(buffered_data):
 
274
                    # No tail to leave behind
 
275
                    buffered_data = []
 
276
                    buffered_len = 0
 
277
                else:
 
278
                    buffered = buffered[buffered_offset:]
 
279
                    buffered_data = [buffered]
 
280
                    buffered_len = len(buffered)
 
281
        if buffered_len:
 
282
            buffered = ''.join(buffered_data)
 
283
            del buffered_data[:]
 
284
            data_chunks.append((input_start, buffered))
 
285
        if data_chunks:
 
286
            mutter('SFTP readv left with %d out-of-order bytes',
 
287
                   sum(map(lambda x: len(x[1]), data_chunks)))
 
288
            # We've processed all the readv data, at this point, anything we
 
289
            # couldn't process is in data_chunks. This doesn't happen often, so
 
290
            # this code path isn't optimized
 
291
            # We use an interesting process for data_chunks
 
292
            # Specifically if we have "bisect_left([(start, len, entries)],
 
293
            #                                       (qstart,)])
 
294
            # If start == qstart, then we get the specific node. Otherwise we
 
295
            # get the previous node
 
296
            while True:
 
297
                idx = bisect.bisect_left(data_chunks, (cur_offset,))
 
298
                if data_chunks[idx][0] == cur_offset: # The data starts here
 
299
                    data = data_chunks[idx][1][:cur_size]
 
300
                elif idx > 0:
 
301
                    # The data is in a portion of a previous page
 
302
                    idx -= 1
 
303
                    sub_offset = cur_offset - data_chunks[idx][0]
 
304
                    data = data_chunks[idx][1]
 
305
                    data = data[sub_offset:sub_offset + cur_size]
 
306
                else:
 
307
                    # We are missing the page where the data should be found,
 
308
                    # something is wrong
 
309
                    data = ''
 
310
                if len(data) != cur_size:
 
311
                    raise AssertionError('We must have miscalulated.'
 
312
                        ' We expected %d bytes, but only found %d'
 
313
                        % (cur_size, len(data)))
 
314
                yield cur_offset, data
 
315
                cur_offset, cur_size = offset_iter.next()
 
316
 
 
317
 
 
318
class SFTPTransport(ConnectedTransport):
 
319
    """Transport implementation for SFTP access."""
 
320
 
 
321
    _do_prefetch = _default_do_prefetch
 
322
    # TODO: jam 20060717 Conceivably these could be configurable, either
 
323
    #       by auto-tuning at run-time, or by a configuration (per host??)
 
324
    #       but the performance curve is pretty flat, so just going with
 
325
    #       reasonable defaults.
 
326
    _max_readv_combine = 200
 
327
    # Having to round trip to the server means waiting for a response,
 
328
    # so it is better to download extra bytes.
 
329
    # 8KiB had good performance for both local and remote network operations
 
330
    _bytes_to_read_before_seek = 8192
 
331
 
 
332
    # The sftp spec says that implementations SHOULD allow reads
 
333
    # to be at least 32K. paramiko.readv() does an async request
 
334
    # for the chunks. So we need to keep it within a single request
 
335
    # size for paramiko <= 1.6.1. paramiko 1.6.2 will probably chop
 
336
    # up the request itself, rather than us having to worry about it
 
337
    _max_request_size = 32768
 
338
 
 
339
    def __init__(self, base, _from_transport=None):
 
340
        super(SFTPTransport, self).__init__(base,
 
341
                                            _from_transport=_from_transport)
 
342
 
 
343
    def _remote_path(self, relpath):
 
344
        """Return the path to be passed along the sftp protocol for relpath.
253
345
        
254
 
        @param relpath: the relative path or path components
255
 
        @type relpath: str or list
256
 
        """
257
 
        return self._unparse_url(self._abspath(relpath))
258
 
    
259
 
    def _abspath(self, relpath):
260
 
        """Return the absolute path segment without the SFTP URL."""
261
 
        # FIXME: share the common code across transports
262
 
        assert isinstance(relpath, basestring)
263
 
        relpath = [urllib.unquote(relpath)]
264
 
        basepath = self._path.split('/')
265
 
        if len(basepath) > 0 and basepath[-1] == '':
266
 
            basepath = basepath[:-1]
267
 
 
268
 
        for p in relpath:
269
 
            if p == '..':
270
 
                if len(basepath) == 0:
271
 
                    # In most filesystems, a request for the parent
272
 
                    # of root, just returns root.
273
 
                    continue
274
 
                basepath.pop()
275
 
            elif p == '.':
276
 
                continue # No-op
277
 
            else:
278
 
                basepath.append(p)
279
 
 
280
 
        path = '/'.join(basepath)
281
 
        # could still be a "relative" path here, but relative on the sftp server
282
 
        return path
283
 
 
284
 
    def relpath(self, abspath):
285
 
        username, password, host, port, path = self._split_url(abspath)
286
 
        error = []
287
 
        if (username != self._username):
288
 
            error.append('username mismatch')
289
 
        if (host != self._host):
290
 
            error.append('host mismatch')
291
 
        if (port != self._port):
292
 
            error.append('port mismatch')
293
 
        if (not path.startswith(self._path)):
294
 
            error.append('path mismatch')
295
 
        if error:
296
 
            extra = ': ' + ', '.join(error)
297
 
            raise PathNotChild(abspath, self.base, extra=extra)
298
 
        pl = len(self._path)
299
 
        return path[pl:].lstrip('/')
 
346
        :param relpath: is a urlencoded string.
 
347
        """
 
348
        relative = urlutils.unescape(relpath).encode('utf-8')
 
349
        remote_path = self._combine_paths(self._path, relative)
 
350
        # the initial slash should be removed from the path, and treated as a
 
351
        # homedir relative path (the path begins with a double slash if it is
 
352
        # absolute).  see draft-ietf-secsh-scp-sftp-ssh-uri-03.txt
 
353
        # RBC 20060118 we are not using this as its too user hostile. instead
 
354
        # we are following lftp and using /~/foo to mean '~/foo'
 
355
        # vila--20070602 and leave absolute paths begin with a single slash.
 
356
        if remote_path.startswith('/~/'):
 
357
            remote_path = remote_path[3:]
 
358
        elif remote_path == '/~':
 
359
            remote_path = ''
 
360
        return remote_path
 
361
 
 
362
    def _create_connection(self, credentials=None):
 
363
        """Create a new connection with the provided credentials.
 
364
 
 
365
        :param credentials: The credentials needed to establish the connection.
 
366
 
 
367
        :return: The created connection and its associated credentials.
 
368
 
 
369
        The credentials are only the password as it may have been entered
 
370
        interactively by the user and may be different from the one provided
 
371
        in base url at transport creation time.
 
372
        """
 
373
        if credentials is None:
 
374
            password = self._password
 
375
        else:
 
376
            password = credentials
 
377
 
 
378
        vendor = ssh._get_ssh_vendor()
 
379
        user = self._user
 
380
        if user is None:
 
381
            auth = config.AuthenticationConfig()
 
382
            user = auth.get_user('ssh', self._host, self._port)
 
383
        connection = vendor.connect_sftp(self._user, password,
 
384
                                         self._host, self._port)
 
385
        return connection, (user, password)
 
386
 
 
387
    def _get_sftp(self):
 
388
        """Ensures that a connection is established"""
 
389
        connection = self._get_connection()
 
390
        if connection is None:
 
391
            # First connection ever
 
392
            connection, credentials = self._create_connection()
 
393
            self._set_connection(connection, credentials)
 
394
        return connection
300
395
 
301
396
    def has(self, relpath):
302
397
        """
303
398
        Does the target location exist?
304
399
        """
305
400
        try:
306
 
            self._sftp.stat(self._abspath(relpath))
 
401
            self._get_sftp().stat(self._remote_path(relpath))
307
402
            return True
308
403
        except IOError:
309
404
            return False
310
405
 
311
 
    def get(self, relpath, decode=False):
 
406
    def get(self, relpath):
312
407
        """
313
408
        Get the file at the given relative path.
314
409
 
315
410
        :param relpath: The relative path to the file
316
411
        """
317
412
        try:
318
 
            path = self._abspath(relpath)
319
 
            f = self._sftp.file(path)
320
 
            if self._do_prefetch and hasattr(f, 'prefetch'):
 
413
            path = self._remote_path(relpath)
 
414
            f = self._get_sftp().file(path, mode='rb')
 
415
            if self._do_prefetch and (getattr(f, 'prefetch', None) is not None):
321
416
                f.prefetch()
322
417
            return f
323
418
        except (IOError, paramiko.SSHException), e:
 
419
            self._translate_io_exception(e, path, ': error retrieving',
 
420
                failure_exc=errors.ReadError)
 
421
 
 
422
    def _readv(self, relpath, offsets):
 
423
        """See Transport.readv()"""
 
424
        # We overload the default readv() because we want to use a file
 
425
        # that does not have prefetch enabled.
 
426
        # Also, if we have a new paramiko, it implements an async readv()
 
427
        if not offsets:
 
428
            return
 
429
 
 
430
        try:
 
431
            path = self._remote_path(relpath)
 
432
            fp = self._get_sftp().file(path, mode='rb')
 
433
            readv = getattr(fp, 'readv', None)
 
434
            if readv:
 
435
                return self._sftp_readv(fp, offsets, relpath)
 
436
            mutter('seek and read %s offsets', len(offsets))
 
437
            return self._seek_and_read(fp, offsets, relpath)
 
438
        except (IOError, paramiko.SSHException), e:
324
439
            self._translate_io_exception(e, path, ': error retrieving')
325
440
 
326
 
    def get_partial(self, relpath, start, length=None):
327
 
        """
328
 
        Get just part of a file.
329
 
 
330
 
        :param relpath: Path to the file, relative to base
331
 
        :param start: The starting position to read from
332
 
        :param length: The length to read. A length of None indicates
333
 
                       read to the end of the file.
334
 
        :return: A file-like object containing at least the specified bytes.
335
 
                 Some implementations may return objects which can be read
336
 
                 past this length, but this is not guaranteed.
337
 
        """
338
 
        # TODO: implement get_partial_multi to help with knit support
339
 
        f = self.get(relpath)
340
 
        f.seek(start)
341
 
        if self._do_prefetch and hasattr(f, 'prefetch'):
342
 
            f.prefetch()
343
 
        return f
344
 
 
345
 
    def put(self, relpath, f):
346
 
        """
347
 
        Copy the file-like or string object into the location.
 
441
    def recommended_page_size(self):
 
442
        """See Transport.recommended_page_size().
 
443
 
 
444
        For SFTP we suggest a large page size to reduce the overhead
 
445
        introduced by latency.
 
446
        """
 
447
        return 64 * 1024
 
448
 
 
449
    def _sftp_readv(self, fp, offsets, relpath='<unknown>'):
 
450
        """Use the readv() member of fp to do async readv.
 
451
 
 
452
        And then read them using paramiko.readv(). paramiko.readv()
 
453
        does not support ranges > 64K, so it caps the request size, and
 
454
        just reads until it gets all the stuff it wants
 
455
        """
 
456
        helper = _SFTPReadvHelper(offsets, relpath)
 
457
        return helper.request_and_yield_offsets(fp)
 
458
 
 
459
    def put_file(self, relpath, f, mode=None):
 
460
        """
 
461
        Copy the file-like object into the location.
348
462
 
349
463
        :param relpath: Location to put the contents, relative to base.
350
 
        :param f:       File-like or string object.
 
464
        :param f:       File-like object.
 
465
        :param mode: The final mode for the file
351
466
        """
352
 
        final_path = self._abspath(relpath)
353
 
        tmp_relpath = '%s.tmp.%.9f.%d.%d' % (relpath, time.time(),
 
467
        final_path = self._remote_path(relpath)
 
468
        return self._put(final_path, f, mode=mode)
 
469
 
 
470
    def _put(self, abspath, f, mode=None):
 
471
        """Helper function so both put() and copy_abspaths can reuse the code"""
 
472
        tmp_abspath = '%s.tmp.%.9f.%d.%d' % (abspath, time.time(),
354
473
                        os.getpid(), random.randint(0,0x7FFFFFFF))
355
 
        tmp_abspath = self._abspath(tmp_relpath)
356
 
        fout = self._sftp_open_exclusive(tmp_relpath)
357
 
 
 
474
        fout = self._sftp_open_exclusive(tmp_abspath, mode=mode)
 
475
        closed = False
358
476
        try:
359
477
            try:
360
 
                self._pump(f, fout)
361
 
            except (paramiko.SSHException, IOError), e:
362
 
                self._translate_io_exception(e, relpath, ': unable to write')
 
478
                fout.set_pipelined(True)
 
479
                length = self._pump(f, fout)
 
480
            except (IOError, paramiko.SSHException), e:
 
481
                self._translate_io_exception(e, tmp_abspath)
 
482
            # XXX: This doesn't truly help like we would like it to.
 
483
            #      The problem is that openssh strips sticky bits. So while we
 
484
            #      can properly set group write permission, we lose the group
 
485
            #      sticky bit. So it is probably best to stop chmodding, and
 
486
            #      just tell users that they need to set the umask correctly.
 
487
            #      The attr.st_mode = mode, in _sftp_open_exclusive
 
488
            #      will handle when the user wants the final mode to be more 
 
489
            #      restrictive. And then we avoid a round trip. Unless 
 
490
            #      paramiko decides to expose an async chmod()
 
491
 
 
492
            # This is designed to chmod() right before we close.
 
493
            # Because we set_pipelined() earlier, theoretically we might 
 
494
            # avoid the round trip for fout.close()
 
495
            if mode is not None:
 
496
                self._get_sftp().chmod(tmp_abspath, mode)
 
497
            fout.close()
 
498
            closed = True
 
499
            self._rename_and_overwrite(tmp_abspath, abspath)
 
500
            return length
363
501
        except Exception, e:
364
502
            # If we fail, try to clean up the temporary file
365
503
            # before we throw the exception
366
504
            # but don't let another exception mess things up
367
 
            try:
368
 
                fout.close()
369
 
                self._sftp.remove(tmp_abspath)
370
 
            except:
371
 
                pass
372
 
            raise e
373
 
        else:
374
 
            # sftp rename doesn't allow overwriting, so play tricks:
375
 
            tmp_safety = 'bzr.tmp.%.9f.%d.%d' % (time.time(), os.getpid(), random.randint(0, 0x7FFFFFFF))
376
 
            tmp_safety = self._abspath(tmp_safety)
377
 
            try:
378
 
                self._sftp.rename(final_path, tmp_safety)
379
 
                file_existed = True
380
 
            except:
381
 
                file_existed = False
382
 
            success = False
 
505
            # Write out the traceback, because otherwise
 
506
            # the catch and throw destroys it
 
507
            import traceback
 
508
            mutter(traceback.format_exc())
 
509
            try:
 
510
                if not closed:
 
511
                    fout.close()
 
512
                self._get_sftp().remove(tmp_abspath)
 
513
            except:
 
514
                # raise the saved except
 
515
                raise e
 
516
            # raise the original with its traceback if we can.
 
517
            raise
 
518
 
 
519
    def _put_non_atomic_helper(self, relpath, writer, mode=None,
 
520
                               create_parent_dir=False,
 
521
                               dir_mode=None):
 
522
        abspath = self._remote_path(relpath)
 
523
 
 
524
        # TODO: jam 20060816 paramiko doesn't publicly expose a way to
 
525
        #       set the file mode at create time. If it does, use it.
 
526
        #       But for now, we just chmod later anyway.
 
527
 
 
528
        def _open_and_write_file():
 
529
            """Try to open the target file, raise error on failure"""
 
530
            fout = None
383
531
            try:
384
532
                try:
385
 
                    self._sftp.rename(tmp_abspath, final_path)
 
533
                    fout = self._get_sftp().file(abspath, mode='wb')
 
534
                    fout.set_pipelined(True)
 
535
                    writer(fout)
386
536
                except (paramiko.SSHException, IOError), e:
387
 
                    self._translate_io_exception(e, relpath, ': unable to rename')
388
 
                else:
389
 
                    success = True
 
537
                    self._translate_io_exception(e, abspath,
 
538
                                                 ': unable to open')
 
539
 
 
540
                # This is designed to chmod() right before we close.
 
541
                # Because we set_pipelined() earlier, theoretically we might 
 
542
                # avoid the round trip for fout.close()
 
543
                if mode is not None:
 
544
                    self._get_sftp().chmod(abspath, mode)
390
545
            finally:
391
 
                if file_existed:
392
 
                    if success:
393
 
                        self._sftp.unlink(tmp_safety)
394
 
                    else:
395
 
                        self._sftp.rename(tmp_safety, final_path)
 
546
                if fout is not None:
 
547
                    fout.close()
 
548
 
 
549
        if not create_parent_dir:
 
550
            _open_and_write_file()
 
551
            return
 
552
 
 
553
        # Try error handling to create the parent directory if we need to
 
554
        try:
 
555
            _open_and_write_file()
 
556
        except NoSuchFile:
 
557
            # Try to create the parent directory, and then go back to
 
558
            # writing the file
 
559
            parent_dir = os.path.dirname(abspath)
 
560
            self._mkdir(parent_dir, dir_mode)
 
561
            _open_and_write_file()
 
562
 
 
563
    def put_file_non_atomic(self, relpath, f, mode=None,
 
564
                            create_parent_dir=False,
 
565
                            dir_mode=None):
 
566
        """Copy the file-like object into the target location.
 
567
 
 
568
        This function is not strictly safe to use. It is only meant to
 
569
        be used when you already know that the target does not exist.
 
570
        It is not safe, because it will open and truncate the remote
 
571
        file. So there may be a time when the file has invalid contents.
 
572
 
 
573
        :param relpath: The remote location to put the contents.
 
574
        :param f:       File-like object.
 
575
        :param mode:    Possible access permissions for new file.
 
576
                        None means do not set remote permissions.
 
577
        :param create_parent_dir: If we cannot create the target file because
 
578
                        the parent directory does not exist, go ahead and
 
579
                        create it, and then try again.
 
580
        """
 
581
        def writer(fout):
 
582
            self._pump(f, fout)
 
583
        self._put_non_atomic_helper(relpath, writer, mode=mode,
 
584
                                    create_parent_dir=create_parent_dir,
 
585
                                    dir_mode=dir_mode)
 
586
 
 
587
    def put_bytes_non_atomic(self, relpath, bytes, mode=None,
 
588
                             create_parent_dir=False,
 
589
                             dir_mode=None):
 
590
        def writer(fout):
 
591
            fout.write(bytes)
 
592
        self._put_non_atomic_helper(relpath, writer, mode=mode,
 
593
                                    create_parent_dir=create_parent_dir,
 
594
                                    dir_mode=dir_mode)
396
595
 
397
596
    def iter_files_recursive(self):
398
597
        """Walk the relative paths of all files in this transport."""
399
598
        queue = list(self.list_dir('.'))
400
599
        while queue:
401
 
            relpath = urllib.quote(queue.pop(0))
 
600
            relpath = queue.pop(0)
402
601
            st = self.stat(relpath)
403
602
            if stat.S_ISDIR(st.st_mode):
404
603
                for i, basename in enumerate(self.list_dir(relpath)):
406
605
            else:
407
606
                yield relpath
408
607
 
409
 
    def mkdir(self, relpath):
 
608
    def _mkdir(self, abspath, mode=None):
 
609
        if mode is None:
 
610
            local_mode = 0777
 
611
        else:
 
612
            local_mode = mode
 
613
        try:
 
614
            self._get_sftp().mkdir(abspath, local_mode)
 
615
            if mode is not None:
 
616
                # chmod a dir through sftp will erase any sgid bit set
 
617
                # on the server side.  So, if the bit mode are already
 
618
                # set, avoid the chmod.  If the mode is not fine but
 
619
                # the sgid bit is set, report a warning to the user
 
620
                # with the umask fix.
 
621
                stat = self._get_sftp().lstat(abspath)
 
622
                mode = mode & 0777 # can't set special bits anyway
 
623
                if mode != stat.st_mode & 0777:
 
624
                    if stat.st_mode & 06000:
 
625
                        warning('About to chmod %s over sftp, which will result'
 
626
                                ' in its suid or sgid bits being cleared.  If'
 
627
                                ' you want to preserve those bits, change your '
 
628
                                ' environment on the server to use umask 0%03o.'
 
629
                                % (abspath, 0777 - mode))
 
630
                    self._get_sftp().chmod(abspath, mode=mode)
 
631
        except (paramiko.SSHException, IOError), e:
 
632
            self._translate_io_exception(e, abspath, ': unable to mkdir',
 
633
                failure_exc=FileExists)
 
634
 
 
635
    def mkdir(self, relpath, mode=None):
410
636
        """Create a directory at the given path."""
 
637
        self._mkdir(self._remote_path(relpath), mode=mode)
 
638
 
 
639
    def open_write_stream(self, relpath, mode=None):
 
640
        """See Transport.open_write_stream."""
 
641
        # initialise the file to zero-length
 
642
        # this is three round trips, but we don't use this 
 
643
        # api more than once per write_group at the moment so 
 
644
        # it is a tolerable overhead. Better would be to truncate
 
645
        # the file after opening. RBC 20070805
 
646
        self.put_bytes_non_atomic(relpath, "", mode)
 
647
        abspath = self._remote_path(relpath)
 
648
        # TODO: jam 20060816 paramiko doesn't publicly expose a way to
 
649
        #       set the file mode at create time. If it does, use it.
 
650
        #       But for now, we just chmod later anyway.
 
651
        handle = None
411
652
        try:
412
 
            path = self._abspath(relpath)
413
 
            self._sftp.mkdir(path)
 
653
            handle = self._get_sftp().file(abspath, mode='wb')
 
654
            handle.set_pipelined(True)
414
655
        except (paramiko.SSHException, IOError), e:
415
 
            self._translate_io_exception(e, relpath, ': unable to mkdir',
416
 
                failure_exc=FileExists)
 
656
            self._translate_io_exception(e, abspath,
 
657
                                         ': unable to open')
 
658
        _file_streams[self.abspath(relpath)] = handle
 
659
        return FileFileStream(self, relpath, handle)
417
660
 
418
 
    def _translate_io_exception(self, e, path, more_info='', failure_exc=NoSuchFile):
 
661
    def _translate_io_exception(self, e, path, more_info='',
 
662
                                failure_exc=PathError):
419
663
        """Translate a paramiko or IOError into a friendlier exception.
420
664
 
421
665
        :param e: The original exception
425
669
        :param failure_exc: Paramiko has the super fun ability to raise completely
426
670
                           opaque errors that just set "e.args = ('Failure',)" with
427
671
                           no more information.
428
 
                           This sometimes means FileExists, but it also sometimes
429
 
                           means NoSuchFile
 
672
                           If this parameter is set, it defines the exception 
 
673
                           to raise in these cases.
430
674
        """
431
675
        # paramiko seems to generate detailless errors.
432
676
        self._translate_error(e, path, raise_generic=False)
433
 
        if hasattr(e, 'args'):
 
677
        if getattr(e, 'args', None) is not None:
434
678
            if (e.args == ('No such file or directory',) or
435
679
                e.args == ('No such file',)):
436
680
                raise NoSuchFile(path, str(e) + more_info)
437
 
            if (e.args == ('mkdir failed',)):
 
681
            if (e.args == ('mkdir failed',) or
 
682
                e.args[0].startswith('syserr: File exists')):
438
683
                raise FileExists(path, str(e) + more_info)
439
684
            # strange but true, for the paramiko server.
440
685
            if (e.args == ('Failure',)):
441
686
                raise failure_exc(path, str(e) + more_info)
 
687
            mutter('Raising exception with args %s', e.args)
 
688
        if getattr(e, 'errno', None) is not None:
 
689
            mutter('Raising exception with errno %s', e.errno)
442
690
        raise e
443
691
 
444
 
    def append(self, relpath, f):
 
692
    def append_file(self, relpath, f, mode=None):
445
693
        """
446
694
        Append the text in the file-like object into the final
447
695
        location.
448
696
        """
449
697
        try:
450
 
            path = self._abspath(relpath)
451
 
            fout = self._sftp.file(path, 'ab')
 
698
            path = self._remote_path(relpath)
 
699
            fout = self._get_sftp().file(path, 'ab')
 
700
            if mode is not None:
 
701
                self._get_sftp().chmod(path, mode)
 
702
            result = fout.tell()
452
703
            self._pump(f, fout)
 
704
            return result
453
705
        except (IOError, paramiko.SSHException), e:
454
706
            self._translate_io_exception(e, relpath, ': unable to append')
455
707
 
456
 
    def copy(self, rel_from, rel_to):
457
 
        """Copy the item at rel_from to the location at rel_to"""
458
 
        path_from = self._abspath(rel_from)
459
 
        path_to = self._abspath(rel_to)
460
 
        self._copy_abspaths(path_from, path_to)
461
 
 
462
 
    def _copy_abspaths(self, path_from, path_to):
463
 
        """Copy files given an absolute path
464
 
 
465
 
        :param path_from: Path on remote server to read
466
 
        :param path_to: Path on remote server to write
467
 
        :return: None
468
 
 
469
 
        TODO: Should the destination location be atomically created?
470
 
              This has not been specified
471
 
        TODO: This should use some sort of remote copy, rather than
472
 
              pulling the data locally, and then writing it remotely
473
 
        """
474
 
        try:
475
 
            fin = self._sftp.file(path_from, 'rb')
476
 
            try:
477
 
                fout = self._sftp.file(path_to, 'wb')
478
 
                try:
479
 
                    fout.set_pipelined(True)
480
 
                    self._pump(fin, fout)
481
 
                finally:
482
 
                    fout.close()
483
 
            finally:
484
 
                fin.close()
485
 
        except (IOError, paramiko.SSHException), e:
486
 
            self._translate_io_exception(e, path_from, ': unable copy to: %r' % path_to)
487
 
 
488
 
    def copy_to(self, relpaths, other, pb=None):
489
 
        """Copy a set of entries from self into another Transport.
490
 
 
491
 
        :param relpaths: A list/generator of entries to be copied.
492
 
        """
493
 
        if isinstance(other, SFTPTransport) and other._sftp is self._sftp:
494
 
            # Both from & to are on the same remote filesystem
495
 
            # We can use a remote copy, instead of pulling locally, and pushing
496
 
 
497
 
            total = self._get_total(relpaths)
498
 
            count = 0
499
 
            for path in relpaths:
500
 
                path_from = self._abspath(relpath)
501
 
                path_to = other._abspath(relpath)
502
 
                self._update_pb(pb, 'copy-to', count, total)
503
 
                self._copy_abspaths(path_from, path_to)
504
 
                count += 1
505
 
            return count
506
 
        else:
507
 
            return super(SFTPTransport, self).copy_to(relpaths, other, pb=pb)
508
 
 
509
 
        # The dummy implementation just does a simple get + put
510
 
        def copy_entry(path):
511
 
            other.put(path, self.get(path))
512
 
 
513
 
        return self._iterate_over(relpaths, copy_entry, pb, 'copy_to', expand=False)
 
708
    def rename(self, rel_from, rel_to):
 
709
        """Rename without special overwriting"""
 
710
        try:
 
711
            self._get_sftp().rename(self._remote_path(rel_from),
 
712
                              self._remote_path(rel_to))
 
713
        except (IOError, paramiko.SSHException), e:
 
714
            self._translate_io_exception(e, rel_from,
 
715
                    ': unable to rename to %r' % (rel_to))
 
716
 
 
717
    def _rename_and_overwrite(self, abs_from, abs_to):
 
718
        """Do a fancy rename on the remote server.
 
719
        
 
720
        Using the implementation provided by osutils.
 
721
        """
 
722
        try:
 
723
            sftp = self._get_sftp()
 
724
            fancy_rename(abs_from, abs_to,
 
725
                         rename_func=sftp.rename,
 
726
                         unlink_func=sftp.remove)
 
727
        except (IOError, paramiko.SSHException), e:
 
728
            self._translate_io_exception(e, abs_from,
 
729
                                         ': unable to rename to %r' % (abs_to))
514
730
 
515
731
    def move(self, rel_from, rel_to):
516
732
        """Move the item at rel_from to the location at rel_to"""
517
 
        path_from = self._abspath(rel_from)
518
 
        path_to = self._abspath(rel_to)
519
 
        try:
520
 
            self._sftp.rename(path_from, path_to)
521
 
        except (IOError, paramiko.SSHException), e:
522
 
            self._translate_io_exception(e, path_from, ': unable to move to: %r' % path_to)
 
733
        path_from = self._remote_path(rel_from)
 
734
        path_to = self._remote_path(rel_to)
 
735
        self._rename_and_overwrite(path_from, path_to)
523
736
 
524
737
    def delete(self, relpath):
525
738
        """Delete the item at relpath"""
526
 
        path = self._abspath(relpath)
 
739
        path = self._remote_path(relpath)
527
740
        try:
528
 
            self._sftp.remove(path)
 
741
            self._get_sftp().remove(path)
529
742
        except (IOError, paramiko.SSHException), e:
530
743
            self._translate_io_exception(e, path, ': unable to delete')
531
744
            
 
745
    def external_url(self):
 
746
        """See bzrlib.transport.Transport.external_url."""
 
747
        # the external path for SFTP is the base
 
748
        return self.base
 
749
 
532
750
    def listable(self):
533
751
        """Return True if this store supports listing."""
534
752
        return True
538
756
        Return a list of all files at the given location.
539
757
        """
540
758
        # does anything actually use this?
541
 
        path = self._abspath(relpath)
 
759
        # -- Unknown
 
760
        # This is at least used by copy_tree for remote upgrades.
 
761
        # -- David Allouche 2006-08-11
 
762
        path = self._remote_path(relpath)
542
763
        try:
543
 
            return self._sftp.listdir(path)
 
764
            entries = self._get_sftp().listdir(path)
544
765
        except (IOError, paramiko.SSHException), e:
545
766
            self._translate_io_exception(e, path, ': failed to list_dir')
 
767
        return [urlutils.escape(entry) for entry in entries]
 
768
 
 
769
    def rmdir(self, relpath):
 
770
        """See Transport.rmdir."""
 
771
        path = self._remote_path(relpath)
 
772
        try:
 
773
            return self._get_sftp().rmdir(path)
 
774
        except (IOError, paramiko.SSHException), e:
 
775
            self._translate_io_exception(e, path, ': failed to rmdir')
546
776
 
547
777
    def stat(self, relpath):
548
778
        """Return the stat information for a file."""
549
 
        path = self._abspath(relpath)
 
779
        path = self._remote_path(relpath)
550
780
        try:
551
 
            return self._sftp.stat(path)
 
781
            return self._get_sftp().stat(path)
552
782
        except (IOError, paramiko.SSHException), e:
553
783
            self._translate_io_exception(e, path, ': unable to stat')
554
784
 
578
808
        # that we have taken the lock.
579
809
        return SFTPLock(relpath, self)
580
810
 
581
 
 
582
 
    def _unparse_url(self, path=None):
583
 
        if path is None:
584
 
            path = self._path
585
 
        path = urllib.quote(path)
586
 
        if path.startswith('/'):
587
 
            path = '/%2F' + path[1:]
588
 
        else:
589
 
            path = '/' + path
590
 
        netloc = urllib.quote(self._host)
591
 
        if self._username is not None:
592
 
            netloc = '%s@%s' % (urllib.quote(self._username), netloc)
593
 
        if self._port is not None:
594
 
            netloc = '%s:%d' % (netloc, self._port)
595
 
 
596
 
        return urlparse.urlunparse(('sftp', netloc, path, '', '', ''))
597
 
 
598
 
    def _split_url(self, url):
599
 
        if isinstance(url, unicode):
600
 
            url = url.encode('utf-8')
601
 
        (scheme, netloc, path, params,
602
 
         query, fragment) = urlparse.urlparse(url, allow_fragments=False)
603
 
        assert scheme == 'sftp'
604
 
        username = password = host = port = None
605
 
        if '@' in netloc:
606
 
            username, host = netloc.split('@', 1)
607
 
            if ':' in username:
608
 
                username, password = username.split(':', 1)
609
 
                password = urllib.unquote(password)
610
 
            username = urllib.unquote(username)
611
 
        else:
612
 
            host = netloc
613
 
 
614
 
        if ':' in host:
615
 
            host, port = host.rsplit(':', 1)
616
 
            try:
617
 
                port = int(port)
618
 
            except ValueError:
619
 
                # TODO: Should this be ConnectionError?
620
 
                raise TransportError('%s: invalid port number' % port)
621
 
        host = urllib.unquote(host)
622
 
 
623
 
        path = urllib.unquote(path)
624
 
 
625
 
        # the initial slash should be removed from the path, and treated
626
 
        # as a homedir relative path (the path begins with a double slash
627
 
        # if it is absolute).
628
 
        # see draft-ietf-secsh-scp-sftp-ssh-uri-03.txt
629
 
        if path.startswith('/'):
630
 
            path = path[1:]
631
 
 
632
 
        return (username, password, host, port, path)
633
 
 
634
 
    def _parse_url(self, url):
635
 
        (self._username, self._password,
636
 
         self._host, self._port, self._path) = self._split_url(url)
637
 
 
638
 
    def _sftp_connect(self):
639
 
        """Connect to the remote sftp server.
640
 
        After this, self._sftp should have a valid connection (or
641
 
        we raise an TransportError 'could not connect').
642
 
 
643
 
        TODO: Raise a more reasonable ConnectionFailed exception
644
 
        """
645
 
        global _connected_hosts
646
 
 
647
 
        idx = (self._host, self._port, self._username)
648
 
        try:
649
 
            self._sftp = _connected_hosts[idx]
650
 
            return
651
 
        except KeyError:
652
 
            pass
653
 
        
654
 
        vendor = _get_ssh_vendor()
655
 
        if vendor != 'none':
656
 
            sock = SFTPSubprocess(self._host, self._port, self._username)
657
 
            self._sftp = SFTPClient(sock)
658
 
        else:
659
 
            self._paramiko_connect()
660
 
 
661
 
        _connected_hosts[idx] = self._sftp
662
 
 
663
 
    def _paramiko_connect(self):
664
 
        global SYSTEM_HOSTKEYS, BZR_HOSTKEYS
665
 
        
666
 
        load_host_keys()
667
 
 
668
 
        try:
669
 
            t = paramiko.Transport((self._host, self._port or 22))
670
 
            t.start_client()
671
 
        except paramiko.SSHException, e:
672
 
            raise ConnectionError('Unable to reach SSH host %s:%d' %
673
 
                                  (self._host, self._port), e)
674
 
            
675
 
        server_key = t.get_remote_server_key()
676
 
        server_key_hex = paramiko.util.hexify(server_key.get_fingerprint())
677
 
        keytype = server_key.get_name()
678
 
        if SYSTEM_HOSTKEYS.has_key(self._host) and SYSTEM_HOSTKEYS[self._host].has_key(keytype):
679
 
            our_server_key = SYSTEM_HOSTKEYS[self._host][keytype]
680
 
            our_server_key_hex = paramiko.util.hexify(our_server_key.get_fingerprint())
681
 
        elif BZR_HOSTKEYS.has_key(self._host) and BZR_HOSTKEYS[self._host].has_key(keytype):
682
 
            our_server_key = BZR_HOSTKEYS[self._host][keytype]
683
 
            our_server_key_hex = paramiko.util.hexify(our_server_key.get_fingerprint())
684
 
        else:
685
 
            warning('Adding %s host key for %s: %s' % (keytype, self._host, server_key_hex))
686
 
            if not BZR_HOSTKEYS.has_key(self._host):
687
 
                BZR_HOSTKEYS[self._host] = {}
688
 
            BZR_HOSTKEYS[self._host][keytype] = server_key
689
 
            our_server_key = server_key
690
 
            our_server_key_hex = paramiko.util.hexify(our_server_key.get_fingerprint())
691
 
            save_host_keys()
692
 
        if server_key != our_server_key:
693
 
            filename1 = os.path.expanduser('~/.ssh/known_hosts')
694
 
            filename2 = os.path.join(config_dir(), 'ssh_host_keys')
695
 
            raise TransportError('Host keys for %s do not match!  %s != %s' % \
696
 
                (self._host, our_server_key_hex, server_key_hex),
697
 
                ['Try editing %s or %s' % (filename1, filename2)])
698
 
 
699
 
        self._sftp_auth(t)
700
 
        
701
 
        try:
702
 
            self._sftp = t.open_sftp_client()
703
 
        except paramiko.SSHException, e:
704
 
            raise ConnectionError('Unable to start sftp client %s:%d' %
705
 
                                  (self._host, self._port), e)
706
 
 
707
 
    def _sftp_auth(self, transport):
708
 
        # paramiko requires a username, but it might be none if nothing was supplied
709
 
        # use the local username, just in case.
710
 
        # We don't override self._username, because if we aren't using paramiko,
711
 
        # the username might be specified in ~/.ssh/config and we don't want to
712
 
        # force it to something else
713
 
        # Also, it would mess up the self.relpath() functionality
714
 
        username = self._username or getpass.getuser()
715
 
 
716
 
        # Paramiko tries to open a socket.AF_UNIX in order to connect
717
 
        # to ssh-agent. That attribute doesn't exist on win32 (it does in cygwin)
718
 
        # so we get an AttributeError exception. For now, just don't try to
719
 
        # connect to an agent if we are on win32
720
 
        if sys.platform != 'win32':
721
 
            agent = paramiko.Agent()
722
 
            for key in agent.get_keys():
723
 
                mutter('Trying SSH agent key %s' % paramiko.util.hexify(key.get_fingerprint()))
724
 
                try:
725
 
                    transport.auth_publickey(username, key)
726
 
                    return
727
 
                except paramiko.SSHException, e:
728
 
                    pass
729
 
        
730
 
        # okay, try finding id_rsa or id_dss?  (posix only)
731
 
        if self._try_pkey_auth(transport, paramiko.RSAKey, username, 'id_rsa'):
732
 
            return
733
 
        if self._try_pkey_auth(transport, paramiko.DSSKey, username, 'id_dsa'):
734
 
            return
735
 
 
736
 
 
737
 
        if self._password:
738
 
            try:
739
 
                transport.auth_password(username, self._password)
740
 
                return
741
 
            except paramiko.SSHException, e:
742
 
                pass
743
 
 
744
 
            # FIXME: Don't keep a password held in memory if you can help it
745
 
            #self._password = None
746
 
 
747
 
        # give up and ask for a password
748
 
        password = bzrlib.ui.ui_factory.get_password(
749
 
                prompt='SSH %(user)s@%(host)s password',
750
 
                user=username, host=self._host)
751
 
        try:
752
 
            transport.auth_password(username, password)
753
 
        except paramiko.SSHException, e:
754
 
            raise ConnectionError('Unable to authenticate to SSH host as %s@%s' %
755
 
                                  (username, self._host), e)
756
 
 
757
 
    def _try_pkey_auth(self, transport, pkey_class, username, filename):
758
 
        filename = os.path.expanduser('~/.ssh/' + filename)
759
 
        try:
760
 
            key = pkey_class.from_private_key_file(filename)
761
 
            transport.auth_publickey(username, key)
762
 
            return True
763
 
        except paramiko.PasswordRequiredException:
764
 
            password = bzrlib.ui.ui_factory.get_password(
765
 
                    prompt='SSH %(filename)s password',
766
 
                    filename=filename)
767
 
            try:
768
 
                key = pkey_class.from_private_key_file(filename, password)
769
 
                transport.auth_publickey(username, key)
770
 
                return True
771
 
            except paramiko.SSHException:
772
 
                mutter('SSH authentication via %s key failed.' % (os.path.basename(filename),))
773
 
        except paramiko.SSHException:
774
 
            mutter('SSH authentication via %s key failed.' % (os.path.basename(filename),))
775
 
        except IOError:
776
 
            pass
777
 
        return False
778
 
 
779
 
    def _sftp_open_exclusive(self, relpath):
 
811
    def _sftp_open_exclusive(self, abspath, mode=None):
780
812
        """Open a remote path exclusively.
781
813
 
782
814
        SFTP supports O_EXCL (SFTP_FLAG_EXCL), which fails if
787
819
        WARNING: This breaks the SFTPClient abstraction, so it
788
820
        could easily break against an updated version of paramiko.
789
821
 
790
 
        :param relpath: The relative path, where the file should be opened
 
822
        :param abspath: The remote absolute path where the file should be opened
 
823
        :param mode: The mode permissions bits for the new file
791
824
        """
792
 
        path = self._sftp._adjust_cwd(self._abspath(relpath))
 
825
        # TODO: jam 20060816 Paramiko >= 1.6.2 (probably earlier) supports
 
826
        #       using the 'x' flag to indicate SFTP_FLAG_EXCL.
 
827
        #       However, there is no way to set the permission mode at open 
 
828
        #       time using the sftp_client.file() functionality.
 
829
        path = self._get_sftp()._adjust_cwd(abspath)
 
830
        # mutter('sftp abspath %s => %s', abspath, path)
793
831
        attr = SFTPAttributes()
794
 
        mode = (SFTP_FLAG_WRITE | SFTP_FLAG_CREATE 
 
832
        if mode is not None:
 
833
            attr.st_mode = mode
 
834
        omode = (SFTP_FLAG_WRITE | SFTP_FLAG_CREATE 
795
835
                | SFTP_FLAG_TRUNC | SFTP_FLAG_EXCL)
796
836
        try:
797
 
            t, msg = self._sftp._request(CMD_OPEN, path, mode, attr)
 
837
            t, msg = self._get_sftp()._request(CMD_OPEN, path, omode, attr)
798
838
            if t != CMD_HANDLE:
799
839
                raise TransportError('Expected an SFTP handle')
800
840
            handle = msg.get_string()
801
 
            return SFTPFile(self._sftp, handle, 'w', -1)
 
841
            return SFTPFile(self._get_sftp(), handle, 'wb', -1)
802
842
        except (paramiko.SSHException, IOError), e:
803
 
            self._translate_io_exception(e, relpath, ': unable to open',
 
843
            self._translate_io_exception(e, abspath, ': unable to open',
804
844
                failure_exc=FileExists)
805
845
 
 
846
    def _can_roundtrip_unix_modebits(self):
 
847
        if sys.platform == 'win32':
 
848
            # anyone else?
 
849
            return False
 
850
        else:
 
851
            return True
 
852
 
 
853
# ------------- server test implementation --------------
 
854
import threading
 
855
 
 
856
from bzrlib.tests.stub_sftp import StubServer, StubSFTPServer
 
857
 
 
858
STUB_SERVER_KEY = """
 
859
-----BEGIN RSA PRIVATE KEY-----
 
860
MIICWgIBAAKBgQDTj1bqB4WmayWNPB+8jVSYpZYk80Ujvj680pOTh2bORBjbIAyz
 
861
oWGW+GUjzKxTiiPvVmxFgx5wdsFvF03v34lEVVhMpouqPAYQ15N37K/ir5XY+9m/
 
862
d8ufMCkjeXsQkKqFbAlQcnWMCRnOoPHS3I4vi6hmnDDeeYTSRvfLbW0fhwIBIwKB
 
863
gBIiOqZYaoqbeD9OS9z2K9KR2atlTxGxOJPXiP4ESqP3NVScWNwyZ3NXHpyrJLa0
 
864
EbVtzsQhLn6rF+TzXnOlcipFvjsem3iYzCpuChfGQ6SovTcOjHV9z+hnpXvQ/fon
 
865
soVRZY65wKnF7IAoUwTmJS9opqgrN6kRgCd3DASAMd1bAkEA96SBVWFt/fJBNJ9H
 
866
tYnBKZGw0VeHOYmVYbvMSstssn8un+pQpUm9vlG/bp7Oxd/m+b9KWEh2xPfv6zqU
 
867
avNwHwJBANqzGZa/EpzF4J8pGti7oIAPUIDGMtfIcmqNXVMckrmzQ2vTfqtkEZsA
 
868
4rE1IERRyiJQx6EJsz21wJmGV9WJQ5kCQQDwkS0uXqVdFzgHO6S++tjmjYcxwr3g
 
869
H0CoFYSgbddOT6miqRskOQF3DZVkJT3kyuBgU2zKygz52ukQZMqxCb1fAkASvuTv
 
870
qfpH87Qq5kQhNKdbbwbmd2NxlNabazPijWuphGTdW0VfJdWfklyS2Kr+iqrs/5wV
 
871
HhathJt636Eg7oIjAkA8ht3MQ+XSl9yIJIS8gVpbPxSw5OMfw0PjVE7tBdQruiSc
 
872
nvuQES5C9BMHjF39LZiGH1iLQy7FgdHyoP+eodI7
 
873
-----END RSA PRIVATE KEY-----
 
874
"""
 
875
 
 
876
 
 
877
class SocketListener(threading.Thread):
 
878
 
 
879
    def __init__(self, callback):
 
880
        threading.Thread.__init__(self)
 
881
        self._callback = callback
 
882
        self._socket = socket.socket()
 
883
        self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
 
884
        self._socket.bind(('localhost', 0))
 
885
        self._socket.listen(1)
 
886
        self.port = self._socket.getsockname()[1]
 
887
        self._stop_event = threading.Event()
 
888
 
 
889
    def stop(self):
 
890
        # called from outside this thread
 
891
        self._stop_event.set()
 
892
        # use a timeout here, because if the test fails, the server thread may
 
893
        # never notice the stop_event.
 
894
        self.join(5.0)
 
895
        self._socket.close()
 
896
 
 
897
    def run(self):
 
898
        while True:
 
899
            readable, writable_unused, exception_unused = \
 
900
                select.select([self._socket], [], [], 0.1)
 
901
            if self._stop_event.isSet():
 
902
                return
 
903
            if len(readable) == 0:
 
904
                continue
 
905
            try:
 
906
                s, addr_unused = self._socket.accept()
 
907
                # because the loopback socket is inline, and transports are
 
908
                # never explicitly closed, best to launch a new thread.
 
909
                threading.Thread(target=self._callback, args=(s,)).start()
 
910
            except socket.error, x:
 
911
                sys.excepthook(*sys.exc_info())
 
912
                warning('Socket error during accept() within unit test server'
 
913
                        ' thread: %r' % x)
 
914
            except Exception, x:
 
915
                # probably a failed test; unit test thread will log the
 
916
                # failure/error
 
917
                sys.excepthook(*sys.exc_info())
 
918
                warning('Exception from within unit test server thread: %r' % 
 
919
                        x)
 
920
 
 
921
 
 
922
class SocketDelay(object):
 
923
    """A socket decorator to make TCP appear slower.
 
924
 
 
925
    This changes recv, send, and sendall to add a fixed latency to each python
 
926
    call if a new roundtrip is detected. That is, when a recv is called and the
 
927
    flag new_roundtrip is set, latency is charged. Every send and send_all
 
928
    sets this flag.
 
929
 
 
930
    In addition every send, sendall and recv sleeps a bit per character send to
 
931
    simulate bandwidth.
 
932
 
 
933
    Not all methods are implemented, this is deliberate as this class is not a
 
934
    replacement for the builtin sockets layer. fileno is not implemented to
 
935
    prevent the proxy being bypassed. 
 
936
    """
 
937
 
 
938
    simulated_time = 0
 
939
    _proxied_arguments = dict.fromkeys([
 
940
        "close", "getpeername", "getsockname", "getsockopt", "gettimeout",
 
941
        "setblocking", "setsockopt", "settimeout", "shutdown"])
 
942
 
 
943
    def __init__(self, sock, latency, bandwidth=1.0, 
 
944
                 really_sleep=True):
 
945
        """ 
 
946
        :param bandwith: simulated bandwith (MegaBit)
 
947
        :param really_sleep: If set to false, the SocketDelay will just
 
948
        increase a counter, instead of calling time.sleep. This is useful for
 
949
        unittesting the SocketDelay.
 
950
        """
 
951
        self.sock = sock
 
952
        self.latency = latency
 
953
        self.really_sleep = really_sleep
 
954
        self.time_per_byte = 1 / (bandwidth / 8.0 * 1024 * 1024) 
 
955
        self.new_roundtrip = False
 
956
 
 
957
    def sleep(self, s):
 
958
        if self.really_sleep:
 
959
            time.sleep(s)
 
960
        else:
 
961
            SocketDelay.simulated_time += s
 
962
 
 
963
    def __getattr__(self, attr):
 
964
        if attr in SocketDelay._proxied_arguments:
 
965
            return getattr(self.sock, attr)
 
966
        raise AttributeError("'SocketDelay' object has no attribute %r" %
 
967
                             attr)
 
968
 
 
969
    def dup(self):
 
970
        return SocketDelay(self.sock.dup(), self.latency, self.time_per_byte,
 
971
                           self._sleep)
 
972
 
 
973
    def recv(self, *args):
 
974
        data = self.sock.recv(*args)
 
975
        if data and self.new_roundtrip:
 
976
            self.new_roundtrip = False
 
977
            self.sleep(self.latency)
 
978
        self.sleep(len(data) * self.time_per_byte)
 
979
        return data
 
980
 
 
981
    def sendall(self, data, flags=0):
 
982
        if not self.new_roundtrip:
 
983
            self.new_roundtrip = True
 
984
            self.sleep(self.latency)
 
985
        self.sleep(len(data) * self.time_per_byte)
 
986
        return self.sock.sendall(data, flags)
 
987
 
 
988
    def send(self, data, flags=0):
 
989
        if not self.new_roundtrip:
 
990
            self.new_roundtrip = True
 
991
            self.sleep(self.latency)
 
992
        bytes_sent = self.sock.send(data, flags)
 
993
        self.sleep(bytes_sent * self.time_per_byte)
 
994
        return bytes_sent
 
995
 
 
996
 
 
997
class SFTPServer(Server):
 
998
    """Common code for SFTP server facilities."""
 
999
 
 
1000
    def __init__(self, server_interface=StubServer):
 
1001
        self._original_vendor = None
 
1002
        self._homedir = None
 
1003
        self._server_homedir = None
 
1004
        self._listener = None
 
1005
        self._root = None
 
1006
        self._vendor = ssh.ParamikoVendor()
 
1007
        self._server_interface = server_interface
 
1008
        # sftp server logs
 
1009
        self.logs = []
 
1010
        self.add_latency = 0
 
1011
 
 
1012
    def _get_sftp_url(self, path):
 
1013
        """Calculate an sftp url to this server for path."""
 
1014
        return 'sftp://foo:bar@localhost:%d/%s' % (self._listener.port, path)
 
1015
 
 
1016
    def log(self, message):
 
1017
        """StubServer uses this to log when a new server is created."""
 
1018
        self.logs.append(message)
 
1019
 
 
1020
    def _run_server_entry(self, sock):
 
1021
        """Entry point for all implementations of _run_server.
 
1022
        
 
1023
        If self.add_latency is > 0.000001 then sock is given a latency adding
 
1024
        decorator.
 
1025
        """
 
1026
        if self.add_latency > 0.000001:
 
1027
            sock = SocketDelay(sock, self.add_latency)
 
1028
        return self._run_server(sock)
 
1029
 
 
1030
    def _run_server(self, s):
 
1031
        ssh_server = paramiko.Transport(s)
 
1032
        key_file = pathjoin(self._homedir, 'test_rsa.key')
 
1033
        f = open(key_file, 'w')
 
1034
        f.write(STUB_SERVER_KEY)
 
1035
        f.close()
 
1036
        host_key = paramiko.RSAKey.from_private_key_file(key_file)
 
1037
        ssh_server.add_server_key(host_key)
 
1038
        server = self._server_interface(self)
 
1039
        ssh_server.set_subsystem_handler('sftp', paramiko.SFTPServer,
 
1040
                                         StubSFTPServer, root=self._root,
 
1041
                                         home=self._server_homedir)
 
1042
        event = threading.Event()
 
1043
        ssh_server.start_server(event, server)
 
1044
        event.wait(5.0)
 
1045
    
 
1046
    def setUp(self, backing_server=None):
 
1047
        # XXX: TODO: make sftpserver back onto backing_server rather than local
 
1048
        # disk.
 
1049
        if not (backing_server is None or
 
1050
                isinstance(backing_server, local.LocalURLServer)):
 
1051
            raise AssertionError(
 
1052
                "backing_server should not be %r, because this can only serve the "
 
1053
                "local current working directory." % (backing_server,))
 
1054
        self._original_vendor = ssh._ssh_vendor_manager._cached_ssh_vendor
 
1055
        ssh._ssh_vendor_manager._cached_ssh_vendor = self._vendor
 
1056
        if sys.platform == 'win32':
 
1057
            # Win32 needs to use the UNICODE api
 
1058
            self._homedir = getcwd()
 
1059
        else:
 
1060
            # But Linux SFTP servers should just deal in bytestreams
 
1061
            self._homedir = os.getcwd()
 
1062
        if self._server_homedir is None:
 
1063
            self._server_homedir = self._homedir
 
1064
        self._root = '/'
 
1065
        if sys.platform == 'win32':
 
1066
            self._root = ''
 
1067
        self._listener = SocketListener(self._run_server_entry)
 
1068
        self._listener.setDaemon(True)
 
1069
        self._listener.start()
 
1070
 
 
1071
    def tearDown(self):
 
1072
        """See bzrlib.transport.Server.tearDown."""
 
1073
        self._listener.stop()
 
1074
        ssh._ssh_vendor_manager._cached_ssh_vendor = self._original_vendor
 
1075
 
 
1076
    def get_bogus_url(self):
 
1077
        """See bzrlib.transport.Server.get_bogus_url."""
 
1078
        # this is chosen to try to prevent trouble with proxies, wierd dns, etc
 
1079
        # we bind a random socket, so that we get a guaranteed unused port
 
1080
        # we just never listen on that port
 
1081
        s = socket.socket()
 
1082
        s.bind(('localhost', 0))
 
1083
        return 'sftp://%s:%s/' % s.getsockname()
 
1084
 
 
1085
 
 
1086
class SFTPFullAbsoluteServer(SFTPServer):
 
1087
    """A test server for sftp transports, using absolute urls and ssh."""
 
1088
 
 
1089
    def get_url(self):
 
1090
        """See bzrlib.transport.Server.get_url."""
 
1091
        homedir = self._homedir
 
1092
        if sys.platform != 'win32':
 
1093
            # Remove the initial '/' on all platforms but win32
 
1094
            homedir = homedir[1:]
 
1095
        return self._get_sftp_url(urlutils.escape(homedir))
 
1096
 
 
1097
 
 
1098
class SFTPServerWithoutSSH(SFTPServer):
 
1099
    """An SFTP server that uses a simple TCP socket pair rather than SSH."""
 
1100
 
 
1101
    def __init__(self):
 
1102
        super(SFTPServerWithoutSSH, self).__init__()
 
1103
        self._vendor = ssh.LoopbackVendor()
 
1104
 
 
1105
    def _run_server(self, sock):
 
1106
        # Re-import these as locals, so that they're still accessible during
 
1107
        # interpreter shutdown (when all module globals get set to None, leading
 
1108
        # to confusing errors like "'NoneType' object has no attribute 'error'".
 
1109
        class FakeChannel(object):
 
1110
            def get_transport(self):
 
1111
                return self
 
1112
            def get_log_channel(self):
 
1113
                return 'paramiko'
 
1114
            def get_name(self):
 
1115
                return '1'
 
1116
            def get_hexdump(self):
 
1117
                return False
 
1118
            def close(self):
 
1119
                pass
 
1120
 
 
1121
        server = paramiko.SFTPServer(
 
1122
            FakeChannel(), 'sftp', StubServer(self), StubSFTPServer,
 
1123
            root=self._root, home=self._server_homedir)
 
1124
        try:
 
1125
            server.start_subsystem(
 
1126
                'sftp', None, ssh.SocketAsChannelAdapter(sock))
 
1127
        except socket.error, e:
 
1128
            if (len(e.args) > 0) and (e.args[0] == errno.EPIPE):
 
1129
                # it's okay for the client to disconnect abruptly
 
1130
                # (bug in paramiko 1.6: it should absorb this exception)
 
1131
                pass
 
1132
            else:
 
1133
                raise
 
1134
        except Exception, e:
 
1135
            # This typically seems to happen during interpreter shutdown, so
 
1136
            # most of the useful ways to report this error are won't work.
 
1137
            # Writing the exception type, and then the text of the exception,
 
1138
            # seems to be the best we can do.
 
1139
            import sys
 
1140
            sys.stderr.write('\nEXCEPTION %r: ' % (e.__class__,))
 
1141
            sys.stderr.write('%s\n\n' % (e,))
 
1142
        server.finish_subsystem()
 
1143
 
 
1144
 
 
1145
class SFTPAbsoluteServer(SFTPServerWithoutSSH):
 
1146
    """A test server for sftp transports, using absolute urls."""
 
1147
 
 
1148
    def get_url(self):
 
1149
        """See bzrlib.transport.Server.get_url."""
 
1150
        homedir = self._homedir
 
1151
        if sys.platform != 'win32':
 
1152
            # Remove the initial '/' on all platforms but win32
 
1153
            homedir = homedir[1:]
 
1154
        return self._get_sftp_url(urlutils.escape(homedir))
 
1155
 
 
1156
 
 
1157
class SFTPHomeDirServer(SFTPServerWithoutSSH):
 
1158
    """A test server for sftp transports, using homedir relative urls."""
 
1159
 
 
1160
    def get_url(self):
 
1161
        """See bzrlib.transport.Server.get_url."""
 
1162
        return self._get_sftp_url("~/")
 
1163
 
 
1164
 
 
1165
class SFTPSiblingAbsoluteServer(SFTPAbsoluteServer):
 
1166
    """A test server for sftp transports where only absolute paths will work.
 
1167
 
 
1168
    It does this by serving from a deeply-nested directory that doesn't exist.
 
1169
    """
 
1170
 
 
1171
    def setUp(self, backing_server=None):
 
1172
        self._server_homedir = '/dev/noone/runs/tests/here'
 
1173
        super(SFTPSiblingAbsoluteServer, self).setUp(backing_server)
 
1174
 
 
1175
 
 
1176
def get_test_permutations():
 
1177
    """Return the permutations to be used in testing."""
 
1178
    return [(SFTPTransport, SFTPAbsoluteServer),
 
1179
            (SFTPTransport, SFTPHomeDirServer),
 
1180
            (SFTPTransport, SFTPSiblingAbsoluteServer),
 
1181
            ]