~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/tests/__init__.py

Late bind to PatienceSequenceMatcher to allow plugin to override.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005 by Canonical Ltd
 
1
# Copyright (C) 2005, 2006 by Canonical Ltd
2
2
 
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
17
17
 
 
18
# TODO: Perhaps there should be an API to find out if bzr running under the
 
19
# test suite -- some plugins might want to avoid making intrusive changes if
 
20
# this is the case.  However, we want behaviour under to test to diverge as
 
21
# little as possible, so this should be used rarely if it's added at all.
 
22
# (Suggestion from j-a-meinel, 2005-11-24)
 
23
 
 
24
# NOTE: Some classes in here use camelCaseNaming() rather than
 
25
# underscore_naming().  That's for consistency with unittest; it's not the
 
26
# general style of bzrlib.  Please continue that consistency when adding e.g.
 
27
# new assertFoo() methods.
 
28
 
 
29
import codecs
18
30
from cStringIO import StringIO
19
31
import difflib
20
32
import errno
21
33
import logging
22
34
import os
23
35
import re
24
 
import shutil
 
36
import stat
25
37
import sys
26
38
import tempfile
27
39
import unittest
28
40
import time
29
41
 
 
42
 
 
43
import bzrlib.branch
 
44
import bzrlib.bzrdir as bzrdir
30
45
import bzrlib.commands
 
46
import bzrlib.errors as errors
 
47
import bzrlib.inventory
 
48
import bzrlib.iterablefile
 
49
import bzrlib.lockdir
 
50
try:
 
51
    import bzrlib.lsprof
 
52
except ImportError:
 
53
    # lsprof not available
 
54
    pass
 
55
from bzrlib.merge import merge_inner
 
56
import bzrlib.merge3
 
57
import bzrlib.osutils
 
58
import bzrlib.osutils as osutils
 
59
import bzrlib.plugin
 
60
import bzrlib.progress as progress
 
61
from bzrlib.revision import common_ancestor
 
62
import bzrlib.store
31
63
import bzrlib.trace
32
 
import bzrlib.fetch
33
 
import bzrlib.osutils as osutils
34
 
from bzrlib.selftest import TestUtil
35
 
from bzrlib.selftest.TestUtil import TestLoader, TestSuite
36
 
from bzrlib.selftest.treeshape import build_tree_contents
 
64
from bzrlib.transport import urlescape, get_transport
 
65
import bzrlib.transport
 
66
from bzrlib.transport.local import LocalRelpathServer
 
67
from bzrlib.transport.readonly import ReadonlyServer
 
68
from bzrlib.trace import mutter
 
69
from bzrlib.tests.TestUtil import TestLoader, TestSuite
 
70
from bzrlib.tests.treeshape import build_tree_contents
 
71
from bzrlib.workingtree import WorkingTree, WorkingTreeFormat2
 
72
 
 
73
default_transport = LocalRelpathServer
37
74
 
38
75
MODULES_TO_TEST = []
39
 
MODULES_TO_DOCTEST = []
40
 
 
41
 
from logging import debug, warning, error
42
 
 
43
 
 
44
 
 
45
 
class EarlyStoppingTestResultAdapter(object):
46
 
    """An adapter for TestResult to stop at the first first failure or error"""
47
 
 
48
 
    def __init__(self, result):
49
 
        self._result = result
50
 
 
51
 
    def addError(self, test, err):
52
 
        self._result.addError(test, err)
53
 
        self._result.stop()
54
 
 
55
 
    def addFailure(self, test, err):
56
 
        self._result.addFailure(test, err)
57
 
        self._result.stop()
58
 
 
59
 
    def __getattr__(self, name):
60
 
        return getattr(self._result, name)
61
 
 
62
 
    def __setattr__(self, name, value):
63
 
        if name == '_result':
64
 
            object.__setattr__(self, name, value)
65
 
        return setattr(self._result, name, value)
 
76
MODULES_TO_DOCTEST = [
 
77
                      bzrlib.branch,
 
78
                      bzrlib.commands,
 
79
                      bzrlib.errors,
 
80
                      bzrlib.inventory,
 
81
                      bzrlib.iterablefile,
 
82
                      bzrlib.lockdir,
 
83
                      bzrlib.merge3,
 
84
                      bzrlib.option,
 
85
                      bzrlib.osutils,
 
86
                      bzrlib.store
 
87
                      ]
 
88
def packages_to_test():
 
89
    """Return a list of packages to test.
 
90
 
 
91
    The packages are not globally imported so that import failures are
 
92
    triggered when running selftest, not when importing the command.
 
93
    """
 
94
    import bzrlib.doc
 
95
    import bzrlib.tests.blackbox
 
96
    import bzrlib.tests.branch_implementations
 
97
    import bzrlib.tests.bzrdir_implementations
 
98
    import bzrlib.tests.interrepository_implementations
 
99
    import bzrlib.tests.interversionedfile_implementations
 
100
    import bzrlib.tests.repository_implementations
 
101
    import bzrlib.tests.revisionstore_implementations
 
102
    import bzrlib.tests.workingtree_implementations
 
103
    return [
 
104
            bzrlib.doc,
 
105
            bzrlib.tests.blackbox,
 
106
            bzrlib.tests.branch_implementations,
 
107
            bzrlib.tests.bzrdir_implementations,
 
108
            bzrlib.tests.interrepository_implementations,
 
109
            bzrlib.tests.interversionedfile_implementations,
 
110
            bzrlib.tests.repository_implementations,
 
111
            bzrlib.tests.revisionstore_implementations,
 
112
            bzrlib.tests.workingtree_implementations,
 
113
            ]
66
114
 
67
115
 
68
116
class _MyResult(unittest._TextTestResult):
69
 
    """
70
 
    Custom TestResult.
71
 
 
72
 
    No special behaviour for now.
73
 
    """
74
 
 
75
 
    def _elapsedTime(self):
76
 
        return "(Took %.3fs)" % (time.time() - self._start_time)
 
117
    """Custom TestResult.
 
118
 
 
119
    Shows output in a different format, including displaying runtime for tests.
 
120
    """
 
121
    stop_early = False
 
122
    
 
123
    def __init__(self, stream, descriptions, verbosity, pb=None):
 
124
        unittest._TextTestResult.__init__(self, stream, descriptions, verbosity)
 
125
        self.pb = pb
 
126
    
 
127
    def extractBenchmarkTime(self, testCase):
 
128
        """Add a benchmark time for the current test case."""
 
129
        self._benchmarkTime = getattr(testCase, "_benchtime", None)
 
130
    
 
131
    def _elapsedTestTimeString(self):
 
132
        """Return a time string for the overall time the current test has taken."""
 
133
        return self._formatTime(time.time() - self._start_time)
 
134
 
 
135
    def _testTimeString(self):
 
136
        if self._benchmarkTime is not None:
 
137
            return "%s/%s" % (
 
138
                self._formatTime(self._benchmarkTime),
 
139
                self._elapsedTestTimeString())
 
140
        else:
 
141
            return "      %s" % self._elapsedTestTimeString()
 
142
 
 
143
    def _formatTime(self, seconds):
 
144
        """Format seconds as milliseconds with leading spaces."""
 
145
        return "%5dms" % (1000 * seconds)
 
146
 
 
147
    def _ellipsise_unimportant_words(self, a_string, final_width,
 
148
                                   keep_start=False):
 
149
        """Add ellipses (sp?) for overly long strings.
 
150
        
 
151
        :param keep_start: If true preserve the start of a_string rather
 
152
                           than the end of it.
 
153
        """
 
154
        if keep_start:
 
155
            if len(a_string) > final_width:
 
156
                result = a_string[:final_width-3] + '...'
 
157
            else:
 
158
                result = a_string
 
159
        else:
 
160
            if len(a_string) > final_width:
 
161
                result = '...' + a_string[3-final_width:]
 
162
            else:
 
163
                result = a_string
 
164
        return result.ljust(final_width)
77
165
 
78
166
    def startTest(self, test):
79
167
        unittest.TestResult.startTest(self, test)
80
 
        # TODO: Maybe show test.shortDescription somewhere?
81
 
        what = test.shortDescription() or test.id()        
 
168
        # In a short description, the important words are in
 
169
        # the beginning, but in an id, the important words are
 
170
        # at the end
 
171
        SHOW_DESCRIPTIONS = False
 
172
 
 
173
        if not self.showAll and self.dots and self.pb is not None:
 
174
            final_width = 13
 
175
        else:
 
176
            final_width = osutils.terminal_width()
 
177
            final_width = final_width - 15 - 8
 
178
        what = None
 
179
        if SHOW_DESCRIPTIONS:
 
180
            what = test.shortDescription()
 
181
            if what:
 
182
                what = self._ellipsise_unimportant_words(what, final_width, keep_start=True)
 
183
        if what is None:
 
184
            what = test.id()
 
185
            if what.startswith('bzrlib.tests.'):
 
186
                what = what[13:]
 
187
            what = self._ellipsise_unimportant_words(what, final_width)
82
188
        if self.showAll:
83
 
            self.stream.write('%-70.70s' % what)
 
189
            self.stream.write(what)
 
190
        elif self.dots and self.pb is not None:
 
191
            self.pb.update(what, self.testsRun - 1, None)
84
192
        self.stream.flush()
 
193
        self._recordTestStartTime()
 
194
 
 
195
    def _recordTestStartTime(self):
 
196
        """Record that a test has started."""
85
197
        self._start_time = time.time()
86
198
 
87
199
    def addError(self, test, err):
 
200
        if isinstance(err[1], TestSkipped):
 
201
            return self.addSkipped(test, err)    
88
202
        unittest.TestResult.addError(self, test, err)
 
203
        self.extractBenchmarkTime(test)
89
204
        if self.showAll:
90
 
            self.stream.writeln("ERROR %s" % self._elapsedTime())
91
 
        elif self.dots:
 
205
            self.stream.writeln("ERROR %s" % self._testTimeString())
 
206
        elif self.dots and self.pb is None:
92
207
            self.stream.write('E')
 
208
        elif self.dots:
 
209
            self.pb.update(self._ellipsise_unimportant_words('ERROR', 13), self.testsRun, None)
93
210
        self.stream.flush()
 
211
        if self.stop_early:
 
212
            self.stop()
94
213
 
95
214
    def addFailure(self, test, err):
96
215
        unittest.TestResult.addFailure(self, test, err)
 
216
        self.extractBenchmarkTime(test)
97
217
        if self.showAll:
98
 
            self.stream.writeln("FAIL %s" % self._elapsedTime())
99
 
        elif self.dots:
 
218
            self.stream.writeln(" FAIL %s" % self._testTimeString())
 
219
        elif self.dots and self.pb is None:
100
220
            self.stream.write('F')
 
221
        elif self.dots:
 
222
            self.pb.update(self._ellipsise_unimportant_words('FAIL', 13), self.testsRun, None)
101
223
        self.stream.flush()
 
224
        if self.stop_early:
 
225
            self.stop()
102
226
 
103
227
    def addSuccess(self, test):
 
228
        self.extractBenchmarkTime(test)
104
229
        if self.showAll:
105
 
            self.stream.writeln('OK %s' % self._elapsedTime())
106
 
        elif self.dots:
 
230
            self.stream.writeln('   OK %s' % self._testTimeString())
 
231
            for bench_called, stats in getattr(test, '_benchcalls', []):
 
232
                self.stream.writeln('LSProf output for %s(%s, %s)' % bench_called)
 
233
                stats.pprint(file=self.stream)
 
234
        elif self.dots and self.pb is None:
107
235
            self.stream.write('~')
108
 
        self.stream.flush()
 
236
        elif self.dots:
 
237
            self.pb.update(self._ellipsise_unimportant_words('OK', 13), self.testsRun, None)
 
238
        self.stream.flush()
 
239
        unittest.TestResult.addSuccess(self, test)
 
240
 
 
241
    def addSkipped(self, test, skip_excinfo):
 
242
        self.extractBenchmarkTime(test)
 
243
        if self.showAll:
 
244
            print >>self.stream, ' SKIP %s' % self._testTimeString()
 
245
            print >>self.stream, '     %s' % skip_excinfo[1]
 
246
        elif self.dots and self.pb is None:
 
247
            self.stream.write('S')
 
248
        elif self.dots:
 
249
            self.pb.update(self._ellipsise_unimportant_words('SKIP', 13), self.testsRun, None)
 
250
        self.stream.flush()
 
251
        # seems best to treat this as success from point-of-view of unittest
 
252
        # -- it actually does nothing so it barely matters :)
109
253
        unittest.TestResult.addSuccess(self, test)
110
254
 
111
255
    def printErrorList(self, flavour, errors):
112
256
        for test, err in errors:
113
257
            self.stream.writeln(self.separator1)
114
 
            self.stream.writeln("%s: %s" % (flavour,self.getDescription(test)))
115
 
            if hasattr(test, '_get_log'):
116
 
                self.stream.writeln()
117
 
                self.stream.writeln('log from this test:')
 
258
            self.stream.writeln("%s: %s" % (flavour, self.getDescription(test)))
 
259
            if getattr(test, '_get_log', None) is not None:
 
260
                print >>self.stream
 
261
                print >>self.stream, \
 
262
                        ('vvvv[log from %s]' % test.id()).ljust(78,'-')
118
263
                print >>self.stream, test._get_log()
 
264
                print >>self.stream, \
 
265
                        ('^^^^[log from %s]' % test.id()).ljust(78,'-')
119
266
            self.stream.writeln(self.separator2)
120
267
            self.stream.writeln("%s" % err)
121
268
 
122
269
 
123
 
class TextTestRunner(unittest.TextTestRunner):
 
270
class TextTestRunner(object):
124
271
    stop_on_failure = False
125
272
 
 
273
    def __init__(self,
 
274
                 stream=sys.stderr,
 
275
                 descriptions=0,
 
276
                 verbosity=1,
 
277
                 keep_output=False,
 
278
                 pb=None):
 
279
        self.stream = unittest._WritelnDecorator(stream)
 
280
        self.descriptions = descriptions
 
281
        self.verbosity = verbosity
 
282
        self.keep_output = keep_output
 
283
        self.pb = pb
 
284
 
126
285
    def _makeResult(self):
127
 
        result = _MyResult(self.stream, self.descriptions, self.verbosity)
128
 
        if self.stop_on_failure:
129
 
            result = EarlyStoppingTestResultAdapter(result)
 
286
        result = _MyResult(self.stream,
 
287
                           self.descriptions,
 
288
                           self.verbosity,
 
289
                           pb=self.pb)
 
290
        result.stop_early = self.stop_on_failure
 
291
        return result
 
292
 
 
293
    def run(self, test):
 
294
        "Run the given test case or test suite."
 
295
        result = self._makeResult()
 
296
        startTime = time.time()
 
297
        if self.pb is not None:
 
298
            self.pb.update('Running tests', 0, test.countTestCases())
 
299
        test.run(result)
 
300
        stopTime = time.time()
 
301
        timeTaken = stopTime - startTime
 
302
        result.printErrors()
 
303
        self.stream.writeln(result.separator2)
 
304
        run = result.testsRun
 
305
        self.stream.writeln("Ran %d test%s in %.3fs" %
 
306
                            (run, run != 1 and "s" or "", timeTaken))
 
307
        self.stream.writeln()
 
308
        if not result.wasSuccessful():
 
309
            self.stream.write("FAILED (")
 
310
            failed, errored = map(len, (result.failures, result.errors))
 
311
            if failed:
 
312
                self.stream.write("failures=%d" % failed)
 
313
            if errored:
 
314
                if failed: self.stream.write(", ")
 
315
                self.stream.write("errors=%d" % errored)
 
316
            self.stream.writeln(")")
 
317
        else:
 
318
            self.stream.writeln("OK")
 
319
        if self.pb is not None:
 
320
            self.pb.update('Cleaning up', 0, 1)
 
321
        # This is still a little bogus, 
 
322
        # but only a little. Folk not using our testrunner will
 
323
        # have to delete their temp directories themselves.
 
324
        test_root = TestCaseInTempDir.TEST_ROOT
 
325
        if result.wasSuccessful() or not self.keep_output:
 
326
            if test_root is not None:
 
327
                    osutils.rmtree(test_root)
 
328
        else:
 
329
            if self.pb is not None:
 
330
                self.pb.note("Failed tests working directories are in '%s'\n",
 
331
                             test_root)
 
332
            else:
 
333
                self.stream.writeln(
 
334
                    "Failed tests working directories are in '%s'\n" %
 
335
                    test_root)
 
336
        TestCaseInTempDir.TEST_ROOT = None
 
337
        if self.pb is not None:
 
338
            self.pb.clear()
130
339
        return result
131
340
 
132
341
 
159
368
 
160
369
    Error and debug log messages are redirected from their usual
161
370
    location into a temporary file, the contents of which can be
162
 
    retrieved by _get_log().
 
371
    retrieved by _get_log().  We use a real OS file, not an in-memory object,
 
372
    so that it can also capture file IO.  When the test completes this file
 
373
    is read into memory and removed from disk.
163
374
       
164
375
    There are also convenience functions to invoke bzr's command-line
165
 
    routine, and to build and check bzr trees."""
 
376
    routine, and to build and check bzr trees.
 
377
   
 
378
    In addition to the usual method of overriding tearDown(), this class also
 
379
    allows subclasses to register functions into the _cleanups list, which is
 
380
    run in order as the object is torn down.  It's less likely this will be
 
381
    accidentally overlooked.
 
382
    """
166
383
 
167
 
    BZRPATH = 'bzr'
168
384
    _log_file_name = None
 
385
    _log_contents = ''
 
386
    # record lsprof data when performing benchmark calls.
 
387
    _gather_lsprof_in_benchmarks = False
 
388
 
 
389
    def __init__(self, methodName='testMethod'):
 
390
        super(TestCase, self).__init__(methodName)
 
391
        self._cleanups = []
169
392
 
170
393
    def setUp(self):
171
394
        unittest.TestCase.setUp(self)
172
 
        self.oldenv = os.environ.get('HOME', None)
173
 
        os.environ['HOME'] = os.getcwd()
174
 
        self.bzr_email = os.environ.get('BZREMAIL')
175
 
        if self.bzr_email is not None:
176
 
            del os.environ['BZREMAIL']
177
 
        self.email = os.environ.get('EMAIL')
178
 
        if self.email is not None:
179
 
            del os.environ['EMAIL']
 
395
        self._cleanEnvironment()
180
396
        bzrlib.trace.disable_default_logging()
181
 
        self._enable_file_logging()
 
397
        self._startLogFile()
 
398
        self._benchcalls = []
 
399
        self._benchtime = None
182
400
 
183
401
    def _ndiff_strings(self, a, b):
184
402
        """Return ndiff between two strings containing lines.
195
413
                                  charjunk=lambda x: False)
196
414
        return ''.join(difflines)
197
415
 
198
 
    def assertEqualDiff(self, a, b):
 
416
    def assertEqualDiff(self, a, b, message=None):
199
417
        """Assert two texts are equal, if not raise an exception.
200
418
        
201
419
        This is intended for use with multi-line strings where it can 
204
422
        # TODO: perhaps override assertEquals to call this for strings?
205
423
        if a == b:
206
424
            return
207
 
        raise AssertionError("texts not equal:\n" + 
 
425
        if message is None:
 
426
            message = "texts not equal:\n"
 
427
        raise AssertionError(message + 
208
428
                             self._ndiff_strings(a, b))      
 
429
        
 
430
    def assertEqualMode(self, mode, mode_test):
 
431
        self.assertEqual(mode, mode_test,
 
432
                         'mode mismatch %o != %o' % (mode, mode_test))
 
433
 
 
434
    def assertStartsWith(self, s, prefix):
 
435
        if not s.startswith(prefix):
 
436
            raise AssertionError('string %r does not start with %r' % (s, prefix))
 
437
 
 
438
    def assertEndsWith(self, s, suffix):
 
439
        """Asserts that s ends with suffix."""
 
440
        if not s.endswith(suffix):
 
441
            raise AssertionError('string %r does not end with %r' % (s, suffix))
209
442
 
210
443
    def assertContainsRe(self, haystack, needle_re):
211
444
        """Assert that a contains something matching a regular expression."""
213
446
            raise AssertionError('pattern "%s" not found in "%s"'
214
447
                    % (needle_re, haystack))
215
448
 
216
 
    def _enable_file_logging(self):
 
449
    def assertSubset(self, sublist, superlist):
 
450
        """Assert that every entry in sublist is present in superlist."""
 
451
        missing = []
 
452
        for entry in sublist:
 
453
            if entry not in superlist:
 
454
                missing.append(entry)
 
455
        if len(missing) > 0:
 
456
            raise AssertionError("value(s) %r not present in container %r" % 
 
457
                                 (missing, superlist))
 
458
 
 
459
    def assertIs(self, left, right):
 
460
        if not (left is right):
 
461
            raise AssertionError("%r is not %r." % (left, right))
 
462
 
 
463
    def assertTransportMode(self, transport, path, mode):
 
464
        """Fail if a path does not have mode mode.
 
465
        
 
466
        If modes are not supported on this transport, the assertion is ignored.
 
467
        """
 
468
        if not transport._can_roundtrip_unix_modebits():
 
469
            return
 
470
        path_stat = transport.stat(path)
 
471
        actual_mode = stat.S_IMODE(path_stat.st_mode)
 
472
        self.assertEqual(mode, actual_mode,
 
473
            'mode of %r incorrect (%o != %o)' % (path, mode, actual_mode))
 
474
 
 
475
    def assertIsInstance(self, obj, kls):
 
476
        """Fail if obj is not an instance of kls"""
 
477
        if not isinstance(obj, kls):
 
478
            self.fail("%r is an instance of %s rather than %s" % (
 
479
                obj, obj.__class__, kls))
 
480
 
 
481
    def _startLogFile(self):
 
482
        """Send bzr and test log messages to a temporary file.
 
483
 
 
484
        The file is removed as the test is torn down.
 
485
        """
217
486
        fileno, name = tempfile.mkstemp(suffix='.log', prefix='testbzr')
218
 
 
219
 
        self._log_file = os.fdopen(fileno, 'w+')
220
 
 
221
 
        hdlr = logging.StreamHandler(self._log_file)
222
 
        hdlr.setLevel(logging.DEBUG)
223
 
        hdlr.setFormatter(logging.Formatter('%(levelname)8s  %(message)s'))
224
 
        logging.getLogger('').addHandler(hdlr)
225
 
        logging.getLogger('').setLevel(logging.DEBUG)
226
 
        self._log_hdlr = hdlr
227
 
        debug('opened log file %s', name)
228
 
        
 
487
        encoder, decoder, stream_reader, stream_writer = codecs.lookup('UTF-8')
 
488
        self._log_file = stream_writer(os.fdopen(fileno, 'w+'))
 
489
        self._log_nonce = bzrlib.trace.enable_test_log(self._log_file)
229
490
        self._log_file_name = name
230
 
 
231
 
    def tearDown(self):
232
 
        os.environ['HOME'] = self.oldenv
233
 
        if os.environ.get('BZREMAIL') is not None:
234
 
            del os.environ['BZREMAIL']
235
 
        if self.bzr_email is not None:
236
 
            os.environ['BZREMAIL'] = self.bzr_email
237
 
        if os.environ.get('EMAIL') is not None:
238
 
            del os.environ['EMAIL']
239
 
        if self.email is not None:
240
 
            os.environ['EMAIL'] = self.email
241
 
        logging.getLogger('').removeHandler(self._log_hdlr)
242
 
        bzrlib.trace.enable_default_logging()
243
 
        logging.debug('%s teardown', self.id())
 
491
        self.addCleanup(self._finishLogFile)
 
492
 
 
493
    def _finishLogFile(self):
 
494
        """Finished with the log file.
 
495
 
 
496
        Read contents into memory, close, and delete.
 
497
        """
 
498
        bzrlib.trace.disable_test_log(self._log_nonce)
 
499
        self._log_file.seek(0)
 
500
        self._log_contents = self._log_file.read()
244
501
        self._log_file.close()
 
502
        os.remove(self._log_file_name)
 
503
        self._log_file = self._log_file_name = None
 
504
 
 
505
    def addCleanup(self, callable):
 
506
        """Arrange to run a callable when this case is torn down.
 
507
 
 
508
        Callables are run in the reverse of the order they are registered, 
 
509
        ie last-in first-out.
 
510
        """
 
511
        if callable in self._cleanups:
 
512
            raise ValueError("cleanup function %r already registered on %s" 
 
513
                    % (callable, self))
 
514
        self._cleanups.append(callable)
 
515
 
 
516
    def _cleanEnvironment(self):
 
517
        new_env = {
 
518
            'HOME': os.getcwd(),
 
519
            'APPDATA': os.getcwd(),
 
520
            'BZREMAIL': None,
 
521
            'EMAIL': None,
 
522
        }
 
523
        self.__old_env = {}
 
524
        self.addCleanup(self._restoreEnvironment)
 
525
        for name, value in new_env.iteritems():
 
526
            self._captureVar(name, value)
 
527
 
 
528
 
 
529
    def _captureVar(self, name, newvalue):
 
530
        """Set an environment variable, preparing it to be reset when finished."""
 
531
        self.__old_env[name] = os.environ.get(name, None)
 
532
        if newvalue is None:
 
533
            if name in os.environ:
 
534
                del os.environ[name]
 
535
        else:
 
536
            os.environ[name] = newvalue
 
537
 
 
538
    @staticmethod
 
539
    def _restoreVar(name, value):
 
540
        if value is None:
 
541
            if name in os.environ:
 
542
                del os.environ[name]
 
543
        else:
 
544
            os.environ[name] = value
 
545
 
 
546
    def _restoreEnvironment(self):
 
547
        for name, value in self.__old_env.iteritems():
 
548
            self._restoreVar(name, value)
 
549
 
 
550
    def tearDown(self):
 
551
        self._runCleanups()
245
552
        unittest.TestCase.tearDown(self)
246
553
 
 
554
    def time(self, callable, *args, **kwargs):
 
555
        """Run callable and accrue the time it takes to the benchmark time.
 
556
        
 
557
        If lsprofiling is enabled (i.e. by --lsprof-time to bzr selftest) then
 
558
        this will cause lsprofile statistics to be gathered and stored in
 
559
        self._benchcalls.
 
560
        """
 
561
        if self._benchtime is None:
 
562
            self._benchtime = 0
 
563
        start = time.time()
 
564
        try:
 
565
            if not self._gather_lsprof_in_benchmarks:
 
566
                return callable(*args, **kwargs)
 
567
            else:
 
568
                # record this benchmark
 
569
                ret, stats = bzrlib.lsprof.profile(callable, *args, **kwargs)
 
570
                stats.sort()
 
571
                self._benchcalls.append(((callable, args, kwargs), stats))
 
572
                return ret
 
573
        finally:
 
574
            self._benchtime += time.time() - start
 
575
 
 
576
    def _runCleanups(self):
 
577
        """Run registered cleanup functions. 
 
578
 
 
579
        This should only be called from TestCase.tearDown.
 
580
        """
 
581
        # TODO: Perhaps this should keep running cleanups even if 
 
582
        # one of them fails?
 
583
        for cleanup_fn in reversed(self._cleanups):
 
584
            cleanup_fn()
 
585
 
247
586
    def log(self, *args):
248
 
        logging.debug(*args)
 
587
        mutter(*args)
249
588
 
250
589
    def _get_log(self):
251
590
        """Return as a string the log for this test"""
252
591
        if self._log_file_name:
253
592
            return open(self._log_file_name).read()
254
593
        else:
255
 
            return ''
 
594
            return self._log_contents
 
595
        # TODO: Delete the log after it's been read in
256
596
 
257
 
    def capture(self, cmd):
 
597
    def capture(self, cmd, retcode=0):
258
598
        """Shortcut that splits cmd into words, runs, and returns stdout"""
259
 
        return self.run_bzr_captured(cmd.split())[0]
 
599
        return self.run_bzr_captured(cmd.split(), retcode=retcode)[0]
260
600
 
261
 
    def run_bzr_captured(self, argv, retcode=0):
262
 
        """Invoke bzr and return (result, stdout, stderr).
 
601
    def run_bzr_captured(self, argv, retcode=0, stdin=None):
 
602
        """Invoke bzr and return (stdout, stderr).
263
603
 
264
604
        Useful for code that wants to check the contents of the
265
605
        output, the way error messages are presented, etc.
277
617
 
278
618
        argv -- arguments to invoke bzr
279
619
        retcode -- expected return code, or None for don't-care.
 
620
        :param stdin: A string to be used as stdin for the command.
280
621
        """
 
622
        if stdin is not None:
 
623
            stdin = StringIO(stdin)
281
624
        stdout = StringIO()
282
625
        stderr = StringIO()
283
626
        self.log('run bzr: %s', ' '.join(argv))
 
627
        # FIXME: don't call into logging here
284
628
        handler = logging.StreamHandler(stderr)
285
629
        handler.setFormatter(bzrlib.trace.QuietFormatter())
286
630
        handler.setLevel(logging.INFO)
287
631
        logger = logging.getLogger('')
288
632
        logger.addHandler(handler)
 
633
        old_ui_factory = bzrlib.ui.ui_factory
 
634
        bzrlib.ui.ui_factory = bzrlib.tests.blackbox.TestUIFactory(
 
635
            stdout=stdout,
 
636
            stderr=stderr)
 
637
        bzrlib.ui.ui_factory.stdin = stdin
289
638
        try:
290
 
            result = self.apply_redirected(None, stdout, stderr,
 
639
            result = self.apply_redirected(stdin, stdout, stderr,
291
640
                                           bzrlib.commands.run_bzr_catch_errors,
292
641
                                           argv)
293
642
        finally:
294
643
            logger.removeHandler(handler)
 
644
            bzrlib.ui.ui_factory = old_ui_factory
295
645
        out = stdout.getvalue()
296
646
        err = stderr.getvalue()
297
647
        if out:
311
661
 
312
662
        This sends the stdout/stderr results into the test's log,
313
663
        where it may be useful for debugging.  See also run_captured.
 
664
 
 
665
        :param stdin: A string to be used as stdin for the command.
314
666
        """
315
667
        retcode = kwargs.pop('retcode', 0)
316
 
        return self.run_bzr_captured(args, retcode)
 
668
        stdin = kwargs.pop('stdin', None)
 
669
        return self.run_bzr_captured(args, retcode, stdin)
317
670
 
318
671
    def check_inventory_shape(self, inv, shape):
319
672
        """Compare an inventory to a list of expected names.
345
698
        if stdin is None:
346
699
            stdin = StringIO("")
347
700
        if stdout is None:
348
 
            if hasattr(self, "_log_file"):
 
701
            if getattr(self, "_log_file", None) is not None:
349
702
                stdout = self._log_file
350
703
            else:
351
704
                stdout = StringIO()
352
705
        if stderr is None:
353
 
            if hasattr(self, "_log_file"):
 
706
            if getattr(self, "_log_file", None is not None):
354
707
                stderr = self._log_file
355
708
            else:
356
709
                stderr = StringIO()
367
720
            sys.stderr = real_stderr
368
721
            sys.stdin = real_stdin
369
722
 
 
723
    def merge(self, branch_from, wt_to):
 
724
        """A helper for tests to do a ui-less merge.
 
725
 
 
726
        This should move to the main library when someone has time to integrate
 
727
        it in.
 
728
        """
 
729
        # minimal ui-less merge.
 
730
        wt_to.branch.fetch(branch_from)
 
731
        base_rev = common_ancestor(branch_from.last_revision(),
 
732
                                   wt_to.branch.last_revision(),
 
733
                                   wt_to.branch.repository)
 
734
        merge_inner(wt_to.branch, branch_from.basis_tree(), 
 
735
                    wt_to.branch.repository.revision_tree(base_rev),
 
736
                    this_tree=wt_to)
 
737
        wt_to.add_pending_merge(branch_from.last_revision())
 
738
 
370
739
 
371
740
BzrTestBase = TestCase
372
741
 
401
770
            return
402
771
        i = 0
403
772
        while True:
404
 
            root = 'test%04d.tmp' % i
 
773
            root = u'test%04d.tmp' % i
405
774
            try:
406
775
                os.mkdir(root)
407
776
            except OSError, e:
411
780
                else:
412
781
                    raise
413
782
            # successfully created
414
 
            TestCaseInTempDir.TEST_ROOT = os.path.abspath(root)
 
783
            TestCaseInTempDir.TEST_ROOT = osutils.abspath(root)
415
784
            break
416
785
        # make a fake bzr directory there to prevent any tests propagating
417
786
        # up onto the source directory's real branch
418
 
        os.mkdir(os.path.join(TestCaseInTempDir.TEST_ROOT, '.bzr'))
 
787
        bzrdir.BzrDir.create_standalone_workingtree(TestCaseInTempDir.TEST_ROOT)
419
788
 
420
789
    def setUp(self):
 
790
        super(TestCaseInTempDir, self).setUp()
421
791
        self._make_test_root()
422
 
        self._currentdir = os.getcwdu()
423
 
        short_id = self.id().replace('bzrlib.selftest.', '') \
424
 
                   .replace('__main__.', '')
425
 
        self.test_dir = os.path.join(self.TEST_ROOT, short_id)
426
 
        os.mkdir(self.test_dir)
427
 
        os.chdir(self.test_dir)
428
 
        super(TestCaseInTempDir, self).setUp()
 
792
        _currentdir = os.getcwdu()
 
793
        # shorten the name, to avoid test failures due to path length
 
794
        short_id = self.id().replace('bzrlib.tests.', '') \
 
795
                   .replace('__main__.', '')[-100:]
 
796
        # it's possible the same test class is run several times for
 
797
        # parameterized tests, so make sure the names don't collide.  
 
798
        i = 0
 
799
        while True:
 
800
            if i > 0:
 
801
                candidate_dir = '%s/%s.%d' % (self.TEST_ROOT, short_id, i)
 
802
            else:
 
803
                candidate_dir = '%s/%s' % (self.TEST_ROOT, short_id)
 
804
            if os.path.exists(candidate_dir):
 
805
                i = i + 1
 
806
                continue
 
807
            else:
 
808
                self.test_dir = candidate_dir
 
809
                os.mkdir(self.test_dir)
 
810
                os.chdir(self.test_dir)
 
811
                break
 
812
        os.environ['HOME'] = self.test_dir
 
813
        os.environ['APPDATA'] = self.test_dir
 
814
        def _leaveDirectory():
 
815
            os.chdir(_currentdir)
 
816
        self.addCleanup(_leaveDirectory)
429
817
        
430
 
    def tearDown(self):
431
 
        os.chdir(self._currentdir)
432
 
        super(TestCaseInTempDir, self).tearDown()
433
 
 
434
 
    def build_tree(self, shape):
 
818
    def build_tree(self, shape, line_endings='native', transport=None):
435
819
        """Build a test tree according to a pattern.
436
820
 
437
821
        shape is a sequence of file specifications.  If the final
438
822
        character is '/', a directory is created.
439
823
 
440
824
        This doesn't add anything to a branch.
 
825
        :param line_endings: Either 'binary' or 'native'
 
826
                             in binary mode, exact contents are written
 
827
                             in native mode, the line endings match the
 
828
                             default platform endings.
 
829
 
 
830
        :param transport: A transport to write to, for building trees on 
 
831
                          VFS's. If the transport is readonly or None,
 
832
                          "." is opened automatically.
441
833
        """
442
834
        # XXX: It's OK to just create them using forward slashes on windows?
 
835
        if transport is None or transport.is_readonly():
 
836
            transport = get_transport(".")
443
837
        for name in shape:
444
 
            assert isinstance(name, basestring)
 
838
            self.assert_(isinstance(name, basestring))
445
839
            if name[-1] == '/':
446
 
                os.mkdir(name[:-1])
 
840
                transport.mkdir(urlescape(name[:-1]))
447
841
            else:
448
 
                f = file(name, 'wt')
449
 
                print >>f, "contents of", name
450
 
                f.close()
 
842
                if line_endings == 'binary':
 
843
                    end = '\n'
 
844
                elif line_endings == 'native':
 
845
                    end = os.linesep
 
846
                else:
 
847
                    raise errors.BzrError('Invalid line ending request %r' % (line_endings,))
 
848
                content = "contents of %s%s" % (name, end)
 
849
                transport.put(urlescape(name), StringIO(content))
451
850
 
452
851
    def build_tree_contents(self, shape):
453
 
        bzrlib.selftest.build_tree_contents(shape)
 
852
        build_tree_contents(shape)
454
853
 
455
854
    def failUnlessExists(self, path):
456
855
        """Fail unless path, which may be abs or relative, exists."""
457
856
        self.failUnless(osutils.lexists(path))
 
857
 
 
858
    def failIfExists(self, path):
 
859
        """Fail if path, which may be abs or relative, exists."""
 
860
        self.failIf(osutils.lexists(path))
458
861
        
459
862
    def assertFileEqual(self, content, path):
460
863
        """Fail if path does not contain 'content'."""
461
864
        self.failUnless(osutils.lexists(path))
462
865
        self.assertEqualDiff(content, open(path, 'r').read())
 
866
 
 
867
 
 
868
class TestCaseWithTransport(TestCaseInTempDir):
 
869
    """A test case that provides get_url and get_readonly_url facilities.
 
870
 
 
871
    These back onto two transport servers, one for readonly access and one for
 
872
    read write access.
 
873
 
 
874
    If no explicit class is provided for readonly access, a
 
875
    ReadonlyTransportDecorator is used instead which allows the use of non disk
 
876
    based read write transports.
 
877
 
 
878
    If an explicit class is provided for readonly access, that server and the 
 
879
    readwrite one must both define get_url() as resolving to os.getcwd().
 
880
    """
 
881
 
 
882
    def __init__(self, methodName='testMethod'):
 
883
        super(TestCaseWithTransport, self).__init__(methodName)
 
884
        self.__readonly_server = None
 
885
        self.__server = None
 
886
        self.transport_server = default_transport
 
887
        self.transport_readonly_server = None
 
888
 
 
889
    def get_readonly_url(self, relpath=None):
 
890
        """Get a URL for the readonly transport.
 
891
 
 
892
        This will either be backed by '.' or a decorator to the transport 
 
893
        used by self.get_url()
 
894
        relpath provides for clients to get a path relative to the base url.
 
895
        These should only be downwards relative, not upwards.
 
896
        """
 
897
        base = self.get_readonly_server().get_url()
 
898
        if relpath is not None:
 
899
            if not base.endswith('/'):
 
900
                base = base + '/'
 
901
            base = base + relpath
 
902
        return base
 
903
 
 
904
    def get_readonly_server(self):
 
905
        """Get the server instance for the readonly transport
 
906
 
 
907
        This is useful for some tests with specific servers to do diagnostics.
 
908
        """
 
909
        if self.__readonly_server is None:
 
910
            if self.transport_readonly_server is None:
 
911
                # readonly decorator requested
 
912
                # bring up the server
 
913
                self.get_url()
 
914
                self.__readonly_server = ReadonlyServer()
 
915
                self.__readonly_server.setUp(self.__server)
 
916
            else:
 
917
                self.__readonly_server = self.transport_readonly_server()
 
918
                self.__readonly_server.setUp()
 
919
            self.addCleanup(self.__readonly_server.tearDown)
 
920
        return self.__readonly_server
 
921
 
 
922
    def get_server(self):
 
923
        """Get the read/write server instance.
 
924
 
 
925
        This is useful for some tests with specific servers that need
 
926
        diagnostics.
 
927
        """
 
928
        if self.__server is None:
 
929
            self.__server = self.transport_server()
 
930
            self.__server.setUp()
 
931
            self.addCleanup(self.__server.tearDown)
 
932
        return self.__server
 
933
 
 
934
    def get_url(self, relpath=None):
 
935
        """Get a URL for the readwrite transport.
 
936
 
 
937
        This will either be backed by '.' or to an equivalent non-file based
 
938
        facility.
 
939
        relpath provides for clients to get a path relative to the base url.
 
940
        These should only be downwards relative, not upwards.
 
941
        """
 
942
        base = self.get_server().get_url()
 
943
        if relpath is not None and relpath != '.':
 
944
            if not base.endswith('/'):
 
945
                base = base + '/'
 
946
            base = base + relpath
 
947
        return base
 
948
 
 
949
    def get_transport(self):
 
950
        """Return a writeable transport for the test scratch space"""
 
951
        t = get_transport(self.get_url())
 
952
        self.assertFalse(t.is_readonly())
 
953
        return t
 
954
 
 
955
    def get_readonly_transport(self):
 
956
        """Return a readonly transport for the test scratch space
463
957
        
464
 
 
465
 
class MetaTestLog(TestCase):
466
 
    def test_logging(self):
467
 
        """Test logs are captured when a test fails."""
468
 
        logging.info('an info message')
469
 
        warning('something looks dodgy...')
470
 
        logging.debug('hello, test is running')
471
 
        ## assert 0
 
958
        This can be used to test that operations which should only need
 
959
        readonly access in fact do not try to write.
 
960
        """
 
961
        t = get_transport(self.get_readonly_url())
 
962
        self.assertTrue(t.is_readonly())
 
963
        return t
 
964
 
 
965
    def make_branch(self, relpath, format=None):
 
966
        """Create a branch on the transport at relpath."""
 
967
        repo = self.make_repository(relpath, format=format)
 
968
        return repo.bzrdir.create_branch()
 
969
 
 
970
    def make_bzrdir(self, relpath, format=None):
 
971
        try:
 
972
            url = self.get_url(relpath)
 
973
            segments = relpath.split('/')
 
974
            if segments and segments[-1] not in ('', '.'):
 
975
                parent = self.get_url('/'.join(segments[:-1]))
 
976
                t = get_transport(parent)
 
977
                try:
 
978
                    t.mkdir(segments[-1])
 
979
                except errors.FileExists:
 
980
                    pass
 
981
            if format is None:
 
982
                format=bzrlib.bzrdir.BzrDirFormat.get_default_format()
 
983
            # FIXME: make this use a single transport someday. RBC 20060418
 
984
            return format.initialize_on_transport(get_transport(relpath))
 
985
        except errors.UninitializableFormat:
 
986
            raise TestSkipped("Format %s is not initializable." % format)
 
987
 
 
988
    def make_repository(self, relpath, shared=False, format=None):
 
989
        """Create a repository on our default transport at relpath."""
 
990
        made_control = self.make_bzrdir(relpath, format=format)
 
991
        return made_control.create_repository(shared=shared)
 
992
 
 
993
    def make_branch_and_tree(self, relpath, format=None):
 
994
        """Create a branch on the transport and a tree locally.
 
995
 
 
996
        Returns the tree.
 
997
        """
 
998
        # TODO: always use the local disk path for the working tree,
 
999
        # this obviously requires a format that supports branch references
 
1000
        # so check for that by checking bzrdir.BzrDirFormat.get_default_format()
 
1001
        # RBC 20060208
 
1002
        b = self.make_branch(relpath, format=format)
 
1003
        try:
 
1004
            return b.bzrdir.create_workingtree()
 
1005
        except errors.NotLocalUrl:
 
1006
            # new formats - catch No tree error and create
 
1007
            # a branch reference and a checkout.
 
1008
            # old formats at that point - raise TestSkipped.
 
1009
            # TODO: rbc 20060208
 
1010
            return WorkingTreeFormat2().initialize(bzrdir.BzrDir.open(relpath))
 
1011
 
 
1012
    def assertIsDirectory(self, relpath, transport):
 
1013
        """Assert that relpath within transport is a directory.
 
1014
 
 
1015
        This may not be possible on all transports; in that case it propagates
 
1016
        a TransportNotPossible.
 
1017
        """
 
1018
        try:
 
1019
            mode = transport.stat(relpath).st_mode
 
1020
        except errors.NoSuchFile:
 
1021
            self.fail("path %s is not a directory; no such file"
 
1022
                      % (relpath))
 
1023
        if not stat.S_ISDIR(mode):
 
1024
            self.fail("path %s is not a directory; has mode %#o"
 
1025
                      % (relpath, mode))
 
1026
 
 
1027
 
 
1028
class ChrootedTestCase(TestCaseWithTransport):
 
1029
    """A support class that provides readonly urls outside the local namespace.
 
1030
 
 
1031
    This is done by checking if self.transport_server is a MemoryServer. if it
 
1032
    is then we are chrooted already, if it is not then an HttpServer is used
 
1033
    for readonly urls.
 
1034
 
 
1035
    TODO RBC 20060127: make this an option to TestCaseWithTransport so it can
 
1036
                       be used without needed to redo it when a different 
 
1037
                       subclass is in use ?
 
1038
    """
 
1039
 
 
1040
    def setUp(self):
 
1041
        super(ChrootedTestCase, self).setUp()
 
1042
        if not self.transport_server == bzrlib.transport.memory.MemoryServer:
 
1043
            self.transport_readonly_server = bzrlib.transport.http.HttpServer
472
1044
 
473
1045
 
474
1046
def filter_suite_by_re(suite, pattern):
475
 
    result = TestUtil.TestSuite()
 
1047
    result = TestSuite()
476
1048
    filter_re = re.compile(pattern)
477
1049
    for test in iter_suite_tests(suite):
478
1050
        if filter_re.search(test.id()):
481
1053
 
482
1054
 
483
1055
def run_suite(suite, name='test', verbose=False, pattern=".*",
484
 
              stop_on_failure=False):
 
1056
              stop_on_failure=False, keep_output=False,
 
1057
              transport=None, lsprof_timed=None):
485
1058
    TestCaseInTempDir._TEST_NAME = name
 
1059
    TestCase._gather_lsprof_in_benchmarks = lsprof_timed
486
1060
    if verbose:
487
1061
        verbosity = 2
 
1062
        pb = None
488
1063
    else:
489
1064
        verbosity = 1
 
1065
        pb = progress.ProgressBar()
490
1066
    runner = TextTestRunner(stream=sys.stdout,
491
1067
                            descriptions=0,
492
 
                            verbosity=verbosity)
 
1068
                            verbosity=verbosity,
 
1069
                            keep_output=keep_output,
 
1070
                            pb=pb)
493
1071
    runner.stop_on_failure=stop_on_failure
494
1072
    if pattern != '.*':
495
1073
        suite = filter_suite_by_re(suite, pattern)
496
1074
    result = runner.run(suite)
497
 
    # This is still a little bogus, 
498
 
    # but only a little. Folk not using our testrunner will
499
 
    # have to delete their temp directories themselves.
500
 
    if result.wasSuccessful():
501
 
        if TestCaseInTempDir.TEST_ROOT is not None:
502
 
            shutil.rmtree(TestCaseInTempDir.TEST_ROOT) 
503
 
    else:
504
 
        print "Failed tests working directories are in '%s'\n" % TestCaseInTempDir.TEST_ROOT
505
1075
    return result.wasSuccessful()
506
1076
 
507
1077
 
508
 
def selftest(verbose=False, pattern=".*", stop_on_failure=True):
 
1078
def selftest(verbose=False, pattern=".*", stop_on_failure=True,
 
1079
             keep_output=False,
 
1080
             transport=None,
 
1081
             test_suite_factory=None,
 
1082
             lsprof_timed=None):
509
1083
    """Run the whole test suite under the enhanced runner"""
510
 
    return run_suite(test_suite(), 'testbzr', verbose=verbose, pattern=pattern,
511
 
                     stop_on_failure=stop_on_failure)
 
1084
    global default_transport
 
1085
    if transport is None:
 
1086
        transport = default_transport
 
1087
    old_transport = default_transport
 
1088
    default_transport = transport
 
1089
    try:
 
1090
        if test_suite_factory is None:
 
1091
            suite = test_suite()
 
1092
        else:
 
1093
            suite = test_suite_factory()
 
1094
        return run_suite(suite, 'testbzr', verbose=verbose, pattern=pattern,
 
1095
                     stop_on_failure=stop_on_failure, keep_output=keep_output,
 
1096
                     transport=transport,
 
1097
                     lsprof_timed=lsprof_timed)
 
1098
    finally:
 
1099
        default_transport = old_transport
512
1100
 
513
1101
 
514
1102
def test_suite():
515
 
    """Build and return TestSuite for the whole program."""
516
 
    import bzrlib.store, bzrlib.inventory, bzrlib.branch
517
 
    import bzrlib.osutils, bzrlib.merge3, bzrlib.plugin
 
1103
    """Build and return TestSuite for the whole of bzrlib.
 
1104
    
 
1105
    This function can be replaced if you need to change the default test
 
1106
    suite on a global basis, but it is not encouraged.
 
1107
    """
518
1108
    from doctest import DocTestSuite
519
1109
 
520
 
    global MODULES_TO_TEST, MODULES_TO_DOCTEST
 
1110
    global MODULES_TO_DOCTEST
521
1111
 
522
 
    testmod_names = \
523
 
                  ['bzrlib.selftest.MetaTestLog',
524
 
                   'bzrlib.selftest.testgpg',
525
 
                   'bzrlib.selftest.testidentitymap',
526
 
                   'bzrlib.selftest.testinv',
527
 
                   'bzrlib.selftest.test_ancestry',
528
 
                   'bzrlib.selftest.test_commit',
529
 
                   'bzrlib.selftest.test_command',
530
 
                   'bzrlib.selftest.test_commit_merge',
531
 
                   'bzrlib.selftest.testconfig',
532
 
                   'bzrlib.selftest.versioning',
533
 
                   'bzrlib.selftest.testmerge3',
534
 
                   'bzrlib.selftest.testmerge',
535
 
                   'bzrlib.selftest.testhashcache',
536
 
                   'bzrlib.selftest.teststatus',
537
 
                   'bzrlib.selftest.testlog',
538
 
                   'bzrlib.selftest.testrevisionnamespaces',
539
 
                   'bzrlib.selftest.testbranch',
540
 
                   'bzrlib.selftest.testrevision',
541
 
                   'bzrlib.selftest.test_revision_info',
542
 
                   'bzrlib.selftest.test_merge_core',
543
 
                   'bzrlib.selftest.test_smart_add',
544
 
                   'bzrlib.selftest.test_bad_files',
545
 
                   'bzrlib.selftest.testdiff',
546
 
                   'bzrlib.selftest.test_parent',
547
 
                   'bzrlib.selftest.test_xml',
548
 
                   'bzrlib.selftest.test_weave',
549
 
                   'bzrlib.selftest.testfetch',
550
 
                   'bzrlib.selftest.whitebox',
551
 
                   'bzrlib.selftest.teststore',
552
 
                   'bzrlib.selftest.blackbox',
553
 
                   'bzrlib.selftest.testsampler',
554
 
                   'bzrlib.selftest.testtransactions',
555
 
                   'bzrlib.selftest.testtransport',
556
 
                   'bzrlib.selftest.testgraph',
557
 
                   'bzrlib.selftest.testworkingtree',
558
 
                   'bzrlib.selftest.test_upgrade',
559
 
                   'bzrlib.selftest.test_conflicts',
560
 
                   'bzrlib.selftest.testtestament',
561
 
                   'bzrlib.selftest.testannotate',
562
 
                   'bzrlib.selftest.testrevprops',
563
 
                   'bzrlib.selftest.testoptions',
564
 
                   'bzrlib.selftest.testhttp',
565
 
                   'bzrlib.selftest.testnonascii',
 
1112
    testmod_names = [ \
 
1113
                   'bzrlib.tests.test_ancestry',
 
1114
                   'bzrlib.tests.test_api',
 
1115
                   'bzrlib.tests.test_bad_files',
 
1116
                   'bzrlib.tests.test_branch',
 
1117
                   'bzrlib.tests.test_bzrdir',
 
1118
                   'bzrlib.tests.test_command',
 
1119
                   'bzrlib.tests.test_commit',
 
1120
                   'bzrlib.tests.test_commit_merge',
 
1121
                   'bzrlib.tests.test_config',
 
1122
                   'bzrlib.tests.test_conflicts',
 
1123
                   'bzrlib.tests.test_decorators',
 
1124
                   'bzrlib.tests.test_diff',
 
1125
                   'bzrlib.tests.test_doc_generate',
 
1126
                   'bzrlib.tests.test_errors',
 
1127
                   'bzrlib.tests.test_escaped_store',
 
1128
                   'bzrlib.tests.test_fetch',
 
1129
                   'bzrlib.tests.test_gpg',
 
1130
                   'bzrlib.tests.test_graph',
 
1131
                   'bzrlib.tests.test_hashcache',
 
1132
                   'bzrlib.tests.test_http',
 
1133
                   'bzrlib.tests.test_identitymap',
 
1134
                   'bzrlib.tests.test_inv',
 
1135
                   'bzrlib.tests.test_knit',
 
1136
                   'bzrlib.tests.test_lockdir',
 
1137
                   'bzrlib.tests.test_lockable_files',
 
1138
                   'bzrlib.tests.test_log',
 
1139
                   'bzrlib.tests.test_merge',
 
1140
                   'bzrlib.tests.test_merge3',
 
1141
                   'bzrlib.tests.test_merge_core',
 
1142
                   'bzrlib.tests.test_missing',
 
1143
                   'bzrlib.tests.test_msgeditor',
 
1144
                   'bzrlib.tests.test_nonascii',
 
1145
                   'bzrlib.tests.test_options',
 
1146
                   'bzrlib.tests.test_osutils',
 
1147
                   'bzrlib.tests.test_patch',
 
1148
                   'bzrlib.tests.test_permissions',
 
1149
                   'bzrlib.tests.test_plugins',
 
1150
                   'bzrlib.tests.test_progress',
 
1151
                   'bzrlib.tests.test_reconcile',
 
1152
                   'bzrlib.tests.test_repository',
 
1153
                   'bzrlib.tests.test_revision',
 
1154
                   'bzrlib.tests.test_revisionnamespaces',
 
1155
                   'bzrlib.tests.test_revprops',
 
1156
                   'bzrlib.tests.test_rio',
 
1157
                   'bzrlib.tests.test_sampler',
 
1158
                   'bzrlib.tests.test_selftest',
 
1159
                   'bzrlib.tests.test_setup',
 
1160
                   'bzrlib.tests.test_sftp_transport',
 
1161
                   'bzrlib.tests.test_smart_add',
 
1162
                   'bzrlib.tests.test_source',
 
1163
                   'bzrlib.tests.test_status',
 
1164
                   'bzrlib.tests.test_store',
 
1165
                   'bzrlib.tests.test_symbol_versioning',
 
1166
                   'bzrlib.tests.test_testament',
 
1167
                   'bzrlib.tests.test_textfile',
 
1168
                   'bzrlib.tests.test_textmerge',
 
1169
                   'bzrlib.tests.test_trace',
 
1170
                   'bzrlib.tests.test_transactions',
 
1171
                   'bzrlib.tests.test_transform',
 
1172
                   'bzrlib.tests.test_transport',
 
1173
                   'bzrlib.tests.test_tsort',
 
1174
                   'bzrlib.tests.test_tuned_gzip',
 
1175
                   'bzrlib.tests.test_ui',
 
1176
                   'bzrlib.tests.test_upgrade',
 
1177
                   'bzrlib.tests.test_versionedfile',
 
1178
                   'bzrlib.tests.test_weave',
 
1179
                   'bzrlib.tests.test_whitebox',
 
1180
                   'bzrlib.tests.test_workingtree',
 
1181
                   'bzrlib.tests.test_xml',
566
1182
                   ]
567
 
 
568
 
    for m in (bzrlib.store, bzrlib.inventory, bzrlib.branch,
569
 
              bzrlib.osutils, bzrlib.commands, bzrlib.merge3,
570
 
              bzrlib.errors,
571
 
              ):
572
 
        if m not in MODULES_TO_DOCTEST:
573
 
            MODULES_TO_DOCTEST.append(m)
574
 
 
575
 
    TestCase.BZRPATH = os.path.join(os.path.realpath(os.path.dirname(bzrlib.__path__[0])), 'bzr')
576
 
    print '%-30s %s' % ('bzr binary', TestCase.BZRPATH)
577
 
    print
 
1183
    test_transport_implementations = [
 
1184
        'bzrlib.tests.test_transport_implementations']
 
1185
 
578
1186
    suite = TestSuite()
579
 
    suite.addTest(TestLoader().loadTestsFromNames(testmod_names))
 
1187
    loader = TestUtil.TestLoader()
 
1188
    from bzrlib.transport import TransportTestProviderAdapter
 
1189
    adapter = TransportTestProviderAdapter()
 
1190
    adapt_modules(test_transport_implementations, adapter, loader, suite)
 
1191
    suite.addTest(loader.loadTestsFromModuleNames(testmod_names))
 
1192
    for package in packages_to_test():
 
1193
        suite.addTest(package.test_suite())
580
1194
    for m in MODULES_TO_TEST:
581
 
         suite.addTest(TestLoader().loadTestsFromModule(m))
 
1195
        suite.addTest(loader.loadTestsFromModule(m))
582
1196
    for m in (MODULES_TO_DOCTEST):
583
1197
        suite.addTest(DocTestSuite(m))
584
 
    for p in bzrlib.plugin.all_plugins:
585
 
        if hasattr(p, 'test_suite'):
586
 
            suite.addTest(p.test_suite())
 
1198
    for name, plugin in bzrlib.plugin.all_plugins().items():
 
1199
        if getattr(plugin, 'test_suite', None) is not None:
 
1200
            suite.addTest(plugin.test_suite())
587
1201
    return suite
588
1202
 
 
1203
 
 
1204
def adapt_modules(mods_list, adapter, loader, suite):
 
1205
    """Adapt the modules in mods_list using adapter and add to suite."""
 
1206
    for test in iter_suite_tests(loader.loadTestsFromModuleNames(mods_list)):
 
1207
        suite.addTests(adapter.adapt(test))