/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/tests/__init__.py

(robertc) Partial fix for bug #39542 - allow lightweight checkouts over http.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
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
5
5
# the Free Software Foundation; either version 2 of the License, or
6
6
# (at your option) any later version.
7
 
 
 
7
#
8
8
# This program is distributed in the hope that it will be useful,
9
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
11
# GNU General Public License for more details.
12
 
 
 
12
#
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
29
29
import codecs
30
30
from cStringIO import StringIO
31
31
import difflib
 
32
import doctest
32
33
import errno
33
34
import logging
34
35
import os
35
36
import re
36
 
import shutil
 
37
import shlex
37
38
import stat
 
39
from subprocess import Popen, PIPE
38
40
import sys
39
41
import tempfile
40
42
import unittest
44
46
import bzrlib.branch
45
47
import bzrlib.bzrdir as bzrdir
46
48
import bzrlib.commands
 
49
import bzrlib.bundle.serializer
47
50
import bzrlib.errors as errors
48
51
import bzrlib.inventory
49
52
import bzrlib.iterablefile
50
53
import bzrlib.lockdir
 
54
try:
 
55
    import bzrlib.lsprof
 
56
except ImportError:
 
57
    # lsprof not available
 
58
    pass
51
59
from bzrlib.merge import merge_inner
52
60
import bzrlib.merge3
53
61
import bzrlib.osutils
54
62
import bzrlib.osutils as osutils
55
63
import bzrlib.plugin
 
64
import bzrlib.progress as progress
56
65
from bzrlib.revision import common_ancestor
57
66
import bzrlib.store
 
67
from bzrlib import symbol_versioning
58
68
import bzrlib.trace
59
 
from bzrlib.transport import urlescape, get_transport
 
69
from bzrlib.transport import get_transport
60
70
import bzrlib.transport
61
71
from bzrlib.transport.local import LocalRelpathServer
62
72
from bzrlib.transport.readonly import ReadonlyServer
63
73
from bzrlib.trace import mutter
64
 
from bzrlib.tests.TestUtil import TestLoader, TestSuite
 
74
from bzrlib.tests import TestUtil
 
75
from bzrlib.tests.TestUtil import (
 
76
                          TestSuite,
 
77
                          TestLoader,
 
78
                          )
65
79
from bzrlib.tests.treeshape import build_tree_contents
 
80
import bzrlib.urlutils as urlutils
66
81
from bzrlib.workingtree import WorkingTree, WorkingTreeFormat2
67
82
 
68
83
default_transport = LocalRelpathServer
70
85
MODULES_TO_TEST = []
71
86
MODULES_TO_DOCTEST = [
72
87
                      bzrlib.branch,
 
88
                      bzrlib.bundle.serializer,
73
89
                      bzrlib.commands,
74
90
                      bzrlib.errors,
75
91
                      bzrlib.inventory,
80
96
                      bzrlib.osutils,
81
97
                      bzrlib.store
82
98
                      ]
 
99
 
 
100
 
83
101
def packages_to_test():
84
102
    """Return a list of packages to test.
85
103
 
92
110
    import bzrlib.tests.bzrdir_implementations
93
111
    import bzrlib.tests.interrepository_implementations
94
112
    import bzrlib.tests.interversionedfile_implementations
 
113
    import bzrlib.tests.intertree_implementations
95
114
    import bzrlib.tests.repository_implementations
96
115
    import bzrlib.tests.revisionstore_implementations
 
116
    import bzrlib.tests.tree_implementations
97
117
    import bzrlib.tests.workingtree_implementations
98
118
    return [
99
119
            bzrlib.doc,
102
122
            bzrlib.tests.bzrdir_implementations,
103
123
            bzrlib.tests.interrepository_implementations,
104
124
            bzrlib.tests.interversionedfile_implementations,
 
125
            bzrlib.tests.intertree_implementations,
105
126
            bzrlib.tests.repository_implementations,
106
127
            bzrlib.tests.revisionstore_implementations,
 
128
            bzrlib.tests.tree_implementations,
107
129
            bzrlib.tests.workingtree_implementations,
108
130
            ]
109
131
 
114
136
    Shows output in a different format, including displaying runtime for tests.
115
137
    """
116
138
    stop_early = False
117
 
 
118
 
    def _elapsedTime(self):
119
 
        return "%5dms" % (1000 * (time.time() - self._start_time))
 
139
    
 
140
    def __init__(self, stream, descriptions, verbosity, pb=None,
 
141
                 bench_history=None):
 
142
        """Construct new TestResult.
 
143
 
 
144
        :param bench_history: Optionally, a writable file object to accumulate
 
145
            benchmark results.
 
146
        """
 
147
        unittest._TextTestResult.__init__(self, stream, descriptions, verbosity)
 
148
        self.pb = pb
 
149
        if bench_history is not None:
 
150
            from bzrlib.version import _get_bzr_source_tree
 
151
            src_tree = _get_bzr_source_tree()
 
152
            if src_tree:
 
153
                try:
 
154
                    revision_id = src_tree.get_parent_ids()[0]
 
155
                except IndexError:
 
156
                    # XXX: if this is a brand new tree, do the same as if there
 
157
                    # is no branch.
 
158
                    revision_id = ''
 
159
            else:
 
160
                # XXX: If there's no branch, what should we do?
 
161
                revision_id = ''
 
162
            bench_history.write("--date %s %s\n" % (time.time(), revision_id))
 
163
        self._bench_history = bench_history
 
164
    
 
165
    def extractBenchmarkTime(self, testCase):
 
166
        """Add a benchmark time for the current test case."""
 
167
        self._benchmarkTime = getattr(testCase, "_benchtime", None)
 
168
    
 
169
    def _elapsedTestTimeString(self):
 
170
        """Return a time string for the overall time the current test has taken."""
 
171
        return self._formatTime(time.time() - self._start_time)
 
172
 
 
173
    def _testTimeString(self):
 
174
        if self._benchmarkTime is not None:
 
175
            return "%s/%s" % (
 
176
                self._formatTime(self._benchmarkTime),
 
177
                self._elapsedTestTimeString())
 
178
        else:
 
179
            return "      %s" % self._elapsedTestTimeString()
 
180
 
 
181
    def _formatTime(self, seconds):
 
182
        """Format seconds as milliseconds with leading spaces."""
 
183
        return "%5dms" % (1000 * seconds)
 
184
 
 
185
    def _ellipsise_unimportant_words(self, a_string, final_width,
 
186
                                   keep_start=False):
 
187
        """Add ellipses (sp?) for overly long strings.
 
188
        
 
189
        :param keep_start: If true preserve the start of a_string rather
 
190
                           than the end of it.
 
191
        """
 
192
        if keep_start:
 
193
            if len(a_string) > final_width:
 
194
                result = a_string[:final_width-3] + '...'
 
195
            else:
 
196
                result = a_string
 
197
        else:
 
198
            if len(a_string) > final_width:
 
199
                result = '...' + a_string[3-final_width:]
 
200
            else:
 
201
                result = a_string
 
202
        return result.ljust(final_width)
120
203
 
121
204
    def startTest(self, test):
122
205
        unittest.TestResult.startTest(self, test)
124
207
        # the beginning, but in an id, the important words are
125
208
        # at the end
126
209
        SHOW_DESCRIPTIONS = False
 
210
 
 
211
        if not self.showAll and self.dots and self.pb is not None:
 
212
            final_width = 13
 
213
        else:
 
214
            final_width = osutils.terminal_width()
 
215
            final_width = final_width - 15 - 8
 
216
        what = None
 
217
        if SHOW_DESCRIPTIONS:
 
218
            what = test.shortDescription()
 
219
            if what:
 
220
                what = self._ellipsise_unimportant_words(what, final_width, keep_start=True)
 
221
        if what is None:
 
222
            what = test.id()
 
223
            if what.startswith('bzrlib.tests.'):
 
224
                what = what[13:]
 
225
            what = self._ellipsise_unimportant_words(what, final_width)
127
226
        if self.showAll:
128
 
            width = osutils.terminal_width()
129
 
            name_width = width - 15
130
 
            what = None
131
 
            if SHOW_DESCRIPTIONS:
132
 
                what = test.shortDescription()
133
 
                if what:
134
 
                    if len(what) > name_width:
135
 
                        what = what[:name_width-3] + '...'
136
 
            if what is None:
137
 
                what = test.id()
138
 
                if what.startswith('bzrlib.tests.'):
139
 
                    what = what[13:]
140
 
                if len(what) > name_width:
141
 
                    what = '...' + what[3-name_width:]
142
 
            what = what.ljust(name_width)
143
227
            self.stream.write(what)
 
228
        elif self.dots and self.pb is not None:
 
229
            self.pb.update(what, self.testsRun - 1, None)
144
230
        self.stream.flush()
 
231
        self._recordTestStartTime()
 
232
 
 
233
    def _recordTestStartTime(self):
 
234
        """Record that a test has started."""
145
235
        self._start_time = time.time()
146
236
 
147
237
    def addError(self, test, err):
148
238
        if isinstance(err[1], TestSkipped):
149
239
            return self.addSkipped(test, err)    
150
240
        unittest.TestResult.addError(self, test, err)
 
241
        self.extractBenchmarkTime(test)
151
242
        if self.showAll:
152
 
            self.stream.writeln("ERROR %s" % self._elapsedTime())
153
 
        elif self.dots:
 
243
            self.stream.writeln("ERROR %s" % self._testTimeString())
 
244
        elif self.dots and self.pb is None:
154
245
            self.stream.write('E')
 
246
        elif self.dots:
 
247
            self.pb.update(self._ellipsise_unimportant_words('ERROR', 13), self.testsRun, None)
 
248
            self.pb.note(self._ellipsise_unimportant_words(
 
249
                            test.id() + ': ERROR',
 
250
                            osutils.terminal_width()))
155
251
        self.stream.flush()
156
252
        if self.stop_early:
157
253
            self.stop()
158
254
 
159
255
    def addFailure(self, test, err):
160
256
        unittest.TestResult.addFailure(self, test, err)
 
257
        self.extractBenchmarkTime(test)
161
258
        if self.showAll:
162
 
            self.stream.writeln(" FAIL %s" % self._elapsedTime())
163
 
        elif self.dots:
 
259
            self.stream.writeln(" FAIL %s" % self._testTimeString())
 
260
        elif self.dots and self.pb is None:
164
261
            self.stream.write('F')
 
262
        elif self.dots:
 
263
            self.pb.update(self._ellipsise_unimportant_words('FAIL', 13), self.testsRun, None)
 
264
            self.pb.note(self._ellipsise_unimportant_words(
 
265
                            test.id() + ': FAIL',
 
266
                            osutils.terminal_width()))
165
267
        self.stream.flush()
166
268
        if self.stop_early:
167
269
            self.stop()
168
270
 
169
271
    def addSuccess(self, test):
 
272
        self.extractBenchmarkTime(test)
 
273
        if self._bench_history is not None:
 
274
            if self._benchmarkTime is not None:
 
275
                self._bench_history.write("%s %s\n" % (
 
276
                    self._formatTime(self._benchmarkTime),
 
277
                    test.id()))
170
278
        if self.showAll:
171
 
            self.stream.writeln('   OK %s' % self._elapsedTime())
172
 
        elif self.dots:
 
279
            self.stream.writeln('   OK %s' % self._testTimeString())
 
280
            for bench_called, stats in getattr(test, '_benchcalls', []):
 
281
                self.stream.writeln('LSProf output for %s(%s, %s)' % bench_called)
 
282
                stats.pprint(file=self.stream)
 
283
        elif self.dots and self.pb is None:
173
284
            self.stream.write('~')
 
285
        elif self.dots:
 
286
            self.pb.update(self._ellipsise_unimportant_words('OK', 13), self.testsRun, None)
174
287
        self.stream.flush()
175
288
        unittest.TestResult.addSuccess(self, test)
176
289
 
177
290
    def addSkipped(self, test, skip_excinfo):
 
291
        self.extractBenchmarkTime(test)
178
292
        if self.showAll:
179
 
            print >>self.stream, ' SKIP %s' % self._elapsedTime()
 
293
            print >>self.stream, ' SKIP %s' % self._testTimeString()
180
294
            print >>self.stream, '     %s' % skip_excinfo[1]
181
 
        elif self.dots:
 
295
        elif self.dots and self.pb is None:
182
296
            self.stream.write('S')
 
297
        elif self.dots:
 
298
            self.pb.update(self._ellipsise_unimportant_words('SKIP', 13), self.testsRun, None)
183
299
        self.stream.flush()
184
300
        # seems best to treat this as success from point-of-view of unittest
185
301
        # -- it actually does nothing so it barely matters :)
186
 
        unittest.TestResult.addSuccess(self, test)
 
302
        try:
 
303
            test.tearDown()
 
304
        except KeyboardInterrupt:
 
305
            raise
 
306
        except:
 
307
            self.addError(test, test.__exc_info())
 
308
        else:
 
309
            unittest.TestResult.addSuccess(self, test)
187
310
 
188
311
    def printErrorList(self, flavour, errors):
189
312
        for test, err in errors:
200
323
            self.stream.writeln("%s" % err)
201
324
 
202
325
 
203
 
class TextTestRunner(unittest.TextTestRunner):
 
326
class TextTestRunner(object):
204
327
    stop_on_failure = False
205
328
 
 
329
    def __init__(self,
 
330
                 stream=sys.stderr,
 
331
                 descriptions=0,
 
332
                 verbosity=1,
 
333
                 keep_output=False,
 
334
                 pb=None,
 
335
                 bench_history=None):
 
336
        self.stream = unittest._WritelnDecorator(stream)
 
337
        self.descriptions = descriptions
 
338
        self.verbosity = verbosity
 
339
        self.keep_output = keep_output
 
340
        self.pb = pb
 
341
        self._bench_history = bench_history
 
342
 
206
343
    def _makeResult(self):
207
 
        result = _MyResult(self.stream, self.descriptions, self.verbosity)
 
344
        result = _MyResult(self.stream,
 
345
                           self.descriptions,
 
346
                           self.verbosity,
 
347
                           pb=self.pb,
 
348
                           bench_history=self._bench_history)
208
349
        result.stop_early = self.stop_on_failure
209
350
        return result
210
351
 
 
352
    def run(self, test):
 
353
        "Run the given test case or test suite."
 
354
        result = self._makeResult()
 
355
        startTime = time.time()
 
356
        if self.pb is not None:
 
357
            self.pb.update('Running tests', 0, test.countTestCases())
 
358
        test.run(result)
 
359
        stopTime = time.time()
 
360
        timeTaken = stopTime - startTime
 
361
        result.printErrors()
 
362
        self.stream.writeln(result.separator2)
 
363
        run = result.testsRun
 
364
        self.stream.writeln("Ran %d test%s in %.3fs" %
 
365
                            (run, run != 1 and "s" or "", timeTaken))
 
366
        self.stream.writeln()
 
367
        if not result.wasSuccessful():
 
368
            self.stream.write("FAILED (")
 
369
            failed, errored = map(len, (result.failures, result.errors))
 
370
            if failed:
 
371
                self.stream.write("failures=%d" % failed)
 
372
            if errored:
 
373
                if failed: self.stream.write(", ")
 
374
                self.stream.write("errors=%d" % errored)
 
375
            self.stream.writeln(")")
 
376
        else:
 
377
            self.stream.writeln("OK")
 
378
        if self.pb is not None:
 
379
            self.pb.update('Cleaning up', 0, 1)
 
380
        # This is still a little bogus, 
 
381
        # but only a little. Folk not using our testrunner will
 
382
        # have to delete their temp directories themselves.
 
383
        test_root = TestCaseInTempDir.TEST_ROOT
 
384
        if result.wasSuccessful() or not self.keep_output:
 
385
            if test_root is not None:
 
386
                # If LANG=C we probably have created some bogus paths
 
387
                # which rmtree(unicode) will fail to delete
 
388
                # so make sure we are using rmtree(str) to delete everything
 
389
                # except on win32, where rmtree(str) will fail
 
390
                # since it doesn't have the property of byte-stream paths
 
391
                # (they are either ascii or mbcs)
 
392
                if sys.platform == 'win32':
 
393
                    # make sure we are using the unicode win32 api
 
394
                    test_root = unicode(test_root)
 
395
                else:
 
396
                    test_root = test_root.encode(
 
397
                        sys.getfilesystemencoding())
 
398
                osutils.rmtree(test_root)
 
399
        else:
 
400
            if self.pb is not None:
 
401
                self.pb.note("Failed tests working directories are in '%s'\n",
 
402
                             test_root)
 
403
            else:
 
404
                self.stream.writeln(
 
405
                    "Failed tests working directories are in '%s'\n" %
 
406
                    test_root)
 
407
        TestCaseInTempDir.TEST_ROOT = None
 
408
        if self.pb is not None:
 
409
            self.pb.clear()
 
410
        return result
 
411
 
211
412
 
212
413
def iter_suite_tests(suite):
213
414
    """Return all tests in a suite, recursing through nested suites"""
224
425
 
225
426
class TestSkipped(Exception):
226
427
    """Indicates that a test was intentionally skipped, rather than failing."""
227
 
    # XXX: Not used yet
228
428
 
229
429
 
230
430
class CommandFailed(Exception):
231
431
    pass
232
432
 
 
433
 
 
434
class StringIOWrapper(object):
 
435
    """A wrapper around cStringIO which just adds an encoding attribute.
 
436
    
 
437
    Internally we can check sys.stdout to see what the output encoding
 
438
    should be. However, cStringIO has no encoding attribute that we can
 
439
    set. So we wrap it instead.
 
440
    """
 
441
    encoding='ascii'
 
442
    _cstring = None
 
443
 
 
444
    def __init__(self, s=None):
 
445
        if s is not None:
 
446
            self.__dict__['_cstring'] = StringIO(s)
 
447
        else:
 
448
            self.__dict__['_cstring'] = StringIO()
 
449
 
 
450
    def __getattr__(self, name, getattr=getattr):
 
451
        return getattr(self.__dict__['_cstring'], name)
 
452
 
 
453
    def __setattr__(self, name, val):
 
454
        if name == 'encoding':
 
455
            self.__dict__['encoding'] = val
 
456
        else:
 
457
            return setattr(self._cstring, name, val)
 
458
 
 
459
 
233
460
class TestCase(unittest.TestCase):
234
461
    """Base class for bzr unit tests.
235
462
    
251
478
    accidentally overlooked.
252
479
    """
253
480
 
254
 
    BZRPATH = 'bzr'
255
481
    _log_file_name = None
256
482
    _log_contents = ''
 
483
    # record lsprof data when performing benchmark calls.
 
484
    _gather_lsprof_in_benchmarks = False
257
485
 
258
486
    def __init__(self, methodName='testMethod'):
259
487
        super(TestCase, self).__init__(methodName)
264
492
        self._cleanEnvironment()
265
493
        bzrlib.trace.disable_default_logging()
266
494
        self._startLogFile()
 
495
        self._benchcalls = []
 
496
        self._benchtime = None
267
497
 
268
498
    def _ndiff_strings(self, a, b):
269
499
        """Return ndiff between two strings containing lines.
303
533
            raise AssertionError('string %r does not start with %r' % (s, prefix))
304
534
 
305
535
    def assertEndsWith(self, s, suffix):
306
 
        if not s.endswith(prefix):
 
536
        """Asserts that s ends with suffix."""
 
537
        if not s.endswith(suffix):
307
538
            raise AssertionError('string %r does not end with %r' % (s, suffix))
308
539
 
309
540
    def assertContainsRe(self, haystack, needle_re):
312
543
            raise AssertionError('pattern "%s" not found in "%s"'
313
544
                    % (needle_re, haystack))
314
545
 
 
546
    def assertNotContainsRe(self, haystack, needle_re):
 
547
        """Assert that a does not match a regular expression"""
 
548
        if re.search(needle_re, haystack):
 
549
            raise AssertionError('pattern "%s" found in "%s"'
 
550
                    % (needle_re, haystack))
 
551
 
315
552
    def assertSubset(self, sublist, superlist):
316
553
        """Assert that every entry in sublist is present in superlist."""
317
554
        missing = []
341
578
    def assertIsInstance(self, obj, kls):
342
579
        """Fail if obj is not an instance of kls"""
343
580
        if not isinstance(obj, kls):
344
 
            self.fail("%r is not an instance of %s" % (obj, kls))
 
581
            self.fail("%r is an instance of %s rather than %s" % (
 
582
                obj, obj.__class__, kls))
 
583
 
 
584
    def _capture_warnings(self, a_callable, *args, **kwargs):
 
585
        """A helper for callDeprecated and applyDeprecated.
 
586
 
 
587
        :param a_callable: A callable to call.
 
588
        :param args: The positional arguments for the callable
 
589
        :param kwargs: The keyword arguments for the callable
 
590
        :return: A tuple (warnings, result). result is the result of calling
 
591
            a_callable(*args, **kwargs).
 
592
        """
 
593
        local_warnings = []
 
594
        def capture_warnings(msg, cls, stacklevel=None):
 
595
            # we've hooked into a deprecation specific callpath,
 
596
            # only deprecations should getting sent via it.
 
597
            self.assertEqual(cls, DeprecationWarning)
 
598
            local_warnings.append(msg)
 
599
        original_warning_method = symbol_versioning.warn
 
600
        symbol_versioning.set_warning_method(capture_warnings)
 
601
        try:
 
602
            result = a_callable(*args, **kwargs)
 
603
        finally:
 
604
            symbol_versioning.set_warning_method(original_warning_method)
 
605
        return (local_warnings, result)
 
606
 
 
607
    def applyDeprecated(self, deprecation_format, a_callable, *args, **kwargs):
 
608
        """Call a deprecated callable without warning the user.
 
609
 
 
610
        :param deprecation_format: The deprecation format that the callable
 
611
            should have been deprecated with. This is the same type as the 
 
612
            parameter to deprecated_method/deprecated_function. If the 
 
613
            callable is not deprecated with this format, an assertion error
 
614
            will be raised.
 
615
        :param a_callable: A callable to call. This may be a bound method or
 
616
            a regular function. It will be called with *args and **kwargs.
 
617
        :param args: The positional arguments for the callable
 
618
        :param kwargs: The keyword arguments for the callable
 
619
        :return: The result of a_callable(*args, **kwargs)
 
620
        """
 
621
        call_warnings, result = self._capture_warnings(a_callable,
 
622
            *args, **kwargs)
 
623
        expected_first_warning = symbol_versioning.deprecation_string(
 
624
            a_callable, deprecation_format)
 
625
        if len(call_warnings) == 0:
 
626
            self.fail("No assertion generated by call to %s" %
 
627
                a_callable)
 
628
        self.assertEqual(expected_first_warning, call_warnings[0])
 
629
        return result
 
630
 
 
631
    def callDeprecated(self, expected, callable, *args, **kwargs):
 
632
        """Assert that a callable is deprecated in a particular way.
 
633
 
 
634
        This is a very precise test for unusual requirements. The 
 
635
        applyDeprecated helper function is probably more suited for most tests
 
636
        as it allows you to simply specify the deprecation format being used
 
637
        and will ensure that that is issued for the function being called.
 
638
 
 
639
        :param expected: a list of the deprecation warnings expected, in order
 
640
        :param callable: The callable to call
 
641
        :param args: The positional arguments for the callable
 
642
        :param kwargs: The keyword arguments for the callable
 
643
        """
 
644
        call_warnings, result = self._capture_warnings(callable,
 
645
            *args, **kwargs)
 
646
        self.assertEqual(expected, call_warnings)
 
647
        return result
345
648
 
346
649
    def _startLogFile(self):
347
650
        """Send bzr and test log messages to a temporary file.
349
652
        The file is removed as the test is torn down.
350
653
        """
351
654
        fileno, name = tempfile.mkstemp(suffix='.log', prefix='testbzr')
352
 
        encoder, decoder, stream_reader, stream_writer = codecs.lookup('UTF-8')
353
 
        self._log_file = stream_writer(os.fdopen(fileno, 'w+'))
 
655
        self._log_file = os.fdopen(fileno, 'w+')
354
656
        self._log_nonce = bzrlib.trace.enable_test_log(self._log_file)
355
657
        self._log_file_name = name
356
658
        self.addCleanup(self._finishLogFile)
360
662
 
361
663
        Read contents into memory, close, and delete.
362
664
        """
 
665
        if self._log_file is None:
 
666
            return
363
667
        bzrlib.trace.disable_test_log(self._log_nonce)
364
668
        self._log_file.seek(0)
365
669
        self._log_contents = self._log_file.read()
382
686
        new_env = {
383
687
            'HOME': os.getcwd(),
384
688
            'APPDATA': os.getcwd(),
385
 
            'BZREMAIL': None,
 
689
            'BZR_EMAIL': None,
 
690
            'BZREMAIL': None, # may still be present in the environment
386
691
            'EMAIL': None,
 
692
            'BZR_PROGRESS_BAR': None,
387
693
        }
388
694
        self.__old_env = {}
389
695
        self.addCleanup(self._restoreEnvironment)
390
696
        for name, value in new_env.iteritems():
391
697
            self._captureVar(name, value)
392
698
 
393
 
 
394
699
    def _captureVar(self, name, newvalue):
395
 
        """Set an environment variable, preparing it to be reset when finished."""
396
 
        self.__old_env[name] = os.environ.get(name, None)
397
 
        if newvalue is None:
398
 
            if name in os.environ:
399
 
                del os.environ[name]
400
 
        else:
401
 
            os.environ[name] = newvalue
402
 
 
403
 
    @staticmethod
404
 
    def _restoreVar(name, value):
405
 
        if value is None:
406
 
            if name in os.environ:
407
 
                del os.environ[name]
408
 
        else:
409
 
            os.environ[name] = value
 
700
        """Set an environment variable, and reset it when finished."""
 
701
        self.__old_env[name] = osutils.set_or_unset_env(name, newvalue)
410
702
 
411
703
    def _restoreEnvironment(self):
412
704
        for name, value in self.__old_env.iteritems():
413
 
            self._restoreVar(name, value)
 
705
            osutils.set_or_unset_env(name, value)
414
706
 
415
707
    def tearDown(self):
416
708
        self._runCleanups()
417
709
        unittest.TestCase.tearDown(self)
418
710
 
 
711
    def time(self, callable, *args, **kwargs):
 
712
        """Run callable and accrue the time it takes to the benchmark time.
 
713
        
 
714
        If lsprofiling is enabled (i.e. by --lsprof-time to bzr selftest) then
 
715
        this will cause lsprofile statistics to be gathered and stored in
 
716
        self._benchcalls.
 
717
        """
 
718
        if self._benchtime is None:
 
719
            self._benchtime = 0
 
720
        start = time.time()
 
721
        try:
 
722
            if not self._gather_lsprof_in_benchmarks:
 
723
                return callable(*args, **kwargs)
 
724
            else:
 
725
                # record this benchmark
 
726
                ret, stats = bzrlib.lsprof.profile(callable, *args, **kwargs)
 
727
                stats.sort()
 
728
                self._benchcalls.append(((callable, args, kwargs), stats))
 
729
                return ret
 
730
        finally:
 
731
            self._benchtime += time.time() - start
 
732
 
419
733
    def _runCleanups(self):
420
734
        """Run registered cleanup functions. 
421
735
 
441
755
        """Shortcut that splits cmd into words, runs, and returns stdout"""
442
756
        return self.run_bzr_captured(cmd.split(), retcode=retcode)[0]
443
757
 
444
 
    def run_bzr_captured(self, argv, retcode=0):
 
758
    def run_bzr_captured(self, argv, retcode=0, encoding=None, stdin=None):
445
759
        """Invoke bzr and return (stdout, stderr).
446
760
 
447
761
        Useful for code that wants to check the contents of the
458
772
        errors, and with logging set to something approximating the
459
773
        default, so that error reporting can be checked.
460
774
 
461
 
        argv -- arguments to invoke bzr
462
 
        retcode -- expected return code, or None for don't-care.
 
775
        :param argv: arguments to invoke bzr
 
776
        :param retcode: expected return code, or None for don't-care.
 
777
        :param encoding: encoding for sys.stdout and sys.stderr
 
778
        :param stdin: A string to be used as stdin for the command.
463
779
        """
464
 
        stdout = StringIO()
465
 
        stderr = StringIO()
466
 
        self.log('run bzr: %s', ' '.join(argv))
 
780
        if encoding is None:
 
781
            encoding = bzrlib.user_encoding
 
782
        if stdin is not None:
 
783
            stdin = StringIO(stdin)
 
784
        stdout = StringIOWrapper()
 
785
        stderr = StringIOWrapper()
 
786
        stdout.encoding = encoding
 
787
        stderr.encoding = encoding
 
788
 
 
789
        self.log('run bzr: %r', argv)
467
790
        # FIXME: don't call into logging here
468
791
        handler = logging.StreamHandler(stderr)
469
 
        handler.setFormatter(bzrlib.trace.QuietFormatter())
470
792
        handler.setLevel(logging.INFO)
471
793
        logger = logging.getLogger('')
472
794
        logger.addHandler(handler)
 
795
        old_ui_factory = bzrlib.ui.ui_factory
 
796
        bzrlib.ui.ui_factory = bzrlib.tests.blackbox.TestUIFactory(
 
797
            stdout=stdout,
 
798
            stderr=stderr)
 
799
        bzrlib.ui.ui_factory.stdin = stdin
473
800
        try:
474
 
            result = self.apply_redirected(None, stdout, stderr,
 
801
            result = self.apply_redirected(stdin, stdout, stderr,
475
802
                                           bzrlib.commands.run_bzr_catch_errors,
476
803
                                           argv)
477
804
        finally:
478
805
            logger.removeHandler(handler)
 
806
            bzrlib.ui.ui_factory = old_ui_factory
 
807
 
479
808
        out = stdout.getvalue()
480
809
        err = stderr.getvalue()
481
810
        if out:
482
 
            self.log('output:\n%s', out)
 
811
            self.log('output:\n%r', out)
483
812
        if err:
484
 
            self.log('errors:\n%s', err)
 
813
            self.log('errors:\n%r', err)
485
814
        if retcode is not None:
486
 
            self.assertEquals(result, retcode)
 
815
            self.assertEquals(retcode, result)
487
816
        return out, err
488
817
 
489
818
    def run_bzr(self, *args, **kwargs):
495
824
 
496
825
        This sends the stdout/stderr results into the test's log,
497
826
        where it may be useful for debugging.  See also run_captured.
 
827
 
 
828
        :param stdin: A string to be used as stdin for the command.
498
829
        """
499
830
        retcode = kwargs.pop('retcode', 0)
500
 
        return self.run_bzr_captured(args, retcode)
 
831
        encoding = kwargs.pop('encoding', None)
 
832
        stdin = kwargs.pop('stdin', None)
 
833
        return self.run_bzr_captured(args, retcode=retcode, encoding=encoding, stdin=stdin)
 
834
 
 
835
    def run_bzr_decode(self, *args, **kwargs):
 
836
        if 'encoding' in kwargs:
 
837
            encoding = kwargs['encoding']
 
838
        else:
 
839
            encoding = bzrlib.user_encoding
 
840
        return self.run_bzr(*args, **kwargs)[0].decode(encoding)
 
841
 
 
842
    def run_bzr_error(self, error_regexes, *args, **kwargs):
 
843
        """Run bzr, and check that stderr contains the supplied regexes
 
844
        
 
845
        :param error_regexes: Sequence of regular expressions which 
 
846
            must each be found in the error output. The relative ordering
 
847
            is not enforced.
 
848
        :param args: command-line arguments for bzr
 
849
        :param kwargs: Keyword arguments which are interpreted by run_bzr
 
850
            This function changes the default value of retcode to be 3,
 
851
            since in most cases this is run when you expect bzr to fail.
 
852
        :return: (out, err) The actual output of running the command (in case you
 
853
                 want to do more inspection)
 
854
 
 
855
        Examples of use:
 
856
            # Make sure that commit is failing because there is nothing to do
 
857
            self.run_bzr_error(['no changes to commit'],
 
858
                               'commit', '-m', 'my commit comment')
 
859
            # Make sure --strict is handling an unknown file, rather than
 
860
            # giving us the 'nothing to do' error
 
861
            self.build_tree(['unknown'])
 
862
            self.run_bzr_error(['Commit refused because there are unknown files'],
 
863
                               'commit', '--strict', '-m', 'my commit comment')
 
864
        """
 
865
        kwargs.setdefault('retcode', 3)
 
866
        out, err = self.run_bzr(*args, **kwargs)
 
867
        for regex in error_regexes:
 
868
            self.assertContainsRe(err, regex)
 
869
        return out, err
 
870
 
 
871
    def run_bzr_subprocess(self, *args, **kwargs):
 
872
        """Run bzr in a subprocess for testing.
 
873
 
 
874
        This starts a new Python interpreter and runs bzr in there. 
 
875
        This should only be used for tests that have a justifiable need for
 
876
        this isolation: e.g. they are testing startup time, or signal
 
877
        handling, or early startup code, etc.  Subprocess code can't be 
 
878
        profiled or debugged so easily.
 
879
 
 
880
        :param retcode: The status code that is expected.  Defaults to 0.  If
 
881
            None is supplied, the status code is not checked.
 
882
        :param env_changes: A dictionary which lists changes to environment
 
883
            variables. A value of None will unset the env variable.
 
884
            The values must be strings. The change will only occur in the
 
885
            child, so you don't need to fix the environment after running.
 
886
        :param universal_newlines: Convert CRLF => LF
 
887
        """
 
888
        env_changes = kwargs.get('env_changes', {})
 
889
 
 
890
        old_env = {}
 
891
 
 
892
        def cleanup_environment():
 
893
            for env_var, value in env_changes.iteritems():
 
894
                old_env[env_var] = osutils.set_or_unset_env(env_var, value)
 
895
 
 
896
        def restore_environment():
 
897
            for env_var, value in old_env.iteritems():
 
898
                osutils.set_or_unset_env(env_var, value)
 
899
 
 
900
        bzr_path = os.path.dirname(os.path.dirname(bzrlib.__file__))+'/bzr'
 
901
        args = list(args)
 
902
 
 
903
        try:
 
904
            # win32 subprocess doesn't support preexec_fn
 
905
            # so we will avoid using it on all platforms, just to
 
906
            # make sure the code path is used, and we don't break on win32
 
907
            cleanup_environment()
 
908
            process = Popen([sys.executable, bzr_path]+args,
 
909
                             stdout=PIPE, stderr=PIPE)
 
910
        finally:
 
911
            restore_environment()
 
912
            
 
913
        out = process.stdout.read()
 
914
        err = process.stderr.read()
 
915
 
 
916
        if kwargs.get('universal_newlines', False):
 
917
            out = out.replace('\r\n', '\n')
 
918
            err = err.replace('\r\n', '\n')
 
919
 
 
920
        retcode = process.wait()
 
921
        supplied_retcode = kwargs.get('retcode', 0)
 
922
        if supplied_retcode is not None:
 
923
            assert supplied_retcode == retcode
 
924
        return [out, err]
501
925
 
502
926
    def check_inventory_shape(self, inv, shape):
503
927
        """Compare an inventory to a list of expected names.
551
975
            sys.stderr = real_stderr
552
976
            sys.stdin = real_stdin
553
977
 
 
978
    @symbol_versioning.deprecated_method(symbol_versioning.zero_eleven)
554
979
    def merge(self, branch_from, wt_to):
555
980
        """A helper for tests to do a ui-less merge.
556
981
 
562
987
        base_rev = common_ancestor(branch_from.last_revision(),
563
988
                                   wt_to.branch.last_revision(),
564
989
                                   wt_to.branch.repository)
565
 
        merge_inner(wt_to.branch, branch_from.basis_tree(), 
 
990
        merge_inner(wt_to.branch, branch_from.basis_tree(),
566
991
                    wt_to.branch.repository.revision_tree(base_rev),
567
992
                    this_tree=wt_to)
568
 
        wt_to.add_pending_merge(branch_from.last_revision())
 
993
        wt_to.add_parent_tree_id(branch_from.last_revision())
569
994
 
570
995
 
571
996
BzrTestBase = TestCase
636
1061
                i = i + 1
637
1062
                continue
638
1063
            else:
639
 
                self.test_dir = candidate_dir
 
1064
                os.mkdir(candidate_dir)
 
1065
                self.test_home_dir = candidate_dir + '/home'
 
1066
                os.mkdir(self.test_home_dir)
 
1067
                self.test_dir = candidate_dir + '/work'
640
1068
                os.mkdir(self.test_dir)
641
1069
                os.chdir(self.test_dir)
642
1070
                break
643
 
        os.environ['HOME'] = self.test_dir
644
 
        os.environ['APPDATA'] = self.test_dir
 
1071
        os.environ['HOME'] = self.test_home_dir
 
1072
        os.environ['APPDATA'] = self.test_home_dir
645
1073
        def _leaveDirectory():
646
1074
            os.chdir(_currentdir)
647
1075
        self.addCleanup(_leaveDirectory)
652
1080
        shape is a sequence of file specifications.  If the final
653
1081
        character is '/', a directory is created.
654
1082
 
 
1083
        This assumes that all the elements in the tree being built are new.
 
1084
 
655
1085
        This doesn't add anything to a branch.
656
1086
        :param line_endings: Either 'binary' or 'native'
657
1087
                             in binary mode, exact contents are written
662
1092
                          VFS's. If the transport is readonly or None,
663
1093
                          "." is opened automatically.
664
1094
        """
665
 
        # XXX: It's OK to just create them using forward slashes on windows?
 
1095
        # It's OK to just create them using forward slashes on windows.
666
1096
        if transport is None or transport.is_readonly():
667
1097
            transport = get_transport(".")
668
1098
        for name in shape:
669
1099
            self.assert_(isinstance(name, basestring))
670
1100
            if name[-1] == '/':
671
 
                transport.mkdir(urlescape(name[:-1]))
 
1101
                transport.mkdir(urlutils.escape(name[:-1]))
672
1102
            else:
673
1103
                if line_endings == 'binary':
674
1104
                    end = '\n'
676
1106
                    end = os.linesep
677
1107
                else:
678
1108
                    raise errors.BzrError('Invalid line ending request %r' % (line_endings,))
679
 
                content = "contents of %s%s" % (name, end)
680
 
                transport.put(urlescape(name), StringIO(content))
 
1109
                content = "contents of %s%s" % (name.encode('utf-8'), end)
 
1110
                # Technically 'put()' is the right command. However, put
 
1111
                # uses an AtomicFile, which requires an extra rename into place
 
1112
                # As long as the files didn't exist in the past, append() will
 
1113
                # do the same thing as put()
 
1114
                # On jam's machine, make_kernel_like_tree is:
 
1115
                #   put:    4.5-7.5s (averaging 6s)
 
1116
                #   append: 2.9-4.5s
 
1117
                #   put_non_atomic: 2.9-4.5s
 
1118
                transport.put_bytes_non_atomic(urlutils.escape(name), content)
681
1119
 
682
1120
    def build_tree_contents(self, shape):
683
1121
        build_tree_contents(shape)
693
1131
    def assertFileEqual(self, content, path):
694
1132
        """Fail if path does not contain 'content'."""
695
1133
        self.failUnless(osutils.lexists(path))
 
1134
        # TODO: jam 20060427 Shouldn't this be 'rb'?
696
1135
        self.assertEqualDiff(content, open(path, 'r').read())
697
1136
 
698
1137
 
774
1213
        if relpath is not None and relpath != '.':
775
1214
            if not base.endswith('/'):
776
1215
                base = base + '/'
777
 
            base = base + relpath
 
1216
            base = base + urlutils.escape(relpath)
778
1217
        return base
779
1218
 
780
1219
    def get_transport(self):
793
1232
        self.assertTrue(t.is_readonly())
794
1233
        return t
795
1234
 
796
 
    def make_branch(self, relpath):
 
1235
    def make_branch(self, relpath, format=None):
797
1236
        """Create a branch on the transport at relpath."""
798
 
        repo = self.make_repository(relpath)
 
1237
        repo = self.make_repository(relpath, format=format)
799
1238
        return repo.bzrdir.create_branch()
800
1239
 
801
 
    def make_bzrdir(self, relpath):
 
1240
    def make_bzrdir(self, relpath, format=None):
802
1241
        try:
803
1242
            url = self.get_url(relpath)
804
 
            segments = relpath.split('/')
 
1243
            mutter('relpath %r => url %r', relpath, url)
 
1244
            segments = url.split('/')
805
1245
            if segments and segments[-1] not in ('', '.'):
806
 
                parent = self.get_url('/'.join(segments[:-1]))
 
1246
                parent = '/'.join(segments[:-1])
807
1247
                t = get_transport(parent)
808
1248
                try:
809
1249
                    t.mkdir(segments[-1])
810
1250
                except errors.FileExists:
811
1251
                    pass
812
 
            return bzrlib.bzrdir.BzrDir.create(url)
 
1252
            if format is None:
 
1253
                format=bzrlib.bzrdir.BzrDirFormat.get_default_format()
 
1254
            # FIXME: make this use a single transport someday. RBC 20060418
 
1255
            return format.initialize_on_transport(get_transport(relpath))
813
1256
        except errors.UninitializableFormat:
814
 
            raise TestSkipped("Format %s is not initializable.")
 
1257
            raise TestSkipped("Format %s is not initializable." % format)
815
1258
 
816
 
    def make_repository(self, relpath, shared=False):
 
1259
    def make_repository(self, relpath, shared=False, format=None):
817
1260
        """Create a repository on our default transport at relpath."""
818
 
        made_control = self.make_bzrdir(relpath)
 
1261
        made_control = self.make_bzrdir(relpath, format=format)
819
1262
        return made_control.create_repository(shared=shared)
820
1263
 
821
 
    def make_branch_and_tree(self, relpath):
 
1264
    def make_branch_and_tree(self, relpath, format=None):
822
1265
        """Create a branch on the transport and a tree locally.
823
1266
 
824
1267
        Returns the tree.
827
1270
        # this obviously requires a format that supports branch references
828
1271
        # so check for that by checking bzrdir.BzrDirFormat.get_default_format()
829
1272
        # RBC 20060208
830
 
        b = self.make_branch(relpath)
 
1273
        b = self.make_branch(relpath, format=format)
831
1274
        try:
832
1275
            return b.bzrdir.create_workingtree()
833
1276
        except errors.NotLocalUrl:
872
1315
 
873
1316
 
874
1317
def filter_suite_by_re(suite, pattern):
875
 
    result = TestSuite()
 
1318
    result = TestUtil.TestSuite()
876
1319
    filter_re = re.compile(pattern)
877
1320
    for test in iter_suite_tests(suite):
878
1321
        if filter_re.search(test.id()):
882
1325
 
883
1326
def run_suite(suite, name='test', verbose=False, pattern=".*",
884
1327
              stop_on_failure=False, keep_output=False,
885
 
              transport=None):
 
1328
              transport=None, lsprof_timed=None, bench_history=None):
886
1329
    TestCaseInTempDir._TEST_NAME = name
 
1330
    TestCase._gather_lsprof_in_benchmarks = lsprof_timed
887
1331
    if verbose:
888
1332
        verbosity = 2
 
1333
        pb = None
889
1334
    else:
890
1335
        verbosity = 1
 
1336
        pb = progress.ProgressBar()
891
1337
    runner = TextTestRunner(stream=sys.stdout,
892
1338
                            descriptions=0,
893
 
                            verbosity=verbosity)
 
1339
                            verbosity=verbosity,
 
1340
                            keep_output=keep_output,
 
1341
                            pb=pb,
 
1342
                            bench_history=bench_history)
894
1343
    runner.stop_on_failure=stop_on_failure
895
1344
    if pattern != '.*':
896
1345
        suite = filter_suite_by_re(suite, pattern)
897
1346
    result = runner.run(suite)
898
 
    # This is still a little bogus, 
899
 
    # but only a little. Folk not using our testrunner will
900
 
    # have to delete their temp directories themselves.
901
 
    test_root = TestCaseInTempDir.TEST_ROOT
902
 
    if result.wasSuccessful() or not keep_output:
903
 
        if test_root is not None:
904
 
            print 'Deleting test root %s...' % test_root
905
 
            try:
906
 
                shutil.rmtree(test_root)
907
 
            finally:
908
 
                print
909
 
    else:
910
 
        print "Failed tests working directories are in '%s'\n" % TestCaseInTempDir.TEST_ROOT
911
1347
    return result.wasSuccessful()
912
1348
 
913
1349
 
914
1350
def selftest(verbose=False, pattern=".*", stop_on_failure=True,
915
1351
             keep_output=False,
916
 
             transport=None):
 
1352
             transport=None,
 
1353
             test_suite_factory=None,
 
1354
             lsprof_timed=None,
 
1355
             bench_history=None):
917
1356
    """Run the whole test suite under the enhanced runner"""
 
1357
    # XXX: Very ugly way to do this...
 
1358
    # Disable warning about old formats because we don't want it to disturb
 
1359
    # any blackbox tests.
 
1360
    from bzrlib import repository
 
1361
    repository._deprecation_warning_done = True
 
1362
 
918
1363
    global default_transport
919
1364
    if transport is None:
920
1365
        transport = default_transport
921
1366
    old_transport = default_transport
922
1367
    default_transport = transport
923
 
    suite = test_suite()
924
1368
    try:
 
1369
        if test_suite_factory is None:
 
1370
            suite = test_suite()
 
1371
        else:
 
1372
            suite = test_suite_factory()
925
1373
        return run_suite(suite, 'testbzr', verbose=verbose, pattern=pattern,
926
1374
                     stop_on_failure=stop_on_failure, keep_output=keep_output,
927
 
                     transport=transport)
 
1375
                     transport=transport,
 
1376
                     lsprof_timed=lsprof_timed,
 
1377
                     bench_history=bench_history)
928
1378
    finally:
929
1379
        default_transport = old_transport
930
1380
 
931
1381
 
932
 
 
933
1382
def test_suite():
934
 
    """Build and return TestSuite for the whole program."""
935
 
    from doctest import DocTestSuite
936
 
 
937
 
    global MODULES_TO_DOCTEST
938
 
 
939
 
    testmod_names = [ \
 
1383
    """Build and return TestSuite for the whole of bzrlib.
 
1384
    
 
1385
    This function can be replaced if you need to change the default test
 
1386
    suite on a global basis, but it is not encouraged.
 
1387
    """
 
1388
    testmod_names = [
940
1389
                   'bzrlib.tests.test_ancestry',
941
 
                   'bzrlib.tests.test_annotate',
942
1390
                   'bzrlib.tests.test_api',
 
1391
                   'bzrlib.tests.test_atomicfile',
943
1392
                   'bzrlib.tests.test_bad_files',
944
 
                   'bzrlib.tests.test_basis_inventory',
945
1393
                   'bzrlib.tests.test_branch',
 
1394
                   'bzrlib.tests.test_bundle',
946
1395
                   'bzrlib.tests.test_bzrdir',
 
1396
                   'bzrlib.tests.test_cache_utf8',
947
1397
                   'bzrlib.tests.test_command',
948
1398
                   'bzrlib.tests.test_commit',
949
1399
                   'bzrlib.tests.test_commit_merge',
959
1409
                   'bzrlib.tests.test_graph',
960
1410
                   'bzrlib.tests.test_hashcache',
961
1411
                   'bzrlib.tests.test_http',
 
1412
                   'bzrlib.tests.test_http_response',
962
1413
                   'bzrlib.tests.test_identitymap',
 
1414
                   'bzrlib.tests.test_ignores',
963
1415
                   'bzrlib.tests.test_inv',
964
1416
                   'bzrlib.tests.test_knit',
965
1417
                   'bzrlib.tests.test_lockdir',
973
1425
                   'bzrlib.tests.test_nonascii',
974
1426
                   'bzrlib.tests.test_options',
975
1427
                   'bzrlib.tests.test_osutils',
 
1428
                   'bzrlib.tests.test_patch',
 
1429
                   'bzrlib.tests.test_patches',
976
1430
                   'bzrlib.tests.test_permissions',
977
1431
                   'bzrlib.tests.test_plugins',
978
1432
                   'bzrlib.tests.test_progress',
979
1433
                   'bzrlib.tests.test_reconcile',
980
1434
                   'bzrlib.tests.test_repository',
 
1435
                   'bzrlib.tests.test_revert',
981
1436
                   'bzrlib.tests.test_revision',
982
1437
                   'bzrlib.tests.test_revisionnamespaces',
983
 
                   'bzrlib.tests.test_revprops',
 
1438
                   'bzrlib.tests.test_revisiontree',
984
1439
                   'bzrlib.tests.test_rio',
985
1440
                   'bzrlib.tests.test_sampler',
986
1441
                   'bzrlib.tests.test_selftest',
987
1442
                   'bzrlib.tests.test_setup',
988
1443
                   'bzrlib.tests.test_sftp_transport',
 
1444
                   'bzrlib.tests.test_ftp_transport',
989
1445
                   'bzrlib.tests.test_smart_add',
990
1446
                   'bzrlib.tests.test_source',
 
1447
                   'bzrlib.tests.test_status',
991
1448
                   'bzrlib.tests.test_store',
992
1449
                   'bzrlib.tests.test_symbol_versioning',
993
1450
                   'bzrlib.tests.test_testament',
 
1451
                   'bzrlib.tests.test_textfile',
 
1452
                   'bzrlib.tests.test_textmerge',
994
1453
                   'bzrlib.tests.test_trace',
995
1454
                   'bzrlib.tests.test_transactions',
996
1455
                   'bzrlib.tests.test_transform',
997
1456
                   'bzrlib.tests.test_transport',
 
1457
                   'bzrlib.tests.test_tree',
998
1458
                   'bzrlib.tests.test_tsort',
 
1459
                   'bzrlib.tests.test_tuned_gzip',
999
1460
                   'bzrlib.tests.test_ui',
1000
1461
                   'bzrlib.tests.test_upgrade',
 
1462
                   'bzrlib.tests.test_urlutils',
1001
1463
                   'bzrlib.tests.test_versionedfile',
 
1464
                   'bzrlib.tests.test_version',
1002
1465
                   'bzrlib.tests.test_weave',
1003
1466
                   'bzrlib.tests.test_whitebox',
1004
1467
                   'bzrlib.tests.test_workingtree',
1005
1468
                   'bzrlib.tests.test_xml',
1006
1469
                   ]
1007
1470
    test_transport_implementations = [
1008
 
        'bzrlib.tests.test_transport_implementations']
1009
 
 
1010
 
    TestCase.BZRPATH = osutils.pathjoin(
1011
 
            osutils.realpath(osutils.dirname(bzrlib.__path__[0])), 'bzr')
1012
 
    print '%10s: %s' % ('bzr', osutils.realpath(sys.argv[0]))
1013
 
    print '%10s: %s' % ('bzrlib', bzrlib.__path__[0])
1014
 
    print
1015
 
    suite = TestSuite()
1016
 
    # python2.4's TestLoader.loadTestsFromNames gives very poor 
1017
 
    # errors if it fails to load a named module - no indication of what's
1018
 
    # actually wrong, just "no such module".  We should probably override that
1019
 
    # class, but for the moment just load them ourselves. (mbp 20051202)
1020
 
    loader = TestLoader()
 
1471
        'bzrlib.tests.test_transport_implementations',
 
1472
        'bzrlib.tests.test_read_bundle',
 
1473
        ]
 
1474
    suite = TestUtil.TestSuite()
 
1475
    loader = TestUtil.TestLoader()
 
1476
    suite.addTest(loader.loadTestsFromModuleNames(testmod_names))
1021
1477
    from bzrlib.transport import TransportTestProviderAdapter
1022
1478
    adapter = TransportTestProviderAdapter()
1023
1479
    adapt_modules(test_transport_implementations, adapter, loader, suite)
1024
 
    for mod_name in testmod_names:
1025
 
        mod = _load_module_by_name(mod_name)
1026
 
        suite.addTest(loader.loadTestsFromModule(mod))
1027
1480
    for package in packages_to_test():
1028
1481
        suite.addTest(package.test_suite())
1029
1482
    for m in MODULES_TO_TEST:
1030
1483
        suite.addTest(loader.loadTestsFromModule(m))
1031
 
    for m in (MODULES_TO_DOCTEST):
1032
 
        suite.addTest(DocTestSuite(m))
 
1484
    for m in MODULES_TO_DOCTEST:
 
1485
        suite.addTest(doctest.DocTestSuite(m))
1033
1486
    for name, plugin in bzrlib.plugin.all_plugins().items():
1034
1487
        if getattr(plugin, 'test_suite', None) is not None:
1035
1488
            suite.addTest(plugin.test_suite())
1038
1491
 
1039
1492
def adapt_modules(mods_list, adapter, loader, suite):
1040
1493
    """Adapt the modules in mods_list using adapter and add to suite."""
1041
 
    for mod_name in mods_list:
1042
 
        mod = _load_module_by_name(mod_name)
1043
 
        for test in iter_suite_tests(loader.loadTestsFromModule(mod)):
1044
 
            suite.addTests(adapter.adapt(test))
1045
 
 
1046
 
 
1047
 
def _load_module_by_name(mod_name):
1048
 
    parts = mod_name.split('.')
1049
 
    module = __import__(mod_name)
1050
 
    del parts[0]
1051
 
    # for historical reasons python returns the top-level module even though
1052
 
    # it loads the submodule; we need to walk down to get the one we want.
1053
 
    while parts:
1054
 
        module = getattr(module, parts.pop(0))
1055
 
    return module
 
1494
    for test in iter_suite_tests(loader.loadTestsFromModuleNames(mods_list)):
 
1495
        suite.addTests(adapter.adapt(test))