~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/log.py

  • Committer: Andrew Bennetts
  • Date: 2009-04-02 05:53:12 UTC
  • mto: This revision was merged to the branch mainline in revision 4242.
  • Revision ID: andrew.bennetts@canonical.com-20090402055312-h7mvgumvm7e620mj
Fix nits in spelling and naming.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2010 Canonical Ltd
 
1
# Copyright (C) 2005, 2006, 2007, 2009 Canonical Ltd
2
2
#
3
3
# This program is free software; you can redistribute it and/or modify
4
4
# it under the terms of the GNU General Public License as published by
65
65
lazy_import(globals(), """
66
66
 
67
67
from bzrlib import (
68
 
    bzrdir,
69
68
    config,
70
69
    diff,
71
70
    errors,
72
 
    foreign,
73
71
    repository as _mod_repository,
74
72
    revision as _mod_revision,
75
73
    revisionspec,
83
81
    )
84
82
from bzrlib.osutils import (
85
83
    format_date,
86
 
    format_date_with_offset_in_original_timezone,
87
84
    get_terminal_encoding,
88
85
    re_compile_checked,
89
86
    terminal_width,
90
87
    )
91
 
from bzrlib.symbol_versioning import (
92
 
    deprecated_function,
93
 
    deprecated_in,
94
 
    )
95
88
 
96
89
 
97
90
def find_touching_revisions(branch, file_id):
109
102
    last_path = None
110
103
    revno = 1
111
104
    for revision_id in branch.revision_history():
112
 
        this_inv = branch.repository.get_inventory(revision_id)
 
105
        this_inv = branch.repository.get_revision_inventory(revision_id)
113
106
        if file_id in this_inv:
114
107
            this_ie = this_inv[file_id]
115
108
            this_path = this_inv.id2path(file_id)
159
152
             show_diff=False):
160
153
    """Write out human-readable log of commits to this branch.
161
154
 
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
155
    :param lf: The LogFormatter object showing the output.
168
156
 
169
157
    :param specific_fileid: If not None, list only the commits affecting the
186
174
 
187
175
    :param show_diff: If True, output a diff after each revision.
188
176
    """
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
 
    'exclude_common_ancestry': False,
224
 
    '_match_using_deltas': True,
225
 
    }
226
 
 
227
 
 
228
 
def make_log_request_dict(direction='reverse', specific_fileids=None,
229
 
                          start_revision=None, end_revision=None, limit=None,
230
 
                          message_search=None, levels=1, generate_tags=True,
231
 
                          delta_type=None,
232
 
                          diff_type=None, _match_using_deltas=True,
233
 
                          exclude_common_ancestry=False,
234
 
                          ):
235
 
    """Convenience function for making a logging request dictionary.
236
 
 
237
 
    Using this function may make code slightly safer by ensuring
238
 
    parameters have the correct names. It also provides a reference
239
 
    point for documenting the supported parameters.
240
 
 
241
 
    :param direction: 'reverse' (default) is latest to earliest;
242
 
      'forward' is earliest to latest.
243
 
 
244
 
    :param specific_fileids: If not None, only include revisions
245
 
      affecting the specified files, rather than all revisions.
246
 
 
247
 
    :param start_revision: If not None, only generate
248
 
      revisions >= start_revision
249
 
 
250
 
    :param end_revision: If not None, only generate
251
 
      revisions <= end_revision
252
 
 
253
 
    :param limit: If set, generate only 'limit' revisions, all revisions
254
 
      are shown if None or 0.
255
 
 
256
 
    :param message_search: If not None, only include revisions with
257
 
      matching commit messages
258
 
 
259
 
    :param levels: the number of levels of revisions to
260
 
      generate; 1 for just the mainline; 0 for all levels.
261
 
 
262
 
    :param generate_tags: If True, include tags for matched revisions.
263
 
 
264
 
    :param delta_type: Either 'full', 'partial' or None.
265
 
      'full' means generate the complete delta - adds/deletes/modifies/etc;
266
 
      'partial' means filter the delta using specific_fileids;
267
 
      None means do not generate any delta.
268
 
 
269
 
    :param diff_type: Either 'full', 'partial' or None.
270
 
      'full' means generate the complete diff - adds/deletes/modifies/etc;
271
 
      'partial' means filter the diff using specific_fileids;
272
 
      None means do not generate any diff.
273
 
 
274
 
    :param _match_using_deltas: a private parameter controlling the
275
 
      algorithm used for matching specific_fileids. This parameter
276
 
      may be removed in the future so bzrlib client code should NOT
277
 
      use it.
278
 
 
279
 
    :param exclude_common_ancestry: Whether -rX..Y should be interpreted as a
280
 
      range operator or as a graph difference.
281
 
    """
282
 
    return {
283
 
        'direction': direction,
284
 
        'specific_fileids': specific_fileids,
285
 
        'start_revision': start_revision,
286
 
        'end_revision': end_revision,
287
 
        'limit': limit,
288
 
        'message_search': message_search,
289
 
        'levels': levels,
290
 
        'generate_tags': generate_tags,
291
 
        'delta_type': delta_type,
292
 
        'diff_type': diff_type,
293
 
        'exclude_common_ancestry': exclude_common_ancestry,
294
 
        # Add 'private' attributes for features that may be deprecated
295
 
        '_match_using_deltas': _match_using_deltas,
296
 
    }
297
 
 
298
 
 
299
 
def _apply_log_request_defaults(rqst):
300
 
    """Apply default values to a request dictionary."""
301
 
    result = _DEFAULT_REQUEST_PARAMS
302
 
    if rqst:
303
 
        result.update(rqst)
304
 
    return result
305
 
 
306
 
 
307
 
class LogGenerator(object):
308
 
    """A generator of log revisions."""
309
 
 
310
 
    def iter_log_revisions(self):
311
 
        """Iterate over LogRevision objects.
312
 
 
313
 
        :return: An iterator yielding LogRevision objects.
314
 
        """
315
 
        raise NotImplementedError(self.iter_log_revisions)
316
 
 
317
 
 
318
 
class Logger(object):
319
 
    """An object that generates, formats and displays a log."""
320
 
 
321
 
    def __init__(self, branch, rqst):
322
 
        """Create a Logger.
323
 
 
324
 
        :param branch: the branch to log
325
 
        :param rqst: A dictionary specifying the query parameters.
326
 
          See make_log_request_dict() for supported values.
327
 
        """
328
 
        self.branch = branch
329
 
        self.rqst = _apply_log_request_defaults(rqst)
330
 
 
331
 
    def show(self, lf):
332
 
        """Display the log.
333
 
 
334
 
        :param lf: The LogFormatter object to send the output to.
335
 
        """
336
 
        if not isinstance(lf, LogFormatter):
337
 
            warn("not a LogFormatter instance: %r" % lf)
338
 
 
339
 
        self.branch.lock_read()
340
 
        try:
341
 
            if getattr(lf, 'begin_log', None):
342
 
                lf.begin_log()
343
 
            self._show_body(lf)
344
 
            if getattr(lf, 'end_log', None):
345
 
                lf.end_log()
346
 
        finally:
347
 
            self.branch.unlock()
348
 
 
349
 
    def _show_body(self, lf):
350
 
        """Show the main log output.
351
 
 
352
 
        Subclasses may wish to override this.
353
 
        """
354
 
        # Tweak the LogRequest based on what the LogFormatter can handle.
355
 
        # (There's no point generating stuff if the formatter can't display it.)
356
 
        rqst = self.rqst
357
 
        rqst['levels'] = lf.get_levels()
358
 
        if not getattr(lf, 'supports_tags', False):
359
 
            rqst['generate_tags'] = False
360
 
        if not getattr(lf, 'supports_delta', False):
361
 
            rqst['delta_type'] = None
362
 
        if not getattr(lf, 'supports_diff', False):
363
 
            rqst['diff_type'] = None
364
 
 
365
 
        # Find and print the interesting revisions
366
 
        generator = self._generator_factory(self.branch, rqst)
367
 
        for lr in generator.iter_log_revisions():
 
177
    branch.lock_read()
 
178
    try:
 
179
        if getattr(lf, 'begin_log', None):
 
180
            lf.begin_log()
 
181
 
 
182
        _show_log(branch, lf, specific_fileid, verbose, direction,
 
183
                  start_revision, end_revision, search, limit, show_diff)
 
184
 
 
185
        if getattr(lf, 'end_log', None):
 
186
            lf.end_log()
 
187
    finally:
 
188
        branch.unlock()
 
189
 
 
190
 
 
191
def _show_log(branch,
 
192
             lf,
 
193
             specific_fileid=None,
 
194
             verbose=False,
 
195
             direction='reverse',
 
196
             start_revision=None,
 
197
             end_revision=None,
 
198
             search=None,
 
199
             limit=None,
 
200
             show_diff=False):
 
201
    """Worker function for show_log - see show_log."""
 
202
    if not isinstance(lf, LogFormatter):
 
203
        warn("not a LogFormatter instance: %r" % lf)
 
204
    if specific_fileid:
 
205
        trace.mutter('get log for file_id %r', specific_fileid)
 
206
 
 
207
    # Consult the LogFormatter about what it needs and can handle
 
208
    levels_to_display = lf.get_levels()
 
209
    generate_merge_revisions = levels_to_display != 1
 
210
    allow_single_merge_revision = True
 
211
    if not getattr(lf, 'supports_merge_revisions', False):
 
212
        allow_single_merge_revision = getattr(lf,
 
213
            'supports_single_merge_revision', False)
 
214
    generate_tags = getattr(lf, 'supports_tags', False)
 
215
    if generate_tags and branch.supports_tags():
 
216
        rev_tag_dict = branch.tags.get_reverse_tag_dict()
 
217
    else:
 
218
        rev_tag_dict = {}
 
219
    generate_delta = verbose and getattr(lf, 'supports_delta', False)
 
220
    generate_diff = show_diff and getattr(lf, 'supports_diff', False)
 
221
 
 
222
    # Find and print the interesting revisions
 
223
    repo = branch.repository
 
224
    log_count = 0
 
225
    revision_iterator = _create_log_revision_iterator(branch,
 
226
        start_revision, end_revision, direction, specific_fileid, search,
 
227
        generate_merge_revisions, allow_single_merge_revision,
 
228
        generate_delta, limited_output=limit > 0)
 
229
    for revs in revision_iterator:
 
230
        for (rev_id, revno, merge_depth), rev, delta in revs:
 
231
            # Note: 0 levels means show everything; merge_depth counts from 0
 
232
            if levels_to_display != 0 and merge_depth >= levels_to_display:
 
233
                continue
 
234
            if generate_diff:
 
235
                diff = _format_diff(repo, rev, rev_id, specific_fileid)
 
236
            else:
 
237
                diff = None
 
238
            lr = LogRevision(rev, revno, merge_depth, delta,
 
239
                             rev_tag_dict.get(rev_id), diff)
368
240
            lf.log_revision(lr)
369
 
        lf.show_advice()
370
 
 
371
 
    def _generator_factory(self, branch, rqst):
372
 
        """Make the LogGenerator object to use.
373
 
        
374
 
        Subclasses may wish to override this.
375
 
        """
376
 
        return _DefaultLogGenerator(branch, rqst)
 
241
            if limit:
 
242
                log_count += 1
 
243
                if log_count >= limit:
 
244
                    return
 
245
 
 
246
 
 
247
def _format_diff(repo, rev, rev_id, specific_fileid):
 
248
    if len(rev.parent_ids) == 0:
 
249
        ancestor_id = _mod_revision.NULL_REVISION
 
250
    else:
 
251
        ancestor_id = rev.parent_ids[0]
 
252
    tree_1 = repo.revision_tree(ancestor_id)
 
253
    tree_2 = repo.revision_tree(rev_id)
 
254
    if specific_fileid:
 
255
        specific_files = [tree_2.id2path(specific_fileid)]
 
256
    else:
 
257
        specific_files = None
 
258
    s = StringIO()
 
259
    diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
 
260
        new_label='')
 
261
    return s.getvalue()
377
262
 
378
263
 
379
264
class _StartNotLinearAncestor(Exception):
380
265
    """Raised when a start revision is not found walking left-hand history."""
381
266
 
382
267
 
383
 
class _DefaultLogGenerator(LogGenerator):
384
 
    """The default generator of log revisions."""
385
 
 
386
 
    def __init__(self, branch, rqst):
387
 
        self.branch = branch
388
 
        self.rqst = rqst
389
 
        if rqst.get('generate_tags') and branch.supports_tags():
390
 
            self.rev_tag_dict = branch.tags.get_reverse_tag_dict()
391
 
        else:
392
 
            self.rev_tag_dict = {}
393
 
 
394
 
    def iter_log_revisions(self):
395
 
        """Iterate over LogRevision objects.
396
 
 
397
 
        :return: An iterator yielding LogRevision objects.
398
 
        """
399
 
        rqst = self.rqst
400
 
        levels = rqst.get('levels')
401
 
        limit = rqst.get('limit')
402
 
        diff_type = rqst.get('diff_type')
403
 
        log_count = 0
404
 
        revision_iterator = self._create_log_revision_iterator()
405
 
        for revs in revision_iterator:
406
 
            for (rev_id, revno, merge_depth), rev, delta in revs:
407
 
                # 0 levels means show everything; merge_depth counts from 0
408
 
                if levels != 0 and merge_depth >= levels:
409
 
                    continue
410
 
                if diff_type is None:
411
 
                    diff = None
412
 
                else:
413
 
                    diff = self._format_diff(rev, rev_id, diff_type)
414
 
                yield LogRevision(rev, revno, merge_depth, delta,
415
 
                    self.rev_tag_dict.get(rev_id), diff)
416
 
                if limit:
417
 
                    log_count += 1
418
 
                    if log_count >= limit:
419
 
                        return
420
 
 
421
 
    def _format_diff(self, rev, rev_id, diff_type):
422
 
        repo = self.branch.repository
423
 
        if len(rev.parent_ids) == 0:
424
 
            ancestor_id = _mod_revision.NULL_REVISION
425
 
        else:
426
 
            ancestor_id = rev.parent_ids[0]
427
 
        tree_1 = repo.revision_tree(ancestor_id)
428
 
        tree_2 = repo.revision_tree(rev_id)
429
 
        file_ids = self.rqst.get('specific_fileids')
430
 
        if diff_type == 'partial' and file_ids is not None:
431
 
            specific_files = [tree_2.id2path(id) for id in file_ids]
432
 
        else:
433
 
            specific_files = None
434
 
        s = StringIO()
435
 
        diff.show_diff_trees(tree_1, tree_2, s, specific_files, old_label='',
436
 
            new_label='')
437
 
        return s.getvalue()
438
 
 
439
 
    def _create_log_revision_iterator(self):
440
 
        """Create a revision iterator for log.
441
 
 
442
 
        :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
443
 
            delta).
444
 
        """
445
 
        self.start_rev_id, self.end_rev_id = _get_revision_limits(
446
 
            self.branch, self.rqst.get('start_revision'),
447
 
            self.rqst.get('end_revision'))
448
 
        if self.rqst.get('_match_using_deltas'):
449
 
            return self._log_revision_iterator_using_delta_matching()
450
 
        else:
451
 
            # We're using the per-file-graph algorithm. This scales really
452
 
            # well but only makes sense if there is a single file and it's
453
 
            # not a directory
454
 
            file_count = len(self.rqst.get('specific_fileids'))
455
 
            if file_count != 1:
456
 
                raise BzrError("illegal LogRequest: must match-using-deltas "
457
 
                    "when logging %d files" % file_count)
458
 
            return self._log_revision_iterator_using_per_file_graph()
459
 
 
460
 
    def _log_revision_iterator_using_delta_matching(self):
461
 
        # Get the base revisions, filtering by the revision range
462
 
        rqst = self.rqst
463
 
        generate_merge_revisions = rqst.get('levels') != 1
464
 
        delayed_graph_generation = not rqst.get('specific_fileids') and (
465
 
                rqst.get('limit') or self.start_rev_id or self.end_rev_id)
466
 
        view_revisions = _calc_view_revisions(
467
 
            self.branch, self.start_rev_id, self.end_rev_id,
468
 
            rqst.get('direction'),
469
 
            generate_merge_revisions=generate_merge_revisions,
470
 
            delayed_graph_generation=delayed_graph_generation,
471
 
            exclude_common_ancestry=rqst.get('exclude_common_ancestry'))
472
 
 
473
 
        # Apply the other filters
474
 
        return make_log_rev_iterator(self.branch, view_revisions,
475
 
            rqst.get('delta_type'), rqst.get('message_search'),
476
 
            file_ids=rqst.get('specific_fileids'),
477
 
            direction=rqst.get('direction'))
478
 
 
479
 
    def _log_revision_iterator_using_per_file_graph(self):
480
 
        # Get the base revisions, filtering by the revision range.
481
 
        # Note that we always generate the merge revisions because
482
 
        # filter_revisions_touching_file_id() requires them ...
483
 
        rqst = self.rqst
484
 
        view_revisions = _calc_view_revisions(
485
 
            self.branch, self.start_rev_id, self.end_rev_id,
486
 
            rqst.get('direction'), generate_merge_revisions=True,
487
 
            exclude_common_ancestry=rqst.get('exclude_common_ancestry'))
 
268
def _create_log_revision_iterator(branch, start_revision, end_revision,
 
269
    direction, specific_fileid, search, generate_merge_revisions,
 
270
    allow_single_merge_revision, generate_delta, limited_output=False):
 
271
    """Create a revision iterator for log.
 
272
 
 
273
    :param branch: The branch being logged.
 
274
    :param start_revision: If not None, only show revisions >= start_revision
 
275
    :param end_revision: If not None, only show revisions <= end_revision
 
276
    :param direction: 'reverse' (default) is latest to earliest; 'forward' is
 
277
        earliest to latest.
 
278
    :param specific_fileid: If not None, list only the commits affecting the
 
279
        specified file.
 
280
    :param search: If not None, only show revisions with matching commit
 
281
        messages.
 
282
    :param generate_merge_revisions: If False, show only mainline revisions.
 
283
    :param allow_single_merge_revision: If True, logging of a single
 
284
        revision off the mainline is to be allowed
 
285
    :param generate_delta: Whether to generate a delta for each revision.
 
286
    :param limited_output: if True, the user only wants a limited result
 
287
 
 
288
    :return: An iterator over lists of ((rev_id, revno, merge_depth), rev,
 
289
        delta).
 
290
    """
 
291
    start_rev_id, end_rev_id = _get_revision_limits(branch, start_revision,
 
292
        end_revision)
 
293
 
 
294
    # Decide how file-ids are matched: delta-filtering vs per-file graph.
 
295
    # Delta filtering allows revisions to be displayed incrementally
 
296
    # though the total time is much slower for huge repositories: log -v
 
297
    # is the *lower* performance bound. At least until the split
 
298
    # inventory format arrives, per-file-graph needs to remain the
 
299
    # default except in verbose mode. Delta filtering should give more
 
300
    # accurate results (e.g. inclusion of FILE deletions) so arguably
 
301
    # it should always be used in the future.
 
302
    use_deltas_for_matching = specific_fileid and generate_delta
 
303
    delayed_graph_generation = not specific_fileid and (
 
304
            start_rev_id or end_rev_id or limited_output)
 
305
    generate_merges = generate_merge_revisions or (specific_fileid and
 
306
        not use_deltas_for_matching)
 
307
    view_revisions = _calc_view_revisions(branch, start_rev_id, end_rev_id,
 
308
        direction, generate_merges, allow_single_merge_revision,
 
309
        delayed_graph_generation=delayed_graph_generation)
 
310
    search_deltas_for_fileids = None
 
311
    if use_deltas_for_matching:
 
312
        search_deltas_for_fileids = set([specific_fileid])
 
313
    elif specific_fileid:
488
314
        if not isinstance(view_revisions, list):
489
315
            view_revisions = list(view_revisions)
490
 
        view_revisions = _filter_revisions_touching_file_id(self.branch,
491
 
            rqst.get('specific_fileids')[0], view_revisions,
492
 
            include_merges=rqst.get('levels') != 1)
493
 
        return make_log_rev_iterator(self.branch, view_revisions,
494
 
            rqst.get('delta_type'), rqst.get('message_search'))
 
316
        view_revisions = _filter_revisions_touching_file_id(branch,
 
317
            specific_fileid, view_revisions,
 
318
            include_merges=generate_merge_revisions)
 
319
    return make_log_rev_iterator(branch, view_revisions, generate_delta,
 
320
        search, file_ids=search_deltas_for_fileids, direction=direction)
495
321
 
496
322
 
497
323
def _calc_view_revisions(branch, start_rev_id, end_rev_id, direction,
498
 
                         generate_merge_revisions,
499
 
                         delayed_graph_generation=False,
500
 
                         exclude_common_ancestry=False,
501
 
                         ):
 
324
    generate_merge_revisions, allow_single_merge_revision,
 
325
    delayed_graph_generation=False):
502
326
    """Calculate the revisions to view.
503
327
 
504
328
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
505
329
             a list of the same tuples.
506
330
    """
507
 
    if (exclude_common_ancestry and start_rev_id == end_rev_id):
508
 
        raise errors.BzrCommandError(
509
 
            '--exclude-common-ancestry requires two different revisions')
510
 
    if direction not in ('reverse', 'forward'):
511
 
        raise ValueError('invalid direction %r' % direction)
512
331
    br_revno, br_rev_id = branch.last_revision_info()
513
332
    if br_revno == 0:
514
333
        return []
515
334
 
516
 
    if (end_rev_id and start_rev_id == end_rev_id
517
 
        and (not generate_merge_revisions
518
 
             or not _has_merges(branch, end_rev_id))):
519
 
        # If a single revision is requested, check we can handle it
520
 
        iter_revs = _generate_one_revision(branch, end_rev_id, br_rev_id,
521
 
                                           br_revno)
522
 
    elif not generate_merge_revisions:
523
 
        # If we only want to see linear revisions, we can iterate ...
524
 
        iter_revs = _generate_flat_revisions(branch, start_rev_id, end_rev_id,
525
 
                                             direction)
526
 
        if direction == 'forward':
527
 
            iter_revs = reversed(iter_revs)
528
 
    else:
529
 
        iter_revs = _generate_all_revisions(branch, start_rev_id, end_rev_id,
530
 
                                            direction, delayed_graph_generation,
531
 
                                            exclude_common_ancestry)
532
 
        if direction == 'forward':
533
 
            iter_revs = _rebase_merge_depth(reverse_by_depth(list(iter_revs)))
534
 
    return iter_revs
535
 
 
536
 
 
537
 
def _generate_one_revision(branch, rev_id, br_rev_id, br_revno):
538
 
    if rev_id == br_rev_id:
539
 
        # It's the tip
540
 
        return [(br_rev_id, br_revno, 0)]
541
 
    else:
542
 
        revno = branch.revision_id_to_dotted_revno(rev_id)
543
 
        revno_str = '.'.join(str(n) for n in revno)
544
 
        return [(rev_id, revno_str, 0)]
545
 
 
546
 
 
547
 
def _generate_flat_revisions(branch, start_rev_id, end_rev_id, direction):
548
 
    result = _linear_view_revisions(branch, start_rev_id, end_rev_id)
549
 
    # If a start limit was given and it's not obviously an
550
 
    # ancestor of the end limit, check it before outputting anything
551
 
    if direction == 'forward' or (start_rev_id
552
 
        and not _is_obvious_ancestor(branch, start_rev_id, end_rev_id)):
553
 
        try:
554
 
            result = list(result)
555
 
        except _StartNotLinearAncestor:
556
 
            raise errors.BzrCommandError('Start revision not found in'
557
 
                ' left-hand history of end revision.')
558
 
    return result
559
 
 
560
 
 
561
 
def _generate_all_revisions(branch, start_rev_id, end_rev_id, direction,
562
 
                            delayed_graph_generation,
563
 
                            exclude_common_ancestry=False):
 
335
    # If a single revision is requested, check we can handle it
 
336
    generate_single_revision = (end_rev_id and start_rev_id == end_rev_id and
 
337
        (not generate_merge_revisions or not _has_merges(branch, end_rev_id)))
 
338
    if generate_single_revision:
 
339
        if end_rev_id == br_rev_id:
 
340
            # It's the tip
 
341
            return [(br_rev_id, br_revno, 0)]
 
342
        else:
 
343
            revno = branch.revision_id_to_dotted_revno(end_rev_id)
 
344
            if len(revno) > 1 and not allow_single_merge_revision:
 
345
                # It's a merge revision and the log formatter is
 
346
                # completely brain dead. This "feature" of allowing
 
347
                # log formatters incapable of displaying dotted revnos
 
348
                # ought to be deprecated IMNSHO. IGC 20091022
 
349
                raise errors.BzrCommandError('Selected log formatter only'
 
350
                    ' supports mainline revisions.')
 
351
            revno_str = '.'.join(str(n) for n in revno)
 
352
            return [(end_rev_id, revno_str, 0)]
 
353
 
 
354
    # If we only want to see linear revisions, we can iterate ...
 
355
    if not generate_merge_revisions:
 
356
        result = _linear_view_revisions(branch, start_rev_id, end_rev_id)
 
357
        # If a start limit was given and it's not obviously an
 
358
        # ancestor of the end limit, check it before outputting anything
 
359
        if direction == 'forward' or (start_rev_id
 
360
            and not _is_obvious_ancestor(branch, start_rev_id, end_rev_id)):
 
361
            try:
 
362
                result = list(result)
 
363
            except _StartNotLinearAncestor:
 
364
                raise errors.BzrCommandError('Start revision not found in'
 
365
                    ' left-hand history of end revision.')
 
366
        if direction == 'forward':
 
367
            result = reversed(list(result))
 
368
        return result
 
369
 
564
370
    # On large trees, generating the merge graph can take 30-60 seconds
565
371
    # so we delay doing it until a merge is detected, incrementally
566
372
    # returning initial (non-merge) revisions while we can.
567
 
 
568
 
    # The above is only true for old formats (<= 0.92), for newer formats, a
569
 
    # couple of seconds only should be needed to load the whole graph and the
570
 
    # other graph operations needed are even faster than that -- vila 100201
571
373
    initial_revisions = []
572
374
    if delayed_graph_generation:
573
375
        try:
574
 
            for rev_id, revno, depth in  _linear_view_revisions(
575
 
                branch, start_rev_id, end_rev_id):
 
376
            for rev_id, revno, depth in \
 
377
                _linear_view_revisions(branch, start_rev_id, end_rev_id):
576
378
                if _has_merges(branch, rev_id):
577
 
                    # The end_rev_id can be nested down somewhere. We need an
578
 
                    # explicit ancestry check. There is an ambiguity here as we
579
 
                    # may not raise _StartNotLinearAncestor for a revision that
580
 
                    # is an ancestor but not a *linear* one. But since we have
581
 
                    # loaded the graph to do the check (or calculate a dotted
582
 
                    # revno), we may as well accept to show the log...  We need
583
 
                    # the check only if start_rev_id is not None as all
584
 
                    # revisions have _mod_revision.NULL_REVISION as an ancestor
585
 
                    # -- vila 20100319
586
 
                    graph = branch.repository.get_graph()
587
 
                    if (start_rev_id is not None
588
 
                        and not graph.is_ancestor(start_rev_id, end_rev_id)):
589
 
                        raise _StartNotLinearAncestor()
590
 
                    # Since we collected the revisions so far, we need to
591
 
                    # adjust end_rev_id.
592
379
                    end_rev_id = rev_id
593
380
                    break
594
381
                else:
595
382
                    initial_revisions.append((rev_id, revno, depth))
596
383
            else:
597
384
                # No merged revisions found
598
 
                return initial_revisions
 
385
                if direction == 'reverse':
 
386
                    return initial_revisions
 
387
                elif direction == 'forward':
 
388
                    return reversed(initial_revisions)
 
389
                else:
 
390
                    raise ValueError('invalid direction %r' % direction)
599
391
        except _StartNotLinearAncestor:
600
392
            # A merge was never detected so the lower revision limit can't
601
393
            # be nested down somewhere
602
394
            raise errors.BzrCommandError('Start revision not found in'
603
395
                ' history of end revision.')
604
396
 
605
 
    # We exit the loop above because we encounter a revision with merges, from
606
 
    # this revision, we need to switch to _graph_view_revisions.
607
 
 
608
397
    # A log including nested merges is required. If the direction is reverse,
609
398
    # we rebase the initial merge depths so that the development line is
610
399
    # shown naturally, i.e. just like it is for linear logging. We can easily
612
401
    # indented at the end seems slightly nicer in that case.
613
402
    view_revisions = chain(iter(initial_revisions),
614
403
        _graph_view_revisions(branch, start_rev_id, end_rev_id,
615
 
                              rebase_initial_depths=(direction == 'reverse'),
616
 
                              exclude_common_ancestry=exclude_common_ancestry))
617
 
    return view_revisions
 
404
        rebase_initial_depths=direction == 'reverse'))
 
405
    if direction == 'reverse':
 
406
        return view_revisions
 
407
    elif direction == 'forward':
 
408
        # Forward means oldest first, adjusting for depth.
 
409
        view_revisions = reverse_by_depth(list(view_revisions))
 
410
        return _rebase_merge_depth(view_revisions)
 
411
    else:
 
412
        raise ValueError('invalid direction %r' % direction)
618
413
 
619
414
 
620
415
def _has_merges(branch, rev_id):
638
433
        else:
639
434
            # not obvious
640
435
            return False
641
 
    # if either start or end is not specified then we use either the first or
642
 
    # the last revision and *they* are obvious ancestors.
643
436
    return True
644
437
 
645
438
 
678
471
 
679
472
 
680
473
def _graph_view_revisions(branch, start_rev_id, end_rev_id,
681
 
                          rebase_initial_depths=True,
682
 
                          exclude_common_ancestry=False):
 
474
    rebase_initial_depths=True):
683
475
    """Calculate revisions to view including merges, newest to oldest.
684
476
 
685
477
    :param branch: the branch
689
481
      revision is found?
690
482
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples.
691
483
    """
692
 
    if exclude_common_ancestry:
693
 
        stop_rule = 'with-merges-without-common-ancestry'
694
 
    else:
695
 
        stop_rule = 'with-merges'
696
484
    view_revisions = branch.iter_merge_sorted_revisions(
697
485
        start_revision_id=end_rev_id, stop_revision_id=start_rev_id,
698
 
        stop_rule=stop_rule)
 
486
        stop_rule="with-merges")
699
487
    if not rebase_initial_depths:
700
488
        for (rev_id, merge_depth, revno, end_of_merge
701
489
             ) in view_revisions:
712
500
                depth_adjustment = merge_depth
713
501
            if depth_adjustment:
714
502
                if merge_depth < depth_adjustment:
715
 
                    # From now on we reduce the depth adjustement, this can be
716
 
                    # surprising for users. The alternative requires two passes
717
 
                    # which breaks the fast display of the first revision
718
 
                    # though.
719
503
                    depth_adjustment = merge_depth
720
504
                merge_depth -= depth_adjustment
721
505
            yield rev_id, '.'.join(map(str, revno)), merge_depth
722
506
 
723
507
 
724
 
@deprecated_function(deprecated_in((2, 2, 0)))
725
508
def calculate_view_revisions(branch, start_revision, end_revision, direction,
726
 
        specific_fileid, generate_merge_revisions):
 
509
        specific_fileid, generate_merge_revisions, allow_single_merge_revision):
727
510
    """Calculate the revisions to view.
728
511
 
729
512
    :return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
730
513
             a list of the same tuples.
731
514
    """
 
515
    # This method is no longer called by the main code path.
 
516
    # It is retained for API compatibility and may be deprecated
 
517
    # soon. IGC 20090116
732
518
    start_rev_id, end_rev_id = _get_revision_limits(branch, start_revision,
733
519
        end_revision)
734
520
    view_revisions = list(_calc_view_revisions(branch, start_rev_id, end_rev_id,
735
 
        direction, generate_merge_revisions or specific_fileid))
 
521
        direction, generate_merge_revisions or specific_fileid,
 
522
        allow_single_merge_revision))
736
523
    if specific_fileid:
737
524
        view_revisions = _filter_revisions_touching_file_id(branch,
738
525
            specific_fileid, view_revisions,
757
544
    :param branch: The branch being logged.
758
545
    :param view_revisions: The revisions being viewed.
759
546
    :param generate_delta: Whether to generate a delta for each revision.
760
 
      Permitted values are None, 'full' and 'partial'.
761
547
    :param search: A user text search string.
762
548
    :param file_ids: If non empty, only revisions matching one or more of
763
549
      the file-ids are to be kept.
822
608
 
823
609
    :param branch: The branch being logged.
824
610
    :param generate_delta: Whether to generate a delta for each revision.
825
 
      Permitted values are None, 'full' and 'partial'.
826
611
    :param search: A user text search string.
827
612
    :param log_rev_iterator: An input iterator containing all revisions that
828
613
        could be displayed, in lists.
838
623
        generate_delta, fileids, direction)
839
624
 
840
625
 
841
 
def _generate_deltas(repository, log_rev_iterator, delta_type, fileids,
 
626
def _generate_deltas(repository, log_rev_iterator, always_delta, fileids,
842
627
    direction):
843
628
    """Create deltas for each batch of revisions in log_rev_iterator.
844
629
 
862
647
        if check_fileids and not fileid_set:
863
648
            return
864
649
        revisions = [rev[1] for rev in revs]
 
650
        deltas = repository.get_deltas_for_revisions(revisions)
865
651
        new_revs = []
866
 
        if delta_type == 'full' and not check_fileids:
867
 
            deltas = repository.get_deltas_for_revisions(revisions)
868
 
            for rev, delta in izip(revs, deltas):
869
 
                new_revs.append((rev[0], rev[1], delta))
870
 
        else:
871
 
            deltas = repository.get_deltas_for_revisions(revisions, fileid_set)
872
 
            for rev, delta in izip(revs, deltas):
873
 
                if check_fileids:
874
 
                    if delta is None or not delta.has_changed():
875
 
                        continue
876
 
                    else:
877
 
                        _update_fileids(delta, fileid_set, stop_on)
878
 
                        if delta_type is None:
879
 
                            delta = None
880
 
                        elif delta_type == 'full':
881
 
                            # If the file matches all the time, rebuilding
882
 
                            # a full delta like this in addition to a partial
883
 
                            # one could be slow. However, it's likely that
884
 
                            # most revisions won't get this far, making it
885
 
                            # faster to filter on the partial deltas and
886
 
                            # build the occasional full delta than always
887
 
                            # building full deltas and filtering those.
888
 
                            rev_id = rev[0][0]
889
 
                            delta = repository.get_revision_delta(rev_id)
890
 
                new_revs.append((rev[0], rev[1], delta))
 
652
        for rev, delta in izip(revs, deltas):
 
653
            if check_fileids:
 
654
                if not _delta_matches_fileids(delta, fileid_set, stop_on):
 
655
                    continue
 
656
                elif not always_delta:
 
657
                    # Delta was created just for matching - ditch it
 
658
                    # Note: It would probably be a better UI to return
 
659
                    # a delta filtered by the file-ids, rather than
 
660
                    # None at all. That functional enhancement can
 
661
                    # come later ...
 
662
                    delta = None
 
663
            new_revs.append((rev[0], rev[1], delta))
891
664
        yield new_revs
892
665
 
893
666
 
894
 
def _update_fileids(delta, fileids, stop_on):
895
 
    """Update the set of file-ids to search based on file lifecycle events.
896
 
    
897
 
    :param fileids: a set of fileids to update
 
667
def _delta_matches_fileids(delta, fileids, stop_on='add'):
 
668
    """Check is a delta matches one of more file-ids.
 
669
 
 
670
    :param fileids: a set of fileids to match against.
898
671
    :param stop_on: either 'add' or 'remove' - take file-ids out of the
899
672
      fileids set once their add or remove entry is detected respectively
900
673
    """
901
 
    if stop_on == 'add':
902
 
        for item in delta.added:
903
 
            if item[1] in fileids:
904
 
                fileids.remove(item[1])
905
 
    elif stop_on == 'delete':
906
 
        for item in delta.removed:
907
 
            if item[1] in fileids:
908
 
                fileids.remove(item[1])
 
674
    if not fileids:
 
675
        return False
 
676
    result = False
 
677
    for item in delta.added:
 
678
        if item[1] in fileids:
 
679
            if stop_on == 'add':
 
680
                fileids.remove(item[1])
 
681
            result = True
 
682
    for item in delta.removed:
 
683
        if item[1] in fileids:
 
684
            if stop_on == 'delete':
 
685
                fileids.remove(item[1])
 
686
            result = True
 
687
    if result:
 
688
        return True
 
689
    for l in (delta.modified, delta.renamed, delta.kind_changed):
 
690
        for item in l:
 
691
            if item[1] in fileids:
 
692
                return True
 
693
    return False
909
694
 
910
695
 
911
696
def _make_revision_objects(branch, generate_delta, search, log_rev_iterator):
1084
869
    return mainline_revs, rev_nos, start_rev_id, end_rev_id
1085
870
 
1086
871
 
1087
 
@deprecated_function(deprecated_in((2, 2, 0)))
1088
872
def _filter_revision_range(view_revisions, start_rev_id, end_rev_id):
1089
873
    """Filter view_revisions based on revision ranges.
1090
874
 
1099
883
 
1100
884
    :return: The filtered view_revisions.
1101
885
    """
 
886
    # This method is no longer called by the main code path.
 
887
    # It may be removed soon. IGC 20090127
1102
888
    if start_rev_id or end_rev_id:
1103
889
        revision_ids = [r for r, n, d in view_revisions]
1104
890
        if start_rev_id:
1210
996
    return result
1211
997
 
1212
998
 
1213
 
@deprecated_function(deprecated_in((2, 2, 0)))
1214
999
def get_view_revisions(mainline_revs, rev_nos, branch, direction,
1215
1000
                       include_merges=True):
1216
1001
    """Produce an iterator of revisions to show
1217
1002
    :return: an iterator of (revision_id, revno, merge_depth)
1218
1003
    (if there is no revno for a revision, None is supplied)
1219
1004
    """
 
1005
    # This method is no longer called by the main code path.
 
1006
    # It is retained for API compatibility and may be deprecated
 
1007
    # soon. IGC 20090127
1220
1008
    if not include_merges:
1221
1009
        revision_ids = mainline_revs[1:]
1222
1010
        if direction == 'reverse':
1317
1105
        one (2) should be used.
1318
1106
 
1319
1107
    - supports_merge_revisions must be True if this log formatter supports
1320
 
        merge revisions.  If not, then only mainline revisions will be passed
1321
 
        to the formatter.
 
1108
        merge revisions.  If not, and if supports_single_merge_revision is
 
1109
        also not True, then only mainline revisions will be passed to the
 
1110
        formatter.
1322
1111
 
1323
1112
    - preferred_levels is the number of levels this formatter defaults to.
1324
1113
        The default value is zero meaning display all levels.
1325
1114
        This value is only relevant if supports_merge_revisions is True.
1326
1115
 
 
1116
    - supports_single_merge_revision must be True if this log formatter
 
1117
        supports logging only a single merge revision.  This flag is
 
1118
        only relevant if supports_merge_revisions is not True.
 
1119
 
1327
1120
    - supports_tags must be True if this log formatter supports tags.
1328
1121
        Otherwise the tags attribute may not be populated.
1329
1122
 
1340
1133
    preferred_levels = 0
1341
1134
 
1342
1135
    def __init__(self, to_file, show_ids=False, show_timezone='original',
1343
 
                 delta_format=None, levels=None, show_advice=False,
1344
 
                 to_exact_file=None):
 
1136
                 delta_format=None, levels=None):
1345
1137
        """Create a LogFormatter.
1346
1138
 
1347
1139
        :param to_file: the file to output to
1348
 
        :param to_exact_file: if set, gives an output stream to which 
1349
 
             non-Unicode diffs are written.
1350
1140
        :param show_ids: if True, revision-ids are to be displayed
1351
1141
        :param show_timezone: the timezone to use
1352
1142
        :param delta_format: the level of delta information to display
1353
 
          or None to leave it to the formatter to decide
 
1143
          or None to leave it u to the formatter to decide
1354
1144
        :param levels: the number of levels to display; None or -1 to
1355
1145
          let the log formatter decide.
1356
 
        :param show_advice: whether to show advice at the end of the
1357
 
          log or not
1358
1146
        """
1359
1147
        self.to_file = to_file
1360
1148
        # 'exact' stream used to show diff, it should print content 'as is'
1361
1149
        # and should not try to decode/encode it to unicode to avoid bug #328007
1362
 
        if to_exact_file is not None:
1363
 
            self.to_exact_file = to_exact_file
1364
 
        else:
1365
 
            # XXX: somewhat hacky; this assumes it's a codec writer; it's better
1366
 
            # for code that expects to get diffs to pass in the exact file
1367
 
            # stream
1368
 
            self.to_exact_file = getattr(to_file, 'stream', to_file)
 
1150
        self.to_exact_file = getattr(to_file, 'stream', to_file)
1369
1151
        self.show_ids = show_ids
1370
1152
        self.show_timezone = show_timezone
1371
1153
        if delta_format is None:
1373
1155
            delta_format = 2 # long format
1374
1156
        self.delta_format = delta_format
1375
1157
        self.levels = levels
1376
 
        self._show_advice = show_advice
1377
 
        self._merge_count = 0
1378
1158
 
1379
1159
    def get_levels(self):
1380
1160
        """Get the number of levels to display or 0 for all."""
1381
1161
        if getattr(self, 'supports_merge_revisions', False):
1382
1162
            if self.levels is None or self.levels == -1:
1383
 
                self.levels = self.preferred_levels
1384
 
        else:
1385
 
            self.levels = 1
1386
 
        return self.levels
 
1163
                return self.preferred_levels
 
1164
            else:
 
1165
                return self.levels
 
1166
        return 1
1387
1167
 
1388
1168
    def log_revision(self, revision):
1389
1169
        """Log a revision.
1392
1172
        """
1393
1173
        raise NotImplementedError('not implemented in abstract base')
1394
1174
 
1395
 
    def show_advice(self):
1396
 
        """Output user advice, if any, when the log is completed."""
1397
 
        if self._show_advice and self.levels == 1 and self._merge_count > 0:
1398
 
            advice_sep = self.get_advice_separator()
1399
 
            if advice_sep:
1400
 
                self.to_file.write(advice_sep)
1401
 
            self.to_file.write(
1402
 
                "Use --include-merges or -n0 to see merged revisions.\n")
1403
 
 
1404
 
    def get_advice_separator(self):
1405
 
        """Get the text separating the log from the closing advice."""
1406
 
        return ''
1407
 
 
1408
1175
    def short_committer(self, rev):
1409
1176
        name, address = config.parse_username(rev.committer)
1410
1177
        if name:
1417
1184
            return name
1418
1185
        return address
1419
1186
 
1420
 
    def merge_marker(self, revision):
1421
 
        """Get the merge marker to include in the output or '' if none."""
1422
 
        if len(revision.rev.parent_ids) > 1:
1423
 
            self._merge_count += 1
1424
 
            return ' [merge]'
1425
 
        else:
1426
 
            return ''
1427
 
 
1428
1187
    def show_properties(self, revision, indent):
1429
1188
        """Displays the custom properties returned by each registered handler.
1430
1189
 
1431
1190
        If a registered handler raises an error it is propagated.
1432
1191
        """
1433
 
        for line in self.custom_properties(revision):
1434
 
            self.to_file.write("%s%s\n" % (indent, line))
1435
 
 
1436
 
    def custom_properties(self, revision):
1437
 
        """Format the custom properties returned by each registered handler.
1438
 
 
1439
 
        If a registered handler raises an error it is propagated.
1440
 
 
1441
 
        :return: a list of formatted lines (excluding trailing newlines)
1442
 
        """
1443
 
        lines = self._foreign_info_properties(revision)
1444
1192
        for key, handler in properties_handler_registry.iteritems():
1445
 
            lines.extend(self._format_properties(handler(revision)))
1446
 
        return lines
1447
 
 
1448
 
    def _foreign_info_properties(self, rev):
1449
 
        """Custom log displayer for foreign revision identifiers.
1450
 
 
1451
 
        :param rev: Revision object.
1452
 
        """
1453
 
        # Revision comes directly from a foreign repository
1454
 
        if isinstance(rev, foreign.ForeignRevision):
1455
 
            return self._format_properties(
1456
 
                rev.mapping.vcs.show_foreign_revid(rev.foreign_revid))
1457
 
 
1458
 
        # Imported foreign revision revision ids always contain :
1459
 
        if not ":" in rev.revision_id:
1460
 
            return []
1461
 
 
1462
 
        # Revision was once imported from a foreign repository
1463
 
        try:
1464
 
            foreign_revid, mapping = \
1465
 
                foreign.foreign_vcs_registry.parse_revision_id(rev.revision_id)
1466
 
        except errors.InvalidRevisionId:
1467
 
            return []
1468
 
 
1469
 
        return self._format_properties(
1470
 
            mapping.vcs.show_foreign_revid(foreign_revid))
1471
 
 
1472
 
    def _format_properties(self, properties):
1473
 
        lines = []
1474
 
        for key, value in properties.items():
1475
 
            lines.append(key + ': ' + value)
1476
 
        return lines
 
1193
            for key, value in handler(revision).items():
 
1194
                self.to_file.write(indent + key + ': ' + value + '\n')
1477
1195
 
1478
1196
    def show_diff(self, to_file, diff, indent):
1479
1197
        for l in diff.rstrip().split('\n'):
1480
1198
            to_file.write(indent + '%s\n' % (l,))
1481
1199
 
1482
1200
 
1483
 
# Separator between revisions in long format
1484
 
_LONG_SEP = '-' * 60
1485
 
 
1486
 
 
1487
1201
class LongLogFormatter(LogFormatter):
1488
1202
 
1489
1203
    supports_merge_revisions = True
1490
 
    preferred_levels = 1
1491
1204
    supports_delta = True
1492
1205
    supports_tags = True
1493
1206
    supports_diff = True
1494
1207
 
1495
 
    def __init__(self, *args, **kwargs):
1496
 
        super(LongLogFormatter, self).__init__(*args, **kwargs)
1497
 
        if self.show_timezone == 'original':
1498
 
            self.date_string = self._date_string_original_timezone
1499
 
        else:
1500
 
            self.date_string = self._date_string_with_timezone
1501
 
 
1502
 
    def _date_string_with_timezone(self, rev):
1503
 
        return format_date(rev.timestamp, rev.timezone or 0,
1504
 
                           self.show_timezone)
1505
 
 
1506
 
    def _date_string_original_timezone(self, rev):
1507
 
        return format_date_with_offset_in_original_timezone(rev.timestamp,
1508
 
            rev.timezone or 0)
1509
 
 
1510
1208
    def log_revision(self, revision):
1511
1209
        """Log a revision, either merged or not."""
1512
1210
        indent = '    ' * revision.merge_depth
1513
 
        lines = [_LONG_SEP]
 
1211
        to_file = self.to_file
 
1212
        to_file.write(indent + '-' * 60 + '\n')
1514
1213
        if revision.revno is not None:
1515
 
            lines.append('revno: %s%s' % (revision.revno,
1516
 
                self.merge_marker(revision)))
 
1214
            to_file.write(indent + 'revno: %s\n' % (revision.revno,))
1517
1215
        if revision.tags:
1518
 
            lines.append('tags: %s' % (', '.join(revision.tags)))
 
1216
            to_file.write(indent + 'tags: %s\n' % (', '.join(revision.tags)))
1519
1217
        if self.show_ids:
1520
 
            lines.append('revision-id: %s' % (revision.rev.revision_id,))
 
1218
            to_file.write(indent + 'revision-id: ' + revision.rev.revision_id)
 
1219
            to_file.write('\n')
1521
1220
            for parent_id in revision.rev.parent_ids:
1522
 
                lines.append('parent: %s' % (parent_id,))
1523
 
        lines.extend(self.custom_properties(revision.rev))
 
1221
                to_file.write(indent + 'parent: %s\n' % (parent_id,))
 
1222
        self.show_properties(revision.rev, indent)
1524
1223
 
1525
1224
        committer = revision.rev.committer
1526
1225
        authors = revision.rev.get_apparent_authors()
1527
1226
        if authors != [committer]:
1528
 
            lines.append('author: %s' % (", ".join(authors),))
1529
 
        lines.append('committer: %s' % (committer,))
 
1227
            to_file.write(indent + 'author: %s\n' % (", ".join(authors),))
 
1228
        to_file.write(indent + 'committer: %s\n' % (committer,))
1530
1229
 
1531
1230
        branch_nick = revision.rev.properties.get('branch-nick', None)
1532
1231
        if branch_nick is not None:
1533
 
            lines.append('branch nick: %s' % (branch_nick,))
1534
 
 
1535
 
        lines.append('timestamp: %s' % (self.date_string(revision.rev),))
1536
 
 
1537
 
        lines.append('message:')
 
1232
            to_file.write(indent + 'branch nick: %s\n' % (branch_nick,))
 
1233
 
 
1234
        date_str = format_date(revision.rev.timestamp,
 
1235
                               revision.rev.timezone or 0,
 
1236
                               self.show_timezone)
 
1237
        to_file.write(indent + 'timestamp: %s\n' % (date_str,))
 
1238
 
 
1239
        to_file.write(indent + 'message:\n')
1538
1240
        if not revision.rev.message:
1539
 
            lines.append('  (no message)')
 
1241
            to_file.write(indent + '  (no message)\n')
1540
1242
        else:
1541
1243
            message = revision.rev.message.rstrip('\r\n')
1542
1244
            for l in message.split('\n'):
1543
 
                lines.append('  %s' % (l,))
1544
 
 
1545
 
        # Dump the output, appending the delta and diff if requested
1546
 
        to_file = self.to_file
1547
 
        to_file.write("%s%s\n" % (indent, ('\n' + indent).join(lines)))
 
1245
                to_file.write(indent + '  %s\n' % (l,))
1548
1246
        if revision.delta is not None:
1549
 
            # Use the standard status output to display changes
1550
 
            from bzrlib.delta import report_delta
1551
 
            report_delta(to_file, revision.delta, short_status=False, 
1552
 
                         show_ids=self.show_ids, indent=indent)
 
1247
            # We don't respect delta_format for compatibility
 
1248
            revision.delta.show(to_file, self.show_ids, indent=indent,
 
1249
                                short_status=False)
1553
1250
        if revision.diff is not None:
1554
1251
            to_file.write(indent + 'diff:\n')
1555
 
            to_file.flush()
1556
1252
            # Note: we explicitly don't indent the diff (relative to the
1557
1253
            # revision information) so that the output can be fed to patch -p0
1558
1254
            self.show_diff(self.to_exact_file, revision.diff, indent)
1559
 
            self.to_exact_file.flush()
1560
 
 
1561
 
    def get_advice_separator(self):
1562
 
        """Get the text separating the log from the closing advice."""
1563
 
        return '-' * 60 + '\n'
1564
1255
 
1565
1256
 
1566
1257
class ShortLogFormatter(LogFormatter):
1596
1287
        offset = ' ' * (revno_width + 1)
1597
1288
 
1598
1289
        to_file = self.to_file
 
1290
        is_merge = ''
 
1291
        if len(revision.rev.parent_ids) > 1:
 
1292
            is_merge = ' [merge]'
1599
1293
        tags = ''
1600
1294
        if revision.tags:
1601
1295
            tags = ' {%s}' % (', '.join(revision.tags))
1605
1299
                            revision.rev.timezone or 0,
1606
1300
                            self.show_timezone, date_fmt="%Y-%m-%d",
1607
1301
                            show_offset=False),
1608
 
                tags, self.merge_marker(revision)))
 
1302
                tags, is_merge))
1609
1303
        self.show_properties(revision.rev, indent+offset)
1610
1304
        if self.show_ids:
1611
1305
            to_file.write(indent + offset + 'revision-id:%s\n'
1618
1312
                to_file.write(indent + offset + '%s\n' % (l,))
1619
1313
 
1620
1314
        if revision.delta is not None:
1621
 
            # Use the standard status output to display changes
1622
 
            from bzrlib.delta import report_delta
1623
 
            report_delta(to_file, revision.delta, 
1624
 
                         short_status=self.delta_format==1, 
1625
 
                         show_ids=self.show_ids, indent=indent + offset)
 
1315
            revision.delta.show(to_file, self.show_ids, indent=indent + offset,
 
1316
                                short_status=self.delta_format==1)
1626
1317
        if revision.diff is not None:
1627
1318
            self.show_diff(self.to_exact_file, revision.diff, '      ')
1628
1319
        to_file.write('\n')
1636
1327
 
1637
1328
    def __init__(self, *args, **kwargs):
1638
1329
        super(LineLogFormatter, self).__init__(*args, **kwargs)
1639
 
        width = terminal_width()
1640
 
        if width is not None:
1641
 
            # we need one extra space for terminals that wrap on last char
1642
 
            width = width - 1
1643
 
        self._max_chars = width
 
1330
        self._max_chars = terminal_width() - 1
1644
1331
 
1645
1332
    def truncate(self, str, max_len):
1646
 
        if max_len is None or len(str) <= max_len:
 
1333
        if len(str) <= max_len:
1647
1334
            return str
1648
 
        return str[:max_len-3] + '...'
 
1335
        return str[:max_len-3]+'...'
1649
1336
 
1650
1337
    def date_string(self, rev):
1651
1338
        return format_date(rev.timestamp, rev.timezone or 0,
1703
1390
                               self.show_timezone,
1704
1391
                               date_fmt='%Y-%m-%d',
1705
1392
                               show_offset=False)
1706
 
        committer_str = revision.rev.get_apparent_authors()[0].replace (' <', '  <')
 
1393
        committer_str = revision.rev.committer.replace (' <', '  <')
1707
1394
        to_file.write('%s  %s\n\n' % (date_str,committer_str))
1708
1395
 
1709
1396
        if revision.delta is not None and revision.delta.has_changed():
1930
1617
        lf.log_revision(lr)
1931
1618
 
1932
1619
 
1933
 
def _get_info_for_log_files(revisionspec_list, file_list, add_cleanup):
1934
 
    """Find file-ids and kinds given a list of files and a revision range.
1935
 
 
1936
 
    We search for files at the end of the range. If not found there,
1937
 
    we try the start of the range.
1938
 
 
1939
 
    :param revisionspec_list: revision range as parsed on the command line
1940
 
    :param file_list: the list of paths given on the command line;
1941
 
      the first of these can be a branch location or a file path,
1942
 
      the remainder must be file paths
1943
 
    :param add_cleanup: When the branch returned is read locked,
1944
 
      an unlock call will be queued to the cleanup.
1945
 
    :return: (branch, info_list, start_rev_info, end_rev_info) where
1946
 
      info_list is a list of (relative_path, file_id, kind) tuples where
1947
 
      kind is one of values 'directory', 'file', 'symlink', 'tree-reference'.
1948
 
      branch will be read-locked.
 
1620
def _get_fileid_to_log(revision, tree, b, fp):
 
1621
    """Find the file-id to log for a file path in a revision range.
 
1622
 
 
1623
    :param revision: the revision range as parsed on the command line
 
1624
    :param tree: the working tree, if any
 
1625
    :param b: the branch
 
1626
    :param fp: file path
1949
1627
    """
1950
 
    from builtins import _get_revision_range, safe_relpath_files
1951
 
    tree, b, path = bzrdir.BzrDir.open_containing_tree_or_branch(file_list[0])
1952
 
    add_cleanup(b.lock_read().unlock)
1953
 
    # XXX: It's damn messy converting a list of paths to relative paths when
1954
 
    # those paths might be deleted ones, they might be on a case-insensitive
1955
 
    # filesystem and/or they might be in silly locations (like another branch).
1956
 
    # For example, what should "log bzr://branch/dir/file1 file2" do? (Is
1957
 
    # file2 implicitly in the same dir as file1 or should its directory be
1958
 
    # taken from the current tree somehow?) For now, this solves the common
1959
 
    # case of running log in a nested directory, assuming paths beyond the
1960
 
    # first one haven't been deleted ...
1961
 
    if tree:
1962
 
        relpaths = [path] + safe_relpath_files(tree, file_list[1:])
1963
 
    else:
1964
 
        relpaths = [path] + file_list[1:]
1965
 
    info_list = []
1966
 
    start_rev_info, end_rev_info = _get_revision_range(revisionspec_list, b,
1967
 
        "log")
1968
 
    if relpaths in ([], [u'']):
1969
 
        return b, [], start_rev_info, end_rev_info
1970
 
    if start_rev_info is None and end_rev_info is None:
 
1628
    if revision is None:
1971
1629
        if tree is None:
1972
1630
            tree = b.basis_tree()
1973
 
        tree1 = None
1974
 
        for fp in relpaths:
1975
 
            file_id = tree.path2id(fp)
1976
 
            kind = _get_kind_for_file_id(tree, file_id)
1977
 
            if file_id is None:
1978
 
                # go back to when time began
1979
 
                if tree1 is None:
1980
 
                    try:
1981
 
                        rev1 = b.get_rev_id(1)
1982
 
                    except errors.NoSuchRevision:
1983
 
                        # No history at all
1984
 
                        file_id = None
1985
 
                        kind = None
1986
 
                    else:
1987
 
                        tree1 = b.repository.revision_tree(rev1)
1988
 
                if tree1:
1989
 
                    file_id = tree1.path2id(fp)
1990
 
                    kind = _get_kind_for_file_id(tree1, file_id)
1991
 
            info_list.append((fp, file_id, kind))
 
1631
        file_id = tree.path2id(fp)
 
1632
        if file_id is None:
 
1633
            # go back to when time began
 
1634
            try:
 
1635
                rev1 = b.get_rev_id(1)
 
1636
            except errors.NoSuchRevision:
 
1637
                # No history at all
 
1638
                file_id = None
 
1639
            else:
 
1640
                tree = b.repository.revision_tree(rev1)
 
1641
                file_id = tree.path2id(fp)
1992
1642
 
1993
 
    elif start_rev_info == end_rev_info:
 
1643
    elif len(revision) == 1:
1994
1644
        # One revision given - file must exist in it
1995
 
        tree = b.repository.revision_tree(end_rev_info.rev_id)
1996
 
        for fp in relpaths:
1997
 
            file_id = tree.path2id(fp)
1998
 
            kind = _get_kind_for_file_id(tree, file_id)
1999
 
            info_list.append((fp, file_id, kind))
 
1645
        tree = revision[0].as_tree(b)
 
1646
        file_id = tree.path2id(fp)
2000
1647
 
2001
 
    else:
 
1648
    elif len(revision) == 2:
2002
1649
        # Revision range given. Get the file-id from the end tree.
2003
1650
        # If that fails, try the start tree.
2004
 
        rev_id = end_rev_info.rev_id
 
1651
        rev_id = revision[1].as_revision_id(b)
2005
1652
        if rev_id is None:
2006
1653
            tree = b.basis_tree()
2007
1654
        else:
2008
 
            tree = b.repository.revision_tree(rev_id)
2009
 
        tree1 = None
2010
 
        for fp in relpaths:
 
1655
            tree = revision[1].as_tree(b)
 
1656
        file_id = tree.path2id(fp)
 
1657
        if file_id is None:
 
1658
            rev_id = revision[0].as_revision_id(b)
 
1659
            if rev_id is None:
 
1660
                rev1 = b.get_rev_id(1)
 
1661
                tree = b.repository.revision_tree(rev1)
 
1662
            else:
 
1663
                tree = revision[0].as_tree(b)
2011
1664
            file_id = tree.path2id(fp)
2012
 
            kind = _get_kind_for_file_id(tree, file_id)
2013
 
            if file_id is None:
2014
 
                if tree1 is None:
2015
 
                    rev_id = start_rev_info.rev_id
2016
 
                    if rev_id is None:
2017
 
                        rev1 = b.get_rev_id(1)
2018
 
                        tree1 = b.repository.revision_tree(rev1)
2019
 
                    else:
2020
 
                        tree1 = b.repository.revision_tree(rev_id)
2021
 
                file_id = tree1.path2id(fp)
2022
 
                kind = _get_kind_for_file_id(tree1, file_id)
2023
 
            info_list.append((fp, file_id, kind))
2024
 
    return b, info_list, start_rev_info, end_rev_info
2025
 
 
2026
 
 
2027
 
def _get_kind_for_file_id(tree, file_id):
2028
 
    """Return the kind of a file-id or None if it doesn't exist."""
2029
 
    if file_id is not None:
2030
 
        return tree.kind(file_id)
2031
1665
    else:
2032
 
        return None
 
1666
        raise errors.BzrCommandError(
 
1667
            'bzr log --revision takes one or two values.')
 
1668
    return file_id
2033
1669
 
2034
1670
 
2035
1671
properties_handler_registry = registry.Registry()
2036
 
 
2037
 
# Use the properties handlers to print out bug information if available
2038
 
def _bugs_properties_handler(revision):
2039
 
    if revision.properties.has_key('bugs'):
2040
 
        bug_lines = revision.properties['bugs'].split('\n')
2041
 
        bug_rows = [line.split(' ', 1) for line in bug_lines]
2042
 
        fixed_bug_urls = [row[0] for row in bug_rows if
2043
 
                          len(row) > 1 and row[1] == 'fixed']
2044
 
 
2045
 
        if fixed_bug_urls:
2046
 
            return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
2047
 
    return {}
2048
 
 
2049
 
properties_handler_registry.register('bugs_properties_handler',
2050
 
                                     _bugs_properties_handler)
 
1672
properties_handler_registry.register_lazy("foreign",
 
1673
                                          "bzrlib.foreign",
 
1674
                                          "show_foreign_properties")
2051
1675
 
2052
1676
 
2053
1677
# adapters which revision ids to log are filtered. When log is called, the