/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 breezy/log.py

  • Committer: Martin
  • Date: 2017-06-05 20:48:31 UTC
  • mto: This revision was merged to the branch mainline in revision 6658.
  • Revision ID: gzlist@googlemail.com-20170605204831-20accykspjcrx0a8
Apply 2to3 dict fixer and clean up resulting mess using view helpers

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2010 Canonical Ltd
 
1
# Copyright (C) 2005-2011 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
 
 
19
17
"""Code to show logs of changes.
20
18
 
21
19
Various flavors of log can be produced:
49
47
all the changes since the previous revision that touched hello.c.
50
48
"""
51
49
 
 
50
from __future__ import absolute_import
 
51
 
52
52
import codecs
53
 
from cStringIO import StringIO
54
 
from itertools import (
55
 
    chain,
56
 
    izip,
57
 
    )
 
53
import itertools
58
54
import re
59
55
import sys
60
56
from warnings import (
61
57
    warn,
62
58
    )
63
59
 
64
 
from bzrlib.lazy_import import lazy_import
 
60
from .lazy_import import lazy_import
65
61
lazy_import(globals(), """
66
62
 
67
 
from bzrlib import (
68
 
    bzrdir,
 
63
from breezy import (
69
64
    config,
 
65
    controldir,
70
66
    diff,
71
67
    errors,
72
68
    foreign,
73
69
    repository as _mod_repository,
74
70
    revision as _mod_revision,
75
71
    revisionspec,
76
 
    trace,
77
72
    tsort,
78
73
    )
 
74
from breezy.i18n import gettext, ngettext
79
75
""")
80
76
 
81
 
from bzrlib import (
 
77
from . import (
 
78
    lazy_regex,
82
79
    registry,
83
80
    )
84
 
from bzrlib.osutils import (
 
81
from .osutils import (
85
82
    format_date,
86
83
    format_date_with_offset_in_original_timezone,
 
84
    get_diff_header_encoding,
87
85
    get_terminal_encoding,
88
 
    re_compile_checked,
89
86
    terminal_width,
90
87
    )
91
 
from bzrlib.symbol_versioning import (
92
 
    deprecated_function,
93
 
    deprecated_in,
 
88
from breezy.sixish import (
 
89
    BytesIO,
 
90
    range,
 
91
    zip,
94
92
    )
95
93
 
96
94
 
108
106
    last_ie = None
109
107
    last_path = None
110
108
    revno = 1
111
 
    for revision_id in branch.revision_history():
 
109
    graph = branch.repository.get_graph()
 
110
    history = list(graph.iter_lefthand_ancestry(branch.last_revision(),
 
111
        [_mod_revision.NULL_REVISION]))
 
112
    for revision_id in reversed(history):
112
113
        this_inv = branch.repository.get_inventory(revision_id)
113
 
        if file_id in this_inv:
 
114
        if this_inv.has_id(file_id):
114
115
            this_ie = this_inv[file_id]
115
116
            this_path = this_inv.id2path(file_id)
116
117
        else:
138
139
        revno += 1
139
140
 
140
141
 
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
148
 
 
149
 
 
150
142
def show_log(branch,
151
143
             lf,
152
144
             specific_fileid=None,
156
148
             end_revision=None,
157
149
             search=None,
158
150
             limit=None,
159
 
             show_diff=False):
 
151
             show_diff=False,
 
152
             match=None):
160
153
    """Write out human-readable log of commits to this branch.
161
154
 
162
155
    This function is being retained for backwards compatibility but
185
178
        if None or 0.
186
179
 
187
180
    :param show_diff: If True, output a diff after each revision.
 
181
 
 
182
    :param match: Dictionary of search lists to use when matching revision
 
183
      properties.
188
184
    """
189
185
    # Convert old-style parameters to new-style parameters
190
186
    if specific_fileid is not None:
214
210
    Logger(branch, rqst).show(lf)
215
211
 
216
212
 
217
 
# Note: This needs to be kept this in sync with the defaults in
 
213
# Note: This needs to be kept in sync with the defaults in
218
214
# make_log_request_dict() below
219
215
_DEFAULT_REQUEST_PARAMS = {
220
216
    'direction': 'reverse',
221
 
    'levels': 1,
 
217
    'levels': None,
222
218
    'generate_tags': True,
223
219
    'exclude_common_ancestry': False,
224
220
    '_match_using_deltas': True,
227
223
 
228
224
def make_log_request_dict(direction='reverse', specific_fileids=None,
229
225
                          start_revision=None, end_revision=None, limit=None,
230
 
                          message_search=None, levels=1, generate_tags=True,
 
226
                          message_search=None, levels=None, generate_tags=True,
231
227
                          delta_type=None,
232
228
                          diff_type=None, _match_using_deltas=True,
233
 
                          exclude_common_ancestry=False,
 
229
                          exclude_common_ancestry=False, match=None,
 
230
                          signature=False, omit_merges=False,
234
231
                          ):
235
232
    """Convenience function for making a logging request dictionary.
236
233
 
257
254
      matching commit messages
258
255
 
259
256
    :param levels: the number of levels of revisions to
260
 
      generate; 1 for just the mainline; 0 for all levels.
 
257
      generate; 1 for just the mainline; 0 for all levels, or None for
 
258
      a sensible default.
261
259
 
262
260
    :param generate_tags: If True, include tags for matched revisions.
263
 
 
 
261
`
264
262
    :param delta_type: Either 'full', 'partial' or None.
265
263
      'full' means generate the complete delta - adds/deletes/modifies/etc;
266
264
      'partial' means filter the delta using specific_fileids;
273
271
 
274
272
    :param _match_using_deltas: a private parameter controlling the
275
273
      algorithm used for matching specific_fileids. This parameter
276
 
      may be removed in the future so bzrlib client code should NOT
 
274
      may be removed in the future so breezy client code should NOT
277
275
      use it.
278
276
 
279
277
    :param exclude_common_ancestry: Whether -rX..Y should be interpreted as a
280
278
      range operator or as a graph difference.
 
279
 
 
280
    :param signature: show digital signature information
 
281
 
 
282
    :param match: Dictionary of list of search strings to use when filtering
 
283
      revisions. Keys can be 'message', 'author', 'committer', 'bugs' or
 
284
      the empty string to match any of the preceding properties.
 
285
 
 
286
    :param omit_merges: If True, commits with more than one parent are
 
287
      omitted.
 
288
 
281
289
    """
 
290
    # Take care of old style message_search parameter
 
291
    if message_search:
 
292
        if match:
 
293
            if 'message' in match:
 
294
                match['message'].append(message_search)
 
295
            else:
 
296
                match['message'] = [message_search]
 
297
        else:
 
298
            match={ 'message': [message_search] }
282
299
    return {
283
300
        'direction': direction,
284
301
        'specific_fileids': specific_fileids,
285
302
        'start_revision': start_revision,
286
303
        'end_revision': end_revision,
287
304
        'limit': limit,
288
 
        'message_search': message_search,
289
305
        'levels': levels,
290
306
        'generate_tags': generate_tags,
291
307
        'delta_type': delta_type,
292
308
        'diff_type': diff_type,
293
309
        'exclude_common_ancestry': exclude_common_ancestry,
 
310
        'signature': signature,
 
311
        'match': match,
 
312
        'omit_merges': omit_merges,
294
313
        # Add 'private' attributes for features that may be deprecated
295
314
        '_match_using_deltas': _match_using_deltas,
296
315
    }
298
317
 
299
318
def _apply_log_request_defaults(rqst):
300
319
    """Apply default values to a request dictionary."""
301
 
    result = _DEFAULT_REQUEST_PARAMS
 
320
    result = _DEFAULT_REQUEST_PARAMS.copy()
302
321
    if rqst:
303
322
        result.update(rqst)
304
323
    return result
305
324
 
306
325
 
 
326
def format_signature_validity(rev_id, repo):
 
327
    """get the signature validity
 
328
 
 
329
    :param rev_id: revision id to validate
 
330
    :param repo: repository of revision
 
331
    :return: human readable string to print to log
 
332
    """
 
333
    from breezy import gpg
 
334
 
 
335
    gpg_strategy = gpg.GPGStrategy(None)
 
336
    result = repo.verify_revision_signature(rev_id, gpg_strategy)
 
337
    if result[0] == gpg.SIGNATURE_VALID:
 
338
        return u"valid signature from {0}".format(result[1])
 
339
    if result[0] == gpg.SIGNATURE_KEY_MISSING:
 
340
        return "unknown key {0}".format(result[1])
 
341
    if result[0] == gpg.SIGNATURE_NOT_VALID:
 
342
        return "invalid signature!"
 
343
    if result[0] == gpg.SIGNATURE_NOT_SIGNED:
 
344
        return "no signature"
 
345
 
 
346
 
307
347
class LogGenerator(object):
308
348
    """A generator of log revisions."""
309
349
 
354
394
        # Tweak the LogRequest based on what the LogFormatter can handle.
355
395
        # (There's no point generating stuff if the formatter can't display it.)
356
396
        rqst = self.rqst
357
 
        rqst['levels'] = lf.get_levels()
 
397
        if rqst['levels'] is None or lf.get_levels() > rqst['levels']:
 
398
            # user didn't specify levels, use whatever the LF can handle:
 
399
            rqst['levels'] = lf.get_levels()
 
400
 
358
401
        if not getattr(lf, 'supports_tags', False):
359
402
            rqst['generate_tags'] = False
360
403
        if not getattr(lf, 'supports_delta', False):
361
404
            rqst['delta_type'] = None
362
405
        if not getattr(lf, 'supports_diff', False):
363
406
            rqst['diff_type'] = None
 
407
        if not getattr(lf, 'supports_signatures', False):
 
408
            rqst['signature'] = False
364
409
 
365
410
        # Find and print the interesting revisions
366
411
        generator = self._generator_factory(self.branch, rqst)
370
415
 
371
416
    def _generator_factory(self, branch, rqst):
372
417
        """Make the LogGenerator object to use.
373
 
        
 
418
 
374
419
        Subclasses may wish to override this.
375
420
        """
376
421
        return _DefaultLogGenerator(branch, rqst)
400
445
        levels = rqst.get('levels')
401
446
        limit = rqst.get('limit')
402
447
        diff_type = rqst.get('diff_type')
 
448
        show_signature = rqst.get('signature')
 
449
        omit_merges = rqst.get('omit_merges')
403
450
        log_count = 0
404
451
        revision_iterator = self._create_log_revision_iterator()
405
452
        for revs in revision_iterator:
407
454
                # 0 levels means show everything; merge_depth counts from 0
408
455
                if levels != 0 and merge_depth >= levels:
409
456
                    continue
 
457
                if omit_merges and len(rev.parent_ids) > 1:
 
458
                    continue
410
459
                if diff_type is None:
411
460
                    diff = None
412
461
                else:
413
462
                    diff = self._format_diff(rev, rev_id, diff_type)
 
463
                if show_signature:
 
464
                    signature = format_signature_validity(rev_id,
 
465
                                                self.branch.repository)
 
466
                else:
 
467
                    signature = None
414
468
                yield LogRevision(rev, revno, merge_depth, delta,
415
 
                    self.rev_tag_dict.get(rev_id), diff)
 
469
                    self.rev_tag_dict.get(rev_id), diff, signature)
416
470
                if limit:
417
471
                    log_count += 1
418
472
                    if log_count >= limit:
431
485
            specific_files = [tree_2.id2path(id) for id in file_ids]
432
486
        else:
433
487
            specific_files = None
434
 
        s = StringIO()
 
488
        s = BytesIO()
 
489
        path_encoding = get_diff_header_encoding()
435
490
        diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
436
 
            new_label='')
 
491
            new_label='', path_encoding=path_encoding)
437
492
        return s.getvalue()
438
493
 
439
494
    def _create_log_revision_iterator(self):
472
527
 
473
528
        # Apply the other filters
474
529
        return make_log_rev_iterator(self.branch, view_revisions,
475
 
            rqst.get('delta_type'), rqst.get('message_search'),
 
530
            rqst.get('delta_type'), rqst.get('match'),
476
531
            file_ids=rqst.get('specific_fileids'),
477
532
            direction=rqst.get('direction'))
478
533
 
491
546
            rqst.get('specific_fileids')[0], view_revisions,
492
547
            include_merges=rqst.get('levels') != 1)
493
548
        return make_log_rev_iterator(self.branch, view_revisions,
494
 
            rqst.get('delta_type'), rqst.get('message_search'))
 
549
            rqst.get('delta_type'), rqst.get('match'))
495
550
 
496
551
 
497
552
def _calc_view_revisions(branch, start_rev_id, end_rev_id, direction,
505
560
             a list of the same tuples.
506
561
    """
507
562
    if (exclude_common_ancestry and start_rev_id == end_rev_id):
508
 
        raise errors.BzrCommandError(
509
 
            '--exclude-common-ancestry requires two different revisions')
 
563
        raise errors.BzrCommandError(gettext(
 
564
            '--exclude-common-ancestry requires two different revisions'))
510
565
    if direction not in ('reverse', 'forward'):
511
 
        raise ValueError('invalid direction %r' % direction)
 
566
        raise ValueError(gettext('invalid direction %r') % direction)
512
567
    br_revno, br_rev_id = branch.last_revision_info()
513
568
    if br_revno == 0:
514
569
        return []
517
572
        and (not generate_merge_revisions
518
573
             or not _has_merges(branch, end_rev_id))):
519
574
        # If a single revision is requested, check we can handle it
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)))
 
575
        return  _generate_one_revision(branch, end_rev_id, br_rev_id,
 
576
                                       br_revno)
 
577
    if not generate_merge_revisions:
 
578
        try:
 
579
            # If we only want to see linear revisions, we can iterate ...
 
580
            iter_revs = _linear_view_revisions(
 
581
                branch, start_rev_id, end_rev_id,
 
582
                exclude_common_ancestry=exclude_common_ancestry)
 
583
            # If a start limit was given and it's not obviously an
 
584
            # ancestor of the end limit, check it before outputting anything
 
585
            if (direction == 'forward'
 
586
                or (start_rev_id and not _is_obvious_ancestor(
 
587
                        branch, start_rev_id, end_rev_id))):
 
588
                    iter_revs = list(iter_revs)
 
589
            if direction == 'forward':
 
590
                iter_revs = reversed(iter_revs)
 
591
            return iter_revs
 
592
        except _StartNotLinearAncestor:
 
593
            # Switch to the slower implementation that may be able to find a
 
594
            # non-obvious ancestor out of the left-hand history.
 
595
            pass
 
596
    iter_revs = _generate_all_revisions(branch, start_rev_id, end_rev_id,
 
597
                                        direction, delayed_graph_generation,
 
598
                                        exclude_common_ancestry)
 
599
    if direction == 'forward':
 
600
        iter_revs = _rebase_merge_depth(reverse_by_depth(list(iter_revs)))
534
601
    return iter_revs
535
602
 
536
603
 
539
606
        # It's the tip
540
607
        return [(br_rev_id, br_revno, 0)]
541
608
    else:
542
 
        revno = branch.revision_id_to_dotted_revno(rev_id)
543
 
        revno_str = '.'.join(str(n) for n in revno)
 
609
        revno_str = _compute_revno_str(branch, rev_id)
544
610
        return [(rev_id, revno_str, 0)]
545
611
 
546
612
 
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
 
 
561
613
def _generate_all_revisions(branch, start_rev_id, end_rev_id, direction,
562
614
                            delayed_graph_generation,
563
615
                            exclude_common_ancestry=False):
572
624
    if delayed_graph_generation:
573
625
        try:
574
626
            for rev_id, revno, depth in  _linear_view_revisions(
575
 
                branch, start_rev_id, end_rev_id):
 
627
                branch, start_rev_id, end_rev_id, exclude_common_ancestry):
576
628
                if _has_merges(branch, rev_id):
577
629
                    # The end_rev_id can be nested down somewhere. We need an
578
630
                    # explicit ancestry check. There is an ambiguity here as we
599
651
        except _StartNotLinearAncestor:
600
652
            # A merge was never detected so the lower revision limit can't
601
653
            # be nested down somewhere
602
 
            raise errors.BzrCommandError('Start revision not found in'
603
 
                ' history of end revision.')
 
654
            raise errors.BzrCommandError(gettext('Start revision not found in'
 
655
                ' history of end revision.'))
604
656
 
605
657
    # We exit the loop above because we encounter a revision with merges, from
606
658
    # this revision, we need to switch to _graph_view_revisions.
610
662
    # shown naturally, i.e. just like it is for linear logging. We can easily
611
663
    # make forward the exact opposite display, but showing the merge revisions
612
664
    # indented at the end seems slightly nicer in that case.
613
 
    view_revisions = chain(iter(initial_revisions),
 
665
    view_revisions = itertools.chain(iter(initial_revisions),
614
666
        _graph_view_revisions(branch, start_rev_id, end_rev_id,
615
667
                              rebase_initial_depths=(direction == 'reverse'),
616
668
                              exclude_common_ancestry=exclude_common_ancestry))
623
675
    return len(parents) > 1
624
676
 
625
677
 
 
678
def _compute_revno_str(branch, rev_id):
 
679
    """Compute the revno string from a rev_id.
 
680
 
 
681
    :return: The revno string, or None if the revision is not in the supplied
 
682
        branch.
 
683
    """
 
684
    try:
 
685
        revno = branch.revision_id_to_dotted_revno(rev_id)
 
686
    except errors.NoSuchRevision:
 
687
        # The revision must be outside of this branch
 
688
        return None
 
689
    else:
 
690
        return '.'.join(str(n) for n in revno)
 
691
 
 
692
 
626
693
def _is_obvious_ancestor(branch, start_rev_id, end_rev_id):
627
694
    """Is start_rev_id an obvious ancestor of end_rev_id?"""
628
695
    if start_rev_id and end_rev_id:
629
 
        start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
630
 
        end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
 
696
        try:
 
697
            start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
 
698
            end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
 
699
        except errors.NoSuchRevision:
 
700
            # one or both is not in the branch; not obvious
 
701
            return False
631
702
        if len(start_dotted) == 1 and len(end_dotted) == 1:
632
703
            # both on mainline
633
704
            return start_dotted[0] <= end_dotted[0]
643
714
    return True
644
715
 
645
716
 
646
 
def _linear_view_revisions(branch, start_rev_id, end_rev_id):
 
717
def _linear_view_revisions(branch, start_rev_id, end_rev_id,
 
718
                           exclude_common_ancestry=False):
647
719
    """Calculate a sequence of revisions to view, newest to oldest.
648
720
 
649
721
    :param start_rev_id: the lower revision-id
650
722
    :param end_rev_id: the upper revision-id
 
723
    :param exclude_common_ancestry: Whether the start_rev_id should be part of
 
724
        the iterated revisions.
651
725
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
652
726
    :raises _StartNotLinearAncestor: if a start_rev_id is specified but
653
 
      is not found walking the left-hand history
 
727
        is not found walking the left-hand history
654
728
    """
655
729
    br_revno, br_rev_id = branch.last_revision_info()
656
730
    repo = branch.repository
 
731
    graph = repo.get_graph()
657
732
    if start_rev_id is None and end_rev_id is None:
658
733
        cur_revno = br_revno
659
 
        for revision_id in repo.iter_reverse_revision_history(br_rev_id):
 
734
        for revision_id in graph.iter_lefthand_ancestry(br_rev_id,
 
735
            (_mod_revision.NULL_REVISION,)):
660
736
            yield revision_id, str(cur_revno), 0
661
737
            cur_revno -= 1
662
738
    else:
663
739
        if end_rev_id is None:
664
740
            end_rev_id = br_rev_id
665
741
        found_start = start_rev_id is 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)
 
742
        for revision_id in graph.iter_lefthand_ancestry(end_rev_id,
 
743
                (_mod_revision.NULL_REVISION,)):
 
744
            revno_str = _compute_revno_str(branch, revision_id)
669
745
            if not found_start and revision_id == start_rev_id:
670
 
                yield revision_id, revno_str, 0
 
746
                if not exclude_common_ancestry:
 
747
                    yield revision_id, revno_str, 0
671
748
                found_start = True
672
749
                break
673
750
            else:
721
798
            yield rev_id, '.'.join(map(str, revno)), merge_depth
722
799
 
723
800
 
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
 
 
743
801
def _rebase_merge_depth(view_revisions):
744
802
    """Adjust depths upwards so the top level is 0."""
745
803
    # If either the first or last revision have a merge_depth of 0, we're done
767
825
    """
768
826
    # Convert view_revisions into (view, None, None) groups to fit with
769
827
    # the standard interface here.
770
 
    if type(view_revisions) == list:
 
828
    if isinstance(view_revisions, list):
771
829
        # A single batch conversion is faster than many incremental ones.
772
830
        # As we have all the data, do a batch conversion.
773
831
        nones = [None] * len(view_revisions)
774
 
        log_rev_iterator = iter([zip(view_revisions, nones, nones)])
 
832
        log_rev_iterator = iter([list(zip(view_revisions, nones, nones))])
775
833
    else:
776
834
        def _convert():
777
835
            for view in view_revisions:
789
847
    return log_rev_iterator
790
848
 
791
849
 
792
 
def _make_search_filter(branch, generate_delta, search, log_rev_iterator):
 
850
def _make_search_filter(branch, generate_delta, match, log_rev_iterator):
793
851
    """Create a filtered iterator of log_rev_iterator matching on a regex.
794
852
 
795
853
    :param branch: The branch being logged.
796
854
    :param generate_delta: Whether to generate a delta for each revision.
797
 
    :param search: A user text search string.
 
855
    :param match: A dictionary with properties as keys and lists of strings
 
856
        as values. To match, a revision may match any of the supplied strings
 
857
        within a single property but must match at least one string for each
 
858
        property.
798
859
    :param log_rev_iterator: An input iterator containing all revisions that
799
860
        could be displayed, in lists.
800
861
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
801
862
        delta).
802
863
    """
803
 
    if search is None:
 
864
    if match is None:
804
865
        return 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):
 
866
    searchRE = [(k, [re.compile(x, re.IGNORECASE) for x in v])
 
867
                for k, v in match.items()]
 
868
    return _filter_re(searchRE, log_rev_iterator)
 
869
 
 
870
 
 
871
def _filter_re(searchRE, log_rev_iterator):
811
872
    for revs in log_rev_iterator:
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
817
 
 
 
873
        new_revs = [rev for rev in revs if _match_filter(searchRE, rev[1])]
 
874
        if new_revs:
 
875
            yield new_revs
 
876
 
 
877
def _match_filter(searchRE, rev):
 
878
    strings = {
 
879
               'message': (rev.message,),
 
880
               'committer': (rev.committer,),
 
881
               'author': (rev.get_apparent_authors()),
 
882
               'bugs': list(rev.iter_bugs())
 
883
               }
 
884
    strings[''] = [item for inner_list in strings.values()
 
885
                   for item in inner_list]
 
886
    for (k,v) in searchRE:
 
887
        if k in strings and not _match_any_filter(strings[k], v):
 
888
            return False
 
889
    return True
 
890
 
 
891
def _match_any_filter(strings, res):
 
892
    return any(re.search(s) for re in res for s in strings)
818
893
 
819
894
def _make_delta_filter(branch, generate_delta, search, log_rev_iterator,
820
895
    fileids=None, direction='reverse'):
865
940
        new_revs = []
866
941
        if delta_type == 'full' and not check_fileids:
867
942
            deltas = repository.get_deltas_for_revisions(revisions)
868
 
            for rev, delta in izip(revs, deltas):
 
943
            for rev, delta in zip(revs, deltas):
869
944
                new_revs.append((rev[0], rev[1], delta))
870
945
        else:
871
946
            deltas = repository.get_deltas_for_revisions(revisions, fileid_set)
872
 
            for rev, delta in izip(revs, deltas):
 
947
            for rev, delta in zip(revs, deltas):
873
948
                if check_fileids:
874
949
                    if delta is None or not delta.has_changed():
875
950
                        continue
893
968
 
894
969
def _update_fileids(delta, fileids, stop_on):
895
970
    """Update the set of file-ids to search based on file lifecycle events.
896
 
    
 
971
 
897
972
    :param fileids: a set of fileids to update
898
973
    :param stop_on: either 'add' or 'remove' - take file-ids out of the
899
974
      fileids set once their add or remove entry is detected respectively
925
1000
        revision_ids = [view[0] for view, _, _ in revs]
926
1001
        revisions = repository.get_revisions(revision_ids)
927
1002
        revs = [(rev[0], revision, rev[2]) for rev, revision in
928
 
            izip(revs, revisions)]
 
1003
            zip(revs, revisions)]
929
1004
        yield revs
930
1005
 
931
1006
 
940
1015
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
941
1016
        delta).
942
1017
    """
943
 
    repository = branch.repository
944
1018
    num = 9
945
1019
    for batch in log_rev_iterator:
946
1020
        batch = iter(batch)
995
1069
    if branch_revno != 0:
996
1070
        if (start_rev_id == _mod_revision.NULL_REVISION
997
1071
            or end_rev_id == _mod_revision.NULL_REVISION):
998
 
            raise errors.BzrCommandError('Logging revision 0 is invalid.')
 
1072
            raise errors.BzrCommandError(gettext('Logging revision 0 is invalid.'))
999
1073
        if start_revno > end_revno:
1000
 
            raise errors.BzrCommandError("Start revision must be older than "
1001
 
                                         "the end revision.")
 
1074
            raise errors.BzrCommandError(gettext("Start revision must be "
 
1075
                                         "older than the end revision."))
1002
1076
    return (start_rev_id, end_rev_id)
1003
1077
 
1004
1078
 
1053
1127
 
1054
1128
    if ((start_rev_id == _mod_revision.NULL_REVISION)
1055
1129
        or (end_rev_id == _mod_revision.NULL_REVISION)):
1056
 
        raise errors.BzrCommandError('Logging revision 0 is invalid.')
 
1130
        raise errors.BzrCommandError(gettext('Logging revision 0 is invalid.'))
1057
1131
    if start_revno > end_revno:
1058
 
        raise errors.BzrCommandError("Start revision must be older than "
1059
 
                                     "the end revision.")
 
1132
        raise errors.BzrCommandError(gettext("Start revision must be older "
 
1133
                                     "than the end revision."))
1060
1134
 
1061
1135
    if end_revno < start_revno:
1062
1136
        return None, None, None, None
1063
1137
    cur_revno = branch_revno
1064
1138
    rev_nos = {}
1065
1139
    mainline_revs = []
1066
 
    for revision_id in branch.repository.iter_reverse_revision_history(
1067
 
                        branch_last_revision):
 
1140
    graph = branch.repository.get_graph()
 
1141
    for revision_id in graph.iter_lefthand_ancestry(
 
1142
            branch_last_revision, (_mod_revision.NULL_REVISION,)):
1068
1143
        if cur_revno < start_revno:
1069
1144
            # We have gone far enough, but we always add 1 more revision
1070
1145
            rev_nos[revision_id] = cur_revno
1084
1159
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
1085
1160
 
1086
1161
 
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
 
 
1131
1162
def _filter_revisions_touching_file_id(branch, file_id, view_revisions,
1132
1163
    include_merges=True):
1133
1164
    r"""Return the list of revision ids which touch a given file id.
1136
1167
    This includes the revisions which directly change the file id,
1137
1168
    and the revisions which merge these changes. So if the
1138
1169
    revision graph is::
 
1170
 
1139
1171
        A-.
1140
1172
        |\ \
1141
1173
        B C E
1168
1200
    """
1169
1201
    # Lookup all possible text keys to determine which ones actually modified
1170
1202
    # the file.
 
1203
    graph = branch.repository.get_file_graph()
 
1204
    get_parent_map = graph.get_parent_map
1171
1205
    text_keys = [(file_id, rev_id) for rev_id, revno, depth in view_revisions]
1172
1206
    next_keys = None
1173
1207
    # Looking up keys in batches of 1000 can cut the time in half, as well as
1177
1211
    #       indexing layer. We might consider passing in hints as to the known
1178
1212
    #       access pattern (sparse/clustered, high success rate/low success
1179
1213
    #       rate). This particular access is clustered with a low success rate.
1180
 
    get_parent_map = branch.repository.texts.get_parent_map
1181
1214
    modified_text_revisions = set()
1182
1215
    chunk_size = 1000
1183
 
    for start in xrange(0, len(text_keys), chunk_size):
 
1216
    for start in range(0, len(text_keys), chunk_size):
1184
1217
        next_keys = text_keys[start:start + chunk_size]
1185
1218
        # Only keep the revision_id portion of the key
1186
1219
        modified_text_revisions.update(
1201
1234
 
1202
1235
        if rev_id in modified_text_revisions:
1203
1236
            # This needs to be logged, along with the extra revisions
1204
 
            for idx in xrange(len(current_merge_stack)):
 
1237
            for idx in range(len(current_merge_stack)):
1205
1238
                node = current_merge_stack[idx]
1206
1239
                if node is not None:
1207
1240
                    if include_merges or node[2] == 0:
1210
1243
    return result
1211
1244
 
1212
1245
 
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
 
 
1254
1246
def reverse_by_depth(merge_sorted_revisions, _depth=0):
1255
1247
    """Reverse revisions by depth.
1256
1248
 
1291
1283
    """
1292
1284
 
1293
1285
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
1294
 
                 tags=None, diff=None):
 
1286
                 tags=None, diff=None, signature=None):
1295
1287
        self.rev = rev
1296
 
        self.revno = str(revno)
 
1288
        if revno is None:
 
1289
            self.revno = None
 
1290
        else:
 
1291
            self.revno = str(revno)
1297
1292
        self.merge_depth = merge_depth
1298
1293
        self.delta = delta
1299
1294
        self.tags = tags
1300
1295
        self.diff = diff
 
1296
        self.signature = signature
1301
1297
 
1302
1298
 
1303
1299
class LogFormatter(object):
1312
1308
    to indicate which LogRevision attributes it supports:
1313
1309
 
1314
1310
    - supports_delta must be True if this log formatter supports delta.
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.
 
1311
      Otherwise the delta attribute may not be populated.  The 'delta_format'
 
1312
      attribute describes whether the 'short_status' format (1) or the long
 
1313
      one (2) should be used.
1318
1314
 
1319
1315
    - supports_merge_revisions must be True if this log formatter supports
1320
 
        merge revisions.  If not, then only mainline revisions will be passed
1321
 
        to the formatter.
 
1316
      merge revisions.  If not, then only mainline revisions will be passed
 
1317
      to the formatter.
1322
1318
 
1323
1319
    - preferred_levels is the number of levels this formatter defaults to.
1324
 
        The default value is zero meaning display all levels.
1325
 
        This value is only relevant if supports_merge_revisions is True.
 
1320
      The default value is zero meaning display all levels.
 
1321
      This value is only relevant if supports_merge_revisions is True.
1326
1322
 
1327
1323
    - supports_tags must be True if this log formatter supports tags.
1328
 
        Otherwise the tags attribute may not be populated.
 
1324
      Otherwise the tags attribute may not be populated.
1329
1325
 
1330
1326
    - supports_diff must be True if this log formatter supports diffs.
1331
 
        Otherwise the diff attribute may not be populated.
 
1327
      Otherwise the diff attribute may not be populated.
 
1328
 
 
1329
    - supports_signatures must be True if this log formatter supports GPG
 
1330
      signatures.
1332
1331
 
1333
1332
    Plugins can register functions to show custom revision properties using
1334
1333
    the properties_handler_registry. The registered function
1335
 
    must respect the following interface description:
 
1334
    must respect the following interface description::
 
1335
 
1336
1336
        def my_show_properties(properties_dict):
1337
1337
            # code that returns a dict {'name':'value'} of the properties
1338
1338
            # to be shown
1341
1341
 
1342
1342
    def __init__(self, to_file, show_ids=False, show_timezone='original',
1343
1343
                 delta_format=None, levels=None, show_advice=False,
1344
 
                 to_exact_file=None):
 
1344
                 to_exact_file=None, author_list_handler=None):
1345
1345
        """Create a LogFormatter.
1346
1346
 
1347
1347
        :param to_file: the file to output to
1348
 
        :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
1349
1349
             non-Unicode diffs are written.
1350
1350
        :param show_ids: if True, revision-ids are to be displayed
1351
1351
        :param show_timezone: the timezone to use
1355
1355
          let the log formatter decide.
1356
1356
        :param show_advice: whether to show advice at the end of the
1357
1357
          log or not
 
1358
        :param author_list_handler: callable generating a list of
 
1359
          authors to display for a given revision
1358
1360
        """
1359
1361
        self.to_file = to_file
1360
1362
        # 'exact' stream used to show diff, it should print content 'as is'
1375
1377
        self.levels = levels
1376
1378
        self._show_advice = show_advice
1377
1379
        self._merge_count = 0
 
1380
        self._author_list_handler = author_list_handler
1378
1381
 
1379
1382
    def get_levels(self):
1380
1383
        """Get the number of levels to display or 0 for all."""
1399
1402
            if advice_sep:
1400
1403
                self.to_file.write(advice_sep)
1401
1404
            self.to_file.write(
1402
 
                "Use --include-merges or -n0 to see merged revisions.\n")
 
1405
                "Use --include-merged or -n0 to see merged revisions.\n")
1403
1406
 
1404
1407
    def get_advice_separator(self):
1405
1408
        """Get the text separating the log from the closing advice."""
1412
1415
        return address
1413
1416
 
1414
1417
    def short_author(self, rev):
1415
 
        name, address = config.parse_username(rev.get_apparent_authors()[0])
1416
 
        if name:
1417
 
            return name
1418
 
        return address
 
1418
        return self.authors(rev, 'first', short=True, sep=', ')
 
1419
 
 
1420
    def authors(self, rev, who, short=False, sep=None):
 
1421
        """Generate list of authors, taking --authors option into account.
 
1422
 
 
1423
        The caller has to specify the name of a author list handler,
 
1424
        as provided by the author list registry, using the ``who``
 
1425
        argument.  That name only sets a default, though: when the
 
1426
        user selected a different author list generation using the
 
1427
        ``--authors`` command line switch, as represented by the
 
1428
        ``author_list_handler`` constructor argument, that value takes
 
1429
        precedence.
 
1430
 
 
1431
        :param rev: The revision for which to generate the list of authors.
 
1432
        :param who: Name of the default handler.
 
1433
        :param short: Whether to shorten names to either name or address.
 
1434
        :param sep: What separator to use for automatic concatenation.
 
1435
        """
 
1436
        if self._author_list_handler is not None:
 
1437
            # The user did specify --authors, which overrides the default
 
1438
            author_list_handler = self._author_list_handler
 
1439
        else:
 
1440
            # The user didn't specify --authors, so we use the caller's default
 
1441
            author_list_handler = author_list_registry.get(who)
 
1442
        names = author_list_handler(rev)
 
1443
        if short:
 
1444
            for i in range(len(names)):
 
1445
                name, address = config.parse_username(names[i])
 
1446
                if name:
 
1447
                    names[i] = name
 
1448
                else:
 
1449
                    names[i] = address
 
1450
        if sep is not None:
 
1451
            names = sep.join(names)
 
1452
        return names
1419
1453
 
1420
1454
    def merge_marker(self, revision):
1421
1455
        """Get the merge marker to include in the output or '' if none."""
1491
1525
    supports_delta = True
1492
1526
    supports_tags = True
1493
1527
    supports_diff = True
 
1528
    supports_signatures = True
1494
1529
 
1495
1530
    def __init__(self, *args, **kwargs):
1496
1531
        super(LongLogFormatter, self).__init__(*args, **kwargs)
1516
1551
                self.merge_marker(revision)))
1517
1552
        if revision.tags:
1518
1553
            lines.append('tags: %s' % (', '.join(revision.tags)))
1519
 
        if self.show_ids:
 
1554
        if self.show_ids or revision.revno is None:
1520
1555
            lines.append('revision-id: %s' % (revision.rev.revision_id,))
 
1556
        if self.show_ids:
1521
1557
            for parent_id in revision.rev.parent_ids:
1522
1558
                lines.append('parent: %s' % (parent_id,))
1523
1559
        lines.extend(self.custom_properties(revision.rev))
1524
1560
 
1525
1561
        committer = revision.rev.committer
1526
 
        authors = revision.rev.get_apparent_authors()
 
1562
        authors = self.authors(revision.rev, 'all')
1527
1563
        if authors != [committer]:
1528
1564
            lines.append('author: %s' % (", ".join(authors),))
1529
1565
        lines.append('committer: %s' % (committer,))
1534
1570
 
1535
1571
        lines.append('timestamp: %s' % (self.date_string(revision.rev),))
1536
1572
 
 
1573
        if revision.signature is not None:
 
1574
            lines.append('signature: ' + revision.signature)
 
1575
 
1537
1576
        lines.append('message:')
1538
1577
        if not revision.rev.message:
1539
1578
            lines.append('  (no message)')
1547
1586
        to_file.write("%s%s\n" % (indent, ('\n' + indent).join(lines)))
1548
1587
        if revision.delta is not None:
1549
1588
            # Use the standard status output to display changes
1550
 
            from bzrlib.delta import report_delta
1551
 
            report_delta(to_file, revision.delta, short_status=False, 
 
1589
            from breezy.delta import report_delta
 
1590
            report_delta(to_file, revision.delta, short_status=False,
1552
1591
                         show_ids=self.show_ids, indent=indent)
1553
1592
        if revision.diff is not None:
1554
1593
            to_file.write(indent + 'diff:\n')
1586
1625
        indent = '    ' * depth
1587
1626
        revno_width = self.revno_width_by_depth.get(depth)
1588
1627
        if revno_width is None:
1589
 
            if revision.revno.find('.') == -1:
 
1628
            if revision.revno is None or revision.revno.find('.') == -1:
1590
1629
                # mainline revno, e.g. 12345
1591
1630
                revno_width = 5
1592
1631
            else:
1600
1639
        if revision.tags:
1601
1640
            tags = ' {%s}' % (', '.join(revision.tags))
1602
1641
        to_file.write(indent + "%*s %s\t%s%s%s\n" % (revno_width,
1603
 
                revision.revno, self.short_author(revision.rev),
 
1642
                revision.revno or "", self.short_author(revision.rev),
1604
1643
                format_date(revision.rev.timestamp,
1605
1644
                            revision.rev.timezone or 0,
1606
1645
                            self.show_timezone, date_fmt="%Y-%m-%d",
1607
1646
                            show_offset=False),
1608
1647
                tags, self.merge_marker(revision)))
1609
1648
        self.show_properties(revision.rev, indent+offset)
1610
 
        if self.show_ids:
 
1649
        if self.show_ids or revision.revno is None:
1611
1650
            to_file.write(indent + offset + 'revision-id:%s\n'
1612
1651
                          % (revision.rev.revision_id,))
1613
1652
        if not revision.rev.message:
1619
1658
 
1620
1659
        if revision.delta is not None:
1621
1660
            # Use the standard status output to display changes
1622
 
            from bzrlib.delta import report_delta
1623
 
            report_delta(to_file, revision.delta, 
1624
 
                         short_status=self.delta_format==1, 
 
1661
            from breezy.delta import report_delta
 
1662
            report_delta(to_file, revision.delta,
 
1663
                         short_status=self.delta_format==1,
1625
1664
                         show_ids=self.show_ids, indent=indent + offset)
1626
1665
        if revision.diff is not None:
1627
1666
            self.show_diff(self.to_exact_file, revision.diff, '      ')
1666
1705
 
1667
1706
    def log_string(self, revno, rev, max_chars, tags=None, prefix=''):
1668
1707
        """Format log info into one string. Truncate tail of 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
 
1708
 
 
1709
        :param revno:      revision number or None.
 
1710
                           Revision numbers counts from 1.
 
1711
        :param rev:        revision object
 
1712
        :param max_chars:  maximum length of resulting string
 
1713
        :param tags:       list of tags or None
 
1714
        :param prefix:     string to prefix each line
 
1715
        :return:           formatted truncated string
1676
1716
        """
1677
1717
        out = []
1678
1718
        if revno:
1679
1719
            # show revno only when is not None
1680
1720
            out.append("%s:" % revno)
1681
 
        out.append(self.truncate(self.short_author(rev), 20))
 
1721
        if max_chars is not None:
 
1722
            out.append(self.truncate(self.short_author(rev), (max_chars+3)/4))
 
1723
        else:
 
1724
            out.append(self.short_author(rev))
1682
1725
        out.append(self.date_string(rev))
1683
1726
        if len(rev.parent_ids) > 1:
1684
1727
            out.append('[merge]')
1703
1746
                               self.show_timezone,
1704
1747
                               date_fmt='%Y-%m-%d',
1705
1748
                               show_offset=False)
1706
 
        committer_str = revision.rev.get_apparent_authors()[0].replace (' <', '  <')
 
1749
        committer_str = self.authors(revision.rev, 'first', sep=', ')
 
1750
        committer_str = committer_str.replace(' <', '  <')
1707
1751
        to_file.write('%s  %s\n\n' % (date_str,committer_str))
1708
1752
 
1709
1753
        if revision.delta is not None and revision.delta.has_changed():
1742
1786
        return self.get(name)(*args, **kwargs)
1743
1787
 
1744
1788
    def get_default(self, branch):
1745
 
        return self.get(branch.get_config().log_format())
 
1789
        c = branch.get_config_stack()
 
1790
        return self.get(c.get('log_format'))
1746
1791
 
1747
1792
 
1748
1793
log_formatter_registry = LogFormatterRegistry()
1749
1794
 
1750
1795
 
1751
1796
log_formatter_registry.register('short', ShortLogFormatter,
1752
 
                                'Moderately short log format')
 
1797
                                'Moderately short log format.')
1753
1798
log_formatter_registry.register('long', LongLogFormatter,
1754
 
                                'Detailed log format')
 
1799
                                'Detailed log format.')
1755
1800
log_formatter_registry.register('line', LineLogFormatter,
1756
 
                                'Log format with one line per revision')
 
1801
                                'Log format with one line per revision.')
1757
1802
log_formatter_registry.register('gnu-changelog', GnuChangelogLogFormatter,
1758
 
                                'Format used by GNU ChangeLog files')
 
1803
                                'Format used by GNU ChangeLog files.')
1759
1804
 
1760
1805
 
1761
1806
def register_formatter(name, formatter):
1771
1816
    try:
1772
1817
        return log_formatter_registry.make_formatter(name, *args, **kwargs)
1773
1818
    except KeyError:
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)
 
1819
        raise errors.BzrCommandError(gettext("unknown log formatter: %r") % name)
 
1820
 
 
1821
 
 
1822
def author_list_all(rev):
 
1823
    return rev.get_apparent_authors()[:]
 
1824
 
 
1825
 
 
1826
def author_list_first(rev):
 
1827
    lst = rev.get_apparent_authors()
 
1828
    try:
 
1829
        return [lst[0]]
 
1830
    except IndexError:
 
1831
        return []
 
1832
 
 
1833
 
 
1834
def author_list_committer(rev):
 
1835
    return [rev.committer]
 
1836
 
 
1837
 
 
1838
author_list_registry = registry.Registry()
 
1839
 
 
1840
author_list_registry.register('all', author_list_all,
 
1841
                              'All authors')
 
1842
 
 
1843
author_list_registry.register('first', author_list_first,
 
1844
                              'The first author')
 
1845
 
 
1846
author_list_registry.register('committer', author_list_committer,
 
1847
                              'The committer')
1781
1848
 
1782
1849
 
1783
1850
def show_changed_revisions(branch, old_rh, new_rh, to_file=None,
1800
1867
    # This is the first index which is different between
1801
1868
    # old and new
1802
1869
    base_idx = None
1803
 
    for i in xrange(max(len(new_rh),
1804
 
                        len(old_rh))):
 
1870
    for i in range(max(len(new_rh), len(old_rh))):
1805
1871
        if (len(new_rh) <= i
1806
1872
            or len(old_rh) <= i
1807
1873
            or new_rh[i] != old_rh[i]):
1848
1914
    old_revisions = set()
1849
1915
    new_history = []
1850
1916
    new_revisions = set()
1851
 
    new_iter = repository.iter_reverse_revision_history(new_revision_id)
1852
 
    old_iter = repository.iter_reverse_revision_history(old_revision_id)
 
1917
    graph = repository.get_graph()
 
1918
    new_iter = graph.iter_lefthand_ancestry(new_revision_id)
 
1919
    old_iter = graph.iter_lefthand_ancestry(old_revision_id)
1853
1920
    stop_revision = None
1854
1921
    do_old = True
1855
1922
    do_new = True
1856
1923
    while do_new or do_old:
1857
1924
        if do_new:
1858
1925
            try:
1859
 
                new_revision = new_iter.next()
 
1926
                new_revision = next(new_iter)
1860
1927
            except StopIteration:
1861
1928
                do_new = False
1862
1929
            else:
1867
1934
                    break
1868
1935
        if do_old:
1869
1936
            try:
1870
 
                old_revision = old_iter.next()
 
1937
                old_revision = next(old_iter)
1871
1938
            except StopIteration:
1872
1939
                do_old = False
1873
1940
            else:
1930
1997
        lf.log_revision(lr)
1931
1998
 
1932
1999
 
1933
 
def _get_info_for_log_files(revisionspec_list, file_list):
 
2000
def _get_info_for_log_files(revisionspec_list, file_list, add_cleanup):
1934
2001
    """Find file-ids and kinds given a list of files and a revision range.
1935
2002
 
1936
2003
    We search for files at the end of the range. If not found there,
1940
2007
    :param file_list: the list of paths given on the command line;
1941
2008
      the first of these can be a branch location or a file path,
1942
2009
      the remainder must be file paths
 
2010
    :param add_cleanup: When the branch returned is read locked,
 
2011
      an unlock call will be queued to the cleanup.
1943
2012
    :return: (branch, info_list, start_rev_info, end_rev_info) where
1944
2013
      info_list is a list of (relative_path, file_id, kind) tuples where
1945
2014
      kind is one of values 'directory', 'file', 'symlink', 'tree-reference'.
1946
2015
      branch will be read-locked.
1947
2016
    """
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()
 
2017
    from breezy.builtins import _get_revision_range
 
2018
    tree, b, path = controldir.ControlDir.open_containing_tree_or_branch(
 
2019
        file_list[0])
 
2020
    add_cleanup(b.lock_read().unlock)
1951
2021
    # XXX: It's damn messy converting a list of paths to relative paths when
1952
2022
    # those paths might be deleted ones, they might be on a case-insensitive
1953
2023
    # filesystem and/or they might be in silly locations (like another branch).
1957
2027
    # case of running log in a nested directory, assuming paths beyond the
1958
2028
    # first one haven't been deleted ...
1959
2029
    if tree:
1960
 
        relpaths = [path] + safe_relpath_files(tree, file_list[1:])
 
2030
        relpaths = [path] + tree.safe_relpath_files(file_list[1:])
1961
2031
    else:
1962
2032
        relpaths = [path] + file_list[1:]
1963
2033
    info_list = []
2034
2104
 
2035
2105
# Use the properties handlers to print out bug information if available
2036
2106
def _bugs_properties_handler(revision):
2037
 
    if revision.properties.has_key('bugs'):
 
2107
    if 'bugs' in revision.properties:
2038
2108
        bug_lines = revision.properties['bugs'].split('\n')
2039
2109
        bug_rows = [line.split(' ', 1) for line in bug_lines]
2040
2110
        fixed_bug_urls = [row[0] for row in bug_rows if
2041
2111
                          len(row) > 1 and row[1] == 'fixed']
2042
2112
 
2043
2113
        if fixed_bug_urls:
2044
 
            return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
 
2114
            return {ngettext('fixes bug', 'fixes bugs', len(fixed_bug_urls)):\
 
2115
                    ' '.join(fixed_bug_urls)}
2045
2116
    return {}
2046
2117
 
2047
2118
properties_handler_registry.register('bugs_properties_handler',