Merge lp:~jelmer/brz/medusa into lp:brz

[Jelmer Vernooij]

Drop support for medusa, support newer versions of pyftpdlib.

Drop support for medusa.

Support newer versions of pyftpdlib.

[Martin Packman (gz)]

Looks good to me.

review: Approve

=== modified file 'breezy/tests/ftp_server/__init__.py'
--- breezy/tests/ftp_server/__init__.py	2017-05-21 18:10:28 +0000
+++ breezy/tests/ftp_server/__init__.py	2017-06-11 13:38:25 +0000
@@ -27,27 +27,11 @@
 
 
 try:
-    from breezy.tests.ftp_server import medusa_based
-    # medusa is bogus starting with python2.6, since we don't support earlier
-    # pythons anymore, it's currently useless. There is hope though that the
-    # unicode bugs get fixed in the future so we leave it disabled until
-    # then. Keeping the framework in place means that only the following line
-    # will need to be changed.  The last tests were conducted with medusa-2.0
-    # -- vila 20110607
-    medusa_available = False
-except ImportError:
-    medusa_available = False
-
-
-try:
-    from breezy.tests.ftp_server import pyftpdlib_based
-    if pyftpdlib_based.pyftplib_version >= (0, 7, 0):
-        pyftpdlib_available = True
-    else:
-        # 0.6.0 breaks SITE CHMOD
-        pyftpdlib_available = False
+    import pyftpdlib
 except ImportError:
     pyftpdlib_available = False
+else:
+    pyftpdlib_available = True
 
 
 class _FTPServerFeature(features.Feature):
@@ -56,12 +40,11 @@
     Right now, the only way this is available is if one of the following is
     installed:
 
-    - 'medusa': http://www.amk.ca/python/code/medusa.html
     - 'pyftpdlib': http://code.google.com/p/pyftpdlib/
     """
 
     def _probe(self):
-        return medusa_available or pyftpdlib_available
+        return pyftpdlib_available
 
     def feature_name(self):
         return 'FTPServer'
@@ -92,9 +75,8 @@
         raise tests.UnavailableFeature(FTPServerFeature)
 
 
-if medusa_available:
-    FTPTestServer = medusa_based.FTPTestServer
-elif pyftpdlib_available:
+if pyftpdlib_available:
+    from . import pyftpdlib_based
     FTPTestServer = pyftpdlib_based.FTPTestServer
 else:
     FTPTestServer = UnavailableFTPTestServer

=== removed file 'breezy/tests/ftp_server/medusa_based.py'
--- breezy/tests/ftp_server/medusa_based.py	2017-05-22 00:56:52 +0000
+++ breezy/tests/ftp_server/medusa_based.py	1970-01-01 00:00:00 +0000
@@ -1,295 +0,0 @@
-# Copyright (C) 2007-2010 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
-"""
-FTP test server.
-
-Based on medusa: http://www.amk.ca/python/code/medusa.html
-"""
-
-import asyncore
-import errno
-import os
-import select
-import stat
-import threading
-
-import medusa
-import medusa.filesys
-import medusa.ftp_server
-
-from ... import (
-    osutils,
-    tests,
-    trace,
-    )
-from .. import test_server
-
-
-class test_filesystem(medusa.filesys.os_filesystem):
-    """A custom filesystem wrapper to add missing functionalities."""
-
-    def chmod(self, path, mode):
-        p = self.normalize(self.path_module.join (self.wd, path))
-        return os.chmod(self.translate(p), mode)
-
-
-class test_authorizer(object):
-    """A custom Authorizer object for running the test suite.
-
-    The reason we cannot use dummy_authorizer, is because it sets the
-    channel to readonly, which we don't always want to do.
-    """
-
-    def __init__(self, root):
-        self.root = root
-        # If secured_user is set secured_password will be checked
-        self.secured_user = None
-        self.secured_password = None
-
-    def authorize(self, channel, username, password):
-        """Return (success, reply_string, filesystem)"""
-        channel.persona = -1, -1
-        if username == 'anonymous':
-            channel.read_only = 1
-        else:
-            channel.read_only = 0
-
-        # Check secured_user if set
-        if (self.secured_user is not None
-            and username == self.secured_user
-            and password != self.secured_password):
-            return 0, 'Password invalid.', None
-        else:
-            return 1, 'OK.', test_filesystem(self.root)
-
-
-class ftp_channel(medusa.ftp_server.ftp_channel):
-    """Customized ftp channel"""
-
-    def log(self, message):
-        """Redirect logging requests."""
-        trace.mutter('ftp_channel: %s', message)
-
-    def log_info(self, message, type='info'):
-        """Redirect logging requests."""
-        trace.mutter('ftp_channel %s: %s', type, message)
-
-    def cmd_rnfr(self, line):
-        """Prepare for renaming a file."""
-        self._renaming = line[1]
-        self.respond('350 Ready for RNTO')
-        # TODO: jam 20060516 in testing, the ftp server seems to
-        #       check that the file already exists, or it sends
-        #       550 RNFR command failed
-
-    def cmd_rnto(self, line):
-        """Rename a file based on the target given.
-
-        rnto must be called after calling rnfr.
-        """
-        if not self._renaming:
-            self.respond('503 RNFR required first.')
-        pfrom = self.filesystem.translate(self._renaming)
-        self._renaming = None
-        pto = self.filesystem.translate(line[1])
-        if os.path.exists(pto):
-            self.respond('550 RNTO failed: file exists')
-            return
-        try:
-            os.rename(pfrom, pto)
-        except (IOError, OSError) as e:
-            # TODO: jam 20060516 return custom responses based on
-            #       why the command failed
-            # (bialix 20070418) str(e) on Python 2.5 @ Windows
-            # sometimes don't provide expected error message;
-            # so we obtain such message via os.strerror()
-            self.respond('550 RNTO failed: %s' % os.strerror(e.errno))
-        except:
-            self.respond('550 RNTO failed')
-            # For a test server, we will go ahead and just die
-            raise
-        else:
-            self.respond('250 Rename successful.')
-
-    def cmd_size(self, line):
-        """Return the size of a file
-
-        This is overloaded to help the test suite determine if the
-        target is a directory.
-        """
-        filename = line[1]
-        if not self.filesystem.isfile(filename):
-            if self.filesystem.isdir(filename):
-                self.respond('550 "%s" is a directory' % (filename,))
-            else:
-                self.respond('550 "%s" is not a file' % (filename,))
-        else:
-            self.respond('213 %d'
-                % (self.filesystem.stat(filename)[stat.ST_SIZE]),)
-
-    def cmd_mkd(self, line):
-        """Create a directory.
-
-        Overloaded because default implementation does not distinguish
-        *why* it cannot make a directory.
-        """
-        if len (line) != 2:
-            self.command_not_understood(''.join(line))
-        else:
-            path = line[1]
-            try:
-                self.filesystem.mkdir (path)
-                self.respond ('257 MKD command successful.')
-            except (IOError, OSError) as e:
-                # (bialix 20070418) str(e) on Python 2.5 @ Windows
-                # sometimes don't provide expected error message;
-                # so we obtain such message via os.strerror()
-                self.respond ('550 error creating directory: %s' %
-                              os.strerror(e.errno))
-            except:
-                self.respond ('550 error creating directory.')
-
-    def cmd_site(self, line):
-        """Site specific commands."""
-        command, args = line[1].split(' ', 1)
-        if command.lower() == 'chmod':
-            try:
-                mode, path = args.split()
-                mode = int(mode, 8)
-            except ValueError:
-                # We catch both malformed line and malformed mode with the same
-                # ValueError.
-                self.command_not_understood(' '.join(line))
-                return
-            try:
-                # Yes path and mode are reversed
-                self.filesystem.chmod(path, mode)
-                self.respond('200 SITE CHMOD command successful')
-            except AttributeError:
-                # The chmod method is not available in read-only and will raise
-                # AttributeError since a different filesystem is used in that
-                # case
-                self.command_not_authorized(' '.join(line))
-        else:
-            # Another site specific command was requested. We don't know that
-            # one
-            self.command_not_understood(' '.join(line))
-
-
-class ftp_server(medusa.ftp_server.ftp_server):
-    """Customize the behavior of the Medusa ftp_server.
-
-    There are a few warts on the ftp_server, based on how it expects
-    to be used.
-    """
-    _renaming = None
-    ftp_channel_class = ftp_channel
-
-    def __init__(self, *args, **kwargs):
-        trace.mutter('Initializing ftp_server: %r, %r', args, kwargs)
-        medusa.ftp_server.ftp_server.__init__(self, *args, **kwargs)
-
-    def log(self, message):
-        """Redirect logging requests."""
-        trace.mutter('ftp_server: %s', message)
-
-    def log_info(self, message, type='info'):
-        """Override the asyncore.log_info so we don't stipple the screen."""
-        trace.mutter('ftp_server %s: %s', type, message)
-
-
-class FTPTestServer(test_server.TestServer):
-    """Common code for FTP server facilities."""
-
-    no_unicode_support = True
-
-    def __init__(self):
-        self._root = None
-        self._ftp_server = None
-        self._port = None
-        self._async_thread = None
-        # ftp server logs
-        self.logs = []
-
-    def get_url(self):
-        """Calculate an ftp url to this server."""
-        return 'ftp://foo:bar@localhost:%d/' % (self._port)
-
-    def get_bogus_url(self):
-        """Return a URL which cannot be connected to."""
-        return 'ftp://127.0.0.1:1'
-
-    def log(self, message):
-        """This is used by medusa.ftp_server to log connections, etc."""
-        self.logs.append(message)
-
-    def start_server(self, vfs_server=None):
-        if not (vfs_server is None or isinstance(vfs_server,
-                                                 test_server.LocalURLServer)):
-            raise AssertionError(
-                "FTPServer currently assumes local transport, got %s" % vfs_server)
-        self._root = osutils.getcwd()
-        self._ftp_server = ftp_server(
-            authorizer=test_authorizer(root=self._root),
-            ip='localhost',
-            port=0, # bind to a random port
-            resolver=None,
-            logger_object=self # Use FTPServer.log() for messages
-            )
-        self._port = self._ftp_server.getsockname()[1]
-        # Don't let it loop forever, or handle an infinite number of requests.
-        # In this case it will run for 1000s, or 10000 requests
-        self._async_thread = threading.Thread(
-                target=FTPTestServer._asyncore_loop_ignore_EBADF,
-                kwargs={'timeout':0.1, 'count':10000})
-        if 'threads' in tests.selftest_debug_flags:
-            sys.stderr.write('Thread started: %s\n'
-                             % (self._async_thread.ident,))
-        self._async_thread.setDaemon(True)
-        self._async_thread.start()
-
-    def stop_server(self):
-        self._ftp_server.close()
-        asyncore.close_all()
-        self._async_thread.join()
-        if 'threads' in tests.selftest_debug_flags:
-            sys.stderr.write('Thread  joined: %s\n'
-                             % (self._async_thread.ident,))
-
-    @staticmethod
-    def _asyncore_loop_ignore_EBADF(*args, **kwargs):
-        """Ignore EBADF during server shutdown.
-
-        We close the socket to get the server to shutdown, but this causes
-        select.select() to raise EBADF.
-        """
-        try:
-            asyncore.loop(*args, **kwargs)
-            # FIXME: If we reach that point, we should raise an exception
-            # explaining that the 'count' parameter in setUp is too low or
-            # testers may wonder why their test just sits there waiting for a
-            # server that is already dead. Note that if the tester waits too
-            # long under pdb the server will also die.
-        except select.error as e:
-            if e.args[0] != errno.EBADF:
-                raise
-
-    def add_user(self, user, password):
-        """Add a user with write access."""
-        authorizer = server = self._ftp_server.authorizer
-        authorizer.secured_user = user
-        authorizer.secured_password = password
-

=== modified file 'breezy/tests/ftp_server/pyftpdlib_based.py'
--- breezy/tests/ftp_server/pyftpdlib_based.py	2017-05-22 00:56:52 +0000
+++ breezy/tests/ftp_server/pyftpdlib_based.py	2017-06-11 13:38:25 +0000
@@ -20,8 +20,20 @@
 """
 
 import errno
+import logging
 import os
-from pyftpdlib import ftpserver
+import pyftpdlib
+import sys
+from pyftpdlib.authorizers import (
+    AuthorizerError,
+    DummyAuthorizer,
+    )
+from pyftpdlib.filesystems import AbstractedFS
+from pyftpdlib.handlers import (
+    FTPHandler,
+    proto_cmds,
+    )
+from pyftpdlib.servers import FTPServer
 import select
 import threading
 
@@ -34,22 +46,31 @@
 from breezy.tests import test_server
 
 
+class NullHandler(logging.Handler):
+
+    def emit(self, record):
+        pass
+
+# Shut up very verbose pyftpdlib
+logging.getLogger('pyftpdlib').addHandler(NullHandler())
+
+
 # Convert the pyftplib string version into a tuple to avoid traps in string
 # comparison.
-pyftplib_version = tuple(map(int, ftpserver.__ver__.split('.')))
-
-
-class AnonymousWithWriteAccessAuthorizer(ftpserver.DummyAuthorizer):
+pyftplib_version = tuple(map(int, pyftpdlib.__ver__.split('.')))
+
+
+class AnonymousWithWriteAccessAuthorizer(DummyAuthorizer):
 
     def _check_permissions(self, username, perm):
         # Like base implementation but don't warn about write permissions
         # assigned to anonymous, since that's exactly our purpose.
         for p in perm:
             if p not in self.read_perms + self.write_perms:
-                raise ftpserver.AuthorizerError('No such permission "%s"' %p)
-
-
-class BzrConformingFS(ftpserver.AbstractedFS):
+                raise AuthorizerError('No such permission "%s"' %p)
+
+
+class BzrConformingFS(AbstractedFS):
 
     def chmod(self, path, mode):
         return os.chmod(path, mode)
@@ -59,19 +80,20 @@
         return [osutils.safe_utf8(s) for s in os.listdir(path)]
 
     def fs2ftp(self, fspath):
-        p = ftpserver.AbstractedFS.fs2ftp(self, osutils.safe_unicode(fspath))
+        p = AbstractedFS.fs2ftp(self, osutils.safe_unicode(fspath))
         return osutils.safe_utf8(p)
 
     def ftp2fs(self, ftppath):
         p = osutils.safe_unicode(ftppath)
-        return ftpserver.AbstractedFS.ftp2fs(self, p)
-
-class BzrConformingFTPHandler(ftpserver.FTPHandler):
+        return AbstractedFS.ftp2fs(self, p)
+
+
+class BzrConformingFTPHandler(FTPHandler):
 
     abstracted_fs = BzrConformingFS
 
-    def __init__(self, conn, server):
-        ftpserver.FTPHandler.__init__(self, conn, server)
+    def __init__(self, conn, server, ioloop=None):
+        FTPHandler.__init__(self, conn, server)
         self.authorizer = server.authorizer
 
     def ftp_SIZE(self, path):
@@ -83,7 +105,7 @@
             self.log('FAIL SIZE "%s". %s.' % (line, why))
             self.respond("550 %s."  %why)
         else:
-            ftpserver.FTPHandler.ftp_SIZE(self, path)
+            FTPHandler.ftp_SIZE(self, path)
 
     def ftp_NLST(self, path):
         # bzr is overly picky here, but we want to make the test suite pass
@@ -94,7 +116,7 @@
             self.log('FAIL NLST "%s". %s.' % (line, why))
             self.respond("550 %s."  %why)
         else:
-            ftpserver.FTPHandler.ftp_NLST(self, path)
+            FTPHandler.ftp_NLST(self, path)
 
     def log_cmd(self, cmd, arg, respcode, respstr):
         # base class version choke on unicode, the alternative is to just
@@ -107,12 +129,12 @@
 
 
 # An empty password is valid, hence the arg is neither mandatory nor forbidden
-ftpserver.proto_cmds['PASS']['arg'] = None
+proto_cmds['PASS']['arg'] = None
 
-class ftp_server(ftpserver.FTPServer):
+class ftp_server(FTPServer):
 
     def __init__(self, address, handler, authorizer):
-        ftpserver.FTPServer.__init__(self, address, handler)
+        FTPServer.__init__(self, address, handler)
         self.authorizer = authorizer
         # Worth backporting upstream ?
         self.addr = self.socket.getsockname()
@@ -155,13 +177,6 @@
         authorizer.add_anonymous(self._root, perm='elradfmwM')
         self._ftp_server = ftp_server(address, BzrConformingFTPHandler,
                                       authorizer)
-        # This is hacky as hell, will not work if we need two servers working
-        # at the same time, but that's the best we can do so far...
-        # FIXME: At least log and logline could be overriden in the handler ?
-        # -- vila 20090227
-        ftpserver.log = self.log
-        ftpserver.logline = self.log
-        ftpserver.logerror = self.log
 
         self._port = self._ftp_server.socket.getsockname()[1]
         self._ftpd_starting = threading.Lock()
@@ -196,11 +211,11 @@
         self._ftpd_starting.release()
         while self._ftpd_running:
             try:
-                self._ftp_server.serve_forever(timeout=0.1, count=1)
+                self._ftp_server.serve_forever(timeout=0.1)
             except select.error as e:
                 if e.args[0] != errno.EBADF:
                     raise
-        self._ftp_server.close_all(ignore_all=True)
+        self._ftp_server.close_all()
 
     def add_user(self, user, password):
         """Add a user with write access."""

=== modified file 'doc/en/release-notes/brz-3.0.txt'
--- doc/en/release-notes/brz-3.0.txt	2017-06-11 01:27:46 +0000
+++ doc/en/release-notes/brz-3.0.txt	2017-06-11 13:38:25 +0000
@@ -41,6 +41,9 @@
    URL schemes "http+pycurl://" and "https+pycurl://" has been dropped.
    (Jelmer Vernooij, #82086, #377389, #122258, #516222, #545776, #1696602)
 
+ * Support for medusa for FTP tests has been dropped, only
+   pyftpdlib is now supported. (Jelmer Vernooij)
+
 New Features
 ************
 
@@ -135,5 +138,8 @@
    which caused ``output_encoding = iso-8859-1`` to be added to the
    users' bazaar.conf. (Jelmer Vernooij)
 
+ * Newer versions of ``pyftpdlib`` are now supported for running FTP tests.
+   (Jelmer Vernooij)
+
 ..
    vim: tw=74 ft=rst ff=unix

=== modified file 'setup.py'
--- setup.py	2017-06-07 00:34:37 +0000
+++ setup.py	2017-06-11 13:38:25 +0000
@@ -587,7 +587,6 @@
     excludes = """Tkinter psyco ElementPath r_hmac
                   ImaginaryModule cElementTree elementtree.ElementTree
                   Crypto.PublicKey._fastmath
-                  medusa medusa.filesys medusa.ftp_server
                   tools
                   resource validate""".split()
     dll_excludes = []