/brz/remove-bazaar

To get this branch, use:
bzr branch http://gegoxaren.bato24.eu/bzr/brz/remove-bazaar

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: Martin von Gagern
  • Date: 2010-04-20 08:47:38 UTC
  • mfrom: (5167 +trunk)
  • mto: This revision was merged to the branch mainline in revision 5195.
  • Revision ID: martin.vgagern@gmx.net-20100420084738-ygymnqmdllzrhpfn
merge trunk

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006, 2007 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
12
12
#
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
 
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
16
 
17
17
 
18
18
 
50
50
"""
51
51
 
52
52
import codecs
 
53
from cStringIO import StringIO
53
54
from itertools import (
 
55
    chain,
54
56
    izip,
55
57
    )
56
58
import re
63
65
lazy_import(globals(), """
64
66
 
65
67
from bzrlib import (
 
68
    bzrdir,
66
69
    config,
 
70
    diff,
67
71
    errors,
 
72
    foreign,
68
73
    repository as _mod_repository,
69
74
    revision as _mod_revision,
70
75
    revisionspec,
78
83
    )
79
84
from bzrlib.osutils import (
80
85
    format_date,
 
86
    format_date_with_offset_in_original_timezone,
81
87
    get_terminal_encoding,
 
88
    re_compile_checked,
82
89
    terminal_width,
83
90
    )
 
91
from bzrlib.symbol_versioning import (
 
92
    deprecated_function,
 
93
    deprecated_in,
 
94
    )
84
95
 
85
96
 
86
97
def find_touching_revisions(branch, file_id):
98
109
    last_path = None
99
110
    revno = 1
100
111
    for revision_id in branch.revision_history():
101
 
        this_inv = branch.repository.get_revision_inventory(revision_id)
 
112
        this_inv = branch.repository.get_inventory(revision_id)
102
113
        if file_id in this_inv:
103
114
            this_ie = this_inv[file_id]
104
115
            this_path = this_inv.id2path(file_id)
144
155
             start_revision=None,
145
156
             end_revision=None,
146
157
             search=None,
147
 
             limit=None):
 
158
             limit=None,
 
159
             show_diff=False):
148
160
    """Write out human-readable log of commits to this branch.
149
161
 
150
 
    lf
151
 
        LogFormatter object to show the output.
152
 
 
153
 
    specific_fileid
154
 
        If true, list only the commits affecting the specified
155
 
        file, rather than all commits.
156
 
 
157
 
    verbose
158
 
        If true show added/changed/deleted/renamed files.
159
 
 
160
 
    direction
161
 
        'reverse' (default) is latest to earliest;
162
 
        'forward' is earliest to latest.
163
 
 
164
 
    start_revision
165
 
        If not None, only show revisions >= start_revision
166
 
 
167
 
    end_revision
168
 
        If not None, only show revisions <= end_revision
169
 
 
170
 
    search
171
 
        If not None, only show revisions with matching commit messages
172
 
 
173
 
    limit
174
 
        If not None or 0, only show limit revisions
175
 
    """
176
 
    branch.lock_read()
177
 
    try:
178
 
        if getattr(lf, 'begin_log', None):
179
 
            lf.begin_log()
180
 
 
181
 
        _show_log(branch, lf, specific_fileid, verbose, direction,
182
 
                  start_revision, end_revision, search, limit)
183
 
 
184
 
        if getattr(lf, 'end_log', None):
185
 
            lf.end_log()
186
 
    finally:
187
 
        branch.unlock()
188
 
 
189
 
 
190
 
def _show_log(branch,
191
 
             lf,
192
 
             specific_fileid=None,
193
 
             verbose=False,
194
 
             direction='reverse',
195
 
             start_revision=None,
196
 
             end_revision=None,
197
 
             search=None,
198
 
             limit=None):
199
 
    """Worker function for show_log - see show_log."""
200
 
    if not isinstance(lf, LogFormatter):
201
 
        warn("not a LogFormatter instance: %r" % lf)
202
 
 
203
 
    if specific_fileid:
204
 
        trace.mutter('get log for file_id %r', specific_fileid)
205
 
    generate_merge_revisions = getattr(lf, 'supports_merge_revisions', False)
206
 
    allow_single_merge_revision = getattr(lf,
207
 
        'supports_single_merge_revision', False)
208
 
    view_revisions = calculate_view_revisions(branch, start_revision,
209
 
                                              end_revision, direction,
210
 
                                              specific_fileid,
211
 
                                              generate_merge_revisions,
212
 
                                              allow_single_merge_revision)
213
 
    rev_tag_dict = {}
214
 
    generate_tags = getattr(lf, 'supports_tags', False)
215
 
    if generate_tags:
216
 
        if branch.supports_tags():
217
 
            rev_tag_dict = branch.tags.get_reverse_tag_dict()
218
 
 
219
 
    generate_delta = verbose and getattr(lf, 'supports_delta', False)
220
 
 
221
 
    # now we just print all the revisions
222
 
    log_count = 0
223
 
    revision_iterator = make_log_rev_iterator(branch, view_revisions,
224
 
        generate_delta, search)
225
 
    for revs in revision_iterator:
226
 
        for (rev_id, revno, merge_depth), rev, delta in revs:
227
 
            lr = LogRevision(rev, revno, merge_depth, delta,
228
 
                             rev_tag_dict.get(rev_id))
 
162
    This function is being retained for backwards compatibility but
 
163
    should not be extended with new parameters. Use the new Logger class
 
164
    instead, eg. Logger(branch, rqst).show(lf), adding parameters to the
 
165
    make_log_request_dict function.
 
166
 
 
167
    :param lf: The LogFormatter object showing the output.
 
168
 
 
169
    :param specific_fileid: If not None, list only the commits affecting the
 
170
        specified file, rather than all commits.
 
171
 
 
172
    :param verbose: If True show added/changed/deleted/renamed files.
 
173
 
 
174
    :param direction: 'reverse' (default) is latest to earliest; 'forward' is
 
175
        earliest to latest.
 
176
 
 
177
    :param start_revision: If not None, only show revisions >= start_revision
 
178
 
 
179
    :param end_revision: If not None, only show revisions <= end_revision
 
180
 
 
181
    :param search: If not None, only show revisions with matching commit
 
182
        messages
 
183
 
 
184
    :param limit: If set, shows only 'limit' revisions, all revisions are shown
 
185
        if None or 0.
 
186
 
 
187
    :param show_diff: If True, output a diff after each revision.
 
188
    """
 
189
    # Convert old-style parameters to new-style parameters
 
190
    if specific_fileid is not None:
 
191
        file_ids = [specific_fileid]
 
192
    else:
 
193
        file_ids = None
 
194
    if verbose:
 
195
        if file_ids:
 
196
            delta_type = 'partial'
 
197
        else:
 
198
            delta_type = 'full'
 
199
    else:
 
200
        delta_type = None
 
201
    if show_diff:
 
202
        if file_ids:
 
203
            diff_type = 'partial'
 
204
        else:
 
205
            diff_type = 'full'
 
206
    else:
 
207
        diff_type = None
 
208
 
 
209
    # Build the request and execute it
 
210
    rqst = make_log_request_dict(direction=direction, specific_fileids=file_ids,
 
211
        start_revision=start_revision, end_revision=end_revision,
 
212
        limit=limit, message_search=search,
 
213
        delta_type=delta_type, diff_type=diff_type)
 
214
    Logger(branch, rqst).show(lf)
 
215
 
 
216
 
 
217
# Note: This needs to be kept this in sync with the defaults in
 
218
# make_log_request_dict() below
 
219
_DEFAULT_REQUEST_PARAMS = {
 
220
    'direction': 'reverse',
 
221
    'levels': 1,
 
222
    'generate_tags': True,
 
223
    '_match_using_deltas': True,
 
224
    }
 
225
 
 
226
 
 
227
def make_log_request_dict(direction='reverse', specific_fileids=None,
 
228
    start_revision=None, end_revision=None, limit=None,
 
229
    message_search=None, levels=1, generate_tags=True, delta_type=None,
 
230
    diff_type=None, _match_using_deltas=True):
 
231
    """Convenience function for making a logging request dictionary.
 
232
 
 
233
    Using this function may make code slightly safer by ensuring
 
234
    parameters have the correct names. It also provides a reference
 
235
    point for documenting the supported parameters.
 
236
 
 
237
    :param direction: 'reverse' (default) is latest to earliest;
 
238
      'forward' is earliest to latest.
 
239
 
 
240
    :param specific_fileids: If not None, only include revisions
 
241
      affecting the specified files, rather than all revisions.
 
242
 
 
243
    :param start_revision: If not None, only generate
 
244
      revisions >= start_revision
 
245
 
 
246
    :param end_revision: If not None, only generate
 
247
      revisions <= end_revision
 
248
 
 
249
    :param limit: If set, generate only 'limit' revisions, all revisions
 
250
      are shown if None or 0.
 
251
 
 
252
    :param message_search: If not None, only include revisions with
 
253
      matching commit messages
 
254
 
 
255
    :param levels: the number of levels of revisions to
 
256
      generate; 1 for just the mainline; 0 for all levels.
 
257
 
 
258
    :param generate_tags: If True, include tags for matched revisions.
 
259
 
 
260
    :param delta_type: Either 'full', 'partial' or None.
 
261
      'full' means generate the complete delta - adds/deletes/modifies/etc;
 
262
      'partial' means filter the delta using specific_fileids;
 
263
      None means do not generate any delta.
 
264
 
 
265
    :param diff_type: Either 'full', 'partial' or None.
 
266
      'full' means generate the complete diff - adds/deletes/modifies/etc;
 
267
      'partial' means filter the diff using specific_fileids;
 
268
      None means do not generate any diff.
 
269
 
 
270
    :param _match_using_deltas: a private parameter controlling the
 
271
      algorithm used for matching specific_fileids. This parameter
 
272
      may be removed in the future so bzrlib client code should NOT
 
273
      use it.
 
274
    """
 
275
    return {
 
276
        'direction': direction,
 
277
        'specific_fileids': specific_fileids,
 
278
        'start_revision': start_revision,
 
279
        'end_revision': end_revision,
 
280
        'limit': limit,
 
281
        'message_search': message_search,
 
282
        'levels': levels,
 
283
        'generate_tags': generate_tags,
 
284
        'delta_type': delta_type,
 
285
        'diff_type': diff_type,
 
286
        # Add 'private' attributes for features that may be deprecated
 
287
        '_match_using_deltas': _match_using_deltas,
 
288
    }
 
289
 
 
290
 
 
291
def _apply_log_request_defaults(rqst):
 
292
    """Apply default values to a request dictionary."""
 
293
    result = _DEFAULT_REQUEST_PARAMS
 
294
    if rqst:
 
295
        result.update(rqst)
 
296
    return result
 
297
 
 
298
 
 
299
class LogGenerator(object):
 
300
    """A generator of log revisions."""
 
301
 
 
302
    def iter_log_revisions(self):
 
303
        """Iterate over LogRevision objects.
 
304
 
 
305
        :return: An iterator yielding LogRevision objects.
 
306
        """
 
307
        raise NotImplementedError(self.iter_log_revisions)
 
308
 
 
309
 
 
310
class Logger(object):
 
311
    """An object that generates, formats and displays a log."""
 
312
 
 
313
    def __init__(self, branch, rqst):
 
314
        """Create a Logger.
 
315
 
 
316
        :param branch: the branch to log
 
317
        :param rqst: A dictionary specifying the query parameters.
 
318
          See make_log_request_dict() for supported values.
 
319
        """
 
320
        self.branch = branch
 
321
        self.rqst = _apply_log_request_defaults(rqst)
 
322
 
 
323
    def show(self, lf):
 
324
        """Display the log.
 
325
 
 
326
        :param lf: The LogFormatter object to send the output to.
 
327
        """
 
328
        if not isinstance(lf, LogFormatter):
 
329
            warn("not a LogFormatter instance: %r" % lf)
 
330
 
 
331
        self.branch.lock_read()
 
332
        try:
 
333
            if getattr(lf, 'begin_log', None):
 
334
                lf.begin_log()
 
335
            self._show_body(lf)
 
336
            if getattr(lf, 'end_log', None):
 
337
                lf.end_log()
 
338
        finally:
 
339
            self.branch.unlock()
 
340
 
 
341
    def _show_body(self, lf):
 
342
        """Show the main log output.
 
343
 
 
344
        Subclasses may wish to override this.
 
345
        """
 
346
        # Tweak the LogRequest based on what the LogFormatter can handle.
 
347
        # (There's no point generating stuff if the formatter can't display it.)
 
348
        rqst = self.rqst
 
349
        rqst['levels'] = lf.get_levels()
 
350
        if not getattr(lf, 'supports_tags', False):
 
351
            rqst['generate_tags'] = False
 
352
        if not getattr(lf, 'supports_delta', False):
 
353
            rqst['delta_type'] = None
 
354
        if not getattr(lf, 'supports_diff', False):
 
355
            rqst['diff_type'] = None
 
356
 
 
357
        # Find and print the interesting revisions
 
358
        generator = self._generator_factory(self.branch, rqst)
 
359
        for lr in generator.iter_log_revisions():
229
360
            lf.log_revision(lr)
230
 
            if limit:
231
 
                log_count += 1
232
 
                if log_count >= limit:
233
 
                    return
234
 
 
235
 
 
 
361
        lf.show_advice()
 
362
 
 
363
    def _generator_factory(self, branch, rqst):
 
364
        """Make the LogGenerator object to use.
 
365
        
 
366
        Subclasses may wish to override this.
 
367
        """
 
368
        return _DefaultLogGenerator(branch, rqst)
 
369
 
 
370
 
 
371
class _StartNotLinearAncestor(Exception):
 
372
    """Raised when a start revision is not found walking left-hand history."""
 
373
 
 
374
 
 
375
class _DefaultLogGenerator(LogGenerator):
 
376
    """The default generator of log revisions."""
 
377
 
 
378
    def __init__(self, branch, rqst):
 
379
        self.branch = branch
 
380
        self.rqst = rqst
 
381
        if rqst.get('generate_tags') and branch.supports_tags():
 
382
            self.rev_tag_dict = branch.tags.get_reverse_tag_dict()
 
383
        else:
 
384
            self.rev_tag_dict = {}
 
385
 
 
386
    def iter_log_revisions(self):
 
387
        """Iterate over LogRevision objects.
 
388
 
 
389
        :return: An iterator yielding LogRevision objects.
 
390
        """
 
391
        rqst = self.rqst
 
392
        levels = rqst.get('levels')
 
393
        limit = rqst.get('limit')
 
394
        diff_type = rqst.get('diff_type')
 
395
        log_count = 0
 
396
        revision_iterator = self._create_log_revision_iterator()
 
397
        for revs in revision_iterator:
 
398
            for (rev_id, revno, merge_depth), rev, delta in revs:
 
399
                # 0 levels means show everything; merge_depth counts from 0
 
400
                if levels != 0 and merge_depth >= levels:
 
401
                    continue
 
402
                if diff_type is None:
 
403
                    diff = None
 
404
                else:
 
405
                    diff = self._format_diff(rev, rev_id, diff_type)
 
406
                yield LogRevision(rev, revno, merge_depth, delta,
 
407
                    self.rev_tag_dict.get(rev_id), diff)
 
408
                if limit:
 
409
                    log_count += 1
 
410
                    if log_count >= limit:
 
411
                        return
 
412
 
 
413
    def _format_diff(self, rev, rev_id, diff_type):
 
414
        repo = self.branch.repository
 
415
        if len(rev.parent_ids) == 0:
 
416
            ancestor_id = _mod_revision.NULL_REVISION
 
417
        else:
 
418
            ancestor_id = rev.parent_ids[0]
 
419
        tree_1 = repo.revision_tree(ancestor_id)
 
420
        tree_2 = repo.revision_tree(rev_id)
 
421
        file_ids = self.rqst.get('specific_fileids')
 
422
        if diff_type == 'partial' and file_ids is not None:
 
423
            specific_files = [tree_2.id2path(id) for id in file_ids]
 
424
        else:
 
425
            specific_files = None
 
426
        s = StringIO()
 
427
        diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
 
428
            new_label='')
 
429
        return s.getvalue()
 
430
 
 
431
    def _create_log_revision_iterator(self):
 
432
        """Create a revision iterator for log.
 
433
 
 
434
        :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
 
435
            delta).
 
436
        """
 
437
        self.start_rev_id, self.end_rev_id = _get_revision_limits(
 
438
            self.branch, self.rqst.get('start_revision'),
 
439
            self.rqst.get('end_revision'))
 
440
        if self.rqst.get('_match_using_deltas'):
 
441
            return self._log_revision_iterator_using_delta_matching()
 
442
        else:
 
443
            # We're using the per-file-graph algorithm. This scales really
 
444
            # well but only makes sense if there is a single file and it's
 
445
            # not a directory
 
446
            file_count = len(self.rqst.get('specific_fileids'))
 
447
            if file_count != 1:
 
448
                raise BzrError("illegal LogRequest: must match-using-deltas "
 
449
                    "when logging %d files" % file_count)
 
450
            return self._log_revision_iterator_using_per_file_graph()
 
451
 
 
452
    def _log_revision_iterator_using_delta_matching(self):
 
453
        # Get the base revisions, filtering by the revision range
 
454
        rqst = self.rqst
 
455
        generate_merge_revisions = rqst.get('levels') != 1
 
456
        delayed_graph_generation = not rqst.get('specific_fileids') and (
 
457
                rqst.get('limit') or self.start_rev_id or self.end_rev_id)
 
458
        view_revisions = _calc_view_revisions(
 
459
            self.branch, self.start_rev_id, self.end_rev_id,
 
460
            rqst.get('direction'),
 
461
            generate_merge_revisions=generate_merge_revisions,
 
462
            delayed_graph_generation=delayed_graph_generation)
 
463
 
 
464
        # Apply the other filters
 
465
        return make_log_rev_iterator(self.branch, view_revisions,
 
466
            rqst.get('delta_type'), rqst.get('message_search'),
 
467
            file_ids=rqst.get('specific_fileids'),
 
468
            direction=rqst.get('direction'))
 
469
 
 
470
    def _log_revision_iterator_using_per_file_graph(self):
 
471
        # Get the base revisions, filtering by the revision range.
 
472
        # Note that we always generate the merge revisions because
 
473
        # filter_revisions_touching_file_id() requires them ...
 
474
        rqst = self.rqst
 
475
        view_revisions = _calc_view_revisions(
 
476
            self.branch, self.start_rev_id, self.end_rev_id,
 
477
            rqst.get('direction'), generate_merge_revisions=True)
 
478
        if not isinstance(view_revisions, list):
 
479
            view_revisions = list(view_revisions)
 
480
        view_revisions = _filter_revisions_touching_file_id(self.branch,
 
481
            rqst.get('specific_fileids')[0], view_revisions,
 
482
            include_merges=rqst.get('levels') != 1)
 
483
        return make_log_rev_iterator(self.branch, view_revisions,
 
484
            rqst.get('delta_type'), rqst.get('message_search'))
 
485
 
 
486
 
 
487
def _calc_view_revisions(branch, start_rev_id, end_rev_id, direction,
 
488
    generate_merge_revisions, delayed_graph_generation=False):
 
489
    """Calculate the revisions to view.
 
490
 
 
491
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
 
492
             a list of the same tuples.
 
493
    """
 
494
    if direction not in ('reverse', 'forward'):
 
495
        raise ValueError('invalid direction %r' % direction)
 
496
    br_revno, br_rev_id = branch.last_revision_info()
 
497
    if br_revno == 0:
 
498
        return []
 
499
 
 
500
    if (end_rev_id and start_rev_id == end_rev_id
 
501
        and (not generate_merge_revisions
 
502
             or not _has_merges(branch, end_rev_id))):
 
503
        # If a single revision is requested, check we can handle it
 
504
        iter_revs = _generate_one_revision(branch, end_rev_id, br_rev_id,
 
505
                                           br_revno)
 
506
    elif not generate_merge_revisions:
 
507
        # If we only want to see linear revisions, we can iterate ...
 
508
        iter_revs = _generate_flat_revisions(branch, start_rev_id, end_rev_id,
 
509
                                             direction)
 
510
        if direction == 'forward':
 
511
            iter_revs = reversed(iter_revs)
 
512
    else:
 
513
        iter_revs = _generate_all_revisions(branch, start_rev_id, end_rev_id,
 
514
                                            direction, delayed_graph_generation)
 
515
        if direction == 'forward':
 
516
            iter_revs = _rebase_merge_depth(reverse_by_depth(list(iter_revs)))
 
517
    return iter_revs
 
518
 
 
519
 
 
520
def _generate_one_revision(branch, rev_id, br_rev_id, br_revno):
 
521
    if rev_id == br_rev_id:
 
522
        # It's the tip
 
523
        return [(br_rev_id, br_revno, 0)]
 
524
    else:
 
525
        revno = branch.revision_id_to_dotted_revno(rev_id)
 
526
        revno_str = '.'.join(str(n) for n in revno)
 
527
        return [(rev_id, revno_str, 0)]
 
528
 
 
529
 
 
530
def _generate_flat_revisions(branch, start_rev_id, end_rev_id, direction):
 
531
    result = _linear_view_revisions(branch, start_rev_id, end_rev_id)
 
532
    # If a start limit was given and it's not obviously an
 
533
    # ancestor of the end limit, check it before outputting anything
 
534
    if direction == 'forward' or (start_rev_id
 
535
        and not _is_obvious_ancestor(branch, start_rev_id, end_rev_id)):
 
536
        try:
 
537
            result = list(result)
 
538
        except _StartNotLinearAncestor:
 
539
            raise errors.BzrCommandError('Start revision not found in'
 
540
                ' left-hand history of end revision.')
 
541
    return result
 
542
 
 
543
 
 
544
def _generate_all_revisions(branch, start_rev_id, end_rev_id, direction,
 
545
                            delayed_graph_generation):
 
546
    # On large trees, generating the merge graph can take 30-60 seconds
 
547
    # so we delay doing it until a merge is detected, incrementally
 
548
    # returning initial (non-merge) revisions while we can.
 
549
 
 
550
    # The above is only true for old formats (<= 0.92), for newer formats, a
 
551
    # couple of seconds only should be needed to load the whole graph and the
 
552
    # other graph operations needed are even faster than that -- vila 100201
 
553
    initial_revisions = []
 
554
    if delayed_graph_generation:
 
555
        try:
 
556
            for rev_id, revno, depth in  _linear_view_revisions(
 
557
                branch, start_rev_id, end_rev_id):
 
558
                if _has_merges(branch, rev_id):
 
559
                    # The end_rev_id can be nested down somewhere. We need an
 
560
                    # explicit ancestry check. There is an ambiguity here as we
 
561
                    # may not raise _StartNotLinearAncestor for a revision that
 
562
                    # is an ancestor but not a *linear* one. But since we have
 
563
                    # loaded the graph to do the check (or calculate a dotted
 
564
                    # revno), we may as well accept to show the log...  We need
 
565
                    # the check only if start_rev_id is not None as all
 
566
                    # revisions have _mod_revision.NULL_REVISION as an ancestor
 
567
                    # -- vila 20100319
 
568
                    graph = branch.repository.get_graph()
 
569
                    if (start_rev_id is not None
 
570
                        and not graph.is_ancestor(start_rev_id, end_rev_id)):
 
571
                        raise _StartNotLinearAncestor()
 
572
                    # Since we collected the revisions so far, we need to
 
573
                    # adjust end_rev_id.
 
574
                    end_rev_id = rev_id
 
575
                    break
 
576
                else:
 
577
                    initial_revisions.append((rev_id, revno, depth))
 
578
            else:
 
579
                # No merged revisions found
 
580
                return initial_revisions
 
581
        except _StartNotLinearAncestor:
 
582
            # A merge was never detected so the lower revision limit can't
 
583
            # be nested down somewhere
 
584
            raise errors.BzrCommandError('Start revision not found in'
 
585
                ' history of end revision.')
 
586
 
 
587
    # We exit the loop above because we encounter a revision with merges, from
 
588
    # this revision, we need to switch to _graph_view_revisions.
 
589
 
 
590
    # A log including nested merges is required. If the direction is reverse,
 
591
    # we rebase the initial merge depths so that the development line is
 
592
    # shown naturally, i.e. just like it is for linear logging. We can easily
 
593
    # make forward the exact opposite display, but showing the merge revisions
 
594
    # indented at the end seems slightly nicer in that case.
 
595
    view_revisions = chain(iter(initial_revisions),
 
596
        _graph_view_revisions(branch, start_rev_id, end_rev_id,
 
597
                              rebase_initial_depths=(direction == 'reverse')))
 
598
    return view_revisions
 
599
 
 
600
 
 
601
def _has_merges(branch, rev_id):
 
602
    """Does a revision have multiple parents or not?"""
 
603
    parents = branch.repository.get_parent_map([rev_id]).get(rev_id, [])
 
604
    return len(parents) > 1
 
605
 
 
606
 
 
607
def _is_obvious_ancestor(branch, start_rev_id, end_rev_id):
 
608
    """Is start_rev_id an obvious ancestor of end_rev_id?"""
 
609
    if start_rev_id and end_rev_id:
 
610
        start_dotted = branch.revision_id_to_dotted_revno(start_rev_id)
 
611
        end_dotted = branch.revision_id_to_dotted_revno(end_rev_id)
 
612
        if len(start_dotted) == 1 and len(end_dotted) == 1:
 
613
            # both on mainline
 
614
            return start_dotted[0] <= end_dotted[0]
 
615
        elif (len(start_dotted) == 3 and len(end_dotted) == 3 and
 
616
            start_dotted[0:1] == end_dotted[0:1]):
 
617
            # both on same development line
 
618
            return start_dotted[2] <= end_dotted[2]
 
619
        else:
 
620
            # not obvious
 
621
            return False
 
622
    # if either start or end is not specified then we use either the first or
 
623
    # the last revision and *they* are obvious ancestors.
 
624
    return True
 
625
 
 
626
 
 
627
def _linear_view_revisions(branch, start_rev_id, end_rev_id):
 
628
    """Calculate a sequence of revisions to view, newest to oldest.
 
629
 
 
630
    :param start_rev_id: the lower revision-id
 
631
    :param end_rev_id: the upper revision-id
 
632
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
 
633
    :raises _StartNotLinearAncestor: if a start_rev_id is specified but
 
634
      is not found walking the left-hand history
 
635
    """
 
636
    br_revno, br_rev_id = branch.last_revision_info()
 
637
    repo = branch.repository
 
638
    if start_rev_id is None and end_rev_id is None:
 
639
        cur_revno = br_revno
 
640
        for revision_id in repo.iter_reverse_revision_history(br_rev_id):
 
641
            yield revision_id, str(cur_revno), 0
 
642
            cur_revno -= 1
 
643
    else:
 
644
        if end_rev_id is None:
 
645
            end_rev_id = br_rev_id
 
646
        found_start = start_rev_id is None
 
647
        for revision_id in repo.iter_reverse_revision_history(end_rev_id):
 
648
            revno = branch.revision_id_to_dotted_revno(revision_id)
 
649
            revno_str = '.'.join(str(n) for n in revno)
 
650
            if not found_start and revision_id == start_rev_id:
 
651
                yield revision_id, revno_str, 0
 
652
                found_start = True
 
653
                break
 
654
            else:
 
655
                yield revision_id, revno_str, 0
 
656
        else:
 
657
            if not found_start:
 
658
                raise _StartNotLinearAncestor()
 
659
 
 
660
 
 
661
def _graph_view_revisions(branch, start_rev_id, end_rev_id,
 
662
                          rebase_initial_depths=True):
 
663
    """Calculate revisions to view including merges, newest to oldest.
 
664
 
 
665
    :param branch: the branch
 
666
    :param start_rev_id: the lower revision-id
 
667
    :param end_rev_id: the upper revision-id
 
668
    :param rebase_initial_depth: should depths be rebased until a mainline
 
669
      revision is found?
 
670
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
 
671
    """
 
672
    view_revisions = branch.iter_merge_sorted_revisions(
 
673
        start_revision_id=end_rev_id, stop_revision_id=start_rev_id,
 
674
        stop_rule="with-merges")
 
675
    if not rebase_initial_depths:
 
676
        for (rev_id, merge_depth, revno, end_of_merge
 
677
             ) in view_revisions:
 
678
            yield rev_id, '.'.join(map(str, revno)), merge_depth
 
679
    else:
 
680
        # We're following a development line starting at a merged revision.
 
681
        # We need to adjust depths down by the initial depth until we find
 
682
        # a depth less than it. Then we use that depth as the adjustment.
 
683
        # If and when we reach the mainline, depth adjustment ends.
 
684
        depth_adjustment = None
 
685
        for (rev_id, merge_depth, revno, end_of_merge
 
686
             ) in view_revisions:
 
687
            if depth_adjustment is None:
 
688
                depth_adjustment = merge_depth
 
689
            if depth_adjustment:
 
690
                if merge_depth < depth_adjustment:
 
691
                    # From now on we reduce the depth adjustement, this can be
 
692
                    # surprising for users. The alternative requires two passes
 
693
                    # which breaks the fast display of the first revision
 
694
                    # though.
 
695
                    depth_adjustment = merge_depth
 
696
                merge_depth -= depth_adjustment
 
697
            yield rev_id, '.'.join(map(str, revno)), merge_depth
 
698
 
 
699
 
 
700
@deprecated_function(deprecated_in((2, 2, 0)))
236
701
def calculate_view_revisions(branch, start_revision, end_revision, direction,
237
 
                             specific_fileid, generate_merge_revisions,
238
 
                             allow_single_merge_revision):
239
 
    if (not generate_merge_revisions and start_revision is end_revision is
240
 
        None and direction == 'reverse' and specific_fileid is None):
241
 
        return _linear_view_revisions(branch)
242
 
 
243
 
    mainline_revs, rev_nos, start_rev_id, end_rev_id = \
244
 
        _get_mainline_revs(branch, start_revision, end_revision)
245
 
    if not mainline_revs:
246
 
        return []
247
 
 
248
 
    if direction == 'reverse':
249
 
        start_rev_id, end_rev_id = end_rev_id, start_rev_id
250
 
 
251
 
    generate_single_revision = False
252
 
    if ((not generate_merge_revisions)
253
 
        and ((start_rev_id and (start_rev_id not in rev_nos))
254
 
            or (end_rev_id and (end_rev_id not in rev_nos)))):
255
 
        generate_single_revision = ((start_rev_id == end_rev_id)
256
 
            and allow_single_merge_revision)
257
 
        if not generate_single_revision:
258
 
            raise errors.BzrCommandError('Selected log formatter only supports'
259
 
                ' mainline revisions.')
260
 
        generate_merge_revisions = generate_single_revision
261
 
    view_revs_iter = get_view_revisions(mainline_revs, rev_nos, branch,
262
 
                          direction, include_merges=generate_merge_revisions)
263
 
    view_revisions = _filter_revision_range(list(view_revs_iter),
264
 
                                            start_rev_id,
265
 
                                            end_rev_id)
266
 
    if view_revisions and generate_single_revision:
267
 
        view_revisions = view_revisions[0:1]
 
702
        specific_fileid, generate_merge_revisions):
 
703
    """Calculate the revisions to view.
 
704
 
 
705
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
 
706
             a list of the same tuples.
 
707
    """
 
708
    start_rev_id, end_rev_id = _get_revision_limits(branch, start_revision,
 
709
        end_revision)
 
710
    view_revisions = list(_calc_view_revisions(branch, start_rev_id, end_rev_id,
 
711
        direction, generate_merge_revisions or specific_fileid))
268
712
    if specific_fileid:
269
713
        view_revisions = _filter_revisions_touching_file_id(branch,
270
 
                                                         specific_fileid,
271
 
                                                         view_revisions,
272
 
                                                         direction)
273
 
 
274
 
    # rebase merge_depth - unless there are no revisions or 
275
 
    # either the first or last revision have merge_depth = 0.
 
714
            specific_fileid, view_revisions,
 
715
            include_merges=generate_merge_revisions)
 
716
    return _rebase_merge_depth(view_revisions)
 
717
 
 
718
 
 
719
def _rebase_merge_depth(view_revisions):
 
720
    """Adjust depths upwards so the top level is 0."""
 
721
    # If either the first or last revision have a merge_depth of 0, we're done
276
722
    if view_revisions and view_revisions[0][2] and view_revisions[-1][2]:
277
723
        min_depth = min([d for r,n,d in view_revisions])
278
724
        if min_depth != 0:
280
726
    return view_revisions
281
727
 
282
728
 
283
 
def _linear_view_revisions(branch):
284
 
    start_revno, start_revision_id = branch.last_revision_info()
285
 
    repo = branch.repository
286
 
    revision_ids = repo.iter_reverse_revision_history(start_revision_id)
287
 
    for num, revision_id in enumerate(revision_ids):
288
 
        yield revision_id, str(start_revno - num), 0
289
 
 
290
 
 
291
 
def make_log_rev_iterator(branch, view_revisions, generate_delta, search):
 
729
def make_log_rev_iterator(branch, view_revisions, generate_delta, search,
 
730
        file_ids=None, direction='reverse'):
292
731
    """Create a revision iterator for log.
293
732
 
294
733
    :param branch: The branch being logged.
295
734
    :param view_revisions: The revisions being viewed.
296
735
    :param generate_delta: Whether to generate a delta for each revision.
 
736
      Permitted values are None, 'full' and 'partial'.
297
737
    :param search: A user text search string.
 
738
    :param file_ids: If non empty, only revisions matching one or more of
 
739
      the file-ids are to be kept.
 
740
    :param direction: the direction in which view_revisions is sorted
298
741
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
299
742
        delta).
300
743
    """
311
754
                yield (view, None, None)
312
755
        log_rev_iterator = iter([_convert()])
313
756
    for adapter in log_adapters:
314
 
        log_rev_iterator = adapter(branch, generate_delta, search,
315
 
            log_rev_iterator)
 
757
        # It would be nicer if log adapters were first class objects
 
758
        # with custom parameters. This will do for now. IGC 20090127
 
759
        if adapter == _make_delta_filter:
 
760
            log_rev_iterator = adapter(branch, generate_delta,
 
761
                search, log_rev_iterator, file_ids, direction)
 
762
        else:
 
763
            log_rev_iterator = adapter(branch, generate_delta,
 
764
                search, log_rev_iterator)
316
765
    return log_rev_iterator
317
766
 
318
767
 
329
778
    """
330
779
    if search is None:
331
780
        return log_rev_iterator
332
 
    # Compile the search now to get early errors.
333
 
    searchRE = re.compile(search, re.IGNORECASE)
 
781
    searchRE = re_compile_checked(search, re.IGNORECASE,
 
782
            'log message filter')
334
783
    return _filter_message_re(searchRE, log_rev_iterator)
335
784
 
336
785
 
343
792
        yield new_revs
344
793
 
345
794
 
346
 
def _make_delta_filter(branch, generate_delta, search, log_rev_iterator):
 
795
def _make_delta_filter(branch, generate_delta, search, log_rev_iterator,
 
796
    fileids=None, direction='reverse'):
347
797
    """Add revision deltas to a log iterator if needed.
348
798
 
349
799
    :param branch: The branch being logged.
350
800
    :param generate_delta: Whether to generate a delta for each revision.
 
801
      Permitted values are None, 'full' and 'partial'.
351
802
    :param search: A user text search string.
352
803
    :param log_rev_iterator: An input iterator containing all revisions that
353
804
        could be displayed, in lists.
 
805
    :param fileids: If non empty, only revisions matching one or more of
 
806
      the file-ids are to be kept.
 
807
    :param direction: the direction in which view_revisions is sorted
354
808
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
355
809
        delta).
356
810
    """
357
 
    if not generate_delta:
 
811
    if not generate_delta and not fileids:
358
812
        return log_rev_iterator
359
 
    return _generate_deltas(branch.repository, log_rev_iterator)
360
 
 
361
 
 
362
 
def _generate_deltas(repository, log_rev_iterator):
363
 
    """Create deltas for each batch of revisions in log_rev_iterator."""
 
813
    return _generate_deltas(branch.repository, log_rev_iterator,
 
814
        generate_delta, fileids, direction)
 
815
 
 
816
 
 
817
def _generate_deltas(repository, log_rev_iterator, delta_type, fileids,
 
818
    direction):
 
819
    """Create deltas for each batch of revisions in log_rev_iterator.
 
820
 
 
821
    If we're only generating deltas for the sake of filtering against
 
822
    file-ids, we stop generating deltas once all file-ids reach the
 
823
    appropriate life-cycle point. If we're receiving data newest to
 
824
    oldest, then that life-cycle point is 'add', otherwise it's 'remove'.
 
825
    """
 
826
    check_fileids = fileids is not None and len(fileids) > 0
 
827
    if check_fileids:
 
828
        fileid_set = set(fileids)
 
829
        if direction == 'reverse':
 
830
            stop_on = 'add'
 
831
        else:
 
832
            stop_on = 'remove'
 
833
    else:
 
834
        fileid_set = None
364
835
    for revs in log_rev_iterator:
 
836
        # If we were matching against fileids and we've run out,
 
837
        # there's nothing left to do
 
838
        if check_fileids and not fileid_set:
 
839
            return
365
840
        revisions = [rev[1] for rev in revs]
366
 
        deltas = repository.get_deltas_for_revisions(revisions)
367
 
        revs = [(rev[0], rev[1], delta) for rev, delta in izip(revs, deltas)]
368
 
        yield revs
 
841
        new_revs = []
 
842
        if delta_type == 'full' and not check_fileids:
 
843
            deltas = repository.get_deltas_for_revisions(revisions)
 
844
            for rev, delta in izip(revs, deltas):
 
845
                new_revs.append((rev[0], rev[1], delta))
 
846
        else:
 
847
            deltas = repository.get_deltas_for_revisions(revisions, fileid_set)
 
848
            for rev, delta in izip(revs, deltas):
 
849
                if check_fileids:
 
850
                    if delta is None or not delta.has_changed():
 
851
                        continue
 
852
                    else:
 
853
                        _update_fileids(delta, fileid_set, stop_on)
 
854
                        if delta_type is None:
 
855
                            delta = None
 
856
                        elif delta_type == 'full':
 
857
                            # If the file matches all the time, rebuilding
 
858
                            # a full delta like this in addition to a partial
 
859
                            # one could be slow. However, it's likely that
 
860
                            # most revisions won't get this far, making it
 
861
                            # faster to filter on the partial deltas and
 
862
                            # build the occasional full delta than always
 
863
                            # building full deltas and filtering those.
 
864
                            rev_id = rev[0][0]
 
865
                            delta = repository.get_revision_delta(rev_id)
 
866
                new_revs.append((rev[0], rev[1], delta))
 
867
        yield new_revs
 
868
 
 
869
 
 
870
def _update_fileids(delta, fileids, stop_on):
 
871
    """Update the set of file-ids to search based on file lifecycle events.
 
872
    
 
873
    :param fileids: a set of fileids to update
 
874
    :param stop_on: either 'add' or 'remove' - take file-ids out of the
 
875
      fileids set once their add or remove entry is detected respectively
 
876
    """
 
877
    if stop_on == 'add':
 
878
        for item in delta.added:
 
879
            if item[1] in fileids:
 
880
                fileids.remove(item[1])
 
881
    elif stop_on == 'delete':
 
882
        for item in delta.removed:
 
883
            if item[1] in fileids:
 
884
                fileids.remove(item[1])
369
885
 
370
886
 
371
887
def _make_revision_objects(branch, generate_delta, search, log_rev_iterator):
397
913
    :param search: A user text search string.
398
914
    :param log_rev_iterator: An input iterator containing all revisions that
399
915
        could be displayed, in lists.
400
 
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev, delta).
 
916
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
 
917
        delta).
401
918
    """
402
919
    repository = branch.repository
403
920
    num = 9
411
928
            num = min(int(num * 1.5), 200)
412
929
 
413
930
 
 
931
def _get_revision_limits(branch, start_revision, end_revision):
 
932
    """Get and check revision limits.
 
933
 
 
934
    :param  branch: The branch containing the revisions.
 
935
 
 
936
    :param  start_revision: The first revision to be logged.
 
937
            For backwards compatibility this may be a mainline integer revno,
 
938
            but for merge revision support a RevisionInfo is expected.
 
939
 
 
940
    :param  end_revision: The last revision to be logged.
 
941
            For backwards compatibility this may be a mainline integer revno,
 
942
            but for merge revision support a RevisionInfo is expected.
 
943
 
 
944
    :return: (start_rev_id, end_rev_id) tuple.
 
945
    """
 
946
    branch_revno, branch_rev_id = branch.last_revision_info()
 
947
    start_rev_id = None
 
948
    if start_revision is None:
 
949
        start_revno = 1
 
950
    else:
 
951
        if isinstance(start_revision, revisionspec.RevisionInfo):
 
952
            start_rev_id = start_revision.rev_id
 
953
            start_revno = start_revision.revno or 1
 
954
        else:
 
955
            branch.check_real_revno(start_revision)
 
956
            start_revno = start_revision
 
957
            start_rev_id = branch.get_rev_id(start_revno)
 
958
 
 
959
    end_rev_id = None
 
960
    if end_revision is None:
 
961
        end_revno = branch_revno
 
962
    else:
 
963
        if isinstance(end_revision, revisionspec.RevisionInfo):
 
964
            end_rev_id = end_revision.rev_id
 
965
            end_revno = end_revision.revno or branch_revno
 
966
        else:
 
967
            branch.check_real_revno(end_revision)
 
968
            end_revno = end_revision
 
969
            end_rev_id = branch.get_rev_id(end_revno)
 
970
 
 
971
    if branch_revno != 0:
 
972
        if (start_rev_id == _mod_revision.NULL_REVISION
 
973
            or end_rev_id == _mod_revision.NULL_REVISION):
 
974
            raise errors.BzrCommandError('Logging revision 0 is invalid.')
 
975
        if start_revno > end_revno:
 
976
            raise errors.BzrCommandError("Start revision must be older than "
 
977
                                         "the end revision.")
 
978
    return (start_rev_id, end_rev_id)
 
979
 
 
980
 
414
981
def _get_mainline_revs(branch, start_revision, end_revision):
415
982
    """Get the mainline revisions from the branch.
416
 
    
 
983
 
417
984
    Generates the list of mainline revisions for the branch.
418
 
    
419
 
    :param  branch: The branch containing the revisions. 
 
985
 
 
986
    :param  branch: The branch containing the revisions.
420
987
 
421
988
    :param  start_revision: The first revision to be logged.
422
989
            For backwards compatibility this may be a mainline integer revno,
432
999
    if branch_revno == 0:
433
1000
        return None, None, None, None
434
1001
 
435
 
    # For mainline generation, map start_revision and end_revision to 
436
 
    # mainline revnos. If the revision is not on the mainline choose the 
437
 
    # appropriate extreme of the mainline instead - the extra will be 
 
1002
    # For mainline generation, map start_revision and end_revision to
 
1003
    # mainline revnos. If the revision is not on the mainline choose the
 
1004
    # appropriate extreme of the mainline instead - the extra will be
438
1005
    # filtered later.
439
1006
    # Also map the revisions to rev_ids, to be used in the later filtering
440
1007
    # stage.
441
 
    start_rev_id = None 
 
1008
    start_rev_id = None
442
1009
    if start_revision is None:
443
1010
        start_revno = 1
444
1011
    else:
448
1015
        else:
449
1016
            branch.check_real_revno(start_revision)
450
1017
            start_revno = start_revision
451
 
    
 
1018
 
452
1019
    end_rev_id = None
453
1020
    if end_revision is None:
454
1021
        end_revno = branch_revno
493
1060
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
494
1061
 
495
1062
 
 
1063
@deprecated_function(deprecated_in((2, 2, 0)))
496
1064
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
497
1065
    """Filter view_revisions based on revision ranges.
498
1066
 
499
 
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth) 
 
1067
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth)
500
1068
            tuples to be filtered.
501
1069
 
502
1070
    :param start_rev_id: If not NONE specifies the first revision to be logged.
507
1075
 
508
1076
    :return: The filtered view_revisions.
509
1077
    """
510
 
    if start_rev_id or end_rev_id: 
 
1078
    if start_rev_id or end_rev_id:
511
1079
        revision_ids = [r for r, n, d in view_revisions]
512
1080
        if start_rev_id:
513
1081
            start_index = revision_ids.index(start_rev_id)
520
1088
                end_index = revision_ids.index(end_rev_id)
521
1089
            else:
522
1090
                end_index = len(view_revisions) - 1
523
 
        # To include the revisions merged into the last revision, 
 
1091
        # To include the revisions merged into the last revision,
524
1092
        # extend end_rev_id down to, but not including, the next rev
525
1093
        # with the same or lesser merge_depth
526
1094
        end_merge_depth = view_revisions[end_index][2]
537
1105
 
538
1106
 
539
1107
def _filter_revisions_touching_file_id(branch, file_id, view_revisions,
540
 
                                       direction):
 
1108
    include_merges=True):
541
1109
    r"""Return the list of revision ids which touch a given file id.
542
1110
 
543
1111
    The function filters view_revisions and returns a subset.
562
1130
    This will also be restricted based on a subset of the mainline.
563
1131
 
564
1132
    :param branch: The branch where we can get text revision information.
 
1133
 
565
1134
    :param file_id: Filter out revisions that do not touch file_id.
 
1135
 
566
1136
    :param view_revisions: A list of (revision_id, dotted_revno, merge_depth)
567
1137
        tuples. This is the list of revisions which will be filtered. It is
568
 
        assumed that view_revisions is in merge_sort order (either forward or
569
 
        reverse).
570
 
    :param direction: The direction of view_revisions.  See also
571
 
        reverse_by_depth, and get_view_revisions
 
1138
        assumed that view_revisions is in merge_sort order (i.e. newest
 
1139
        revision first ).
 
1140
 
 
1141
    :param include_merges: include merge revisions in the result or not
 
1142
 
572
1143
    :return: A list of (revision_id, dotted_revno, merge_depth) tuples.
573
1144
    """
574
1145
    # Lookup all possible text keys to determine which ones actually modified
575
1146
    # the file.
576
1147
    text_keys = [(file_id, rev_id) for rev_id, revno, depth in view_revisions]
 
1148
    next_keys = None
577
1149
    # Looking up keys in batches of 1000 can cut the time in half, as well as
578
1150
    # memory consumption. GraphIndex *does* like to look for a few keys in
579
1151
    # parallel, it just doesn't like looking for *lots* of keys in parallel.
592
1164
    del text_keys, next_keys
593
1165
 
594
1166
    result = []
595
 
    if direction == 'forward':
596
 
        # TODO: The algorithm for finding 'merges' of file changes expects
597
 
        #       'reverse' order (the default from 'merge_sort()'). Instead of
598
 
        #       forcing this, we could just use the reverse_by_depth order.
599
 
        view_revisions = reverse_by_depth(view_revisions)
600
1167
    # Track what revisions will merge the current revision, replace entries
601
1168
    # with 'None' when they have been added to result
602
1169
    current_merge_stack = [None]
613
1180
            for idx in xrange(len(current_merge_stack)):
614
1181
                node = current_merge_stack[idx]
615
1182
                if node is not None:
616
 
                    result.append(node)
617
 
                    current_merge_stack[idx] = None
618
 
    if direction == 'forward':
619
 
        result = reverse_by_depth(result)
 
1183
                    if include_merges or node[2] == 0:
 
1184
                        result.append(node)
 
1185
                        current_merge_stack[idx] = None
620
1186
    return result
621
1187
 
622
1188
 
 
1189
@deprecated_function(deprecated_in((2, 2, 0)))
623
1190
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
624
1191
                       include_merges=True):
625
1192
    """Produce an iterator of revisions to show
626
1193
    :return: an iterator of (revision_id, revno, merge_depth)
627
1194
    (if there is no revno for a revision, None is supplied)
628
1195
    """
629
 
    if include_merges is False:
 
1196
    if not include_merges:
630
1197
        revision_ids = mainline_revs[1:]
631
1198
        if direction == 'reverse':
632
1199
            revision_ids.reverse()
655
1222
    elif direction != 'reverse':
656
1223
        raise ValueError('invalid direction %r' % direction)
657
1224
 
658
 
    for sequence, rev_id, merge_depth, revno, end_of_merge in merge_sorted_revisions:
 
1225
    for (sequence, rev_id, merge_depth, revno, end_of_merge
 
1226
         ) in merge_sorted_revisions:
659
1227
        yield rev_id, '.'.join(map(str, revno)), merge_depth
660
1228
 
661
1229
 
666
1234
    revision of that depth.  There may be no topological justification for this,
667
1235
    but it looks much nicer.
668
1236
    """
 
1237
    # Add a fake revision at start so that we can always attach sub revisions
 
1238
    merge_sorted_revisions = [(None, None, _depth)] + merge_sorted_revisions
669
1239
    zd_revisions = []
670
1240
    for val in merge_sorted_revisions:
671
1241
        if val[2] == _depth:
 
1242
            # Each revision at the current depth becomes a chunk grouping all
 
1243
            # higher depth revisions.
672
1244
            zd_revisions.append([val])
673
1245
        else:
674
1246
            zd_revisions[-1].append(val)
675
1247
    for revisions in zd_revisions:
676
1248
        if len(revisions) > 1:
 
1249
            # We have higher depth revisions, let reverse them locally
677
1250
            revisions[1:] = reverse_by_depth(revisions[1:], _depth + 1)
678
1251
    zd_revisions.reverse()
679
1252
    result = []
680
1253
    for chunk in zd_revisions:
681
1254
        result.extend(chunk)
 
1255
    if _depth == 0:
 
1256
        # Top level call, get rid of the fake revisions that have been added
 
1257
        result = [r for r in result if r[0] is not None and r[1] is not None]
682
1258
    return result
683
1259
 
684
1260
 
686
1262
    """A revision to be logged (by LogFormatter.log_revision).
687
1263
 
688
1264
    A simple wrapper for the attributes of a revision to be logged.
689
 
    The attributes may or may not be populated, as determined by the 
 
1265
    The attributes may or may not be populated, as determined by the
690
1266
    logging options and the log formatter capabilities.
691
1267
    """
692
1268
 
693
1269
    def __init__(self, rev=None, revno=None, merge_depth=0, delta=None,
694
 
                 tags=None):
 
1270
                 tags=None, diff=None):
695
1271
        self.rev = rev
696
 
        self.revno = revno
 
1272
        self.revno = str(revno)
697
1273
        self.merge_depth = merge_depth
698
1274
        self.delta = delta
699
1275
        self.tags = tags
 
1276
        self.diff = diff
700
1277
 
701
1278
 
702
1279
class LogFormatter(object):
707
1284
    If the LogFormatter needs to be informed of the beginning or end of
708
1285
    a log it should implement the begin_log and/or end_log hook methods.
709
1286
 
710
 
    A LogFormatter should define the following supports_XXX flags 
 
1287
    A LogFormatter should define the following supports_XXX flags
711
1288
    to indicate which LogRevision attributes it supports:
712
1289
 
713
1290
    - supports_delta must be True if this log formatter supports delta.
714
 
        Otherwise the delta attribute may not be populated.
715
 
    - supports_merge_revisions must be True if this log formatter supports 
716
 
        merge revisions.  If not, and if supports_single_merge_revisions is
717
 
        also not True, then only mainline revisions will be passed to the 
718
 
        formatter.
719
 
    - supports_single_merge_revision must be True if this log formatter
720
 
        supports logging only a single merge revision.  This flag is
721
 
        only relevant if supports_merge_revisions is not True.
 
1291
        Otherwise the delta attribute may not be populated.  The 'delta_format'
 
1292
        attribute describes whether the 'short_status' format (1) or the long
 
1293
        one (2) should be used.
 
1294
 
 
1295
    - supports_merge_revisions must be True if this log formatter supports
 
1296
        merge revisions.  If not, then only mainline revisions will be passed
 
1297
        to the formatter.
 
1298
 
 
1299
    - preferred_levels is the number of levels this formatter defaults to.
 
1300
        The default value is zero meaning display all levels.
 
1301
        This value is only relevant if supports_merge_revisions is True.
 
1302
 
722
1303
    - supports_tags must be True if this log formatter supports tags.
723
1304
        Otherwise the tags attribute may not be populated.
724
1305
 
 
1306
    - supports_diff must be True if this log formatter supports diffs.
 
1307
        Otherwise the diff attribute may not be populated.
 
1308
 
725
1309
    Plugins can register functions to show custom revision properties using
726
1310
    the properties_handler_registry. The registered function
727
1311
    must respect the following interface description:
728
1312
        def my_show_properties(properties_dict):
729
 
            # code that returns a dict {'name':'value'} of the properties 
 
1313
            # code that returns a dict {'name':'value'} of the properties
730
1314
            # to be shown
731
1315
    """
732
 
 
733
 
    def __init__(self, to_file, show_ids=False, show_timezone='original'):
 
1316
    preferred_levels = 0
 
1317
 
 
1318
    def __init__(self, to_file, show_ids=False, show_timezone='original',
 
1319
                 delta_format=None, levels=None, show_advice=False,
 
1320
                 to_exact_file=None):
 
1321
        """Create a LogFormatter.
 
1322
 
 
1323
        :param to_file: the file to output to
 
1324
        :param to_exact_file: if set, gives an output stream to which 
 
1325
             non-Unicode diffs are written.
 
1326
        :param show_ids: if True, revision-ids are to be displayed
 
1327
        :param show_timezone: the timezone to use
 
1328
        :param delta_format: the level of delta information to display
 
1329
          or None to leave it to the formatter to decide
 
1330
        :param levels: the number of levels to display; None or -1 to
 
1331
          let the log formatter decide.
 
1332
        :param show_advice: whether to show advice at the end of the
 
1333
          log or not
 
1334
        """
734
1335
        self.to_file = to_file
 
1336
        # 'exact' stream used to show diff, it should print content 'as is'
 
1337
        # and should not try to decode/encode it to unicode to avoid bug #328007
 
1338
        if to_exact_file is not None:
 
1339
            self.to_exact_file = to_exact_file
 
1340
        else:
 
1341
            # XXX: somewhat hacky; this assumes it's a codec writer; it's better
 
1342
            # for code that expects to get diffs to pass in the exact file
 
1343
            # stream
 
1344
            self.to_exact_file = getattr(to_file, 'stream', to_file)
735
1345
        self.show_ids = show_ids
736
1346
        self.show_timezone = show_timezone
737
 
 
738
 
# TODO: uncomment this block after show() has been removed.
739
 
# Until then defining log_revision would prevent _show_log calling show() 
740
 
# in legacy formatters.
741
 
#    def log_revision(self, revision):
742
 
#        """Log a revision.
743
 
#
744
 
#        :param  revision:   The LogRevision to be logged.
745
 
#        """
746
 
#        raise NotImplementedError('not implemented in abstract base')
 
1347
        if delta_format is None:
 
1348
            # Ensures backward compatibility
 
1349
            delta_format = 2 # long format
 
1350
        self.delta_format = delta_format
 
1351
        self.levels = levels
 
1352
        self._show_advice = show_advice
 
1353
        self._merge_count = 0
 
1354
 
 
1355
    def get_levels(self):
 
1356
        """Get the number of levels to display or 0 for all."""
 
1357
        if getattr(self, 'supports_merge_revisions', False):
 
1358
            if self.levels is None or self.levels == -1:
 
1359
                self.levels = self.preferred_levels
 
1360
        else:
 
1361
            self.levels = 1
 
1362
        return self.levels
 
1363
 
 
1364
    def log_revision(self, revision):
 
1365
        """Log a revision.
 
1366
 
 
1367
        :param  revision:   The LogRevision to be logged.
 
1368
        """
 
1369
        raise NotImplementedError('not implemented in abstract base')
 
1370
 
 
1371
    def show_advice(self):
 
1372
        """Output user advice, if any, when the log is completed."""
 
1373
        if self._show_advice and self.levels == 1 and self._merge_count > 0:
 
1374
            advice_sep = self.get_advice_separator()
 
1375
            if advice_sep:
 
1376
                self.to_file.write(advice_sep)
 
1377
            self.to_file.write(
 
1378
                "Use --include-merges or -n0 to see merged revisions.\n")
 
1379
 
 
1380
    def get_advice_separator(self):
 
1381
        """Get the text separating the log from the closing advice."""
 
1382
        return ''
747
1383
 
748
1384
    def short_committer(self, rev):
749
1385
        name, address = config.parse_username(rev.committer)
752
1388
        return address
753
1389
 
754
1390
    def short_author(self, rev):
755
 
        name, address = config.parse_username(rev.get_apparent_author())
 
1391
        name, address = config.parse_username(rev.get_apparent_authors()[0])
756
1392
        if name:
757
1393
            return name
758
1394
        return address
759
1395
 
 
1396
    def merge_marker(self, revision):
 
1397
        """Get the merge marker to include in the output or '' if none."""
 
1398
        if len(revision.rev.parent_ids) > 1:
 
1399
            self._merge_count += 1
 
1400
            return ' [merge]'
 
1401
        else:
 
1402
            return ''
 
1403
 
760
1404
    def show_properties(self, revision, indent):
761
1405
        """Displays the custom properties returned by each registered handler.
762
 
        
763
 
        If a registered handler raises an error it is propagated.
764
 
        """
 
1406
 
 
1407
        If a registered handler raises an error it is propagated.
 
1408
        """
 
1409
        for line in self.custom_properties(revision):
 
1410
            self.to_file.write("%s%s\n" % (indent, line))
 
1411
 
 
1412
    def custom_properties(self, revision):
 
1413
        """Format the custom properties returned by each registered handler.
 
1414
 
 
1415
        If a registered handler raises an error it is propagated.
 
1416
 
 
1417
        :return: a list of formatted lines (excluding trailing newlines)
 
1418
        """
 
1419
        lines = self._foreign_info_properties(revision)
765
1420
        for key, handler in properties_handler_registry.iteritems():
766
 
            for key, value in handler(revision).items():
767
 
                self.to_file.write(indent + key + ': ' + value + '\n')
 
1421
            lines.extend(self._format_properties(handler(revision)))
 
1422
        return lines
 
1423
 
 
1424
    def _foreign_info_properties(self, rev):
 
1425
        """Custom log displayer for foreign revision identifiers.
 
1426
 
 
1427
        :param rev: Revision object.
 
1428
        """
 
1429
        # Revision comes directly from a foreign repository
 
1430
        if isinstance(rev, foreign.ForeignRevision):
 
1431
            return self._format_properties(
 
1432
                rev.mapping.vcs.show_foreign_revid(rev.foreign_revid))
 
1433
 
 
1434
        # Imported foreign revision revision ids always contain :
 
1435
        if not ":" in rev.revision_id:
 
1436
            return []
 
1437
 
 
1438
        # Revision was once imported from a foreign repository
 
1439
        try:
 
1440
            foreign_revid, mapping = \
 
1441
                foreign.foreign_vcs_registry.parse_revision_id(rev.revision_id)
 
1442
        except errors.InvalidRevisionId:
 
1443
            return []
 
1444
 
 
1445
        return self._format_properties(
 
1446
            mapping.vcs.show_foreign_revid(foreign_revid))
 
1447
 
 
1448
    def _format_properties(self, properties):
 
1449
        lines = []
 
1450
        for key, value in properties.items():
 
1451
            lines.append(key + ': ' + value)
 
1452
        return lines
 
1453
 
 
1454
    def show_diff(self, to_file, diff, indent):
 
1455
        for l in diff.rstrip().split('\n'):
 
1456
            to_file.write(indent + '%s\n' % (l,))
 
1457
 
 
1458
 
 
1459
# Separator between revisions in long format
 
1460
_LONG_SEP = '-' * 60
768
1461
 
769
1462
 
770
1463
class LongLogFormatter(LogFormatter):
771
1464
 
772
1465
    supports_merge_revisions = True
 
1466
    preferred_levels = 1
773
1467
    supports_delta = True
774
1468
    supports_tags = True
 
1469
    supports_diff = True
 
1470
 
 
1471
    def __init__(self, *args, **kwargs):
 
1472
        super(LongLogFormatter, self).__init__(*args, **kwargs)
 
1473
        if self.show_timezone == 'original':
 
1474
            self.date_string = self._date_string_original_timezone
 
1475
        else:
 
1476
            self.date_string = self._date_string_with_timezone
 
1477
 
 
1478
    def _date_string_with_timezone(self, rev):
 
1479
        return format_date(rev.timestamp, rev.timezone or 0,
 
1480
                           self.show_timezone)
 
1481
 
 
1482
    def _date_string_original_timezone(self, rev):
 
1483
        return format_date_with_offset_in_original_timezone(rev.timestamp,
 
1484
            rev.timezone or 0)
775
1485
 
776
1486
    def log_revision(self, revision):
777
1487
        """Log a revision, either merged or not."""
778
1488
        indent = '    ' * revision.merge_depth
779
 
        to_file = self.to_file
780
 
        to_file.write(indent + '-' * 60 + '\n')
 
1489
        lines = [_LONG_SEP]
781
1490
        if revision.revno is not None:
782
 
            to_file.write(indent + 'revno: %s\n' % (revision.revno,))
 
1491
            lines.append('revno: %s%s' % (revision.revno,
 
1492
                self.merge_marker(revision)))
783
1493
        if revision.tags:
784
 
            to_file.write(indent + 'tags: %s\n' % (', '.join(revision.tags)))
 
1494
            lines.append('tags: %s' % (', '.join(revision.tags)))
785
1495
        if self.show_ids:
786
 
            to_file.write(indent + 'revision-id: ' + revision.rev.revision_id)
787
 
            to_file.write('\n')
 
1496
            lines.append('revision-id: %s' % (revision.rev.revision_id,))
788
1497
            for parent_id in revision.rev.parent_ids:
789
 
                to_file.write(indent + 'parent: %s\n' % (parent_id,))
790
 
        self.show_properties(revision.rev, indent)
 
1498
                lines.append('parent: %s' % (parent_id,))
 
1499
        lines.extend(self.custom_properties(revision.rev))
791
1500
 
792
 
        author = revision.rev.properties.get('author', None)
793
 
        if author is not None:
794
 
            to_file.write(indent + 'author: %s\n' % (author,))
795
 
        to_file.write(indent + 'committer: %s\n' % (revision.rev.committer,))
 
1501
        committer = revision.rev.committer
 
1502
        authors = revision.rev.get_apparent_authors()
 
1503
        if authors != [committer]:
 
1504
            lines.append('author: %s' % (", ".join(authors),))
 
1505
        lines.append('committer: %s' % (committer,))
796
1506
 
797
1507
        branch_nick = revision.rev.properties.get('branch-nick', None)
798
1508
        if branch_nick is not None:
799
 
            to_file.write(indent + 'branch nick: %s\n' % (branch_nick,))
800
 
 
801
 
        date_str = format_date(revision.rev.timestamp,
802
 
                               revision.rev.timezone or 0,
803
 
                               self.show_timezone)
804
 
        to_file.write(indent + 'timestamp: %s\n' % (date_str,))
805
 
 
806
 
        to_file.write(indent + 'message:\n')
 
1509
            lines.append('branch nick: %s' % (branch_nick,))
 
1510
 
 
1511
        lines.append('timestamp: %s' % (self.date_string(revision.rev),))
 
1512
 
 
1513
        lines.append('message:')
807
1514
        if not revision.rev.message:
808
 
            to_file.write(indent + '  (no message)\n')
 
1515
            lines.append('  (no message)')
809
1516
        else:
810
1517
            message = revision.rev.message.rstrip('\r\n')
811
1518
            for l in message.split('\n'):
812
 
                to_file.write(indent + '  %s\n' % (l,))
 
1519
                lines.append('  %s' % (l,))
 
1520
 
 
1521
        # Dump the output, appending the delta and diff if requested
 
1522
        to_file = self.to_file
 
1523
        to_file.write("%s%s\n" % (indent, ('\n' + indent).join(lines)))
813
1524
        if revision.delta is not None:
814
 
            revision.delta.show(to_file, self.show_ids, indent=indent)
 
1525
            # Use the standard status output to display changes
 
1526
            from bzrlib.delta import report_delta
 
1527
            report_delta(to_file, revision.delta, short_status=False, 
 
1528
                         show_ids=self.show_ids, indent=indent)
 
1529
        if revision.diff is not None:
 
1530
            to_file.write(indent + 'diff:\n')
 
1531
            to_file.flush()
 
1532
            # Note: we explicitly don't indent the diff (relative to the
 
1533
            # revision information) so that the output can be fed to patch -p0
 
1534
            self.show_diff(self.to_exact_file, revision.diff, indent)
 
1535
            self.to_exact_file.flush()
 
1536
 
 
1537
    def get_advice_separator(self):
 
1538
        """Get the text separating the log from the closing advice."""
 
1539
        return '-' * 60 + '\n'
815
1540
 
816
1541
 
817
1542
class ShortLogFormatter(LogFormatter):
818
1543
 
 
1544
    supports_merge_revisions = True
 
1545
    preferred_levels = 1
819
1546
    supports_delta = True
820
 
    supports_single_merge_revision = True
 
1547
    supports_tags = True
 
1548
    supports_diff = True
 
1549
 
 
1550
    def __init__(self, *args, **kwargs):
 
1551
        super(ShortLogFormatter, self).__init__(*args, **kwargs)
 
1552
        self.revno_width_by_depth = {}
821
1553
 
822
1554
    def log_revision(self, revision):
 
1555
        # We need two indents: one per depth and one for the information
 
1556
        # relative to that indent. Most mainline revnos are 5 chars or
 
1557
        # less while dotted revnos are typically 11 chars or less. Once
 
1558
        # calculated, we need to remember the offset for a given depth
 
1559
        # as we might be starting from a dotted revno in the first column
 
1560
        # and we want subsequent mainline revisions to line up.
 
1561
        depth = revision.merge_depth
 
1562
        indent = '    ' * depth
 
1563
        revno_width = self.revno_width_by_depth.get(depth)
 
1564
        if revno_width is None:
 
1565
            if revision.revno.find('.') == -1:
 
1566
                # mainline revno, e.g. 12345
 
1567
                revno_width = 5
 
1568
            else:
 
1569
                # dotted revno, e.g. 12345.10.55
 
1570
                revno_width = 11
 
1571
            self.revno_width_by_depth[depth] = revno_width
 
1572
        offset = ' ' * (revno_width + 1)
 
1573
 
823
1574
        to_file = self.to_file
824
 
        is_merge = ''
825
 
        if len(revision.rev.parent_ids) > 1:
826
 
            is_merge = ' [merge]'
827
 
        to_file.write("%5s %s\t%s%s\n" % (revision.revno,
828
 
                self.short_author(revision.rev),
 
1575
        tags = ''
 
1576
        if revision.tags:
 
1577
            tags = ' {%s}' % (', '.join(revision.tags))
 
1578
        to_file.write(indent + "%*s %s\t%s%s%s\n" % (revno_width,
 
1579
                revision.revno, self.short_author(revision.rev),
829
1580
                format_date(revision.rev.timestamp,
830
1581
                            revision.rev.timezone or 0,
831
1582
                            self.show_timezone, date_fmt="%Y-%m-%d",
832
1583
                            show_offset=False),
833
 
                is_merge))
 
1584
                tags, self.merge_marker(revision)))
 
1585
        self.show_properties(revision.rev, indent+offset)
834
1586
        if self.show_ids:
835
 
            to_file.write('      revision-id:%s\n' % (revision.rev.revision_id,))
 
1587
            to_file.write(indent + offset + 'revision-id:%s\n'
 
1588
                          % (revision.rev.revision_id,))
836
1589
        if not revision.rev.message:
837
 
            to_file.write('      (no message)\n')
 
1590
            to_file.write(indent + offset + '(no message)\n')
838
1591
        else:
839
1592
            message = revision.rev.message.rstrip('\r\n')
840
1593
            for l in message.split('\n'):
841
 
                to_file.write('      %s\n' % (l,))
 
1594
                to_file.write(indent + offset + '%s\n' % (l,))
842
1595
 
843
 
        # TODO: Why not show the modified files in a shorter form as
844
 
        # well? rewrap them single lines of appropriate length
845
1596
        if revision.delta is not None:
846
 
            revision.delta.show(to_file, self.show_ids)
 
1597
            # Use the standard status output to display changes
 
1598
            from bzrlib.delta import report_delta
 
1599
            report_delta(to_file, revision.delta, 
 
1600
                         short_status=self.delta_format==1, 
 
1601
                         show_ids=self.show_ids, indent=indent + offset)
 
1602
        if revision.diff is not None:
 
1603
            self.show_diff(self.to_exact_file, revision.diff, '      ')
847
1604
        to_file.write('\n')
848
1605
 
849
1606
 
850
1607
class LineLogFormatter(LogFormatter):
851
1608
 
852
 
    supports_single_merge_revision = True
 
1609
    supports_merge_revisions = True
 
1610
    preferred_levels = 1
 
1611
    supports_tags = True
853
1612
 
854
1613
    def __init__(self, *args, **kwargs):
855
1614
        super(LineLogFormatter, self).__init__(*args, **kwargs)
856
 
        self._max_chars = terminal_width() - 1
 
1615
        width = terminal_width()
 
1616
        if width is not None:
 
1617
            # we need one extra space for terminals that wrap on last char
 
1618
            width = width - 1
 
1619
        self._max_chars = width
857
1620
 
858
1621
    def truncate(self, str, max_len):
859
 
        if len(str) <= max_len:
 
1622
        if max_len is None or len(str) <= max_len:
860
1623
            return str
861
 
        return str[:max_len-3]+'...'
 
1624
        return str[:max_len-3] + '...'
862
1625
 
863
1626
    def date_string(self, rev):
864
 
        return format_date(rev.timestamp, rev.timezone or 0, 
 
1627
        return format_date(rev.timestamp, rev.timezone or 0,
865
1628
                           self.show_timezone, date_fmt="%Y-%m-%d",
866
1629
                           show_offset=False)
867
1630
 
872
1635
            return rev.message
873
1636
 
874
1637
    def log_revision(self, revision):
 
1638
        indent = '  ' * revision.merge_depth
875
1639
        self.to_file.write(self.log_string(revision.revno, revision.rev,
876
 
                                              self._max_chars))
 
1640
            self._max_chars, revision.tags, indent))
877
1641
        self.to_file.write('\n')
878
1642
 
879
 
    def log_string(self, revno, rev, max_chars):
 
1643
    def log_string(self, revno, rev, max_chars, tags=None, prefix=''):
880
1644
        """Format log info into one string. Truncate tail of string
881
1645
        :param  revno:      revision number or None.
882
1646
                            Revision numbers counts from 1.
883
 
        :param  rev:        revision info object
 
1647
        :param  rev:        revision object
884
1648
        :param  max_chars:  maximum length of resulting string
 
1649
        :param  tags:       list of tags or None
 
1650
        :param  prefix:     string to prefix each line
885
1651
        :return:            formatted truncated string
886
1652
        """
887
1653
        out = []
890
1656
            out.append("%s:" % revno)
891
1657
        out.append(self.truncate(self.short_author(rev), 20))
892
1658
        out.append(self.date_string(rev))
 
1659
        if len(rev.parent_ids) > 1:
 
1660
            out.append('[merge]')
 
1661
        if tags:
 
1662
            tag_str = '{%s}' % (', '.join(tags))
 
1663
            out.append(tag_str)
893
1664
        out.append(rev.get_summary())
894
 
        return self.truncate(" ".join(out).rstrip('\n'), max_chars)
 
1665
        return self.truncate(prefix + " ".join(out).rstrip('\n'), max_chars)
 
1666
 
 
1667
 
 
1668
class GnuChangelogLogFormatter(LogFormatter):
 
1669
 
 
1670
    supports_merge_revisions = True
 
1671
    supports_delta = True
 
1672
 
 
1673
    def log_revision(self, revision):
 
1674
        """Log a revision, either merged or not."""
 
1675
        to_file = self.to_file
 
1676
 
 
1677
        date_str = format_date(revision.rev.timestamp,
 
1678
                               revision.rev.timezone or 0,
 
1679
                               self.show_timezone,
 
1680
                               date_fmt='%Y-%m-%d',
 
1681
                               show_offset=False)
 
1682
        committer_str = revision.rev.get_apparent_authors()[0].replace (' <', '  <')
 
1683
        to_file.write('%s  %s\n\n' % (date_str,committer_str))
 
1684
 
 
1685
        if revision.delta is not None and revision.delta.has_changed():
 
1686
            for c in revision.delta.added + revision.delta.removed + revision.delta.modified:
 
1687
                path, = c[:1]
 
1688
                to_file.write('\t* %s:\n' % (path,))
 
1689
            for c in revision.delta.renamed:
 
1690
                oldpath,newpath = c[:2]
 
1691
                # For renamed files, show both the old and the new path
 
1692
                to_file.write('\t* %s:\n\t* %s:\n' % (oldpath,newpath))
 
1693
            to_file.write('\n')
 
1694
 
 
1695
        if not revision.rev.message:
 
1696
            to_file.write('\tNo commit message\n')
 
1697
        else:
 
1698
            message = revision.rev.message.rstrip('\r\n')
 
1699
            for l in message.split('\n'):
 
1700
                to_file.write('\t%s\n' % (l.lstrip(),))
 
1701
            to_file.write('\n')
895
1702
 
896
1703
 
897
1704
def line_log(rev, max_chars):
923
1730
                                'Detailed log format')
924
1731
log_formatter_registry.register('line', LineLogFormatter,
925
1732
                                'Log format with one line per revision')
 
1733
log_formatter_registry.register('gnu-changelog', GnuChangelogLogFormatter,
 
1734
                                'Format used by GNU ChangeLog files')
926
1735
 
927
1736
 
928
1737
def register_formatter(name, formatter):
1002
1811
                 search=None)
1003
1812
 
1004
1813
 
 
1814
def get_history_change(old_revision_id, new_revision_id, repository):
 
1815
    """Calculate the uncommon lefthand history between two revisions.
 
1816
 
 
1817
    :param old_revision_id: The original revision id.
 
1818
    :param new_revision_id: The new revision id.
 
1819
    :param repository: The repository to use for the calculation.
 
1820
 
 
1821
    return old_history, new_history
 
1822
    """
 
1823
    old_history = []
 
1824
    old_revisions = set()
 
1825
    new_history = []
 
1826
    new_revisions = set()
 
1827
    new_iter = repository.iter_reverse_revision_history(new_revision_id)
 
1828
    old_iter = repository.iter_reverse_revision_history(old_revision_id)
 
1829
    stop_revision = None
 
1830
    do_old = True
 
1831
    do_new = True
 
1832
    while do_new or do_old:
 
1833
        if do_new:
 
1834
            try:
 
1835
                new_revision = new_iter.next()
 
1836
            except StopIteration:
 
1837
                do_new = False
 
1838
            else:
 
1839
                new_history.append(new_revision)
 
1840
                new_revisions.add(new_revision)
 
1841
                if new_revision in old_revisions:
 
1842
                    stop_revision = new_revision
 
1843
                    break
 
1844
        if do_old:
 
1845
            try:
 
1846
                old_revision = old_iter.next()
 
1847
            except StopIteration:
 
1848
                do_old = False
 
1849
            else:
 
1850
                old_history.append(old_revision)
 
1851
                old_revisions.add(old_revision)
 
1852
                if old_revision in new_revisions:
 
1853
                    stop_revision = old_revision
 
1854
                    break
 
1855
    new_history.reverse()
 
1856
    old_history.reverse()
 
1857
    if stop_revision is not None:
 
1858
        new_history = new_history[new_history.index(stop_revision) + 1:]
 
1859
        old_history = old_history[old_history.index(stop_revision) + 1:]
 
1860
    return old_history, new_history
 
1861
 
 
1862
 
 
1863
def show_branch_change(branch, output, old_revno, old_revision_id):
 
1864
    """Show the changes made to a branch.
 
1865
 
 
1866
    :param branch: The branch to show changes about.
 
1867
    :param output: A file-like object to write changes to.
 
1868
    :param old_revno: The revno of the old tip.
 
1869
    :param old_revision_id: The revision_id of the old tip.
 
1870
    """
 
1871
    new_revno, new_revision_id = branch.last_revision_info()
 
1872
    old_history, new_history = get_history_change(old_revision_id,
 
1873
                                                  new_revision_id,
 
1874
                                                  branch.repository)
 
1875
    if old_history == [] and new_history == []:
 
1876
        output.write('Nothing seems to have changed\n')
 
1877
        return
 
1878
 
 
1879
    log_format = log_formatter_registry.get_default(branch)
 
1880
    lf = log_format(show_ids=False, to_file=output, show_timezone='original')
 
1881
    if old_history != []:
 
1882
        output.write('*'*60)
 
1883
        output.write('\nRemoved Revisions:\n')
 
1884
        show_flat_log(branch.repository, old_history, old_revno, lf)
 
1885
        output.write('*'*60)
 
1886
        output.write('\n\n')
 
1887
    if new_history != []:
 
1888
        output.write('Added Revisions:\n')
 
1889
        start_revno = new_revno - len(new_history) + 1
 
1890
        show_log(branch, lf, None, verbose=False, direction='forward',
 
1891
                 start_revision=start_revno,)
 
1892
 
 
1893
 
 
1894
def show_flat_log(repository, history, last_revno, lf):
 
1895
    """Show a simple log of the specified history.
 
1896
 
 
1897
    :param repository: The repository to retrieve revisions from.
 
1898
    :param history: A list of revision_ids indicating the lefthand history.
 
1899
    :param last_revno: The revno of the last revision_id in the history.
 
1900
    :param lf: The log formatter to use.
 
1901
    """
 
1902
    start_revno = last_revno - len(history) + 1
 
1903
    revisions = repository.get_revisions(history)
 
1904
    for i, rev in enumerate(revisions):
 
1905
        lr = LogRevision(rev, i + last_revno, 0, None)
 
1906
        lf.log_revision(lr)
 
1907
 
 
1908
 
 
1909
def _get_info_for_log_files(revisionspec_list, file_list):
 
1910
    """Find file-ids and kinds given a list of files and a revision range.
 
1911
 
 
1912
    We search for files at the end of the range. If not found there,
 
1913
    we try the start of the range.
 
1914
 
 
1915
    :param revisionspec_list: revision range as parsed on the command line
 
1916
    :param file_list: the list of paths given on the command line;
 
1917
      the first of these can be a branch location or a file path,
 
1918
      the remainder must be file paths
 
1919
    :return: (branch, info_list, start_rev_info, end_rev_info) where
 
1920
      info_list is a list of (relative_path, file_id, kind) tuples where
 
1921
      kind is one of values 'directory', 'file', 'symlink', 'tree-reference'.
 
1922
      branch will be read-locked.
 
1923
    """
 
1924
    from builtins import _get_revision_range, safe_relpath_files
 
1925
    tree, b, path = bzrdir.BzrDir.open_containing_tree_or_branch(file_list[0])
 
1926
    b.lock_read()
 
1927
    # XXX: It's damn messy converting a list of paths to relative paths when
 
1928
    # those paths might be deleted ones, they might be on a case-insensitive
 
1929
    # filesystem and/or they might be in silly locations (like another branch).
 
1930
    # For example, what should "log bzr://branch/dir/file1 file2" do? (Is
 
1931
    # file2 implicitly in the same dir as file1 or should its directory be
 
1932
    # taken from the current tree somehow?) For now, this solves the common
 
1933
    # case of running log in a nested directory, assuming paths beyond the
 
1934
    # first one haven't been deleted ...
 
1935
    if tree:
 
1936
        relpaths = [path] + safe_relpath_files(tree, file_list[1:])
 
1937
    else:
 
1938
        relpaths = [path] + file_list[1:]
 
1939
    info_list = []
 
1940
    start_rev_info, end_rev_info = _get_revision_range(revisionspec_list, b,
 
1941
        "log")
 
1942
    if relpaths in ([], [u'']):
 
1943
        return b, [], start_rev_info, end_rev_info
 
1944
    if start_rev_info is None and end_rev_info is None:
 
1945
        if tree is None:
 
1946
            tree = b.basis_tree()
 
1947
        tree1 = None
 
1948
        for fp in relpaths:
 
1949
            file_id = tree.path2id(fp)
 
1950
            kind = _get_kind_for_file_id(tree, file_id)
 
1951
            if file_id is None:
 
1952
                # go back to when time began
 
1953
                if tree1 is None:
 
1954
                    try:
 
1955
                        rev1 = b.get_rev_id(1)
 
1956
                    except errors.NoSuchRevision:
 
1957
                        # No history at all
 
1958
                        file_id = None
 
1959
                        kind = None
 
1960
                    else:
 
1961
                        tree1 = b.repository.revision_tree(rev1)
 
1962
                if tree1:
 
1963
                    file_id = tree1.path2id(fp)
 
1964
                    kind = _get_kind_for_file_id(tree1, file_id)
 
1965
            info_list.append((fp, file_id, kind))
 
1966
 
 
1967
    elif start_rev_info == end_rev_info:
 
1968
        # One revision given - file must exist in it
 
1969
        tree = b.repository.revision_tree(end_rev_info.rev_id)
 
1970
        for fp in relpaths:
 
1971
            file_id = tree.path2id(fp)
 
1972
            kind = _get_kind_for_file_id(tree, file_id)
 
1973
            info_list.append((fp, file_id, kind))
 
1974
 
 
1975
    else:
 
1976
        # Revision range given. Get the file-id from the end tree.
 
1977
        # If that fails, try the start tree.
 
1978
        rev_id = end_rev_info.rev_id
 
1979
        if rev_id is None:
 
1980
            tree = b.basis_tree()
 
1981
        else:
 
1982
            tree = b.repository.revision_tree(rev_id)
 
1983
        tree1 = None
 
1984
        for fp in relpaths:
 
1985
            file_id = tree.path2id(fp)
 
1986
            kind = _get_kind_for_file_id(tree, file_id)
 
1987
            if file_id is None:
 
1988
                if tree1 is None:
 
1989
                    rev_id = start_rev_info.rev_id
 
1990
                    if rev_id is None:
 
1991
                        rev1 = b.get_rev_id(1)
 
1992
                        tree1 = b.repository.revision_tree(rev1)
 
1993
                    else:
 
1994
                        tree1 = b.repository.revision_tree(rev_id)
 
1995
                file_id = tree1.path2id(fp)
 
1996
                kind = _get_kind_for_file_id(tree1, file_id)
 
1997
            info_list.append((fp, file_id, kind))
 
1998
    return b, info_list, start_rev_info, end_rev_info
 
1999
 
 
2000
 
 
2001
def _get_kind_for_file_id(tree, file_id):
 
2002
    """Return the kind of a file-id or None if it doesn't exist."""
 
2003
    if file_id is not None:
 
2004
        return tree.kind(file_id)
 
2005
    else:
 
2006
        return None
 
2007
 
 
2008
 
1005
2009
properties_handler_registry = registry.Registry()
1006
2010
 
 
2011
# Use the properties handlers to print out bug information if available
 
2012
def _bugs_properties_handler(revision):
 
2013
    if revision.properties.has_key('bugs'):
 
2014
        bug_lines = revision.properties['bugs'].split('\n')
 
2015
        bug_rows = [line.split(' ', 1) for line in bug_lines]
 
2016
        fixed_bug_urls = [row[0] for row in bug_rows if
 
2017
                          len(row) > 1 and row[1] == 'fixed']
 
2018
 
 
2019
        if fixed_bug_urls:
 
2020
            return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
 
2021
    return {}
 
2022
 
 
2023
properties_handler_registry.register('bugs_properties_handler',
 
2024
                                     _bugs_properties_handler)
 
2025
 
 
2026
 
1007
2027
# adapters which revision ids to log are filtered. When log is called, the
1008
2028
# log_rev_iterator is adapted through each of these factory methods.
1009
2029
# Plugins are welcome to mutate this list in any way they like - as long