~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: Vincent Ladeuil
  • Date: 2009-05-04 14:48:21 UTC
  • mto: (4349.1.1 integration)
  • mto: This revision was merged to the branch mainline in revision 4350.
  • Revision ID: v.ladeuil+lp@free.fr-20090504144821-39dvqkikmd3zqkdg
Handle servers proposing several authentication schemes.

* bzrlib/transport/http/_urllib2_wrappers.py:
(AbstractAuthHandler.auth_required): Several schemes can be
proposed by the server, try to match each one in turn.
(BasicAuthHandler.auth_match): Delete dead code.

* bzrlib/tests/test_http.py:
(load_tests): Separate proxy and http authentication tests as they
require different server setups.
(TestAuth.create_transport_readonly_server): Simplified by using
parameter provided by load_tests.
(TestAuth.test_changing_nonce): Adapt to new parametrization.
(TestProxyAuth.create_transport_readonly_server): Deleted.

* bzrlib/tests/http_utils.py:
(DigestAndBasicAuthRequestHandler, HTTPBasicAndDigestAuthServer,
ProxyBasicAndDigestAuthServer): Add a test server proposing both
basic and digest auth schemes but accepting only digest as valid.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2011 Canonical Ltd
 
1
# Copyright (C) 2005, 2006, 2007, 2009 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
69
69
    config,
70
70
    diff,
71
71
    errors,
72
 
    foreign,
73
72
    repository as _mod_repository,
74
73
    revision as _mod_revision,
75
74
    revisionspec,
 
75
    trace,
76
76
    tsort,
77
 
    i18n,
78
77
    )
79
78
""")
80
79
 
81
80
from bzrlib import (
82
 
    lazy_regex,
83
81
    registry,
84
82
    )
85
83
from bzrlib.osutils import (
86
84
    format_date,
87
 
    format_date_with_offset_in_original_timezone,
88
 
    get_diff_header_encoding,
89
85
    get_terminal_encoding,
 
86
    re_compile_checked,
90
87
    terminal_width,
91
88
    )
92
 
from bzrlib.symbol_versioning import (
93
 
    deprecated_function,
94
 
    deprecated_in,
95
 
    )
96
89
 
97
90
 
98
91
def find_touching_revisions(branch, file_id):
110
103
    last_path = None
111
104
    revno = 1
112
105
    for revision_id in branch.revision_history():
113
 
        this_inv = branch.repository.get_inventory(revision_id)
114
 
        if this_inv.has_id(file_id):
 
106
        this_inv = branch.repository.get_revision_inventory(revision_id)
 
107
        if file_id in this_inv:
115
108
            this_ie = this_inv[file_id]
116
109
            this_path = this_inv.id2path(file_id)
117
110
        else:
221
214
    'direction': 'reverse',
222
215
    'levels': 1,
223
216
    'generate_tags': True,
224
 
    'exclude_common_ancestry': False,
225
217
    '_match_using_deltas': True,
226
218
    }
227
219
 
228
220
 
229
221
def make_log_request_dict(direction='reverse', specific_fileids=None,
230
 
                          start_revision=None, end_revision=None, limit=None,
231
 
                          message_search=None, levels=1, generate_tags=True,
232
 
                          delta_type=None,
233
 
                          diff_type=None, _match_using_deltas=True,
234
 
                          exclude_common_ancestry=False,
235
 
                          signature=False,
236
 
                          ):
 
222
    start_revision=None, end_revision=None, limit=None,
 
223
    message_search=None, levels=1, generate_tags=True, delta_type=None,
 
224
    diff_type=None, _match_using_deltas=True):
237
225
    """Convenience function for making a logging request dictionary.
238
226
 
239
227
    Using this function may make code slightly safer by ensuring
262
250
      generate; 1 for just the mainline; 0 for all levels.
263
251
 
264
252
    :param generate_tags: If True, include tags for matched revisions.
265
 
`
 
253
 
266
254
    :param delta_type: Either 'full', 'partial' or None.
267
255
      'full' means generate the complete delta - adds/deletes/modifies/etc;
268
256
      'partial' means filter the delta using specific_fileids;
277
265
      algorithm used for matching specific_fileids. This parameter
278
266
      may be removed in the future so bzrlib client code should NOT
279
267
      use it.
280
 
 
281
 
    :param exclude_common_ancestry: Whether -rX..Y should be interpreted as a
282
 
      range operator or as a graph difference.
283
 
 
284
 
    :param signature: show digital signature information
285
268
    """
286
269
    return {
287
270
        'direction': direction,
294
277
        'generate_tags': generate_tags,
295
278
        'delta_type': delta_type,
296
279
        'diff_type': diff_type,
297
 
        'exclude_common_ancestry': exclude_common_ancestry,
298
 
        'signature': signature,
299
280
        # Add 'private' attributes for features that may be deprecated
300
281
        '_match_using_deltas': _match_using_deltas,
301
282
    }
303
284
 
304
285
def _apply_log_request_defaults(rqst):
305
286
    """Apply default values to a request dictionary."""
306
 
    result = _DEFAULT_REQUEST_PARAMS.copy()
 
287
    result = _DEFAULT_REQUEST_PARAMS
307
288
    if rqst:
308
289
        result.update(rqst)
309
290
    return result
310
291
 
311
292
 
312
 
def format_signature_validity(rev_id, repo):
313
 
    """get the signature validity
314
 
    
315
 
    :param rev_id: revision id to validate
316
 
    :param repo: repository of revision
317
 
    :return: human readable string to print to log
318
 
    """
319
 
    from bzrlib import gpg
320
 
 
321
 
    gpg_strategy = gpg.GPGStrategy(None)
322
 
    result = repo.verify_revision(rev_id, gpg_strategy)
323
 
    if result[0] == gpg.SIGNATURE_VALID:
324
 
        return "valid signature from {0}".format(result[1])
325
 
    if result[0] == gpg.SIGNATURE_KEY_MISSING:
326
 
        return "unknown key {0}".format(result[1])
327
 
    if result[0] == gpg.SIGNATURE_NOT_VALID:
328
 
        return "invalid signature!"
329
 
    if result[0] == gpg.SIGNATURE_NOT_SIGNED:
330
 
        return "no signature"
331
 
 
332
 
 
333
293
class LogGenerator(object):
334
294
    """A generator of log revisions."""
335
295
 
342
302
 
343
303
 
344
304
class Logger(object):
345
 
    """An object that generates, formats and displays a log."""
 
305
    """An object the generates, formats and displays a log."""
346
306
 
347
307
    def __init__(self, branch, rqst):
348
308
        """Create a Logger.
387
347
            rqst['delta_type'] = None
388
348
        if not getattr(lf, 'supports_diff', False):
389
349
            rqst['diff_type'] = None
390
 
        if not getattr(lf, 'supports_signatures', False):
391
 
            rqst['signature'] = False
392
350
 
393
351
        # Find and print the interesting revisions
394
352
        generator = self._generator_factory(self.branch, rqst)
425
383
        :return: An iterator yielding LogRevision objects.
426
384
        """
427
385
        rqst = self.rqst
428
 
        levels = rqst.get('levels')
429
 
        limit = rqst.get('limit')
430
 
        diff_type = rqst.get('diff_type')
431
 
        show_signature = rqst.get('signature')
432
386
        log_count = 0
433
387
        revision_iterator = self._create_log_revision_iterator()
434
388
        for revs in revision_iterator:
435
389
            for (rev_id, revno, merge_depth), rev, delta in revs:
436
390
                # 0 levels means show everything; merge_depth counts from 0
 
391
                levels = rqst.get('levels')
437
392
                if levels != 0 and merge_depth >= levels:
438
393
                    continue
439
 
                if diff_type is None:
440
 
                    diff = None
441
 
                else:
442
 
                    diff = self._format_diff(rev, rev_id, diff_type)
443
 
                if show_signature:
444
 
                    signature = format_signature_validity(rev_id,
445
 
                                                self.branch.repository)
446
 
                else:
447
 
                    signature = None
 
394
                diff = self._format_diff(rev, rev_id)
448
395
                yield LogRevision(rev, revno, merge_depth, delta,
449
 
                    self.rev_tag_dict.get(rev_id), diff, signature)
 
396
                    self.rev_tag_dict.get(rev_id), diff)
 
397
                limit = rqst.get('limit')
450
398
                if limit:
451
399
                    log_count += 1
452
400
                    if log_count >= limit:
453
401
                        return
454
402
 
455
 
    def _format_diff(self, rev, rev_id, diff_type):
 
403
    def _format_diff(self, rev, rev_id):
 
404
        diff_type = self.rqst.get('diff_type')
 
405
        if diff_type is None:
 
406
            return None
456
407
        repo = self.branch.repository
457
408
        if len(rev.parent_ids) == 0:
458
409
            ancestor_id = _mod_revision.NULL_REVISION
466
417
        else:
467
418
            specific_files = None
468
419
        s = StringIO()
469
 
        path_encoding = get_diff_header_encoding()
470
420
        diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
471
 
            new_label='', path_encoding=path_encoding)
 
421
            new_label='')
472
422
        return s.getvalue()
473
423
 
474
424
    def _create_log_revision_iterator(self):
498
448
        generate_merge_revisions = rqst.get('levels') != 1
499
449
        delayed_graph_generation = not rqst.get('specific_fileids') and (
500
450
                rqst.get('limit') or self.start_rev_id or self.end_rev_id)
501
 
        view_revisions = _calc_view_revisions(
502
 
            self.branch, self.start_rev_id, self.end_rev_id,
503
 
            rqst.get('direction'),
504
 
            generate_merge_revisions=generate_merge_revisions,
505
 
            delayed_graph_generation=delayed_graph_generation,
506
 
            exclude_common_ancestry=rqst.get('exclude_common_ancestry'))
 
451
        view_revisions = _calc_view_revisions(self.branch, self.start_rev_id,
 
452
            self.end_rev_id, rqst.get('direction'), generate_merge_revisions,
 
453
            delayed_graph_generation=delayed_graph_generation)
507
454
 
508
455
        # Apply the other filters
509
456
        return make_log_rev_iterator(self.branch, view_revisions,
516
463
        # Note that we always generate the merge revisions because
517
464
        # filter_revisions_touching_file_id() requires them ...
518
465
        rqst = self.rqst
519
 
        view_revisions = _calc_view_revisions(
520
 
            self.branch, self.start_rev_id, self.end_rev_id,
521
 
            rqst.get('direction'), generate_merge_revisions=True,
522
 
            exclude_common_ancestry=rqst.get('exclude_common_ancestry'))
 
466
        view_revisions = _calc_view_revisions(self.branch, self.start_rev_id,
 
467
            self.end_rev_id, rqst.get('direction'), True)
523
468
        if not isinstance(view_revisions, list):
524
469
            view_revisions = list(view_revisions)
525
470
        view_revisions = _filter_revisions_touching_file_id(self.branch,
530
475
 
531
476
 
532
477
def _calc_view_revisions(branch, start_rev_id, end_rev_id, direction,
533
 
                         generate_merge_revisions,
534
 
                         delayed_graph_generation=False,
535
 
                         exclude_common_ancestry=False,
536
 
                         ):
 
478
    generate_merge_revisions, delayed_graph_generation=False):
537
479
    """Calculate the revisions to view.
538
480
 
539
481
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
540
482
             a list of the same tuples.
541
483
    """
542
 
    if (exclude_common_ancestry and start_rev_id == end_rev_id):
543
 
        raise errors.BzrCommandError(
544
 
            '--exclude-common-ancestry requires two different revisions')
545
 
    if direction not in ('reverse', 'forward'):
546
 
        raise ValueError('invalid direction %r' % direction)
547
484
    br_revno, br_rev_id = branch.last_revision_info()
548
485
    if br_revno == 0:
549
486
        return []
550
487
 
551
 
    if (end_rev_id and start_rev_id == end_rev_id
552
 
        and (not generate_merge_revisions
553
 
             or not _has_merges(branch, end_rev_id))):
554
 
        # If a single revision is requested, check we can handle it
555
 
        iter_revs = _generate_one_revision(branch, end_rev_id, br_rev_id,
556
 
                                           br_revno)
557
 
    elif not generate_merge_revisions:
558
 
        # If we only want to see linear revisions, we can iterate ...
559
 
        iter_revs = _generate_flat_revisions(branch, start_rev_id, end_rev_id,
560
 
                                             direction, exclude_common_ancestry)
561
 
        if direction == 'forward':
562
 
            iter_revs = reversed(iter_revs)
 
488
    # If a single revision is requested, check we can handle it
 
489
    generate_single_revision = (end_rev_id and start_rev_id == end_rev_id and
 
490
        (not generate_merge_revisions or not _has_merges(branch, end_rev_id)))
 
491
    if generate_single_revision:
 
492
        return _generate_one_revision(branch, end_rev_id, br_rev_id, br_revno)
 
493
 
 
494
    # If we only want to see linear revisions, we can iterate ...
 
495
    if not generate_merge_revisions:
 
496
        return _generate_flat_revisions(branch, start_rev_id, end_rev_id,
 
497
            direction)
563
498
    else:
564
 
        iter_revs = _generate_all_revisions(branch, start_rev_id, end_rev_id,
565
 
                                            direction, delayed_graph_generation,
566
 
                                            exclude_common_ancestry)
567
 
        if direction == 'forward':
568
 
            iter_revs = _rebase_merge_depth(reverse_by_depth(list(iter_revs)))
569
 
    return iter_revs
 
499
        return _generate_all_revisions(branch, start_rev_id, end_rev_id,
 
500
            direction, delayed_graph_generation)
570
501
 
571
502
 
572
503
def _generate_one_revision(branch, rev_id, br_rev_id, br_revno):
574
505
        # It's the tip
575
506
        return [(br_rev_id, br_revno, 0)]
576
507
    else:
577
 
        revno_str = _compute_revno_str(branch, rev_id)
 
508
        revno = branch.revision_id_to_dotted_revno(rev_id)
 
509
        revno_str = '.'.join(str(n) for n in revno)
578
510
        return [(rev_id, revno_str, 0)]
579
511
 
580
512
 
581
 
def _generate_flat_revisions(branch, start_rev_id, end_rev_id, direction,
582
 
                             exclude_common_ancestry=False):
583
 
    result = _linear_view_revisions(
584
 
        branch, start_rev_id, end_rev_id,
585
 
        exclude_common_ancestry=exclude_common_ancestry)
 
513
def _generate_flat_revisions(branch, start_rev_id, end_rev_id, direction):
 
514
    result = _linear_view_revisions(branch, start_rev_id, end_rev_id)
586
515
    # If a start limit was given and it's not obviously an
587
516
    # ancestor of the end limit, check it before outputting anything
588
517
    if direction == 'forward' or (start_rev_id
592
521
        except _StartNotLinearAncestor:
593
522
            raise errors.BzrCommandError('Start revision not found in'
594
523
                ' left-hand history of end revision.')
 
524
    if direction == 'forward':
 
525
        result = reversed(result)
595
526
    return result
596
527
 
597
528
 
598
529
def _generate_all_revisions(branch, start_rev_id, end_rev_id, direction,
599
 
                            delayed_graph_generation,
600
 
                            exclude_common_ancestry=False):
 
530
    delayed_graph_generation):
601
531
    # On large trees, generating the merge graph can take 30-60 seconds
602
532
    # so we delay doing it until a merge is detected, incrementally
603
533
    # returning initial (non-merge) revisions while we can.
604
 
 
605
 
    # The above is only true for old formats (<= 0.92), for newer formats, a
606
 
    # couple of seconds only should be needed to load the whole graph and the
607
 
    # other graph operations needed are even faster than that -- vila 100201
608
534
    initial_revisions = []
609
535
    if delayed_graph_generation:
610
536
        try:
611
 
            for rev_id, revno, depth in  _linear_view_revisions(
612
 
                branch, start_rev_id, end_rev_id, exclude_common_ancestry):
 
537
            for rev_id, revno, depth in \
 
538
                _linear_view_revisions(branch, start_rev_id, end_rev_id):
613
539
                if _has_merges(branch, rev_id):
614
 
                    # The end_rev_id can be nested down somewhere. We need an
615
 
                    # explicit ancestry check. There is an ambiguity here as we
616
 
                    # may not raise _StartNotLinearAncestor for a revision that
617
 
                    # is an ancestor but not a *linear* one. But since we have
618
 
                    # loaded the graph to do the check (or calculate a dotted
619
 
                    # revno), we may as well accept to show the log...  We need
620
 
                    # the check only if start_rev_id is not None as all
621
 
                    # revisions have _mod_revision.NULL_REVISION as an ancestor
622
 
                    # -- vila 20100319
623
 
                    graph = branch.repository.get_graph()
624
 
                    if (start_rev_id is not None
625
 
                        and not graph.is_ancestor(start_rev_id, end_rev_id)):
626
 
                        raise _StartNotLinearAncestor()
627
 
                    # Since we collected the revisions so far, we need to
628
 
                    # adjust end_rev_id.
629
540
                    end_rev_id = rev_id
630
541
                    break
631
542
                else:
632
543
                    initial_revisions.append((rev_id, revno, depth))
633
544
            else:
634
545
                # No merged revisions found
635
 
                return initial_revisions
 
546
                if direction == 'reverse':
 
547
                    return initial_revisions
 
548
                elif direction == 'forward':
 
549
                    return reversed(initial_revisions)
 
550
                else:
 
551
                    raise ValueError('invalid direction %r' % direction)
636
552
        except _StartNotLinearAncestor:
637
553
            # A merge was never detected so the lower revision limit can't
638
554
            # be nested down somewhere
639
555
            raise errors.BzrCommandError('Start revision not found in'
640
556
                ' history of end revision.')
641
557
 
642
 
    # We exit the loop above because we encounter a revision with merges, from
643
 
    # this revision, we need to switch to _graph_view_revisions.
644
 
 
645
558
    # A log including nested merges is required. If the direction is reverse,
646
559
    # we rebase the initial merge depths so that the development line is
647
560
    # shown naturally, i.e. just like it is for linear logging. We can easily
649
562
    # indented at the end seems slightly nicer in that case.
650
563
    view_revisions = chain(iter(initial_revisions),
651
564
        _graph_view_revisions(branch, start_rev_id, end_rev_id,
652
 
                              rebase_initial_depths=(direction == 'reverse'),
653
 
                              exclude_common_ancestry=exclude_common_ancestry))
654
 
    return view_revisions
 
565
        rebase_initial_depths=direction == 'reverse'))
 
566
    if direction == 'reverse':
 
567
        return view_revisions
 
568
    elif direction == 'forward':
 
569
        # Forward means oldest first, adjusting for depth.
 
570
        view_revisions = reverse_by_depth(list(view_revisions))
 
571
        return _rebase_merge_depth(view_revisions)
 
572
    else:
 
573
        raise ValueError('invalid direction %r' % direction)
655
574
 
656
575
 
657
576
def _has_merges(branch, rev_id):
660
579
    return len(parents) > 1
661
580
 
662
581
 
663
 
def _compute_revno_str(branch, rev_id):
664
 
    """Compute the revno string from a rev_id.
665
 
 
666
 
    :return: The revno string, or None if the revision is not in the supplied
667
 
        branch.
668
 
    """
669
 
    try:
670
 
        revno = branch.revision_id_to_dotted_revno(rev_id)
671
 
    except errors.NoSuchRevision:
672
 
        # The revision must be outside of this branch
673
 
        return None
674
 
    else:
675
 
        return '.'.join(str(n) for n in revno)
676
 
 
677
 
 
678
582
def _is_obvious_ancestor(branch, start_rev_id, end_rev_id):
679
583
    """Is start_rev_id an obvious ancestor of end_rev_id?"""
680
584
    if start_rev_id and end_rev_id:
681
 
        try:
682
 
            start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
683
 
            end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
684
 
        except errors.NoSuchRevision:
685
 
            # one or both is not in the branch; not obvious
686
 
            return False
 
585
        start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
 
586
        end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
687
587
        if len(start_dotted) == 1 and len(end_dotted) == 1:
688
588
            # both on mainline
689
589
            return start_dotted[0] <= end_dotted[0]
694
594
        else:
695
595
            # not obvious
696
596
            return False
697
 
    # if either start or end is not specified then we use either the first or
698
 
    # the last revision and *they* are obvious ancestors.
699
597
    return True
700
598
 
701
599
 
702
 
def _linear_view_revisions(branch, start_rev_id, end_rev_id,
703
 
                           exclude_common_ancestry=False):
 
600
def _linear_view_revisions(branch, start_rev_id, end_rev_id):
704
601
    """Calculate a sequence of revisions to view, newest to oldest.
705
602
 
706
603
    :param start_rev_id: the lower revision-id
707
604
    :param end_rev_id: the upper revision-id
708
 
    :param exclude_common_ancestry: Whether the start_rev_id should be part of
709
 
        the iterated revisions.
710
605
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
711
606
    :raises _StartNotLinearAncestor: if a start_rev_id is specified but
712
 
        is not found walking the left-hand history
 
607
      is not found walking the left-hand history
713
608
    """
714
609
    br_revno, br_rev_id = branch.last_revision_info()
715
610
    repo = branch.repository
716
 
    graph = repo.get_graph()
717
611
    if start_rev_id is None and end_rev_id is None:
718
612
        cur_revno = br_revno
719
 
        for revision_id in graph.iter_lefthand_ancestry(br_rev_id,
720
 
            (_mod_revision.NULL_REVISION,)):
 
613
        for revision_id in repo.iter_reverse_revision_history(br_rev_id):
721
614
            yield revision_id, str(cur_revno), 0
722
615
            cur_revno -= 1
723
616
    else:
724
617
        if end_rev_id is None:
725
618
            end_rev_id = br_rev_id
726
619
        found_start = start_rev_id is None
727
 
        for revision_id in graph.iter_lefthand_ancestry(end_rev_id,
728
 
                (_mod_revision.NULL_REVISION,)):
729
 
            revno_str = _compute_revno_str(branch, revision_id)
 
620
        for revision_id in repo.iter_reverse_revision_history(end_rev_id):
 
621
            revno = branch.revision_id_to_dotted_revno(revision_id)
 
622
            revno_str = '.'.join(str(n) for n in revno)
730
623
            if not found_start and revision_id == start_rev_id:
731
 
                if not exclude_common_ancestry:
732
 
                    yield revision_id, revno_str, 0
 
624
                yield revision_id, revno_str, 0
733
625
                found_start = True
734
626
                break
735
627
            else:
740
632
 
741
633
 
742
634
def _graph_view_revisions(branch, start_rev_id, end_rev_id,
743
 
                          rebase_initial_depths=True,
744
 
                          exclude_common_ancestry=False):
 
635
    rebase_initial_depths=True):
745
636
    """Calculate revisions to view including merges, newest to oldest.
746
637
 
747
638
    :param branch: the branch
751
642
      revision is found?
752
643
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
753
644
    """
754
 
    if exclude_common_ancestry:
755
 
        stop_rule = 'with-merges-without-common-ancestry'
756
 
    else:
757
 
        stop_rule = 'with-merges'
758
645
    view_revisions = branch.iter_merge_sorted_revisions(
759
646
        start_revision_id=end_rev_id, stop_revision_id=start_rev_id,
760
 
        stop_rule=stop_rule)
 
647
        stop_rule="with-merges")
761
648
    if not rebase_initial_depths:
762
649
        for (rev_id, merge_depth, revno, end_of_merge
763
650
             ) in view_revisions:
774
661
                depth_adjustment = merge_depth
775
662
            if depth_adjustment:
776
663
                if merge_depth < depth_adjustment:
777
 
                    # From now on we reduce the depth adjustement, this can be
778
 
                    # surprising for users. The alternative requires two passes
779
 
                    # which breaks the fast display of the first revision
780
 
                    # though.
781
664
                    depth_adjustment = merge_depth
782
665
                merge_depth -= depth_adjustment
783
666
            yield rev_id, '.'.join(map(str, revno)), merge_depth
784
667
 
785
668
 
786
 
@deprecated_function(deprecated_in((2, 2, 0)))
787
669
def calculate_view_revisions(branch, start_revision, end_revision, direction,
788
670
        specific_fileid, generate_merge_revisions):
789
671
    """Calculate the revisions to view.
791
673
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
792
674
             a list of the same tuples.
793
675
    """
 
676
    # This method is no longer called by the main code path.
 
677
    # It is retained for API compatibility and may be deprecated
 
678
    # soon. IGC 20090116
794
679
    start_rev_id, end_rev_id = _get_revision_limits(branch, start_revision,
795
680
        end_revision)
796
681
    view_revisions = list(_calc_view_revisions(branch, start_rev_id, end_rev_id,
864
749
    """
865
750
    if search is None:
866
751
        return log_rev_iterator
867
 
    searchRE = lazy_regex.lazy_compile(search, re.IGNORECASE)
 
752
    searchRE = re_compile_checked(search, re.IGNORECASE,
 
753
            'log message filter')
868
754
    return _filter_message_re(searchRE, log_rev_iterator)
869
755
 
870
756
 
1124
1010
    cur_revno = branch_revno
1125
1011
    rev_nos = {}
1126
1012
    mainline_revs = []
1127
 
    graph = branch.repository.get_graph()
1128
 
    for revision_id in graph.iter_lefthand_ancestry(
1129
 
            branch_last_revision, (_mod_revision.NULL_REVISION,)):
 
1013
    for revision_id in branch.repository.iter_reverse_revision_history(
 
1014
                        branch_last_revision):
1130
1015
        if cur_revno < start_revno:
1131
1016
            # We have gone far enough, but we always add 1 more revision
1132
1017
            rev_nos[revision_id] = cur_revno
1146
1031
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
1147
1032
 
1148
1033
 
1149
 
@deprecated_function(deprecated_in((2, 2, 0)))
1150
1034
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
1151
1035
    """Filter view_revisions based on revision ranges.
1152
1036
 
1161
1045
 
1162
1046
    :return: The filtered view_revisions.
1163
1047
    """
 
1048
    # This method is no longer called by the main code path.
 
1049
    # It may be removed soon. IGC 20090127
1164
1050
    if start_rev_id or end_rev_id:
1165
1051
        revision_ids = [r for r, n, d in view_revisions]
1166
1052
        if start_rev_id:
1198
1084
    This includes the revisions which directly change the file id,
1199
1085
    and the revisions which merge these changes. So if the
1200
1086
    revision graph is::
1201
 
 
1202
1087
        A-.
1203
1088
        |\ \
1204
1089
        B C E
1231
1116
    """
1232
1117
    # Lookup all possible text keys to determine which ones actually modified
1233
1118
    # the file.
1234
 
    graph = branch.repository.get_file_graph()
1235
 
    get_parent_map = graph.get_parent_map
1236
1119
    text_keys = [(file_id, rev_id) for rev_id, revno, depth in view_revisions]
1237
1120
    next_keys = None
1238
1121
    # Looking up keys in batches of 1000 can cut the time in half, as well as
1242
1125
    #       indexing layer. We might consider passing in hints as to the known
1243
1126
    #       access pattern (sparse/clustered, high success rate/low success
1244
1127
    #       rate). This particular access is clustered with a low success rate.
 
1128
    get_parent_map = branch.repository.texts.get_parent_map
1245
1129
    modified_text_revisions = set()
1246
1130
    chunk_size = 1000
1247
1131
    for start in xrange(0, len(text_keys), chunk_size):
1274
1158
    return result
1275
1159
 
1276
1160
 
1277
 
@deprecated_function(deprecated_in((2, 2, 0)))
1278
1161
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
1279
1162
                       include_merges=True):
1280
1163
    """Produce an iterator of revisions to show
1281
1164
    :return: an iterator of (revision_id, revno, merge_depth)
1282
1165
    (if there is no revno for a revision, None is supplied)
1283
1166
    """
 
1167
    # This method is no longer called by the main code path.
 
1168
    # It is retained for API compatibility and may be deprecated
 
1169
    # soon. IGC 20090127
1284
1170
    if not include_merges:
1285
1171
        revision_ids = mainline_revs[1:]
1286
1172
        if direction == 'reverse':
1355
1241
    """
1356
1242
 
1357
1243
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
1358
 
                 tags=None, diff=None, signature=None):
 
1244
                 tags=None, diff=None):
1359
1245
        self.rev = rev
1360
 
        if revno is None:
1361
 
            self.revno = None
1362
 
        else:
1363
 
            self.revno = str(revno)
 
1246
        self.revno = str(revno)
1364
1247
        self.merge_depth = merge_depth
1365
1248
        self.delta = delta
1366
1249
        self.tags = tags
1367
1250
        self.diff = diff
1368
 
        self.signature = signature
1369
1251
 
1370
1252
 
1371
1253
class LogFormatter(object):
1380
1262
    to indicate which LogRevision attributes it supports:
1381
1263
 
1382
1264
    - supports_delta must be True if this log formatter supports delta.
1383
 
      Otherwise the delta attribute may not be populated.  The 'delta_format'
1384
 
      attribute describes whether the 'short_status' format (1) or the long
1385
 
      one (2) should be used.
 
1265
        Otherwise the delta attribute may not be populated.  The 'delta_format'
 
1266
        attribute describes whether the 'short_status' format (1) or the long
 
1267
        one (2) should be used.
1386
1268
 
1387
1269
    - supports_merge_revisions must be True if this log formatter supports
1388
 
      merge revisions.  If not, then only mainline revisions will be passed
1389
 
      to the formatter.
 
1270
        merge revisions.  If not, then only mainline revisions will be passed
 
1271
        to the formatter.
1390
1272
 
1391
1273
    - preferred_levels is the number of levels this formatter defaults to.
1392
 
      The default value is zero meaning display all levels.
1393
 
      This value is only relevant if supports_merge_revisions is True.
 
1274
        The default value is zero meaning display all levels.
 
1275
        This value is only relevant if supports_merge_revisions is True.
1394
1276
 
1395
1277
    - supports_tags must be True if this log formatter supports tags.
1396
 
      Otherwise the tags attribute may not be populated.
 
1278
        Otherwise the tags attribute may not be populated.
1397
1279
 
1398
1280
    - supports_diff must be True if this log formatter supports diffs.
1399
 
      Otherwise the diff attribute may not be populated.
1400
 
 
1401
 
    - supports_signatures must be True if this log formatter supports GPG
1402
 
      signatures.
 
1281
        Otherwise the diff attribute may not be populated.
1403
1282
 
1404
1283
    Plugins can register functions to show custom revision properties using
1405
1284
    the properties_handler_registry. The registered function
1406
 
    must respect the following interface description::
1407
 
 
 
1285
    must respect the following interface description:
1408
1286
        def my_show_properties(properties_dict):
1409
1287
            # code that returns a dict {'name':'value'} of the properties
1410
1288
            # to be shown
1412
1290
    preferred_levels = 0
1413
1291
 
1414
1292
    def __init__(self, to_file, show_ids=False, show_timezone='original',
1415
 
                 delta_format=None, levels=None, show_advice=False,
1416
 
                 to_exact_file=None, author_list_handler=None):
 
1293
                 delta_format=None, levels=None, show_advice=False):
1417
1294
        """Create a LogFormatter.
1418
1295
 
1419
1296
        :param to_file: the file to output to
1420
 
        :param to_exact_file: if set, gives an output stream to which 
1421
 
             non-Unicode diffs are written.
1422
1297
        :param show_ids: if True, revision-ids are to be displayed
1423
1298
        :param show_timezone: the timezone to use
1424
1299
        :param delta_format: the level of delta information to display
1427
1302
          let the log formatter decide.
1428
1303
        :param show_advice: whether to show advice at the end of the
1429
1304
          log or not
1430
 
        :param author_list_handler: callable generating a list of
1431
 
          authors to display for a given revision
1432
1305
        """
1433
1306
        self.to_file = to_file
1434
1307
        # 'exact' stream used to show diff, it should print content 'as is'
1435
1308
        # and should not try to decode/encode it to unicode to avoid bug #328007
1436
 
        if to_exact_file is not None:
1437
 
            self.to_exact_file = to_exact_file
1438
 
        else:
1439
 
            # XXX: somewhat hacky; this assumes it's a codec writer; it's better
1440
 
            # for code that expects to get diffs to pass in the exact file
1441
 
            # stream
1442
 
            self.to_exact_file = getattr(to_file, 'stream', to_file)
 
1309
        self.to_exact_file = getattr(to_file, 'stream', to_file)
1443
1310
        self.show_ids = show_ids
1444
1311
        self.show_timezone = show_timezone
1445
1312
        if delta_format is None:
1449
1316
        self.levels = levels
1450
1317
        self._show_advice = show_advice
1451
1318
        self._merge_count = 0
1452
 
        self._author_list_handler = author_list_handler
1453
1319
 
1454
1320
    def get_levels(self):
1455
1321
        """Get the number of levels to display or 0 for all."""
1487
1353
        return address
1488
1354
 
1489
1355
    def short_author(self, rev):
1490
 
        return self.authors(rev, 'first', short=True, sep=', ')
1491
 
 
1492
 
    def authors(self, rev, who, short=False, sep=None):
1493
 
        """Generate list of authors, taking --authors option into account.
1494
 
 
1495
 
        The caller has to specify the name of a author list handler,
1496
 
        as provided by the author list registry, using the ``who``
1497
 
        argument.  That name only sets a default, though: when the
1498
 
        user selected a different author list generation using the
1499
 
        ``--authors`` command line switch, as represented by the
1500
 
        ``author_list_handler`` constructor argument, that value takes
1501
 
        precedence.
1502
 
 
1503
 
        :param rev: The revision for which to generate the list of authors.
1504
 
        :param who: Name of the default handler.
1505
 
        :param short: Whether to shorten names to either name or address.
1506
 
        :param sep: What separator to use for automatic concatenation.
1507
 
        """
1508
 
        if self._author_list_handler is not None:
1509
 
            # The user did specify --authors, which overrides the default
1510
 
            author_list_handler = self._author_list_handler
1511
 
        else:
1512
 
            # The user didn't specify --authors, so we use the caller's default
1513
 
            author_list_handler = author_list_registry.get(who)
1514
 
        names = author_list_handler(rev)
1515
 
        if short:
1516
 
            for i in range(len(names)):
1517
 
                name, address = config.parse_username(names[i])
1518
 
                if name:
1519
 
                    names[i] = name
1520
 
                else:
1521
 
                    names[i] = address
1522
 
        if sep is not None:
1523
 
            names = sep.join(names)
1524
 
        return names
 
1356
        name, address = config.parse_username(rev.get_apparent_authors()[0])
 
1357
        if name:
 
1358
            return name
 
1359
        return address
1525
1360
 
1526
1361
    def merge_marker(self, revision):
1527
1362
        """Get the merge marker to include in the output or '' if none."""
1536
1371
 
1537
1372
        If a registered handler raises an error it is propagated.
1538
1373
        """
1539
 
        for line in self.custom_properties(revision):
1540
 
            self.to_file.write("%s%s\n" % (indent, line))
1541
 
 
1542
 
    def custom_properties(self, revision):
1543
 
        """Format the custom properties returned by each registered handler.
1544
 
 
1545
 
        If a registered handler raises an error it is propagated.
1546
 
 
1547
 
        :return: a list of formatted lines (excluding trailing newlines)
1548
 
        """
1549
 
        lines = self._foreign_info_properties(revision)
1550
1374
        for key, handler in properties_handler_registry.iteritems():
1551
 
            lines.extend(self._format_properties(handler(revision)))
1552
 
        return lines
1553
 
 
1554
 
    def _foreign_info_properties(self, rev):
1555
 
        """Custom log displayer for foreign revision identifiers.
1556
 
 
1557
 
        :param rev: Revision object.
1558
 
        """
1559
 
        # Revision comes directly from a foreign repository
1560
 
        if isinstance(rev, foreign.ForeignRevision):
1561
 
            return self._format_properties(
1562
 
                rev.mapping.vcs.show_foreign_revid(rev.foreign_revid))
1563
 
 
1564
 
        # Imported foreign revision revision ids always contain :
1565
 
        if not ":" in rev.revision_id:
1566
 
            return []
1567
 
 
1568
 
        # Revision was once imported from a foreign repository
1569
 
        try:
1570
 
            foreign_revid, mapping = \
1571
 
                foreign.foreign_vcs_registry.parse_revision_id(rev.revision_id)
1572
 
        except errors.InvalidRevisionId:
1573
 
            return []
1574
 
 
1575
 
        return self._format_properties(
1576
 
            mapping.vcs.show_foreign_revid(foreign_revid))
1577
 
 
1578
 
    def _format_properties(self, properties):
1579
 
        lines = []
1580
 
        for key, value in properties.items():
1581
 
            lines.append(key + ': ' + value)
1582
 
        return lines
 
1375
            for key, value in handler(revision).items():
 
1376
                self.to_file.write(indent + key + ': ' + value + '\n')
1583
1377
 
1584
1378
    def show_diff(self, to_file, diff, indent):
1585
1379
        for l in diff.rstrip().split('\n'):
1586
1380
            to_file.write(indent + '%s\n' % (l,))
1587
1381
 
1588
1382
 
1589
 
# Separator between revisions in long format
1590
 
_LONG_SEP = '-' * 60
1591
 
 
1592
 
 
1593
1383
class LongLogFormatter(LogFormatter):
1594
1384
 
1595
1385
    supports_merge_revisions = True
1597
1387
    supports_delta = True
1598
1388
    supports_tags = True
1599
1389
    supports_diff = True
1600
 
    supports_signatures = True
1601
 
 
1602
 
    def __init__(self, *args, **kwargs):
1603
 
        super(LongLogFormatter, self).__init__(*args, **kwargs)
1604
 
        if self.show_timezone == 'original':
1605
 
            self.date_string = self._date_string_original_timezone
1606
 
        else:
1607
 
            self.date_string = self._date_string_with_timezone
1608
 
 
1609
 
    def _date_string_with_timezone(self, rev):
1610
 
        return format_date(rev.timestamp, rev.timezone or 0,
1611
 
                           self.show_timezone)
1612
 
 
1613
 
    def _date_string_original_timezone(self, rev):
1614
 
        return format_date_with_offset_in_original_timezone(rev.timestamp,
1615
 
            rev.timezone or 0)
1616
1390
 
1617
1391
    def log_revision(self, revision):
1618
1392
        """Log a revision, either merged or not."""
1619
1393
        indent = '    ' * revision.merge_depth
1620
 
        lines = [_LONG_SEP]
 
1394
        to_file = self.to_file
 
1395
        to_file.write(indent + '-' * 60 + '\n')
1621
1396
        if revision.revno is not None:
1622
 
            lines.append('revno: %s%s' % (revision.revno,
 
1397
            to_file.write(indent + 'revno: %s%s\n' % (revision.revno,
1623
1398
                self.merge_marker(revision)))
1624
1399
        if revision.tags:
1625
 
            lines.append('tags: %s' % (', '.join(revision.tags)))
1626
 
        if self.show_ids or revision.revno is None:
1627
 
            lines.append('revision-id: %s' % (revision.rev.revision_id,))
 
1400
            to_file.write(indent + 'tags: %s\n' % (', '.join(revision.tags)))
1628
1401
        if self.show_ids:
 
1402
            to_file.write(indent + 'revision-id: ' + revision.rev.revision_id)
 
1403
            to_file.write('\n')
1629
1404
            for parent_id in revision.rev.parent_ids:
1630
 
                lines.append('parent: %s' % (parent_id,))
1631
 
        lines.extend(self.custom_properties(revision.rev))
 
1405
                to_file.write(indent + 'parent: %s\n' % (parent_id,))
 
1406
        self.show_properties(revision.rev, indent)
1632
1407
 
1633
1408
        committer = revision.rev.committer
1634
 
        authors = self.authors(revision.rev, 'all')
 
1409
        authors = revision.rev.get_apparent_authors()
1635
1410
        if authors != [committer]:
1636
 
            lines.append('author: %s' % (", ".join(authors),))
1637
 
        lines.append('committer: %s' % (committer,))
 
1411
            to_file.write(indent + 'author: %s\n' % (", ".join(authors),))
 
1412
        to_file.write(indent + 'committer: %s\n' % (committer,))
1638
1413
 
1639
1414
        branch_nick = revision.rev.properties.get('branch-nick', None)
1640
1415
        if branch_nick is not None:
1641
 
            lines.append('branch nick: %s' % (branch_nick,))
1642
 
 
1643
 
        lines.append('timestamp: %s' % (self.date_string(revision.rev),))
1644
 
 
1645
 
        if revision.signature is not None:
1646
 
            lines.append('signature: ' + revision.signature)
1647
 
 
1648
 
        lines.append('message:')
 
1416
            to_file.write(indent + 'branch nick: %s\n' % (branch_nick,))
 
1417
 
 
1418
        date_str = format_date(revision.rev.timestamp,
 
1419
                               revision.rev.timezone or 0,
 
1420
                               self.show_timezone)
 
1421
        to_file.write(indent + 'timestamp: %s\n' % (date_str,))
 
1422
 
 
1423
        to_file.write(indent + 'message:\n')
1649
1424
        if not revision.rev.message:
1650
 
            lines.append('  (no message)')
 
1425
            to_file.write(indent + '  (no message)\n')
1651
1426
        else:
1652
1427
            message = revision.rev.message.rstrip('\r\n')
1653
1428
            for l in message.split('\n'):
1654
 
                lines.append('  %s' % (l,))
1655
 
 
1656
 
        # Dump the output, appending the delta and diff if requested
1657
 
        to_file = self.to_file
1658
 
        to_file.write("%s%s\n" % (indent, ('\n' + indent).join(lines)))
 
1429
                to_file.write(indent + '  %s\n' % (l,))
1659
1430
        if revision.delta is not None:
1660
 
            # Use the standard status output to display changes
1661
 
            from bzrlib.delta import report_delta
1662
 
            report_delta(to_file, revision.delta, short_status=False, 
1663
 
                         show_ids=self.show_ids, indent=indent)
 
1431
            # We don't respect delta_format for compatibility
 
1432
            revision.delta.show(to_file, self.show_ids, indent=indent,
 
1433
                                short_status=False)
1664
1434
        if revision.diff is not None:
1665
1435
            to_file.write(indent + 'diff:\n')
1666
 
            to_file.flush()
1667
1436
            # Note: we explicitly don't indent the diff (relative to the
1668
1437
            # revision information) so that the output can be fed to patch -p0
1669
1438
            self.show_diff(self.to_exact_file, revision.diff, indent)
1670
 
            self.to_exact_file.flush()
1671
1439
 
1672
1440
    def get_advice_separator(self):
1673
1441
        """Get the text separating the log from the closing advice."""
1697
1465
        indent = '    ' * depth
1698
1466
        revno_width = self.revno_width_by_depth.get(depth)
1699
1467
        if revno_width is None:
1700
 
            if revision.revno is None or revision.revno.find('.') == -1:
 
1468
            if revision.revno.find('.') == -1:
1701
1469
                # mainline revno, e.g. 12345
1702
1470
                revno_width = 5
1703
1471
            else:
1711
1479
        if revision.tags:
1712
1480
            tags = ' {%s}' % (', '.join(revision.tags))
1713
1481
        to_file.write(indent + "%*s %s\t%s%s%s\n" % (revno_width,
1714
 
                revision.revno or "", self.short_author(revision.rev),
 
1482
                revision.revno, self.short_author(revision.rev),
1715
1483
                format_date(revision.rev.timestamp,
1716
1484
                            revision.rev.timezone or 0,
1717
1485
                            self.show_timezone, date_fmt="%Y-%m-%d",
1718
1486
                            show_offset=False),
1719
1487
                tags, self.merge_marker(revision)))
1720
1488
        self.show_properties(revision.rev, indent+offset)
1721
 
        if self.show_ids or revision.revno is None:
 
1489
        if self.show_ids:
1722
1490
            to_file.write(indent + offset + 'revision-id:%s\n'
1723
1491
                          % (revision.rev.revision_id,))
1724
1492
        if not revision.rev.message:
1729
1497
                to_file.write(indent + offset + '%s\n' % (l,))
1730
1498
 
1731
1499
        if revision.delta is not None:
1732
 
            # Use the standard status output to display changes
1733
 
            from bzrlib.delta import report_delta
1734
 
            report_delta(to_file, revision.delta, 
1735
 
                         short_status=self.delta_format==1, 
1736
 
                         show_ids=self.show_ids, indent=indent + offset)
 
1500
            revision.delta.show(to_file, self.show_ids, indent=indent + offset,
 
1501
                                short_status=self.delta_format==1)
1737
1502
        if revision.diff is not None:
1738
1503
            self.show_diff(self.to_exact_file, revision.diff, '      ')
1739
1504
        to_file.write('\n')
1747
1512
 
1748
1513
    def __init__(self, *args, **kwargs):
1749
1514
        super(LineLogFormatter, self).__init__(*args, **kwargs)
1750
 
        width = terminal_width()
1751
 
        if width is not None:
1752
 
            # we need one extra space for terminals that wrap on last char
1753
 
            width = width - 1
1754
 
        self._max_chars = width
 
1515
        self._max_chars = terminal_width() - 1
1755
1516
 
1756
1517
    def truncate(self, str, max_len):
1757
 
        if max_len is None or len(str) <= max_len:
 
1518
        if len(str) <= max_len:
1758
1519
            return str
1759
 
        return str[:max_len-3] + '...'
 
1520
        return str[:max_len-3]+'...'
1760
1521
 
1761
1522
    def date_string(self, rev):
1762
1523
        return format_date(rev.timestamp, rev.timezone or 0,
1777
1538
 
1778
1539
    def log_string(self, revno, rev, max_chars, tags=None, prefix=''):
1779
1540
        """Format log info into one string. Truncate tail of string
1780
 
 
1781
 
        :param revno:      revision number or None.
1782
 
                           Revision numbers counts from 1.
1783
 
        :param rev:        revision object
1784
 
        :param max_chars:  maximum length of resulting string
1785
 
        :param tags:       list of tags or None
1786
 
        :param prefix:     string to prefix each line
1787
 
        :return:           formatted truncated string
 
1541
        :param  revno:      revision number or None.
 
1542
                            Revision numbers counts from 1.
 
1543
        :param  rev:        revision object
 
1544
        :param  max_chars:  maximum length of resulting string
 
1545
        :param  tags:       list of tags or None
 
1546
        :param  prefix:     string to prefix each line
 
1547
        :return:            formatted truncated string
1788
1548
        """
1789
1549
        out = []
1790
1550
        if revno:
1791
1551
            # show revno only when is not None
1792
1552
            out.append("%s:" % revno)
1793
 
        if max_chars is not None:
1794
 
            out.append(self.truncate(self.short_author(rev), (max_chars+3)/4))
1795
 
        else:
1796
 
            out.append(self.short_author(rev))
 
1553
        out.append(self.truncate(self.short_author(rev), 20))
1797
1554
        out.append(self.date_string(rev))
1798
1555
        if len(rev.parent_ids) > 1:
1799
1556
            out.append('[merge]')
1818
1575
                               self.show_timezone,
1819
1576
                               date_fmt='%Y-%m-%d',
1820
1577
                               show_offset=False)
1821
 
        committer_str = self.authors(revision.rev, 'first', sep=', ')
1822
 
        committer_str = committer_str.replace(' <', '  <')
 
1578
        committer_str = revision.rev.committer.replace (' <', '  <')
1823
1579
        to_file.write('%s  %s\n\n' % (date_str,committer_str))
1824
1580
 
1825
1581
        if revision.delta is not None and revision.delta.has_changed():
1890
1646
        raise errors.BzrCommandError("unknown log formatter: %r" % name)
1891
1647
 
1892
1648
 
1893
 
def author_list_all(rev):
1894
 
    return rev.get_apparent_authors()[:]
1895
 
 
1896
 
 
1897
 
def author_list_first(rev):
1898
 
    lst = rev.get_apparent_authors()
1899
 
    try:
1900
 
        return [lst[0]]
1901
 
    except IndexError:
1902
 
        return []
1903
 
 
1904
 
 
1905
 
def author_list_committer(rev):
1906
 
    return [rev.committer]
1907
 
 
1908
 
 
1909
 
author_list_registry = registry.Registry()
1910
 
 
1911
 
author_list_registry.register('all', author_list_all,
1912
 
                              'All authors')
1913
 
 
1914
 
author_list_registry.register('first', author_list_first,
1915
 
                              'The first author')
1916
 
 
1917
 
author_list_registry.register('committer', author_list_committer,
1918
 
                              'The committer')
1919
 
 
1920
 
 
1921
1649
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
1922
1650
    # deprecated; for compatibility
1923
1651
    lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
1992
1720
    old_revisions = set()
1993
1721
    new_history = []
1994
1722
    new_revisions = set()
1995
 
    graph = repository.get_graph()
1996
 
    new_iter = graph.iter_lefthand_ancestry(new_revision_id)
1997
 
    old_iter = graph.iter_lefthand_ancestry(old_revision_id)
 
1723
    new_iter = repository.iter_reverse_revision_history(new_revision_id)
 
1724
    old_iter = repository.iter_reverse_revision_history(old_revision_id)
1998
1725
    stop_revision = None
1999
1726
    do_old = True
2000
1727
    do_new = True
2075
1802
        lf.log_revision(lr)
2076
1803
 
2077
1804
 
2078
 
def _get_info_for_log_files(revisionspec_list, file_list, add_cleanup):
 
1805
def _get_info_for_log_files(revisionspec_list, file_list):
2079
1806
    """Find file-ids and kinds given a list of files and a revision range.
2080
1807
 
2081
1808
    We search for files at the end of the range. If not found there,
2085
1812
    :param file_list: the list of paths given on the command line;
2086
1813
      the first of these can be a branch location or a file path,
2087
1814
      the remainder must be file paths
2088
 
    :param add_cleanup: When the branch returned is read locked,
2089
 
      an unlock call will be queued to the cleanup.
2090
1815
    :return: (branch, info_list, start_rev_info, end_rev_info) where
2091
1816
      info_list is a list of (relative_path, file_id, kind) tuples where
2092
1817
      kind is one of values 'directory', 'file', 'symlink', 'tree-reference'.
2093
 
      branch will be read-locked.
2094
1818
    """
2095
 
    from builtins import _get_revision_range
 
1819
    from builtins import _get_revision_range, safe_relpath_files
2096
1820
    tree, b, path = bzrdir.BzrDir.open_containing_tree_or_branch(file_list[0])
2097
 
    add_cleanup(b.lock_read().unlock)
2098
1821
    # XXX: It's damn messy converting a list of paths to relative paths when
2099
1822
    # those paths might be deleted ones, they might be on a case-insensitive
2100
1823
    # filesystem and/or they might be in silly locations (like another branch).
2104
1827
    # case of running log in a nested directory, assuming paths beyond the
2105
1828
    # first one haven't been deleted ...
2106
1829
    if tree:
2107
 
        relpaths = [path] + tree.safe_relpath_files(file_list[1:])
 
1830
        relpaths = [path] + safe_relpath_files(tree, file_list[1:])
2108
1831
    else:
2109
1832
        relpaths = [path] + file_list[1:]
2110
1833
    info_list = []
2178
1901
 
2179
1902
 
2180
1903
properties_handler_registry = registry.Registry()
2181
 
 
2182
 
# Use the properties handlers to print out bug information if available
2183
 
def _bugs_properties_handler(revision):
2184
 
    if revision.properties.has_key('bugs'):
2185
 
        bug_lines = revision.properties['bugs'].split('\n')
2186
 
        bug_rows = [line.split(' ', 1) for line in bug_lines]
2187
 
        fixed_bug_urls = [row[0] for row in bug_rows if
2188
 
                          len(row) > 1 and row[1] == 'fixed']
2189
 
 
2190
 
        if fixed_bug_urls:
2191
 
            return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
2192
 
    return {}
2193
 
 
2194
 
properties_handler_registry.register('bugs_properties_handler',
2195
 
                                     _bugs_properties_handler)
 
1904
properties_handler_registry.register_lazy("foreign",
 
1905
                                          "bzrlib.foreign",
 
1906
                                          "show_foreign_properties")
2196
1907
 
2197
1908
 
2198
1909
# adapters which revision ids to log are filtered. When log is called, the