/brz/remove-bazaar

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

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: Robert Collins
  • Date: 2010-05-06 11:08:10 UTC
  • mto: This revision was merged to the branch mainline in revision 5223.
  • Revision ID: robertc@robertcollins.net-20100506110810-h3j07fh5gmw54s25
Cleaner matcher matching revised unlocking protocol.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2011 Canonical Ltd
 
1
# Copyright (C) 2005-2010 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
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
16
 
 
17
 
 
18
 
17
19
"""Code to show logs of changes.
18
20
 
19
21
Various flavors of log can be produced:
47
49
all the changes since the previous revision that touched hello.c.
48
50
"""
49
51
 
50
 
from __future__ import absolute_import
51
 
 
52
52
import codecs
53
 
import itertools
 
53
from cStringIO import StringIO
 
54
from itertools import (
 
55
    chain,
 
56
    izip,
 
57
    )
54
58
import re
55
59
import sys
56
60
from warnings import (
57
61
    warn,
58
62
    )
59
63
 
60
 
from .lazy_import import lazy_import
 
64
from bzrlib.lazy_import import lazy_import
61
65
lazy_import(globals(), """
62
66
 
63
 
from breezy import (
 
67
from bzrlib import (
 
68
    bzrdir,
64
69
    config,
65
 
    controldir,
66
70
    diff,
 
71
    errors,
67
72
    foreign,
68
 
    lazy_regex,
 
73
    repository as _mod_repository,
69
74
    revision as _mod_revision,
 
75
    revisionspec,
 
76
    trace,
 
77
    tsort,
70
78
    )
71
 
from breezy.i18n import gettext, ngettext
72
79
""")
73
80
 
74
 
from . import (
75
 
    errors,
 
81
from bzrlib import (
76
82
    registry,
77
 
    revisionspec,
78
83
    )
79
 
from .osutils import (
 
84
from bzrlib.osutils import (
80
85
    format_date,
81
86
    format_date_with_offset_in_original_timezone,
82
 
    get_diff_header_encoding,
83
87
    get_terminal_encoding,
 
88
    re_compile_checked,
84
89
    terminal_width,
85
90
    )
86
 
from .sixish import (
87
 
    BytesIO,
88
 
    range,
89
 
    zip,
 
91
from bzrlib.symbol_versioning import (
 
92
    deprecated_function,
 
93
    deprecated_in,
90
94
    )
91
 
from .tree import find_previous_path
92
 
 
93
 
 
94
 
def find_touching_revisions(repository, last_revision, last_tree, last_path):
 
95
 
 
96
 
 
97
def find_touching_revisions(branch, file_id):
95
98
    """Yield a description of revisions which affect the file_id.
96
99
 
97
100
    Each returned element is (revno, revision_id, description)
102
105
    TODO: Perhaps some way to limit this to only particular revisions,
103
106
    or to traverse a non-mainline set of revisions?
104
107
    """
105
 
    last_verifier = last_tree.get_file_verifier(last_path)
106
 
    graph = repository.get_graph()
107
 
    history = list(graph.iter_lefthand_ancestry(last_revision, []))
108
 
    revno = len(history)
109
 
    for revision_id in history:
110
 
        this_tree = repository.revision_tree(revision_id)
111
 
        this_path = find_previous_path(last_tree, this_tree, last_path)
 
108
    last_ie = None
 
109
    last_path = None
 
110
    revno = 1
 
111
    for revision_id in branch.revision_history():
 
112
        this_inv = branch.repository.get_inventory(revision_id)
 
113
        if file_id in this_inv:
 
114
            this_ie = this_inv[file_id]
 
115
            this_path = this_inv.id2path(file_id)
 
116
        else:
 
117
            this_ie = this_path = None
112
118
 
113
119
        # now we know how it was last time, and how it is in this revision.
114
120
        # are those two states effectively the same or not?
115
 
        if this_path is not None and last_path is None:
116
 
            yield revno, revision_id, "deleted " + this_path
117
 
            this_verifier = this_tree.get_file_verifier(this_path)
118
 
        elif this_path is None and last_path is not None:
119
 
            yield revno, revision_id, "added " + last_path
 
121
 
 
122
        if not this_ie and not last_ie:
 
123
            # not present in either
 
124
            pass
 
125
        elif this_ie and not last_ie:
 
126
            yield revno, revision_id, "added " + this_path
 
127
        elif not this_ie and last_ie:
 
128
            # deleted here
 
129
            yield revno, revision_id, "deleted " + last_path
120
130
        elif this_path != last_path:
121
 
            yield revno, revision_id, ("renamed %s => %s" % (this_path, last_path))
122
 
            this_verifier = this_tree.get_file_verifier(this_path)
123
 
        else:
124
 
            this_verifier = this_tree.get_file_verifier(this_path)
125
 
            if (this_verifier != last_verifier):
126
 
                yield revno, revision_id, "modified " + this_path
 
131
            yield revno, revision_id, ("renamed %s => %s" % (last_path, this_path))
 
132
        elif (this_ie.text_size != last_ie.text_size
 
133
              or this_ie.text_sha1 != last_ie.text_sha1):
 
134
            yield revno, revision_id, "modified " + this_path
127
135
 
128
 
        last_verifier = this_verifier
 
136
        last_ie = this_ie
129
137
        last_path = this_path
130
 
        last_tree = this_tree
131
 
        if last_path is None:
132
 
            return
133
 
        revno -= 1
 
138
        revno += 1
 
139
 
 
140
 
 
141
def _enumerate_history(branch):
 
142
    rh = []
 
143
    revno = 1
 
144
    for rev_id in branch.revision_history():
 
145
        rh.append((revno, rev_id))
 
146
        revno += 1
 
147
    return rh
134
148
 
135
149
 
136
150
def show_log(branch,
142
156
             end_revision=None,
143
157
             search=None,
144
158
             limit=None,
145
 
             show_diff=False,
146
 
             match=None):
 
159
             show_diff=False):
147
160
    """Write out human-readable log of commits to this branch.
148
161
 
149
162
    This function is being retained for backwards compatibility but
172
185
        if None or 0.
173
186
 
174
187
    :param show_diff: If True, output a diff after each revision.
175
 
 
176
 
    :param match: Dictionary of search lists to use when matching revision
177
 
      properties.
178
188
    """
179
189
    # Convert old-style parameters to new-style parameters
180
190
    if specific_fileid is not None:
196
206
    else:
197
207
        diff_type = None
198
208
 
199
 
    if isinstance(start_revision, int):
200
 
        try:
201
 
            start_revision = revisionspec.RevisionInfo(branch, start_revision)
202
 
        except errors.NoSuchRevision:
203
 
            raise errors.InvalidRevisionNumber(start_revision)
204
 
 
205
 
    if isinstance(end_revision, int):
206
 
        try:
207
 
            end_revision = revisionspec.RevisionInfo(branch, end_revision)
208
 
        except errors.NoSuchRevision:
209
 
            raise errors.InvalidRevisionNumber(end_revision)
210
 
 
211
 
    if end_revision is not None and end_revision.revno == 0:
212
 
        raise errors.InvalidRevisionNumber(end_revision.revno)
213
 
 
214
209
    # Build the request and execute it
215
210
    rqst = make_log_request_dict(direction=direction, specific_fileids=file_ids,
216
 
                                 start_revision=start_revision, end_revision=end_revision,
217
 
                                 limit=limit, message_search=search,
218
 
                                 delta_type=delta_type, diff_type=diff_type)
 
211
        start_revision=start_revision, end_revision=end_revision,
 
212
        limit=limit, message_search=search,
 
213
        delta_type=delta_type, diff_type=diff_type)
219
214
    Logger(branch, rqst).show(lf)
220
215
 
221
216
 
222
 
# Note: This needs to be kept in sync with the defaults in
 
217
# Note: This needs to be kept this in sync with the defaults in
223
218
# make_log_request_dict() below
224
219
_DEFAULT_REQUEST_PARAMS = {
225
220
    'direction': 'reverse',
226
 
    'levels': None,
 
221
    'levels': 1,
227
222
    'generate_tags': True,
228
223
    'exclude_common_ancestry': False,
229
224
    '_match_using_deltas': True,
232
227
 
233
228
def make_log_request_dict(direction='reverse', specific_fileids=None,
234
229
                          start_revision=None, end_revision=None, limit=None,
235
 
                          message_search=None, levels=None, generate_tags=True,
 
230
                          message_search=None, levels=1, generate_tags=True,
236
231
                          delta_type=None,
237
232
                          diff_type=None, _match_using_deltas=True,
238
 
                          exclude_common_ancestry=False, match=None,
239
 
                          signature=False, omit_merges=False,
 
233
                          exclude_common_ancestry=False,
240
234
                          ):
241
235
    """Convenience function for making a logging request dictionary.
242
236
 
263
257
      matching commit messages
264
258
 
265
259
    :param levels: the number of levels of revisions to
266
 
      generate; 1 for just the mainline; 0 for all levels, or None for
267
 
      a sensible default.
 
260
      generate; 1 for just the mainline; 0 for all levels.
268
261
 
269
262
    :param generate_tags: If True, include tags for matched revisions.
270
 
`
 
263
 
271
264
    :param delta_type: Either 'full', 'partial' or None.
272
265
      'full' means generate the complete delta - adds/deletes/modifies/etc;
273
266
      'partial' means filter the delta using specific_fileids;
280
273
 
281
274
    :param _match_using_deltas: a private parameter controlling the
282
275
      algorithm used for matching specific_fileids. This parameter
283
 
      may be removed in the future so breezy client code should NOT
 
276
      may be removed in the future so bzrlib client code should NOT
284
277
      use it.
285
278
 
286
279
    :param exclude_common_ancestry: Whether -rX..Y should be interpreted as a
287
280
      range operator or as a graph difference.
288
 
 
289
 
    :param signature: show digital signature information
290
 
 
291
 
    :param match: Dictionary of list of search strings to use when filtering
292
 
      revisions. Keys can be 'message', 'author', 'committer', 'bugs' or
293
 
      the empty string to match any of the preceding properties.
294
 
 
295
 
    :param omit_merges: If True, commits with more than one parent are
296
 
      omitted.
297
 
 
298
281
    """
299
 
    # Take care of old style message_search parameter
300
 
    if message_search:
301
 
        if match:
302
 
            if 'message' in match:
303
 
                match['message'].append(message_search)
304
 
            else:
305
 
                match['message'] = [message_search]
306
 
        else:
307
 
            match = {'message': [message_search]}
308
282
    return {
309
283
        'direction': direction,
310
284
        'specific_fileids': specific_fileids,
311
285
        'start_revision': start_revision,
312
286
        'end_revision': end_revision,
313
287
        'limit': limit,
 
288
        'message_search': message_search,
314
289
        'levels': levels,
315
290
        'generate_tags': generate_tags,
316
291
        'delta_type': delta_type,
317
292
        'diff_type': diff_type,
318
293
        'exclude_common_ancestry': exclude_common_ancestry,
319
 
        'signature': signature,
320
 
        'match': match,
321
 
        'omit_merges': omit_merges,
322
294
        # Add 'private' attributes for features that may be deprecated
323
295
        '_match_using_deltas': _match_using_deltas,
324
296
    }
326
298
 
327
299
def _apply_log_request_defaults(rqst):
328
300
    """Apply default values to a request dictionary."""
329
 
    result = _DEFAULT_REQUEST_PARAMS.copy()
 
301
    result = _DEFAULT_REQUEST_PARAMS
330
302
    if rqst:
331
303
        result.update(rqst)
332
304
    return result
333
305
 
334
306
 
335
 
def format_signature_validity(rev_id, branch):
336
 
    """get the signature validity
337
 
 
338
 
    :param rev_id: revision id to validate
339
 
    :param branch: branch of revision
340
 
    :return: human readable string to print to log
341
 
    """
342
 
    from breezy import gpg
343
 
 
344
 
    gpg_strategy = gpg.GPGStrategy(branch.get_config_stack())
345
 
    result = branch.repository.verify_revision_signature(rev_id, gpg_strategy)
346
 
    if result[0] == gpg.SIGNATURE_VALID:
347
 
        return u"valid signature from {0}".format(result[1])
348
 
    if result[0] == gpg.SIGNATURE_KEY_MISSING:
349
 
        return "unknown key {0}".format(result[1])
350
 
    if result[0] == gpg.SIGNATURE_NOT_VALID:
351
 
        return "invalid signature!"
352
 
    if result[0] == gpg.SIGNATURE_NOT_SIGNED:
353
 
        return "no signature"
354
 
 
355
 
 
356
307
class LogGenerator(object):
357
308
    """A generator of log revisions."""
358
309
 
385
336
        if not isinstance(lf, LogFormatter):
386
337
            warn("not a LogFormatter instance: %r" % lf)
387
338
 
388
 
        with self.branch.lock_read():
 
339
        self.branch.lock_read()
 
340
        try:
389
341
            if getattr(lf, 'begin_log', None):
390
342
                lf.begin_log()
391
343
            self._show_body(lf)
392
344
            if getattr(lf, 'end_log', None):
393
345
                lf.end_log()
 
346
        finally:
 
347
            self.branch.unlock()
394
348
 
395
349
    def _show_body(self, lf):
396
350
        """Show the main log output.
400
354
        # Tweak the LogRequest based on what the LogFormatter can handle.
401
355
        # (There's no point generating stuff if the formatter can't display it.)
402
356
        rqst = self.rqst
403
 
        if rqst['levels'] is None or lf.get_levels() > rqst['levels']:
404
 
            # user didn't specify levels, use whatever the LF can handle:
405
 
            rqst['levels'] = lf.get_levels()
406
 
 
 
357
        rqst['levels'] = lf.get_levels()
407
358
        if not getattr(lf, 'supports_tags', False):
408
359
            rqst['generate_tags'] = False
409
360
        if not getattr(lf, 'supports_delta', False):
410
361
            rqst['delta_type'] = None
411
362
        if not getattr(lf, 'supports_diff', False):
412
363
            rqst['diff_type'] = None
413
 
        if not getattr(lf, 'supports_signatures', False):
414
 
            rqst['signature'] = False
415
364
 
416
365
        # Find and print the interesting revisions
417
366
        generator = self._generator_factory(self.branch, rqst)
418
 
        try:
419
 
            for lr in generator.iter_log_revisions():
420
 
                lf.log_revision(lr)
421
 
        except errors.GhostRevisionUnusableHere:
422
 
            raise errors.BzrCommandError(
423
 
                gettext('Further revision history missing.'))
 
367
        for lr in generator.iter_log_revisions():
 
368
            lf.log_revision(lr)
424
369
        lf.show_advice()
425
370
 
426
371
    def _generator_factory(self, branch, rqst):
427
372
        """Make the LogGenerator object to use.
428
 
 
 
373
        
429
374
        Subclasses may wish to override this.
430
375
        """
431
376
        return _DefaultLogGenerator(branch, rqst)
455
400
        levels = rqst.get('levels')
456
401
        limit = rqst.get('limit')
457
402
        diff_type = rqst.get('diff_type')
458
 
        show_signature = rqst.get('signature')
459
 
        omit_merges = rqst.get('omit_merges')
460
403
        log_count = 0
461
404
        revision_iterator = self._create_log_revision_iterator()
462
405
        for revs in revision_iterator:
463
406
            for (rev_id, revno, merge_depth), rev, delta in revs:
464
407
                # 0 levels means show everything; merge_depth counts from 0
465
 
                if (levels != 0 and merge_depth is not None and
466
 
                        merge_depth >= levels):
467
 
                    continue
468
 
                if omit_merges and len(rev.parent_ids) > 1:
469
 
                    continue
470
 
                if rev is None:
471
 
                    raise errors.GhostRevisionUnusableHere(rev_id)
 
408
                if levels != 0 and merge_depth >= levels:
 
409
                    continue
472
410
                if diff_type is None:
473
411
                    diff = None
474
412
                else:
475
413
                    diff = self._format_diff(rev, rev_id, diff_type)
476
 
                if show_signature:
477
 
                    signature = format_signature_validity(rev_id, self.branch)
478
 
                else:
479
 
                    signature = None
480
 
                yield LogRevision(
481
 
                    rev, revno, merge_depth, delta,
482
 
                    self.rev_tag_dict.get(rev_id), diff, signature)
 
414
                yield LogRevision(rev, revno, merge_depth, delta,
 
415
                    self.rev_tag_dict.get(rev_id), diff)
483
416
                if limit:
484
417
                    log_count += 1
485
418
                    if log_count >= limit:
498
431
            specific_files = [tree_2.id2path(id) for id in file_ids]
499
432
        else:
500
433
            specific_files = None
501
 
        s = BytesIO()
502
 
        path_encoding = get_diff_header_encoding()
 
434
        s = StringIO()
503
435
        diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
504
 
                             new_label='', path_encoding=path_encoding)
 
436
            new_label='')
505
437
        return s.getvalue()
506
438
 
507
439
    def _create_log_revision_iterator(self):
521
453
            # not a directory
522
454
            file_count = len(self.rqst.get('specific_fileids'))
523
455
            if file_count != 1:
524
 
                raise errors.BzrError(
525
 
                    "illegal LogRequest: must match-using-deltas "
 
456
                raise BzrError("illegal LogRequest: must match-using-deltas "
526
457
                    "when logging %d files" % file_count)
527
458
            return self._log_revision_iterator_using_per_file_graph()
528
459
 
531
462
        rqst = self.rqst
532
463
        generate_merge_revisions = rqst.get('levels') != 1
533
464
        delayed_graph_generation = not rqst.get('specific_fileids') and (
534
 
            rqst.get('limit') or self.start_rev_id or self.end_rev_id)
 
465
                rqst.get('limit') or self.start_rev_id or self.end_rev_id)
535
466
        view_revisions = _calc_view_revisions(
536
467
            self.branch, self.start_rev_id, self.end_rev_id,
537
468
            rqst.get('direction'),
541
472
 
542
473
        # Apply the other filters
543
474
        return make_log_rev_iterator(self.branch, view_revisions,
544
 
                                     rqst.get('delta_type'), rqst.get('match'),
545
 
                                     file_ids=rqst.get('specific_fileids'),
546
 
                                     direction=rqst.get('direction'))
 
475
            rqst.get('delta_type'), rqst.get('message_search'),
 
476
            file_ids=rqst.get('specific_fileids'),
 
477
            direction=rqst.get('direction'))
547
478
 
548
479
    def _log_revision_iterator_using_per_file_graph(self):
549
480
        # Get the base revisions, filtering by the revision range.
557
488
        if not isinstance(view_revisions, list):
558
489
            view_revisions = list(view_revisions)
559
490
        view_revisions = _filter_revisions_touching_file_id(self.branch,
560
 
                                                            rqst.get('specific_fileids')[
561
 
                                                                0], view_revisions,
562
 
                                                            include_merges=rqst.get('levels') != 1)
 
491
            rqst.get('specific_fileids')[0], view_revisions,
 
492
            include_merges=rqst.get('levels') != 1)
563
493
        return make_log_rev_iterator(self.branch, view_revisions,
564
 
                                     rqst.get('delta_type'), rqst.get('match'))
 
494
            rqst.get('delta_type'), rqst.get('message_search'))
565
495
 
566
496
 
567
497
def _calc_view_revisions(branch, start_rev_id, end_rev_id, direction,
575
505
             a list of the same tuples.
576
506
    """
577
507
    if (exclude_common_ancestry and start_rev_id == end_rev_id):
578
 
        raise errors.BzrCommandError(gettext(
579
 
            '--exclude-common-ancestry requires two different revisions'))
 
508
        raise errors.BzrCommandError(
 
509
            '--exclude-common-ancestry requires two different revisions')
580
510
    if direction not in ('reverse', 'forward'):
581
 
        raise ValueError(gettext('invalid direction %r') % direction)
582
 
    br_rev_id = branch.last_revision()
583
 
    if br_rev_id == _mod_revision.NULL_REVISION:
 
511
        raise ValueError('invalid direction %r' % direction)
 
512
    br_revno, br_rev_id = branch.last_revision_info()
 
513
    if br_revno == 0:
584
514
        return []
585
515
 
586
516
    if (end_rev_id and start_rev_id == end_rev_id
587
517
        and (not generate_merge_revisions
588
518
             or not _has_merges(branch, end_rev_id))):
589
519
        # If a single revision is requested, check we can handle it
590
 
        return _generate_one_revision(branch, end_rev_id, br_rev_id,
591
 
                                      branch.revno())
592
 
    if not generate_merge_revisions:
593
 
        try:
594
 
            # If we only want to see linear revisions, we can iterate ...
595
 
            iter_revs = _linear_view_revisions(
596
 
                branch, start_rev_id, end_rev_id,
597
 
                exclude_common_ancestry=exclude_common_ancestry)
598
 
            # If a start limit was given and it's not obviously an
599
 
            # ancestor of the end limit, check it before outputting anything
600
 
            if (direction == 'forward'
601
 
                or (start_rev_id and not _is_obvious_ancestor(
602
 
                    branch, start_rev_id, end_rev_id))):
603
 
                iter_revs = list(iter_revs)
604
 
            if direction == 'forward':
605
 
                iter_revs = reversed(iter_revs)
606
 
            return iter_revs
607
 
        except _StartNotLinearAncestor:
608
 
            # Switch to the slower implementation that may be able to find a
609
 
            # non-obvious ancestor out of the left-hand history.
610
 
            pass
611
 
    iter_revs = _generate_all_revisions(branch, start_rev_id, end_rev_id,
612
 
                                        direction, delayed_graph_generation,
613
 
                                        exclude_common_ancestry)
614
 
    if direction == 'forward':
615
 
        iter_revs = _rebase_merge_depth(reverse_by_depth(list(iter_revs)))
 
520
        iter_revs = _generate_one_revision(branch, end_rev_id, br_rev_id,
 
521
                                           br_revno)
 
522
    elif not generate_merge_revisions:
 
523
        # If we only want to see linear revisions, we can iterate ...
 
524
        iter_revs = _generate_flat_revisions(branch, start_rev_id, end_rev_id,
 
525
                                             direction)
 
526
        if direction == 'forward':
 
527
            iter_revs = reversed(iter_revs)
 
528
    else:
 
529
        iter_revs = _generate_all_revisions(branch, start_rev_id, end_rev_id,
 
530
                                            direction, delayed_graph_generation,
 
531
                                            exclude_common_ancestry)
 
532
        if direction == 'forward':
 
533
            iter_revs = _rebase_merge_depth(reverse_by_depth(list(iter_revs)))
616
534
    return iter_revs
617
535
 
618
536
 
621
539
        # It's the tip
622
540
        return [(br_rev_id, br_revno, 0)]
623
541
    else:
624
 
        revno_str = _compute_revno_str(branch, rev_id)
 
542
        revno = branch.revision_id_to_dotted_revno(rev_id)
 
543
        revno_str = '.'.join(str(n) for n in revno)
625
544
        return [(rev_id, revno_str, 0)]
626
545
 
627
546
 
 
547
def _generate_flat_revisions(branch, start_rev_id, end_rev_id, direction):
 
548
    result = _linear_view_revisions(branch, start_rev_id, end_rev_id)
 
549
    # If a start limit was given and it's not obviously an
 
550
    # ancestor of the end limit, check it before outputting anything
 
551
    if direction == 'forward' or (start_rev_id
 
552
        and not _is_obvious_ancestor(branch, start_rev_id, end_rev_id)):
 
553
        try:
 
554
            result = list(result)
 
555
        except _StartNotLinearAncestor:
 
556
            raise errors.BzrCommandError('Start revision not found in'
 
557
                ' left-hand history of end revision.')
 
558
    return result
 
559
 
 
560
 
628
561
def _generate_all_revisions(branch, start_rev_id, end_rev_id, direction,
629
562
                            delayed_graph_generation,
630
563
                            exclude_common_ancestry=False):
638
571
    initial_revisions = []
639
572
    if delayed_graph_generation:
640
573
        try:
641
 
            for rev_id, revno, depth in _linear_view_revisions(
642
 
                    branch, start_rev_id, end_rev_id, exclude_common_ancestry):
 
574
            for rev_id, revno, depth in  _linear_view_revisions(
 
575
                branch, start_rev_id, end_rev_id):
643
576
                if _has_merges(branch, rev_id):
644
577
                    # The end_rev_id can be nested down somewhere. We need an
645
578
                    # explicit ancestry check. There is an ambiguity here as we
652
585
                    # -- vila 20100319
653
586
                    graph = branch.repository.get_graph()
654
587
                    if (start_rev_id is not None
655
 
                            and not graph.is_ancestor(start_rev_id, end_rev_id)):
 
588
                        and not graph.is_ancestor(start_rev_id, end_rev_id)):
656
589
                        raise _StartNotLinearAncestor()
657
590
                    # Since we collected the revisions so far, we need to
658
591
                    # adjust end_rev_id.
666
599
        except _StartNotLinearAncestor:
667
600
            # A merge was never detected so the lower revision limit can't
668
601
            # be nested down somewhere
669
 
            raise errors.BzrCommandError(gettext('Start revision not found in'
670
 
                                                 ' history of end revision.'))
 
602
            raise errors.BzrCommandError('Start revision not found in'
 
603
                ' history of end revision.')
671
604
 
672
605
    # We exit the loop above because we encounter a revision with merges, from
673
606
    # this revision, we need to switch to _graph_view_revisions.
677
610
    # shown naturally, i.e. just like it is for linear logging. We can easily
678
611
    # make forward the exact opposite display, but showing the merge revisions
679
612
    # indented at the end seems slightly nicer in that case.
680
 
    view_revisions = itertools.chain(iter(initial_revisions),
681
 
                                     _graph_view_revisions(branch, start_rev_id, end_rev_id,
682
 
                                                           rebase_initial_depths=(
683
 
                                                               direction == 'reverse'),
684
 
                                                           exclude_common_ancestry=exclude_common_ancestry))
 
613
    view_revisions = chain(iter(initial_revisions),
 
614
        _graph_view_revisions(branch, start_rev_id, end_rev_id,
 
615
                              rebase_initial_depths=(direction == 'reverse'),
 
616
                              exclude_common_ancestry=exclude_common_ancestry))
685
617
    return view_revisions
686
618
 
687
619
 
691
623
    return len(parents) > 1
692
624
 
693
625
 
694
 
def _compute_revno_str(branch, rev_id):
695
 
    """Compute the revno string from a rev_id.
696
 
 
697
 
    :return: The revno string, or None if the revision is not in the supplied
698
 
        branch.
699
 
    """
700
 
    try:
701
 
        revno = branch.revision_id_to_dotted_revno(rev_id)
702
 
    except errors.NoSuchRevision:
703
 
        # The revision must be outside of this branch
704
 
        return None
705
 
    else:
706
 
        return '.'.join(str(n) for n in revno)
707
 
 
708
 
 
709
626
def _is_obvious_ancestor(branch, start_rev_id, end_rev_id):
710
627
    """Is start_rev_id an obvious ancestor of end_rev_id?"""
711
628
    if start_rev_id and end_rev_id:
712
 
        try:
713
 
            start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
714
 
            end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
715
 
        except errors.NoSuchRevision:
716
 
            # one or both is not in the branch; not obvious
717
 
            return False
 
629
        start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
 
630
        end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
718
631
        if len(start_dotted) == 1 and len(end_dotted) == 1:
719
632
            # both on mainline
720
633
            return start_dotted[0] <= end_dotted[0]
721
634
        elif (len(start_dotted) == 3 and len(end_dotted) == 3 and
722
 
              start_dotted[0:1] == end_dotted[0:1]):
 
635
            start_dotted[0:1] == end_dotted[0:1]):
723
636
            # both on same development line
724
637
            return start_dotted[2] <= end_dotted[2]
725
638
        else:
730
643
    return True
731
644
 
732
645
 
733
 
def _linear_view_revisions(branch, start_rev_id, end_rev_id,
734
 
                           exclude_common_ancestry=False):
 
646
def _linear_view_revisions(branch, start_rev_id, end_rev_id):
735
647
    """Calculate a sequence of revisions to view, newest to oldest.
736
648
 
737
649
    :param start_rev_id: the lower revision-id
738
650
    :param end_rev_id: the upper revision-id
739
 
    :param exclude_common_ancestry: Whether the start_rev_id should be part of
740
 
        the iterated revisions.
741
651
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
742
 
        dotted_revno will be None for ghosts
743
652
    :raises _StartNotLinearAncestor: if a start_rev_id is specified but
744
 
        is not found walking the left-hand history
 
653
      is not found walking the left-hand history
745
654
    """
 
655
    br_revno, br_rev_id = branch.last_revision_info()
746
656
    repo = branch.repository
747
 
    graph = repo.get_graph()
748
657
    if start_rev_id is None and end_rev_id is None:
749
 
        try:
750
 
            br_revno, br_rev_id = branch.last_revision_info()
751
 
        except errors.GhostRevisionsHaveNoRevno:
752
 
            br_rev_id = branch.last_revision()
753
 
            cur_revno = None
754
 
        else:
755
 
            cur_revno = br_revno
756
 
        graph_iter = graph.iter_lefthand_ancestry(br_rev_id,
757
 
                                                  (_mod_revision.NULL_REVISION,))
758
 
        while True:
759
 
            try:
760
 
                revision_id = next(graph_iter)
761
 
            except errors.RevisionNotPresent as e:
762
 
                # Oops, a ghost.
763
 
                yield e.revision_id, None, None
764
 
                break
765
 
            except StopIteration:
766
 
                break
767
 
            else:
768
 
                yield revision_id, str(cur_revno) if cur_revno is not None else None, 0
769
 
                if cur_revno is not None:
770
 
                    cur_revno -= 1
 
658
        cur_revno = br_revno
 
659
        for revision_id in repo.iter_reverse_revision_history(br_rev_id):
 
660
            yield revision_id, str(cur_revno), 0
 
661
            cur_revno -= 1
771
662
    else:
772
 
        br_rev_id = branch.last_revision()
773
663
        if end_rev_id is None:
774
664
            end_rev_id = br_rev_id
775
665
        found_start = start_rev_id is None
776
 
        graph_iter = graph.iter_lefthand_ancestry(end_rev_id,
777
 
                                                  (_mod_revision.NULL_REVISION,))
778
 
        while True:
779
 
            try:
780
 
                revision_id = next(graph_iter)
781
 
            except StopIteration:
782
 
                break
783
 
            except errors.RevisionNotPresent as e:
784
 
                # Oops, a ghost.
785
 
                yield e.revision_id, None, None
 
666
        for revision_id in repo.iter_reverse_revision_history(end_rev_id):
 
667
            revno = branch.revision_id_to_dotted_revno(revision_id)
 
668
            revno_str = '.'.join(str(n) for n in revno)
 
669
            if not found_start and revision_id == start_rev_id:
 
670
                yield revision_id, revno_str, 0
 
671
                found_start = True
786
672
                break
787
673
            else:
788
 
                revno_str = _compute_revno_str(branch, revision_id)
789
 
                if not found_start and revision_id == start_rev_id:
790
 
                    if not exclude_common_ancestry:
791
 
                        yield revision_id, revno_str, 0
792
 
                    found_start = True
793
 
                    break
794
 
                else:
795
 
                    yield revision_id, revno_str, 0
796
 
        if not found_start:
797
 
            raise _StartNotLinearAncestor()
 
674
                yield revision_id, revno_str, 0
 
675
        else:
 
676
            if not found_start:
 
677
                raise _StartNotLinearAncestor()
798
678
 
799
679
 
800
680
def _graph_view_revisions(branch, start_rev_id, end_rev_id,
841
721
            yield rev_id, '.'.join(map(str, revno)), merge_depth
842
722
 
843
723
 
 
724
@deprecated_function(deprecated_in((2, 2, 0)))
 
725
def calculate_view_revisions(branch, start_revision, end_revision, direction,
 
726
        specific_fileid, generate_merge_revisions):
 
727
    """Calculate the revisions to view.
 
728
 
 
729
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
 
730
             a list of the same tuples.
 
731
    """
 
732
    start_rev_id, end_rev_id = _get_revision_limits(branch, start_revision,
 
733
        end_revision)
 
734
    view_revisions = list(_calc_view_revisions(branch, start_rev_id, end_rev_id,
 
735
        direction, generate_merge_revisions or specific_fileid))
 
736
    if specific_fileid:
 
737
        view_revisions = _filter_revisions_touching_file_id(branch,
 
738
            specific_fileid, view_revisions,
 
739
            include_merges=generate_merge_revisions)
 
740
    return _rebase_merge_depth(view_revisions)
 
741
 
 
742
 
844
743
def _rebase_merge_depth(view_revisions):
845
744
    """Adjust depths upwards so the top level is 0."""
846
745
    # If either the first or last revision have a merge_depth of 0, we're done
847
746
    if view_revisions and view_revisions[0][2] and view_revisions[-1][2]:
848
 
        min_depth = min([d for r, n, d in view_revisions])
 
747
        min_depth = min([d for r,n,d in view_revisions])
849
748
        if min_depth != 0:
850
 
            view_revisions = [(r, n, d - min_depth)
851
 
                              for r, n, d in view_revisions]
 
749
            view_revisions = [(r,n,d-min_depth) for r,n,d in view_revisions]
852
750
    return view_revisions
853
751
 
854
752
 
855
753
def make_log_rev_iterator(branch, view_revisions, generate_delta, search,
856
 
                          file_ids=None, direction='reverse'):
 
754
        file_ids=None, direction='reverse'):
857
755
    """Create a revision iterator for log.
858
756
 
859
757
    :param branch: The branch being logged.
869
767
    """
870
768
    # Convert view_revisions into (view, None, None) groups to fit with
871
769
    # the standard interface here.
872
 
    if isinstance(view_revisions, list):
 
770
    if type(view_revisions) == list:
873
771
        # A single batch conversion is faster than many incremental ones.
874
772
        # As we have all the data, do a batch conversion.
875
773
        nones = [None] * len(view_revisions)
876
 
        log_rev_iterator = iter([list(zip(view_revisions, nones, nones))])
 
774
        log_rev_iterator = iter([zip(view_revisions, nones, nones)])
877
775
    else:
878
776
        def _convert():
879
777
            for view in view_revisions:
883
781
        # It would be nicer if log adapters were first class objects
884
782
        # with custom parameters. This will do for now. IGC 20090127
885
783
        if adapter == _make_delta_filter:
886
 
            log_rev_iterator = adapter(
887
 
                branch, generate_delta, search, log_rev_iterator, file_ids,
888
 
                direction)
 
784
            log_rev_iterator = adapter(branch, generate_delta,
 
785
                search, log_rev_iterator, file_ids, direction)
889
786
        else:
890
 
            log_rev_iterator = adapter(
891
 
                branch, generate_delta, search, log_rev_iterator)
 
787
            log_rev_iterator = adapter(branch, generate_delta,
 
788
                search, log_rev_iterator)
892
789
    return log_rev_iterator
893
790
 
894
791
 
895
 
def _make_search_filter(branch, generate_delta, match, log_rev_iterator):
 
792
def _make_search_filter(branch, generate_delta, search, log_rev_iterator):
896
793
    """Create a filtered iterator of log_rev_iterator matching on a regex.
897
794
 
898
795
    :param branch: The branch being logged.
899
796
    :param generate_delta: Whether to generate a delta for each revision.
900
 
    :param match: A dictionary with properties as keys and lists of strings
901
 
        as values. To match, a revision may match any of the supplied strings
902
 
        within a single property but must match at least one string for each
903
 
        property.
 
797
    :param search: A user text search string.
904
798
    :param log_rev_iterator: An input iterator containing all revisions that
905
799
        could be displayed, in lists.
906
800
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
907
801
        delta).
908
802
    """
909
 
    if not match:
 
803
    if search is None:
910
804
        return log_rev_iterator
911
 
    # Use lazy_compile so mapping to InvalidPattern error occurs.
912
 
    searchRE = [(k, [lazy_regex.lazy_compile(x, re.IGNORECASE) for x in v])
913
 
                for k, v in match.items()]
914
 
    return _filter_re(searchRE, log_rev_iterator)
915
 
 
916
 
 
917
 
def _filter_re(searchRE, log_rev_iterator):
 
805
    searchRE = re_compile_checked(search, re.IGNORECASE,
 
806
            'log message filter')
 
807
    return _filter_message_re(searchRE, log_rev_iterator)
 
808
 
 
809
 
 
810
def _filter_message_re(searchRE, log_rev_iterator):
918
811
    for revs in log_rev_iterator:
919
 
        new_revs = [rev for rev in revs if _match_filter(searchRE, rev[1])]
920
 
        if new_revs:
921
 
            yield new_revs
922
 
 
923
 
 
924
 
def _match_filter(searchRE, rev):
925
 
    strings = {
926
 
        'message': (rev.message,),
927
 
        'committer': (rev.committer,),
928
 
        'author': (rev.get_apparent_authors()),
929
 
        'bugs': list(rev.iter_bugs())
930
 
        }
931
 
    strings[''] = [item for inner_list in strings.values()
932
 
                   for item in inner_list]
933
 
    for k, v in searchRE:
934
 
        if k in strings and not _match_any_filter(strings[k], v):
935
 
            return False
936
 
    return True
937
 
 
938
 
 
939
 
def _match_any_filter(strings, res):
940
 
    return any(r.search(s) for r in res for s in strings)
 
812
        new_revs = []
 
813
        for (rev_id, revno, merge_depth), rev, delta in revs:
 
814
            if searchRE.search(rev.message):
 
815
                new_revs.append(((rev_id, revno, merge_depth), rev, delta))
 
816
        yield new_revs
941
817
 
942
818
 
943
819
def _make_delta_filter(branch, generate_delta, search, log_rev_iterator,
944
 
                       fileids=None, direction='reverse'):
 
820
    fileids=None, direction='reverse'):
945
821
    """Add revision deltas to a log iterator if needed.
946
822
 
947
823
    :param branch: The branch being logged.
959
835
    if not generate_delta and not fileids:
960
836
        return log_rev_iterator
961
837
    return _generate_deltas(branch.repository, log_rev_iterator,
962
 
                            generate_delta, fileids, direction)
 
838
        generate_delta, fileids, direction)
963
839
 
964
840
 
965
841
def _generate_deltas(repository, log_rev_iterator, delta_type, fileids,
966
 
                     direction):
 
842
    direction):
967
843
    """Create deltas for each batch of revisions in log_rev_iterator.
968
844
 
969
845
    If we're only generating deltas for the sake of filtering against
989
865
        new_revs = []
990
866
        if delta_type == 'full' and not check_fileids:
991
867
            deltas = repository.get_deltas_for_revisions(revisions)
992
 
            for rev, delta in zip(revs, deltas):
 
868
            for rev, delta in izip(revs, deltas):
993
869
                new_revs.append((rev[0], rev[1], delta))
994
870
        else:
995
871
            deltas = repository.get_deltas_for_revisions(revisions, fileid_set)
996
 
            for rev, delta in zip(revs, deltas):
 
872
            for rev, delta in izip(revs, deltas):
997
873
                if check_fileids:
998
874
                    if delta is None or not delta.has_changed():
999
875
                        continue
1017
893
 
1018
894
def _update_fileids(delta, fileids, stop_on):
1019
895
    """Update the set of file-ids to search based on file lifecycle events.
1020
 
 
 
896
    
1021
897
    :param fileids: a set of fileids to update
1022
898
    :param stop_on: either 'add' or 'remove' - take file-ids out of the
1023
899
      fileids set once their add or remove entry is detected respectively
1047
923
    for revs in log_rev_iterator:
1048
924
        # r = revision_id, n = revno, d = merge depth
1049
925
        revision_ids = [view[0] for view, _, _ in revs]
1050
 
        revisions = dict(repository.iter_revisions(revision_ids))
1051
 
        yield [(rev[0], revisions[rev[0][0]], rev[2]) for rev in revs]
 
926
        revisions = repository.get_revisions(revision_ids)
 
927
        revs = [(rev[0], revision, rev[2]) for rev, revision in
 
928
            izip(revs, revisions)]
 
929
        yield revs
1052
930
 
1053
931
 
1054
932
def _make_batch_filter(branch, generate_delta, search, log_rev_iterator):
1062
940
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
1063
941
        delta).
1064
942
    """
 
943
    repository = branch.repository
1065
944
    num = 9
1066
945
    for batch in log_rev_iterator:
1067
946
        batch = iter(batch)
1079
958
    :param  branch: The branch containing the revisions.
1080
959
 
1081
960
    :param  start_revision: The first revision to be logged.
 
961
            For backwards compatibility this may be a mainline integer revno,
1082
962
            but for merge revision support a RevisionInfo is expected.
1083
963
 
1084
964
    :param  end_revision: The last revision to be logged.
1087
967
 
1088
968
    :return: (start_rev_id, end_rev_id) tuple.
1089
969
    """
 
970
    branch_revno, branch_rev_id = branch.last_revision_info()
1090
971
    start_rev_id = None
1091
 
    start_revno = None
1092
 
    if start_revision is not None:
1093
 
        if not isinstance(start_revision, revisionspec.RevisionInfo):
1094
 
            raise TypeError(start_revision)
1095
 
        start_rev_id = start_revision.rev_id
1096
 
        start_revno = start_revision.revno
1097
 
    if start_revno is None:
 
972
    if start_revision is None:
1098
973
        start_revno = 1
 
974
    else:
 
975
        if isinstance(start_revision, revisionspec.RevisionInfo):
 
976
            start_rev_id = start_revision.rev_id
 
977
            start_revno = start_revision.revno or 1
 
978
        else:
 
979
            branch.check_real_revno(start_revision)
 
980
            start_revno = start_revision
 
981
            start_rev_id = branch.get_rev_id(start_revno)
1099
982
 
1100
983
    end_rev_id = None
1101
 
    end_revno = None
1102
 
    if end_revision is not None:
1103
 
        if not isinstance(end_revision, revisionspec.RevisionInfo):
1104
 
            raise TypeError(start_revision)
1105
 
        end_rev_id = end_revision.rev_id
1106
 
        end_revno = end_revision.revno
1107
 
    if end_revno is None:
1108
 
        try:
1109
 
            end_revno = branch.revno()
1110
 
        except errors.GhostRevisionsHaveNoRevno:
1111
 
            end_revno = None
 
984
    if end_revision is None:
 
985
        end_revno = branch_revno
 
986
    else:
 
987
        if isinstance(end_revision, revisionspec.RevisionInfo):
 
988
            end_rev_id = end_revision.rev_id
 
989
            end_revno = end_revision.revno or branch_revno
 
990
        else:
 
991
            branch.check_real_revno(end_revision)
 
992
            end_revno = end_revision
 
993
            end_rev_id = branch.get_rev_id(end_revno)
1112
994
 
1113
 
    if branch.last_revision() != _mod_revision.NULL_REVISION:
 
995
    if branch_revno != 0:
1114
996
        if (start_rev_id == _mod_revision.NULL_REVISION
1115
 
                or end_rev_id == _mod_revision.NULL_REVISION):
1116
 
            raise errors.BzrCommandError(
1117
 
                gettext('Logging revision 0 is invalid.'))
1118
 
        if end_revno is not None and start_revno > end_revno:
1119
 
            raise errors.BzrCommandError(
1120
 
                gettext("Start revision must be older than the end revision."))
 
997
            or end_rev_id == _mod_revision.NULL_REVISION):
 
998
            raise errors.BzrCommandError('Logging revision 0 is invalid.')
 
999
        if start_revno > end_revno:
 
1000
            raise errors.BzrCommandError("Start revision must be older than "
 
1001
                                         "the end revision.")
1121
1002
    return (start_rev_id, end_rev_id)
1122
1003
 
1123
1004
 
1171
1052
            end_revno = end_revision
1172
1053
 
1173
1054
    if ((start_rev_id == _mod_revision.NULL_REVISION)
1174
 
            or (end_rev_id == _mod_revision.NULL_REVISION)):
1175
 
        raise errors.BzrCommandError(gettext('Logging revision 0 is invalid.'))
 
1055
        or (end_rev_id == _mod_revision.NULL_REVISION)):
 
1056
        raise errors.BzrCommandError('Logging revision 0 is invalid.')
1176
1057
    if start_revno > end_revno:
1177
 
        raise errors.BzrCommandError(gettext("Start revision must be older "
1178
 
                                             "than the end revision."))
 
1058
        raise errors.BzrCommandError("Start revision must be older than "
 
1059
                                     "the end revision.")
1179
1060
 
1180
1061
    if end_revno < start_revno:
1181
1062
        return None, None, None, None
1182
1063
    cur_revno = branch_revno
1183
1064
    rev_nos = {}
1184
1065
    mainline_revs = []
1185
 
    graph = branch.repository.get_graph()
1186
 
    for revision_id in graph.iter_lefthand_ancestry(
1187
 
            branch_last_revision, (_mod_revision.NULL_REVISION,)):
 
1066
    for revision_id in branch.repository.iter_reverse_revision_history(
 
1067
                        branch_last_revision):
1188
1068
        if cur_revno < start_revno:
1189
1069
            # We have gone far enough, but we always add 1 more revision
1190
1070
            rev_nos[revision_id] = cur_revno
1204
1084
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
1205
1085
 
1206
1086
 
 
1087
@deprecated_function(deprecated_in((2, 2, 0)))
 
1088
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
 
1089
    """Filter view_revisions based on revision ranges.
 
1090
 
 
1091
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth)
 
1092
            tuples to be filtered.
 
1093
 
 
1094
    :param start_rev_id: If not NONE specifies the first revision to be logged.
 
1095
            If NONE then all revisions up to the end_rev_id are logged.
 
1096
 
 
1097
    :param end_rev_id: If not NONE specifies the last revision to be logged.
 
1098
            If NONE then all revisions up to the end of the log are logged.
 
1099
 
 
1100
    :return: The filtered view_revisions.
 
1101
    """
 
1102
    if start_rev_id or end_rev_id:
 
1103
        revision_ids = [r for r, n, d in view_revisions]
 
1104
        if start_rev_id:
 
1105
            start_index = revision_ids.index(start_rev_id)
 
1106
        else:
 
1107
            start_index = 0
 
1108
        if start_rev_id == end_rev_id:
 
1109
            end_index = start_index
 
1110
        else:
 
1111
            if end_rev_id:
 
1112
                end_index = revision_ids.index(end_rev_id)
 
1113
            else:
 
1114
                end_index = len(view_revisions) - 1
 
1115
        # To include the revisions merged into the last revision,
 
1116
        # extend end_rev_id down to, but not including, the next rev
 
1117
        # with the same or lesser merge_depth
 
1118
        end_merge_depth = view_revisions[end_index][2]
 
1119
        try:
 
1120
            for index in xrange(end_index+1, len(view_revisions)+1):
 
1121
                if view_revisions[index][2] <= end_merge_depth:
 
1122
                    end_index = index - 1
 
1123
                    break
 
1124
        except IndexError:
 
1125
            # if the search falls off the end then log to the end as well
 
1126
            end_index = len(view_revisions) - 1
 
1127
        view_revisions = view_revisions[start_index:end_index+1]
 
1128
    return view_revisions
 
1129
 
 
1130
 
1207
1131
def _filter_revisions_touching_file_id(branch, file_id, view_revisions,
1208
 
                                       include_merges=True):
 
1132
    include_merges=True):
1209
1133
    r"""Return the list of revision ids which touch a given file id.
1210
1134
 
1211
1135
    The function filters view_revisions and returns a subset.
1212
1136
    This includes the revisions which directly change the file id,
1213
1137
    and the revisions which merge these changes. So if the
1214
1138
    revision graph is::
1215
 
 
1216
1139
        A-.
1217
1140
        |\ \
1218
1141
        B C E
1245
1168
    """
1246
1169
    # Lookup all possible text keys to determine which ones actually modified
1247
1170
    # the file.
1248
 
    graph = branch.repository.get_file_graph()
1249
 
    get_parent_map = graph.get_parent_map
1250
1171
    text_keys = [(file_id, rev_id) for rev_id, revno, depth in view_revisions]
1251
1172
    next_keys = None
1252
1173
    # Looking up keys in batches of 1000 can cut the time in half, as well as
1256
1177
    #       indexing layer. We might consider passing in hints as to the known
1257
1178
    #       access pattern (sparse/clustered, high success rate/low success
1258
1179
    #       rate). This particular access is clustered with a low success rate.
 
1180
    get_parent_map = branch.repository.texts.get_parent_map
1259
1181
    modified_text_revisions = set()
1260
1182
    chunk_size = 1000
1261
 
    for start in range(0, len(text_keys), chunk_size):
 
1183
    for start in xrange(0, len(text_keys), chunk_size):
1262
1184
        next_keys = text_keys[start:start + chunk_size]
1263
1185
        # Only keep the revision_id portion of the key
1264
1186
        modified_text_revisions.update(
1279
1201
 
1280
1202
        if rev_id in modified_text_revisions:
1281
1203
            # This needs to be logged, along with the extra revisions
1282
 
            for idx in range(len(current_merge_stack)):
 
1204
            for idx in xrange(len(current_merge_stack)):
1283
1205
                node = current_merge_stack[idx]
1284
1206
                if node is not None:
1285
1207
                    if include_merges or node[2] == 0:
1288
1210
    return result
1289
1211
 
1290
1212
 
 
1213
@deprecated_function(deprecated_in((2, 2, 0)))
 
1214
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
 
1215
                       include_merges=True):
 
1216
    """Produce an iterator of revisions to show
 
1217
    :return: an iterator of (revision_id, revno, merge_depth)
 
1218
    (if there is no revno for a revision, None is supplied)
 
1219
    """
 
1220
    if not include_merges:
 
1221
        revision_ids = mainline_revs[1:]
 
1222
        if direction == 'reverse':
 
1223
            revision_ids.reverse()
 
1224
        for revision_id in revision_ids:
 
1225
            yield revision_id, str(rev_nos[revision_id]), 0
 
1226
        return
 
1227
    graph = branch.repository.get_graph()
 
1228
    # This asks for all mainline revisions, which means we only have to spider
 
1229
    # sideways, rather than depth history. That said, its still size-of-history
 
1230
    # and should be addressed.
 
1231
    # mainline_revisions always includes an extra revision at the beginning, so
 
1232
    # don't request it.
 
1233
    parent_map = dict(((key, value) for key, value in
 
1234
        graph.iter_ancestry(mainline_revs[1:]) if value is not None))
 
1235
    # filter out ghosts; merge_sort errors on ghosts.
 
1236
    rev_graph = _mod_repository._strip_NULL_ghosts(parent_map)
 
1237
    merge_sorted_revisions = tsort.merge_sort(
 
1238
        rev_graph,
 
1239
        mainline_revs[-1],
 
1240
        mainline_revs,
 
1241
        generate_revno=True)
 
1242
 
 
1243
    if direction == 'forward':
 
1244
        # forward means oldest first.
 
1245
        merge_sorted_revisions = reverse_by_depth(merge_sorted_revisions)
 
1246
    elif direction != 'reverse':
 
1247
        raise ValueError('invalid direction %r' % direction)
 
1248
 
 
1249
    for (sequence, rev_id, merge_depth, revno, end_of_merge
 
1250
         ) in merge_sorted_revisions:
 
1251
        yield rev_id, '.'.join(map(str, revno)), merge_depth
 
1252
 
 
1253
 
1291
1254
def reverse_by_depth(merge_sorted_revisions, _depth=0):
1292
1255
    """Reverse revisions by depth.
1293
1256
 
1294
1257
    Revisions with a different depth are sorted as a group with the previous
1295
 
    revision of that depth.  There may be no topological justification for this
 
1258
    revision of that depth.  There may be no topological justification for this,
1296
1259
    but it looks much nicer.
1297
1260
    """
1298
1261
    # Add a fake revision at start so that we can always attach sub revisions
1328
1291
    """
1329
1292
 
1330
1293
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
1331
 
                 tags=None, diff=None, signature=None):
 
1294
                 tags=None, diff=None):
1332
1295
        self.rev = rev
1333
 
        if revno is None:
1334
 
            self.revno = None
1335
 
        else:
1336
 
            self.revno = str(revno)
 
1296
        self.revno = str(revno)
1337
1297
        self.merge_depth = merge_depth
1338
1298
        self.delta = delta
1339
1299
        self.tags = tags
1340
1300
        self.diff = diff
1341
 
        self.signature = signature
1342
1301
 
1343
1302
 
1344
1303
class LogFormatter(object):
1353
1312
    to indicate which LogRevision attributes it supports:
1354
1313
 
1355
1314
    - supports_delta must be True if this log formatter supports delta.
1356
 
      Otherwise the delta attribute may not be populated.  The 'delta_format'
1357
 
      attribute describes whether the 'short_status' format (1) or the long
1358
 
      one (2) should be used.
 
1315
        Otherwise the delta attribute may not be populated.  The 'delta_format'
 
1316
        attribute describes whether the 'short_status' format (1) or the long
 
1317
        one (2) should be used.
1359
1318
 
1360
1319
    - supports_merge_revisions must be True if this log formatter supports
1361
 
      merge revisions.  If not, then only mainline revisions will be passed
1362
 
      to the formatter.
 
1320
        merge revisions.  If not, then only mainline revisions will be passed
 
1321
        to the formatter.
1363
1322
 
1364
1323
    - preferred_levels is the number of levels this formatter defaults to.
1365
 
      The default value is zero meaning display all levels.
1366
 
      This value is only relevant if supports_merge_revisions is True.
 
1324
        The default value is zero meaning display all levels.
 
1325
        This value is only relevant if supports_merge_revisions is True.
1367
1326
 
1368
1327
    - supports_tags must be True if this log formatter supports tags.
1369
 
      Otherwise the tags attribute may not be populated.
 
1328
        Otherwise the tags attribute may not be populated.
1370
1329
 
1371
1330
    - supports_diff must be True if this log formatter supports diffs.
1372
 
      Otherwise the diff attribute may not be populated.
1373
 
 
1374
 
    - supports_signatures must be True if this log formatter supports GPG
1375
 
      signatures.
 
1331
        Otherwise the diff attribute may not be populated.
1376
1332
 
1377
1333
    Plugins can register functions to show custom revision properties using
1378
1334
    the properties_handler_registry. The registered function
1379
 
    must respect the following interface description::
1380
 
 
 
1335
    must respect the following interface description:
1381
1336
        def my_show_properties(properties_dict):
1382
1337
            # code that returns a dict {'name':'value'} of the properties
1383
1338
            # to be shown
1386
1341
 
1387
1342
    def __init__(self, to_file, show_ids=False, show_timezone='original',
1388
1343
                 delta_format=None, levels=None, show_advice=False,
1389
 
                 to_exact_file=None, author_list_handler=None):
 
1344
                 to_exact_file=None):
1390
1345
        """Create a LogFormatter.
1391
1346
 
1392
1347
        :param to_file: the file to output to
1393
 
        :param to_exact_file: if set, gives an output stream to which
 
1348
        :param to_exact_file: if set, gives an output stream to which 
1394
1349
             non-Unicode diffs are written.
1395
1350
        :param show_ids: if True, revision-ids are to be displayed
1396
1351
        :param show_timezone: the timezone to use
1400
1355
          let the log formatter decide.
1401
1356
        :param show_advice: whether to show advice at the end of the
1402
1357
          log or not
1403
 
        :param author_list_handler: callable generating a list of
1404
 
          authors to display for a given revision
1405
1358
        """
1406
1359
        self.to_file = to_file
1407
1360
        # 'exact' stream used to show diff, it should print content 'as is'
1408
 
        # and should not try to decode/encode it to unicode to avoid bug
1409
 
        # #328007
 
1361
        # and should not try to decode/encode it to unicode to avoid bug #328007
1410
1362
        if to_exact_file is not None:
1411
1363
            self.to_exact_file = to_exact_file
1412
1364
        else:
1413
 
            # XXX: somewhat hacky; this assumes it's a codec writer; it's
1414
 
            # better for code that expects to get diffs to pass in the exact
1415
 
            # file stream
 
1365
            # XXX: somewhat hacky; this assumes it's a codec writer; it's better
 
1366
            # for code that expects to get diffs to pass in the exact file
 
1367
            # stream
1416
1368
            self.to_exact_file = getattr(to_file, 'stream', to_file)
1417
1369
        self.show_ids = show_ids
1418
1370
        self.show_timezone = show_timezone
1419
1371
        if delta_format is None:
1420
1372
            # Ensures backward compatibility
1421
 
            delta_format = 2  # long format
 
1373
            delta_format = 2 # long format
1422
1374
        self.delta_format = delta_format
1423
1375
        self.levels = levels
1424
1376
        self._show_advice = show_advice
1425
1377
        self._merge_count = 0
1426
 
        self._author_list_handler = author_list_handler
1427
1378
 
1428
1379
    def get_levels(self):
1429
1380
        """Get the number of levels to display or 0 for all."""
1448
1399
            if advice_sep:
1449
1400
                self.to_file.write(advice_sep)
1450
1401
            self.to_file.write(
1451
 
                "Use --include-merged or -n0 to see merged revisions.\n")
 
1402
                "Use --include-merges or -n0 to see merged revisions.\n")
1452
1403
 
1453
1404
    def get_advice_separator(self):
1454
1405
        """Get the text separating the log from the closing advice."""
1461
1412
        return address
1462
1413
 
1463
1414
    def short_author(self, rev):
1464
 
        return self.authors(rev, 'first', short=True, sep=', ')
1465
 
 
1466
 
    def authors(self, rev, who, short=False, sep=None):
1467
 
        """Generate list of authors, taking --authors option into account.
1468
 
 
1469
 
        The caller has to specify the name of a author list handler,
1470
 
        as provided by the author list registry, using the ``who``
1471
 
        argument.  That name only sets a default, though: when the
1472
 
        user selected a different author list generation using the
1473
 
        ``--authors`` command line switch, as represented by the
1474
 
        ``author_list_handler`` constructor argument, that value takes
1475
 
        precedence.
1476
 
 
1477
 
        :param rev: The revision for which to generate the list of authors.
1478
 
        :param who: Name of the default handler.
1479
 
        :param short: Whether to shorten names to either name or address.
1480
 
        :param sep: What separator to use for automatic concatenation.
1481
 
        """
1482
 
        if self._author_list_handler is not None:
1483
 
            # The user did specify --authors, which overrides the default
1484
 
            author_list_handler = self._author_list_handler
1485
 
        else:
1486
 
            # The user didn't specify --authors, so we use the caller's default
1487
 
            author_list_handler = author_list_registry.get(who)
1488
 
        names = author_list_handler(rev)
1489
 
        if short:
1490
 
            for i in range(len(names)):
1491
 
                name, address = config.parse_username(names[i])
1492
 
                if name:
1493
 
                    names[i] = name
1494
 
                else:
1495
 
                    names[i] = address
1496
 
        if sep is not None:
1497
 
            names = sep.join(names)
1498
 
        return names
 
1415
        name, address = config.parse_username(rev.get_apparent_authors()[0])
 
1416
        if name:
 
1417
            return name
 
1418
        return address
1499
1419
 
1500
1420
    def merge_marker(self, revision):
1501
1421
        """Get the merge marker to include in the output or '' if none."""
1536
1456
                rev.mapping.vcs.show_foreign_revid(rev.foreign_revid))
1537
1457
 
1538
1458
        # Imported foreign revision revision ids always contain :
1539
 
        if b":" not in rev.revision_id:
 
1459
        if not ":" in rev.revision_id:
1540
1460
            return []
1541
1461
 
1542
1462
        # Revision was once imported from a foreign repository
1556
1476
        return lines
1557
1477
 
1558
1478
    def show_diff(self, to_file, diff, indent):
1559
 
        encoding = get_terminal_encoding()
1560
 
        for l in diff.rstrip().split(b'\n'):
1561
 
            to_file.write(indent + l.decode(encoding, 'ignore') + '\n')
 
1479
        for l in diff.rstrip().split('\n'):
 
1480
            to_file.write(indent + '%s\n' % (l,))
1562
1481
 
1563
1482
 
1564
1483
# Separator between revisions in long format
1572
1491
    supports_delta = True
1573
1492
    supports_tags = True
1574
1493
    supports_diff = True
1575
 
    supports_signatures = True
1576
1494
 
1577
1495
    def __init__(self, *args, **kwargs):
1578
1496
        super(LongLogFormatter, self).__init__(*args, **kwargs)
1587
1505
 
1588
1506
    def _date_string_original_timezone(self, rev):
1589
1507
        return format_date_with_offset_in_original_timezone(rev.timestamp,
1590
 
                                                            rev.timezone or 0)
 
1508
            rev.timezone or 0)
1591
1509
 
1592
1510
    def log_revision(self, revision):
1593
1511
        """Log a revision, either merged or not."""
1595
1513
        lines = [_LONG_SEP]
1596
1514
        if revision.revno is not None:
1597
1515
            lines.append('revno: %s%s' % (revision.revno,
1598
 
                                          self.merge_marker(revision)))
 
1516
                self.merge_marker(revision)))
1599
1517
        if revision.tags:
1600
 
            lines.append('tags: %s' % (', '.join(sorted(revision.tags))))
1601
 
        if self.show_ids or revision.revno is None:
1602
 
            lines.append('revision-id: %s' %
1603
 
                         (revision.rev.revision_id.decode('utf-8'),))
 
1518
            lines.append('tags: %s' % (', '.join(revision.tags)))
1604
1519
        if self.show_ids:
 
1520
            lines.append('revision-id: %s' % (revision.rev.revision_id,))
1605
1521
            for parent_id in revision.rev.parent_ids:
1606
 
                lines.append('parent: %s' % (parent_id.decode('utf-8'),))
 
1522
                lines.append('parent: %s' % (parent_id,))
1607
1523
        lines.extend(self.custom_properties(revision.rev))
1608
1524
 
1609
1525
        committer = revision.rev.committer
1610
 
        authors = self.authors(revision.rev, 'all')
 
1526
        authors = revision.rev.get_apparent_authors()
1611
1527
        if authors != [committer]:
1612
1528
            lines.append('author: %s' % (", ".join(authors),))
1613
1529
        lines.append('committer: %s' % (committer,))
1618
1534
 
1619
1535
        lines.append('timestamp: %s' % (self.date_string(revision.rev),))
1620
1536
 
1621
 
        if revision.signature is not None:
1622
 
            lines.append('signature: ' + revision.signature)
1623
 
 
1624
1537
        lines.append('message:')
1625
1538
        if not revision.rev.message:
1626
1539
            lines.append('  (no message)')
1634
1547
        to_file.write("%s%s\n" % (indent, ('\n' + indent).join(lines)))
1635
1548
        if revision.delta is not None:
1636
1549
            # Use the standard status output to display changes
1637
 
            from breezy.delta import report_delta
1638
 
            report_delta(to_file, revision.delta, short_status=False,
 
1550
            from bzrlib.delta import report_delta
 
1551
            report_delta(to_file, revision.delta, short_status=False, 
1639
1552
                         show_ids=self.show_ids, indent=indent)
1640
1553
        if revision.diff is not None:
1641
1554
            to_file.write(indent + 'diff:\n')
1673
1586
        indent = '    ' * depth
1674
1587
        revno_width = self.revno_width_by_depth.get(depth)
1675
1588
        if revno_width is None:
1676
 
            if revision.revno is None or revision.revno.find('.') == -1:
 
1589
            if revision.revno.find('.') == -1:
1677
1590
                # mainline revno, e.g. 12345
1678
1591
                revno_width = 5
1679
1592
            else:
1685
1598
        to_file = self.to_file
1686
1599
        tags = ''
1687
1600
        if revision.tags:
1688
 
            tags = ' {%s}' % (', '.join(sorted(revision.tags)))
 
1601
            tags = ' {%s}' % (', '.join(revision.tags))
1689
1602
        to_file.write(indent + "%*s %s\t%s%s%s\n" % (revno_width,
1690
 
                                                     revision.revno or "", self.short_author(
1691
 
                                                         revision.rev),
1692
 
                                                     format_date(revision.rev.timestamp,
1693
 
                                                                 revision.rev.timezone or 0,
1694
 
                                                                 self.show_timezone, date_fmt="%Y-%m-%d",
1695
 
                                                                 show_offset=False),
1696
 
                                                     tags, self.merge_marker(revision)))
1697
 
        self.show_properties(revision.rev, indent + offset)
1698
 
        if self.show_ids or revision.revno is None:
 
1603
                revision.revno, self.short_author(revision.rev),
 
1604
                format_date(revision.rev.timestamp,
 
1605
                            revision.rev.timezone or 0,
 
1606
                            self.show_timezone, date_fmt="%Y-%m-%d",
 
1607
                            show_offset=False),
 
1608
                tags, self.merge_marker(revision)))
 
1609
        self.show_properties(revision.rev, indent+offset)
 
1610
        if self.show_ids:
1699
1611
            to_file.write(indent + offset + 'revision-id:%s\n'
1700
 
                          % (revision.rev.revision_id.decode('utf-8'),))
 
1612
                          % (revision.rev.revision_id,))
1701
1613
        if not revision.rev.message:
1702
1614
            to_file.write(indent + offset + '(no message)\n')
1703
1615
        else:
1707
1619
 
1708
1620
        if revision.delta is not None:
1709
1621
            # Use the standard status output to display changes
1710
 
            from breezy.delta import report_delta
1711
 
            report_delta(to_file, revision.delta,
1712
 
                         short_status=self.delta_format == 1,
 
1622
            from bzrlib.delta import report_delta
 
1623
            report_delta(to_file, revision.delta, 
 
1624
                         short_status=self.delta_format==1, 
1713
1625
                         show_ids=self.show_ids, indent=indent + offset)
1714
1626
        if revision.diff is not None:
1715
1627
            self.show_diff(self.to_exact_file, revision.diff, '      ')
1733
1645
    def truncate(self, str, max_len):
1734
1646
        if max_len is None or len(str) <= max_len:
1735
1647
            return str
1736
 
        return str[:max_len - 3] + '...'
 
1648
        return str[:max_len-3] + '...'
1737
1649
 
1738
1650
    def date_string(self, rev):
1739
1651
        return format_date(rev.timestamp, rev.timezone or 0,
1749
1661
    def log_revision(self, revision):
1750
1662
        indent = '  ' * revision.merge_depth
1751
1663
        self.to_file.write(self.log_string(revision.revno, revision.rev,
1752
 
                                           self._max_chars, revision.tags, indent))
 
1664
            self._max_chars, revision.tags, indent))
1753
1665
        self.to_file.write('\n')
1754
1666
 
1755
1667
    def log_string(self, revno, rev, max_chars, tags=None, prefix=''):
1756
1668
        """Format log info into one string. Truncate tail of string
1757
 
 
1758
 
        :param revno:      revision number or None.
1759
 
                           Revision numbers counts from 1.
1760
 
        :param rev:        revision object
1761
 
        :param max_chars:  maximum length of resulting string
1762
 
        :param tags:       list of tags or None
1763
 
        :param prefix:     string to prefix each line
1764
 
        :return:           formatted truncated string
 
1669
        :param  revno:      revision number or None.
 
1670
                            Revision numbers counts from 1.
 
1671
        :param  rev:        revision object
 
1672
        :param  max_chars:  maximum length of resulting string
 
1673
        :param  tags:       list of tags or None
 
1674
        :param  prefix:     string to prefix each line
 
1675
        :return:            formatted truncated string
1765
1676
        """
1766
1677
        out = []
1767
1678
        if revno:
1768
1679
            # show revno only when is not None
1769
1680
            out.append("%s:" % revno)
1770
 
        if max_chars is not None:
1771
 
            out.append(self.truncate(
1772
 
                self.short_author(rev), (max_chars + 3) // 4))
1773
 
        else:
1774
 
            out.append(self.short_author(rev))
 
1681
        out.append(self.truncate(self.short_author(rev), 20))
1775
1682
        out.append(self.date_string(rev))
1776
1683
        if len(rev.parent_ids) > 1:
1777
1684
            out.append('[merge]')
1778
1685
        if tags:
1779
 
            tag_str = '{%s}' % (', '.join(sorted(tags)))
 
1686
            tag_str = '{%s}' % (', '.join(tags))
1780
1687
            out.append(tag_str)
1781
1688
        out.append(rev.get_summary())
1782
1689
        return self.truncate(prefix + " ".join(out).rstrip('\n'), max_chars)
1796
1703
                               self.show_timezone,
1797
1704
                               date_fmt='%Y-%m-%d',
1798
1705
                               show_offset=False)
1799
 
        committer_str = self.authors(revision.rev, 'first', sep=', ')
1800
 
        committer_str = committer_str.replace(' <', '  <')
1801
 
        to_file.write('%s  %s\n\n' % (date_str, committer_str))
 
1706
        committer_str = revision.rev.get_apparent_authors()[0].replace (' <', '  <')
 
1707
        to_file.write('%s  %s\n\n' % (date_str,committer_str))
1802
1708
 
1803
1709
        if revision.delta is not None and revision.delta.has_changed():
1804
1710
            for c in revision.delta.added + revision.delta.removed + revision.delta.modified:
1805
1711
                path, = c[:1]
1806
1712
                to_file.write('\t* %s:\n' % (path,))
1807
1713
            for c in revision.delta.renamed:
1808
 
                oldpath, newpath = c[:2]
 
1714
                oldpath,newpath = c[:2]
1809
1715
                # For renamed files, show both the old and the new path
1810
 
                to_file.write('\t* %s:\n\t* %s:\n' % (oldpath, newpath))
 
1716
                to_file.write('\t* %s:\n\t* %s:\n' % (oldpath,newpath))
1811
1717
            to_file.write('\n')
1812
1718
 
1813
1719
        if not revision.rev.message:
1836
1742
        return self.get(name)(*args, **kwargs)
1837
1743
 
1838
1744
    def get_default(self, branch):
1839
 
        c = branch.get_config_stack()
1840
 
        return self.get(c.get('log_format'))
 
1745
        return self.get(branch.get_config().log_format())
1841
1746
 
1842
1747
 
1843
1748
log_formatter_registry = LogFormatterRegistry()
1844
1749
 
1845
1750
 
1846
1751
log_formatter_registry.register('short', ShortLogFormatter,
1847
 
                                'Moderately short log format.')
 
1752
                                'Moderately short log format')
1848
1753
log_formatter_registry.register('long', LongLogFormatter,
1849
 
                                'Detailed log format.')
 
1754
                                'Detailed log format')
1850
1755
log_formatter_registry.register('line', LineLogFormatter,
1851
 
                                'Log format with one line per revision.')
 
1756
                                'Log format with one line per revision')
1852
1757
log_formatter_registry.register('gnu-changelog', GnuChangelogLogFormatter,
1853
 
                                'Format used by GNU ChangeLog files.')
 
1758
                                'Format used by GNU ChangeLog files')
1854
1759
 
1855
1760
 
1856
1761
def register_formatter(name, formatter):
1866
1771
    try:
1867
1772
        return log_formatter_registry.make_formatter(name, *args, **kwargs)
1868
1773
    except KeyError:
1869
 
        raise errors.BzrCommandError(
1870
 
            gettext("unknown log formatter: %r") % name)
1871
 
 
1872
 
 
1873
 
def author_list_all(rev):
1874
 
    return rev.get_apparent_authors()[:]
1875
 
 
1876
 
 
1877
 
def author_list_first(rev):
1878
 
    lst = rev.get_apparent_authors()
1879
 
    try:
1880
 
        return [lst[0]]
1881
 
    except IndexError:
1882
 
        return []
1883
 
 
1884
 
 
1885
 
def author_list_committer(rev):
1886
 
    return [rev.committer]
1887
 
 
1888
 
 
1889
 
author_list_registry = registry.Registry()
1890
 
 
1891
 
author_list_registry.register('all', author_list_all,
1892
 
                              'All authors')
1893
 
 
1894
 
author_list_registry.register('first', author_list_first,
1895
 
                              'The first author')
1896
 
 
1897
 
author_list_registry.register('committer', author_list_committer,
1898
 
                              'The committer')
 
1774
        raise errors.BzrCommandError("unknown log formatter: %r" % name)
 
1775
 
 
1776
 
 
1777
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
 
1778
    # deprecated; for compatibility
 
1779
    lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
 
1780
    lf.show(revno, rev, delta)
1899
1781
 
1900
1782
 
1901
1783
def show_changed_revisions(branch, old_rh, new_rh, to_file=None,
1909
1791
    """
1910
1792
    if to_file is None:
1911
1793
        to_file = codecs.getwriter(get_terminal_encoding())(sys.stdout,
1912
 
                                                            errors='replace')
 
1794
            errors='replace')
1913
1795
    lf = log_formatter(log_format,
1914
1796
                       show_ids=False,
1915
1797
                       to_file=to_file,
1918
1800
    # This is the first index which is different between
1919
1801
    # old and new
1920
1802
    base_idx = None
1921
 
    for i in range(max(len(new_rh), len(old_rh))):
 
1803
    for i in xrange(max(len(new_rh),
 
1804
                        len(old_rh))):
1922
1805
        if (len(new_rh) <= i
1923
1806
            or len(old_rh) <= i
1924
 
                or new_rh[i] != old_rh[i]):
 
1807
            or new_rh[i] != old_rh[i]):
1925
1808
            base_idx = i
1926
1809
            break
1927
1810
 
1928
1811
    if base_idx is None:
1929
1812
        to_file.write('Nothing seems to have changed\n')
1930
1813
        return
1931
 
    # TODO: It might be nice to do something like show_log
1932
 
    # and show the merged entries. But since this is the
1933
 
    # removed revisions, it shouldn't be as important
 
1814
    ## TODO: It might be nice to do something like show_log
 
1815
    ##       and show the merged entries. But since this is the
 
1816
    ##       removed revisions, it shouldn't be as important
1934
1817
    if base_idx < len(old_rh):
1935
 
        to_file.write('*' * 60)
 
1818
        to_file.write('*'*60)
1936
1819
        to_file.write('\nRemoved Revisions:\n')
1937
1820
        for i in range(base_idx, len(old_rh)):
1938
1821
            rev = branch.repository.get_revision(old_rh[i])
1939
 
            lr = LogRevision(rev, i + 1, 0, None)
 
1822
            lr = LogRevision(rev, i+1, 0, None)
1940
1823
            lf.log_revision(lr)
1941
 
        to_file.write('*' * 60)
 
1824
        to_file.write('*'*60)
1942
1825
        to_file.write('\n\n')
1943
1826
    if base_idx < len(new_rh):
1944
1827
        to_file.write('Added Revisions:\n')
1947
1830
                 None,
1948
1831
                 verbose=False,
1949
1832
                 direction='forward',
1950
 
                 start_revision=base_idx + 1,
 
1833
                 start_revision=base_idx+1,
1951
1834
                 end_revision=len(new_rh),
1952
1835
                 search=None)
1953
1836
 
1965
1848
    old_revisions = set()
1966
1849
    new_history = []
1967
1850
    new_revisions = set()
1968
 
    graph = repository.get_graph()
1969
 
    new_iter = graph.iter_lefthand_ancestry(new_revision_id)
1970
 
    old_iter = graph.iter_lefthand_ancestry(old_revision_id)
 
1851
    new_iter = repository.iter_reverse_revision_history(new_revision_id)
 
1852
    old_iter = repository.iter_reverse_revision_history(old_revision_id)
1971
1853
    stop_revision = None
1972
1854
    do_old = True
1973
1855
    do_new = True
1974
1856
    while do_new or do_old:
1975
1857
        if do_new:
1976
1858
            try:
1977
 
                new_revision = next(new_iter)
 
1859
                new_revision = new_iter.next()
1978
1860
            except StopIteration:
1979
1861
                do_new = False
1980
1862
            else:
1985
1867
                    break
1986
1868
        if do_old:
1987
1869
            try:
1988
 
                old_revision = next(old_iter)
 
1870
                old_revision = old_iter.next()
1989
1871
            except StopIteration:
1990
1872
                do_old = False
1991
1873
            else:
2021
1903
    log_format = log_formatter_registry.get_default(branch)
2022
1904
    lf = log_format(show_ids=False, to_file=output, show_timezone='original')
2023
1905
    if old_history != []:
2024
 
        output.write('*' * 60)
 
1906
        output.write('*'*60)
2025
1907
        output.write('\nRemoved Revisions:\n')
2026
1908
        show_flat_log(branch.repository, old_history, old_revno, lf)
2027
 
        output.write('*' * 60)
 
1909
        output.write('*'*60)
2028
1910
        output.write('\n\n')
2029
1911
    if new_history != []:
2030
1912
        output.write('Added Revisions:\n')
2031
1913
        start_revno = new_revno - len(new_history) + 1
2032
1914
        show_log(branch, lf, None, verbose=False, direction='forward',
2033
 
                 start_revision=start_revno)
 
1915
                 start_revision=start_revno,)
2034
1916
 
2035
1917
 
2036
1918
def show_flat_log(repository, history, last_revno, lf):
2041
1923
    :param last_revno: The revno of the last revision_id in the history.
2042
1924
    :param lf: The log formatter to use.
2043
1925
    """
 
1926
    start_revno = last_revno - len(history) + 1
2044
1927
    revisions = repository.get_revisions(history)
2045
1928
    for i, rev in enumerate(revisions):
2046
1929
        lr = LogRevision(rev, i + last_revno, 0, None)
2047
1930
        lf.log_revision(lr)
2048
1931
 
2049
1932
 
2050
 
def _get_info_for_log_files(revisionspec_list, file_list, add_cleanup):
 
1933
def _get_info_for_log_files(revisionspec_list, file_list):
2051
1934
    """Find file-ids and kinds given a list of files and a revision range.
2052
1935
 
2053
1936
    We search for files at the end of the range. If not found there,
2057
1940
    :param file_list: the list of paths given on the command line;
2058
1941
      the first of these can be a branch location or a file path,
2059
1942
      the remainder must be file paths
2060
 
    :param add_cleanup: When the branch returned is read locked,
2061
 
      an unlock call will be queued to the cleanup.
2062
1943
    :return: (branch, info_list, start_rev_info, end_rev_info) where
2063
1944
      info_list is a list of (relative_path, file_id, kind) tuples where
2064
1945
      kind is one of values 'directory', 'file', 'symlink', 'tree-reference'.
2065
1946
      branch will be read-locked.
2066
1947
    """
2067
 
    from breezy.builtins import _get_revision_range
2068
 
    tree, b, path = controldir.ControlDir.open_containing_tree_or_branch(
2069
 
        file_list[0])
2070
 
    add_cleanup(b.lock_read().unlock)
 
1948
    from builtins import _get_revision_range, safe_relpath_files
 
1949
    tree, b, path = bzrdir.BzrDir.open_containing_tree_or_branch(file_list[0])
 
1950
    b.lock_read()
2071
1951
    # XXX: It's damn messy converting a list of paths to relative paths when
2072
1952
    # those paths might be deleted ones, they might be on a case-insensitive
2073
1953
    # filesystem and/or they might be in silly locations (like another branch).
2077
1957
    # case of running log in a nested directory, assuming paths beyond the
2078
1958
    # first one haven't been deleted ...
2079
1959
    if tree:
2080
 
        relpaths = [path] + tree.safe_relpath_files(file_list[1:])
 
1960
        relpaths = [path] + safe_relpath_files(tree, file_list[1:])
2081
1961
    else:
2082
1962
        relpaths = [path] + file_list[1:]
2083
1963
    info_list = []
2084
1964
    start_rev_info, end_rev_info = _get_revision_range(revisionspec_list, b,
2085
 
                                                       "log")
 
1965
        "log")
2086
1966
    if relpaths in ([], [u'']):
2087
1967
        return b, [], start_rev_info, end_rev_info
2088
1968
    if start_rev_info is None and end_rev_info is None:
2091
1971
        tree1 = None
2092
1972
        for fp in relpaths:
2093
1973
            file_id = tree.path2id(fp)
2094
 
            kind = _get_kind_for_file_id(tree, fp, file_id)
 
1974
            kind = _get_kind_for_file_id(tree, file_id)
2095
1975
            if file_id is None:
2096
1976
                # go back to when time began
2097
1977
                if tree1 is None:
2105
1985
                        tree1 = b.repository.revision_tree(rev1)
2106
1986
                if tree1:
2107
1987
                    file_id = tree1.path2id(fp)
2108
 
                    kind = _get_kind_for_file_id(tree1, fp, file_id)
 
1988
                    kind = _get_kind_for_file_id(tree1, file_id)
2109
1989
            info_list.append((fp, file_id, kind))
2110
1990
 
2111
1991
    elif start_rev_info == end_rev_info:
2113
1993
        tree = b.repository.revision_tree(end_rev_info.rev_id)
2114
1994
        for fp in relpaths:
2115
1995
            file_id = tree.path2id(fp)
2116
 
            kind = _get_kind_for_file_id(tree, fp, file_id)
 
1996
            kind = _get_kind_for_file_id(tree, file_id)
2117
1997
            info_list.append((fp, file_id, kind))
2118
1998
 
2119
1999
    else:
2127
2007
        tree1 = None
2128
2008
        for fp in relpaths:
2129
2009
            file_id = tree.path2id(fp)
2130
 
            kind = _get_kind_for_file_id(tree, fp, file_id)
 
2010
            kind = _get_kind_for_file_id(tree, file_id)
2131
2011
            if file_id is None:
2132
2012
                if tree1 is None:
2133
2013
                    rev_id = start_rev_info.rev_id
2137
2017
                    else:
2138
2018
                        tree1 = b.repository.revision_tree(rev_id)
2139
2019
                file_id = tree1.path2id(fp)
2140
 
                kind = _get_kind_for_file_id(tree1, fp, file_id)
 
2020
                kind = _get_kind_for_file_id(tree1, file_id)
2141
2021
            info_list.append((fp, file_id, kind))
2142
2022
    return b, info_list, start_rev_info, end_rev_info
2143
2023
 
2144
2024
 
2145
 
def _get_kind_for_file_id(tree, path, file_id):
 
2025
def _get_kind_for_file_id(tree, file_id):
2146
2026
    """Return the kind of a file-id or None if it doesn't exist."""
2147
2027
    if file_id is not None:
2148
 
        return tree.kind(path)
 
2028
        return tree.kind(file_id)
2149
2029
    else:
2150
2030
        return None
2151
2031
 
2153
2033
properties_handler_registry = registry.Registry()
2154
2034
 
2155
2035
# Use the properties handlers to print out bug information if available
2156
 
 
2157
 
 
2158
2036
def _bugs_properties_handler(revision):
2159
 
    ret = {}
2160
 
    if 'bugs' in revision.properties:
 
2037
    if revision.properties.has_key('bugs'):
2161
2038
        bug_lines = revision.properties['bugs'].split('\n')
2162
2039
        bug_rows = [line.split(' ', 1) for line in bug_lines]
2163
2040
        fixed_bug_urls = [row[0] for row in bug_rows if
2164
2041
                          len(row) > 1 and row[1] == 'fixed']
2165
 
        related_bug_urls = [row[0] for row in bug_rows if
2166
 
                            len(row) > 1 and row[1] == 'related']
 
2042
 
2167
2043
        if fixed_bug_urls:
2168
 
            text = ngettext('fixes bug', 'fixes bugs', len(fixed_bug_urls))
2169
 
            ret[text] = ' '.join(fixed_bug_urls)
2170
 
        if related_bug_urls:
2171
 
            text = ngettext('related bug', 'related bugs',
2172
 
                            len(related_bug_urls))
2173
 
            ret[text] = ' '.join(related_bug_urls)
2174
 
    return ret
2175
 
 
 
2044
            return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
 
2045
    return {}
2176
2046
 
2177
2047
properties_handler_registry.register('bugs_properties_handler',
2178
2048
                                     _bugs_properties_handler)