/brz/remove-bazaar

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

« back to all changes in this revision

Viewing changes to breezy/commit.py

  • Committer: Vincent Ladeuil
  • Date: 2019-06-18 11:21:15 UTC
  • mfrom: (7290.1.31 work)
  • mto: This revision was merged to the branch mainline in revision 7351.
  • Revision ID: v.ladeuil+brz@free.fr-20190618112115-578pnbegj3bnc6pa
Merge 3.0 resolving conflicts.

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005-2010 Canonical Ltd
 
1
# Copyright (C) 2005-2011 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
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
16
16
 
 
17
from __future__ import absolute_import
17
18
 
18
19
# The newly committed revision is going to have a shape corresponding
19
20
# to that of the working tree.  Files that are not in the
49
50
# TODO: Change the parameter 'rev_id' to 'revision_id' to be consistent with
50
51
# the rest of the code; add a deprecation of the old name.
51
52
 
52
 
from bzrlib import (
 
53
from . import (
53
54
    debug,
54
55
    errors,
55
 
    revision,
56
56
    trace,
57
 
    tree,
 
57
    ui,
58
58
    )
59
 
from bzrlib.branch import Branch
60
 
from bzrlib.cleanup import OperationWithCleanups
61
 
import bzrlib.config
62
 
from bzrlib.errors import (BzrError, PointlessCommit,
63
 
                           ConflictsInTree,
64
 
                           StrictCommitFailed
65
 
                           )
66
 
from bzrlib.osutils import (get_user_encoding,
67
 
                            is_inside_any,
68
 
                            minimum_path_selection,
69
 
                            splitpath,
70
 
                            )
71
 
from bzrlib.trace import mutter, note, is_quiet
72
 
from bzrlib.inventory import Inventory, InventoryEntry, make_entry
73
 
from bzrlib import symbol_versioning
74
 
from bzrlib.urlutils import unescape_for_display
75
 
import bzrlib.ui
 
59
from .branch import Branch
 
60
from .cleanup import OperationWithCleanups
 
61
import breezy.config
 
62
from .errors import (BzrError,
 
63
                     ConflictsInTree,
 
64
                     StrictCommitFailed
 
65
                     )
 
66
from .osutils import (get_user_encoding,
 
67
                      has_symlinks,
 
68
                      is_inside_any,
 
69
                      minimum_path_selection,
 
70
                      )
 
71
from .trace import mutter, note, is_quiet
 
72
from .tree import TreeChange
 
73
from .urlutils import unescape_for_display
 
74
from .i18n import gettext
 
75
 
 
76
 
 
77
class PointlessCommit(BzrError):
 
78
 
 
79
    _fmt = "No changes to commit"
 
80
 
 
81
 
 
82
class CannotCommitSelectedFileMerge(BzrError):
 
83
 
 
84
    _fmt = 'Selected-file commit of merges is not supported yet:'\
 
85
        ' files %(files_str)s'
 
86
 
 
87
    def __init__(self, files):
 
88
        files_str = ', '.join(files)
 
89
        BzrError.__init__(self, files=files, files_str=files_str)
 
90
 
 
91
 
 
92
def filter_excluded(iter_changes, exclude):
 
93
    """Filter exclude filenames.
 
94
 
 
95
    :param iter_changes: iter_changes function
 
96
    :param exclude: List of paths to exclude
 
97
    :return: iter_changes function
 
98
    """
 
99
    for change in iter_changes:
 
100
        new_excluded = (change.path[1] is not None and
 
101
                        is_inside_any(exclude, change.path[1]))
 
102
 
 
103
        old_excluded = (change.path[0] is not None and
 
104
                        is_inside_any(exclude, change.path[0]))
 
105
 
 
106
        if old_excluded and new_excluded:
 
107
            continue
 
108
 
 
109
        if old_excluded or new_excluded:
 
110
            # TODO(jelmer): Perhaps raise an error here instead?
 
111
            continue
 
112
 
 
113
        yield change
76
114
 
77
115
 
78
116
class NullCommitReporter(object):
79
117
    """I report on progress of a commit."""
80
118
 
81
 
    def started(self, revno, revid, location=None):
82
 
        if location is None:
83
 
            symbol_versioning.warn("As of bzr 1.0 you must pass a location "
84
 
                                   "to started.", DeprecationWarning,
85
 
                                   stacklevel=2)
 
119
    def started(self, revno, revid, location):
86
120
        pass
87
121
 
88
122
    def snapshot_change(self, change, path):
114
148
        note(format, *args)
115
149
 
116
150
    def snapshot_change(self, change, path):
117
 
        if path == '' and change in ('added', 'modified'):
 
151
        if path == '' and change in (gettext('added'), gettext('modified')):
118
152
            return
119
153
        self._note("%s %s", change, path)
120
154
 
121
 
    def started(self, revno, rev_id, location=None):
122
 
        if location is not None:
123
 
            location = ' to: ' + unescape_for_display(location, 'utf-8')
124
 
        else:
125
 
            # When started was added, location was only made optional by
126
 
            # accident.  Matt Nordhoff 20071129
127
 
            symbol_versioning.warn("As of bzr 1.0 you must pass a location "
128
 
                                   "to started.", DeprecationWarning,
129
 
                                   stacklevel=2)
130
 
            location = ''
131
 
        self._note('Committing%s', location)
 
155
    def started(self, revno, rev_id, location):
 
156
        self._note(
 
157
            gettext('Committing to: %s'),
 
158
            unescape_for_display(location, 'utf-8'))
132
159
 
133
160
    def completed(self, revno, rev_id):
134
 
        self._note('Committed revision %d.', revno)
 
161
        self._note(gettext('Committed revision %d.'), revno)
135
162
        # self._note goes to the console too; so while we want to log the
136
163
        # rev_id, we can't trivially only log it. (See bug 526425). Long
137
164
        # term we should rearrange the reporting structure, but for now
140
167
        mutter('Committed revid %s as revno %d.', rev_id, revno)
141
168
 
142
169
    def deleted(self, path):
143
 
        self._note('deleted %s', path)
 
170
        self._note(gettext('deleted %s'), path)
144
171
 
145
172
    def missing(self, path):
146
 
        self._note('missing %s', path)
 
173
        self._note(gettext('missing %s'), path)
147
174
 
148
175
    def renamed(self, change, old_path, new_path):
149
176
        self._note('%s %s => %s', change, old_path, new_path)
164
191
            the working directory; these should be removed from the
165
192
            working inventory.
166
193
    """
 
194
 
167
195
    def __init__(self,
168
196
                 reporter=None,
169
 
                 config=None):
 
197
                 config_stack=None):
170
198
        """Create a Commit object.
171
199
 
172
200
        :param reporter: the default reporter to use or None to decide later
173
201
        """
174
202
        self.reporter = reporter
175
 
        self.config = config
 
203
        self.config_stack = config_stack
 
204
 
 
205
    @staticmethod
 
206
    def update_revprops(revprops, branch, authors=None,
 
207
                        local=False, possible_master_transports=None):
 
208
        if revprops is None:
 
209
            revprops = {}
 
210
        if possible_master_transports is None:
 
211
            possible_master_transports = []
 
212
        if (u'branch-nick' not in revprops and
 
213
                branch.repository._format.supports_storing_branch_nick):
 
214
            revprops[u'branch-nick'] = branch._get_nick(
 
215
                local,
 
216
                possible_master_transports)
 
217
        if authors is not None:
 
218
            if u'author' in revprops or u'authors' in revprops:
 
219
                # XXX: maybe we should just accept one of them?
 
220
                raise AssertionError('author property given twice')
 
221
            if authors:
 
222
                for individual in authors:
 
223
                    if '\n' in individual:
 
224
                        raise AssertionError('\\n is not a valid character '
 
225
                                             'in an author identity')
 
226
                revprops[u'authors'] = '\n'.join(authors)
 
227
        return revprops
176
228
 
177
229
    def commit(self,
178
230
               message=None,
192
244
               message_callback=None,
193
245
               recursive='down',
194
246
               exclude=None,
195
 
               possible_master_transports=None):
 
247
               possible_master_transports=None,
 
248
               lossy=False):
196
249
        """Commit working copy as a new revision.
197
250
 
198
251
        :param message: the commit message (it or message_callback is required)
199
 
        :param message_callback: A callback: message = message_callback(cmt_obj)
 
252
        :param message_callback: A callback: message =
 
253
            message_callback(cmt_obj)
200
254
 
201
255
        :param timestamp: if not None, seconds-since-epoch for a
202
256
            postdated/predated commit.
225
279
        :param exclude: None or a list of relative paths to exclude from the
226
280
            commit. Pending changes to excluded files will be ignored by the
227
281
            commit.
 
282
        :param lossy: When committing to a foreign VCS, ignore any
 
283
            data that can not be natively represented.
228
284
        """
229
285
        operation = OperationWithCleanups(self._commit)
230
286
        self.revprops = revprops or {}
231
287
        # XXX: Can be set on __init__ or passed in - this is a bit ugly.
232
 
        self.config = config or self.config
 
288
        self.config_stack = config or self.config_stack
233
289
        return operation.run(
234
 
               message=message,
235
 
               timestamp=timestamp,
236
 
               timezone=timezone,
237
 
               committer=committer,
238
 
               specific_files=specific_files,
239
 
               rev_id=rev_id,
240
 
               allow_pointless=allow_pointless,
241
 
               strict=strict,
242
 
               verbose=verbose,
243
 
               working_tree=working_tree,
244
 
               local=local,
245
 
               reporter=reporter,
246
 
               message_callback=message_callback,
247
 
               recursive=recursive,
248
 
               exclude=exclude,
249
 
               possible_master_transports=possible_master_transports)
 
290
            message=message,
 
291
            timestamp=timestamp,
 
292
            timezone=timezone,
 
293
            committer=committer,
 
294
            specific_files=specific_files,
 
295
            rev_id=rev_id,
 
296
            allow_pointless=allow_pointless,
 
297
            strict=strict,
 
298
            verbose=verbose,
 
299
            working_tree=working_tree,
 
300
            local=local,
 
301
            reporter=reporter,
 
302
            message_callback=message_callback,
 
303
            recursive=recursive,
 
304
            exclude=exclude,
 
305
            possible_master_transports=possible_master_transports,
 
306
            lossy=lossy)
250
307
 
251
308
    def _commit(self, operation, message, timestamp, timezone, committer,
252
 
            specific_files, rev_id, allow_pointless, strict, verbose,
253
 
            working_tree, local, reporter, message_callback, recursive,
254
 
            exclude, possible_master_transports):
 
309
                specific_files, rev_id, allow_pointless, strict, verbose,
 
310
                working_tree, local, reporter, message_callback, recursive,
 
311
                exclude, possible_master_transports, lossy):
255
312
        mutter('preparing to commit')
256
313
 
257
314
        if working_tree is None:
264
321
                    raise errors.RootNotRich()
265
322
        if message_callback is None:
266
323
            if message is not None:
267
 
                if isinstance(message, str):
 
324
                if isinstance(message, bytes):
268
325
                    message = message.decode(get_user_encoding())
269
 
                message_callback = lambda x: message
 
326
 
 
327
                def message_callback(x):
 
328
                    return message
270
329
            else:
271
330
                raise BzrError("The message or message_callback keyword"
272
331
                               " parameter is required for commit().")
289
348
                minimum_path_selection(specific_files))
290
349
        else:
291
350
            self.specific_files = None
292
 
            
 
351
 
293
352
        self.allow_pointless = allow_pointless
294
353
        self.message_callback = message_callback
295
354
        self.timestamp = timestamp
301
360
        self.work_tree.lock_write()
302
361
        operation.add_cleanup(self.work_tree.unlock)
303
362
        self.parents = self.work_tree.get_parent_ids()
304
 
        # We can use record_iter_changes IFF iter_changes is compatible with
305
 
        # the command line parameters, and the repository has fast delta
306
 
        # generation. See bug 347649.
307
 
        self.use_record_iter_changes = (
308
 
            not self.exclude and 
309
 
            not self.branch.repository._format.supports_tree_reference and
310
 
            (self.branch.repository._format.fast_deltas or
311
 
             len(self.parents) < 2))
312
 
        self.pb = bzrlib.ui.ui_factory.nested_progress_bar()
 
363
        self.pb = ui.ui_factory.nested_progress_bar()
313
364
        operation.add_cleanup(self.pb.finished)
314
365
        self.basis_revid = self.work_tree.last_revision()
315
366
        self.basis_tree = self.work_tree.basis_tree()
323
374
        self._check_bound_branch(operation, possible_master_transports)
324
375
 
325
376
        # Check that the working tree is up to date
326
 
        old_revno, new_revno = self._check_out_of_date_tree()
 
377
        old_revno, old_revid, new_revno = self._check_out_of_date_tree()
327
378
 
328
379
        # Complete configuration setup
329
380
        if reporter is not None:
330
381
            self.reporter = reporter
331
382
        elif self.reporter is None:
332
383
            self.reporter = self._select_reporter()
333
 
        if self.config is None:
334
 
            self.config = self.branch.get_config()
335
 
 
336
 
        self._set_specific_file_ids()
 
384
        if self.config_stack is None:
 
385
            self.config_stack = self.work_tree.get_config_stack()
337
386
 
338
387
        # Setup the progress bar. As the number of files that need to be
339
388
        # committed in unknown, progress is reported as stages.
343
392
        self.pb_stage_count = 0
344
393
        self.pb_stage_total = 5
345
394
        if self.bound_branch:
346
 
            self.pb_stage_total += 1
 
395
            # 2 extra stages: "Uploading data to master branch" and "Merging
 
396
            # tags to master branch"
 
397
            self.pb_stage_total += 2
347
398
        self.pb.show_pct = False
348
399
        self.pb.show_spinner = False
349
400
        self.pb.show_eta = False
350
401
        self.pb.show_count = True
351
402
        self.pb.show_bar = True
352
403
 
353
 
        self._gather_parents()
354
404
        # After a merge, a selected file commit is not supported.
355
405
        # See 'bzr help merge' for an explanation as to why.
356
406
        if len(self.parents) > 1 and self.specific_files is not None:
357
 
            raise errors.CannotCommitSelectedFileMerge(self.specific_files)
 
407
            raise CannotCommitSelectedFileMerge(self.specific_files)
358
408
        # Excludes are a form of selected file commit.
359
409
        if len(self.parents) > 1 and self.exclude:
360
 
            raise errors.CannotCommitSelectedFileMerge(self.exclude)
 
410
            raise CannotCommitSelectedFileMerge(self.exclude)
361
411
 
362
412
        # Collect the changes
363
413
        self._set_progress_stage("Collecting changes", counter=True)
364
 
        self.builder = self.branch.get_commit_builder(self.parents,
365
 
            self.config, timestamp, timezone, committer, self.revprops, rev_id)
 
414
        self._lossy = lossy
 
415
        self.builder = self.branch.get_commit_builder(
 
416
            self.parents, self.config_stack, timestamp, timezone, committer,
 
417
            self.revprops, rev_id, lossy=lossy)
 
418
 
 
419
        if self.builder.updates_branch and self.bound_branch:
 
420
            self.builder.abort()
 
421
            raise AssertionError(
 
422
                "bound branches not supported for commit builders "
 
423
                "that update the branch")
366
424
 
367
425
        try:
368
 
            self.builder.will_record_deletes()
369
426
            # find the location being committed to
370
427
            if self.bound_branch:
371
428
                master_location = self.master_branch.base
392
449
            # Add revision data to the local branch
393
450
            self.rev_id = self.builder.commit(self.message)
394
451
 
395
 
        except Exception, e:
 
452
        except Exception:
396
453
            mutter("aborting commit write group because of exception:")
397
454
            trace.log_exception_quietly()
398
 
            note("aborting commit write group: %r" % (e,))
399
455
            self.builder.abort()
400
456
            raise
401
457
 
402
 
        self._process_pre_hooks(old_revno, new_revno)
403
 
 
404
 
        # Upload revision data to the master.
405
 
        # this will propagate merged revisions too if needed.
406
 
        if self.bound_branch:
407
 
            self._set_progress_stage("Uploading data to master branch")
408
 
            # 'commit' to the master first so a timeout here causes the
409
 
            # local branch to be out of date
410
 
            self.master_branch.import_last_revision_info(
411
 
                self.branch.repository, new_revno, self.rev_id)
412
 
 
413
 
        # and now do the commit locally.
414
 
        self.branch.set_last_revision_info(new_revno, self.rev_id)
 
458
        self._update_branches(old_revno, old_revid, new_revno)
415
459
 
416
460
        # Make the working tree be up to date with the branch. This
417
461
        # includes automatic changes scheduled to be made to the tree, such
418
462
        # as updating its basis and unversioning paths that were missing.
419
 
        self.work_tree.unversion(self.deleted_ids)
 
463
        self.work_tree.unversion(self.deleted_paths)
420
464
        self._set_progress_stage("Updating the working tree")
421
465
        self.work_tree.update_basis_by_delta(self.rev_id,
422
 
             self.builder.get_basis_delta())
 
466
                                             self.builder.get_basis_delta())
423
467
        self.reporter.completed(new_revno, self.rev_id)
424
468
        self._process_post_hooks(old_revno, new_revno)
425
469
        return self.rev_id
426
470
 
 
471
    def _update_branches(self, old_revno, old_revid, new_revno):
 
472
        """Update the master and local branch to the new revision.
 
473
 
 
474
        This will try to make sure that the master branch is updated
 
475
        before the local branch.
 
476
 
 
477
        :param old_revno: Revision number of master branch before the
 
478
            commit
 
479
        :param old_revid: Tip of master branch before the commit
 
480
        :param new_revno: Revision number of the new commit
 
481
        """
 
482
        if not self.builder.updates_branch:
 
483
            self._process_pre_hooks(old_revno, new_revno)
 
484
 
 
485
            # Upload revision data to the master.
 
486
            # this will propagate merged revisions too if needed.
 
487
            if self.bound_branch:
 
488
                self._set_progress_stage("Uploading data to master branch")
 
489
                # 'commit' to the master first so a timeout here causes the
 
490
                # local branch to be out of date
 
491
                (new_revno, self.rev_id) = self.master_branch.import_last_revision_info_and_tags(
 
492
                    self.branch, new_revno, self.rev_id, lossy=self._lossy)
 
493
                if self._lossy:
 
494
                    self.branch.fetch(self.master_branch, self.rev_id)
 
495
 
 
496
            # and now do the commit locally.
 
497
            self.branch.set_last_revision_info(new_revno, self.rev_id)
 
498
        else:
 
499
            try:
 
500
                self._process_pre_hooks(old_revno, new_revno)
 
501
            except BaseException:
 
502
                # The commit builder will already have updated the branch,
 
503
                # revert it.
 
504
                self.branch.set_last_revision_info(old_revno, old_revid)
 
505
                raise
 
506
 
 
507
        # Merge local tags to remote
 
508
        if self.bound_branch:
 
509
            self._set_progress_stage("Merging tags to master branch")
 
510
            tag_updates, tag_conflicts = self.branch.tags.merge_to(
 
511
                self.master_branch.tags)
 
512
            if tag_conflicts:
 
513
                warning_lines = ['    ' + name for name, _, _ in tag_conflicts]
 
514
                note(gettext("Conflicting tags in bound branch:\n{0}".format(
 
515
                    "\n".join(warning_lines))))
 
516
 
427
517
    def _select_reporter(self):
428
518
        """Select the CommitReporter to use."""
429
519
        if is_quiet():
436
526
        # A merge with no effect on files
437
527
        if len(self.parents) > 1:
438
528
            return
439
 
        # TODO: we could simplify this by using self.builder.basis_delta.
440
 
 
441
 
        # The initial commit adds a root directory, but this in itself is not
442
 
        # a worthwhile commit.
443
 
        if (self.basis_revid == revision.NULL_REVISION and
444
 
            ((self.builder.new_inventory is not None and
445
 
             len(self.builder.new_inventory) == 1) or
446
 
            len(self.builder._basis_delta) == 1)):
447
 
            raise PointlessCommit()
448
529
        if self.builder.any_changes():
449
530
            return
450
531
        raise PointlessCommit()
471
552
        # If the master branch is bound, we must fail
472
553
        master_bound_location = self.master_branch.get_bound_location()
473
554
        if master_bound_location:
474
 
            raise errors.CommitToDoubleBoundBranch(self.branch,
475
 
                    self.master_branch, master_bound_location)
 
555
            raise errors.CommitToDoubleBoundBranch(
 
556
                self.branch, self.master_branch, master_bound_location)
476
557
 
477
558
        # TODO: jam 20051230 We could automatically push local
478
559
        #       commits to the remote branch if they would fit.
480
561
        #       to local.
481
562
 
482
563
        # Make sure the local branch is identical to the master
483
 
        master_info = self.master_branch.last_revision_info()
484
 
        local_info = self.branch.last_revision_info()
485
 
        if local_info != master_info:
 
564
        master_revid = self.master_branch.last_revision()
 
565
        local_revid = self.branch.last_revision()
 
566
        if local_revid != master_revid:
486
567
            raise errors.BoundBranchOutOfDate(self.branch,
487
 
                    self.master_branch)
 
568
                                              self.master_branch)
488
569
 
489
570
        # Now things are ready to change the master branch
490
571
        # so grab the lock
495
576
    def _check_out_of_date_tree(self):
496
577
        """Check that the working tree is up to date.
497
578
 
498
 
        :return: old_revision_number,new_revision_number tuple
 
579
        :return: old_revision_number, old_revision_id, new_revision_number
 
580
            tuple
499
581
        """
500
582
        try:
501
583
            first_tree_parent = self.work_tree.get_parent_ids()[0]
504
586
            # this is so that we still consider the master branch
505
587
            # - in a checkout scenario the tree may have no
506
588
            # parents but the branch may do.
507
 
            first_tree_parent = bzrlib.revision.NULL_REVISION
508
 
        old_revno, master_last = self.master_branch.last_revision_info()
 
589
            first_tree_parent = breezy.revision.NULL_REVISION
 
590
        try:
 
591
            old_revno, master_last = self.master_branch.last_revision_info()
 
592
        except errors.UnsupportedOperation:
 
593
            master_last = self.master_branch.last_revision()
 
594
            old_revno = self.branch.revision_id_to_revno(master_last)
509
595
        if master_last != first_tree_parent:
510
 
            if master_last != bzrlib.revision.NULL_REVISION:
 
596
            if master_last != breezy.revision.NULL_REVISION:
511
597
                raise errors.OutOfDateTree(self.work_tree)
512
598
        if self.branch.repository.has_revision(first_tree_parent):
513
599
            new_revno = old_revno + 1
514
600
        else:
515
601
            # ghost parents never appear in revision history.
516
602
            new_revno = 1
517
 
        return old_revno,new_revno
 
603
        return old_revno, master_last, new_revno
518
604
 
519
605
    def _process_pre_hooks(self, old_revno, new_revno):
520
606
        """Process any registered pre commit hooks."""
526
612
        # Process the post commit hooks, if any
527
613
        self._set_progress_stage("Running post_commit hooks")
528
614
        # old style commit hooks - should be deprecated ? (obsoleted in
529
 
        # 0.15)
530
 
        if self.config.post_commit() is not None:
531
 
            hooks = self.config.post_commit().split(' ')
 
615
        # 0.15^H^H^H^H 2.5.0)
 
616
        post_commit = self.config_stack.get('post_commit')
 
617
        if post_commit is not None:
 
618
            hooks = post_commit.split(' ')
532
619
            # this would be nicer with twisted.python.reflect.namedAny
533
620
            for hook in hooks:
534
621
                result = eval(hook + '(branch, rev_id)',
535
 
                              {'branch':self.branch,
536
 
                               'bzrlib':bzrlib,
537
 
                               'rev_id':self.rev_id})
 
622
                              {'branch': self.branch,
 
623
                               'breezy': breezy,
 
624
                               'rev_id': self.rev_id})
538
625
        # process new style post commit hooks
539
626
        self._process_hooks("post_commit", old_revno, new_revno)
540
627
 
555
642
        if self.parents:
556
643
            old_revid = self.parents[0]
557
644
        else:
558
 
            old_revid = bzrlib.revision.NULL_REVISION
 
645
            old_revid = breezy.revision.NULL_REVISION
559
646
 
560
647
        if hook_name == "pre_commit":
561
648
            future_tree = self.builder.revision_tree()
562
649
            tree_delta = future_tree.changes_from(self.basis_tree,
563
 
                                             include_root=True)
 
650
                                                  include_root=True)
564
651
 
565
652
        for hook in Branch.hooks[hook_name]:
566
653
            # show the running hook in the progress bar. As hooks may
581
668
                     old_revno, old_revid, new_revno, self.rev_id,
582
669
                     tree_delta, future_tree)
583
670
 
584
 
    def _gather_parents(self):
585
 
        """Record the parents of a merge for merge detection."""
586
 
        # TODO: Make sure that this list doesn't contain duplicate
587
 
        # entries and the order is preserved when doing this.
588
 
        if self.use_record_iter_changes:
589
 
            return
590
 
        self.basis_inv = self.basis_tree.inventory
591
 
        self.parent_invs = [self.basis_inv]
592
 
        for revision in self.parents[1:]:
593
 
            if self.branch.repository.has_revision(revision):
594
 
                mutter('commit parent revision {%s}', revision)
595
 
                inventory = self.branch.repository.get_inventory(revision)
596
 
                self.parent_invs.append(inventory)
597
 
            else:
598
 
                mutter('commit parent ghost revision {%s}', revision)
599
 
 
600
671
    def _update_builder_with_changes(self):
601
672
        """Update the commit builder with the data about what has changed.
602
673
        """
603
 
        exclude = self.exclude
604
674
        specific_files = self.specific_files
605
 
        mutter("Selecting files for commit with filter %s", specific_files)
 
675
        mutter("Selecting files for commit with filter %r", specific_files)
606
676
 
607
677
        self._check_strict()
608
 
        if self.use_record_iter_changes:
609
 
            iter_changes = self.work_tree.iter_changes(self.basis_tree,
610
 
                specific_files=specific_files)
611
 
            iter_changes = self._filter_iter_changes(iter_changes)
612
 
            for file_id, path, fs_hash in self.builder.record_iter_changes(
 
678
        iter_changes = self.work_tree.iter_changes(
 
679
            self.basis_tree, specific_files=specific_files)
 
680
        if self.exclude:
 
681
            iter_changes = filter_excluded(iter_changes, self.exclude)
 
682
        iter_changes = self._filter_iter_changes(iter_changes)
 
683
        for path, fs_hash in self.builder.record_iter_changes(
613
684
                self.work_tree, self.basis_revid, iter_changes):
614
 
                self.work_tree._observed_sha1(file_id, path, fs_hash)
615
 
        else:
616
 
            # Build the new inventory
617
 
            self._populate_from_inventory()
618
 
            self._record_unselected()
619
 
            self._report_and_accumulate_deletes()
 
685
            self.work_tree._observed_sha1(path, fs_hash)
620
686
 
621
687
    def _filter_iter_changes(self, iter_changes):
622
688
        """Process iter_changes.
623
689
 
624
 
        This method reports on the changes in iter_changes to the user, and 
 
690
        This method reports on the changes in iter_changes to the user, and
625
691
        converts 'missing' entries in the iter_changes iterator to 'deleted'
626
692
        entries. 'missing' entries have their
627
693
 
630
696
        """
631
697
        reporter = self.reporter
632
698
        report_changes = reporter.is_verbose()
633
 
        deleted_ids = []
 
699
        deleted_paths = []
634
700
        for change in iter_changes:
635
701
            if report_changes:
636
 
                old_path = change[1][0]
637
 
                new_path = change[1][1]
638
 
                versioned = change[3][1]
639
 
            kind = change[6][1]
640
 
            versioned = change[3][1]
 
702
                old_path = change.path[0]
 
703
                new_path = change.path[1]
 
704
                versioned = change.versioned[1]
 
705
            kind = change.kind[1]
 
706
            versioned = change.versioned[1]
641
707
            if kind is None and versioned:
642
708
                # 'missing' path
643
709
                if report_changes:
644
710
                    reporter.missing(new_path)
645
 
                deleted_ids.append(change[0])
 
711
                if change.kind[0] == 'symlink' and not self.work_tree.supports_symlinks():
 
712
                    trace.warning('Ignoring "%s" as symlinks are not '
 
713
                                  'supported on this filesystem.' % (change.path[0],))
 
714
                    continue
 
715
                deleted_paths.append(change[1][1])
646
716
                # Reset the new path (None) and new versioned flag (False)
647
 
                change = (change[0], (change[1][0], None), change[2],
648
 
                    (change[3][0], False)) + change[4:]
 
717
                change = change.discard_new()
 
718
                new_path = change.path[1]
 
719
                versioned = False
649
720
            elif kind == 'tree-reference':
650
721
                if self.recursive == 'down':
651
 
                    self._commit_nested_tree(change[0], change[1][1])
652
 
            if change[3][0] or change[3][1]:
 
722
                    self._commit_nested_tree(change[1][1])
 
723
            if change.versioned[0] or change.versioned[1]:
653
724
                yield change
654
725
                if report_changes:
655
726
                    if new_path is None:
656
727
                        reporter.deleted(old_path)
657
728
                    elif old_path is None:
658
 
                        reporter.snapshot_change('added', new_path)
 
729
                        reporter.snapshot_change(gettext('added'), new_path)
659
730
                    elif old_path != new_path:
660
 
                        reporter.renamed('renamed', old_path, new_path)
 
731
                        reporter.renamed(gettext('renamed'),
 
732
                                         old_path, new_path)
661
733
                    else:
662
 
                        if (new_path or 
663
 
                            self.work_tree.branch.repository._format.rich_root_data):
 
734
                        if (new_path
 
735
                                or self.work_tree.branch.repository._format.rich_root_data):
664
736
                            # Don't report on changes to '' in non rich root
665
737
                            # repositories.
666
 
                            reporter.snapshot_change('modified', new_path)
 
738
                            reporter.snapshot_change(
 
739
                                gettext('modified'), new_path)
667
740
            self._next_progress_entry()
668
 
        # Unversion IDs that were found to be deleted
669
 
        self.deleted_ids = deleted_ids
670
 
 
671
 
    def _record_unselected(self):
672
 
        # If specific files are selected, then all un-selected files must be
673
 
        # recorded in their previous state. For more details, see
674
 
        # https://lists.ubuntu.com/archives/bazaar/2007q3/028476.html.
675
 
        if self.specific_files or self.exclude:
676
 
            specific_files = self.specific_files or []
677
 
            for path, old_ie in self.basis_inv.iter_entries():
678
 
                if old_ie.file_id in self.builder.new_inventory:
679
 
                    # already added - skip.
680
 
                    continue
681
 
                if (is_inside_any(specific_files, path)
682
 
                    and not is_inside_any(self.exclude, path)):
683
 
                    # was inside the selected path, and not excluded - if not
684
 
                    # present it has been deleted so skip.
685
 
                    continue
686
 
                # From here down it was either not selected, or was excluded:
687
 
                # We preserve the entry unaltered.
688
 
                ie = old_ie.copy()
689
 
                # Note: specific file commits after a merge are currently
690
 
                # prohibited. This test is for sanity/safety in case it's
691
 
                # required after that changes.
692
 
                if len(self.parents) > 1:
693
 
                    ie.revision = None
694
 
                self.builder.record_entry_contents(ie, self.parent_invs, path,
695
 
                    self.basis_tree, None)
696
 
 
697
 
    def _report_and_accumulate_deletes(self):
698
 
        if (isinstance(self.basis_inv, Inventory)
699
 
            and isinstance(self.builder.new_inventory, Inventory)):
700
 
            # the older Inventory classes provide a _byid dict, and building a
701
 
            # set from the keys of this dict is substantially faster than even
702
 
            # getting a set of ids from the inventory
703
 
            #
704
 
            # <lifeless> set(dict) is roughly the same speed as
705
 
            # set(iter(dict)) and both are significantly slower than
706
 
            # set(dict.keys())
707
 
            deleted_ids = set(self.basis_inv._byid.keys()) - \
708
 
               set(self.builder.new_inventory._byid.keys())
709
 
        else:
710
 
            deleted_ids = set(self.basis_inv) - set(self.builder.new_inventory)
711
 
        if deleted_ids:
712
 
            self.any_entries_deleted = True
713
 
            deleted = [(self.basis_tree.id2path(file_id), file_id)
714
 
                for file_id in deleted_ids]
715
 
            deleted.sort()
716
 
            # XXX: this is not quite directory-order sorting
717
 
            for path, file_id in deleted:
718
 
                self.builder.record_delete(path, file_id)
719
 
                self.reporter.deleted(path)
 
741
        # Unversion files that were found to be deleted
 
742
        self.deleted_paths = deleted_paths
720
743
 
721
744
    def _check_strict(self):
722
745
        # XXX: when we use iter_changes this would likely be faster if
727
750
            for unknown in self.work_tree.unknowns():
728
751
                raise StrictCommitFailed()
729
752
 
730
 
    def _populate_from_inventory(self):
731
 
        """Populate the CommitBuilder by walking the working tree inventory."""
732
 
        # Build the revision inventory.
733
 
        #
734
 
        # This starts by creating a new empty inventory. Depending on
735
 
        # which files are selected for commit, and what is present in the
736
 
        # current tree, the new inventory is populated. inventory entries
737
 
        # which are candidates for modification have their revision set to
738
 
        # None; inventory entries that are carried over untouched have their
739
 
        # revision set to their prior value.
740
 
        #
741
 
        # ESEPARATIONOFCONCERNS: this function is diffing and using the diff
742
 
        # results to create a new inventory at the same time, which results
743
 
        # in bugs like #46635.  Any reason not to use/enhance Tree.changes_from?
744
 
        # ADHB 11-07-2006
745
 
 
746
 
        specific_files = self.specific_files
747
 
        exclude = self.exclude
748
 
        report_changes = self.reporter.is_verbose()
749
 
        deleted_ids = []
750
 
        # A tree of paths that have been deleted. E.g. if foo/bar has been
751
 
        # deleted, then we have {'foo':{'bar':{}}}
752
 
        deleted_paths = {}
753
 
        # XXX: Note that entries may have the wrong kind because the entry does
754
 
        # not reflect the status on disk.
755
 
        work_inv = self.work_tree.inventory
756
 
        # NB: entries will include entries within the excluded ids/paths
757
 
        # because iter_entries_by_dir has no 'exclude' facility today.
758
 
        entries = work_inv.iter_entries_by_dir(
759
 
            specific_file_ids=self.specific_file_ids, yield_parents=True)
760
 
        for path, existing_ie in entries:
761
 
            file_id = existing_ie.file_id
762
 
            name = existing_ie.name
763
 
            parent_id = existing_ie.parent_id
764
 
            kind = existing_ie.kind
765
 
            # Skip files that have been deleted from the working tree.
766
 
            # The deleted path ids are also recorded so they can be explicitly
767
 
            # unversioned later.
768
 
            if deleted_paths:
769
 
                path_segments = splitpath(path)
770
 
                deleted_dict = deleted_paths
771
 
                for segment in path_segments:
772
 
                    deleted_dict = deleted_dict.get(segment, None)
773
 
                    if not deleted_dict:
774
 
                        # We either took a path not present in the dict
775
 
                        # (deleted_dict was None), or we've reached an empty
776
 
                        # child dir in the dict, so are now a sub-path.
777
 
                        break
778
 
                else:
779
 
                    deleted_dict = None
780
 
                if deleted_dict is not None:
781
 
                    # the path has a deleted parent, do not add it.
782
 
                    continue
783
 
            if exclude and is_inside_any(exclude, path):
784
 
                # Skip excluded paths. Excluded paths are processed by
785
 
                # _update_builder_with_changes.
786
 
                continue
787
 
            content_summary = self.work_tree.path_content_summary(path)
788
 
            kind = content_summary[0]
789
 
            # Note that when a filter of specific files is given, we must only
790
 
            # skip/record deleted files matching that filter.
791
 
            if not specific_files or is_inside_any(specific_files, path):
792
 
                if kind == 'missing':
793
 
                    if not deleted_paths:
794
 
                        # path won't have been split yet.
795
 
                        path_segments = splitpath(path)
796
 
                    deleted_dict = deleted_paths
797
 
                    for segment in path_segments:
798
 
                        deleted_dict = deleted_dict.setdefault(segment, {})
799
 
                    self.reporter.missing(path)
800
 
                    self._next_progress_entry()
801
 
                    deleted_ids.append(file_id)
802
 
                    continue
803
 
            # TODO: have the builder do the nested commit just-in-time IF and
804
 
            # only if needed.
805
 
            if kind == 'tree-reference':
806
 
                # enforce repository nested tree policy.
807
 
                if (not self.work_tree.supports_tree_reference() or
808
 
                    # repository does not support it either.
809
 
                    not self.branch.repository._format.supports_tree_reference):
810
 
                    kind = 'directory'
811
 
                    content_summary = (kind, None, None, None)
812
 
                elif self.recursive == 'down':
813
 
                    nested_revision_id = self._commit_nested_tree(
814
 
                        file_id, path)
815
 
                    content_summary = (kind, None, None, nested_revision_id)
816
 
                else:
817
 
                    nested_revision_id = self.work_tree.get_reference_revision(file_id)
818
 
                    content_summary = (kind, None, None, nested_revision_id)
819
 
 
820
 
            # Record an entry for this item
821
 
            # Note: I don't particularly want to have the existing_ie
822
 
            # parameter but the test suite currently (28-Jun-07) breaks
823
 
            # without it thanks to a unicode normalisation issue. :-(
824
 
            definitely_changed = kind != existing_ie.kind
825
 
            self._record_entry(path, file_id, specific_files, kind, name,
826
 
                parent_id, definitely_changed, existing_ie, report_changes,
827
 
                content_summary)
828
 
 
829
 
        # Unversion IDs that were found to be deleted
830
 
        self.deleted_ids = deleted_ids
831
 
 
832
 
    def _commit_nested_tree(self, file_id, path):
 
753
    def _commit_nested_tree(self, path):
833
754
        "Commit a nested tree."
834
 
        sub_tree = self.work_tree.get_nested_tree(file_id, path)
 
755
        sub_tree = self.work_tree.get_nested_tree(path)
835
756
        # FIXME: be more comprehensive here:
836
757
        # this works when both trees are in --trees repository,
837
758
        # but when both are bound to a different repository,
839
760
        # finally implement the explicit-caches approach design
840
761
        # a while back - RBC 20070306.
841
762
        if sub_tree.branch.repository.has_same_location(
842
 
            self.work_tree.branch.repository):
 
763
                self.work_tree.branch.repository):
843
764
            sub_tree.branch.repository = \
844
765
                self.work_tree.branch.repository
845
766
        try:
846
767
            return sub_tree.commit(message=None, revprops=self.revprops,
847
 
                recursive=self.recursive,
848
 
                message_callback=self.message_callback,
849
 
                timestamp=self.timestamp, timezone=self.timezone,
850
 
                committer=self.committer,
851
 
                allow_pointless=self.allow_pointless,
852
 
                strict=self.strict, verbose=self.verbose,
853
 
                local=self.local, reporter=self.reporter)
854
 
        except errors.PointlessCommit:
855
 
            return self.work_tree.get_reference_revision(file_id)
856
 
 
857
 
    def _record_entry(self, path, file_id, specific_files, kind, name,
858
 
        parent_id, definitely_changed, existing_ie, report_changes,
859
 
        content_summary):
860
 
        "Record the new inventory entry for a path if any."
861
 
        # mutter('check %s {%s}', path, file_id)
862
 
        # mutter('%s selected for commit', path)
863
 
        if definitely_changed or existing_ie is None:
864
 
            ie = make_entry(kind, name, parent_id, file_id)
865
 
        else:
866
 
            ie = existing_ie.copy()
867
 
            ie.revision = None
868
 
        # For carried over entries we don't care about the fs hash - the repo
869
 
        # isn't generating a sha, so we're not saving computation time.
870
 
        _, _, fs_hash = self.builder.record_entry_contents(
871
 
            ie, self.parent_invs, path, self.work_tree, content_summary)
872
 
        if report_changes:
873
 
            self._report_change(ie, path)
874
 
        if fs_hash:
875
 
            self.work_tree._observed_sha1(ie.file_id, path, fs_hash)
876
 
        return ie
877
 
 
878
 
    def _report_change(self, ie, path):
879
 
        """Report a change to the user.
880
 
 
881
 
        The change that has occurred is described relative to the basis
882
 
        inventory.
883
 
        """
884
 
        if (self.basis_inv.has_id(ie.file_id)):
885
 
            basis_ie = self.basis_inv[ie.file_id]
886
 
        else:
887
 
            basis_ie = None
888
 
        change = ie.describe_change(basis_ie, ie)
889
 
        if change in (InventoryEntry.RENAMED,
890
 
            InventoryEntry.MODIFIED_AND_RENAMED):
891
 
            old_path = self.basis_inv.id2path(ie.file_id)
892
 
            self.reporter.renamed(change, old_path, path)
893
 
            self._next_progress_entry()
894
 
        else:
895
 
            if change == 'unchanged':
896
 
                return
897
 
            self.reporter.snapshot_change(change, path)
898
 
            self._next_progress_entry()
 
768
                                   recursive=self.recursive,
 
769
                                   message_callback=self.message_callback,
 
770
                                   timestamp=self.timestamp,
 
771
                                   timezone=self.timezone,
 
772
                                   committer=self.committer,
 
773
                                   allow_pointless=self.allow_pointless,
 
774
                                   strict=self.strict, verbose=self.verbose,
 
775
                                   local=self.local, reporter=self.reporter)
 
776
        except PointlessCommit:
 
777
            return self.work_tree.get_reference_revision(path)
899
778
 
900
779
    def _set_progress_stage(self, name, counter=False):
901
780
        """Set the progress stage and emit an update to the progress bar."""
914
793
 
915
794
    def _emit_progress(self):
916
795
        if self.pb_entries_count is not None:
917
 
            text = "%s [%d] - Stage" % (self.pb_stage_name,
918
 
                self.pb_entries_count)
 
796
            text = gettext("{0} [{1}] - Stage").format(self.pb_stage_name,
 
797
                                                       self.pb_entries_count)
919
798
        else:
920
 
            text = "%s - Stage" % (self.pb_stage_name, )
 
799
            text = gettext("%s - Stage") % (self.pb_stage_name, )
921
800
        self.pb.update(text, self.pb_stage_count, self.pb_stage_total)
922
 
 
923
 
    def _set_specific_file_ids(self):
924
 
        """populate self.specific_file_ids if we will use it."""
925
 
        if not self.use_record_iter_changes:
926
 
            # If provided, ensure the specified files are versioned
927
 
            if self.specific_files is not None:
928
 
                # Note: This routine is being called because it raises
929
 
                # PathNotVersionedError as a side effect of finding the IDs. We
930
 
                # later use the ids we found as input to the working tree
931
 
                # inventory iterator, so we only consider those ids rather than
932
 
                # examining the whole tree again.
933
 
                # XXX: Dont we have filter_unversioned to do this more
934
 
                # cheaply?
935
 
                self.specific_file_ids = tree.find_ids_across_trees(
936
 
                    self.specific_files, [self.basis_tree, self.work_tree])
937
 
            else:
938
 
                self.specific_file_ids = None