~bzr-pqm/bzr/bzr.dev

# Copyright (C) 2005, 2006, 2008, 2009, 2010 Robey Pointer <robey@lag.net>, Canonical Ltd

#

# This program is free software; you can redistribute it and/or modify

# it under the terms of the GNU General Public License as published by

# the Free Software Foundation; either version 2 of the License, or

# (at your option) any later version.

#

# This program is distributed in the hope that it will be useful,

# but WITHOUT ANY WARRANTY; without even the implied warranty of

# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

# GNU General Public License for more details.

#

# You should have received a copy of the GNU General Public License

# along with this program; if not, write to the Free Software

# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA

"""

A stub SFTP server for loopback SFTP testing.

Adapted from the one in paramiko's unit tests.

"""

import os

import paramiko

import select

import socket

import sys

import threading

import time

from bzrlib import (

    osutils,

    trace,

    urlutils,

    )

from bzrlib.transport import (

    ssh,

    )

from bzrlib.tests import test_server

class StubServer (paramiko.ServerInterface):

    def __init__(self, test_case):

        paramiko.ServerInterface.__init__(self)

        self._test_case = test_case

    def check_auth_password(self, username, password):

        # all are allowed

        self._test_case.log('sftpserver - authorizing: %s' % (username,))

        return paramiko.AUTH_SUCCESSFUL

    def check_channel_request(self, kind, chanid):

        self._test_case.log(

            'sftpserver - channel request: %s, %s' % (kind, chanid))

        return paramiko.OPEN_SUCCEEDED

class StubSFTPHandle (paramiko.SFTPHandle):

    def stat(self):

        try:

            return paramiko.SFTPAttributes.from_stat(

                os.fstat(self.readfile.fileno()))

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

    def chattr(self, attr):

        # python doesn't have equivalents to fchown or fchmod, so we have to

        # use the stored filename

        trace.mutter('Changing permissions on %s to %s', self.filename, attr)

        try:

            paramiko.SFTPServer.set_file_attr(self.filename, attr)

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

class StubSFTPServer (paramiko.SFTPServerInterface):

    def __init__(self, server, root, home=None):

        paramiko.SFTPServerInterface.__init__(self, server)

        # All paths are actually relative to 'root'.

        # this is like implementing chroot().

        self.root = root

        if home is None:

            self.home = ''

        else:

            if not home.startswith(self.root):

                raise AssertionError(

                    "home must be a subdirectory of root (%s vs %s)"

                    % (home, root))

            self.home = home[len(self.root):]

        if self.home.startswith('/'):

            self.home = self.home[1:]

        server._test_case.log('sftpserver - new connection')

    def _realpath(self, path):

        # paths returned from self.canonicalize() always start with

        # a path separator. So if 'root' is just '/', this would cause

        # a double slash at the beginning '//home/dir'.

        if self.root == '/':

            return self.canonicalize(path)

        return self.root + self.canonicalize(path)

    if sys.platform == 'win32':

        def canonicalize(self, path):

            # Win32 sftp paths end up looking like

            #     sftp://host@foo/h:/foo/bar

            # which means absolute paths look like:

            #     /h:/foo/bar

            # and relative paths stay the same:

            #     foo/bar

            # win32 needs to use the Unicode APIs. so we require the

            # paths to be utf8 (Linux just uses bytestreams)

            thispath = path.decode('utf8')

            if path.startswith('/'):

                # Abspath H:/foo/bar

                return os.path.normpath(thispath[1:])

            else:

                return os.path.normpath(os.path.join(self.home, thispath))

    else:

        def canonicalize(self, path):

            if os.path.isabs(path):

                return os.path.normpath(path)

            else:

                return os.path.normpath('/' + os.path.join(self.home, path))

    def chattr(self, path, attr):

        try:

            paramiko.SFTPServer.set_file_attr(path, attr)

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

        return paramiko.SFTP_OK

    def list_folder(self, path):

        path = self._realpath(path)

        try:

            out = [ ]

            # TODO: win32 incorrectly lists paths with non-ascii if path is not

            # unicode. However on unix the server should only deal with

            # bytestreams and posix.listdir does the right thing

            if sys.platform == 'win32':

                flist = [f.encode('utf8') for f in os.listdir(path)]

            else:

                flist = os.listdir(path)

            for fname in flist:

                attr = paramiko.SFTPAttributes.from_stat(

                    os.stat(osutils.pathjoin(path, fname)))

                attr.filename = fname

                out.append(attr)

            return out

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

    def stat(self, path):

        path = self._realpath(path)

        try:

            return paramiko.SFTPAttributes.from_stat(os.stat(path))

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

    def lstat(self, path):

        path = self._realpath(path)

        try:

            return paramiko.SFTPAttributes.from_stat(os.lstat(path))

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

    def open(self, path, flags, attr):

        path = self._realpath(path)

        try:

            flags |= getattr(os, 'O_BINARY', 0)

            if getattr(attr, 'st_mode', None):

                fd = os.open(path, flags, attr.st_mode)

            else:

                # os.open() defaults to 0777 which is

                # an odd default mode for files

                fd = os.open(path, flags, 0666)

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

        if (flags & os.O_CREAT) and (attr is not None):

            attr._flags &= ~attr.FLAG_PERMISSIONS

            paramiko.SFTPServer.set_file_attr(path, attr)

        if flags & os.O_WRONLY:

            fstr = 'wb'

        elif flags & os.O_RDWR:

            fstr = 'rb+'

        else:

            # O_RDONLY (== 0)

            fstr = 'rb'

        try:

            f = os.fdopen(fd, fstr)

        except (IOError, OSError), e:

            return paramiko.SFTPServer.convert_errno(e.errno)

        fobj = StubSFTPHandle()

        fobj.filename = path

        fobj.readfile = f

        fobj.writefile = f

        return fobj

    def remove(self, path):

        path = self._realpath(path)

        try:

            os.remove(path)

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

        return paramiko.SFTP_OK

    def rename(self, oldpath, newpath):

        oldpath = self._realpath(oldpath)

        newpath = self._realpath(newpath)

        try:

            os.rename(oldpath, newpath)

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

        return paramiko.SFTP_OK

    def mkdir(self, path, attr):

        path = self._realpath(path)

        try:

            # Using getattr() in case st_mode is None or 0

            # both evaluate to False

            if getattr(attr, 'st_mode', None):

                os.mkdir(path, attr.st_mode)

            else:

                os.mkdir(path)

            if attr is not None:

                attr._flags &= ~attr.FLAG_PERMISSIONS

                paramiko.SFTPServer.set_file_attr(path, attr)

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

        return paramiko.SFTP_OK

    def rmdir(self, path):

        path = self._realpath(path)

        try:

            os.rmdir(path)

        except OSError, e:

            return paramiko.SFTPServer.convert_errno(e.errno)

        return paramiko.SFTP_OK

    # removed: chattr, symlink, readlink

    # (nothing in bzr's sftp transport uses those)

# ------------- server test implementation --------------

STUB_SERVER_KEY = """

-----BEGIN RSA PRIVATE KEY-----

MIICWgIBAAKBgQDTj1bqB4WmayWNPB+8jVSYpZYk80Ujvj680pOTh2bORBjbIAyz

oWGW+GUjzKxTiiPvVmxFgx5wdsFvF03v34lEVVhMpouqPAYQ15N37K/ir5XY+9m/

d8ufMCkjeXsQkKqFbAlQcnWMCRnOoPHS3I4vi6hmnDDeeYTSRvfLbW0fhwIBIwKB

gBIiOqZYaoqbeD9OS9z2K9KR2atlTxGxOJPXiP4ESqP3NVScWNwyZ3NXHpyrJLa0

EbVtzsQhLn6rF+TzXnOlcipFvjsem3iYzCpuChfGQ6SovTcOjHV9z+hnpXvQ/fon

soVRZY65wKnF7IAoUwTmJS9opqgrN6kRgCd3DASAMd1bAkEA96SBVWFt/fJBNJ9H

tYnBKZGw0VeHOYmVYbvMSstssn8un+pQpUm9vlG/bp7Oxd/m+b9KWEh2xPfv6zqU

avNwHwJBANqzGZa/EpzF4J8pGti7oIAPUIDGMtfIcmqNXVMckrmzQ2vTfqtkEZsA

4rE1IERRyiJQx6EJsz21wJmGV9WJQ5kCQQDwkS0uXqVdFzgHO6S++tjmjYcxwr3g

H0CoFYSgbddOT6miqRskOQF3DZVkJT3kyuBgU2zKygz52ukQZMqxCb1fAkASvuTv

qfpH87Qq5kQhNKdbbwbmd2NxlNabazPijWuphGTdW0VfJdWfklyS2Kr+iqrs/5wV

HhathJt636Eg7oIjAkA8ht3MQ+XSl9yIJIS8gVpbPxSw5OMfw0PjVE7tBdQruiSc

nvuQES5C9BMHjF39LZiGH1iLQy7FgdHyoP+eodI7

-----END RSA PRIVATE KEY-----

"""

class SocketListener(threading.Thread):

    def __init__(self, callback):

        threading.Thread.__init__(self)

        self._callback = callback

        self._socket = socket.socket()

        self._socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

        self._socket.bind(('localhost', 0))

        self._socket.listen(1)

        self.host, self.port = self._socket.getsockname()[:2]

        self._stop_event = threading.Event()

    def stop(self):

        # called from outside this thread

        self._stop_event.set()

        # use a timeout here, because if the test fails, the server thread may

        # never notice the stop_event.

        self.join(5.0)

        self._socket.close()

    def run(self):

        trace.mutter('SocketListener %r has started', self)

        while True:

            readable, writable_unused, exception_unused = \

                select.select([self._socket], [], [], 0.1)

            if self._stop_event.isSet():

                trace.mutter('SocketListener %r has stopped', self)

                return

            if len(readable) == 0:

                continue

            try:

                s, addr_unused = self._socket.accept()

                trace.mutter('SocketListener %r has accepted connection %r',

                    self, s)

                # because the loopback socket is inline, and transports are

                # never explicitly closed, best to launch a new thread.

                threading.Thread(target=self._callback, args=(s,)).start()

            except socket.error, x:

                sys.excepthook(*sys.exc_info())

                trace.warning('Socket error during accept() '

                              'within unit test server thread: %r' % x)

            except Exception, x:

                # probably a failed test; unit test thread will log the

                # failure/error

                sys.excepthook(*sys.exc_info())

                trace.warning(

                    'Exception from within unit test server thread: %r' % x)

class SocketDelay(object):

    """A socket decorator to make TCP appear slower.

    This changes recv, send, and sendall to add a fixed latency to each python

    call if a new roundtrip is detected. That is, when a recv is called and the

    flag new_roundtrip is set, latency is charged. Every send and send_all

    sets this flag.

    In addition every send, sendall and recv sleeps a bit per character send to

    simulate bandwidth.

    Not all methods are implemented, this is deliberate as this class is not a

    replacement for the builtin sockets layer. fileno is not implemented to

    prevent the proxy being bypassed.

    """

    simulated_time = 0

    _proxied_arguments = dict.fromkeys([

        "close", "getpeername", "getsockname", "getsockopt", "gettimeout",

        "setblocking", "setsockopt", "settimeout", "shutdown"])

    def __init__(self, sock, latency, bandwidth=1.0,

                 really_sleep=True):

        """

        :param bandwith: simulated bandwith (MegaBit)

        :param really_sleep: If set to false, the SocketDelay will just

        increase a counter, instead of calling time.sleep. This is useful for

        unittesting the SocketDelay.

        """

        self.sock = sock

        self.latency = latency

        self.really_sleep = really_sleep

        self.time_per_byte = 1 / (bandwidth / 8.0 * 1024 * 1024)

        self.new_roundtrip = False

    def sleep(self, s):

        if self.really_sleep:

            time.sleep(s)

        else:

            SocketDelay.simulated_time += s

    def __getattr__(self, attr):

        if attr in SocketDelay._proxied_arguments:

            return getattr(self.sock, attr)

        raise AttributeError("'SocketDelay' object has no attribute %r" %

                             attr)

    def dup(self):

        return SocketDelay(self.sock.dup(), self.latency, self.time_per_byte,

                           self._sleep)

    def recv(self, *args):

        data = self.sock.recv(*args)

        if data and self.new_roundtrip:

            self.new_roundtrip = False

            self.sleep(self.latency)

        self.sleep(len(data) * self.time_per_byte)

        return data

    def sendall(self, data, flags=0):

        if not self.new_roundtrip:

            self.new_roundtrip = True

            self.sleep(self.latency)

        self.sleep(len(data) * self.time_per_byte)

        return self.sock.sendall(data, flags)

    def send(self, data, flags=0):

        if not self.new_roundtrip:

            self.new_roundtrip = True

            self.sleep(self.latency)

        bytes_sent = self.sock.send(data, flags)

        self.sleep(bytes_sent * self.time_per_byte)

        return bytes_sent

class SFTPServer(test_server.TestServer):

    """Common code for SFTP server facilities."""

    def __init__(self, server_interface=StubServer):

        self._original_vendor = None

        self._homedir = None

        self._server_homedir = None

        self._listener = None

        self._root = None

        self._vendor = ssh.ParamikoVendor()

        self._server_interface = server_interface

        # sftp server logs

        self.logs = []

        self.add_latency = 0

    def _get_sftp_url(self, path):

        """Calculate an sftp url to this server for path."""

        return 'sftp://foo:bar@%s:%d/%s' % (self._listener.host,

                                            self._listener.port, path)

    def log(self, message):

        """StubServer uses this to log when a new server is created."""

        self.logs.append(message)

    def _run_server_entry(self, sock):

        """Entry point for all implementations of _run_server.

        If self.add_latency is > 0.000001 then sock is given a latency adding

        decorator.

        """

        if self.add_latency > 0.000001:

            sock = SocketDelay(sock, self.add_latency)

        return self._run_server(sock)

    def _run_server(self, s):

        ssh_server = paramiko.Transport(s)

        key_file = osutils.pathjoin(self._homedir, 'test_rsa.key')

        f = open(key_file, 'w')

        f.write(STUB_SERVER_KEY)

        f.close()

        host_key = paramiko.RSAKey.from_private_key_file(key_file)

        ssh_server.add_server_key(host_key)

        server = self._server_interface(self)

        ssh_server.set_subsystem_handler('sftp', paramiko.SFTPServer,

                                         StubSFTPServer, root=self._root,

                                         home=self._server_homedir)

        event = threading.Event()

        ssh_server.start_server(event, server)

        event.wait(5.0)

    def start_server(self, backing_server=None):

        # XXX: TODO: make sftpserver back onto backing_server rather than local

        # disk.

        if not (backing_server is None or

                isinstance(backing_server, test_server.LocalURLServer)):

            raise AssertionError(

                'backing_server should not be %r, because this can only serve '

                'the local current working directory.' % (backing_server,))

        self._original_vendor = ssh._ssh_vendor_manager._cached_ssh_vendor

        ssh._ssh_vendor_manager._cached_ssh_vendor = self._vendor

        if sys.platform == 'win32':

            # Win32 needs to use the UNICODE api

            self._homedir = os.getcwdu()

            # Normalize the path or it will be wrongly escaped

            self._homedir = osutils.normpath(self._homedir)

        else:

            # But unix SFTP servers should just deal in bytestreams

            self._homedir = os.getcwd()

        if self._server_homedir is None:

            self._server_homedir = self._homedir

        self._root = '/'

        if sys.platform == 'win32':

            self._root = ''

        self._listener = SocketListener(self._run_server_entry)

        self._listener.setDaemon(True)

        self._listener.start()

    def stop_server(self):

        self._listener.stop()

        ssh._ssh_vendor_manager._cached_ssh_vendor = self._original_vendor

    def get_bogus_url(self):

        """See bzrlib.transport.Server.get_bogus_url."""

        # this is chosen to try to prevent trouble with proxies, wierd dns, etc

        # we bind a random socket, so that we get a guaranteed unused port

        # we just never listen on that port

        s = socket.socket()

        s.bind(('localhost', 0))

        return 'sftp://%s:%s/' % s.getsockname()

class SFTPFullAbsoluteServer(SFTPServer):

    """A test server for sftp transports, using absolute urls and ssh."""

    def get_url(self):

        """See bzrlib.transport.Server.get_url."""

        homedir = self._homedir

        if sys.platform != 'win32':

            # Remove the initial '/' on all platforms but win32

            homedir = homedir[1:]

        return self._get_sftp_url(urlutils.escape(homedir))

class SFTPServerWithoutSSH(SFTPServer):

    """An SFTP server that uses a simple TCP socket pair rather than SSH."""

    def __init__(self):

        super(SFTPServerWithoutSSH, self).__init__()

        self._vendor = ssh.LoopbackVendor()

    def _run_server(self, sock):

        # Re-import these as locals, so that they're still accessible during

        # interpreter shutdown (when all module globals get set to None, leading

        # to confusing errors like "'NoneType' object has no attribute 'error'".

        class FakeChannel(object):

            def get_transport(self):

                return self

            def get_log_channel(self):

                return 'paramiko'

            def get_name(self):

                return '1'

            def get_hexdump(self):

                return False

            def close(self):

                pass

        server = paramiko.SFTPServer(

            FakeChannel(), 'sftp', StubServer(self), StubSFTPServer,

            root=self._root, home=self._server_homedir)

        try:

            server.start_subsystem(

                'sftp', None, ssh.SocketAsChannelAdapter(sock))

        except socket.error, e:

            if (len(e.args) > 0) and (e.args[0] == errno.EPIPE):

                # it's okay for the client to disconnect abruptly

                # (bug in paramiko 1.6: it should absorb this exception)

                pass

            else:

                raise

        except Exception, e:

            # This typically seems to happen during interpreter shutdown, so

            # most of the useful ways to report this error are won't work.

            # Writing the exception type, and then the text of the exception,

            # seems to be the best we can do.

            import sys

            sys.stderr.write('\nEXCEPTION %r: ' % (e.__class__,))

            sys.stderr.write('%s\n\n' % (e,))

        server.finish_subsystem()

class SFTPAbsoluteServer(SFTPServerWithoutSSH):

    """A test server for sftp transports, using absolute urls."""

    def get_url(self):

        """See bzrlib.transport.Server.get_url."""

        homedir = self._homedir

        if sys.platform != 'win32':

            # Remove the initial '/' on all platforms but win32

            homedir = homedir[1:]

        return self._get_sftp_url(urlutils.escape(homedir))

class SFTPHomeDirServer(SFTPServerWithoutSSH):

    """A test server for sftp transports, using homedir relative urls."""

    def get_url(self):

        """See bzrlib.transport.Server.get_url."""

        return self._get_sftp_url("~/")

class SFTPSiblingAbsoluteServer(SFTPAbsoluteServer):

    """A test server for sftp transports where only absolute paths will work.

    It does this by serving from a deeply-nested directory that doesn't exist.

    """

    def start_server(self, backing_server=None):

        self._server_homedir = '/dev/noone/runs/tests/here'

        super(SFTPSiblingAbsoluteServer, self).start_server(backing_server)