~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/selftest/__init__.py

  • Committer: Martin Pool
  • Date: 2005-08-29 10:57:01 UTC
  • mfrom: (1092.1.41)
  • Revision ID: mbp@sourcefrog.net-20050829105701-7aaa81ecf1bfee05
- merge in merge improvements and additional tests 
  from aaron and lifeless

robertc@robertcollins.net-20050825131100-85772edabc817481

Show diffs side-by-side

added added

removed removed

Lines of Context:
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
17
17
 
18
 
from cStringIO import StringIO
19
 
import difflib
20
 
import errno
21
18
import logging
 
19
import unittest
 
20
import tempfile
22
21
import os
23
 
import re
24
 
import shutil
25
22
import sys
26
 
import tempfile
27
 
import unittest
28
 
import time
29
 
import codecs
30
23
 
31
 
import bzrlib.branch
 
24
from testsweet import run_suite
32
25
import bzrlib.commands
33
 
from bzrlib.errors import BzrError
34
 
import bzrlib.inventory
35
 
import bzrlib.iterablefile
36
 
import bzrlib.merge3
37
 
import bzrlib.osutils
38
 
import bzrlib.osutils as osutils
39
 
import bzrlib.plugin
40
 
import bzrlib.store
 
26
 
41
27
import bzrlib.trace
42
 
from bzrlib.trace import mutter
43
 
from bzrlib.tests.TestUtil import TestLoader, TestSuite
44
 
from bzrlib.tests.treeshape import build_tree_contents
 
28
import bzrlib.fetch
45
29
 
46
30
MODULES_TO_TEST = []
47
 
MODULES_TO_DOCTEST = [
48
 
                      bzrlib.branch,
49
 
                      bzrlib.commands,
50
 
                      bzrlib.errors,
51
 
                      bzrlib.inventory,
52
 
                      bzrlib.iterablefile,
53
 
                      bzrlib.merge3,
54
 
                      bzrlib.osutils,
55
 
                      bzrlib.store,
56
 
                      ]
57
 
def packages_to_test():
58
 
    import bzrlib.tests.blackbox
59
 
    return [
60
 
            bzrlib.tests.blackbox
61
 
            ]
62
 
 
63
 
 
64
 
class EarlyStoppingTestResultAdapter(object):
65
 
    """An adapter for TestResult to stop at the first first failure or error"""
66
 
 
67
 
    def __init__(self, result):
68
 
        self._result = result
69
 
 
70
 
    def addError(self, test, err):
71
 
        self._result.addError(test, err)
72
 
        self._result.stop()
73
 
 
74
 
    def addFailure(self, test, err):
75
 
        self._result.addFailure(test, err)
76
 
        self._result.stop()
77
 
 
78
 
    def __getattr__(self, name):
79
 
        return getattr(self._result, name)
80
 
 
81
 
    def __setattr__(self, name, value):
82
 
        if name == '_result':
83
 
            object.__setattr__(self, name, value)
84
 
        return setattr(self._result, name, value)
85
 
 
86
 
 
87
 
class _MyResult(unittest._TextTestResult):
88
 
    """Custom TestResult.
89
 
 
90
 
    Shows output in a different format, including displaying runtime for tests.
91
 
    """
92
 
 
93
 
    def _elapsedTime(self):
94
 
        return "%5dms" % (1000 * (time.time() - self._start_time))
95
 
 
96
 
    def startTest(self, test):
97
 
        unittest.TestResult.startTest(self, test)
98
 
        # In a short description, the important words are in
99
 
        # the beginning, but in an id, the important words are
100
 
        # at the end
101
 
        SHOW_DESCRIPTIONS = False
102
 
        if self.showAll:
103
 
            width = osutils.terminal_width()
104
 
            name_width = width - 15
105
 
            what = None
106
 
            if SHOW_DESCRIPTIONS:
107
 
                what = test.shortDescription()
108
 
                if what:
109
 
                    if len(what) > name_width:
110
 
                        what = what[:name_width-3] + '...'
111
 
            if what is None:
112
 
                what = test.id()
113
 
                if what.startswith('bzrlib.tests.'):
114
 
                    what = what[13:]
115
 
                if len(what) > name_width:
116
 
                    what = '...' + what[3-name_width:]
117
 
            what = what.ljust(name_width)
118
 
            self.stream.write(what)
119
 
        self.stream.flush()
120
 
        self._start_time = time.time()
121
 
 
122
 
    def addError(self, test, err):
123
 
        if isinstance(err[1], TestSkipped):
124
 
            return self.addSkipped(test, err)    
125
 
        unittest.TestResult.addError(self, test, err)
126
 
        if self.showAll:
127
 
            self.stream.writeln("ERROR %s" % self._elapsedTime())
128
 
        elif self.dots:
129
 
            self.stream.write('E')
130
 
        self.stream.flush()
131
 
 
132
 
    def addFailure(self, test, err):
133
 
        unittest.TestResult.addFailure(self, test, err)
134
 
        if self.showAll:
135
 
            self.stream.writeln(" FAIL %s" % self._elapsedTime())
136
 
        elif self.dots:
137
 
            self.stream.write('F')
138
 
        self.stream.flush()
139
 
 
140
 
    def addSuccess(self, test):
141
 
        if self.showAll:
142
 
            self.stream.writeln('   OK %s' % self._elapsedTime())
143
 
        elif self.dots:
144
 
            self.stream.write('~')
145
 
        self.stream.flush()
146
 
        unittest.TestResult.addSuccess(self, test)
147
 
 
148
 
    def addSkipped(self, test, skip_excinfo):
149
 
        if self.showAll:
150
 
            print >>self.stream, ' SKIP %s' % self._elapsedTime()
151
 
            print >>self.stream, '     %s' % skip_excinfo[1]
152
 
        elif self.dots:
153
 
            self.stream.write('S')
154
 
        self.stream.flush()
155
 
        # seems best to treat this as success from point-of-view of unittest
156
 
        # -- it actually does nothing so it barely matters :)
157
 
        unittest.TestResult.addSuccess(self, test)
158
 
 
159
 
    def printErrorList(self, flavour, errors):
160
 
        for test, err in errors:
161
 
            self.stream.writeln(self.separator1)
162
 
            self.stream.writeln("%s: %s" % (flavour,self.getDescription(test)))
163
 
            if hasattr(test, '_get_log'):
164
 
                print >>self.stream
165
 
                print >>self.stream, \
166
 
                        ('vvvv[log from %s]' % test).ljust(78,'-')
167
 
                print >>self.stream, test._get_log()
168
 
                print >>self.stream, \
169
 
                        ('^^^^[log from %s]' % test).ljust(78,'-')
170
 
            self.stream.writeln(self.separator2)
171
 
            self.stream.writeln("%s" % err)
172
 
 
173
 
 
174
 
class TextTestRunner(unittest.TextTestRunner):
175
 
    stop_on_failure = False
176
 
 
177
 
    def _makeResult(self):
178
 
        result = _MyResult(self.stream, self.descriptions, self.verbosity)
179
 
        if self.stop_on_failure:
180
 
            result = EarlyStoppingTestResultAdapter(result)
181
 
        return result
182
 
 
183
 
 
184
 
def iter_suite_tests(suite):
185
 
    """Return all tests in a suite, recursing through nested suites"""
186
 
    for item in suite._tests:
187
 
        if isinstance(item, unittest.TestCase):
188
 
            yield item
189
 
        elif isinstance(item, unittest.TestSuite):
190
 
            for r in iter_suite_tests(item):
191
 
                yield r
192
 
        else:
193
 
            raise Exception('unknown object %r inside test suite %r'
194
 
                            % (item, suite))
195
 
 
196
 
 
197
 
class TestSkipped(Exception):
198
 
    """Indicates that a test was intentionally skipped, rather than failing."""
199
 
    # XXX: Not used yet
200
 
 
201
 
 
202
 
class CommandFailed(Exception):
203
 
    pass
 
31
MODULES_TO_DOCTEST = []
 
32
 
 
33
from logging import debug, warning, error
 
34
 
204
35
 
205
36
class TestCase(unittest.TestCase):
206
37
    """Base class for bzr unit tests.
207
38
    
208
39
    Tests that need access to disk resources should subclass 
209
 
    TestCaseInTempDir not TestCase.
 
40
    FunctionalTestCase not TestCase.
210
41
 
211
42
    Error and debug log messages are redirected from their usual
212
43
    location into a temporary file, the contents of which can be
213
 
    retrieved by _get_log().  We use a real OS file, not an in-memory object,
214
 
    so that it can also capture file IO.  When the test completes this file
215
 
    is read into memory and removed from disk.
 
44
    retrieved by _get_log().
216
45
       
217
46
    There are also convenience functions to invoke bzr's command-line
218
 
    routine, and to build and check bzr trees.
219
 
   
220
 
    In addition to the usual method of overriding tearDown(), this class also
221
 
    allows subclasses to register functions into the _cleanups list, which is
222
 
    run in order as the object is torn down.  It's less likely this will be
223
 
    accidentally overlooked.
224
 
    """
 
47
    routine, and to build and check bzr trees."""
225
48
 
226
49
    BZRPATH = 'bzr'
227
 
    _log_file_name = None
228
 
    _log_contents = ''
229
50
 
230
51
    def setUp(self):
 
52
        # this replaces the default testsweet.TestCase; we don't want logging changed
231
53
        unittest.TestCase.setUp(self)
232
 
        self._cleanups = []
233
 
        self._cleanEnvironment()
234
54
        bzrlib.trace.disable_default_logging()
235
 
        self._startLogFile()
236
 
 
237
 
    def _ndiff_strings(self, a, b):
238
 
        """Return ndiff between two strings containing lines.
239
 
        
240
 
        A trailing newline is added if missing to make the strings
241
 
        print properly."""
242
 
        if b and b[-1] != '\n':
243
 
            b += '\n'
244
 
        if a and a[-1] != '\n':
245
 
            a += '\n'
246
 
        difflines = difflib.ndiff(a.splitlines(True),
247
 
                                  b.splitlines(True),
248
 
                                  linejunk=lambda x: False,
249
 
                                  charjunk=lambda x: False)
250
 
        return ''.join(difflines)
251
 
 
252
 
    def assertEqualDiff(self, a, b):
253
 
        """Assert two texts are equal, if not raise an exception.
254
 
        
255
 
        This is intended for use with multi-line strings where it can 
256
 
        be hard to find the differences by eye.
257
 
        """
258
 
        # TODO: perhaps override assertEquals to call this for strings?
259
 
        if a == b:
260
 
            return
261
 
        raise AssertionError("texts not equal:\n" + 
262
 
                             self._ndiff_strings(a, b))      
263
 
        
264
 
    def assertStartsWith(self, s, prefix):
265
 
        if not s.startswith(prefix):
266
 
            raise AssertionError('string %r does not start with %r' % (s, prefix))
267
 
 
268
 
    def assertEndsWith(self, s, suffix):
269
 
        if not s.endswith(prefix):
270
 
            raise AssertionError('string %r does not end with %r' % (s, suffix))
271
 
 
272
 
    def assertContainsRe(self, haystack, needle_re):
273
 
        """Assert that a contains something matching a regular expression."""
274
 
        if not re.search(needle_re, haystack):
275
 
            raise AssertionError('pattern "%s" not found in "%s"'
276
 
                    % (needle_re, haystack))
277
 
 
278
 
    def AssertSubset(self, sublist, superlist):
279
 
        """Assert that every entry in sublist is present in superlist."""
280
 
        missing = []
281
 
        for entry in sublist:
282
 
            if entry not in superlist:
283
 
                missing.append(entry)
284
 
        if len(missing) > 0:
285
 
            raise AssertionError("value(s) %r not present in container %r" % 
286
 
                                 (missing, superlist))
287
 
 
288
 
    def assertIs(self, left, right):
289
 
        if not (left is right):
290
 
            raise AssertionError("%r is not %r." % (left, right))
291
 
 
292
 
    def _startLogFile(self):
293
 
        """Send bzr and test log messages to a temporary file.
294
 
 
295
 
        The file is removed as the test is torn down.
296
 
        """
 
55
        self._enable_file_logging()
 
56
 
 
57
 
 
58
    def _enable_file_logging(self):
297
59
        fileno, name = tempfile.mkstemp(suffix='.log', prefix='testbzr')
298
 
        encoder, decoder, stream_reader, stream_writer = codecs.lookup('UTF-8')
299
 
        self._log_file = stream_writer(os.fdopen(fileno, 'w+'))
300
 
        bzrlib.trace.enable_test_log(self._log_file)
 
60
 
 
61
        self._log_file = os.fdopen(fileno, 'w+')
 
62
 
 
63
        hdlr = logging.StreamHandler(self._log_file)
 
64
        hdlr.setLevel(logging.DEBUG)
 
65
        hdlr.setFormatter(logging.Formatter('%(levelname)4.4s  %(message)s'))
 
66
        logging.getLogger('').addHandler(hdlr)
 
67
        logging.getLogger('').setLevel(logging.DEBUG)
 
68
        self._log_hdlr = hdlr
 
69
        debug('opened log file %s', name)
 
70
        
301
71
        self._log_file_name = name
302
 
        self.addCleanup(self._finishLogFile)
303
 
 
304
 
    def _finishLogFile(self):
305
 
        """Finished with the log file.
306
 
 
307
 
        Read contents into memory, close, and delete.
308
 
        """
309
 
        bzrlib.trace.disable_test_log()
310
 
        self._log_file.seek(0)
311
 
        self._log_contents = self._log_file.read()
 
72
 
 
73
        
 
74
    def tearDown(self):
 
75
        logging.getLogger('').removeHandler(self._log_hdlr)
 
76
        bzrlib.trace.enable_default_logging()
 
77
        logging.debug('%s teardown', self.id())
312
78
        self._log_file.close()
313
 
        os.remove(self._log_file_name)
314
 
        self._log_file = self._log_file_name = None
315
 
 
316
 
    def addCleanup(self, callable):
317
 
        """Arrange to run a callable when this case is torn down.
318
 
 
319
 
        Callables are run in the reverse of the order they are registered, 
320
 
        ie last-in first-out.
321
 
        """
322
 
        if callable in self._cleanups:
323
 
            raise ValueError("cleanup function %r already registered on %s" 
324
 
                    % (callable, self))
325
 
        self._cleanups.append(callable)
326
 
 
327
 
    def _cleanEnvironment(self):
328
 
        new_env = {
329
 
            'HOME': os.getcwd(),
330
 
            'APPDATA': os.getcwd(),
331
 
            'BZREMAIL': None,
332
 
            'EMAIL': None,
333
 
        }
334
 
        self.__old_env = {}
335
 
        self.addCleanup(self._restoreEnvironment)
336
 
        for name, value in new_env.iteritems():
337
 
            self._captureVar(name, value)
338
 
 
339
 
 
340
 
    def _captureVar(self, name, newvalue):
341
 
        """Set an environment variable, preparing it to be reset when finished."""
342
 
        self.__old_env[name] = os.environ.get(name, None)
343
 
        if newvalue is None:
344
 
            if name in os.environ:
345
 
                del os.environ[name]
346
 
        else:
347
 
            os.environ[name] = newvalue
348
 
 
349
 
    @staticmethod
350
 
    def _restoreVar(name, value):
351
 
        if value is None:
352
 
            if name in os.environ:
353
 
                del os.environ[name]
354
 
        else:
355
 
            os.environ[name] = value
356
 
 
357
 
    def _restoreEnvironment(self):
358
 
        for name, value in self.__old_env.iteritems():
359
 
            self._restoreVar(name, value)
360
 
 
361
 
    def tearDown(self):
362
 
        self._runCleanups()
363
79
        unittest.TestCase.tearDown(self)
364
80
 
365
 
    def _runCleanups(self):
366
 
        """Run registered cleanup functions. 
367
 
 
368
 
        This should only be called from TestCase.tearDown.
369
 
        """
370
 
        for cleanup_fn in reversed(self._cleanups):
371
 
            cleanup_fn()
372
81
 
373
82
    def log(self, *args):
374
 
        mutter(*args)
 
83
        logging.debug(*args)
375
84
 
376
85
    def _get_log(self):
377
86
        """Return as a string the log for this test"""
378
 
        if self._log_file_name:
379
 
            return open(self._log_file_name).read()
380
 
        else:
381
 
            return self._log_contents
382
 
        # TODO: Delete the log after it's been read in
383
 
 
384
 
    def capture(self, cmd, retcode=0):
385
 
        """Shortcut that splits cmd into words, runs, and returns stdout"""
386
 
        return self.run_bzr_captured(cmd.split(), retcode=retcode)[0]
387
 
 
388
 
    def run_bzr_captured(self, argv, retcode=0):
389
 
        """Invoke bzr and return (stdout, stderr).
390
 
 
391
 
        Useful for code that wants to check the contents of the
392
 
        output, the way error messages are presented, etc.
 
87
        return open(self._log_file_name).read()
 
88
 
 
89
    def run_bzr(self, *args, **kwargs):
 
90
        """Invoke bzr, as if it were run from the command line.
393
91
 
394
92
        This should be the main method for tests that want to exercise the
395
93
        overall behavior of the bzr application (rather than a unit test
397
95
 
398
96
        Much of the old code runs bzr by forking a new copy of Python, but
399
97
        that is slower, harder to debug, and generally not necessary.
400
 
 
401
 
        This runs bzr through the interface that catches and reports
402
 
        errors, and with logging set to something approximating the
403
 
        default, so that error reporting can be checked.
404
 
 
405
 
        argv -- arguments to invoke bzr
406
 
        retcode -- expected return code, or None for don't-care.
407
 
        """
408
 
        stdout = StringIO()
409
 
        stderr = StringIO()
410
 
        self.log('run bzr: %s', ' '.join(argv))
411
 
        # FIXME: don't call into logging here
412
 
        handler = logging.StreamHandler(stderr)
413
 
        handler.setFormatter(bzrlib.trace.QuietFormatter())
414
 
        handler.setLevel(logging.INFO)
415
 
        logger = logging.getLogger('')
416
 
        logger.addHandler(handler)
417
 
        try:
418
 
            result = self.apply_redirected(None, stdout, stderr,
419
 
                                           bzrlib.commands.run_bzr_catch_errors,
420
 
                                           argv)
421
 
        finally:
422
 
            logger.removeHandler(handler)
423
 
        out = stdout.getvalue()
424
 
        err = stderr.getvalue()
425
 
        if out:
426
 
            self.log('output:\n%s', out)
427
 
        if err:
428
 
            self.log('errors:\n%s', err)
429
 
        if retcode is not None:
430
 
            self.assertEquals(result, retcode)
431
 
        return out, err
432
 
 
433
 
    def run_bzr(self, *args, **kwargs):
434
 
        """Invoke bzr, as if it were run from the command line.
435
 
 
436
 
        This should be the main method for tests that want to exercise the
437
 
        overall behavior of the bzr application (rather than a unit test
438
 
        or a functional test of the library.)
439
 
 
440
 
        This sends the stdout/stderr results into the test's log,
441
 
        where it may be useful for debugging.  See also run_captured.
442
 
        """
443
 
        retcode = kwargs.pop('retcode', 0)
444
 
        return self.run_bzr_captured(args, retcode)
445
 
 
 
98
        """
 
99
        retcode = kwargs.get('retcode', 0)
 
100
        result = self.apply_redirected(None, None, None,
 
101
                                       bzrlib.commands.run_bzr, args)
 
102
        self.assertEquals(result, retcode)
 
103
        
446
104
    def check_inventory_shape(self, inv, shape):
447
 
        """Compare an inventory to a list of expected names.
 
105
        """
 
106
        Compare an inventory to a list of expected names.
448
107
 
449
108
        Fail if they are not precisely equal.
450
109
        """
463
122
        if extras:
464
123
            self.fail("unexpected paths found in inventory: %r" % extras)
465
124
 
466
 
    def apply_redirected(self, stdin=None, stdout=None, stderr=None,
467
 
                         a_callable=None, *args, **kwargs):
468
 
        """Call callable with redirected std io pipes.
469
 
 
470
 
        Returns the return code."""
471
 
        if not callable(a_callable):
472
 
            raise ValueError("a_callable must be callable.")
473
 
        if stdin is None:
474
 
            stdin = StringIO("")
475
 
        if stdout is None:
476
 
            if hasattr(self, "_log_file"):
477
 
                stdout = self._log_file
478
 
            else:
479
 
                stdout = StringIO()
480
 
        if stderr is None:
481
 
            if hasattr(self, "_log_file"):
482
 
                stderr = self._log_file
483
 
            else:
484
 
                stderr = StringIO()
485
 
        real_stdin = sys.stdin
486
 
        real_stdout = sys.stdout
487
 
        real_stderr = sys.stderr
488
 
        try:
489
 
            sys.stdout = stdout
490
 
            sys.stderr = stderr
491
 
            sys.stdin = stdin
492
 
            return a_callable(*args, **kwargs)
493
 
        finally:
494
 
            sys.stdout = real_stdout
495
 
            sys.stderr = real_stderr
496
 
            sys.stdin = real_stdin
497
 
 
498
 
 
499
125
BzrTestBase = TestCase
500
126
 
501
127
     
502
 
class TestCaseInTempDir(TestCase):
503
 
    """Derived class that runs a test within a temporary directory.
504
 
 
505
 
    This is useful for tests that need to create a branch, etc.
506
 
 
507
 
    The directory is created in a slightly complex way: for each
508
 
    Python invocation, a new temporary top-level directory is created.
509
 
    All test cases create their own directory within that.  If the
510
 
    tests complete successfully, the directory is removed.
 
128
class FunctionalTestCase(TestCase):
 
129
    """Base class for tests that perform function testing - running bzr,
 
130
    using files on disk, and similar activities.
511
131
 
512
132
    InTempDir is an old alias for FunctionalTestCase.
513
133
    """
522
142
        if contents != expect:
523
143
            self.log("expected: %r" % expect)
524
144
            self.log("actually: %r" % contents)
525
 
            self.fail("contents of %s not as expected" % filename)
 
145
            self.fail("contents of %s not as expected")
526
146
 
527
147
    def _make_test_root(self):
528
 
        if TestCaseInTempDir.TEST_ROOT is not None:
 
148
        import os
 
149
        import shutil
 
150
        import tempfile
 
151
        
 
152
        if FunctionalTestCase.TEST_ROOT is not None:
529
153
            return
530
 
        i = 0
531
 
        while True:
532
 
            root = u'test%04d.tmp' % i
533
 
            try:
534
 
                os.mkdir(root)
535
 
            except OSError, e:
536
 
                if e.errno == errno.EEXIST:
537
 
                    i += 1
538
 
                    continue
539
 
                else:
540
 
                    raise
541
 
            # successfully created
542
 
            TestCaseInTempDir.TEST_ROOT = osutils.abspath(root)
543
 
            break
 
154
        FunctionalTestCase.TEST_ROOT = os.path.abspath(
 
155
                                 tempfile.mkdtemp(suffix='.tmp',
 
156
                                                  prefix=self._TEST_NAME + '-',
 
157
                                                  dir=os.curdir))
 
158
    
544
159
        # make a fake bzr directory there to prevent any tests propagating
545
160
        # up onto the source directory's real branch
546
 
        os.mkdir(osutils.pathjoin(TestCaseInTempDir.TEST_ROOT, '.bzr'))
 
161
        os.mkdir(os.path.join(FunctionalTestCase.TEST_ROOT, '.bzr'))
547
162
 
548
163
    def setUp(self):
549
 
        super(TestCaseInTempDir, self).setUp()
 
164
        super(FunctionalTestCase, self).setUp()
 
165
        import os
550
166
        self._make_test_root()
551
 
        _currentdir = os.getcwdu()
552
 
        short_id = self.id().replace('bzrlib.tests.', '') \
553
 
                   .replace('__main__.', '')
554
 
        self.test_dir = osutils.pathjoin(self.TEST_ROOT, short_id)
 
167
        self._currentdir = os.getcwdu()
 
168
        self.test_dir = os.path.join(self.TEST_ROOT, self.id())
555
169
        os.mkdir(self.test_dir)
556
170
        os.chdir(self.test_dir)
557
 
        os.environ['HOME'] = self.test_dir
558
 
        os.environ['APPDATA'] = self.test_dir
559
 
        def _leaveDirectory():
560
 
            os.chdir(_currentdir)
561
 
        self.addCleanup(_leaveDirectory)
562
171
        
563
 
    def build_tree(self, shape, line_endings='native'):
 
172
    def tearDown(self):
 
173
        import os
 
174
        os.chdir(self._currentdir)
 
175
        super(FunctionalTestCase, self).tearDown()
 
176
 
 
177
    def _formcmd(self, cmd):
 
178
        if isinstance(cmd, basestring):
 
179
            cmd = cmd.split()
 
180
        if cmd[0] == 'bzr':
 
181
            cmd[0] = self.BZRPATH
 
182
            if self.OVERRIDE_PYTHON:
 
183
                cmd.insert(0, self.OVERRIDE_PYTHON)
 
184
        self.log('$ %r' % cmd)
 
185
        return cmd
 
186
 
 
187
    def runcmd(self, cmd, retcode=0):
 
188
        """Run one command and check the return code.
 
189
 
 
190
        Returns a tuple of (stdout,stderr) strings.
 
191
 
 
192
        If a single string is based, it is split into words.
 
193
        For commands that are not simple space-separated words, please
 
194
        pass a list instead."""
 
195
        try:
 
196
            import shutil
 
197
            from subprocess import call
 
198
        except ImportError, e:
 
199
            _need_subprocess()
 
200
            raise
 
201
        cmd = self._formcmd(cmd)
 
202
        self.log('$ ' + ' '.join(cmd))
 
203
        actual_retcode = call(cmd, stdout=self._log_file, stderr=self._log_file)
 
204
        if retcode != actual_retcode:
 
205
            raise CommandFailed("test failed: %r returned %d, expected %d"
 
206
                                % (cmd, actual_retcode, retcode))
 
207
 
 
208
    def backtick(self, cmd, retcode=0):
 
209
        """Run a command and return its output"""
 
210
        try:
 
211
            import shutil
 
212
            from subprocess import Popen, PIPE
 
213
        except ImportError, e:
 
214
            _need_subprocess()
 
215
            raise
 
216
 
 
217
        cmd = self._formcmd(cmd)
 
218
        child = Popen(cmd, stdout=PIPE, stderr=self._log_file)
 
219
        outd, errd = child.communicate()
 
220
        self.log(outd)
 
221
        actual_retcode = child.wait()
 
222
 
 
223
        outd = outd.replace('\r', '')
 
224
 
 
225
        if retcode != actual_retcode:
 
226
            raise CommandFailed("test failed: %r returned %d, expected %d"
 
227
                                % (cmd, actual_retcode, retcode))
 
228
 
 
229
        return outd
 
230
 
 
231
 
 
232
 
 
233
    def build_tree(self, shape):
564
234
        """Build a test tree according to a pattern.
565
235
 
566
236
        shape is a sequence of file specifications.  If the final
567
237
        character is '/', a directory is created.
568
238
 
569
239
        This doesn't add anything to a branch.
570
 
        :param line_endings: Either 'binary' or 'native'
571
 
                             in binary mode, exact contents are written
572
 
                             in native mode, the line endings match the
573
 
                             default platform endings.
574
240
        """
575
241
        # XXX: It's OK to just create them using forward slashes on windows?
 
242
        import os
576
243
        for name in shape:
577
 
            self.assert_(isinstance(name, basestring))
 
244
            assert isinstance(name, basestring)
578
245
            if name[-1] == '/':
579
246
                os.mkdir(name[:-1])
580
247
            else:
581
 
                if line_endings == 'binary':
582
 
                    f = file(name, 'wb')
583
 
                elif line_endings == 'native':
584
 
                    f = file(name, 'wt')
585
 
                else:
586
 
                    raise BzrError('Invalid line ending request %r' % (line_endings,))
 
248
                f = file(name, 'wt')
587
249
                print >>f, "contents of", name
588
250
                f.close()
589
 
 
590
 
    def build_tree_contents(self, shape):
591
 
        build_tree_contents(shape)
592
 
 
593
 
    def failUnlessExists(self, path):
594
 
        """Fail unless path, which may be abs or relative, exists."""
595
 
        self.failUnless(osutils.lexists(path))
596
 
 
597
 
    def failIfExists(self, path):
598
 
        """Fail if path, which may be abs or relative, exists."""
599
 
        self.failIf(osutils.lexists(path))
600
 
        
601
 
    def assertFileEqual(self, content, path):
602
 
        """Fail if path does not contain 'content'."""
603
 
        self.failUnless(osutils.lexists(path))
604
 
        self.assertEqualDiff(content, open(path, 'r').read())
605
 
 
606
 
 
607
 
def filter_suite_by_re(suite, pattern):
608
 
    result = TestSuite()
609
 
    filter_re = re.compile(pattern)
610
 
    for test in iter_suite_tests(suite):
611
 
        if filter_re.search(test.id()):
612
 
            result.addTest(test)
613
 
    return result
614
 
 
615
 
 
616
 
def run_suite(suite, name='test', verbose=False, pattern=".*",
617
 
              stop_on_failure=False, keep_output=False):
618
 
    TestCaseInTempDir._TEST_NAME = name
619
 
    if verbose:
620
 
        verbosity = 2
621
 
    else:
622
 
        verbosity = 1
623
 
    runner = TextTestRunner(stream=sys.stdout,
624
 
                            descriptions=0,
625
 
                            verbosity=verbosity)
626
 
    runner.stop_on_failure=stop_on_failure
627
 
    if pattern != '.*':
628
 
        suite = filter_suite_by_re(suite, pattern)
629
 
    result = runner.run(suite)
630
 
    # This is still a little bogus, 
631
 
    # but only a little. Folk not using our testrunner will
632
 
    # have to delete their temp directories themselves.
633
 
    if result.wasSuccessful() or not keep_output:
634
 
        if TestCaseInTempDir.TEST_ROOT is not None:
635
 
            shutil.rmtree(TestCaseInTempDir.TEST_ROOT) 
636
 
    else:
637
 
        print "Failed tests working directories are in '%s'\n" % TestCaseInTempDir.TEST_ROOT
638
 
    return result.wasSuccessful()
639
 
 
640
 
 
641
 
def selftest(verbose=False, pattern=".*", stop_on_failure=True,
642
 
             keep_output=False):
643
 
    """Run the whole test suite under the enhanced runner"""
644
 
    return run_suite(test_suite(), 'testbzr', verbose=verbose, pattern=pattern,
645
 
                     stop_on_failure=stop_on_failure, keep_output=keep_output)
 
251
                
 
252
 
 
253
    def apply_redirected(self, stdin=None, stdout=None, stderr=None,
 
254
                         a_callable=None, *args, **kwargs):
 
255
        """Call callable with redirected std io pipes.
 
256
 
 
257
        Returns the return code."""
 
258
        from StringIO import StringIO
 
259
        if not callable(a_callable):
 
260
            raise ValueError("a_callable must be callable.")
 
261
        if stdin is None:
 
262
            stdin = StringIO("")
 
263
        if stdout is None:
 
264
            stdout = self._log_file
 
265
        if stderr is None:
 
266
            stderr = self._log_file
 
267
        real_stdin = sys.stdin
 
268
        real_stdout = sys.stdout
 
269
        real_stderr = sys.stderr
 
270
        result = None
 
271
        try:
 
272
            sys.stdout = stdout
 
273
            sys.stderr = stderr
 
274
            sys.stdin = stdin
 
275
            result = a_callable(*args, **kwargs)
 
276
        finally:
 
277
            sys.stdout = real_stdout
 
278
            sys.stderr = real_stderr
 
279
            sys.stdin = real_stdin
 
280
        return result
 
281
 
 
282
 
 
283
InTempDir = FunctionalTestCase
 
284
 
 
285
 
 
286
class MetaTestLog(TestCase):
 
287
    def test_logging(self):
 
288
        """Test logs are captured when a test fails."""
 
289
        logging.info('an info message')
 
290
        warning('something looks dodgy...')
 
291
        logging.debug('hello, test is running')
 
292
        ##assert 0
 
293
 
 
294
 
 
295
def selftest(verbose=False, pattern=".*"):
 
296
    return run_suite(test_suite(), 'testbzr', verbose=verbose, pattern=pattern)
646
297
 
647
298
 
648
299
def test_suite():
649
 
    """Build and return TestSuite for the whole program."""
 
300
    from bzrlib.selftest.TestUtil import TestLoader, TestSuite
 
301
    import bzrlib, bzrlib.store, bzrlib.inventory, bzrlib.branch
 
302
    import bzrlib.osutils, bzrlib.commands, bzrlib.merge3, bzrlib.plugin
650
303
    from doctest import DocTestSuite
651
 
 
652
 
    global MODULES_TO_DOCTEST
653
 
 
654
 
    testmod_names = [ \
655
 
                   'bzrlib.tests.test_ancestry',
656
 
                   'bzrlib.tests.test_annotate',
657
 
                   'bzrlib.tests.test_api',
658
 
                   'bzrlib.tests.test_bad_files',
659
 
                   'bzrlib.tests.test_basis_inventory',
660
 
                   'bzrlib.tests.test_branch',
661
 
                   'bzrlib.tests.test_command',
662
 
                   'bzrlib.tests.test_commit',
663
 
                   'bzrlib.tests.test_commit_merge',
664
 
                   'bzrlib.tests.test_config',
665
 
                   'bzrlib.tests.test_conflicts',
666
 
                   'bzrlib.tests.test_diff',
667
 
                   'bzrlib.tests.test_fetch',
668
 
                   'bzrlib.tests.test_gpg',
669
 
                   'bzrlib.tests.test_graph',
670
 
                   'bzrlib.tests.test_hashcache',
671
 
                   'bzrlib.tests.test_http',
672
 
                   'bzrlib.tests.test_identitymap',
673
 
                   'bzrlib.tests.test_inv',
674
 
                   'bzrlib.tests.test_lockable_files',
675
 
                   'bzrlib.tests.test_log',
676
 
                   'bzrlib.tests.test_merge',
677
 
                   'bzrlib.tests.test_merge3',
678
 
                   'bzrlib.tests.test_merge_core',
679
 
                   'bzrlib.tests.test_missing',
680
 
                   'bzrlib.tests.test_msgeditor',
681
 
                   'bzrlib.tests.test_nonascii',
682
 
                   'bzrlib.tests.test_options',
683
 
                   'bzrlib.tests.test_osutils',
684
 
                   'bzrlib.tests.test_parent',
685
 
                   'bzrlib.tests.test_permissions',
686
 
                   'bzrlib.tests.test_plugins',
687
 
                   'bzrlib.tests.test_remove',
688
 
                   'bzrlib.tests.test_revision',
689
 
                   'bzrlib.tests.test_revisionnamespaces',
690
 
                   'bzrlib.tests.test_revprops',
691
 
                   'bzrlib.tests.test_reweave',
692
 
                   'bzrlib.tests.test_rio',
693
 
                   'bzrlib.tests.test_sampler',
694
 
                   'bzrlib.tests.test_selftest',
695
 
                   'bzrlib.tests.test_setup',
696
 
                   'bzrlib.tests.test_sftp_transport',
697
 
                   'bzrlib.tests.test_smart_add',
698
 
                   'bzrlib.tests.test_source',
699
 
                   'bzrlib.tests.test_status',
700
 
                   'bzrlib.tests.test_store',
701
 
                   'bzrlib.tests.test_testament',
702
 
                   'bzrlib.tests.test_trace',
703
 
                   'bzrlib.tests.test_transactions',
704
 
                   'bzrlib.tests.test_transport',
705
 
                   'bzrlib.tests.test_tsort',
706
 
                   'bzrlib.tests.test_ui',
707
 
                   'bzrlib.tests.test_uncommit',
708
 
                   'bzrlib.tests.test_upgrade',
709
 
                   'bzrlib.tests.test_weave',
710
 
                   'bzrlib.tests.test_whitebox',
711
 
                   'bzrlib.tests.test_workingtree',
712
 
                   'bzrlib.tests.test_xml',
 
304
    import os
 
305
    import shutil
 
306
    import time
 
307
    import sys
 
308
 
 
309
    global MODULES_TO_TEST, MODULES_TO_DOCTEST
 
310
 
 
311
    testmod_names = \
 
312
                  ['bzrlib.selftest.MetaTestLog',
 
313
                   'bzrlib.selftest.testinv',
 
314
                   'bzrlib.selftest.testfetch',
 
315
                   'bzrlib.selftest.versioning',
 
316
                   'bzrlib.selftest.whitebox',
 
317
                   'bzrlib.selftest.testmerge3',
 
318
                   'bzrlib.selftest.testhashcache',
 
319
                   'bzrlib.selftest.teststatus',
 
320
                   'bzrlib.selftest.testlog',
 
321
                   'bzrlib.selftest.blackbox',
 
322
                   'bzrlib.selftest.testrevisionnamespaces',
 
323
                   'bzrlib.selftest.testbranch',
 
324
                   'bzrlib.selftest.testrevision',
 
325
                   'bzrlib.selftest.test_merge_core',
 
326
                   'bzrlib.selftest.test_smart_add',
 
327
                   'bzrlib.selftest.testdiff',
 
328
                   'bzrlib.fetch'
713
329
                   ]
714
330
 
715
 
    TestCase.BZRPATH = osutils.pathjoin(
716
 
            osutils.realpath(osutils.dirname(bzrlib.__path__[0])), 'bzr')
717
 
    print '%10s: %s' % ('bzr', osutils.realpath(sys.argv[0]))
718
 
    print '%10s: %s' % ('bzrlib', bzrlib.__path__[0])
 
331
    for m in (bzrlib.store, bzrlib.inventory, bzrlib.branch,
 
332
              bzrlib.osutils, bzrlib.commands, bzrlib.merge3):
 
333
        if m not in MODULES_TO_DOCTEST:
 
334
            MODULES_TO_DOCTEST.append(m)
 
335
 
 
336
    TestCase.BZRPATH = os.path.join(os.path.realpath(os.path.dirname(bzrlib.__path__[0])), 'bzr')
 
337
    print '%-30s %s' % ('bzr binary', TestCase.BZRPATH)
719
338
    print
720
339
    suite = TestSuite()
721
 
    # python2.4's TestLoader.loadTestsFromNames gives very poor 
722
 
    # errors if it fails to load a named module - no indication of what's
723
 
    # actually wrong, just "no such module".  We should probably override that
724
 
    # class, but for the moment just load them ourselves. (mbp 20051202)
725
 
    loader = TestLoader()
726
 
    for mod_name in testmod_names:
727
 
        mod = _load_module_by_name(mod_name)
728
 
        suite.addTest(loader.loadTestsFromModule(mod))
729
 
    for package in packages_to_test():
730
 
        suite.addTest(package.test_suite())
 
340
    suite.addTest(TestLoader().loadTestsFromNames(testmod_names))
731
341
    for m in MODULES_TO_TEST:
732
 
        suite.addTest(loader.loadTestsFromModule(m))
 
342
         suite.addTest(TestLoader().loadTestsFromModule(m))
733
343
    for m in (MODULES_TO_DOCTEST):
734
344
        suite.addTest(DocTestSuite(m))
735
 
    for name, plugin in bzrlib.plugin.all_plugins().items():
736
 
        if hasattr(plugin, 'test_suite'):
737
 
            suite.addTest(plugin.test_suite())
 
345
    for p in bzrlib.plugin.all_plugins:
 
346
        if hasattr(p, 'test_suite'):
 
347
            suite.addTest(p.test_suite())
738
348
    return suite
739
349
 
740
 
 
741
 
def _load_module_by_name(mod_name):
742
 
    parts = mod_name.split('.')
743
 
    module = __import__(mod_name)
744
 
    del parts[0]
745
 
    # for historical reasons python returns the top-level module even though
746
 
    # it loads the submodule; we need to walk down to get the one we want.
747
 
    while parts:
748
 
        module = getattr(module, parts.pop(0))
749
 
    return module