~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: Tarmac
  • Author(s): Vincent Ladeuil
  • Date: 2017-01-30 14:42:05 UTC
  • mfrom: (6620.1.1 trunk)
  • Revision ID: tarmac-20170130144205-r8fh2xpmiuxyozpv
Merge  2.7 into trunk including fix for bug #1657238 [r=vila]

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006, 2007, 2009 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
53
from cStringIO import StringIO
54
54
from itertools import (
65
65
lazy_import(globals(), """
66
66
 
67
67
from bzrlib import (
68
 
    bzrdir,
69
68
    config,
 
69
    controldir,
70
70
    diff,
71
71
    errors,
72
72
    foreign,
73
73
    repository as _mod_repository,
74
74
    revision as _mod_revision,
75
75
    revisionspec,
76
 
    trace,
77
76
    tsort,
78
77
    )
 
78
from bzrlib.i18n import gettext, ngettext
79
79
""")
80
80
 
81
81
from bzrlib import (
 
82
    lazy_regex,
82
83
    registry,
83
84
    )
84
85
from bzrlib.osutils import (
85
86
    format_date,
86
87
    format_date_with_offset_in_original_timezone,
 
88
    get_diff_header_encoding,
87
89
    get_terminal_encoding,
88
 
    re_compile_checked,
89
90
    terminal_width,
90
91
    )
91
 
from bzrlib.symbol_versioning import (
92
 
    deprecated_function,
93
 
    deprecated_in,
94
 
    )
95
92
 
96
93
 
97
94
def find_touching_revisions(branch, file_id):
108
105
    last_ie = None
109
106
    last_path = None
110
107
    revno = 1
111
 
    for revision_id in branch.revision_history():
112
 
        this_inv = branch.repository.get_revision_inventory(revision_id)
113
 
        if file_id in this_inv:
 
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):
 
112
        this_inv = branch.repository.get_inventory(revision_id)
 
113
        if this_inv.has_id(file_id):
114
114
            this_ie = this_inv[file_id]
115
115
            this_path = this_inv.id2path(file_id)
116
116
        else:
138
138
        revno += 1
139
139
 
140
140
 
141
 
def _enumerate_history(branch):
142
 
    rh = []
143
 
    revno = 1
144
 
    for rev_id in branch.revision_history():
145
 
        rh.append((revno, rev_id))
146
 
        revno += 1
147
 
    return rh
148
 
 
149
 
 
150
141
def show_log(branch,
151
142
             lf,
152
143
             specific_fileid=None,
156
147
             end_revision=None,
157
148
             search=None,
158
149
             limit=None,
159
 
             show_diff=False):
 
150
             show_diff=False,
 
151
             match=None):
160
152
    """Write out human-readable log of commits to this branch.
161
153
 
162
154
    This function is being retained for backwards compatibility but
185
177
        if None or 0.
186
178
 
187
179
    :param show_diff: If True, output a diff after each revision.
 
180
 
 
181
    :param match: Dictionary of search lists to use when matching revision
 
182
      properties.
188
183
    """
189
184
    # Convert old-style parameters to new-style parameters
190
185
    if specific_fileid is not None:
214
209
    Logger(branch, rqst).show(lf)
215
210
 
216
211
 
217
 
# Note: This needs to be kept this in sync with the defaults in
 
212
# Note: This needs to be kept in sync with the defaults in
218
213
# make_log_request_dict() below
219
214
_DEFAULT_REQUEST_PARAMS = {
220
215
    'direction': 'reverse',
221
 
    'levels': 1,
 
216
    'levels': None,
222
217
    'generate_tags': True,
 
218
    'exclude_common_ancestry': False,
223
219
    '_match_using_deltas': True,
224
220
    }
225
221
 
226
222
 
227
223
def make_log_request_dict(direction='reverse', specific_fileids=None,
228
 
    start_revision=None, end_revision=None, limit=None,
229
 
    message_search=None, levels=1, generate_tags=True, delta_type=None,
230
 
    diff_type=None, _match_using_deltas=True):
 
224
                          start_revision=None, end_revision=None, limit=None,
 
225
                          message_search=None, levels=None, generate_tags=True,
 
226
                          delta_type=None,
 
227
                          diff_type=None, _match_using_deltas=True,
 
228
                          exclude_common_ancestry=False, match=None,
 
229
                          signature=False, omit_merges=False,
 
230
                          ):
231
231
    """Convenience function for making a logging request dictionary.
232
232
 
233
233
    Using this function may make code slightly safer by ensuring
253
253
      matching commit messages
254
254
 
255
255
    :param levels: the number of levels of revisions to
256
 
      generate; 1 for just the mainline; 0 for all levels.
 
256
      generate; 1 for just the mainline; 0 for all levels, or None for
 
257
      a sensible default.
257
258
 
258
259
    :param generate_tags: If True, include tags for matched revisions.
259
 
 
 
260
`
260
261
    :param delta_type: Either 'full', 'partial' or None.
261
262
      'full' means generate the complete delta - adds/deletes/modifies/etc;
262
263
      'partial' means filter the delta using specific_fileids;
271
272
      algorithm used for matching specific_fileids. This parameter
272
273
      may be removed in the future so bzrlib client code should NOT
273
274
      use it.
 
275
 
 
276
    :param exclude_common_ancestry: Whether -rX..Y should be interpreted as a
 
277
      range operator or as a graph difference.
 
278
 
 
279
    :param signature: show digital signature information
 
280
 
 
281
    :param match: Dictionary of list of search strings to use when filtering
 
282
      revisions. Keys can be 'message', 'author', 'committer', 'bugs' or
 
283
      the empty string to match any of the preceding properties.
 
284
 
 
285
    :param omit_merges: If True, commits with more than one parent are
 
286
      omitted.
 
287
 
274
288
    """
 
289
    # Take care of old style message_search parameter
 
290
    if message_search:
 
291
        if match:
 
292
            if 'message' in match:
 
293
                match['message'].append(message_search)
 
294
            else:
 
295
                match['message'] = [message_search]
 
296
        else:
 
297
            match={ 'message': [message_search] }
275
298
    return {
276
299
        'direction': direction,
277
300
        'specific_fileids': specific_fileids,
278
301
        'start_revision': start_revision,
279
302
        'end_revision': end_revision,
280
303
        'limit': limit,
281
 
        'message_search': message_search,
282
304
        'levels': levels,
283
305
        'generate_tags': generate_tags,
284
306
        'delta_type': delta_type,
285
307
        'diff_type': diff_type,
 
308
        'exclude_common_ancestry': exclude_common_ancestry,
 
309
        'signature': signature,
 
310
        'match': match,
 
311
        'omit_merges': omit_merges,
286
312
        # Add 'private' attributes for features that may be deprecated
287
313
        '_match_using_deltas': _match_using_deltas,
288
314
    }
290
316
 
291
317
def _apply_log_request_defaults(rqst):
292
318
    """Apply default values to a request dictionary."""
293
 
    result = _DEFAULT_REQUEST_PARAMS
 
319
    result = _DEFAULT_REQUEST_PARAMS.copy()
294
320
    if rqst:
295
321
        result.update(rqst)
296
322
    return result
297
323
 
298
324
 
 
325
def format_signature_validity(rev_id, repo):
 
326
    """get the signature validity
 
327
 
 
328
    :param rev_id: revision id to validate
 
329
    :param repo: repository of revision
 
330
    :return: human readable string to print to log
 
331
    """
 
332
    from bzrlib import gpg
 
333
 
 
334
    gpg_strategy = gpg.GPGStrategy(None)
 
335
    result = repo.verify_revision_signature(rev_id, gpg_strategy)
 
336
    if result[0] == gpg.SIGNATURE_VALID:
 
337
        return u"valid signature from {0}".format(result[1])
 
338
    if result[0] == gpg.SIGNATURE_KEY_MISSING:
 
339
        return "unknown key {0}".format(result[1])
 
340
    if result[0] == gpg.SIGNATURE_NOT_VALID:
 
341
        return "invalid signature!"
 
342
    if result[0] == gpg.SIGNATURE_NOT_SIGNED:
 
343
        return "no signature"
 
344
 
 
345
 
299
346
class LogGenerator(object):
300
347
    """A generator of log revisions."""
301
348
 
346
393
        # Tweak the LogRequest based on what the LogFormatter can handle.
347
394
        # (There's no point generating stuff if the formatter can't display it.)
348
395
        rqst = self.rqst
349
 
        rqst['levels'] = lf.get_levels()
 
396
        if rqst['levels'] is None or lf.get_levels() > rqst['levels']:
 
397
            # user didn't specify levels, use whatever the LF can handle:
 
398
            rqst['levels'] = lf.get_levels()
 
399
 
350
400
        if not getattr(lf, 'supports_tags', False):
351
401
            rqst['generate_tags'] = False
352
402
        if not getattr(lf, 'supports_delta', False):
353
403
            rqst['delta_type'] = None
354
404
        if not getattr(lf, 'supports_diff', False):
355
405
            rqst['diff_type'] = None
 
406
        if not getattr(lf, 'supports_signatures', False):
 
407
            rqst['signature'] = False
356
408
 
357
409
        # Find and print the interesting revisions
358
410
        generator = self._generator_factory(self.branch, rqst)
362
414
 
363
415
    def _generator_factory(self, branch, rqst):
364
416
        """Make the LogGenerator object to use.
365
 
        
 
417
 
366
418
        Subclasses may wish to override this.
367
419
        """
368
420
        return _DefaultLogGenerator(branch, rqst)
392
444
        levels = rqst.get('levels')
393
445
        limit = rqst.get('limit')
394
446
        diff_type = rqst.get('diff_type')
 
447
        show_signature = rqst.get('signature')
 
448
        omit_merges = rqst.get('omit_merges')
395
449
        log_count = 0
396
450
        revision_iterator = self._create_log_revision_iterator()
397
451
        for revs in revision_iterator:
399
453
                # 0 levels means show everything; merge_depth counts from 0
400
454
                if levels != 0 and merge_depth >= levels:
401
455
                    continue
 
456
                if omit_merges and len(rev.parent_ids) > 1:
 
457
                    continue
402
458
                if diff_type is None:
403
459
                    diff = None
404
460
                else:
405
461
                    diff = self._format_diff(rev, rev_id, diff_type)
 
462
                if show_signature:
 
463
                    signature = format_signature_validity(rev_id,
 
464
                                                self.branch.repository)
 
465
                else:
 
466
                    signature = None
406
467
                yield LogRevision(rev, revno, merge_depth, delta,
407
 
                    self.rev_tag_dict.get(rev_id), diff)
 
468
                    self.rev_tag_dict.get(rev_id), diff, signature)
408
469
                if limit:
409
470
                    log_count += 1
410
471
                    if log_count >= limit:
424
485
        else:
425
486
            specific_files = None
426
487
        s = StringIO()
 
488
        path_encoding = get_diff_header_encoding()
427
489
        diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
428
 
            new_label='')
 
490
            new_label='', path_encoding=path_encoding)
429
491
        return s.getvalue()
430
492
 
431
493
    def _create_log_revision_iterator(self):
455
517
        generate_merge_revisions = rqst.get('levels') != 1
456
518
        delayed_graph_generation = not rqst.get('specific_fileids') and (
457
519
                rqst.get('limit') or self.start_rev_id or self.end_rev_id)
458
 
        view_revisions = _calc_view_revisions(self.branch, self.start_rev_id,
459
 
            self.end_rev_id, rqst.get('direction'), generate_merge_revisions,
460
 
            delayed_graph_generation=delayed_graph_generation)
 
520
        view_revisions = _calc_view_revisions(
 
521
            self.branch, self.start_rev_id, self.end_rev_id,
 
522
            rqst.get('direction'),
 
523
            generate_merge_revisions=generate_merge_revisions,
 
524
            delayed_graph_generation=delayed_graph_generation,
 
525
            exclude_common_ancestry=rqst.get('exclude_common_ancestry'))
461
526
 
462
527
        # Apply the other filters
463
528
        return make_log_rev_iterator(self.branch, view_revisions,
464
 
            rqst.get('delta_type'), rqst.get('message_search'),
 
529
            rqst.get('delta_type'), rqst.get('match'),
465
530
            file_ids=rqst.get('specific_fileids'),
466
531
            direction=rqst.get('direction'))
467
532
 
470
535
        # Note that we always generate the merge revisions because
471
536
        # filter_revisions_touching_file_id() requires them ...
472
537
        rqst = self.rqst
473
 
        view_revisions = _calc_view_revisions(self.branch, self.start_rev_id,
474
 
            self.end_rev_id, rqst.get('direction'), True)
 
538
        view_revisions = _calc_view_revisions(
 
539
            self.branch, self.start_rev_id, self.end_rev_id,
 
540
            rqst.get('direction'), generate_merge_revisions=True,
 
541
            exclude_common_ancestry=rqst.get('exclude_common_ancestry'))
475
542
        if not isinstance(view_revisions, list):
476
543
            view_revisions = list(view_revisions)
477
544
        view_revisions = _filter_revisions_touching_file_id(self.branch,
478
545
            rqst.get('specific_fileids')[0], view_revisions,
479
546
            include_merges=rqst.get('levels') != 1)
480
547
        return make_log_rev_iterator(self.branch, view_revisions,
481
 
            rqst.get('delta_type'), rqst.get('message_search'))
 
548
            rqst.get('delta_type'), rqst.get('match'))
482
549
 
483
550
 
484
551
def _calc_view_revisions(branch, start_rev_id, end_rev_id, direction,
485
 
    generate_merge_revisions, delayed_graph_generation=False):
 
552
                         generate_merge_revisions,
 
553
                         delayed_graph_generation=False,
 
554
                         exclude_common_ancestry=False,
 
555
                         ):
486
556
    """Calculate the revisions to view.
487
557
 
488
558
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
489
559
             a list of the same tuples.
490
560
    """
 
561
    if (exclude_common_ancestry and start_rev_id == end_rev_id):
 
562
        raise errors.BzrCommandError(gettext(
 
563
            '--exclude-common-ancestry requires two different revisions'))
 
564
    if direction not in ('reverse', 'forward'):
 
565
        raise ValueError(gettext('invalid direction %r') % direction)
491
566
    br_revno, br_rev_id = branch.last_revision_info()
492
567
    if br_revno == 0:
493
568
        return []
494
569
 
495
 
    # If a single revision is requested, check we can handle it
496
 
    generate_single_revision = (end_rev_id and start_rev_id == end_rev_id and
497
 
        (not generate_merge_revisions or not _has_merges(branch, end_rev_id)))
498
 
    if generate_single_revision:
499
 
        return _generate_one_revision(branch, end_rev_id, br_rev_id, br_revno)
500
 
 
501
 
    # If we only want to see linear revisions, we can iterate ...
 
570
    if (end_rev_id and start_rev_id == end_rev_id
 
571
        and (not generate_merge_revisions
 
572
             or not _has_merges(branch, end_rev_id))):
 
573
        # If a single revision is requested, check we can handle it
 
574
        return  _generate_one_revision(branch, end_rev_id, br_rev_id,
 
575
                                       br_revno)
502
576
    if not generate_merge_revisions:
503
 
        return _generate_flat_revisions(branch, start_rev_id, end_rev_id,
504
 
            direction)
505
 
    else:
506
 
        return _generate_all_revisions(branch, start_rev_id, end_rev_id,
507
 
            direction, delayed_graph_generation)
 
577
        try:
 
578
            # If we only want to see linear revisions, we can iterate ...
 
579
            iter_revs = _linear_view_revisions(
 
580
                branch, start_rev_id, end_rev_id,
 
581
                exclude_common_ancestry=exclude_common_ancestry)
 
582
            # If a start limit was given and it's not obviously an
 
583
            # ancestor of the end limit, check it before outputting anything
 
584
            if (direction == 'forward'
 
585
                or (start_rev_id and not _is_obvious_ancestor(
 
586
                        branch, start_rev_id, end_rev_id))):
 
587
                    iter_revs = list(iter_revs)
 
588
            if direction == 'forward':
 
589
                iter_revs = reversed(iter_revs)
 
590
            return iter_revs
 
591
        except _StartNotLinearAncestor:
 
592
            # Switch to the slower implementation that may be able to find a
 
593
            # non-obvious ancestor out of the left-hand history.
 
594
            pass
 
595
    iter_revs = _generate_all_revisions(branch, start_rev_id, end_rev_id,
 
596
                                        direction, delayed_graph_generation,
 
597
                                        exclude_common_ancestry)
 
598
    if direction == 'forward':
 
599
        iter_revs = _rebase_merge_depth(reverse_by_depth(list(iter_revs)))
 
600
    return iter_revs
508
601
 
509
602
 
510
603
def _generate_one_revision(branch, rev_id, br_rev_id, br_revno):
512
605
        # It's the tip
513
606
        return [(br_rev_id, br_revno, 0)]
514
607
    else:
515
 
        revno = branch.revision_id_to_dotted_revno(rev_id)
516
 
        revno_str = '.'.join(str(n) for n in revno)
 
608
        revno_str = _compute_revno_str(branch, rev_id)
517
609
        return [(rev_id, revno_str, 0)]
518
610
 
519
611
 
520
 
def _generate_flat_revisions(branch, start_rev_id, end_rev_id, direction):
521
 
    result = _linear_view_revisions(branch, start_rev_id, end_rev_id)
522
 
    # If a start limit was given and it's not obviously an
523
 
    # ancestor of the end limit, check it before outputting anything
524
 
    if direction == 'forward' or (start_rev_id
525
 
        and not _is_obvious_ancestor(branch, start_rev_id, end_rev_id)):
526
 
        try:
527
 
            result = list(result)
528
 
        except _StartNotLinearAncestor:
529
 
            raise errors.BzrCommandError('Start revision not found in'
530
 
                ' left-hand history of end revision.')
531
 
    if direction == 'forward':
532
 
        result = reversed(result)
533
 
    return result
534
 
 
535
 
 
536
612
def _generate_all_revisions(branch, start_rev_id, end_rev_id, direction,
537
 
    delayed_graph_generation):
 
613
                            delayed_graph_generation,
 
614
                            exclude_common_ancestry=False):
538
615
    # On large trees, generating the merge graph can take 30-60 seconds
539
616
    # so we delay doing it until a merge is detected, incrementally
540
617
    # returning initial (non-merge) revisions while we can.
 
618
 
 
619
    # The above is only true for old formats (<= 0.92), for newer formats, a
 
620
    # couple of seconds only should be needed to load the whole graph and the
 
621
    # other graph operations needed are even faster than that -- vila 100201
541
622
    initial_revisions = []
542
623
    if delayed_graph_generation:
543
624
        try:
544
 
            for rev_id, revno, depth in \
545
 
                _linear_view_revisions(branch, start_rev_id, end_rev_id):
 
625
            for rev_id, revno, depth in  _linear_view_revisions(
 
626
                branch, start_rev_id, end_rev_id, exclude_common_ancestry):
546
627
                if _has_merges(branch, rev_id):
 
628
                    # The end_rev_id can be nested down somewhere. We need an
 
629
                    # explicit ancestry check. There is an ambiguity here as we
 
630
                    # may not raise _StartNotLinearAncestor for a revision that
 
631
                    # is an ancestor but not a *linear* one. But since we have
 
632
                    # loaded the graph to do the check (or calculate a dotted
 
633
                    # revno), we may as well accept to show the log...  We need
 
634
                    # the check only if start_rev_id is not None as all
 
635
                    # revisions have _mod_revision.NULL_REVISION as an ancestor
 
636
                    # -- vila 20100319
 
637
                    graph = branch.repository.get_graph()
 
638
                    if (start_rev_id is not None
 
639
                        and not graph.is_ancestor(start_rev_id, end_rev_id)):
 
640
                        raise _StartNotLinearAncestor()
 
641
                    # Since we collected the revisions so far, we need to
 
642
                    # adjust end_rev_id.
547
643
                    end_rev_id = rev_id
548
644
                    break
549
645
                else:
550
646
                    initial_revisions.append((rev_id, revno, depth))
551
647
            else:
552
648
                # No merged revisions found
553
 
                if direction == 'reverse':
554
 
                    return initial_revisions
555
 
                elif direction == 'forward':
556
 
                    return reversed(initial_revisions)
557
 
                else:
558
 
                    raise ValueError('invalid direction %r' % direction)
 
649
                return initial_revisions
559
650
        except _StartNotLinearAncestor:
560
651
            # A merge was never detected so the lower revision limit can't
561
652
            # be nested down somewhere
562
 
            raise errors.BzrCommandError('Start revision not found in'
563
 
                ' history of end revision.')
 
653
            raise errors.BzrCommandError(gettext('Start revision not found in'
 
654
                ' history of end revision.'))
 
655
 
 
656
    # We exit the loop above because we encounter a revision with merges, from
 
657
    # this revision, we need to switch to _graph_view_revisions.
564
658
 
565
659
    # A log including nested merges is required. If the direction is reverse,
566
660
    # we rebase the initial merge depths so that the development line is
569
663
    # indented at the end seems slightly nicer in that case.
570
664
    view_revisions = chain(iter(initial_revisions),
571
665
        _graph_view_revisions(branch, start_rev_id, end_rev_id,
572
 
        rebase_initial_depths=direction == 'reverse'))
573
 
    if direction == 'reverse':
574
 
        return view_revisions
575
 
    elif direction == 'forward':
576
 
        # Forward means oldest first, adjusting for depth.
577
 
        view_revisions = reverse_by_depth(list(view_revisions))
578
 
        return _rebase_merge_depth(view_revisions)
579
 
    else:
580
 
        raise ValueError('invalid direction %r' % direction)
 
666
                              rebase_initial_depths=(direction == 'reverse'),
 
667
                              exclude_common_ancestry=exclude_common_ancestry))
 
668
    return view_revisions
581
669
 
582
670
 
583
671
def _has_merges(branch, rev_id):
586
674
    return len(parents) > 1
587
675
 
588
676
 
 
677
def _compute_revno_str(branch, rev_id):
 
678
    """Compute the revno string from a rev_id.
 
679
 
 
680
    :return: The revno string, or None if the revision is not in the supplied
 
681
        branch.
 
682
    """
 
683
    try:
 
684
        revno = branch.revision_id_to_dotted_revno(rev_id)
 
685
    except errors.NoSuchRevision:
 
686
        # The revision must be outside of this branch
 
687
        return None
 
688
    else:
 
689
        return '.'.join(str(n) for n in revno)
 
690
 
 
691
 
589
692
def _is_obvious_ancestor(branch, start_rev_id, end_rev_id):
590
693
    """Is start_rev_id an obvious ancestor of end_rev_id?"""
591
694
    if start_rev_id and end_rev_id:
592
 
        start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
593
 
        end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
 
695
        try:
 
696
            start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
 
697
            end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
 
698
        except errors.NoSuchRevision:
 
699
            # one or both is not in the branch; not obvious
 
700
            return False
594
701
        if len(start_dotted) == 1 and len(end_dotted) == 1:
595
702
            # both on mainline
596
703
            return start_dotted[0] <= end_dotted[0]
606
713
    return True
607
714
 
608
715
 
609
 
def _linear_view_revisions(branch, start_rev_id, end_rev_id):
 
716
def _linear_view_revisions(branch, start_rev_id, end_rev_id,
 
717
                           exclude_common_ancestry=False):
610
718
    """Calculate a sequence of revisions to view, newest to oldest.
611
719
 
612
720
    :param start_rev_id: the lower revision-id
613
721
    :param end_rev_id: the upper revision-id
 
722
    :param exclude_common_ancestry: Whether the start_rev_id should be part of
 
723
        the iterated revisions.
614
724
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
615
725
    :raises _StartNotLinearAncestor: if a start_rev_id is specified but
616
 
      is not found walking the left-hand history
 
726
        is not found walking the left-hand history
617
727
    """
618
728
    br_revno, br_rev_id = branch.last_revision_info()
619
729
    repo = branch.repository
 
730
    graph = repo.get_graph()
620
731
    if start_rev_id is None and end_rev_id is None:
621
732
        cur_revno = br_revno
622
 
        for revision_id in repo.iter_reverse_revision_history(br_rev_id):
 
733
        for revision_id in graph.iter_lefthand_ancestry(br_rev_id,
 
734
            (_mod_revision.NULL_REVISION,)):
623
735
            yield revision_id, str(cur_revno), 0
624
736
            cur_revno -= 1
625
737
    else:
626
738
        if end_rev_id is None:
627
739
            end_rev_id = br_rev_id
628
740
        found_start = start_rev_id is None
629
 
        for revision_id in repo.iter_reverse_revision_history(end_rev_id):
630
 
            revno = branch.revision_id_to_dotted_revno(revision_id)
631
 
            revno_str = '.'.join(str(n) for n in revno)
 
741
        for revision_id in graph.iter_lefthand_ancestry(end_rev_id,
 
742
                (_mod_revision.NULL_REVISION,)):
 
743
            revno_str = _compute_revno_str(branch, revision_id)
632
744
            if not found_start and revision_id == start_rev_id:
633
 
                yield revision_id, revno_str, 0
 
745
                if not exclude_common_ancestry:
 
746
                    yield revision_id, revno_str, 0
634
747
                found_start = True
635
748
                break
636
749
            else:
641
754
 
642
755
 
643
756
def _graph_view_revisions(branch, start_rev_id, end_rev_id,
644
 
    rebase_initial_depths=True):
 
757
                          rebase_initial_depths=True,
 
758
                          exclude_common_ancestry=False):
645
759
    """Calculate revisions to view including merges, newest to oldest.
646
760
 
647
761
    :param branch: the branch
651
765
      revision is found?
652
766
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
653
767
    """
 
768
    if exclude_common_ancestry:
 
769
        stop_rule = 'with-merges-without-common-ancestry'
 
770
    else:
 
771
        stop_rule = 'with-merges'
654
772
    view_revisions = branch.iter_merge_sorted_revisions(
655
773
        start_revision_id=end_rev_id, stop_revision_id=start_rev_id,
656
 
        stop_rule="with-merges")
 
774
        stop_rule=stop_rule)
657
775
    if not rebase_initial_depths:
658
776
        for (rev_id, merge_depth, revno, end_of_merge
659
777
             ) in view_revisions:
679
797
            yield rev_id, '.'.join(map(str, revno)), merge_depth
680
798
 
681
799
 
682
 
@deprecated_function(deprecated_in((2, 2, 0)))
683
 
def calculate_view_revisions(branch, start_revision, end_revision, direction,
684
 
        specific_fileid, generate_merge_revisions):
685
 
    """Calculate the revisions to view.
686
 
 
687
 
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
688
 
             a list of the same tuples.
689
 
    """
690
 
    start_rev_id, end_rev_id = _get_revision_limits(branch, start_revision,
691
 
        end_revision)
692
 
    view_revisions = list(_calc_view_revisions(branch, start_rev_id, end_rev_id,
693
 
        direction, generate_merge_revisions or specific_fileid))
694
 
    if specific_fileid:
695
 
        view_revisions = _filter_revisions_touching_file_id(branch,
696
 
            specific_fileid, view_revisions,
697
 
            include_merges=generate_merge_revisions)
698
 
    return _rebase_merge_depth(view_revisions)
699
 
 
700
 
 
701
800
def _rebase_merge_depth(view_revisions):
702
801
    """Adjust depths upwards so the top level is 0."""
703
802
    # If either the first or last revision have a merge_depth of 0, we're done
747
846
    return log_rev_iterator
748
847
 
749
848
 
750
 
def _make_search_filter(branch, generate_delta, search, log_rev_iterator):
 
849
def _make_search_filter(branch, generate_delta, match, log_rev_iterator):
751
850
    """Create a filtered iterator of log_rev_iterator matching on a regex.
752
851
 
753
852
    :param branch: The branch being logged.
754
853
    :param generate_delta: Whether to generate a delta for each revision.
755
 
    :param search: A user text search string.
 
854
    :param match: A dictionary with properties as keys and lists of strings
 
855
        as values. To match, a revision may match any of the supplied strings
 
856
        within a single property but must match at least one string for each
 
857
        property.
756
858
    :param log_rev_iterator: An input iterator containing all revisions that
757
859
        could be displayed, in lists.
758
860
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
759
861
        delta).
760
862
    """
761
 
    if search is None:
 
863
    if match is None:
762
864
        return log_rev_iterator
763
 
    searchRE = re_compile_checked(search, re.IGNORECASE,
764
 
            'log message filter')
765
 
    return _filter_message_re(searchRE, log_rev_iterator)
766
 
 
767
 
 
768
 
def _filter_message_re(searchRE, log_rev_iterator):
 
865
    searchRE = [(k, [re.compile(x, re.IGNORECASE) for x in v])
 
866
                for (k,v) in match.iteritems()]
 
867
    return _filter_re(searchRE, log_rev_iterator)
 
868
 
 
869
 
 
870
def _filter_re(searchRE, log_rev_iterator):
769
871
    for revs in log_rev_iterator:
770
 
        new_revs = []
771
 
        for (rev_id, revno, merge_depth), rev, delta in revs:
772
 
            if searchRE.search(rev.message):
773
 
                new_revs.append(((rev_id, revno, merge_depth), rev, delta))
774
 
        yield new_revs
775
 
 
 
872
        new_revs = [rev for rev in revs if _match_filter(searchRE, rev[1])]
 
873
        if new_revs:
 
874
            yield new_revs
 
875
 
 
876
def _match_filter(searchRE, rev):
 
877
    strings = {
 
878
               'message': (rev.message,),
 
879
               'committer': (rev.committer,),
 
880
               'author': (rev.get_apparent_authors()),
 
881
               'bugs': list(rev.iter_bugs())
 
882
               }
 
883
    strings[''] = [item for inner_list in strings.itervalues()
 
884
                   for item in inner_list]
 
885
    for (k,v) in searchRE:
 
886
        if k in strings and not _match_any_filter(strings[k], v):
 
887
            return False
 
888
    return True
 
889
 
 
890
def _match_any_filter(strings, res):
 
891
    return any([filter(None, map(re.search, strings)) for re in res])
776
892
 
777
893
def _make_delta_filter(branch, generate_delta, search, log_rev_iterator,
778
894
    fileids=None, direction='reverse'):
851
967
 
852
968
def _update_fileids(delta, fileids, stop_on):
853
969
    """Update the set of file-ids to search based on file lifecycle events.
854
 
    
 
970
 
855
971
    :param fileids: a set of fileids to update
856
972
    :param stop_on: either 'add' or 'remove' - take file-ids out of the
857
973
      fileids set once their add or remove entry is detected respectively
898
1014
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
899
1015
        delta).
900
1016
    """
901
 
    repository = branch.repository
902
1017
    num = 9
903
1018
    for batch in log_rev_iterator:
904
1019
        batch = iter(batch)
953
1068
    if branch_revno != 0:
954
1069
        if (start_rev_id == _mod_revision.NULL_REVISION
955
1070
            or end_rev_id == _mod_revision.NULL_REVISION):
956
 
            raise errors.BzrCommandError('Logging revision 0 is invalid.')
 
1071
            raise errors.BzrCommandError(gettext('Logging revision 0 is invalid.'))
957
1072
        if start_revno > end_revno:
958
 
            raise errors.BzrCommandError("Start revision must be older than "
959
 
                                         "the end revision.")
 
1073
            raise errors.BzrCommandError(gettext("Start revision must be "
 
1074
                                         "older than the end revision."))
960
1075
    return (start_rev_id, end_rev_id)
961
1076
 
962
1077
 
1011
1126
 
1012
1127
    if ((start_rev_id == _mod_revision.NULL_REVISION)
1013
1128
        or (end_rev_id == _mod_revision.NULL_REVISION)):
1014
 
        raise errors.BzrCommandError('Logging revision 0 is invalid.')
 
1129
        raise errors.BzrCommandError(gettext('Logging revision 0 is invalid.'))
1015
1130
    if start_revno > end_revno:
1016
 
        raise errors.BzrCommandError("Start revision must be older than "
1017
 
                                     "the end revision.")
 
1131
        raise errors.BzrCommandError(gettext("Start revision must be older "
 
1132
                                     "than the end revision."))
1018
1133
 
1019
1134
    if end_revno < start_revno:
1020
1135
        return None, None, None, None
1021
1136
    cur_revno = branch_revno
1022
1137
    rev_nos = {}
1023
1138
    mainline_revs = []
1024
 
    for revision_id in branch.repository.iter_reverse_revision_history(
1025
 
                        branch_last_revision):
 
1139
    graph = branch.repository.get_graph()
 
1140
    for revision_id in graph.iter_lefthand_ancestry(
 
1141
            branch_last_revision, (_mod_revision.NULL_REVISION,)):
1026
1142
        if cur_revno < start_revno:
1027
1143
            # We have gone far enough, but we always add 1 more revision
1028
1144
            rev_nos[revision_id] = cur_revno
1042
1158
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
1043
1159
 
1044
1160
 
1045
 
@deprecated_function(deprecated_in((2, 2, 0)))
1046
 
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
1047
 
    """Filter view_revisions based on revision ranges.
1048
 
 
1049
 
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth)
1050
 
            tuples to be filtered.
1051
 
 
1052
 
    :param start_rev_id: If not NONE specifies the first revision to be logged.
1053
 
            If NONE then all revisions up to the end_rev_id are logged.
1054
 
 
1055
 
    :param end_rev_id: If not NONE specifies the last revision to be logged.
1056
 
            If NONE then all revisions up to the end of the log are logged.
1057
 
 
1058
 
    :return: The filtered view_revisions.
1059
 
    """
1060
 
    if start_rev_id or end_rev_id:
1061
 
        revision_ids = [r for r, n, d in view_revisions]
1062
 
        if start_rev_id:
1063
 
            start_index = revision_ids.index(start_rev_id)
1064
 
        else:
1065
 
            start_index = 0
1066
 
        if start_rev_id == end_rev_id:
1067
 
            end_index = start_index
1068
 
        else:
1069
 
            if end_rev_id:
1070
 
                end_index = revision_ids.index(end_rev_id)
1071
 
            else:
1072
 
                end_index = len(view_revisions) - 1
1073
 
        # To include the revisions merged into the last revision,
1074
 
        # extend end_rev_id down to, but not including, the next rev
1075
 
        # with the same or lesser merge_depth
1076
 
        end_merge_depth = view_revisions[end_index][2]
1077
 
        try:
1078
 
            for index in xrange(end_index+1, len(view_revisions)+1):
1079
 
                if view_revisions[index][2] <= end_merge_depth:
1080
 
                    end_index = index - 1
1081
 
                    break
1082
 
        except IndexError:
1083
 
            # if the search falls off the end then log to the end as well
1084
 
            end_index = len(view_revisions) - 1
1085
 
        view_revisions = view_revisions[start_index:end_index+1]
1086
 
    return view_revisions
1087
 
 
1088
 
 
1089
1161
def _filter_revisions_touching_file_id(branch, file_id, view_revisions,
1090
1162
    include_merges=True):
1091
1163
    r"""Return the list of revision ids which touch a given file id.
1094
1166
    This includes the revisions which directly change the file id,
1095
1167
    and the revisions which merge these changes. So if the
1096
1168
    revision graph is::
 
1169
 
1097
1170
        A-.
1098
1171
        |\ \
1099
1172
        B C E
1126
1199
    """
1127
1200
    # Lookup all possible text keys to determine which ones actually modified
1128
1201
    # the file.
 
1202
    graph = branch.repository.get_file_graph()
 
1203
    get_parent_map = graph.get_parent_map
1129
1204
    text_keys = [(file_id, rev_id) for rev_id, revno, depth in view_revisions]
1130
1205
    next_keys = None
1131
1206
    # Looking up keys in batches of 1000 can cut the time in half, as well as
1135
1210
    #       indexing layer. We might consider passing in hints as to the known
1136
1211
    #       access pattern (sparse/clustered, high success rate/low success
1137
1212
    #       rate). This particular access is clustered with a low success rate.
1138
 
    get_parent_map = branch.repository.texts.get_parent_map
1139
1213
    modified_text_revisions = set()
1140
1214
    chunk_size = 1000
1141
1215
    for start in xrange(0, len(text_keys), chunk_size):
1168
1242
    return result
1169
1243
 
1170
1244
 
1171
 
@deprecated_function(deprecated_in((2, 2, 0)))
1172
 
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
1173
 
                       include_merges=True):
1174
 
    """Produce an iterator of revisions to show
1175
 
    :return: an iterator of (revision_id, revno, merge_depth)
1176
 
    (if there is no revno for a revision, None is supplied)
1177
 
    """
1178
 
    if not include_merges:
1179
 
        revision_ids = mainline_revs[1:]
1180
 
        if direction == 'reverse':
1181
 
            revision_ids.reverse()
1182
 
        for revision_id in revision_ids:
1183
 
            yield revision_id, str(rev_nos[revision_id]), 0
1184
 
        return
1185
 
    graph = branch.repository.get_graph()
1186
 
    # This asks for all mainline revisions, which means we only have to spider
1187
 
    # sideways, rather than depth history. That said, its still size-of-history
1188
 
    # and should be addressed.
1189
 
    # mainline_revisions always includes an extra revision at the beginning, so
1190
 
    # don't request it.
1191
 
    parent_map = dict(((key, value) for key, value in
1192
 
        graph.iter_ancestry(mainline_revs[1:]) if value is not None))
1193
 
    # filter out ghosts; merge_sort errors on ghosts.
1194
 
    rev_graph = _mod_repository._strip_NULL_ghosts(parent_map)
1195
 
    merge_sorted_revisions = tsort.merge_sort(
1196
 
        rev_graph,
1197
 
        mainline_revs[-1],
1198
 
        mainline_revs,
1199
 
        generate_revno=True)
1200
 
 
1201
 
    if direction == 'forward':
1202
 
        # forward means oldest first.
1203
 
        merge_sorted_revisions = reverse_by_depth(merge_sorted_revisions)
1204
 
    elif direction != 'reverse':
1205
 
        raise ValueError('invalid direction %r' % direction)
1206
 
 
1207
 
    for (sequence, rev_id, merge_depth, revno, end_of_merge
1208
 
         ) in merge_sorted_revisions:
1209
 
        yield rev_id, '.'.join(map(str, revno)), merge_depth
1210
 
 
1211
 
 
1212
1245
def reverse_by_depth(merge_sorted_revisions, _depth=0):
1213
1246
    """Reverse revisions by depth.
1214
1247
 
1249
1282
    """
1250
1283
 
1251
1284
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
1252
 
                 tags=None, diff=None):
 
1285
                 tags=None, diff=None, signature=None):
1253
1286
        self.rev = rev
1254
 
        self.revno = str(revno)
 
1287
        if revno is None:
 
1288
            self.revno = None
 
1289
        else:
 
1290
            self.revno = str(revno)
1255
1291
        self.merge_depth = merge_depth
1256
1292
        self.delta = delta
1257
1293
        self.tags = tags
1258
1294
        self.diff = diff
 
1295
        self.signature = signature
1259
1296
 
1260
1297
 
1261
1298
class LogFormatter(object):
1270
1307
    to indicate which LogRevision attributes it supports:
1271
1308
 
1272
1309
    - supports_delta must be True if this log formatter supports delta.
1273
 
        Otherwise the delta attribute may not be populated.  The 'delta_format'
1274
 
        attribute describes whether the 'short_status' format (1) or the long
1275
 
        one (2) should be used.
 
1310
      Otherwise the delta attribute may not be populated.  The 'delta_format'
 
1311
      attribute describes whether the 'short_status' format (1) or the long
 
1312
      one (2) should be used.
1276
1313
 
1277
1314
    - supports_merge_revisions must be True if this log formatter supports
1278
 
        merge revisions.  If not, then only mainline revisions will be passed
1279
 
        to the formatter.
 
1315
      merge revisions.  If not, then only mainline revisions will be passed
 
1316
      to the formatter.
1280
1317
 
1281
1318
    - preferred_levels is the number of levels this formatter defaults to.
1282
 
        The default value is zero meaning display all levels.
1283
 
        This value is only relevant if supports_merge_revisions is True.
 
1319
      The default value is zero meaning display all levels.
 
1320
      This value is only relevant if supports_merge_revisions is True.
1284
1321
 
1285
1322
    - supports_tags must be True if this log formatter supports tags.
1286
 
        Otherwise the tags attribute may not be populated.
 
1323
      Otherwise the tags attribute may not be populated.
1287
1324
 
1288
1325
    - supports_diff must be True if this log formatter supports diffs.
1289
 
        Otherwise the diff attribute may not be populated.
 
1326
      Otherwise the diff attribute may not be populated.
 
1327
 
 
1328
    - supports_signatures must be True if this log formatter supports GPG
 
1329
      signatures.
1290
1330
 
1291
1331
    Plugins can register functions to show custom revision properties using
1292
1332
    the properties_handler_registry. The registered function
1293
 
    must respect the following interface description:
 
1333
    must respect the following interface description::
 
1334
 
1294
1335
        def my_show_properties(properties_dict):
1295
1336
            # code that returns a dict {'name':'value'} of the properties
1296
1337
            # to be shown
1299
1340
 
1300
1341
    def __init__(self, to_file, show_ids=False, show_timezone='original',
1301
1342
                 delta_format=None, levels=None, show_advice=False,
1302
 
                 to_exact_file=None):
 
1343
                 to_exact_file=None, author_list_handler=None):
1303
1344
        """Create a LogFormatter.
1304
1345
 
1305
1346
        :param to_file: the file to output to
1306
 
        :param to_exact_file: if set, gives an output stream to which 
 
1347
        :param to_exact_file: if set, gives an output stream to which
1307
1348
             non-Unicode diffs are written.
1308
1349
        :param show_ids: if True, revision-ids are to be displayed
1309
1350
        :param show_timezone: the timezone to use
1313
1354
          let the log formatter decide.
1314
1355
        :param show_advice: whether to show advice at the end of the
1315
1356
          log or not
 
1357
        :param author_list_handler: callable generating a list of
 
1358
          authors to display for a given revision
1316
1359
        """
1317
1360
        self.to_file = to_file
1318
1361
        # 'exact' stream used to show diff, it should print content 'as is'
1333
1376
        self.levels = levels
1334
1377
        self._show_advice = show_advice
1335
1378
        self._merge_count = 0
 
1379
        self._author_list_handler = author_list_handler
1336
1380
 
1337
1381
    def get_levels(self):
1338
1382
        """Get the number of levels to display or 0 for all."""
1357
1401
            if advice_sep:
1358
1402
                self.to_file.write(advice_sep)
1359
1403
            self.to_file.write(
1360
 
                "Use --include-merges or -n0 to see merged revisions.\n")
 
1404
                "Use --include-merged or -n0 to see merged revisions.\n")
1361
1405
 
1362
1406
    def get_advice_separator(self):
1363
1407
        """Get the text separating the log from the closing advice."""
1370
1414
        return address
1371
1415
 
1372
1416
    def short_author(self, rev):
1373
 
        name, address = config.parse_username(rev.get_apparent_authors()[0])
1374
 
        if name:
1375
 
            return name
1376
 
        return address
 
1417
        return self.authors(rev, 'first', short=True, sep=', ')
 
1418
 
 
1419
    def authors(self, rev, who, short=False, sep=None):
 
1420
        """Generate list of authors, taking --authors option into account.
 
1421
 
 
1422
        The caller has to specify the name of a author list handler,
 
1423
        as provided by the author list registry, using the ``who``
 
1424
        argument.  That name only sets a default, though: when the
 
1425
        user selected a different author list generation using the
 
1426
        ``--authors`` command line switch, as represented by the
 
1427
        ``author_list_handler`` constructor argument, that value takes
 
1428
        precedence.
 
1429
 
 
1430
        :param rev: The revision for which to generate the list of authors.
 
1431
        :param who: Name of the default handler.
 
1432
        :param short: Whether to shorten names to either name or address.
 
1433
        :param sep: What separator to use for automatic concatenation.
 
1434
        """
 
1435
        if self._author_list_handler is not None:
 
1436
            # The user did specify --authors, which overrides the default
 
1437
            author_list_handler = self._author_list_handler
 
1438
        else:
 
1439
            # The user didn't specify --authors, so we use the caller's default
 
1440
            author_list_handler = author_list_registry.get(who)
 
1441
        names = author_list_handler(rev)
 
1442
        if short:
 
1443
            for i in range(len(names)):
 
1444
                name, address = config.parse_username(names[i])
 
1445
                if name:
 
1446
                    names[i] = name
 
1447
                else:
 
1448
                    names[i] = address
 
1449
        if sep is not None:
 
1450
            names = sep.join(names)
 
1451
        return names
1377
1452
 
1378
1453
    def merge_marker(self, revision):
1379
1454
        """Get the merge marker to include in the output or '' if none."""
1410
1485
        """
1411
1486
        # Revision comes directly from a foreign repository
1412
1487
        if isinstance(rev, foreign.ForeignRevision):
1413
 
            return rev.mapping.vcs.show_foreign_revid(rev.foreign_revid)
 
1488
            return self._format_properties(
 
1489
                rev.mapping.vcs.show_foreign_revid(rev.foreign_revid))
1414
1490
 
1415
1491
        # Imported foreign revision revision ids always contain :
1416
1492
        if not ":" in rev.revision_id:
1448
1524
    supports_delta = True
1449
1525
    supports_tags = True
1450
1526
    supports_diff = True
 
1527
    supports_signatures = True
1451
1528
 
1452
1529
    def __init__(self, *args, **kwargs):
1453
1530
        super(LongLogFormatter, self).__init__(*args, **kwargs)
1473
1550
                self.merge_marker(revision)))
1474
1551
        if revision.tags:
1475
1552
            lines.append('tags: %s' % (', '.join(revision.tags)))
1476
 
        if self.show_ids:
 
1553
        if self.show_ids or revision.revno is None:
1477
1554
            lines.append('revision-id: %s' % (revision.rev.revision_id,))
 
1555
        if self.show_ids:
1478
1556
            for parent_id in revision.rev.parent_ids:
1479
1557
                lines.append('parent: %s' % (parent_id,))
1480
1558
        lines.extend(self.custom_properties(revision.rev))
1481
1559
 
1482
1560
        committer = revision.rev.committer
1483
 
        authors = revision.rev.get_apparent_authors()
 
1561
        authors = self.authors(revision.rev, 'all')
1484
1562
        if authors != [committer]:
1485
1563
            lines.append('author: %s' % (", ".join(authors),))
1486
1564
        lines.append('committer: %s' % (committer,))
1491
1569
 
1492
1570
        lines.append('timestamp: %s' % (self.date_string(revision.rev),))
1493
1571
 
 
1572
        if revision.signature is not None:
 
1573
            lines.append('signature: ' + revision.signature)
 
1574
 
1494
1575
        lines.append('message:')
1495
1576
        if not revision.rev.message:
1496
1577
            lines.append('  (no message)')
1503
1584
        to_file = self.to_file
1504
1585
        to_file.write("%s%s\n" % (indent, ('\n' + indent).join(lines)))
1505
1586
        if revision.delta is not None:
1506
 
            # We don't respect delta_format for compatibility
1507
 
            revision.delta.show(to_file, self.show_ids, indent=indent,
1508
 
                                short_status=False)
 
1587
            # Use the standard status output to display changes
 
1588
            from bzrlib.delta import report_delta
 
1589
            report_delta(to_file, revision.delta, short_status=False,
 
1590
                         show_ids=self.show_ids, indent=indent)
1509
1591
        if revision.diff is not None:
1510
1592
            to_file.write(indent + 'diff:\n')
1511
1593
            to_file.flush()
1542
1624
        indent = '    ' * depth
1543
1625
        revno_width = self.revno_width_by_depth.get(depth)
1544
1626
        if revno_width is None:
1545
 
            if revision.revno.find('.') == -1:
 
1627
            if revision.revno is None or revision.revno.find('.') == -1:
1546
1628
                # mainline revno, e.g. 12345
1547
1629
                revno_width = 5
1548
1630
            else:
1556
1638
        if revision.tags:
1557
1639
            tags = ' {%s}' % (', '.join(revision.tags))
1558
1640
        to_file.write(indent + "%*s %s\t%s%s%s\n" % (revno_width,
1559
 
                revision.revno, self.short_author(revision.rev),
 
1641
                revision.revno or "", self.short_author(revision.rev),
1560
1642
                format_date(revision.rev.timestamp,
1561
1643
                            revision.rev.timezone or 0,
1562
1644
                            self.show_timezone, date_fmt="%Y-%m-%d",
1563
1645
                            show_offset=False),
1564
1646
                tags, self.merge_marker(revision)))
1565
1647
        self.show_properties(revision.rev, indent+offset)
1566
 
        if self.show_ids:
 
1648
        if self.show_ids or revision.revno is None:
1567
1649
            to_file.write(indent + offset + 'revision-id:%s\n'
1568
1650
                          % (revision.rev.revision_id,))
1569
1651
        if not revision.rev.message:
1574
1656
                to_file.write(indent + offset + '%s\n' % (l,))
1575
1657
 
1576
1658
        if revision.delta is not None:
1577
 
            revision.delta.show(to_file, self.show_ids, indent=indent + offset,
1578
 
                                short_status=self.delta_format==1)
 
1659
            # Use the standard status output to display changes
 
1660
            from bzrlib.delta import report_delta
 
1661
            report_delta(to_file, revision.delta,
 
1662
                         short_status=self.delta_format==1,
 
1663
                         show_ids=self.show_ids, indent=indent + offset)
1579
1664
        if revision.diff is not None:
1580
1665
            self.show_diff(self.to_exact_file, revision.diff, '      ')
1581
1666
        to_file.write('\n')
1619
1704
 
1620
1705
    def log_string(self, revno, rev, max_chars, tags=None, prefix=''):
1621
1706
        """Format log info into one string. Truncate tail of string
1622
 
        :param  revno:      revision number or None.
1623
 
                            Revision numbers counts from 1.
1624
 
        :param  rev:        revision object
1625
 
        :param  max_chars:  maximum length of resulting string
1626
 
        :param  tags:       list of tags or None
1627
 
        :param  prefix:     string to prefix each line
1628
 
        :return:            formatted truncated string
 
1707
 
 
1708
        :param revno:      revision number or None.
 
1709
                           Revision numbers counts from 1.
 
1710
        :param rev:        revision object
 
1711
        :param max_chars:  maximum length of resulting string
 
1712
        :param tags:       list of tags or None
 
1713
        :param prefix:     string to prefix each line
 
1714
        :return:           formatted truncated string
1629
1715
        """
1630
1716
        out = []
1631
1717
        if revno:
1632
1718
            # show revno only when is not None
1633
1719
            out.append("%s:" % revno)
1634
 
        out.append(self.truncate(self.short_author(rev), 20))
 
1720
        if max_chars is not None:
 
1721
            out.append(self.truncate(self.short_author(rev), (max_chars+3)/4))
 
1722
        else:
 
1723
            out.append(self.short_author(rev))
1635
1724
        out.append(self.date_string(rev))
1636
1725
        if len(rev.parent_ids) > 1:
1637
1726
            out.append('[merge]')
1656
1745
                               self.show_timezone,
1657
1746
                               date_fmt='%Y-%m-%d',
1658
1747
                               show_offset=False)
1659
 
        committer_str = revision.rev.committer.replace (' <', '  <')
 
1748
        committer_str = self.authors(revision.rev, 'first', sep=', ')
 
1749
        committer_str = committer_str.replace(' <', '  <')
1660
1750
        to_file.write('%s  %s\n\n' % (date_str,committer_str))
1661
1751
 
1662
1752
        if revision.delta is not None and revision.delta.has_changed():
1695
1785
        return self.get(name)(*args, **kwargs)
1696
1786
 
1697
1787
    def get_default(self, branch):
1698
 
        return self.get(branch.get_config().log_format())
 
1788
        c = branch.get_config_stack()
 
1789
        return self.get(c.get('log_format'))
1699
1790
 
1700
1791
 
1701
1792
log_formatter_registry = LogFormatterRegistry()
1702
1793
 
1703
1794
 
1704
1795
log_formatter_registry.register('short', ShortLogFormatter,
1705
 
                                'Moderately short log format')
 
1796
                                'Moderately short log format.')
1706
1797
log_formatter_registry.register('long', LongLogFormatter,
1707
 
                                'Detailed log format')
 
1798
                                'Detailed log format.')
1708
1799
log_formatter_registry.register('line', LineLogFormatter,
1709
 
                                'Log format with one line per revision')
 
1800
                                'Log format with one line per revision.')
1710
1801
log_formatter_registry.register('gnu-changelog', GnuChangelogLogFormatter,
1711
 
                                'Format used by GNU ChangeLog files')
 
1802
                                'Format used by GNU ChangeLog files.')
1712
1803
 
1713
1804
 
1714
1805
def register_formatter(name, formatter):
1724
1815
    try:
1725
1816
        return log_formatter_registry.make_formatter(name, *args, **kwargs)
1726
1817
    except KeyError:
1727
 
        raise errors.BzrCommandError("unknown log formatter: %r" % name)
1728
 
 
1729
 
 
1730
 
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
1731
 
    # deprecated; for compatibility
1732
 
    lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
1733
 
    lf.show(revno, rev, delta)
 
1818
        raise errors.BzrCommandError(gettext("unknown log formatter: %r") % name)
 
1819
 
 
1820
 
 
1821
def author_list_all(rev):
 
1822
    return rev.get_apparent_authors()[:]
 
1823
 
 
1824
 
 
1825
def author_list_first(rev):
 
1826
    lst = rev.get_apparent_authors()
 
1827
    try:
 
1828
        return [lst[0]]
 
1829
    except IndexError:
 
1830
        return []
 
1831
 
 
1832
 
 
1833
def author_list_committer(rev):
 
1834
    return [rev.committer]
 
1835
 
 
1836
 
 
1837
author_list_registry = registry.Registry()
 
1838
 
 
1839
author_list_registry.register('all', author_list_all,
 
1840
                              'All authors')
 
1841
 
 
1842
author_list_registry.register('first', author_list_first,
 
1843
                              'The first author')
 
1844
 
 
1845
author_list_registry.register('committer', author_list_committer,
 
1846
                              'The committer')
1734
1847
 
1735
1848
 
1736
1849
def show_changed_revisions(branch, old_rh, new_rh, to_file=None,
1801
1914
    old_revisions = set()
1802
1915
    new_history = []
1803
1916
    new_revisions = set()
1804
 
    new_iter = repository.iter_reverse_revision_history(new_revision_id)
1805
 
    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)
1806
1920
    stop_revision = None
1807
1921
    do_old = True
1808
1922
    do_new = True
1883
1997
        lf.log_revision(lr)
1884
1998
 
1885
1999
 
1886
 
def _get_info_for_log_files(revisionspec_list, file_list):
 
2000
def _get_info_for_log_files(revisionspec_list, file_list, add_cleanup):
1887
2001
    """Find file-ids and kinds given a list of files and a revision range.
1888
2002
 
1889
2003
    We search for files at the end of the range. If not found there,
1893
2007
    :param file_list: the list of paths given on the command line;
1894
2008
      the first of these can be a branch location or a file path,
1895
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.
1896
2012
    :return: (branch, info_list, start_rev_info, end_rev_info) where
1897
2013
      info_list is a list of (relative_path, file_id, kind) tuples where
1898
2014
      kind is one of values 'directory', 'file', 'symlink', 'tree-reference'.
1899
2015
      branch will be read-locked.
1900
2016
    """
1901
 
    from builtins import _get_revision_range, safe_relpath_files
1902
 
    tree, b, path = bzrdir.BzrDir.open_containing_tree_or_branch(file_list[0])
1903
 
    b.lock_read()
 
2017
    from bzrlib.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)
1904
2021
    # XXX: It's damn messy converting a list of paths to relative paths when
1905
2022
    # those paths might be deleted ones, they might be on a case-insensitive
1906
2023
    # filesystem and/or they might be in silly locations (like another branch).
1910
2027
    # case of running log in a nested directory, assuming paths beyond the
1911
2028
    # first one haven't been deleted ...
1912
2029
    if tree:
1913
 
        relpaths = [path] + safe_relpath_files(tree, file_list[1:])
 
2030
        relpaths = [path] + tree.safe_relpath_files(file_list[1:])
1914
2031
    else:
1915
2032
        relpaths = [path] + file_list[1:]
1916
2033
    info_list = []
1992
2109
        bug_rows = [line.split(' ', 1) for line in bug_lines]
1993
2110
        fixed_bug_urls = [row[0] for row in bug_rows if
1994
2111
                          len(row) > 1 and row[1] == 'fixed']
1995
 
        
 
2112
 
1996
2113
        if fixed_bug_urls:
1997
 
            return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
 
2114
            return {ngettext('fixes bug', 'fixes bugs', len(fixed_bug_urls)):\
 
2115
                    ' '.join(fixed_bug_urls)}
1998
2116
    return {}
1999
2117
 
2000
2118
properties_handler_registry.register('bugs_properties_handler',