~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2010-02-17 13:49:11 UTC
  • mfrom: (4988.11.1 imports)
  • Revision ID: pqm@pqm.ubuntu.com-20100217134911-s77se00ni7xc1hz8
(Jelmer) Remove some unused imports.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2011 Canonical Ltd
 
1
# Copyright (C) 2005-2010 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
73
73
    repository as _mod_repository,
74
74
    revision as _mod_revision,
75
75
    revisionspec,
 
76
    trace,
76
77
    tsort,
77
 
    i18n,
78
78
    )
79
79
""")
80
80
 
81
81
from bzrlib import (
82
 
    lazy_regex,
83
82
    registry,
84
83
    )
85
84
from bzrlib.osutils import (
86
85
    format_date,
87
86
    format_date_with_offset_in_original_timezone,
88
 
    get_diff_header_encoding,
89
87
    get_terminal_encoding,
 
88
    re_compile_checked,
90
89
    terminal_width,
91
90
    )
 
91
from bzrlib.symbol_versioning import (
 
92
    deprecated_function,
 
93
    deprecated_in,
 
94
    )
92
95
 
93
96
 
94
97
def find_touching_revisions(branch, file_id):
106
109
    last_path = None
107
110
    revno = 1
108
111
    for revision_id in branch.revision_history():
109
 
        this_inv = branch.repository.get_inventory(revision_id)
110
 
        if this_inv.has_id(file_id):
 
112
        this_inv = branch.repository.get_revision_inventory(revision_id)
 
113
        if file_id in this_inv:
111
114
            this_ie = this_inv[file_id]
112
115
            this_path = this_inv.id2path(file_id)
113
116
        else:
153
156
             end_revision=None,
154
157
             search=None,
155
158
             limit=None,
156
 
             show_diff=False,
157
 
             match=None):
 
159
             show_diff=False):
158
160
    """Write out human-readable log of commits to this branch.
159
161
 
160
162
    This function is being retained for backwards compatibility but
183
185
        if None or 0.
184
186
 
185
187
    :param show_diff: If True, output a diff after each revision.
186
 
 
187
 
    :param match: Dictionary of search lists to use when matching revision
188
 
      properties.
189
188
    """
190
189
    # Convert old-style parameters to new-style parameters
191
190
    if specific_fileid is not None:
219
218
# make_log_request_dict() below
220
219
_DEFAULT_REQUEST_PARAMS = {
221
220
    'direction': 'reverse',
222
 
    'levels': None,
 
221
    'levels': 1,
223
222
    'generate_tags': True,
224
 
    'exclude_common_ancestry': False,
225
223
    '_match_using_deltas': True,
226
224
    }
227
225
 
228
226
 
229
227
def make_log_request_dict(direction='reverse', specific_fileids=None,
230
 
                          start_revision=None, end_revision=None, limit=None,
231
 
                          message_search=None, levels=None, generate_tags=True,
232
 
                          delta_type=None,
233
 
                          diff_type=None, _match_using_deltas=True,
234
 
                          exclude_common_ancestry=False, match=None,
235
 
                          signature=False,
236
 
                          ):
 
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):
237
231
    """Convenience function for making a logging request dictionary.
238
232
 
239
233
    Using this function may make code slightly safer by ensuring
259
253
      matching commit messages
260
254
 
261
255
    :param levels: the number of levels of revisions to
262
 
      generate; 1 for just the mainline; 0 for all levels, or None for
263
 
      a sensible default.
 
256
      generate; 1 for just the mainline; 0 for all levels.
264
257
 
265
258
    :param generate_tags: If True, include tags for matched revisions.
266
 
`
 
259
 
267
260
    :param delta_type: Either 'full', 'partial' or None.
268
261
      'full' means generate the complete delta - adds/deletes/modifies/etc;
269
262
      'partial' means filter the delta using specific_fileids;
278
271
      algorithm used for matching specific_fileids. This parameter
279
272
      may be removed in the future so bzrlib client code should NOT
280
273
      use it.
281
 
 
282
 
    :param exclude_common_ancestry: Whether -rX..Y should be interpreted as a
283
 
      range operator or as a graph difference.
284
 
 
285
 
    :param signature: show digital signature information
286
 
 
287
 
    :param match: Dictionary of list of search strings to use when filtering
288
 
      revisions. Keys can be 'message', 'author', 'committer', 'bugs' or
289
 
      the empty string to match any of the preceding properties.
290
 
 
291
274
    """
292
 
    # Take care of old style message_search parameter
293
 
    if message_search:
294
 
        if match:
295
 
            if 'message' in match:
296
 
                match['message'].append(message_search)
297
 
            else:
298
 
                match['message'] = [message_search]
299
 
        else:
300
 
            match={ 'message': [message_search] }
301
275
    return {
302
276
        'direction': direction,
303
277
        'specific_fileids': specific_fileids,
304
278
        'start_revision': start_revision,
305
279
        'end_revision': end_revision,
306
280
        'limit': limit,
 
281
        'message_search': message_search,
307
282
        'levels': levels,
308
283
        'generate_tags': generate_tags,
309
284
        'delta_type': delta_type,
310
285
        'diff_type': diff_type,
311
 
        'exclude_common_ancestry': exclude_common_ancestry,
312
 
        'signature': signature,
313
 
        'match': match,
314
286
        # Add 'private' attributes for features that may be deprecated
315
287
        '_match_using_deltas': _match_using_deltas,
316
288
    }
318
290
 
319
291
def _apply_log_request_defaults(rqst):
320
292
    """Apply default values to a request dictionary."""
321
 
    result = _DEFAULT_REQUEST_PARAMS.copy()
 
293
    result = _DEFAULT_REQUEST_PARAMS
322
294
    if rqst:
323
295
        result.update(rqst)
324
296
    return result
325
297
 
326
298
 
327
 
def format_signature_validity(rev_id, repo):
328
 
    """get the signature validity
329
 
 
330
 
    :param rev_id: revision id to validate
331
 
    :param repo: repository of revision
332
 
    :return: human readable string to print to log
333
 
    """
334
 
    from bzrlib import gpg
335
 
 
336
 
    gpg_strategy = gpg.GPGStrategy(None)
337
 
    result = repo.verify_revision(rev_id, gpg_strategy)
338
 
    if result[0] == gpg.SIGNATURE_VALID:
339
 
        return "valid signature from {0}".format(result[1])
340
 
    if result[0] == gpg.SIGNATURE_KEY_MISSING:
341
 
        return "unknown key {0}".format(result[1])
342
 
    if result[0] == gpg.SIGNATURE_NOT_VALID:
343
 
        return "invalid signature!"
344
 
    if result[0] == gpg.SIGNATURE_NOT_SIGNED:
345
 
        return "no signature"
346
 
 
347
 
 
348
299
class LogGenerator(object):
349
300
    """A generator of log revisions."""
350
301
 
395
346
        # Tweak the LogRequest based on what the LogFormatter can handle.
396
347
        # (There's no point generating stuff if the formatter can't display it.)
397
348
        rqst = self.rqst
398
 
        if rqst['levels'] is None or lf.get_levels() > rqst['levels']:
399
 
            # user didn't specify levels, use whatever the LF can handle:
400
 
            rqst['levels'] = lf.get_levels()
401
 
 
 
349
        rqst['levels'] = lf.get_levels()
402
350
        if not getattr(lf, 'supports_tags', False):
403
351
            rqst['generate_tags'] = False
404
352
        if not getattr(lf, 'supports_delta', False):
405
353
            rqst['delta_type'] = None
406
354
        if not getattr(lf, 'supports_diff', False):
407
355
            rqst['diff_type'] = None
408
 
        if not getattr(lf, 'supports_signatures', False):
409
 
            rqst['signature'] = False
410
356
 
411
357
        # Find and print the interesting revisions
412
358
        generator = self._generator_factory(self.branch, rqst)
416
362
 
417
363
    def _generator_factory(self, branch, rqst):
418
364
        """Make the LogGenerator object to use.
419
 
 
 
365
        
420
366
        Subclasses may wish to override this.
421
367
        """
422
368
        return _DefaultLogGenerator(branch, rqst)
446
392
        levels = rqst.get('levels')
447
393
        limit = rqst.get('limit')
448
394
        diff_type = rqst.get('diff_type')
449
 
        show_signature = rqst.get('signature')
450
395
        log_count = 0
451
396
        revision_iterator = self._create_log_revision_iterator()
452
397
        for revs in revision_iterator:
458
403
                    diff = None
459
404
                else:
460
405
                    diff = self._format_diff(rev, rev_id, diff_type)
461
 
                if show_signature:
462
 
                    signature = format_signature_validity(rev_id,
463
 
                                                self.branch.repository)
464
 
                else:
465
 
                    signature = None
466
406
                yield LogRevision(rev, revno, merge_depth, delta,
467
 
                    self.rev_tag_dict.get(rev_id), diff, signature)
 
407
                    self.rev_tag_dict.get(rev_id), diff)
468
408
                if limit:
469
409
                    log_count += 1
470
410
                    if log_count >= limit:
484
424
        else:
485
425
            specific_files = None
486
426
        s = StringIO()
487
 
        path_encoding = get_diff_header_encoding()
488
427
        diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
489
 
            new_label='', path_encoding=path_encoding)
 
428
            new_label='')
490
429
        return s.getvalue()
491
430
 
492
431
    def _create_log_revision_iterator(self):
516
455
        generate_merge_revisions = rqst.get('levels') != 1
517
456
        delayed_graph_generation = not rqst.get('specific_fileids') and (
518
457
                rqst.get('limit') or self.start_rev_id or self.end_rev_id)
519
 
        view_revisions = _calc_view_revisions(
520
 
            self.branch, self.start_rev_id, self.end_rev_id,
521
 
            rqst.get('direction'),
522
 
            generate_merge_revisions=generate_merge_revisions,
523
 
            delayed_graph_generation=delayed_graph_generation,
524
 
            exclude_common_ancestry=rqst.get('exclude_common_ancestry'))
 
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)
525
461
 
526
462
        # Apply the other filters
527
463
        return make_log_rev_iterator(self.branch, view_revisions,
528
 
            rqst.get('delta_type'), rqst.get('match'),
 
464
            rqst.get('delta_type'), rqst.get('message_search'),
529
465
            file_ids=rqst.get('specific_fileids'),
530
466
            direction=rqst.get('direction'))
531
467
 
534
470
        # Note that we always generate the merge revisions because
535
471
        # filter_revisions_touching_file_id() requires them ...
536
472
        rqst = self.rqst
537
 
        view_revisions = _calc_view_revisions(
538
 
            self.branch, self.start_rev_id, self.end_rev_id,
539
 
            rqst.get('direction'), generate_merge_revisions=True,
540
 
            exclude_common_ancestry=rqst.get('exclude_common_ancestry'))
 
473
        view_revisions = _calc_view_revisions(self.branch, self.start_rev_id,
 
474
            self.end_rev_id, rqst.get('direction'), True)
541
475
        if not isinstance(view_revisions, list):
542
476
            view_revisions = list(view_revisions)
543
477
        view_revisions = _filter_revisions_touching_file_id(self.branch,
544
478
            rqst.get('specific_fileids')[0], view_revisions,
545
479
            include_merges=rqst.get('levels') != 1)
546
480
        return make_log_rev_iterator(self.branch, view_revisions,
547
 
            rqst.get('delta_type'), rqst.get('match'))
 
481
            rqst.get('delta_type'), rqst.get('message_search'))
548
482
 
549
483
 
550
484
def _calc_view_revisions(branch, start_rev_id, end_rev_id, direction,
551
 
                         generate_merge_revisions,
552
 
                         delayed_graph_generation=False,
553
 
                         exclude_common_ancestry=False,
554
 
                         ):
 
485
    generate_merge_revisions, delayed_graph_generation=False):
555
486
    """Calculate the revisions to view.
556
487
 
557
488
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
558
489
             a list of the same tuples.
559
490
    """
560
 
    if (exclude_common_ancestry and start_rev_id == end_rev_id):
561
 
        raise errors.BzrCommandError(
562
 
            '--exclude-common-ancestry requires two different revisions')
563
 
    if direction not in ('reverse', 'forward'):
564
 
        raise ValueError('invalid direction %r' % direction)
565
491
    br_revno, br_rev_id = branch.last_revision_info()
566
492
    if br_revno == 0:
567
493
        return []
568
494
 
569
 
    if (end_rev_id and start_rev_id == end_rev_id
570
 
        and (not generate_merge_revisions
571
 
             or not _has_merges(branch, end_rev_id))):
572
 
        # If a single revision is requested, check we can handle it
573
 
        iter_revs = _generate_one_revision(branch, end_rev_id, br_rev_id,
574
 
                                           br_revno)
575
 
    elif not generate_merge_revisions:
576
 
        # If we only want to see linear revisions, we can iterate ...
577
 
        iter_revs = _generate_flat_revisions(branch, start_rev_id, end_rev_id,
578
 
                                             direction, exclude_common_ancestry)
579
 
        if direction == 'forward':
580
 
            iter_revs = reversed(iter_revs)
 
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 ...
 
502
    if not generate_merge_revisions:
 
503
        return _generate_flat_revisions(branch, start_rev_id, end_rev_id,
 
504
            direction)
581
505
    else:
582
 
        iter_revs = _generate_all_revisions(branch, start_rev_id, end_rev_id,
583
 
                                            direction, delayed_graph_generation,
584
 
                                            exclude_common_ancestry)
585
 
        if direction == 'forward':
586
 
            iter_revs = _rebase_merge_depth(reverse_by_depth(list(iter_revs)))
587
 
    return iter_revs
 
506
        return _generate_all_revisions(branch, start_rev_id, end_rev_id,
 
507
            direction, delayed_graph_generation)
588
508
 
589
509
 
590
510
def _generate_one_revision(branch, rev_id, br_rev_id, br_revno):
592
512
        # It's the tip
593
513
        return [(br_rev_id, br_revno, 0)]
594
514
    else:
595
 
        revno_str = _compute_revno_str(branch, rev_id)
 
515
        revno = branch.revision_id_to_dotted_revno(rev_id)
 
516
        revno_str = '.'.join(str(n) for n in revno)
596
517
        return [(rev_id, revno_str, 0)]
597
518
 
598
519
 
599
 
def _generate_flat_revisions(branch, start_rev_id, end_rev_id, direction,
600
 
                             exclude_common_ancestry=False):
601
 
    result = _linear_view_revisions(
602
 
        branch, start_rev_id, end_rev_id,
603
 
        exclude_common_ancestry=exclude_common_ancestry)
 
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)
604
522
    # If a start limit was given and it's not obviously an
605
523
    # ancestor of the end limit, check it before outputting anything
606
524
    if direction == 'forward' or (start_rev_id
610
528
        except _StartNotLinearAncestor:
611
529
            raise errors.BzrCommandError('Start revision not found in'
612
530
                ' left-hand history of end revision.')
 
531
    if direction == 'forward':
 
532
        result = reversed(result)
613
533
    return result
614
534
 
615
535
 
616
536
def _generate_all_revisions(branch, start_rev_id, end_rev_id, direction,
617
 
                            delayed_graph_generation,
618
 
                            exclude_common_ancestry=False):
 
537
                            delayed_graph_generation):
619
538
    # On large trees, generating the merge graph can take 30-60 seconds
620
539
    # so we delay doing it until a merge is detected, incrementally
621
540
    # returning initial (non-merge) revisions while we can.
627
546
    if delayed_graph_generation:
628
547
        try:
629
548
            for rev_id, revno, depth in  _linear_view_revisions(
630
 
                branch, start_rev_id, end_rev_id, exclude_common_ancestry):
 
549
                branch, start_rev_id, end_rev_id):
631
550
                if _has_merges(branch, rev_id):
632
551
                    # The end_rev_id can be nested down somewhere. We need an
633
552
                    # explicit ancestry check. There is an ambiguity here as we
634
553
                    # may not raise _StartNotLinearAncestor for a revision that
635
554
                    # is an ancestor but not a *linear* one. But since we have
636
555
                    # loaded the graph to do the check (or calculate a dotted
637
 
                    # revno), we may as well accept to show the log...  We need
638
 
                    # the check only if start_rev_id is not None as all
639
 
                    # revisions have _mod_revision.NULL_REVISION as an ancestor
640
 
                    # -- vila 20100319
 
556
                    # revno), we may as well accept to show the log... 
 
557
                    # -- vila 100201
641
558
                    graph = branch.repository.get_graph()
642
 
                    if (start_rev_id is not None
643
 
                        and not graph.is_ancestor(start_rev_id, end_rev_id)):
 
559
                    if not graph.is_ancestor(start_rev_id, end_rev_id):
644
560
                        raise _StartNotLinearAncestor()
645
 
                    # Since we collected the revisions so far, we need to
646
 
                    # adjust end_rev_id.
647
561
                    end_rev_id = rev_id
648
562
                    break
649
563
                else:
650
564
                    initial_revisions.append((rev_id, revno, depth))
651
565
            else:
652
566
                # No merged revisions found
653
 
                return initial_revisions
 
567
                if direction == 'reverse':
 
568
                    return initial_revisions
 
569
                elif direction == 'forward':
 
570
                    return reversed(initial_revisions)
 
571
                else:
 
572
                    raise ValueError('invalid direction %r' % direction)
654
573
        except _StartNotLinearAncestor:
655
574
            # A merge was never detected so the lower revision limit can't
656
575
            # be nested down somewhere
657
576
            raise errors.BzrCommandError('Start revision not found in'
658
577
                ' history of end revision.')
659
578
 
660
 
    # We exit the loop above because we encounter a revision with merges, from
661
 
    # this revision, we need to switch to _graph_view_revisions.
662
 
 
663
579
    # A log including nested merges is required. If the direction is reverse,
664
580
    # we rebase the initial merge depths so that the development line is
665
581
    # shown naturally, i.e. just like it is for linear logging. We can easily
667
583
    # indented at the end seems slightly nicer in that case.
668
584
    view_revisions = chain(iter(initial_revisions),
669
585
        _graph_view_revisions(branch, start_rev_id, end_rev_id,
670
 
                              rebase_initial_depths=(direction == 'reverse'),
671
 
                              exclude_common_ancestry=exclude_common_ancestry))
672
 
    return view_revisions
 
586
        rebase_initial_depths=direction == 'reverse'))
 
587
    if direction == 'reverse':
 
588
        return view_revisions
 
589
    elif direction == 'forward':
 
590
        # Forward means oldest first, adjusting for depth.
 
591
        view_revisions = reverse_by_depth(list(view_revisions))
 
592
        return _rebase_merge_depth(view_revisions)
 
593
    else:
 
594
        raise ValueError('invalid direction %r' % direction)
673
595
 
674
596
 
675
597
def _has_merges(branch, rev_id):
678
600
    return len(parents) > 1
679
601
 
680
602
 
681
 
def _compute_revno_str(branch, rev_id):
682
 
    """Compute the revno string from a rev_id.
683
 
 
684
 
    :return: The revno string, or None if the revision is not in the supplied
685
 
        branch.
686
 
    """
687
 
    try:
688
 
        revno = branch.revision_id_to_dotted_revno(rev_id)
689
 
    except errors.NoSuchRevision:
690
 
        # The revision must be outside of this branch
691
 
        return None
692
 
    else:
693
 
        return '.'.join(str(n) for n in revno)
694
 
 
695
 
 
696
603
def _is_obvious_ancestor(branch, start_rev_id, end_rev_id):
697
604
    """Is start_rev_id an obvious ancestor of end_rev_id?"""
698
605
    if start_rev_id and end_rev_id:
699
 
        try:
700
 
            start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
701
 
            end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
702
 
        except errors.NoSuchRevision:
703
 
            # one or both is not in the branch; not obvious
704
 
            return False
 
606
        start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
 
607
        end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
705
608
        if len(start_dotted) == 1 and len(end_dotted) == 1:
706
609
            # both on mainline
707
610
            return start_dotted[0] <= end_dotted[0]
717
620
    return True
718
621
 
719
622
 
720
 
def _linear_view_revisions(branch, start_rev_id, end_rev_id,
721
 
                           exclude_common_ancestry=False):
 
623
def _linear_view_revisions(branch, start_rev_id, end_rev_id):
722
624
    """Calculate a sequence of revisions to view, newest to oldest.
723
625
 
724
626
    :param start_rev_id: the lower revision-id
725
627
    :param end_rev_id: the upper revision-id
726
 
    :param exclude_common_ancestry: Whether the start_rev_id should be part of
727
 
        the iterated revisions.
728
628
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
729
629
    :raises _StartNotLinearAncestor: if a start_rev_id is specified but
730
 
        is not found walking the left-hand history
 
630
      is not found walking the left-hand history
731
631
    """
732
632
    br_revno, br_rev_id = branch.last_revision_info()
733
633
    repo = branch.repository
734
 
    graph = repo.get_graph()
735
634
    if start_rev_id is None and end_rev_id is None:
736
635
        cur_revno = br_revno
737
 
        for revision_id in graph.iter_lefthand_ancestry(br_rev_id,
738
 
            (_mod_revision.NULL_REVISION,)):
 
636
        for revision_id in repo.iter_reverse_revision_history(br_rev_id):
739
637
            yield revision_id, str(cur_revno), 0
740
638
            cur_revno -= 1
741
639
    else:
742
640
        if end_rev_id is None:
743
641
            end_rev_id = br_rev_id
744
642
        found_start = start_rev_id is None
745
 
        for revision_id in graph.iter_lefthand_ancestry(end_rev_id,
746
 
                (_mod_revision.NULL_REVISION,)):
747
 
            revno_str = _compute_revno_str(branch, revision_id)
 
643
        for revision_id in repo.iter_reverse_revision_history(end_rev_id):
 
644
            revno = branch.revision_id_to_dotted_revno(revision_id)
 
645
            revno_str = '.'.join(str(n) for n in revno)
748
646
            if not found_start and revision_id == start_rev_id:
749
 
                if not exclude_common_ancestry:
750
 
                    yield revision_id, revno_str, 0
 
647
                yield revision_id, revno_str, 0
751
648
                found_start = True
752
649
                break
753
650
            else:
758
655
 
759
656
 
760
657
def _graph_view_revisions(branch, start_rev_id, end_rev_id,
761
 
                          rebase_initial_depths=True,
762
 
                          exclude_common_ancestry=False):
 
658
    rebase_initial_depths=True):
763
659
    """Calculate revisions to view including merges, newest to oldest.
764
660
 
765
661
    :param branch: the branch
769
665
      revision is found?
770
666
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
771
667
    """
772
 
    if exclude_common_ancestry:
773
 
        stop_rule = 'with-merges-without-common-ancestry'
774
 
    else:
775
 
        stop_rule = 'with-merges'
776
668
    view_revisions = branch.iter_merge_sorted_revisions(
777
669
        start_revision_id=end_rev_id, stop_revision_id=start_rev_id,
778
 
        stop_rule=stop_rule)
 
670
        stop_rule="with-merges")
779
671
    if not rebase_initial_depths:
780
672
        for (rev_id, merge_depth, revno, end_of_merge
781
673
             ) in view_revisions:
801
693
            yield rev_id, '.'.join(map(str, revno)), merge_depth
802
694
 
803
695
 
 
696
@deprecated_function(deprecated_in((2, 2, 0)))
 
697
def calculate_view_revisions(branch, start_revision, end_revision, direction,
 
698
        specific_fileid, generate_merge_revisions):
 
699
    """Calculate the revisions to view.
 
700
 
 
701
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
 
702
             a list of the same tuples.
 
703
    """
 
704
    start_rev_id, end_rev_id = _get_revision_limits(branch, start_revision,
 
705
        end_revision)
 
706
    view_revisions = list(_calc_view_revisions(branch, start_rev_id, end_rev_id,
 
707
        direction, generate_merge_revisions or specific_fileid))
 
708
    if specific_fileid:
 
709
        view_revisions = _filter_revisions_touching_file_id(branch,
 
710
            specific_fileid, view_revisions,
 
711
            include_merges=generate_merge_revisions)
 
712
    return _rebase_merge_depth(view_revisions)
 
713
 
 
714
 
804
715
def _rebase_merge_depth(view_revisions):
805
716
    """Adjust depths upwards so the top level is 0."""
806
717
    # If either the first or last revision have a merge_depth of 0, we're done
850
761
    return log_rev_iterator
851
762
 
852
763
 
853
 
def _make_search_filter(branch, generate_delta, match, log_rev_iterator):
 
764
def _make_search_filter(branch, generate_delta, search, log_rev_iterator):
854
765
    """Create a filtered iterator of log_rev_iterator matching on a regex.
855
766
 
856
767
    :param branch: The branch being logged.
857
768
    :param generate_delta: Whether to generate a delta for each revision.
858
 
    :param match: A dictionary with properties as keys and lists of strings
859
 
        as values. To match, a revision may match any of the supplied strings
860
 
        within a single property but must match at least one string for each
861
 
        property.
 
769
    :param search: A user text search string.
862
770
    :param log_rev_iterator: An input iterator containing all revisions that
863
771
        could be displayed, in lists.
864
772
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
865
773
        delta).
866
774
    """
867
 
    if match is None:
 
775
    if search is None:
868
776
        return log_rev_iterator
869
 
    searchRE = [(k, [re.compile(x, re.IGNORECASE) for x in v])
870
 
                for (k,v) in match.iteritems()]
871
 
    return _filter_re(searchRE, log_rev_iterator)
872
 
 
873
 
 
874
 
def _filter_re(searchRE, log_rev_iterator):
 
777
    searchRE = re_compile_checked(search, re.IGNORECASE,
 
778
            'log message filter')
 
779
    return _filter_message_re(searchRE, log_rev_iterator)
 
780
 
 
781
 
 
782
def _filter_message_re(searchRE, log_rev_iterator):
875
783
    for revs in log_rev_iterator:
876
 
        new_revs = [rev for rev in revs if _match_filter(searchRE, rev[1])]
877
 
        if new_revs:
878
 
            yield new_revs
879
 
 
880
 
def _match_filter(searchRE, rev):
881
 
    strings = {
882
 
               'message': (rev.message,),
883
 
               'committer': (rev.committer,),
884
 
               'author': (rev.get_apparent_authors()),
885
 
               'bugs': list(rev.iter_bugs())
886
 
               }
887
 
    strings[''] = [item for inner_list in strings.itervalues()
888
 
                   for item in inner_list]
889
 
    for (k,v) in searchRE:
890
 
        if k in strings and not _match_any_filter(strings[k], v):
891
 
            return False
892
 
    return True
893
 
 
894
 
def _match_any_filter(strings, res):
895
 
    return any([filter(None, map(re.search, strings)) for re in res])
 
784
        new_revs = []
 
785
        for (rev_id, revno, merge_depth), rev, delta in revs:
 
786
            if searchRE.search(rev.message):
 
787
                new_revs.append(((rev_id, revno, merge_depth), rev, delta))
 
788
        yield new_revs
 
789
 
896
790
 
897
791
def _make_delta_filter(branch, generate_delta, search, log_rev_iterator,
898
792
    fileids=None, direction='reverse'):
971
865
 
972
866
def _update_fileids(delta, fileids, stop_on):
973
867
    """Update the set of file-ids to search based on file lifecycle events.
974
 
 
 
868
    
975
869
    :param fileids: a set of fileids to update
976
870
    :param stop_on: either 'add' or 'remove' - take file-ids out of the
977
871
      fileids set once their add or remove entry is detected respectively
1018
912
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
1019
913
        delta).
1020
914
    """
 
915
    repository = branch.repository
1021
916
    num = 9
1022
917
    for batch in log_rev_iterator:
1023
918
        batch = iter(batch)
1140
1035
    cur_revno = branch_revno
1141
1036
    rev_nos = {}
1142
1037
    mainline_revs = []
1143
 
    graph = branch.repository.get_graph()
1144
 
    for revision_id in graph.iter_lefthand_ancestry(
1145
 
            branch_last_revision, (_mod_revision.NULL_REVISION,)):
 
1038
    for revision_id in branch.repository.iter_reverse_revision_history(
 
1039
                        branch_last_revision):
1146
1040
        if cur_revno < start_revno:
1147
1041
            # We have gone far enough, but we always add 1 more revision
1148
1042
            rev_nos[revision_id] = cur_revno
1162
1056
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
1163
1057
 
1164
1058
 
 
1059
@deprecated_function(deprecated_in((2, 2, 0)))
 
1060
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
 
1061
    """Filter view_revisions based on revision ranges.
 
1062
 
 
1063
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth)
 
1064
            tuples to be filtered.
 
1065
 
 
1066
    :param start_rev_id: If not NONE specifies the first revision to be logged.
 
1067
            If NONE then all revisions up to the end_rev_id are logged.
 
1068
 
 
1069
    :param end_rev_id: If not NONE specifies the last revision to be logged.
 
1070
            If NONE then all revisions up to the end of the log are logged.
 
1071
 
 
1072
    :return: The filtered view_revisions.
 
1073
    """
 
1074
    if start_rev_id or end_rev_id:
 
1075
        revision_ids = [r for r, n, d in view_revisions]
 
1076
        if start_rev_id:
 
1077
            start_index = revision_ids.index(start_rev_id)
 
1078
        else:
 
1079
            start_index = 0
 
1080
        if start_rev_id == end_rev_id:
 
1081
            end_index = start_index
 
1082
        else:
 
1083
            if end_rev_id:
 
1084
                end_index = revision_ids.index(end_rev_id)
 
1085
            else:
 
1086
                end_index = len(view_revisions) - 1
 
1087
        # To include the revisions merged into the last revision,
 
1088
        # extend end_rev_id down to, but not including, the next rev
 
1089
        # with the same or lesser merge_depth
 
1090
        end_merge_depth = view_revisions[end_index][2]
 
1091
        try:
 
1092
            for index in xrange(end_index+1, len(view_revisions)+1):
 
1093
                if view_revisions[index][2] <= end_merge_depth:
 
1094
                    end_index = index - 1
 
1095
                    break
 
1096
        except IndexError:
 
1097
            # if the search falls off the end then log to the end as well
 
1098
            end_index = len(view_revisions) - 1
 
1099
        view_revisions = view_revisions[start_index:end_index+1]
 
1100
    return view_revisions
 
1101
 
 
1102
 
1165
1103
def _filter_revisions_touching_file_id(branch, file_id, view_revisions,
1166
1104
    include_merges=True):
1167
1105
    r"""Return the list of revision ids which touch a given file id.
1170
1108
    This includes the revisions which directly change the file id,
1171
1109
    and the revisions which merge these changes. So if the
1172
1110
    revision graph is::
1173
 
 
1174
1111
        A-.
1175
1112
        |\ \
1176
1113
        B C E
1203
1140
    """
1204
1141
    # Lookup all possible text keys to determine which ones actually modified
1205
1142
    # the file.
1206
 
    graph = branch.repository.get_file_graph()
1207
 
    get_parent_map = graph.get_parent_map
1208
1143
    text_keys = [(file_id, rev_id) for rev_id, revno, depth in view_revisions]
1209
1144
    next_keys = None
1210
1145
    # Looking up keys in batches of 1000 can cut the time in half, as well as
1214
1149
    #       indexing layer. We might consider passing in hints as to the known
1215
1150
    #       access pattern (sparse/clustered, high success rate/low success
1216
1151
    #       rate). This particular access is clustered with a low success rate.
 
1152
    get_parent_map = branch.repository.texts.get_parent_map
1217
1153
    modified_text_revisions = set()
1218
1154
    chunk_size = 1000
1219
1155
    for start in xrange(0, len(text_keys), chunk_size):
1246
1182
    return result
1247
1183
 
1248
1184
 
 
1185
@deprecated_function(deprecated_in((2, 2, 0)))
 
1186
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
 
1187
                       include_merges=True):
 
1188
    """Produce an iterator of revisions to show
 
1189
    :return: an iterator of (revision_id, revno, merge_depth)
 
1190
    (if there is no revno for a revision, None is supplied)
 
1191
    """
 
1192
    if not include_merges:
 
1193
        revision_ids = mainline_revs[1:]
 
1194
        if direction == 'reverse':
 
1195
            revision_ids.reverse()
 
1196
        for revision_id in revision_ids:
 
1197
            yield revision_id, str(rev_nos[revision_id]), 0
 
1198
        return
 
1199
    graph = branch.repository.get_graph()
 
1200
    # This asks for all mainline revisions, which means we only have to spider
 
1201
    # sideways, rather than depth history. That said, its still size-of-history
 
1202
    # and should be addressed.
 
1203
    # mainline_revisions always includes an extra revision at the beginning, so
 
1204
    # don't request it.
 
1205
    parent_map = dict(((key, value) for key, value in
 
1206
        graph.iter_ancestry(mainline_revs[1:]) if value is not None))
 
1207
    # filter out ghosts; merge_sort errors on ghosts.
 
1208
    rev_graph = _mod_repository._strip_NULL_ghosts(parent_map)
 
1209
    merge_sorted_revisions = tsort.merge_sort(
 
1210
        rev_graph,
 
1211
        mainline_revs[-1],
 
1212
        mainline_revs,
 
1213
        generate_revno=True)
 
1214
 
 
1215
    if direction == 'forward':
 
1216
        # forward means oldest first.
 
1217
        merge_sorted_revisions = reverse_by_depth(merge_sorted_revisions)
 
1218
    elif direction != 'reverse':
 
1219
        raise ValueError('invalid direction %r' % direction)
 
1220
 
 
1221
    for (sequence, rev_id, merge_depth, revno, end_of_merge
 
1222
         ) in merge_sorted_revisions:
 
1223
        yield rev_id, '.'.join(map(str, revno)), merge_depth
 
1224
 
 
1225
 
1249
1226
def reverse_by_depth(merge_sorted_revisions, _depth=0):
1250
1227
    """Reverse revisions by depth.
1251
1228
 
1286
1263
    """
1287
1264
 
1288
1265
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
1289
 
                 tags=None, diff=None, signature=None):
 
1266
                 tags=None, diff=None):
1290
1267
        self.rev = rev
1291
 
        if revno is None:
1292
 
            self.revno = None
1293
 
        else:
1294
 
            self.revno = str(revno)
 
1268
        self.revno = str(revno)
1295
1269
        self.merge_depth = merge_depth
1296
1270
        self.delta = delta
1297
1271
        self.tags = tags
1298
1272
        self.diff = diff
1299
 
        self.signature = signature
1300
1273
 
1301
1274
 
1302
1275
class LogFormatter(object):
1311
1284
    to indicate which LogRevision attributes it supports:
1312
1285
 
1313
1286
    - supports_delta must be True if this log formatter supports delta.
1314
 
      Otherwise the delta attribute may not be populated.  The 'delta_format'
1315
 
      attribute describes whether the 'short_status' format (1) or the long
1316
 
      one (2) should be used.
 
1287
        Otherwise the delta attribute may not be populated.  The 'delta_format'
 
1288
        attribute describes whether the 'short_status' format (1) or the long
 
1289
        one (2) should be used.
1317
1290
 
1318
1291
    - supports_merge_revisions must be True if this log formatter supports
1319
 
      merge revisions.  If not, then only mainline revisions will be passed
1320
 
      to the formatter.
 
1292
        merge revisions.  If not, then only mainline revisions will be passed
 
1293
        to the formatter.
1321
1294
 
1322
1295
    - preferred_levels is the number of levels this formatter defaults to.
1323
 
      The default value is zero meaning display all levels.
1324
 
      This value is only relevant if supports_merge_revisions is True.
 
1296
        The default value is zero meaning display all levels.
 
1297
        This value is only relevant if supports_merge_revisions is True.
1325
1298
 
1326
1299
    - supports_tags must be True if this log formatter supports tags.
1327
 
      Otherwise the tags attribute may not be populated.
 
1300
        Otherwise the tags attribute may not be populated.
1328
1301
 
1329
1302
    - supports_diff must be True if this log formatter supports diffs.
1330
 
      Otherwise the diff attribute may not be populated.
1331
 
 
1332
 
    - supports_signatures must be True if this log formatter supports GPG
1333
 
      signatures.
 
1303
        Otherwise the diff attribute may not be populated.
1334
1304
 
1335
1305
    Plugins can register functions to show custom revision properties using
1336
1306
    the properties_handler_registry. The registered function
1337
 
    must respect the following interface description::
1338
 
 
 
1307
    must respect the following interface description:
1339
1308
        def my_show_properties(properties_dict):
1340
1309
            # code that returns a dict {'name':'value'} of the properties
1341
1310
            # to be shown
1344
1313
 
1345
1314
    def __init__(self, to_file, show_ids=False, show_timezone='original',
1346
1315
                 delta_format=None, levels=None, show_advice=False,
1347
 
                 to_exact_file=None, author_list_handler=None):
 
1316
                 to_exact_file=None):
1348
1317
        """Create a LogFormatter.
1349
1318
 
1350
1319
        :param to_file: the file to output to
1351
 
        :param to_exact_file: if set, gives an output stream to which
 
1320
        :param to_exact_file: if set, gives an output stream to which 
1352
1321
             non-Unicode diffs are written.
1353
1322
        :param show_ids: if True, revision-ids are to be displayed
1354
1323
        :param show_timezone: the timezone to use
1358
1327
          let the log formatter decide.
1359
1328
        :param show_advice: whether to show advice at the end of the
1360
1329
          log or not
1361
 
        :param author_list_handler: callable generating a list of
1362
 
          authors to display for a given revision
1363
1330
        """
1364
1331
        self.to_file = to_file
1365
1332
        # 'exact' stream used to show diff, it should print content 'as is'
1380
1347
        self.levels = levels
1381
1348
        self._show_advice = show_advice
1382
1349
        self._merge_count = 0
1383
 
        self._author_list_handler = author_list_handler
1384
1350
 
1385
1351
    def get_levels(self):
1386
1352
        """Get the number of levels to display or 0 for all."""
1418
1384
        return address
1419
1385
 
1420
1386
    def short_author(self, rev):
1421
 
        return self.authors(rev, 'first', short=True, sep=', ')
1422
 
 
1423
 
    def authors(self, rev, who, short=False, sep=None):
1424
 
        """Generate list of authors, taking --authors option into account.
1425
 
 
1426
 
        The caller has to specify the name of a author list handler,
1427
 
        as provided by the author list registry, using the ``who``
1428
 
        argument.  That name only sets a default, though: when the
1429
 
        user selected a different author list generation using the
1430
 
        ``--authors`` command line switch, as represented by the
1431
 
        ``author_list_handler`` constructor argument, that value takes
1432
 
        precedence.
1433
 
 
1434
 
        :param rev: The revision for which to generate the list of authors.
1435
 
        :param who: Name of the default handler.
1436
 
        :param short: Whether to shorten names to either name or address.
1437
 
        :param sep: What separator to use for automatic concatenation.
1438
 
        """
1439
 
        if self._author_list_handler is not None:
1440
 
            # The user did specify --authors, which overrides the default
1441
 
            author_list_handler = self._author_list_handler
1442
 
        else:
1443
 
            # The user didn't specify --authors, so we use the caller's default
1444
 
            author_list_handler = author_list_registry.get(who)
1445
 
        names = author_list_handler(rev)
1446
 
        if short:
1447
 
            for i in range(len(names)):
1448
 
                name, address = config.parse_username(names[i])
1449
 
                if name:
1450
 
                    names[i] = name
1451
 
                else:
1452
 
                    names[i] = address
1453
 
        if sep is not None:
1454
 
            names = sep.join(names)
1455
 
        return names
 
1387
        name, address = config.parse_username(rev.get_apparent_authors()[0])
 
1388
        if name:
 
1389
            return name
 
1390
        return address
1456
1391
 
1457
1392
    def merge_marker(self, revision):
1458
1393
        """Get the merge marker to include in the output or '' if none."""
1489
1424
        """
1490
1425
        # Revision comes directly from a foreign repository
1491
1426
        if isinstance(rev, foreign.ForeignRevision):
1492
 
            return self._format_properties(
1493
 
                rev.mapping.vcs.show_foreign_revid(rev.foreign_revid))
 
1427
            return self._format_properties(rev.mapping.vcs.show_foreign_revid(rev.foreign_revid))
1494
1428
 
1495
1429
        # Imported foreign revision revision ids always contain :
1496
1430
        if not ":" in rev.revision_id:
1528
1462
    supports_delta = True
1529
1463
    supports_tags = True
1530
1464
    supports_diff = True
1531
 
    supports_signatures = True
1532
1465
 
1533
1466
    def __init__(self, *args, **kwargs):
1534
1467
        super(LongLogFormatter, self).__init__(*args, **kwargs)
1554
1487
                self.merge_marker(revision)))
1555
1488
        if revision.tags:
1556
1489
            lines.append('tags: %s' % (', '.join(revision.tags)))
1557
 
        if self.show_ids or revision.revno is None:
 
1490
        if self.show_ids:
1558
1491
            lines.append('revision-id: %s' % (revision.rev.revision_id,))
1559
 
        if self.show_ids:
1560
1492
            for parent_id in revision.rev.parent_ids:
1561
1493
                lines.append('parent: %s' % (parent_id,))
1562
1494
        lines.extend(self.custom_properties(revision.rev))
1563
1495
 
1564
1496
        committer = revision.rev.committer
1565
 
        authors = self.authors(revision.rev, 'all')
 
1497
        authors = revision.rev.get_apparent_authors()
1566
1498
        if authors != [committer]:
1567
1499
            lines.append('author: %s' % (", ".join(authors),))
1568
1500
        lines.append('committer: %s' % (committer,))
1573
1505
 
1574
1506
        lines.append('timestamp: %s' % (self.date_string(revision.rev),))
1575
1507
 
1576
 
        if revision.signature is not None:
1577
 
            lines.append('signature: ' + revision.signature)
1578
 
 
1579
1508
        lines.append('message:')
1580
1509
        if not revision.rev.message:
1581
1510
            lines.append('  (no message)')
1588
1517
        to_file = self.to_file
1589
1518
        to_file.write("%s%s\n" % (indent, ('\n' + indent).join(lines)))
1590
1519
        if revision.delta is not None:
1591
 
            # Use the standard status output to display changes
1592
 
            from bzrlib.delta import report_delta
1593
 
            report_delta(to_file, revision.delta, short_status=False,
1594
 
                         show_ids=self.show_ids, indent=indent)
 
1520
            # We don't respect delta_format for compatibility
 
1521
            revision.delta.show(to_file, self.show_ids, indent=indent,
 
1522
                                short_status=False)
1595
1523
        if revision.diff is not None:
1596
1524
            to_file.write(indent + 'diff:\n')
1597
1525
            to_file.flush()
1628
1556
        indent = '    ' * depth
1629
1557
        revno_width = self.revno_width_by_depth.get(depth)
1630
1558
        if revno_width is None:
1631
 
            if revision.revno is None or revision.revno.find('.') == -1:
 
1559
            if revision.revno.find('.') == -1:
1632
1560
                # mainline revno, e.g. 12345
1633
1561
                revno_width = 5
1634
1562
            else:
1642
1570
        if revision.tags:
1643
1571
            tags = ' {%s}' % (', '.join(revision.tags))
1644
1572
        to_file.write(indent + "%*s %s\t%s%s%s\n" % (revno_width,
1645
 
                revision.revno or "", self.short_author(revision.rev),
 
1573
                revision.revno, self.short_author(revision.rev),
1646
1574
                format_date(revision.rev.timestamp,
1647
1575
                            revision.rev.timezone or 0,
1648
1576
                            self.show_timezone, date_fmt="%Y-%m-%d",
1649
1577
                            show_offset=False),
1650
1578
                tags, self.merge_marker(revision)))
1651
1579
        self.show_properties(revision.rev, indent+offset)
1652
 
        if self.show_ids or revision.revno is None:
 
1580
        if self.show_ids:
1653
1581
            to_file.write(indent + offset + 'revision-id:%s\n'
1654
1582
                          % (revision.rev.revision_id,))
1655
1583
        if not revision.rev.message:
1660
1588
                to_file.write(indent + offset + '%s\n' % (l,))
1661
1589
 
1662
1590
        if revision.delta is not None:
1663
 
            # Use the standard status output to display changes
1664
 
            from bzrlib.delta import report_delta
1665
 
            report_delta(to_file, revision.delta,
1666
 
                         short_status=self.delta_format==1,
1667
 
                         show_ids=self.show_ids, indent=indent + offset)
 
1591
            revision.delta.show(to_file, self.show_ids, indent=indent + offset,
 
1592
                                short_status=self.delta_format==1)
1668
1593
        if revision.diff is not None:
1669
1594
            self.show_diff(self.to_exact_file, revision.diff, '      ')
1670
1595
        to_file.write('\n')
1708
1633
 
1709
1634
    def log_string(self, revno, rev, max_chars, tags=None, prefix=''):
1710
1635
        """Format log info into one string. Truncate tail of string
1711
 
 
1712
 
        :param revno:      revision number or None.
1713
 
                           Revision numbers counts from 1.
1714
 
        :param rev:        revision object
1715
 
        :param max_chars:  maximum length of resulting string
1716
 
        :param tags:       list of tags or None
1717
 
        :param prefix:     string to prefix each line
1718
 
        :return:           formatted truncated string
 
1636
        :param  revno:      revision number or None.
 
1637
                            Revision numbers counts from 1.
 
1638
        :param  rev:        revision object
 
1639
        :param  max_chars:  maximum length of resulting string
 
1640
        :param  tags:       list of tags or None
 
1641
        :param  prefix:     string to prefix each line
 
1642
        :return:            formatted truncated string
1719
1643
        """
1720
1644
        out = []
1721
1645
        if revno:
1722
1646
            # show revno only when is not None
1723
1647
            out.append("%s:" % revno)
1724
 
        if max_chars is not None:
1725
 
            out.append(self.truncate(self.short_author(rev), (max_chars+3)/4))
1726
 
        else:
1727
 
            out.append(self.short_author(rev))
 
1648
        out.append(self.truncate(self.short_author(rev), 20))
1728
1649
        out.append(self.date_string(rev))
1729
1650
        if len(rev.parent_ids) > 1:
1730
1651
            out.append('[merge]')
1749
1670
                               self.show_timezone,
1750
1671
                               date_fmt='%Y-%m-%d',
1751
1672
                               show_offset=False)
1752
 
        committer_str = self.authors(revision.rev, 'first', sep=', ')
1753
 
        committer_str = committer_str.replace(' <', '  <')
 
1673
        committer_str = revision.rev.committer.replace (' <', '  <')
1754
1674
        to_file.write('%s  %s\n\n' % (date_str,committer_str))
1755
1675
 
1756
1676
        if revision.delta is not None and revision.delta.has_changed():
1821
1741
        raise errors.BzrCommandError("unknown log formatter: %r" % name)
1822
1742
 
1823
1743
 
1824
 
def author_list_all(rev):
1825
 
    return rev.get_apparent_authors()[:]
1826
 
 
1827
 
 
1828
 
def author_list_first(rev):
1829
 
    lst = rev.get_apparent_authors()
1830
 
    try:
1831
 
        return [lst[0]]
1832
 
    except IndexError:
1833
 
        return []
1834
 
 
1835
 
 
1836
 
def author_list_committer(rev):
1837
 
    return [rev.committer]
1838
 
 
1839
 
 
1840
 
author_list_registry = registry.Registry()
1841
 
 
1842
 
author_list_registry.register('all', author_list_all,
1843
 
                              'All authors')
1844
 
 
1845
 
author_list_registry.register('first', author_list_first,
1846
 
                              'The first author')
1847
 
 
1848
 
author_list_registry.register('committer', author_list_committer,
1849
 
                              'The committer')
 
1744
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
 
1745
    # deprecated; for compatibility
 
1746
    lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
 
1747
    lf.show(revno, rev, delta)
1850
1748
 
1851
1749
 
1852
1750
def show_changed_revisions(branch, old_rh, new_rh, to_file=None,
1917
1815
    old_revisions = set()
1918
1816
    new_history = []
1919
1817
    new_revisions = set()
1920
 
    graph = repository.get_graph()
1921
 
    new_iter = graph.iter_lefthand_ancestry(new_revision_id)
1922
 
    old_iter = graph.iter_lefthand_ancestry(old_revision_id)
 
1818
    new_iter = repository.iter_reverse_revision_history(new_revision_id)
 
1819
    old_iter = repository.iter_reverse_revision_history(old_revision_id)
1923
1820
    stop_revision = None
1924
1821
    do_old = True
1925
1822
    do_new = True
2000
1897
        lf.log_revision(lr)
2001
1898
 
2002
1899
 
2003
 
def _get_info_for_log_files(revisionspec_list, file_list, add_cleanup):
 
1900
def _get_info_for_log_files(revisionspec_list, file_list):
2004
1901
    """Find file-ids and kinds given a list of files and a revision range.
2005
1902
 
2006
1903
    We search for files at the end of the range. If not found there,
2010
1907
    :param file_list: the list of paths given on the command line;
2011
1908
      the first of these can be a branch location or a file path,
2012
1909
      the remainder must be file paths
2013
 
    :param add_cleanup: When the branch returned is read locked,
2014
 
      an unlock call will be queued to the cleanup.
2015
1910
    :return: (branch, info_list, start_rev_info, end_rev_info) where
2016
1911
      info_list is a list of (relative_path, file_id, kind) tuples where
2017
1912
      kind is one of values 'directory', 'file', 'symlink', 'tree-reference'.
2018
1913
      branch will be read-locked.
2019
1914
    """
2020
 
    from builtins import _get_revision_range
 
1915
    from builtins import _get_revision_range, safe_relpath_files
2021
1916
    tree, b, path = bzrdir.BzrDir.open_containing_tree_or_branch(file_list[0])
2022
 
    add_cleanup(b.lock_read().unlock)
 
1917
    b.lock_read()
2023
1918
    # XXX: It's damn messy converting a list of paths to relative paths when
2024
1919
    # those paths might be deleted ones, they might be on a case-insensitive
2025
1920
    # filesystem and/or they might be in silly locations (like another branch).
2029
1924
    # case of running log in a nested directory, assuming paths beyond the
2030
1925
    # first one haven't been deleted ...
2031
1926
    if tree:
2032
 
        relpaths = [path] + tree.safe_relpath_files(file_list[1:])
 
1927
        relpaths = [path] + safe_relpath_files(tree, file_list[1:])
2033
1928
    else:
2034
1929
        relpaths = [path] + file_list[1:]
2035
1930
    info_list = []
2111
2006
        bug_rows = [line.split(' ', 1) for line in bug_lines]
2112
2007
        fixed_bug_urls = [row[0] for row in bug_rows if
2113
2008
                          len(row) > 1 and row[1] == 'fixed']
2114
 
 
 
2009
        
2115
2010
        if fixed_bug_urls:
2116
2011
            return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
2117
2012
    return {}