~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: Andrew Bennetts
  • Date: 2010-07-29 11:17:57 UTC
  • mfrom: (5050.3.17 2.2)
  • mto: This revision was merged to the branch mainline in revision 5365.
  • Revision ID: andrew.bennetts@canonical.com-20100729111757-018h3pcefo7z0dnq
Merge lp:bzr/2.2 into lp:bzr.

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
65
65
lazy_import(globals(), """
66
66
 
67
67
from bzrlib import (
 
68
    bzrdir,
68
69
    config,
69
 
    controldir,
70
70
    diff,
71
71
    errors,
72
72
    foreign,
 
73
    osutils,
73
74
    repository as _mod_repository,
74
75
    revision as _mod_revision,
75
76
    revisionspec,
 
77
    trace,
76
78
    tsort,
77
79
    )
78
 
from bzrlib.i18n import gettext, ngettext
79
80
""")
80
81
 
81
82
from bzrlib import (
82
 
    lazy_regex,
83
83
    registry,
84
84
    )
85
85
from bzrlib.osutils import (
86
86
    format_date,
87
87
    format_date_with_offset_in_original_timezone,
88
 
    get_diff_header_encoding,
89
88
    get_terminal_encoding,
90
89
    terminal_width,
91
90
    )
 
91
from bzrlib.symbol_versioning import (
 
92
    deprecated_function,
 
93
    deprecated_in,
 
94
    )
92
95
 
93
96
 
94
97
def find_touching_revisions(branch, file_id):
105
108
    last_ie = None
106
109
    last_path = None
107
110
    revno = 1
108
 
    graph = branch.repository.get_graph()
109
 
    history = list(graph.iter_lefthand_ancestry(branch.last_revision(),
110
 
        [_mod_revision.NULL_REVISION]))
111
 
    for revision_id in reversed(history):
 
111
    for revision_id in branch.revision_history():
112
112
        this_inv = branch.repository.get_inventory(revision_id)
113
 
        if this_inv.has_id(file_id):
 
113
        if file_id in this_inv:
114
114
            this_ie = this_inv[file_id]
115
115
            this_path = this_inv.id2path(file_id)
116
116
        else:
156
156
             end_revision=None,
157
157
             search=None,
158
158
             limit=None,
159
 
             show_diff=False,
160
 
             match=None):
 
159
             show_diff=False):
161
160
    """Write out human-readable log of commits to this branch.
162
161
 
163
162
    This function is being retained for backwards compatibility but
186
185
        if None or 0.
187
186
 
188
187
    :param show_diff: If True, output a diff after each revision.
189
 
 
190
 
    :param match: Dictionary of search lists to use when matching revision
191
 
      properties.
192
188
    """
193
189
    # Convert old-style parameters to new-style parameters
194
190
    if specific_fileid is not None:
218
214
    Logger(branch, rqst).show(lf)
219
215
 
220
216
 
221
 
# 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
222
218
# make_log_request_dict() below
223
219
_DEFAULT_REQUEST_PARAMS = {
224
220
    'direction': 'reverse',
225
 
    'levels': None,
 
221
    'levels': 1,
226
222
    'generate_tags': True,
227
223
    'exclude_common_ancestry': False,
228
224
    '_match_using_deltas': True,
231
227
 
232
228
def make_log_request_dict(direction='reverse', specific_fileids=None,
233
229
                          start_revision=None, end_revision=None, limit=None,
234
 
                          message_search=None, levels=None, generate_tags=True,
 
230
                          message_search=None, levels=1, generate_tags=True,
235
231
                          delta_type=None,
236
232
                          diff_type=None, _match_using_deltas=True,
237
 
                          exclude_common_ancestry=False, match=None,
238
 
                          signature=False, omit_merges=False,
 
233
                          exclude_common_ancestry=False,
239
234
                          ):
240
235
    """Convenience function for making a logging request dictionary.
241
236
 
262
257
      matching commit messages
263
258
 
264
259
    :param levels: the number of levels of revisions to
265
 
      generate; 1 for just the mainline; 0 for all levels, or None for
266
 
      a sensible default.
 
260
      generate; 1 for just the mainline; 0 for all levels.
267
261
 
268
262
    :param generate_tags: If True, include tags for matched revisions.
269
 
`
 
263
 
270
264
    :param delta_type: Either 'full', 'partial' or None.
271
265
      'full' means generate the complete delta - adds/deletes/modifies/etc;
272
266
      'partial' means filter the delta using specific_fileids;
284
278
 
285
279
    :param exclude_common_ancestry: Whether -rX..Y should be interpreted as a
286
280
      range operator or as a graph difference.
287
 
 
288
 
    :param signature: show digital signature information
289
 
 
290
 
    :param match: Dictionary of list of search strings to use when filtering
291
 
      revisions. Keys can be 'message', 'author', 'committer', 'bugs' or
292
 
      the empty string to match any of the preceding properties.
293
 
 
294
 
    :param omit_merges: If True, commits with more than one parent are
295
 
      omitted.
296
 
 
297
281
    """
298
 
    # Take care of old style message_search parameter
299
 
    if message_search:
300
 
        if match:
301
 
            if 'message' in match:
302
 
                match['message'].append(message_search)
303
 
            else:
304
 
                match['message'] = [message_search]
305
 
        else:
306
 
            match={ 'message': [message_search] }
307
282
    return {
308
283
        'direction': direction,
309
284
        'specific_fileids': specific_fileids,
310
285
        'start_revision': start_revision,
311
286
        'end_revision': end_revision,
312
287
        'limit': limit,
 
288
        'message_search': message_search,
313
289
        'levels': levels,
314
290
        'generate_tags': generate_tags,
315
291
        'delta_type': delta_type,
316
292
        'diff_type': diff_type,
317
293
        'exclude_common_ancestry': exclude_common_ancestry,
318
 
        'signature': signature,
319
 
        'match': match,
320
 
        'omit_merges': omit_merges,
321
294
        # Add 'private' attributes for features that may be deprecated
322
295
        '_match_using_deltas': _match_using_deltas,
323
296
    }
325
298
 
326
299
def _apply_log_request_defaults(rqst):
327
300
    """Apply default values to a request dictionary."""
328
 
    result = _DEFAULT_REQUEST_PARAMS.copy()
 
301
    result = _DEFAULT_REQUEST_PARAMS
329
302
    if rqst:
330
303
        result.update(rqst)
331
304
    return result
332
305
 
333
306
 
334
 
def format_signature_validity(rev_id, repo):
335
 
    """get the signature validity
336
 
 
337
 
    :param rev_id: revision id to validate
338
 
    :param repo: repository of revision
339
 
    :return: human readable string to print to log
340
 
    """
341
 
    from bzrlib import gpg
342
 
 
343
 
    gpg_strategy = gpg.GPGStrategy(None)
344
 
    result = repo.verify_revision(rev_id, gpg_strategy)
345
 
    if result[0] == gpg.SIGNATURE_VALID:
346
 
        return "valid signature from {0}".format(result[1])
347
 
    if result[0] == gpg.SIGNATURE_KEY_MISSING:
348
 
        return "unknown key {0}".format(result[1])
349
 
    if result[0] == gpg.SIGNATURE_NOT_VALID:
350
 
        return "invalid signature!"
351
 
    if result[0] == gpg.SIGNATURE_NOT_SIGNED:
352
 
        return "no signature"
353
 
 
354
 
 
355
307
class LogGenerator(object):
356
308
    """A generator of log revisions."""
357
309
 
402
354
        # Tweak the LogRequest based on what the LogFormatter can handle.
403
355
        # (There's no point generating stuff if the formatter can't display it.)
404
356
        rqst = self.rqst
405
 
        if rqst['levels'] is None or lf.get_levels() > rqst['levels']:
406
 
            # user didn't specify levels, use whatever the LF can handle:
407
 
            rqst['levels'] = lf.get_levels()
408
 
 
 
357
        rqst['levels'] = lf.get_levels()
409
358
        if not getattr(lf, 'supports_tags', False):
410
359
            rqst['generate_tags'] = False
411
360
        if not getattr(lf, 'supports_delta', False):
412
361
            rqst['delta_type'] = None
413
362
        if not getattr(lf, 'supports_diff', False):
414
363
            rqst['diff_type'] = None
415
 
        if not getattr(lf, 'supports_signatures', False):
416
 
            rqst['signature'] = False
417
364
 
418
365
        # Find and print the interesting revisions
419
366
        generator = self._generator_factory(self.branch, rqst)
423
370
 
424
371
    def _generator_factory(self, branch, rqst):
425
372
        """Make the LogGenerator object to use.
426
 
 
 
373
        
427
374
        Subclasses may wish to override this.
428
375
        """
429
376
        return _DefaultLogGenerator(branch, rqst)
453
400
        levels = rqst.get('levels')
454
401
        limit = rqst.get('limit')
455
402
        diff_type = rqst.get('diff_type')
456
 
        show_signature = rqst.get('signature')
457
 
        omit_merges = rqst.get('omit_merges')
458
403
        log_count = 0
459
404
        revision_iterator = self._create_log_revision_iterator()
460
405
        for revs in revision_iterator:
462
407
                # 0 levels means show everything; merge_depth counts from 0
463
408
                if levels != 0 and merge_depth >= levels:
464
409
                    continue
465
 
                if omit_merges and len(rev.parent_ids) > 1:
466
 
                    continue
467
410
                if diff_type is None:
468
411
                    diff = None
469
412
                else:
470
413
                    diff = self._format_diff(rev, rev_id, diff_type)
471
 
                if show_signature:
472
 
                    signature = format_signature_validity(rev_id,
473
 
                                                self.branch.repository)
474
 
                else:
475
 
                    signature = None
476
414
                yield LogRevision(rev, revno, merge_depth, delta,
477
 
                    self.rev_tag_dict.get(rev_id), diff, signature)
 
415
                    self.rev_tag_dict.get(rev_id), diff)
478
416
                if limit:
479
417
                    log_count += 1
480
418
                    if log_count >= limit:
494
432
        else:
495
433
            specific_files = None
496
434
        s = StringIO()
497
 
        path_encoding = get_diff_header_encoding()
 
435
        path_encoding = osutils.get_diff_header_encoding()
498
436
        diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
499
437
            new_label='', path_encoding=path_encoding)
500
438
        return s.getvalue()
535
473
 
536
474
        # Apply the other filters
537
475
        return make_log_rev_iterator(self.branch, view_revisions,
538
 
            rqst.get('delta_type'), rqst.get('match'),
 
476
            rqst.get('delta_type'), rqst.get('message_search'),
539
477
            file_ids=rqst.get('specific_fileids'),
540
478
            direction=rqst.get('direction'))
541
479
 
554
492
            rqst.get('specific_fileids')[0], view_revisions,
555
493
            include_merges=rqst.get('levels') != 1)
556
494
        return make_log_rev_iterator(self.branch, view_revisions,
557
 
            rqst.get('delta_type'), rqst.get('match'))
 
495
            rqst.get('delta_type'), rqst.get('message_search'))
558
496
 
559
497
 
560
498
def _calc_view_revisions(branch, start_rev_id, end_rev_id, direction,
568
506
             a list of the same tuples.
569
507
    """
570
508
    if (exclude_common_ancestry and start_rev_id == end_rev_id):
571
 
        raise errors.BzrCommandError(gettext(
572
 
            '--exclude-common-ancestry requires two different revisions'))
 
509
        raise errors.BzrCommandError(
 
510
            '--exclude-common-ancestry requires two different revisions')
573
511
    if direction not in ('reverse', 'forward'):
574
 
        raise ValueError(gettext('invalid direction %r') % direction)
 
512
        raise ValueError('invalid direction %r' % direction)
575
513
    br_revno, br_rev_id = branch.last_revision_info()
576
514
    if br_revno == 0:
577
515
        return []
602
540
        # It's the tip
603
541
        return [(br_rev_id, br_revno, 0)]
604
542
    else:
605
 
        revno_str = _compute_revno_str(branch, rev_id)
 
543
        revno = branch.revision_id_to_dotted_revno(rev_id)
 
544
        revno_str = '.'.join(str(n) for n in revno)
606
545
        return [(rev_id, revno_str, 0)]
607
546
 
608
547
 
618
557
        try:
619
558
            result = list(result)
620
559
        except _StartNotLinearAncestor:
621
 
            raise errors.BzrCommandError(gettext('Start revision not found in'
622
 
                ' left-hand history of end revision.'))
 
560
            raise errors.BzrCommandError('Start revision not found in'
 
561
                ' left-hand history of end revision.')
623
562
    return result
624
563
 
625
564
 
664
603
        except _StartNotLinearAncestor:
665
604
            # A merge was never detected so the lower revision limit can't
666
605
            # be nested down somewhere
667
 
            raise errors.BzrCommandError(gettext('Start revision not found in'
668
 
                ' history of end revision.'))
 
606
            raise errors.BzrCommandError('Start revision not found in'
 
607
                ' history of end revision.')
669
608
 
670
609
    # We exit the loop above because we encounter a revision with merges, from
671
610
    # this revision, we need to switch to _graph_view_revisions.
688
627
    return len(parents) > 1
689
628
 
690
629
 
691
 
def _compute_revno_str(branch, rev_id):
692
 
    """Compute the revno string from a rev_id.
693
 
 
694
 
    :return: The revno string, or None if the revision is not in the supplied
695
 
        branch.
696
 
    """
697
 
    try:
698
 
        revno = branch.revision_id_to_dotted_revno(rev_id)
699
 
    except errors.NoSuchRevision:
700
 
        # The revision must be outside of this branch
701
 
        return None
702
 
    else:
703
 
        return '.'.join(str(n) for n in revno)
704
 
 
705
 
 
706
630
def _is_obvious_ancestor(branch, start_rev_id, end_rev_id):
707
631
    """Is start_rev_id an obvious ancestor of end_rev_id?"""
708
632
    if start_rev_id and end_rev_id:
709
 
        try:
710
 
            start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
711
 
            end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
712
 
        except errors.NoSuchRevision:
713
 
            # one or both is not in the branch; not obvious
714
 
            return False
 
633
        start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
 
634
        end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
715
635
        if len(start_dotted) == 1 and len(end_dotted) == 1:
716
636
            # both on mainline
717
637
            return start_dotted[0] <= end_dotted[0]
741
661
    """
742
662
    br_revno, br_rev_id = branch.last_revision_info()
743
663
    repo = branch.repository
744
 
    graph = repo.get_graph()
745
664
    if start_rev_id is None and end_rev_id is None:
746
665
        cur_revno = br_revno
747
 
        for revision_id in graph.iter_lefthand_ancestry(br_rev_id,
748
 
            (_mod_revision.NULL_REVISION,)):
 
666
        for revision_id in repo.iter_reverse_revision_history(br_rev_id):
749
667
            yield revision_id, str(cur_revno), 0
750
668
            cur_revno -= 1
751
669
    else:
752
670
        if end_rev_id is None:
753
671
            end_rev_id = br_rev_id
754
672
        found_start = start_rev_id is None
755
 
        for revision_id in graph.iter_lefthand_ancestry(end_rev_id,
756
 
                (_mod_revision.NULL_REVISION,)):
757
 
            revno_str = _compute_revno_str(branch, revision_id)
 
673
        for revision_id in repo.iter_reverse_revision_history(end_rev_id):
 
674
            revno = branch.revision_id_to_dotted_revno(revision_id)
 
675
            revno_str = '.'.join(str(n) for n in revno)
758
676
            if not found_start and revision_id == start_rev_id:
759
677
                if not exclude_common_ancestry:
760
678
                    yield revision_id, revno_str, 0
811
729
            yield rev_id, '.'.join(map(str, revno)), merge_depth
812
730
 
813
731
 
 
732
@deprecated_function(deprecated_in((2, 2, 0)))
 
733
def calculate_view_revisions(branch, start_revision, end_revision, direction,
 
734
        specific_fileid, generate_merge_revisions):
 
735
    """Calculate the revisions to view.
 
736
 
 
737
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
 
738
             a list of the same tuples.
 
739
    """
 
740
    start_rev_id, end_rev_id = _get_revision_limits(branch, start_revision,
 
741
        end_revision)
 
742
    view_revisions = list(_calc_view_revisions(branch, start_rev_id, end_rev_id,
 
743
        direction, generate_merge_revisions or specific_fileid))
 
744
    if specific_fileid:
 
745
        view_revisions = _filter_revisions_touching_file_id(branch,
 
746
            specific_fileid, view_revisions,
 
747
            include_merges=generate_merge_revisions)
 
748
    return _rebase_merge_depth(view_revisions)
 
749
 
 
750
 
814
751
def _rebase_merge_depth(view_revisions):
815
752
    """Adjust depths upwards so the top level is 0."""
816
753
    # If either the first or last revision have a merge_depth of 0, we're done
860
797
    return log_rev_iterator
861
798
 
862
799
 
863
 
def _make_search_filter(branch, generate_delta, match, log_rev_iterator):
 
800
def _make_search_filter(branch, generate_delta, search, log_rev_iterator):
864
801
    """Create a filtered iterator of log_rev_iterator matching on a regex.
865
802
 
866
803
    :param branch: The branch being logged.
867
804
    :param generate_delta: Whether to generate a delta for each revision.
868
 
    :param match: A dictionary with properties as keys and lists of strings
869
 
        as values. To match, a revision may match any of the supplied strings
870
 
        within a single property but must match at least one string for each
871
 
        property.
 
805
    :param search: A user text search string.
872
806
    :param log_rev_iterator: An input iterator containing all revisions that
873
807
        could be displayed, in lists.
874
808
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
875
809
        delta).
876
810
    """
877
 
    if match is None:
 
811
    if search is None:
878
812
        return log_rev_iterator
879
 
    searchRE = [(k, [re.compile(x, re.IGNORECASE) for x in v])
880
 
                for (k,v) in match.iteritems()]
881
 
    return _filter_re(searchRE, log_rev_iterator)
882
 
 
883
 
 
884
 
def _filter_re(searchRE, log_rev_iterator):
 
813
    searchRE = re.compile(search, re.IGNORECASE)
 
814
    return _filter_message_re(searchRE, log_rev_iterator)
 
815
 
 
816
 
 
817
def _filter_message_re(searchRE, log_rev_iterator):
885
818
    for revs in log_rev_iterator:
886
 
        new_revs = [rev for rev in revs if _match_filter(searchRE, rev[1])]
887
 
        if new_revs:
888
 
            yield new_revs
889
 
 
890
 
def _match_filter(searchRE, rev):
891
 
    strings = {
892
 
               'message': (rev.message,),
893
 
               'committer': (rev.committer,),
894
 
               'author': (rev.get_apparent_authors()),
895
 
               'bugs': list(rev.iter_bugs())
896
 
               }
897
 
    strings[''] = [item for inner_list in strings.itervalues()
898
 
                   for item in inner_list]
899
 
    for (k,v) in searchRE:
900
 
        if k in strings and not _match_any_filter(strings[k], v):
901
 
            return False
902
 
    return True
903
 
 
904
 
def _match_any_filter(strings, res):
905
 
    return any([filter(None, map(re.search, strings)) for re in res])
 
819
        new_revs = []
 
820
        for (rev_id, revno, merge_depth), rev, delta in revs:
 
821
            if searchRE.search(rev.message):
 
822
                new_revs.append(((rev_id, revno, merge_depth), rev, delta))
 
823
        yield new_revs
 
824
 
906
825
 
907
826
def _make_delta_filter(branch, generate_delta, search, log_rev_iterator,
908
827
    fileids=None, direction='reverse'):
981
900
 
982
901
def _update_fileids(delta, fileids, stop_on):
983
902
    """Update the set of file-ids to search based on file lifecycle events.
984
 
 
 
903
    
985
904
    :param fileids: a set of fileids to update
986
905
    :param stop_on: either 'add' or 'remove' - take file-ids out of the
987
906
      fileids set once their add or remove entry is detected respectively
1028
947
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
1029
948
        delta).
1030
949
    """
 
950
    repository = branch.repository
1031
951
    num = 9
1032
952
    for batch in log_rev_iterator:
1033
953
        batch = iter(batch)
1082
1002
    if branch_revno != 0:
1083
1003
        if (start_rev_id == _mod_revision.NULL_REVISION
1084
1004
            or end_rev_id == _mod_revision.NULL_REVISION):
1085
 
            raise errors.BzrCommandError(gettext('Logging revision 0 is invalid.'))
 
1005
            raise errors.BzrCommandError('Logging revision 0 is invalid.')
1086
1006
        if start_revno > end_revno:
1087
 
            raise errors.BzrCommandError(gettext("Start revision must be "
1088
 
                                         "older than the end revision."))
 
1007
            raise errors.BzrCommandError("Start revision must be older than "
 
1008
                                         "the end revision.")
1089
1009
    return (start_rev_id, end_rev_id)
1090
1010
 
1091
1011
 
1140
1060
 
1141
1061
    if ((start_rev_id == _mod_revision.NULL_REVISION)
1142
1062
        or (end_rev_id == _mod_revision.NULL_REVISION)):
1143
 
        raise errors.BzrCommandError(gettext('Logging revision 0 is invalid.'))
 
1063
        raise errors.BzrCommandError('Logging revision 0 is invalid.')
1144
1064
    if start_revno > end_revno:
1145
 
        raise errors.BzrCommandError(gettext("Start revision must be older "
1146
 
                                     "than the end revision."))
 
1065
        raise errors.BzrCommandError("Start revision must be older than "
 
1066
                                     "the end revision.")
1147
1067
 
1148
1068
    if end_revno < start_revno:
1149
1069
        return None, None, None, None
1150
1070
    cur_revno = branch_revno
1151
1071
    rev_nos = {}
1152
1072
    mainline_revs = []
1153
 
    graph = branch.repository.get_graph()
1154
 
    for revision_id in graph.iter_lefthand_ancestry(
1155
 
            branch_last_revision, (_mod_revision.NULL_REVISION,)):
 
1073
    for revision_id in branch.repository.iter_reverse_revision_history(
 
1074
                        branch_last_revision):
1156
1075
        if cur_revno < start_revno:
1157
1076
            # We have gone far enough, but we always add 1 more revision
1158
1077
            rev_nos[revision_id] = cur_revno
1172
1091
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
1173
1092
 
1174
1093
 
 
1094
@deprecated_function(deprecated_in((2, 2, 0)))
 
1095
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
 
1096
    """Filter view_revisions based on revision ranges.
 
1097
 
 
1098
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth)
 
1099
            tuples to be filtered.
 
1100
 
 
1101
    :param start_rev_id: If not NONE specifies the first revision to be logged.
 
1102
            If NONE then all revisions up to the end_rev_id are logged.
 
1103
 
 
1104
    :param end_rev_id: If not NONE specifies the last revision to be logged.
 
1105
            If NONE then all revisions up to the end of the log are logged.
 
1106
 
 
1107
    :return: The filtered view_revisions.
 
1108
    """
 
1109
    if start_rev_id or end_rev_id:
 
1110
        revision_ids = [r for r, n, d in view_revisions]
 
1111
        if start_rev_id:
 
1112
            start_index = revision_ids.index(start_rev_id)
 
1113
        else:
 
1114
            start_index = 0
 
1115
        if start_rev_id == end_rev_id:
 
1116
            end_index = start_index
 
1117
        else:
 
1118
            if end_rev_id:
 
1119
                end_index = revision_ids.index(end_rev_id)
 
1120
            else:
 
1121
                end_index = len(view_revisions) - 1
 
1122
        # To include the revisions merged into the last revision,
 
1123
        # extend end_rev_id down to, but not including, the next rev
 
1124
        # with the same or lesser merge_depth
 
1125
        end_merge_depth = view_revisions[end_index][2]
 
1126
        try:
 
1127
            for index in xrange(end_index+1, len(view_revisions)+1):
 
1128
                if view_revisions[index][2] <= end_merge_depth:
 
1129
                    end_index = index - 1
 
1130
                    break
 
1131
        except IndexError:
 
1132
            # if the search falls off the end then log to the end as well
 
1133
            end_index = len(view_revisions) - 1
 
1134
        view_revisions = view_revisions[start_index:end_index+1]
 
1135
    return view_revisions
 
1136
 
 
1137
 
1175
1138
def _filter_revisions_touching_file_id(branch, file_id, view_revisions,
1176
1139
    include_merges=True):
1177
1140
    r"""Return the list of revision ids which touch a given file id.
1180
1143
    This includes the revisions which directly change the file id,
1181
1144
    and the revisions which merge these changes. So if the
1182
1145
    revision graph is::
1183
 
 
1184
1146
        A-.
1185
1147
        |\ \
1186
1148
        B C E
1213
1175
    """
1214
1176
    # Lookup all possible text keys to determine which ones actually modified
1215
1177
    # the file.
1216
 
    graph = branch.repository.get_file_graph()
1217
 
    get_parent_map = graph.get_parent_map
1218
1178
    text_keys = [(file_id, rev_id) for rev_id, revno, depth in view_revisions]
1219
1179
    next_keys = None
1220
1180
    # Looking up keys in batches of 1000 can cut the time in half, as well as
1224
1184
    #       indexing layer. We might consider passing in hints as to the known
1225
1185
    #       access pattern (sparse/clustered, high success rate/low success
1226
1186
    #       rate). This particular access is clustered with a low success rate.
 
1187
    get_parent_map = branch.repository.texts.get_parent_map
1227
1188
    modified_text_revisions = set()
1228
1189
    chunk_size = 1000
1229
1190
    for start in xrange(0, len(text_keys), chunk_size):
1256
1217
    return result
1257
1218
 
1258
1219
 
 
1220
@deprecated_function(deprecated_in((2, 2, 0)))
 
1221
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
 
1222
                       include_merges=True):
 
1223
    """Produce an iterator of revisions to show
 
1224
    :return: an iterator of (revision_id, revno, merge_depth)
 
1225
    (if there is no revno for a revision, None is supplied)
 
1226
    """
 
1227
    if not include_merges:
 
1228
        revision_ids = mainline_revs[1:]
 
1229
        if direction == 'reverse':
 
1230
            revision_ids.reverse()
 
1231
        for revision_id in revision_ids:
 
1232
            yield revision_id, str(rev_nos[revision_id]), 0
 
1233
        return
 
1234
    graph = branch.repository.get_graph()
 
1235
    # This asks for all mainline revisions, which means we only have to spider
 
1236
    # sideways, rather than depth history. That said, its still size-of-history
 
1237
    # and should be addressed.
 
1238
    # mainline_revisions always includes an extra revision at the beginning, so
 
1239
    # don't request it.
 
1240
    parent_map = dict(((key, value) for key, value in
 
1241
        graph.iter_ancestry(mainline_revs[1:]) if value is not None))
 
1242
    # filter out ghosts; merge_sort errors on ghosts.
 
1243
    rev_graph = _mod_repository._strip_NULL_ghosts(parent_map)
 
1244
    merge_sorted_revisions = tsort.merge_sort(
 
1245
        rev_graph,
 
1246
        mainline_revs[-1],
 
1247
        mainline_revs,
 
1248
        generate_revno=True)
 
1249
 
 
1250
    if direction == 'forward':
 
1251
        # forward means oldest first.
 
1252
        merge_sorted_revisions = reverse_by_depth(merge_sorted_revisions)
 
1253
    elif direction != 'reverse':
 
1254
        raise ValueError('invalid direction %r' % direction)
 
1255
 
 
1256
    for (sequence, rev_id, merge_depth, revno, end_of_merge
 
1257
         ) in merge_sorted_revisions:
 
1258
        yield rev_id, '.'.join(map(str, revno)), merge_depth
 
1259
 
 
1260
 
1259
1261
def reverse_by_depth(merge_sorted_revisions, _depth=0):
1260
1262
    """Reverse revisions by depth.
1261
1263
 
1296
1298
    """
1297
1299
 
1298
1300
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
1299
 
                 tags=None, diff=None, signature=None):
 
1301
                 tags=None, diff=None):
1300
1302
        self.rev = rev
1301
 
        if revno is None:
1302
 
            self.revno = None
1303
 
        else:
1304
 
            self.revno = str(revno)
 
1303
        self.revno = str(revno)
1305
1304
        self.merge_depth = merge_depth
1306
1305
        self.delta = delta
1307
1306
        self.tags = tags
1308
1307
        self.diff = diff
1309
 
        self.signature = signature
1310
1308
 
1311
1309
 
1312
1310
class LogFormatter(object):
1321
1319
    to indicate which LogRevision attributes it supports:
1322
1320
 
1323
1321
    - supports_delta must be True if this log formatter supports delta.
1324
 
      Otherwise the delta attribute may not be populated.  The 'delta_format'
1325
 
      attribute describes whether the 'short_status' format (1) or the long
1326
 
      one (2) should be used.
 
1322
        Otherwise the delta attribute may not be populated.  The 'delta_format'
 
1323
        attribute describes whether the 'short_status' format (1) or the long
 
1324
        one (2) should be used.
1327
1325
 
1328
1326
    - supports_merge_revisions must be True if this log formatter supports
1329
 
      merge revisions.  If not, then only mainline revisions will be passed
1330
 
      to the formatter.
 
1327
        merge revisions.  If not, then only mainline revisions will be passed
 
1328
        to the formatter.
1331
1329
 
1332
1330
    - preferred_levels is the number of levels this formatter defaults to.
1333
 
      The default value is zero meaning display all levels.
1334
 
      This value is only relevant if supports_merge_revisions is True.
 
1331
        The default value is zero meaning display all levels.
 
1332
        This value is only relevant if supports_merge_revisions is True.
1335
1333
 
1336
1334
    - supports_tags must be True if this log formatter supports tags.
1337
 
      Otherwise the tags attribute may not be populated.
 
1335
        Otherwise the tags attribute may not be populated.
1338
1336
 
1339
1337
    - supports_diff must be True if this log formatter supports diffs.
1340
 
      Otherwise the diff attribute may not be populated.
1341
 
 
1342
 
    - supports_signatures must be True if this log formatter supports GPG
1343
 
      signatures.
 
1338
        Otherwise the diff attribute may not be populated.
1344
1339
 
1345
1340
    Plugins can register functions to show custom revision properties using
1346
1341
    the properties_handler_registry. The registered function
1347
 
    must respect the following interface description::
1348
 
 
 
1342
    must respect the following interface description:
1349
1343
        def my_show_properties(properties_dict):
1350
1344
            # code that returns a dict {'name':'value'} of the properties
1351
1345
            # to be shown
1358
1352
        """Create a LogFormatter.
1359
1353
 
1360
1354
        :param to_file: the file to output to
1361
 
        :param to_exact_file: if set, gives an output stream to which
 
1355
        :param to_exact_file: if set, gives an output stream to which 
1362
1356
             non-Unicode diffs are written.
1363
1357
        :param show_ids: if True, revision-ids are to be displayed
1364
1358
        :param show_timezone: the timezone to use
1415
1409
            if advice_sep:
1416
1410
                self.to_file.write(advice_sep)
1417
1411
            self.to_file.write(
1418
 
                "Use --include-merged or -n0 to see merged revisions.\n")
 
1412
                "Use --include-merges or -n0 to see merged revisions.\n")
1419
1413
 
1420
1414
    def get_advice_separator(self):
1421
1415
        """Get the text separating the log from the closing advice."""
1538
1532
    supports_delta = True
1539
1533
    supports_tags = True
1540
1534
    supports_diff = True
1541
 
    supports_signatures = True
1542
1535
 
1543
1536
    def __init__(self, *args, **kwargs):
1544
1537
        super(LongLogFormatter, self).__init__(*args, **kwargs)
1564
1557
                self.merge_marker(revision)))
1565
1558
        if revision.tags:
1566
1559
            lines.append('tags: %s' % (', '.join(revision.tags)))
1567
 
        if self.show_ids or revision.revno is None:
 
1560
        if self.show_ids:
1568
1561
            lines.append('revision-id: %s' % (revision.rev.revision_id,))
1569
 
        if self.show_ids:
1570
1562
            for parent_id in revision.rev.parent_ids:
1571
1563
                lines.append('parent: %s' % (parent_id,))
1572
1564
        lines.extend(self.custom_properties(revision.rev))
1583
1575
 
1584
1576
        lines.append('timestamp: %s' % (self.date_string(revision.rev),))
1585
1577
 
1586
 
        if revision.signature is not None:
1587
 
            lines.append('signature: ' + revision.signature)
1588
 
 
1589
1578
        lines.append('message:')
1590
1579
        if not revision.rev.message:
1591
1580
            lines.append('  (no message)')
1600
1589
        if revision.delta is not None:
1601
1590
            # Use the standard status output to display changes
1602
1591
            from bzrlib.delta import report_delta
1603
 
            report_delta(to_file, revision.delta, short_status=False,
 
1592
            report_delta(to_file, revision.delta, short_status=False, 
1604
1593
                         show_ids=self.show_ids, indent=indent)
1605
1594
        if revision.diff is not None:
1606
1595
            to_file.write(indent + 'diff:\n')
1638
1627
        indent = '    ' * depth
1639
1628
        revno_width = self.revno_width_by_depth.get(depth)
1640
1629
        if revno_width is None:
1641
 
            if revision.revno is None or revision.revno.find('.') == -1:
 
1630
            if revision.revno.find('.') == -1:
1642
1631
                # mainline revno, e.g. 12345
1643
1632
                revno_width = 5
1644
1633
            else:
1652
1641
        if revision.tags:
1653
1642
            tags = ' {%s}' % (', '.join(revision.tags))
1654
1643
        to_file.write(indent + "%*s %s\t%s%s%s\n" % (revno_width,
1655
 
                revision.revno or "", self.short_author(revision.rev),
 
1644
                revision.revno, self.short_author(revision.rev),
1656
1645
                format_date(revision.rev.timestamp,
1657
1646
                            revision.rev.timezone or 0,
1658
1647
                            self.show_timezone, date_fmt="%Y-%m-%d",
1659
1648
                            show_offset=False),
1660
1649
                tags, self.merge_marker(revision)))
1661
1650
        self.show_properties(revision.rev, indent+offset)
1662
 
        if self.show_ids or revision.revno is None:
 
1651
        if self.show_ids:
1663
1652
            to_file.write(indent + offset + 'revision-id:%s\n'
1664
1653
                          % (revision.rev.revision_id,))
1665
1654
        if not revision.rev.message:
1672
1661
        if revision.delta is not None:
1673
1662
            # Use the standard status output to display changes
1674
1663
            from bzrlib.delta import report_delta
1675
 
            report_delta(to_file, revision.delta,
1676
 
                         short_status=self.delta_format==1,
 
1664
            report_delta(to_file, revision.delta, 
 
1665
                         short_status=self.delta_format==1, 
1677
1666
                         show_ids=self.show_ids, indent=indent + offset)
1678
1667
        if revision.diff is not None:
1679
1668
            self.show_diff(self.to_exact_file, revision.diff, '      ')
1718
1707
 
1719
1708
    def log_string(self, revno, rev, max_chars, tags=None, prefix=''):
1720
1709
        """Format log info into one string. Truncate tail of string
1721
 
 
1722
 
        :param revno:      revision number or None.
1723
 
                           Revision numbers counts from 1.
1724
 
        :param rev:        revision object
1725
 
        :param max_chars:  maximum length of resulting string
1726
 
        :param tags:       list of tags or None
1727
 
        :param prefix:     string to prefix each line
1728
 
        :return:           formatted truncated string
 
1710
        :param  revno:      revision number or None.
 
1711
                            Revision numbers counts from 1.
 
1712
        :param  rev:        revision object
 
1713
        :param  max_chars:  maximum length of resulting string
 
1714
        :param  tags:       list of tags or None
 
1715
        :param  prefix:     string to prefix each line
 
1716
        :return:            formatted truncated string
1729
1717
        """
1730
1718
        out = []
1731
1719
        if revno:
1732
1720
            # show revno only when is not None
1733
1721
            out.append("%s:" % revno)
1734
 
        if max_chars is not None:
1735
 
            out.append(self.truncate(self.short_author(rev), (max_chars+3)/4))
1736
 
        else:
1737
 
            out.append(self.short_author(rev))
 
1722
        out.append(self.truncate(self.short_author(rev), 20))
1738
1723
        out.append(self.date_string(rev))
1739
1724
        if len(rev.parent_ids) > 1:
1740
1725
            out.append('[merge]')
1799
1784
        return self.get(name)(*args, **kwargs)
1800
1785
 
1801
1786
    def get_default(self, branch):
1802
 
        c = branch.get_config_stack()
1803
 
        return self.get(c.get('log_format'))
 
1787
        return self.get(branch.get_config().log_format())
1804
1788
 
1805
1789
 
1806
1790
log_formatter_registry = LogFormatterRegistry()
1829
1813
    try:
1830
1814
        return log_formatter_registry.make_formatter(name, *args, **kwargs)
1831
1815
    except KeyError:
1832
 
        raise errors.BzrCommandError(gettext("unknown log formatter: %r") % name)
 
1816
        raise errors.BzrCommandError("unknown log formatter: %r" % name)
1833
1817
 
1834
1818
 
1835
1819
def author_list_all(rev):
1860
1844
                              'The committer')
1861
1845
 
1862
1846
 
 
1847
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
 
1848
    # deprecated; for compatibility
 
1849
    lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
 
1850
    lf.show(revno, rev, delta)
 
1851
 
 
1852
 
1863
1853
def show_changed_revisions(branch, old_rh, new_rh, to_file=None,
1864
1854
                           log_format='long'):
1865
1855
    """Show the change in revision history comparing the old revision history to the new one.
1928
1918
    old_revisions = set()
1929
1919
    new_history = []
1930
1920
    new_revisions = set()
1931
 
    graph = repository.get_graph()
1932
 
    new_iter = graph.iter_lefthand_ancestry(new_revision_id)
1933
 
    old_iter = graph.iter_lefthand_ancestry(old_revision_id)
 
1921
    new_iter = repository.iter_reverse_revision_history(new_revision_id)
 
1922
    old_iter = repository.iter_reverse_revision_history(old_revision_id)
1934
1923
    stop_revision = None
1935
1924
    do_old = True
1936
1925
    do_new = True
2029
2018
      branch will be read-locked.
2030
2019
    """
2031
2020
    from builtins import _get_revision_range
2032
 
    tree, b, path = controldir.ControlDir.open_containing_tree_or_branch(
2033
 
        file_list[0])
 
2021
    tree, b, path = bzrdir.BzrDir.open_containing_tree_or_branch(file_list[0])
2034
2022
    add_cleanup(b.lock_read().unlock)
2035
2023
    # XXX: It's damn messy converting a list of paths to relative paths when
2036
2024
    # those paths might be deleted ones, they might be on a case-insensitive
2125
2113
                          len(row) > 1 and row[1] == 'fixed']
2126
2114
 
2127
2115
        if fixed_bug_urls:
2128
 
            return {ngettext('fixes bug', 'fixes bugs', len(fixed_bug_urls)):\
2129
 
                    ' '.join(fixed_bug_urls)}
 
2116
            return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
2130
2117
    return {}
2131
2118
 
2132
2119
properties_handler_registry.register('bugs_properties_handler',