220
214
'direction': 'reverse',
222
216
'generate_tags': True,
223
'exclude_common_ancestry': False,
224
217
'_match_using_deltas': True,
228
221
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,
232
diff_type=None, _match_using_deltas=True,
233
exclude_common_ancestry=False,
222
start_revision=None, end_revision=None, limit=None,
223
message_search=None, levels=1, generate_tags=True, delta_type=None,
224
diff_type=None, _match_using_deltas=True):
235
225
"""Convenience function for making a logging request dictionary.
237
227
Using this function may make code slightly safer by ensuring
397
383
:return: An iterator yielding LogRevision objects.
400
levels = rqst.get('levels')
401
limit = rqst.get('limit')
402
diff_type = rqst.get('diff_type')
404
387
revision_iterator = self._create_log_revision_iterator()
405
388
for revs in revision_iterator:
406
389
for (rev_id, revno, merge_depth), rev, delta in revs:
407
390
# 0 levels means show everything; merge_depth counts from 0
391
levels = rqst.get('levels')
408
392
if levels != 0 and merge_depth >= levels:
410
if diff_type is None:
413
diff = self._format_diff(rev, rev_id, diff_type)
394
diff = self._format_diff(rev, rev_id)
414
395
yield LogRevision(rev, revno, merge_depth, delta,
415
396
self.rev_tag_dict.get(rev_id), diff)
397
limit = rqst.get('limit')
418
400
if log_count >= limit:
421
def _format_diff(self, rev, rev_id, diff_type):
403
def _format_diff(self, rev, rev_id):
404
diff_type = self.rqst.get('diff_type')
405
if diff_type is None:
422
407
repo = self.branch.repository
423
408
if len(rev.parent_ids) == 0:
424
409
ancestor_id = _mod_revision.NULL_REVISION
463
448
generate_merge_revisions = rqst.get('levels') != 1
464
449
delayed_graph_generation = not rqst.get('specific_fileids') and (
465
450
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'))
451
view_revisions = _calc_view_revisions(self.branch, self.start_rev_id,
452
self.end_rev_id, rqst.get('direction'), generate_merge_revisions,
453
delayed_graph_generation=delayed_graph_generation)
473
455
# Apply the other filters
474
456
return make_log_rev_iterator(self.branch, view_revisions,
481
463
# Note that we always generate the merge revisions because
482
464
# filter_revisions_touching_file_id() requires them ...
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'))
466
view_revisions = _calc_view_revisions(self.branch, self.start_rev_id,
467
self.end_rev_id, rqst.get('direction'), True)
488
468
if not isinstance(view_revisions, list):
489
469
view_revisions = list(view_revisions)
490
470
view_revisions = _filter_revisions_touching_file_id(self.branch,
497
477
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,
478
generate_merge_revisions, delayed_graph_generation=False):
502
479
"""Calculate the revisions to view.
504
481
:return: An iterator of (revision_id, dotted_revno, merge_depth) tuples OR
505
482
a list of the same tuples.
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
484
br_revno, br_rev_id = branch.last_revision_info()
513
485
if br_revno == 0:
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,
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,
526
if direction == 'forward':
527
iter_revs = reversed(iter_revs)
488
# If a single revision is requested, check we can handle it
489
generate_single_revision = (end_rev_id and start_rev_id == end_rev_id and
490
(not generate_merge_revisions or not _has_merges(branch, end_rev_id)))
491
if generate_single_revision:
492
return _generate_one_revision(branch, end_rev_id, br_rev_id, br_revno)
494
# If we only want to see linear revisions, we can iterate ...
495
if not generate_merge_revisions:
496
return _generate_flat_revisions(branch, start_rev_id, end_rev_id,
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)))
499
return _generate_all_revisions(branch, start_rev_id, end_rev_id,
500
direction, delayed_graph_generation)
537
503
def _generate_one_revision(branch, rev_id, br_rev_id, br_revno):
555
521
except _StartNotLinearAncestor:
556
522
raise errors.BzrCommandError('Start revision not found in'
557
523
' left-hand history of end revision.')
524
if direction == 'forward':
525
result = reversed(result)
561
529
def _generate_all_revisions(branch, start_rev_id, end_rev_id, direction,
562
delayed_graph_generation,
563
exclude_common_ancestry=False):
530
delayed_graph_generation):
564
531
# On large trees, generating the merge graph can take 30-60 seconds
565
532
# so we delay doing it until a merge is detected, incrementally
566
533
# returning initial (non-merge) revisions while we can.
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
534
initial_revisions = []
572
535
if delayed_graph_generation:
574
for rev_id, revno, depth in _linear_view_revisions(
575
branch, start_rev_id, end_rev_id):
537
for rev_id, revno, depth in \
538
_linear_view_revisions(branch, start_rev_id, end_rev_id):
576
539
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
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
592
540
end_rev_id = rev_id
595
543
initial_revisions.append((rev_id, revno, depth))
597
545
# No merged revisions found
598
return initial_revisions
546
if direction == 'reverse':
547
return initial_revisions
548
elif direction == 'forward':
549
return reversed(initial_revisions)
551
raise ValueError('invalid direction %r' % direction)
599
552
except _StartNotLinearAncestor:
600
553
# A merge was never detected so the lower revision limit can't
601
554
# be nested down somewhere
602
555
raise errors.BzrCommandError('Start revision not found in'
603
556
' history of end revision.')
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.
608
558
# A log including nested merges is required. If the direction is reverse,
609
559
# we rebase the initial merge depths so that the development line is
610
560
# shown naturally, i.e. just like it is for linear logging. We can easily
612
562
# indented at the end seems slightly nicer in that case.
613
563
view_revisions = chain(iter(initial_revisions),
614
564
_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
565
rebase_initial_depths=direction == 'reverse'))
566
if direction == 'reverse':
567
return view_revisions
568
elif direction == 'forward':
569
# Forward means oldest first, adjusting for depth.
570
view_revisions = reverse_by_depth(list(view_revisions))
571
return _rebase_merge_depth(view_revisions)
573
raise ValueError('invalid direction %r' % direction)
620
576
def _has_merges(branch, rev_id):
712
661
depth_adjustment = merge_depth
713
662
if depth_adjustment:
714
663
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
719
664
depth_adjustment = merge_depth
720
665
merge_depth -= depth_adjustment
721
666
yield rev_id, '.'.join(map(str, revno)), merge_depth
724
@deprecated_function(deprecated_in((2, 2, 0)))
725
669
def calculate_view_revisions(branch, start_revision, end_revision, direction,
726
670
specific_fileid, generate_merge_revisions):
727
671
"""Calculate the revisions to view.
1340
1290
preferred_levels = 0
1342
1292
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, author_list_handler=None):
1293
delta_format=None, levels=None):
1345
1294
"""Create a LogFormatter.
1347
1296
: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
1297
:param show_ids: if True, revision-ids are to be displayed
1351
1298
:param show_timezone: the timezone to use
1352
1299
:param delta_format: the level of delta information to display
1353
or None to leave it to the formatter to decide
1300
or None to leave it u to the formatter to decide
1354
1301
:param levels: the number of levels to display; None or -1 to
1355
1302
let the log formatter decide.
1356
:param show_advice: whether to show advice at the end of the
1358
:param author_list_handler: callable generating a list of
1359
authors to display for a given revision
1361
1304
self.to_file = to_file
1362
1305
# 'exact' stream used to show diff, it should print content 'as is'
1363
1306
# and should not try to decode/encode it to unicode to avoid bug #328007
1364
if to_exact_file is not None:
1365
self.to_exact_file = to_exact_file
1367
# XXX: somewhat hacky; this assumes it's a codec writer; it's better
1368
# for code that expects to get diffs to pass in the exact file
1370
self.to_exact_file = getattr(to_file, 'stream', to_file)
1307
self.to_exact_file = getattr(to_file, 'stream', to_file)
1371
1308
self.show_ids = show_ids
1372
1309
self.show_timezone = show_timezone
1373
1310
if delta_format is None:
1417
1352
def short_author(self, rev):
1418
return self.authors(rev, 'first', short=True, sep=', ')
1420
def authors(self, rev, who, short=False, sep=None):
1421
"""Generate list of authors, taking --authors option into account.
1423
The caller has to specify the name of a author list handler,
1424
as provided by the author list registry, using the ``who``
1425
argument. That name only sets a default, though: when the
1426
user selected a different author list generation using the
1427
``--authors`` command line switch, as represented by the
1428
``author_list_handler`` constructor argument, that value takes
1431
:param rev: The revision for which to generate the list of authors.
1432
:param who: Name of the default handler.
1433
:param short: Whether to shorten names to either name or address.
1434
:param sep: What separator to use for automatic concatenation.
1436
if self._author_list_handler is not None:
1437
# The user did specify --authors, which overrides the default
1438
author_list_handler = self._author_list_handler
1440
# The user didn't specify --authors, so we use the caller's default
1441
author_list_handler = author_list_registry.get(who)
1442
names = author_list_handler(rev)
1444
for i in range(len(names)):
1445
name, address = config.parse_username(names[i])
1451
names = sep.join(names)
1353
name, address = config.parse_username(rev.get_apparent_authors()[0])
1454
1358
def merge_marker(self, revision):
1455
1359
"""Get the merge marker to include in the output or '' if none."""
1465
1369
If a registered handler raises an error it is propagated.
1467
for line in self.custom_properties(revision):
1468
self.to_file.write("%s%s\n" % (indent, line))
1470
def custom_properties(self, revision):
1471
"""Format the custom properties returned by each registered handler.
1473
If a registered handler raises an error it is propagated.
1475
:return: a list of formatted lines (excluding trailing newlines)
1477
lines = self._foreign_info_properties(revision)
1478
1371
for key, handler in properties_handler_registry.iteritems():
1479
lines.extend(self._format_properties(handler(revision)))
1482
def _foreign_info_properties(self, rev):
1483
"""Custom log displayer for foreign revision identifiers.
1485
:param rev: Revision object.
1487
# Revision comes directly from a foreign repository
1488
if isinstance(rev, foreign.ForeignRevision):
1489
return self._format_properties(
1490
rev.mapping.vcs.show_foreign_revid(rev.foreign_revid))
1492
# Imported foreign revision revision ids always contain :
1493
if not ":" in rev.revision_id:
1496
# Revision was once imported from a foreign repository
1498
foreign_revid, mapping = \
1499
foreign.foreign_vcs_registry.parse_revision_id(rev.revision_id)
1500
except errors.InvalidRevisionId:
1503
return self._format_properties(
1504
mapping.vcs.show_foreign_revid(foreign_revid))
1506
def _format_properties(self, properties):
1508
for key, value in properties.items():
1509
lines.append(key + ': ' + value)
1372
for key, value in handler(revision).items():
1373
self.to_file.write(indent + key + ': ' + value + '\n')
1512
1375
def show_diff(self, to_file, diff, indent):
1513
1376
for l in diff.rstrip().split('\n'):
1514
1377
to_file.write(indent + '%s\n' % (l,))
1517
# Separator between revisions in long format
1518
_LONG_SEP = '-' * 60
1521
1380
class LongLogFormatter(LogFormatter):
1523
1382
supports_merge_revisions = True
1526
1385
supports_tags = True
1527
1386
supports_diff = True
1529
def __init__(self, *args, **kwargs):
1530
super(LongLogFormatter, self).__init__(*args, **kwargs)
1531
if self.show_timezone == 'original':
1532
self.date_string = self._date_string_original_timezone
1534
self.date_string = self._date_string_with_timezone
1536
def _date_string_with_timezone(self, rev):
1537
return format_date(rev.timestamp, rev.timezone or 0,
1540
def _date_string_original_timezone(self, rev):
1541
return format_date_with_offset_in_original_timezone(rev.timestamp,
1544
1388
def log_revision(self, revision):
1545
1389
"""Log a revision, either merged or not."""
1546
1390
indent = ' ' * revision.merge_depth
1391
to_file = self.to_file
1392
to_file.write(indent + '-' * 60 + '\n')
1548
1393
if revision.revno is not None:
1549
lines.append('revno: %s%s' % (revision.revno,
1394
to_file.write(indent + 'revno: %s%s\n' % (revision.revno,
1550
1395
self.merge_marker(revision)))
1551
1396
if revision.tags:
1552
lines.append('tags: %s' % (', '.join(revision.tags)))
1397
to_file.write(indent + 'tags: %s\n' % (', '.join(revision.tags)))
1553
1398
if self.show_ids:
1554
lines.append('revision-id: %s' % (revision.rev.revision_id,))
1399
to_file.write(indent + 'revision-id: ' + revision.rev.revision_id)
1555
1401
for parent_id in revision.rev.parent_ids:
1556
lines.append('parent: %s' % (parent_id,))
1557
lines.extend(self.custom_properties(revision.rev))
1402
to_file.write(indent + 'parent: %s\n' % (parent_id,))
1403
self.show_properties(revision.rev, indent)
1559
1405
committer = revision.rev.committer
1560
authors = self.authors(revision.rev, 'all')
1406
authors = revision.rev.get_apparent_authors()
1561
1407
if authors != [committer]:
1562
lines.append('author: %s' % (", ".join(authors),))
1563
lines.append('committer: %s' % (committer,))
1408
to_file.write(indent + 'author: %s\n' % (", ".join(authors),))
1409
to_file.write(indent + 'committer: %s\n' % (committer,))
1565
1411
branch_nick = revision.rev.properties.get('branch-nick', None)
1566
1412
if branch_nick is not None:
1567
lines.append('branch nick: %s' % (branch_nick,))
1569
lines.append('timestamp: %s' % (self.date_string(revision.rev),))
1571
lines.append('message:')
1413
to_file.write(indent + 'branch nick: %s\n' % (branch_nick,))
1415
date_str = format_date(revision.rev.timestamp,
1416
revision.rev.timezone or 0,
1418
to_file.write(indent + 'timestamp: %s\n' % (date_str,))
1420
to_file.write(indent + 'message:\n')
1572
1421
if not revision.rev.message:
1573
lines.append(' (no message)')
1422
to_file.write(indent + ' (no message)\n')
1575
1424
message = revision.rev.message.rstrip('\r\n')
1576
1425
for l in message.split('\n'):
1577
lines.append(' %s' % (l,))
1579
# Dump the output, appending the delta and diff if requested
1580
to_file = self.to_file
1581
to_file.write("%s%s\n" % (indent, ('\n' + indent).join(lines)))
1426
to_file.write(indent + ' %s\n' % (l,))
1582
1427
if revision.delta is not None:
1583
# Use the standard status output to display changes
1584
from bzrlib.delta import report_delta
1585
report_delta(to_file, revision.delta, short_status=False,
1586
show_ids=self.show_ids, indent=indent)
1428
# We don't respect delta_format for compatibility
1429
revision.delta.show(to_file, self.show_ids, indent=indent,
1587
1431
if revision.diff is not None:
1588
1432
to_file.write(indent + 'diff:\n')
1590
1433
# Note: we explicitly don't indent the diff (relative to the
1591
1434
# revision information) so that the output can be fed to patch -p0
1592
1435
self.show_diff(self.to_exact_file, revision.diff, indent)
1593
self.to_exact_file.flush()
1595
1437
def get_advice_separator(self):
1596
1438
"""Get the text separating the log from the closing advice."""
1652
1494
to_file.write(indent + offset + '%s\n' % (l,))
1654
1496
if revision.delta is not None:
1655
# Use the standard status output to display changes
1656
from bzrlib.delta import report_delta
1657
report_delta(to_file, revision.delta,
1658
short_status=self.delta_format==1,
1659
show_ids=self.show_ids, indent=indent + offset)
1497
revision.delta.show(to_file, self.show_ids, indent=indent + offset,
1498
short_status=self.delta_format==1)
1660
1499
if revision.diff is not None:
1661
1500
self.show_diff(self.to_exact_file, revision.diff, ' ')
1662
1501
to_file.write('\n')
1809
1643
raise errors.BzrCommandError("unknown log formatter: %r" % name)
1812
def author_list_all(rev):
1813
return rev.get_apparent_authors()[:]
1816
def author_list_first(rev):
1817
lst = rev.get_apparent_authors()
1824
def author_list_committer(rev):
1825
return [rev.committer]
1828
author_list_registry = registry.Registry()
1830
author_list_registry.register('all', author_list_all,
1833
author_list_registry.register('first', author_list_first,
1836
author_list_registry.register('committer', author_list_committer,
1840
1646
def show_one_log(revno, rev, delta, verbose, to_file, show_timezone):
1841
1647
# deprecated; for compatibility
1842
1648
lf = LongLogFormatter(to_file=to_file, show_timezone=show_timezone)
2003
1809
:param file_list: the list of paths given on the command line;
2004
1810
the first of these can be a branch location or a file path,
2005
1811
the remainder must be file paths
2006
:param add_cleanup: When the branch returned is read locked,
2007
an unlock call will be queued to the cleanup.
2008
1812
:return: (branch, info_list, start_rev_info, end_rev_info) where
2009
1813
info_list is a list of (relative_path, file_id, kind) tuples where
2010
1814
kind is one of values 'directory', 'file', 'symlink', 'tree-reference'.
2011
branch will be read-locked.
2013
1816
from builtins import _get_revision_range, safe_relpath_files
2014
1817
tree, b, path = bzrdir.BzrDir.open_containing_tree_or_branch(file_list[0])
2015
add_cleanup(b.lock_read().unlock)
2016
1818
# XXX: It's damn messy converting a list of paths to relative paths when
2017
1819
# those paths might be deleted ones, they might be on a case-insensitive
2018
1820
# filesystem and/or they might be in silly locations (like another branch).
2098
1898
properties_handler_registry = registry.Registry()
2100
# Use the properties handlers to print out bug information if available
2101
def _bugs_properties_handler(revision):
2102
if revision.properties.has_key('bugs'):
2103
bug_lines = revision.properties['bugs'].split('\n')
2104
bug_rows = [line.split(' ', 1) for line in bug_lines]
2105
fixed_bug_urls = [row[0] for row in bug_rows if
2106
len(row) > 1 and row[1] == 'fixed']
2109
return {'fixes bug(s)': ' '.join(fixed_bug_urls)}
2112
properties_handler_registry.register('bugs_properties_handler',
2113
_bugs_properties_handler)
1899
properties_handler_registry.register_lazy("foreign",
1901
"show_foreign_properties")
2116
1904
# adapters which revision ids to log are filtered. When log is called, the
added
removed
bzrlib/log.py
