309
318
if self.config is None:
310
319
self.config = self.branch.get_config()
312
# If provided, ensure the specified files are versioned
313
if self.specific_files is not None:
314
# Note: This routine is being called because it raises
315
# PathNotVersionedError as a side effect of finding the IDs. We
316
# later use the ids we found as input to the working tree
317
# inventory iterator, so we only consider those ids rather than
318
# examining the whole tree again.
319
# XXX: Dont we have filter_unversioned to do this more
321
self.specific_file_ids = tree.find_ids_across_trees(
322
specific_files, [self.basis_tree, self.work_tree])
321
self._set_specific_file_ids()
324
323
# Setup the progress bar. As the number of files that need to be
325
324
# committed in unknown, progress is reported as stages.
430
426
# The initial commit adds a root directory, but this in itself is not
431
427
# a worthwhile commit.
432
428
if (self.basis_revid == revision.NULL_REVISION and
433
len(self.builder.new_inventory) == 1):
429
((self.builder.new_inventory is not None and
430
len(self.builder.new_inventory) == 1) or
431
len(self.builder._basis_delta) == 1)):
434
432
raise PointlessCommit()
435
# If length == 1, then we only have the root entry. Which means
436
# that there is no real difference (only the root could be different)
437
# unless deletes occured, in which case the length is irrelevant.
438
if (self.any_entries_deleted or
439
(len(self.builder.new_inventory) != 1 and
440
self.builder.any_changes())):
433
if self.builder.any_changes():
442
435
raise PointlessCommit()
615
608
# serialiser not by commit. Then we can also add an unescaper
616
609
# in the deserializer and start roundtripping revision messages
617
610
# precisely. See repository_implementations/test_repository.py
619
# Python strings can include characters that can't be
620
# represented in well-formed XML; escape characters that
621
# aren't listed in the XML specification
622
# (http://www.w3.org/TR/REC-xml/#NT-Char).
623
self.message, escape_count = re.subn(
624
u'[^\x09\x0A\x0D\u0020-\uD7FF\uE000-\uFFFD]+',
625
lambda match: match.group(0).encode('unicode_escape'),
611
self.message, escape_count = xml_serializer.escape_invalid_chars(
628
614
self.reporter.escaped(escape_count, self.message)
644
632
def _update_builder_with_changes(self):
645
633
"""Update the commit builder with the data about what has changed.
647
# Build the revision inventory.
649
# This starts by creating a new empty inventory. Depending on
650
# which files are selected for commit, and what is present in the
651
# current tree, the new inventory is populated. inventory entries
652
# which are candidates for modification have their revision set to
653
# None; inventory entries that are carried over untouched have their
654
# revision set to their prior value.
656
# ESEPARATIONOFCONCERNS: this function is diffing and using the diff
657
# results to create a new inventory at the same time, which results
658
# in bugs like #46635. Any reason not to use/enhance Tree.changes_from?
661
635
exclude = self.exclude
662
636
specific_files = self.specific_files or []
663
637
mutter("Selecting files for commit with filter %s", specific_files)
665
# Build the new inventory
666
self._populate_from_inventory()
640
if self.use_record_iter_changes:
641
iter_changes = self.work_tree.iter_changes(self.basis_tree)
642
iter_changes = self._filter_iter_changes(iter_changes)
643
for file_id, path, fs_hash in self.builder.record_iter_changes(
644
self.work_tree, self.basis_revid, iter_changes):
645
self.work_tree._observed_sha1(file_id, path, fs_hash)
647
# Build the new inventory
648
self._populate_from_inventory()
649
self._record_unselected()
650
self._report_and_accumulate_deletes()
652
def _filter_iter_changes(self, iter_changes):
653
"""Process iter_changes.
655
This method reports on the changes in iter_changes to the user, and
656
converts 'missing' entries in the iter_changes iterator to 'deleted'
657
entries. 'missing' entries have their
659
:param iter_changes: An iter_changes to process.
660
:return: A generator of changes.
662
reporter = self.reporter
663
report_changes = reporter.is_verbose()
665
for change in iter_changes:
667
old_path = change[1][0]
668
new_path = change[1][1]
669
versioned = change[3][1]
671
versioned = change[3][1]
672
if kind is None and versioned:
675
reporter.missing(new_path)
676
deleted_ids.append(change[0])
677
# Reset the new path (None) and new versioned flag (False)
678
change = (change[0], (change[1][0], None), change[2],
679
(change[3][0], False)) + change[4:]
680
elif kind == 'tree-reference':
681
if self.recursive == 'down':
682
self._commit_nested_tree(change[0], change[1][1])
683
if change[3][0] or change[3][1]:
687
reporter.deleted(old_path)
688
elif old_path is None:
689
reporter.snapshot_change('added', new_path)
690
elif old_path != new_path:
691
reporter.renamed('renamed', old_path, new_path)
694
self.work_tree.branch.repository._format.rich_root_data):
695
# Don't report on changes to '' in non rich root
697
reporter.snapshot_change('modified', new_path)
698
self._next_progress_entry()
699
# Unversion IDs that were found to be deleted
700
self.work_tree.unversion(deleted_ids)
702
def _record_unselected(self):
668
703
# If specific files are selected, then all un-selected files must be
669
704
# recorded in their previous state. For more details, see
670
705
# https://lists.ubuntu.com/archives/bazaar/2007q3/028476.html.
671
if specific_files or exclude:
706
if self.specific_files or self.exclude:
707
specific_files = self.specific_files or []
672
708
for path, old_ie in self.basis_inv.iter_entries():
673
709
if old_ie.file_id in self.builder.new_inventory:
674
710
# already added - skip.
676
712
if (is_inside_any(specific_files, path)
677
and not is_inside_any(exclude, path)):
713
and not is_inside_any(self.exclude, path)):
678
714
# was inside the selected path, and not excluded - if not
679
715
# present it has been deleted so skip.
681
717
# From here down it was either not selected, or was excluded:
682
if old_ie.kind == 'directory':
683
self._next_progress_entry()
684
718
# We preserve the entry unaltered.
685
719
ie = old_ie.copy()
686
720
# Note: specific file commits after a merge are currently
717
749
self.builder.record_delete(path, file_id)
718
750
self.reporter.deleted(path)
720
def _populate_from_inventory(self):
721
"""Populate the CommitBuilder by walking the working tree inventory."""
752
def _check_strict(self):
753
# XXX: when we use iter_changes this would likely be faster if
754
# iter_changes would check for us (even in the presence of
723
757
# raise an exception as soon as we find a single unknown.
724
758
for unknown in self.work_tree.unknowns():
725
759
raise StrictCommitFailed()
761
def _populate_from_inventory(self):
762
"""Populate the CommitBuilder by walking the working tree inventory."""
763
# Build the revision inventory.
765
# This starts by creating a new empty inventory. Depending on
766
# which files are selected for commit, and what is present in the
767
# current tree, the new inventory is populated. inventory entries
768
# which are candidates for modification have their revision set to
769
# None; inventory entries that are carried over untouched have their
770
# revision set to their prior value.
772
# ESEPARATIONOFCONCERNS: this function is diffing and using the diff
773
# results to create a new inventory at the same time, which results
774
# in bugs like #46635. Any reason not to use/enhance Tree.changes_from?
727
777
specific_files = self.specific_files
728
778
exclude = self.exclude
729
779
report_changes = self.reporter.is_verbose()
874
923
InventoryEntry.MODIFIED_AND_RENAMED):
875
924
old_path = self.basis_inv.id2path(ie.file_id)
876
925
self.reporter.renamed(change, old_path, path)
926
self._next_progress_entry()
928
if change == 'unchanged':
878
930
self.reporter.snapshot_change(change, path)
931
self._next_progress_entry()
880
def _set_progress_stage(self, name, entries_title=None):
933
def _set_progress_stage(self, name, counter=False):
881
934
"""Set the progress stage and emit an update to the progress bar."""
882
935
self.pb_stage_name = name
883
936
self.pb_stage_count += 1
884
self.pb_entries_title = entries_title
885
if entries_title is not None:
886
938
self.pb_entries_count = 0
887
self.pb_entries_total = '?'
940
self.pb_entries_count = None
888
941
self._emit_progress()
890
943
def _next_progress_entry(self):
893
946
self._emit_progress()
895
948
def _emit_progress(self):
896
if self.pb_entries_title:
897
if self.pb_entries_total == '?':
898
text = "%s [%s %d] - Stage" % (self.pb_stage_name,
899
self.pb_entries_title, self.pb_entries_count)
901
text = "%s [%s %d/%s] - Stage" % (self.pb_stage_name,
902
self.pb_entries_title, self.pb_entries_count,
903
str(self.pb_entries_total))
949
if self.pb_entries_count is not None:
950
text = "%s [%d] - Stage" % (self.pb_stage_name,
951
self.pb_entries_count)
905
text = "%s - Stage" % (self.pb_stage_name)
953
text = "%s - Stage" % (self.pb_stage_name, )
906
954
self.pb.update(text, self.pb_stage_count, self.pb_stage_total)
956
def _set_specific_file_ids(self):
957
"""populate self.specific_file_ids if we will use it."""
958
if not self.use_record_iter_changes:
959
# If provided, ensure the specified files are versioned
960
if self.specific_files is not None:
961
# Note: This routine is being called because it raises
962
# PathNotVersionedError as a side effect of finding the IDs. We
963
# later use the ids we found as input to the working tree
964
# inventory iterator, so we only consider those ids rather than
965
# examining the whole tree again.
966
# XXX: Dont we have filter_unversioned to do this more
968
self.specific_file_ids = tree.find_ids_across_trees(
969
self.specific_files, [self.basis_tree, self.work_tree])
971
self.specific_file_ids = None