~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/tests/__init__.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2006-04-29 09:19:50 UTC
  • mfrom: (1185.50.89 bzr-jam-integration)
  • Revision ID: pqm@pqm.ubuntu.com-20060429091950-d5ec09cd6e7c591a
Small help-text fixes

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
33
32
import errno
34
33
import logging
35
34
import os
36
35
import re
37
 
import shlex
 
36
import shutil
38
37
import stat
39
 
from subprocess import Popen, PIPE
40
38
import sys
41
39
import tempfile
42
40
import unittest
46
44
import bzrlib.branch
47
45
import bzrlib.bzrdir as bzrdir
48
46
import bzrlib.commands
49
 
import bzrlib.bundle.serializer
50
47
import bzrlib.errors as errors
51
48
import bzrlib.inventory
52
49
import bzrlib.iterablefile
53
50
import bzrlib.lockdir
54
 
try:
55
 
    import bzrlib.lsprof
56
 
except ImportError:
57
 
    # lsprof not available
58
 
    pass
59
51
from bzrlib.merge import merge_inner
60
52
import bzrlib.merge3
61
53
import bzrlib.osutils
62
54
import bzrlib.osutils as osutils
63
55
import bzrlib.plugin
64
 
import bzrlib.progress as progress
65
56
from bzrlib.revision import common_ancestor
66
57
import bzrlib.store
67
 
from bzrlib import symbol_versioning
68
58
import bzrlib.trace
69
 
from bzrlib.transport import get_transport
 
59
from bzrlib.transport import urlescape, get_transport
70
60
import bzrlib.transport
71
61
from bzrlib.transport.local import LocalRelpathServer
72
62
from bzrlib.transport.readonly import ReadonlyServer
73
63
from bzrlib.trace import mutter
74
 
from bzrlib.tests import TestUtil
75
 
from bzrlib.tests.TestUtil import (
76
 
                          TestSuite,
77
 
                          TestLoader,
78
 
                          )
 
64
from bzrlib.tests.TestUtil import TestLoader, TestSuite
79
65
from bzrlib.tests.treeshape import build_tree_contents
80
 
import bzrlib.urlutils as urlutils
81
66
from bzrlib.workingtree import WorkingTree, WorkingTreeFormat2
82
67
 
83
68
default_transport = LocalRelpathServer
85
70
MODULES_TO_TEST = []
86
71
MODULES_TO_DOCTEST = [
87
72
                      bzrlib.branch,
88
 
                      bzrlib.bundle.serializer,
89
73
                      bzrlib.commands,
90
74
                      bzrlib.errors,
91
75
                      bzrlib.inventory,
96
80
                      bzrlib.osutils,
97
81
                      bzrlib.store
98
82
                      ]
99
 
 
100
 
 
101
83
def packages_to_test():
102
84
    """Return a list of packages to test.
103
85
 
110
92
    import bzrlib.tests.bzrdir_implementations
111
93
    import bzrlib.tests.interrepository_implementations
112
94
    import bzrlib.tests.interversionedfile_implementations
113
 
    import bzrlib.tests.intertree_implementations
114
95
    import bzrlib.tests.repository_implementations
115
96
    import bzrlib.tests.revisionstore_implementations
116
 
    import bzrlib.tests.tree_implementations
117
97
    import bzrlib.tests.workingtree_implementations
118
98
    return [
119
99
            bzrlib.doc,
122
102
            bzrlib.tests.bzrdir_implementations,
123
103
            bzrlib.tests.interrepository_implementations,
124
104
            bzrlib.tests.interversionedfile_implementations,
125
 
            bzrlib.tests.intertree_implementations,
126
105
            bzrlib.tests.repository_implementations,
127
106
            bzrlib.tests.revisionstore_implementations,
128
 
            bzrlib.tests.tree_implementations,
129
107
            bzrlib.tests.workingtree_implementations,
130
108
            ]
131
109
 
136
114
    Shows output in a different format, including displaying runtime for tests.
137
115
    """
138
116
    stop_early = False
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)
 
117
 
 
118
    def _elapsedTime(self):
 
119
        return "%5dms" % (1000 * (time.time() - self._start_time))
203
120
 
204
121
    def startTest(self, test):
205
122
        unittest.TestResult.startTest(self, test)
207
124
        # the beginning, but in an id, the important words are
208
125
        # at the end
209
126
        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)
226
127
        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)
227
143
            self.stream.write(what)
228
 
        elif self.dots and self.pb is not None:
229
 
            self.pb.update(what, self.testsRun - 1, None)
230
144
        self.stream.flush()
231
 
        self._recordTestStartTime()
232
 
 
233
 
    def _recordTestStartTime(self):
234
 
        """Record that a test has started."""
235
145
        self._start_time = time.time()
236
146
 
237
147
    def addError(self, test, err):
238
148
        if isinstance(err[1], TestSkipped):
239
149
            return self.addSkipped(test, err)    
240
150
        unittest.TestResult.addError(self, test, err)
241
 
        self.extractBenchmarkTime(test)
242
151
        if self.showAll:
243
 
            self.stream.writeln("ERROR %s" % self._testTimeString())
244
 
        elif self.dots and self.pb is None:
 
152
            self.stream.writeln("ERROR %s" % self._elapsedTime())
 
153
        elif self.dots:
245
154
            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()))
251
155
        self.stream.flush()
252
156
        if self.stop_early:
253
157
            self.stop()
254
158
 
255
159
    def addFailure(self, test, err):
256
160
        unittest.TestResult.addFailure(self, test, err)
257
 
        self.extractBenchmarkTime(test)
258
161
        if self.showAll:
259
 
            self.stream.writeln(" FAIL %s" % self._testTimeString())
260
 
        elif self.dots and self.pb is None:
 
162
            self.stream.writeln(" FAIL %s" % self._elapsedTime())
 
163
        elif self.dots:
261
164
            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()))
267
165
        self.stream.flush()
268
166
        if self.stop_early:
269
167
            self.stop()
270
168
 
271
169
    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()))
278
170
        if self.showAll:
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:
 
171
            self.stream.writeln('   OK %s' % self._elapsedTime())
 
172
        elif self.dots:
284
173
            self.stream.write('~')
285
 
        elif self.dots:
286
 
            self.pb.update(self._ellipsise_unimportant_words('OK', 13), self.testsRun, None)
287
174
        self.stream.flush()
288
175
        unittest.TestResult.addSuccess(self, test)
289
176
 
290
177
    def addSkipped(self, test, skip_excinfo):
291
 
        self.extractBenchmarkTime(test)
292
178
        if self.showAll:
293
 
            print >>self.stream, ' SKIP %s' % self._testTimeString()
 
179
            print >>self.stream, ' SKIP %s' % self._elapsedTime()
294
180
            print >>self.stream, '     %s' % skip_excinfo[1]
295
 
        elif self.dots and self.pb is None:
 
181
        elif self.dots:
296
182
            self.stream.write('S')
297
 
        elif self.dots:
298
 
            self.pb.update(self._ellipsise_unimportant_words('SKIP', 13), self.testsRun, None)
299
183
        self.stream.flush()
300
184
        # seems best to treat this as success from point-of-view of unittest
301
185
        # -- it actually does nothing so it barely matters :)
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)
 
186
        unittest.TestResult.addSuccess(self, test)
310
187
 
311
188
    def printErrorList(self, flavour, errors):
312
189
        for test, err in errors:
323
200
            self.stream.writeln("%s" % err)
324
201
 
325
202
 
326
 
class TextTestRunner(object):
 
203
class TextTestRunner(unittest.TextTestRunner):
327
204
    stop_on_failure = False
328
205
 
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
 
 
343
206
    def _makeResult(self):
344
 
        result = _MyResult(self.stream,
345
 
                           self.descriptions,
346
 
                           self.verbosity,
347
 
                           pb=self.pb,
348
 
                           bench_history=self._bench_history)
 
207
        result = _MyResult(self.stream, self.descriptions, self.verbosity)
349
208
        result.stop_early = self.stop_on_failure
350
209
        return result
351
210
 
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
 
 
412
211
 
413
212
def iter_suite_tests(suite):
414
213
    """Return all tests in a suite, recursing through nested suites"""
425
224
 
426
225
class TestSkipped(Exception):
427
226
    """Indicates that a test was intentionally skipped, rather than failing."""
 
227
    # XXX: Not used yet
428
228
 
429
229
 
430
230
class CommandFailed(Exception):
431
231
    pass
432
232
 
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
 
 
460
233
class TestCase(unittest.TestCase):
461
234
    """Base class for bzr unit tests.
462
235
    
478
251
    accidentally overlooked.
479
252
    """
480
253
 
 
254
    BZRPATH = 'bzr'
481
255
    _log_file_name = None
482
256
    _log_contents = ''
483
 
    # record lsprof data when performing benchmark calls.
484
 
    _gather_lsprof_in_benchmarks = False
485
257
 
486
258
    def __init__(self, methodName='testMethod'):
487
259
        super(TestCase, self).__init__(methodName)
492
264
        self._cleanEnvironment()
493
265
        bzrlib.trace.disable_default_logging()
494
266
        self._startLogFile()
495
 
        self._benchcalls = []
496
 
        self._benchtime = None
497
267
 
498
268
    def _ndiff_strings(self, a, b):
499
269
        """Return ndiff between two strings containing lines.
533
303
            raise AssertionError('string %r does not start with %r' % (s, prefix))
534
304
 
535
305
    def assertEndsWith(self, s, suffix):
536
 
        """Asserts that s ends with suffix."""
537
 
        if not s.endswith(suffix):
 
306
        if not s.endswith(prefix):
538
307
            raise AssertionError('string %r does not end with %r' % (s, suffix))
539
308
 
540
309
    def assertContainsRe(self, haystack, needle_re):
543
312
            raise AssertionError('pattern "%s" not found in "%s"'
544
313
                    % (needle_re, haystack))
545
314
 
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
 
 
552
315
    def assertSubset(self, sublist, superlist):
553
316
        """Assert that every entry in sublist is present in superlist."""
554
317
        missing = []
581
344
            self.fail("%r is an instance of %s rather than %s" % (
582
345
                obj, obj.__class__, kls))
583
346
 
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
648
 
 
649
347
    def _startLogFile(self):
650
348
        """Send bzr and test log messages to a temporary file.
651
349
 
652
350
        The file is removed as the test is torn down.
653
351
        """
654
352
        fileno, name = tempfile.mkstemp(suffix='.log', prefix='testbzr')
655
 
        self._log_file = os.fdopen(fileno, 'w+')
 
353
        encoder, decoder, stream_reader, stream_writer = codecs.lookup('UTF-8')
 
354
        self._log_file = stream_writer(os.fdopen(fileno, 'w+'))
656
355
        self._log_nonce = bzrlib.trace.enable_test_log(self._log_file)
657
356
        self._log_file_name = name
658
357
        self.addCleanup(self._finishLogFile)
662
361
 
663
362
        Read contents into memory, close, and delete.
664
363
        """
665
 
        if self._log_file is None:
666
 
            return
667
364
        bzrlib.trace.disable_test_log(self._log_nonce)
668
365
        self._log_file.seek(0)
669
366
        self._log_contents = self._log_file.read()
686
383
        new_env = {
687
384
            'HOME': os.getcwd(),
688
385
            'APPDATA': os.getcwd(),
689
 
            'BZR_EMAIL': None,
690
 
            'BZREMAIL': None, # may still be present in the environment
 
386
            'BZREMAIL': None,
691
387
            'EMAIL': None,
692
 
            'BZR_PROGRESS_BAR': None,
693
388
        }
694
389
        self.__old_env = {}
695
390
        self.addCleanup(self._restoreEnvironment)
696
391
        for name, value in new_env.iteritems():
697
392
            self._captureVar(name, value)
698
393
 
 
394
 
699
395
    def _captureVar(self, name, newvalue):
700
 
        """Set an environment variable, and reset it when finished."""
701
 
        self.__old_env[name] = osutils.set_or_unset_env(name, newvalue)
 
396
        """Set an environment variable, preparing it to be reset when finished."""
 
397
        self.__old_env[name] = os.environ.get(name, None)
 
398
        if newvalue is None:
 
399
            if name in os.environ:
 
400
                del os.environ[name]
 
401
        else:
 
402
            os.environ[name] = newvalue
 
403
 
 
404
    @staticmethod
 
405
    def _restoreVar(name, value):
 
406
        if value is None:
 
407
            if name in os.environ:
 
408
                del os.environ[name]
 
409
        else:
 
410
            os.environ[name] = value
702
411
 
703
412
    def _restoreEnvironment(self):
704
413
        for name, value in self.__old_env.iteritems():
705
 
            osutils.set_or_unset_env(name, value)
 
414
            self._restoreVar(name, value)
706
415
 
707
416
    def tearDown(self):
708
417
        self._runCleanups()
709
418
        unittest.TestCase.tearDown(self)
710
419
 
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
 
 
733
420
    def _runCleanups(self):
734
421
        """Run registered cleanup functions. 
735
422
 
755
442
        """Shortcut that splits cmd into words, runs, and returns stdout"""
756
443
        return self.run_bzr_captured(cmd.split(), retcode=retcode)[0]
757
444
 
758
 
    def run_bzr_captured(self, argv, retcode=0, encoding=None, stdin=None):
 
445
    def run_bzr_captured(self, argv, retcode=0):
759
446
        """Invoke bzr and return (stdout, stderr).
760
447
 
761
448
        Useful for code that wants to check the contents of the
772
459
        errors, and with logging set to something approximating the
773
460
        default, so that error reporting can be checked.
774
461
 
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.
 
462
        argv -- arguments to invoke bzr
 
463
        retcode -- expected return code, or None for don't-care.
779
464
        """
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)
 
465
        stdout = StringIO()
 
466
        stderr = StringIO()
 
467
        self.log('run bzr: %s', ' '.join(argv))
790
468
        # FIXME: don't call into logging here
791
469
        handler = logging.StreamHandler(stderr)
 
470
        handler.setFormatter(bzrlib.trace.QuietFormatter())
792
471
        handler.setLevel(logging.INFO)
793
472
        logger = logging.getLogger('')
794
473
        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
800
474
        try:
801
 
            result = self.apply_redirected(stdin, stdout, stderr,
 
475
            result = self.apply_redirected(None, stdout, stderr,
802
476
                                           bzrlib.commands.run_bzr_catch_errors,
803
477
                                           argv)
804
478
        finally:
805
479
            logger.removeHandler(handler)
806
 
            bzrlib.ui.ui_factory = old_ui_factory
807
 
 
808
480
        out = stdout.getvalue()
809
481
        err = stderr.getvalue()
810
482
        if out:
811
 
            self.log('output:\n%r', out)
 
483
            self.log('output:\n%s', out)
812
484
        if err:
813
 
            self.log('errors:\n%r', err)
 
485
            self.log('errors:\n%s', err)
814
486
        if retcode is not None:
815
 
            self.assertEquals(retcode, result)
 
487
            self.assertEquals(result, retcode)
816
488
        return out, err
817
489
 
818
490
    def run_bzr(self, *args, **kwargs):
824
496
 
825
497
        This sends the stdout/stderr results into the test's log,
826
498
        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.
829
499
        """
830
500
        retcode = kwargs.pop('retcode', 0)
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
        return self.run_bzr_captured(args, retcode)
925
502
 
926
503
    def check_inventory_shape(self, inv, shape):
927
504
        """Compare an inventory to a list of expected names.
975
552
            sys.stderr = real_stderr
976
553
            sys.stdin = real_stdin
977
554
 
978
 
    @symbol_versioning.deprecated_method(symbol_versioning.zero_eleven)
979
555
    def merge(self, branch_from, wt_to):
980
556
        """A helper for tests to do a ui-less merge.
981
557
 
987
563
        base_rev = common_ancestor(branch_from.last_revision(),
988
564
                                   wt_to.branch.last_revision(),
989
565
                                   wt_to.branch.repository)
990
 
        merge_inner(wt_to.branch, branch_from.basis_tree(),
 
566
        merge_inner(wt_to.branch, branch_from.basis_tree(), 
991
567
                    wt_to.branch.repository.revision_tree(base_rev),
992
568
                    this_tree=wt_to)
993
 
        wt_to.add_parent_tree_id(branch_from.last_revision())
 
569
        wt_to.add_pending_merge(branch_from.last_revision())
994
570
 
995
571
 
996
572
BzrTestBase = TestCase
1061
637
                i = i + 1
1062
638
                continue
1063
639
            else:
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
                self.test_dir = candidate_dir
1068
641
                os.mkdir(self.test_dir)
1069
642
                os.chdir(self.test_dir)
1070
643
                break
1071
 
        os.environ['HOME'] = self.test_home_dir
1072
 
        os.environ['APPDATA'] = self.test_home_dir
 
644
        os.environ['HOME'] = self.test_dir
 
645
        os.environ['APPDATA'] = self.test_dir
1073
646
        def _leaveDirectory():
1074
647
            os.chdir(_currentdir)
1075
648
        self.addCleanup(_leaveDirectory)
1080
653
        shape is a sequence of file specifications.  If the final
1081
654
        character is '/', a directory is created.
1082
655
 
1083
 
        This assumes that all the elements in the tree being built are new.
1084
 
 
1085
656
        This doesn't add anything to a branch.
1086
657
        :param line_endings: Either 'binary' or 'native'
1087
658
                             in binary mode, exact contents are written
1092
663
                          VFS's. If the transport is readonly or None,
1093
664
                          "." is opened automatically.
1094
665
        """
1095
 
        # It's OK to just create them using forward slashes on windows.
 
666
        # XXX: It's OK to just create them using forward slashes on windows?
1096
667
        if transport is None or transport.is_readonly():
1097
668
            transport = get_transport(".")
1098
669
        for name in shape:
1099
670
            self.assert_(isinstance(name, basestring))
1100
671
            if name[-1] == '/':
1101
 
                transport.mkdir(urlutils.escape(name[:-1]))
 
672
                transport.mkdir(urlescape(name[:-1]))
1102
673
            else:
1103
674
                if line_endings == 'binary':
1104
675
                    end = '\n'
1106
677
                    end = os.linesep
1107
678
                else:
1108
679
                    raise errors.BzrError('Invalid line ending request %r' % (line_endings,))
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)
 
680
                content = "contents of %s%s" % (name, end)
 
681
                transport.put(urlescape(name), StringIO(content))
1119
682
 
1120
683
    def build_tree_contents(self, shape):
1121
684
        build_tree_contents(shape)
1131
694
    def assertFileEqual(self, content, path):
1132
695
        """Fail if path does not contain 'content'."""
1133
696
        self.failUnless(osutils.lexists(path))
1134
 
        # TODO: jam 20060427 Shouldn't this be 'rb'?
1135
697
        self.assertEqualDiff(content, open(path, 'r').read())
1136
698
 
1137
699
 
1213
775
        if relpath is not None and relpath != '.':
1214
776
            if not base.endswith('/'):
1215
777
                base = base + '/'
1216
 
            base = base + urlutils.escape(relpath)
 
778
            base = base + relpath
1217
779
        return base
1218
780
 
1219
781
    def get_transport(self):
1240
802
    def make_bzrdir(self, relpath, format=None):
1241
803
        try:
1242
804
            url = self.get_url(relpath)
1243
 
            mutter('relpath %r => url %r', relpath, url)
1244
 
            segments = url.split('/')
 
805
            segments = relpath.split('/')
1245
806
            if segments and segments[-1] not in ('', '.'):
1246
 
                parent = '/'.join(segments[:-1])
 
807
                parent = self.get_url('/'.join(segments[:-1]))
1247
808
                t = get_transport(parent)
1248
809
                try:
1249
810
                    t.mkdir(segments[-1])
1315
876
 
1316
877
 
1317
878
def filter_suite_by_re(suite, pattern):
1318
 
    result = TestUtil.TestSuite()
 
879
    result = TestSuite()
1319
880
    filter_re = re.compile(pattern)
1320
881
    for test in iter_suite_tests(suite):
1321
882
        if filter_re.search(test.id()):
1325
886
 
1326
887
def run_suite(suite, name='test', verbose=False, pattern=".*",
1327
888
              stop_on_failure=False, keep_output=False,
1328
 
              transport=None, lsprof_timed=None, bench_history=None):
 
889
              transport=None):
1329
890
    TestCaseInTempDir._TEST_NAME = name
1330
 
    TestCase._gather_lsprof_in_benchmarks = lsprof_timed
1331
891
    if verbose:
1332
892
        verbosity = 2
1333
 
        pb = None
1334
893
    else:
1335
894
        verbosity = 1
1336
 
        pb = progress.ProgressBar()
1337
895
    runner = TextTestRunner(stream=sys.stdout,
1338
896
                            descriptions=0,
1339
 
                            verbosity=verbosity,
1340
 
                            keep_output=keep_output,
1341
 
                            pb=pb,
1342
 
                            bench_history=bench_history)
 
897
                            verbosity=verbosity)
1343
898
    runner.stop_on_failure=stop_on_failure
1344
899
    if pattern != '.*':
1345
900
        suite = filter_suite_by_re(suite, pattern)
1346
901
    result = runner.run(suite)
 
902
    # This is still a little bogus, 
 
903
    # but only a little. Folk not using our testrunner will
 
904
    # have to delete their temp directories themselves.
 
905
    test_root = TestCaseInTempDir.TEST_ROOT
 
906
    if result.wasSuccessful() or not keep_output:
 
907
        if test_root is not None:
 
908
            print 'Deleting test root %s...' % test_root
 
909
            try:
 
910
                shutil.rmtree(test_root)
 
911
            finally:
 
912
                print
 
913
    else:
 
914
        print "Failed tests working directories are in '%s'\n" % TestCaseInTempDir.TEST_ROOT
1347
915
    return result.wasSuccessful()
1348
916
 
1349
917
 
1350
918
def selftest(verbose=False, pattern=".*", stop_on_failure=True,
1351
919
             keep_output=False,
1352
 
             transport=None,
1353
 
             test_suite_factory=None,
1354
 
             lsprof_timed=None,
1355
 
             bench_history=None):
 
920
             transport=None):
1356
921
    """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
 
 
1363
922
    global default_transport
1364
923
    if transport is None:
1365
924
        transport = default_transport
1366
925
    old_transport = default_transport
1367
926
    default_transport = transport
 
927
    suite = test_suite()
1368
928
    try:
1369
 
        if test_suite_factory is None:
1370
 
            suite = test_suite()
1371
 
        else:
1372
 
            suite = test_suite_factory()
1373
929
        return run_suite(suite, 'testbzr', verbose=verbose, pattern=pattern,
1374
930
                     stop_on_failure=stop_on_failure, keep_output=keep_output,
1375
 
                     transport=transport,
1376
 
                     lsprof_timed=lsprof_timed,
1377
 
                     bench_history=bench_history)
 
931
                     transport=transport)
1378
932
    finally:
1379
933
        default_transport = old_transport
1380
934
 
1381
935
 
 
936
 
1382
937
def test_suite():
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 = [
 
938
    """Build and return TestSuite for the whole program."""
 
939
    from doctest import DocTestSuite
 
940
 
 
941
    global MODULES_TO_DOCTEST
 
942
 
 
943
    testmod_names = [ \
1389
944
                   'bzrlib.tests.test_ancestry',
 
945
                   'bzrlib.tests.test_annotate',
1390
946
                   'bzrlib.tests.test_api',
1391
 
                   'bzrlib.tests.test_atomicfile',
1392
947
                   'bzrlib.tests.test_bad_files',
1393
948
                   'bzrlib.tests.test_branch',
1394
 
                   'bzrlib.tests.test_bundle',
1395
949
                   'bzrlib.tests.test_bzrdir',
1396
 
                   'bzrlib.tests.test_cache_utf8',
1397
950
                   'bzrlib.tests.test_command',
1398
951
                   'bzrlib.tests.test_commit',
1399
952
                   'bzrlib.tests.test_commit_merge',
1409
962
                   'bzrlib.tests.test_graph',
1410
963
                   'bzrlib.tests.test_hashcache',
1411
964
                   'bzrlib.tests.test_http',
1412
 
                   'bzrlib.tests.test_http_response',
1413
965
                   'bzrlib.tests.test_identitymap',
1414
 
                   'bzrlib.tests.test_ignores',
1415
966
                   'bzrlib.tests.test_inv',
1416
967
                   'bzrlib.tests.test_knit',
1417
 
                   'bzrlib.tests.test_lazy_import',
1418
968
                   'bzrlib.tests.test_lockdir',
1419
969
                   'bzrlib.tests.test_lockable_files',
1420
970
                   'bzrlib.tests.test_log',
1427
977
                   'bzrlib.tests.test_options',
1428
978
                   'bzrlib.tests.test_osutils',
1429
979
                   'bzrlib.tests.test_patch',
1430
 
                   'bzrlib.tests.test_patches',
1431
980
                   'bzrlib.tests.test_permissions',
1432
981
                   'bzrlib.tests.test_plugins',
1433
982
                   'bzrlib.tests.test_progress',
1434
983
                   'bzrlib.tests.test_reconcile',
1435
984
                   'bzrlib.tests.test_repository',
1436
 
                   'bzrlib.tests.test_revert',
1437
985
                   'bzrlib.tests.test_revision',
1438
986
                   'bzrlib.tests.test_revisionnamespaces',
1439
 
                   'bzrlib.tests.test_revisiontree',
 
987
                   'bzrlib.tests.test_revprops',
1440
988
                   'bzrlib.tests.test_rio',
1441
989
                   'bzrlib.tests.test_sampler',
1442
990
                   'bzrlib.tests.test_selftest',
1443
991
                   'bzrlib.tests.test_setup',
1444
992
                   'bzrlib.tests.test_sftp_transport',
1445
 
                   'bzrlib.tests.test_ftp_transport',
1446
993
                   'bzrlib.tests.test_smart_add',
1447
994
                   'bzrlib.tests.test_source',
1448
 
                   'bzrlib.tests.test_status',
1449
995
                   'bzrlib.tests.test_store',
1450
996
                   'bzrlib.tests.test_symbol_versioning',
1451
997
                   'bzrlib.tests.test_testament',
1455
1001
                   'bzrlib.tests.test_transactions',
1456
1002
                   'bzrlib.tests.test_transform',
1457
1003
                   'bzrlib.tests.test_transport',
1458
 
                   'bzrlib.tests.test_tree',
1459
1004
                   'bzrlib.tests.test_tsort',
1460
1005
                   'bzrlib.tests.test_tuned_gzip',
1461
1006
                   'bzrlib.tests.test_ui',
1462
1007
                   'bzrlib.tests.test_upgrade',
1463
 
                   'bzrlib.tests.test_urlutils',
1464
1008
                   'bzrlib.tests.test_versionedfile',
1465
 
                   'bzrlib.tests.test_version',
1466
1009
                   'bzrlib.tests.test_weave',
1467
1010
                   'bzrlib.tests.test_whitebox',
1468
1011
                   'bzrlib.tests.test_workingtree',
1469
1012
                   'bzrlib.tests.test_xml',
1470
1013
                   ]
1471
1014
    test_transport_implementations = [
1472
 
        'bzrlib.tests.test_transport_implementations',
1473
 
        'bzrlib.tests.test_read_bundle',
1474
 
        ]
1475
 
    suite = TestUtil.TestSuite()
1476
 
    loader = TestUtil.TestLoader()
1477
 
    suite.addTest(loader.loadTestsFromModuleNames(testmod_names))
 
1015
        'bzrlib.tests.test_transport_implementations']
 
1016
 
 
1017
    TestCase.BZRPATH = osutils.pathjoin(
 
1018
            osutils.realpath(osutils.dirname(bzrlib.__path__[0])), 'bzr')
 
1019
    print '%10s: %s' % ('bzr', osutils.realpath(sys.argv[0]))
 
1020
    print '%10s: %s' % ('bzrlib', bzrlib.__path__[0])
 
1021
    print
 
1022
    suite = TestSuite()
 
1023
    # python2.4's TestLoader.loadTestsFromNames gives very poor 
 
1024
    # errors if it fails to load a named module - no indication of what's
 
1025
    # actually wrong, just "no such module".  We should probably override that
 
1026
    # class, but for the moment just load them ourselves. (mbp 20051202)
 
1027
    loader = TestLoader()
1478
1028
    from bzrlib.transport import TransportTestProviderAdapter
1479
1029
    adapter = TransportTestProviderAdapter()
1480
1030
    adapt_modules(test_transport_implementations, adapter, loader, suite)
 
1031
    for mod_name in testmod_names:
 
1032
        mod = _load_module_by_name(mod_name)
 
1033
        suite.addTest(loader.loadTestsFromModule(mod))
1481
1034
    for package in packages_to_test():
1482
1035
        suite.addTest(package.test_suite())
1483
1036
    for m in MODULES_TO_TEST:
1484
1037
        suite.addTest(loader.loadTestsFromModule(m))
1485
 
    for m in MODULES_TO_DOCTEST:
1486
 
        suite.addTest(doctest.DocTestSuite(m))
 
1038
    for m in (MODULES_TO_DOCTEST):
 
1039
        suite.addTest(DocTestSuite(m))
1487
1040
    for name, plugin in bzrlib.plugin.all_plugins().items():
1488
1041
        if getattr(plugin, 'test_suite', None) is not None:
1489
1042
            suite.addTest(plugin.test_suite())
1492
1045
 
1493
1046
def adapt_modules(mods_list, adapter, loader, suite):
1494
1047
    """Adapt the modules in mods_list using adapter and add to suite."""
1495
 
    for test in iter_suite_tests(loader.loadTestsFromModuleNames(mods_list)):
1496
 
        suite.addTests(adapter.adapt(test))
 
1048
    for mod_name in mods_list:
 
1049
        mod = _load_module_by_name(mod_name)
 
1050
        for test in iter_suite_tests(loader.loadTestsFromModule(mod)):
 
1051
            suite.addTests(adapter.adapt(test))
 
1052
 
 
1053
 
 
1054
def _load_module_by_name(mod_name):
 
1055
    parts = mod_name.split('.')
 
1056
    module = __import__(mod_name)
 
1057
    del parts[0]
 
1058
    # for historical reasons python returns the top-level module even though
 
1059
    # it loads the submodule; we need to walk down to get the one we want.
 
1060
    while parts:
 
1061
        module = getattr(module, parts.pop(0))
 
1062
    return module