~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/commit.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2006-03-22 12:17:00 UTC
  • mfrom: (1616.1.10 bzr.mbp.integration)
  • Revision ID: pqm@pqm.ubuntu.com-20060322121700-79ce0be81013aba1
(mbp) pycurl fixes, other fixes, weave commands, verbose commit changes from robert

Show diffs side-by-side

added added

removed removed

Lines of Context:
1
 
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
 
1
# Copyright (C) 2005 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
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
16
16
 
17
17
 
 
18
# XXX: Can we do any better about making interrupted commits change
 
19
# nothing?  Perhaps the best approach is to integrate commit of
 
20
# AtomicFiles with releasing the lock on the Branch.
 
21
 
 
22
# TODO: Separate 'prepare' phase where we find a list of potentially
 
23
# committed files.  We then can then pause the commit to prompt for a
 
24
# commit message, knowing the summary will be the same as what's
 
25
# actually used for the commit.  (But perhaps simpler to simply get
 
26
# the tree status, then use that for a selective commit?)
 
27
 
18
28
# The newly committed revision is going to have a shape corresponding
19
29
# to that of the working inventory.  Files that are not in the
20
30
# working tree and that were in the predecessor are reported as
46
56
# merges from, then it should still be reported as newly added
47
57
# relative to the basis revision.
48
58
 
49
 
# TODO: Change the parameter 'rev_id' to 'revision_id' to be consistent with
50
 
# the rest of the code; add a deprecation of the old name.
 
59
# TODO: Do checks that the tree can be committed *before* running the 
 
60
# editor; this should include checks for a pointless commit and for 
 
61
# unknown or missing files.
 
62
 
 
63
# TODO: If commit fails, leave the message in a file somewhere.
 
64
 
51
65
 
52
66
import os
53
67
import re
54
68
import sys
55
69
import time
 
70
import pdb
56
71
 
 
72
from binascii import hexlify
57
73
from cStringIO import StringIO
58
74
 
59
 
from bzrlib import (
60
 
    debug,
61
 
    errors,
62
 
    inventory,
63
 
    tree,
64
 
    )
65
 
from bzrlib.branch import Branch
 
75
from bzrlib.atomicfile import AtomicFile
 
76
from bzrlib.osutils import (local_time_offset,
 
77
                            rand_bytes, compact_date,
 
78
                            kind_marker, is_inside_any, quotefn,
 
79
                            sha_file, isdir, isfile,
 
80
                            split_lines)
66
81
import bzrlib.config
 
82
import bzrlib.errors as errors
67
83
from bzrlib.errors import (BzrError, PointlessCommit,
 
84
                           HistoryMissing,
68
85
                           ConflictsInTree,
69
86
                           StrictCommitFailed
70
87
                           )
71
 
from bzrlib.osutils import (kind_marker, isdir,isfile, is_inside_any, 
72
 
                            is_inside_or_parent_of_any,
73
 
                            quotefn, sha_file, split_lines)
 
88
from bzrlib.revision import Revision
74
89
from bzrlib.testament import Testament
75
90
from bzrlib.trace import mutter, note, warning
76
91
from bzrlib.xml5 import serializer_v5
77
 
from bzrlib.inventory import Inventory, InventoryEntry
78
 
from bzrlib import symbol_versioning
79
 
from bzrlib.symbol_versioning import (deprecated_passed,
80
 
        deprecated_function,
81
 
        DEPRECATED_PARAMETER)
 
92
from bzrlib.inventory import Inventory, ROOT_ID
 
93
from bzrlib.symbol_versioning import *
82
94
from bzrlib.workingtree import WorkingTree
83
 
import bzrlib.ui
 
95
 
 
96
 
 
97
@deprecated_function(zero_seven)
 
98
def commit(*args, **kwargs):
 
99
    """Commit a new revision to a branch.
 
100
 
 
101
    Function-style interface for convenience of old callers.
 
102
 
 
103
    New code should use the Commit class instead.
 
104
    """
 
105
    ## XXX: Remove this in favor of Branch.commit?
 
106
    Commit().commit(*args, **kwargs)
84
107
 
85
108
 
86
109
class NullCommitReporter(object):
101
124
    def missing(self, path):
102
125
        pass
103
126
 
104
 
    def renamed(self, change, old_path, new_path):
105
 
        pass
106
 
 
107
127
 
108
128
class ReportCommitToLog(NullCommitReporter):
109
129
 
110
 
    def _note(self, format, *args):
111
 
        """Output a message.
112
 
 
113
 
        Subclasses may choose to override this method.
114
 
        """
115
 
        note(format, *args)
116
 
 
117
130
    def snapshot_change(self, change, path):
118
131
        if change == 'unchanged':
119
132
            return
120
 
        if change == 'added' and path == '':
121
 
            return
122
 
        self._note("%s %s", change, path)
 
133
        note("%s %s", change, path)
123
134
 
124
135
    def completed(self, revno, rev_id):
125
 
        self._note('Committed revision %d.', revno)
 
136
        note('Committed revision %d.', revno)
126
137
    
127
138
    def deleted(self, file_id):
128
 
        self._note('deleted %s', file_id)
 
139
        note('deleted %s', file_id)
129
140
 
130
141
    def escaped(self, escape_count, message):
131
 
        self._note("replaced %d control characters in message", escape_count)
 
142
        note("replaced %d control characters in message", escape_count)
132
143
 
133
144
    def missing(self, path):
134
 
        self._note('missing %s', path)
135
 
 
136
 
    def renamed(self, change, old_path, new_path):
137
 
        self._note('%s %s => %s', change, old_path, new_path)
 
145
        note('missing %s', path)
138
146
 
139
147
 
140
148
class Commit(object):
156
164
            self.reporter = reporter
157
165
        else:
158
166
            self.reporter = NullCommitReporter()
159
 
        self.config = config
 
167
        if config is not None:
 
168
            self.config = config
 
169
        else:
 
170
            self.config = None
160
171
        
161
172
    def commit(self,
162
 
               message=None,
 
173
               branch=DEPRECATED_PARAMETER, message=None,
163
174
               timestamp=None,
164
175
               timezone=None,
165
176
               committer=None,
172
183
               working_tree=None,
173
184
               local=False,
174
185
               reporter=None,
175
 
               config=None,
176
 
               message_callback=None,
177
 
               recursive='down'):
 
186
               config=None):
178
187
        """Commit working copy as a new revision.
179
188
 
180
 
        :param message: the commit message (it or message_callback is required)
181
 
 
182
 
        :param timestamp: if not None, seconds-since-epoch for a
183
 
            postdated/predated commit.
184
 
 
185
 
        :param specific_files: If true, commit only those files.
186
 
 
187
 
        :param rev_id: If set, use this as the new revision id.
 
189
        branch -- the deprecated branch to commit to. New callers should pass in 
 
190
                  working_tree instead
 
191
 
 
192
        message -- the commit message, a mandatory parameter
 
193
 
 
194
        timestamp -- if not None, seconds-since-epoch for a
 
195
             postdated/predated commit.
 
196
 
 
197
        specific_files -- If true, commit only those files.
 
198
 
 
199
        rev_id -- If set, use this as the new revision id.
188
200
            Useful for test or import commands that need to tightly
189
201
            control what revisions are assigned.  If you duplicate
190
202
            a revision id that exists elsewhere it is your own fault.
191
203
            If null (default), a time/random revision id is generated.
192
204
 
193
 
        :param allow_pointless: If true (default), commit even if nothing
 
205
        allow_pointless -- If true (default), commit even if nothing
194
206
            has changed and no merges are recorded.
195
207
 
196
 
        :param strict: If true, don't allow a commit if the working tree
 
208
        strict -- If true, don't allow a commit if the working tree
197
209
            contains unknown files.
198
210
 
199
 
        :param revprops: Properties for new revision
 
211
        revprops -- Properties for new revision
200
212
        :param local: Perform a local only commit.
201
 
        :param recursive: If set to 'down', commit in any subtrees that have
202
 
            pending changes of any sort during this commit.
203
213
        """
204
214
        mutter('preparing to commit')
205
215
 
206
 
        if working_tree is None:
207
 
            raise BzrError("working_tree must be passed into commit().")
 
216
        if deprecated_passed(branch):
 
217
            warn("Commit.commit (branch, ...): The branch parameter is "
 
218
                 "deprecated as of bzr 0.8. Please use working_tree= instead.",
 
219
                 DeprecationWarning, stacklevel=2)
 
220
            self.branch = branch
 
221
            self.work_tree = self.branch.bzrdir.open_workingtree()
 
222
        elif working_tree is None:
 
223
            raise BzrError("One of branch and working_tree must be passed into commit().")
208
224
        else:
209
225
            self.work_tree = working_tree
210
226
            self.branch = self.work_tree.branch
211
 
            if getattr(self.work_tree, 'requires_rich_root', lambda: False)():
212
 
                if not self.branch.repository.supports_rich_root():
213
 
                    raise errors.RootNotRich()
214
 
        if message_callback is None:
215
 
            if message is not None:
216
 
                if isinstance(message, str):
217
 
                    message = message.decode(bzrlib.user_encoding)
218
 
                message_callback = lambda x: message
219
 
            else:
220
 
                raise BzrError("The message or message_callback keyword"
221
 
                               " parameter is required for commit().")
 
227
        if message is None:
 
228
            raise BzrError("The message keyword parameter is required for commit().")
222
229
 
 
230
        self.weave_store = self.branch.repository.weave_store
223
231
        self.bound_branch = None
224
232
        self.local = local
225
233
        self.master_branch = None
226
234
        self.master_locked = False
227
 
        self.rev_id = None
 
235
        self.rev_id = rev_id
228
236
        self.specific_files = specific_files
229
237
        self.allow_pointless = allow_pointless
230
 
        self.recursive = recursive
231
 
        self.revprops = revprops
232
 
        self.message_callback = message_callback
233
 
        self.timestamp = timestamp
234
 
        self.timezone = timezone
235
 
        self.committer = committer
236
 
        self.strict = strict
237
 
        self.verbose = verbose
 
238
        self.revprops = {}
 
239
        if revprops is not None:
 
240
            self.revprops.update(revprops)
238
241
 
239
242
        if reporter is None and self.reporter is None:
240
243
            self.reporter = NullCommitReporter()
242
245
            self.reporter = reporter
243
246
 
244
247
        self.work_tree.lock_write()
245
 
        self.pb = bzrlib.ui.ui_factory.nested_progress_bar()
246
 
        self.basis_tree = self.work_tree.basis_tree()
247
 
        self.basis_tree.lock_read()
248
248
        try:
249
 
            # Cannot commit with conflicts present.
250
 
            if len(self.work_tree.conflicts()) > 0:
251
 
                raise ConflictsInTree
252
 
 
253
 
            # Setup the bound branch variables as needed.
 
249
            # setup the bound branch variables as needed.
254
250
            self._check_bound_branch()
255
251
 
256
 
            # Check that the working tree is up to date
257
 
            old_revno,new_revno = self._check_out_of_date_tree()
258
 
 
 
252
            # check for out of date working trees
 
253
            # if we are bound, then self.branch is the master branch and this
 
254
            # test is thus all we need.
 
255
            if self.work_tree.last_revision() != self.master_branch.last_revision():
 
256
                raise errors.OutOfDateTree(self.work_tree)
 
257
    
259
258
            if strict:
260
259
                # raise an exception as soon as we find a single unknown.
261
260
                for unknown in self.work_tree.unknowns():
262
261
                    raise StrictCommitFailed()
263
 
                   
 
262
    
 
263
            if timestamp is None:
 
264
                self.timestamp = time.time()
 
265
            else:
 
266
                self.timestamp = long(timestamp)
 
267
                
264
268
            if self.config is None:
265
 
                self.config = self.branch.get_config()
266
 
 
267
 
            # If provided, ensure the specified files are versioned
268
 
            if specific_files is not None:
269
 
                # Note: We don't actually need the IDs here. This routine
270
 
                # is being called because it raises PathNotVerisonedError
271
 
                # as a side effect of finding the IDs.
272
 
                # XXX: Dont we have filter_unversioned to do this more
273
 
                # cheaply?
274
 
                tree.find_ids_across_trees(specific_files,
275
 
                                           [self.basis_tree, self.work_tree])
276
 
 
277
 
            # Setup the progress bar. As the number of files that need to be
278
 
            # committed in unknown, progress is reported as stages.
279
 
            # We keep track of entries separately though and include that
280
 
            # information in the progress bar during the relevant stages.
281
 
            self.pb_stage_name = ""
282
 
            self.pb_stage_count = 0
283
 
            self.pb_stage_total = 4
284
 
            if self.bound_branch:
285
 
                self.pb_stage_total += 1
286
 
            self.pb.show_pct = False
287
 
            self.pb.show_spinner = False
288
 
            self.pb.show_eta = False
289
 
            self.pb.show_count = True
290
 
            self.pb.show_bar = True
291
 
 
292
 
            # After a merge, a selected file commit is not supported.
293
 
            # See 'bzr help merge' for an explanation as to why.
 
269
                self.config = bzrlib.config.BranchConfig(self.branch)
 
270
    
 
271
            if rev_id is None:
 
272
                self.rev_id = _gen_revision_id(self.config, self.timestamp)
 
273
            else:
 
274
                self.rev_id = rev_id
 
275
    
 
276
            if committer is None:
 
277
                self.committer = self.config.username()
 
278
            else:
 
279
                assert isinstance(committer, basestring), type(committer)
 
280
                self.committer = committer
 
281
    
 
282
            if timezone is None:
 
283
                self.timezone = local_time_offset()
 
284
            else:
 
285
                self.timezone = int(timezone)
 
286
    
 
287
            if isinstance(message, str):
 
288
                message = message.decode(bzrlib.user_encoding)
 
289
            assert isinstance(message, unicode), type(message)
 
290
            self.message = message
 
291
            self._escape_commit_message()
 
292
 
 
293
            self.work_inv = self.work_tree.inventory
 
294
            self.basis_tree = self.work_tree.basis_tree()
294
295
            self.basis_inv = self.basis_tree.inventory
 
296
 
295
297
            self._gather_parents()
296
298
            if len(self.parents) > 1 and self.specific_files:
297
 
                raise errors.CannotCommitSelectedFileMerge(self.specific_files)
298
 
            
299
 
            # Collect the changes
300
 
            self._emit_progress_set_stage("Collecting changes", show_entries=True)
301
 
            self.builder = self.branch.get_commit_builder(self.parents,
302
 
                self.config, timestamp, timezone, committer, revprops, rev_id)
303
 
            self._update_builder_with_changes()
304
 
            self._check_pointless()
305
 
 
306
 
            # TODO: Now the new inventory is known, check for conflicts.
307
 
            # ADHB 2006-08-08: If this is done, populate_new_inv should not add
308
 
            # weave lines, because nothing should be recorded until it is known
309
 
            # that commit will succeed.
310
 
            self._emit_progress_set_stage("Saving data locally")
311
 
            self.builder.finish_inventory()
312
 
 
313
 
            # Prompt the user for a commit message if none provided
314
 
            message = message_callback(self)
315
 
            assert isinstance(message, unicode), type(message)
316
 
            self.message = message
317
 
            self._escape_commit_message()
318
 
 
319
 
            # Add revision data to the local branch
320
 
            self.rev_id = self.builder.commit(self.message)
321
 
            
322
 
            # Upload revision data to the master.
323
 
            # this will propagate merged revisions too if needed.
 
299
                raise NotImplementedError('selected-file commit of merges is not supported yet')
 
300
            self._check_parents_present()
 
301
            
 
302
            self._remove_deleted()
 
303
            self._populate_new_inv()
 
304
            self._store_snapshot()
 
305
            self._report_deletes()
 
306
 
 
307
            if not (self.allow_pointless
 
308
                    or len(self.parents) > 1
 
309
                    or self.new_inv != self.basis_inv):
 
310
                raise PointlessCommit()
 
311
 
 
312
            if len(list(self.work_tree.iter_conflicts()))>0:
 
313
                raise ConflictsInTree
 
314
 
 
315
            self.inv_sha1 = self.branch.repository.add_inventory(
 
316
                self.rev_id,
 
317
                self.new_inv,
 
318
                self.present_parents
 
319
                )
 
320
            self._make_revision()
 
321
            # revision data is in the local branch now.
 
322
            
 
323
            # upload revision data to the master.
 
324
            # this will propogate merged revisions too if needed.
324
325
            if self.bound_branch:
325
 
                self._emit_progress_set_stage("Uploading data to master branch")
326
326
                self.master_branch.repository.fetch(self.branch.repository,
327
327
                                                    revision_id=self.rev_id)
328
328
                # now the master has the revision data
329
 
                # 'commit' to the master first so a timeout here causes the
330
 
                # local branch to be out of date
331
 
                self.master_branch.set_last_revision_info(new_revno,
332
 
                                                          self.rev_id)
 
329
                # 'commit' to the master first so a timeout here causes the local
 
330
                # branch to be out of date
 
331
                self.master_branch.append_revision(self.rev_id)
333
332
 
334
333
            # and now do the commit locally.
335
 
            self.branch.set_last_revision_info(new_revno, self.rev_id)
 
334
            self.branch.append_revision(self.rev_id)
336
335
 
337
 
            # Make the working tree up to date with the branch
338
 
            self._emit_progress_set_stage("Updating the working tree")
339
 
            rev_tree = self.builder.revision_tree()
340
 
            self.work_tree.set_parent_trees([(self.rev_id, rev_tree)])
341
 
            self.reporter.completed(new_revno, self.rev_id)
342
 
            self._process_hooks(old_revno, new_revno)
 
336
            self.work_tree.set_pending_merges([])
 
337
            if len(self.parents):
 
338
                precursor = self.parents[0]
 
339
            else:
 
340
                precursor = None
 
341
            self.work_tree.set_last_revision(self.rev_id, precursor)
 
342
            # now the work tree is up to date with the branch
 
343
            
 
344
            self.reporter.completed(self.branch.revno(), self.rev_id)
 
345
            if self.config.post_commit() is not None:
 
346
                hooks = self.config.post_commit().split(' ')
 
347
                # this would be nicer with twisted.python.reflect.namedAny
 
348
                for hook in hooks:
 
349
                    result = eval(hook + '(branch, rev_id)',
 
350
                                  {'branch':self.branch,
 
351
                                   'bzrlib':bzrlib,
 
352
                                   'rev_id':self.rev_id})
343
353
        finally:
344
 
            self._cleanup()
345
 
        return self.rev_id
346
 
 
347
 
    def _any_real_changes(self):
348
 
        """Are there real changes between new_inventory and basis?
349
 
 
350
 
        For trees without rich roots, inv.root.revision changes every commit.
351
 
        But if that is the only change, we want to treat it as though there
352
 
        are *no* changes.
353
 
        """
354
 
        new_entries = self.builder.new_inventory.iter_entries()
355
 
        basis_entries = self.basis_inv.iter_entries()
356
 
        new_path, new_root_ie = new_entries.next()
357
 
        basis_path, basis_root_ie = basis_entries.next()
358
 
 
359
 
        # This is a copy of InventoryEntry.__eq__ only leaving out .revision
360
 
        def ie_equal_no_revision(this, other):
361
 
            return ((this.file_id == other.file_id)
362
 
                    and (this.name == other.name)
363
 
                    and (this.symlink_target == other.symlink_target)
364
 
                    and (this.text_sha1 == other.text_sha1)
365
 
                    and (this.text_size == other.text_size)
366
 
                    and (this.text_id == other.text_id)
367
 
                    and (this.parent_id == other.parent_id)
368
 
                    and (this.kind == other.kind)
369
 
                    and (this.executable == other.executable)
370
 
                    and (this.reference_revision == other.reference_revision)
371
 
                    )
372
 
        if not ie_equal_no_revision(new_root_ie, basis_root_ie):
373
 
            return True
374
 
 
375
 
        for new_ie, basis_ie in zip(new_entries, basis_entries):
376
 
            if new_ie != basis_ie:
377
 
                return True
378
 
 
379
 
        # No actual changes present
380
 
        return False
381
 
 
382
 
    def _check_pointless(self):
383
 
        if self.allow_pointless:
384
 
            return
385
 
        # A merge with no effect on files
386
 
        if len(self.parents) > 1:
387
 
            return
388
 
        # work around the fact that a newly-initted tree does differ from its
389
 
        # basis
390
 
        if len(self.basis_inv) == 0 and len(self.builder.new_inventory) == 1:
391
 
            raise PointlessCommit()
392
 
        # Shortcut, if the number of entries changes, then we obviously have
393
 
        # a change
394
 
        if len(self.builder.new_inventory) != len(self.basis_inv):
395
 
            return
396
 
        # If length == 1, then we only have the root entry. Which means
397
 
        # that there is no real difference (only the root could be different)
398
 
        if (len(self.builder.new_inventory) != 1 and self._any_real_changes()):
399
 
            return
400
 
        raise PointlessCommit()
 
354
            self._cleanup_bound_branch()
 
355
            self.work_tree.unlock()
401
356
 
402
357
    def _check_bound_branch(self):
403
358
        """Check to see if the local branch is bound.
429
384
        #       to local.
430
385
        
431
386
        # Make sure the local branch is identical to the master
432
 
        master_info = self.master_branch.last_revision_info()
433
 
        local_info = self.branch.last_revision_info()
434
 
        if local_info != master_info:
 
387
        master_rh = self.master_branch.revision_history()
 
388
        local_rh = self.branch.revision_history()
 
389
        if local_rh != master_rh:
435
390
            raise errors.BoundBranchOutOfDate(self.branch,
436
391
                    self.master_branch)
437
392
 
440
395
        self.bound_branch = self.branch
441
396
        self.master_branch.lock_write()
442
397
        self.master_locked = True
443
 
 
444
 
    def _check_out_of_date_tree(self):
445
 
        """Check that the working tree is up to date.
446
 
 
447
 
        :return: old_revision_number,new_revision_number tuple
448
 
        """
449
 
        try:
450
 
            first_tree_parent = self.work_tree.get_parent_ids()[0]
451
 
        except IndexError:
452
 
            # if there are no parents, treat our parent as 'None'
453
 
            # this is so that we still consider the master branch
454
 
            # - in a checkout scenario the tree may have no
455
 
            # parents but the branch may do.
456
 
            first_tree_parent = bzrlib.revision.NULL_REVISION
457
 
        old_revno, master_last = self.master_branch.last_revision_info()
458
 
        if master_last != first_tree_parent:
459
 
            if master_last != bzrlib.revision.NULL_REVISION:
460
 
                raise errors.OutOfDateTree(self.work_tree)
461
 
        if self.branch.repository.has_revision(first_tree_parent):
462
 
            new_revno = old_revno + 1
463
 
        else:
464
 
            # ghost parents never appear in revision history.
465
 
            new_revno = 1
466
 
        return old_revno,new_revno
467
 
 
468
 
    def _process_hooks(self, old_revno, new_revno):
469
 
        """Process any registered commit hooks."""
470
 
        # Process the post commit hooks, if any
471
 
        self._emit_progress_set_stage("Running post commit hooks")
472
 
        # old style commit hooks - should be deprecated ? (obsoleted in
473
 
        # 0.15)
474
 
        if self.config.post_commit() is not None:
475
 
            hooks = self.config.post_commit().split(' ')
476
 
            # this would be nicer with twisted.python.reflect.namedAny
477
 
            for hook in hooks:
478
 
                result = eval(hook + '(branch, rev_id)',
479
 
                              {'branch':self.branch,
480
 
                               'bzrlib':bzrlib,
481
 
                               'rev_id':self.rev_id})
482
 
        # new style commit hooks:
483
 
        if not self.bound_branch:
484
 
            hook_master = self.branch
485
 
            hook_local = None
486
 
        else:
487
 
            hook_master = self.master_branch
488
 
            hook_local = self.branch
489
 
        # With bound branches, when the master is behind the local branch,
490
 
        # the 'old_revno' and old_revid values here are incorrect.
491
 
        # XXX: FIXME ^. RBC 20060206
492
 
        if self.parents:
493
 
            old_revid = self.parents[0]
494
 
        else:
495
 
            old_revid = bzrlib.revision.NULL_REVISION
496
 
        for hook in Branch.hooks['post_commit']:
497
 
            # show the running hook in the progress bar. As hooks may
498
 
            # end up doing nothing (e.g. because they are not configured by
499
 
            # the user) this is still showing progress, not showing overall
500
 
            # actions - its up to each plugin to show a UI if it want's to
501
 
            # (such as 'Emailing diff to foo@example.com').
502
 
            self.pb_stage_name = "Running post commit hooks [%s]" % \
503
 
                Branch.hooks.get_hook_name(hook)
504
 
            self._emit_progress()
505
 
            if 'hooks' in debug.debug_flags:
506
 
                mutter("Invoking commit hook: %r", hook)
507
 
            hook(hook_local, hook_master, old_revno, old_revid, new_revno,
508
 
                self.rev_id)
509
 
 
510
 
    def _cleanup(self):
511
 
        """Cleanup any open locks, progress bars etc."""
512
 
        cleanups = [self._cleanup_bound_branch,
513
 
                    self.basis_tree.unlock,
514
 
                    self.work_tree.unlock,
515
 
                    self.pb.finished]
516
 
        found_exception = None
517
 
        for cleanup in cleanups:
518
 
            try:
519
 
                cleanup()
520
 
            # we want every cleanup to run no matter what.
521
 
            # so we have a catchall here, but we will raise the
522
 
            # last encountered exception up the stack: and
523
 
            # typically this will be useful enough.
524
 
            except Exception, e:
525
 
                found_exception = e
526
 
        if found_exception is not None: 
527
 
            # don't do a plan raise, because the last exception may have been
528
 
            # trashed, e is our sure-to-work exception even though it loses the
529
 
            # full traceback. XXX: RBC 20060421 perhaps we could check the
530
 
            # exc_info and if its the same one do a plain raise otherwise 
531
 
            # 'raise e' as we do now.
532
 
            raise e
 
398
####        
 
399
####        # Check to see if we have any pending merges. If we do
 
400
####        # those need to be pushed into the master branch
 
401
####        pending_merges = self.work_tree.pending_merges()
 
402
####        if pending_merges:
 
403
####            for revision_id in pending_merges:
 
404
####                self.master_branch.repository.fetch(self.bound_branch.repository,
 
405
####                                                    revision_id=revision_id)
533
406
 
534
407
    def _cleanup_bound_branch(self):
535
408
        """Executed at the end of a try/finally to cleanup a bound branch.
545
418
 
546
419
    def _escape_commit_message(self):
547
420
        """Replace xml-incompatible control characters."""
548
 
        # FIXME: RBC 20060419 this should be done by the revision
549
 
        # serialiser not by commit. Then we can also add an unescaper
550
 
        # in the deserializer and start roundtripping revision messages
551
 
        # precisely. See repository_implementations/test_repository.py
552
 
        
553
421
        # Python strings can include characters that can't be
554
422
        # represented in well-formed XML; escape characters that
555
423
        # aren't listed in the XML specification
563
431
 
564
432
    def _gather_parents(self):
565
433
        """Record the parents of a merge for merge detection."""
566
 
        # TODO: Make sure that this list doesn't contain duplicate 
567
 
        # entries and the order is preserved when doing this.
568
 
        self.parents = self.work_tree.get_parent_ids()
569
 
        self.parent_invs = [self.basis_inv]
570
 
        for revision in self.parents[1:]:
 
434
        pending_merges = self.work_tree.pending_merges()
 
435
        self.parents = []
 
436
        self.parent_invs = []
 
437
        self.present_parents = []
 
438
        precursor_id = self.branch.last_revision()
 
439
        if precursor_id:
 
440
            self.parents.append(precursor_id)
 
441
        self.parents += pending_merges
 
442
        for revision in self.parents:
571
443
            if self.branch.repository.has_revision(revision):
572
 
                mutter('commit parent revision {%s}', revision)
573
444
                inventory = self.branch.repository.get_inventory(revision)
574
445
                self.parent_invs.append(inventory)
575
 
            else:
576
 
                mutter('commit parent ghost revision {%s}', revision)
577
 
 
578
 
    def _update_builder_with_changes(self):
579
 
        """Update the commit builder with the data about what has changed.
 
446
                self.present_parents.append(revision)
 
447
 
 
448
    def _check_parents_present(self):
 
449
        for parent_id in self.parents:
 
450
            mutter('commit parent revision {%s}', parent_id)
 
451
            if not self.branch.repository.has_revision(parent_id):
 
452
                if parent_id == self.branch.last_revision():
 
453
                    warning("parent is missing %r", parent_id)
 
454
                    raise HistoryMissing(self.branch, 'revision', parent_id)
 
455
                else:
 
456
                    mutter("commit will ghost revision %r", parent_id)
 
457
            
 
458
    def _make_revision(self):
 
459
        """Record a new revision object for this commit."""
 
460
        rev = Revision(timestamp=self.timestamp,
 
461
                       timezone=self.timezone,
 
462
                       committer=self.committer,
 
463
                       message=self.message,
 
464
                       inventory_sha1=self.inv_sha1,
 
465
                       revision_id=self.rev_id,
 
466
                       properties=self.revprops)
 
467
        rev.parent_ids = self.parents
 
468
        self.branch.repository.add_revision(self.rev_id, rev, self.new_inv, self.config)
 
469
 
 
470
    def _remove_deleted(self):
 
471
        """Remove deleted files from the working inventories.
 
472
 
 
473
        This is done prior to taking the working inventory as the
 
474
        basis for the new committed inventory.
 
475
 
 
476
        This returns true if any files
 
477
        *that existed in the basis inventory* were deleted.
 
478
        Files that were added and deleted
 
479
        in the working copy don't matter.
580
480
        """
581
 
        # Build the revision inventory.
582
 
        #
583
 
        # This starts by creating a new empty inventory. Depending on
584
 
        # which files are selected for commit, and what is present in the
585
 
        # current tree, the new inventory is populated. inventory entries 
586
 
        # which are candidates for modification have their revision set to
587
 
        # None; inventory entries that are carried over untouched have their
588
 
        # revision set to their prior value.
589
 
        #
590
 
        # ESEPARATIONOFCONCERNS: this function is diffing and using the diff
591
 
        # results to create a new inventory at the same time, which results
592
 
        # in bugs like #46635.  Any reason not to use/enhance Tree.changes_from?
593
 
        # ADHB 11-07-2006
594
 
 
595
 
        specific_files = self.specific_files
596
 
        mutter("Selecting files for commit with filter %s", specific_files)
597
 
        work_inv = self.work_tree.inventory
598
 
        assert work_inv.root is not None
599
 
        self.pb_entries_total = len(work_inv)
600
 
 
601
 
        # Check and warn about old CommitBuilders
602
 
        entries = work_inv.iter_entries()
603
 
        if not self.builder.record_root_entry:
604
 
            symbol_versioning.warn('CommitBuilders should support recording'
605
 
                ' the root entry as of bzr 0.10.', DeprecationWarning, 
606
 
                stacklevel=1)
607
 
            self.builder.new_inventory.add(self.basis_inv.root.copy())
608
 
            entries.next()
609
 
 
 
481
        specific = self.specific_files
610
482
        deleted_ids = []
611
 
        deleted_paths = set()
612
 
        for path, new_ie in entries:
613
 
            self._emit_progress_next_entry()
 
483
        for path, ie in self.work_inv.iter_entries():
 
484
            if specific and not is_inside_any(specific, path):
 
485
                continue
 
486
            if not self.work_tree.has_filename(path):
 
487
                self.reporter.missing(path)
 
488
                deleted_ids.append((path, ie.file_id))
 
489
        if deleted_ids:
 
490
            deleted_ids.sort(reverse=True)
 
491
            for path, file_id in deleted_ids:
 
492
                del self.work_inv[file_id]
 
493
            self.work_tree._write_inventory(self.work_inv)
 
494
 
 
495
    def _store_snapshot(self):
 
496
        """Pass over inventory and record a snapshot.
 
497
 
 
498
        Entries get a new revision when they are modified in 
 
499
        any way, which includes a merge with a new set of
 
500
        parents that have the same entry. 
 
501
        """
 
502
        # XXX: Need to think more here about when the user has
 
503
        # made a specific decision on a particular value -- c.f.
 
504
        # mark-merge.  
 
505
        for path, ie in self.new_inv.iter_entries():
 
506
            previous_entries = ie.find_previous_heads(
 
507
                self.parent_invs,
 
508
                self.weave_store,
 
509
                self.branch.repository.get_transaction())
 
510
            if ie.revision is None:
 
511
                change = ie.snapshot(self.rev_id, path, previous_entries,
 
512
                                     self.work_tree, self.weave_store,
 
513
                                     self.branch.get_transaction())
 
514
            else:
 
515
                change = "unchanged"
 
516
            self.reporter.snapshot_change(change, path)
 
517
 
 
518
    def _populate_new_inv(self):
 
519
        """Build revision inventory.
 
520
 
 
521
        This creates a new empty inventory. Depending on
 
522
        which files are selected for commit, and what is present in the
 
523
        current tree, the new inventory is populated. inventory entries 
 
524
        which are candidates for modification have their revision set to
 
525
        None; inventory entries that are carried over untouched have their
 
526
        revision set to their prior value.
 
527
        """
 
528
        mutter("Selecting files for commit with filter %s", self.specific_files)
 
529
        self.new_inv = Inventory()
 
530
        for path, new_ie in self.work_inv.iter_entries():
614
531
            file_id = new_ie.file_id
615
 
 
616
 
            # Skip files that have been deleted from the working tree.
617
 
            # The deleted files/directories are also recorded so they
618
 
            # can be explicitly unversioned later. Note that when a
619
 
            # filter of specific files is given, we must only skip/record
620
 
            # deleted files matching that filter.
621
 
            if is_inside_any(deleted_paths, path):
622
 
                continue
623
 
            if not specific_files or is_inside_any(specific_files, path):
624
 
                if not self.work_tree.has_filename(path):
625
 
                    deleted_paths.add(path)
626
 
                    self.reporter.missing(path)
627
 
                    deleted_ids.append(file_id)
 
532
            mutter('check %s {%s}', path, new_ie.file_id)
 
533
            if self.specific_files:
 
534
                if not is_inside_any(self.specific_files, path):
 
535
                    mutter('%s not selected for commit', path)
 
536
                    self._carry_entry(file_id)
628
537
                    continue
629
 
            try:
630
 
                kind = self.work_tree.kind(file_id)
631
 
                if kind == 'tree-reference' and self.recursive == 'down':
632
 
                    # nested tree: commit in it
633
 
                    sub_tree = WorkingTree.open(self.work_tree.abspath(path))
634
 
                    # FIXME: be more comprehensive here:
635
 
                    # this works when both trees are in --trees repository,
636
 
                    # but when both are bound to a different repository,
637
 
                    # it fails; a better way of approaching this is to 
638
 
                    # finally implement the explicit-caches approach design
639
 
                    # a while back - RBC 20070306.
640
 
                    if (sub_tree.branch.repository.bzrdir.root_transport.base
641
 
                        ==
642
 
                        self.work_tree.branch.repository.bzrdir.root_transport.base):
643
 
                        sub_tree.branch.repository = \
644
 
                            self.work_tree.branch.repository
645
 
                    try:
646
 
                        sub_tree.commit(message=None, revprops=self.revprops,
647
 
                            recursive=self.recursive,
648
 
                            message_callback=self.message_callback,
649
 
                            timestamp=self.timestamp, timezone=self.timezone,
650
 
                            committer=self.committer,
651
 
                            allow_pointless=self.allow_pointless,
652
 
                            strict=self.strict, verbose=self.verbose,
653
 
                            local=self.local, reporter=self.reporter)
654
 
                    except errors.PointlessCommit:
655
 
                        pass
656
 
                if kind != new_ie.kind:
657
 
                    new_ie = inventory.make_entry(kind, new_ie.name,
658
 
                                                  new_ie.parent_id, file_id)
659
 
            except errors.NoSuchFile:
660
 
                pass
661
 
            # mutter('check %s {%s}', path, file_id)
662
 
            if (not specific_files or 
663
 
                is_inside_or_parent_of_any(specific_files, path)):
664
 
                    # mutter('%s selected for commit', path)
665
 
                    ie = new_ie.copy()
666
 
                    ie.revision = None
667
 
            else:
668
 
                # mutter('%s not selected for commit', path)
669
 
                if self.basis_inv.has_id(file_id):
670
 
                    ie = self.basis_inv[file_id].copy()
671
538
                else:
672
 
                    # this entry is new and not being committed
673
 
                    continue
674
 
            self.builder.record_entry_contents(ie, self.parent_invs, 
675
 
                path, self.work_tree)
676
 
            # describe the nature of the change that has occurred relative to
677
 
            # the basis inventory.
678
 
            if (self.basis_inv.has_id(ie.file_id)):
679
 
                basis_ie = self.basis_inv[ie.file_id]
680
 
            else:
681
 
                basis_ie = None
682
 
            change = ie.describe_change(basis_ie, ie)
683
 
            if change in (InventoryEntry.RENAMED, 
684
 
                InventoryEntry.MODIFIED_AND_RENAMED):
685
 
                old_path = self.basis_inv.id2path(ie.file_id)
686
 
                self.reporter.renamed(change, old_path, path)
687
 
            else:
688
 
                self.reporter.snapshot_change(change, path)
689
 
 
690
 
        # Unversion IDs that were found to be deleted
691
 
        self.work_tree.unversion(deleted_ids)
692
 
 
693
 
        # If specific files/directories were nominated, it is possible
694
 
        # that some data from outside those needs to be preserved from
695
 
        # the basis tree. For example, if a file x is moved from out of
696
 
        # directory foo into directory bar and the user requests
697
 
        # ``commit foo``, then information about bar/x must also be
698
 
        # recorded.
699
 
        if specific_files:
700
 
            for path, new_ie in self.basis_inv.iter_entries():
701
 
                if new_ie.file_id in work_inv:
702
 
                    continue
703
 
                if is_inside_any(specific_files, path):
704
 
                    continue
705
 
                ie = new_ie.copy()
706
 
                ie.revision = None
707
 
                self.builder.record_entry_contents(ie, self.parent_invs, path,
708
 
                                                   self.basis_tree)
709
 
 
710
 
        # Report what was deleted. We could skip this when no deletes are
711
 
        # detected to gain a performance win, but it arguably serves as a
712
 
        # 'safety check' by informing the user whenever anything disappears.
713
 
        for path, ie in self.basis_inv.iter_entries():
714
 
            if ie.file_id not in self.builder.new_inventory:
715
 
                self.reporter.deleted(path)
716
 
 
717
 
    def _emit_progress_set_stage(self, name, show_entries=False):
718
 
        """Set the progress stage and emit an update to the progress bar."""
719
 
        self.pb_stage_name = name
720
 
        self.pb_stage_count += 1
721
 
        self.pb_entries_show = show_entries
722
 
        if show_entries:
723
 
            self.pb_entries_count = 0
724
 
            self.pb_entries_total = '?'
725
 
        self._emit_progress()
726
 
 
727
 
    def _emit_progress_next_entry(self):
728
 
        """Emit an update to the progress bar and increment the file count."""
729
 
        self.pb_entries_count += 1
730
 
        self._emit_progress()
731
 
 
732
 
    def _emit_progress(self):
733
 
        if self.pb_entries_show:
734
 
            text = "%s [Entry %d/%s] - Stage" % (self.pb_stage_name,
735
 
                self.pb_entries_count,str(self.pb_entries_total))
736
 
        else:
737
 
            text = "%s - Stage" % (self.pb_stage_name)
738
 
        self.pb.update(text, self.pb_stage_count, self.pb_stage_total)
739
 
 
 
539
                    # this is selected, ensure its parents are too.
 
540
                    parent_id = new_ie.parent_id
 
541
                    while parent_id != ROOT_ID:
 
542
                        if not self.new_inv.has_id(parent_id):
 
543
                            ie = self._select_entry(self.work_inv[parent_id])
 
544
                            mutter('%s selected for commit because of %s',
 
545
                                   self.new_inv.id2path(parent_id), path)
 
546
 
 
547
                        ie = self.new_inv[parent_id]
 
548
                        if ie.revision is not None:
 
549
                            ie.revision = None
 
550
                            mutter('%s selected for commit because of %s',
 
551
                                   self.new_inv.id2path(parent_id), path)
 
552
                        parent_id = ie.parent_id
 
553
            mutter('%s selected for commit', path)
 
554
            self._select_entry(new_ie)
 
555
 
 
556
    def _select_entry(self, new_ie):
 
557
        """Make new_ie be considered for committing."""
 
558
        ie = new_ie.copy()
 
559
        ie.revision = None
 
560
        self.new_inv.add(ie)
 
561
        return ie
 
562
 
 
563
    def _carry_entry(self, file_id):
 
564
        """Carry the file unchanged from the basis revision."""
 
565
        if self.basis_inv.has_id(file_id):
 
566
            self.new_inv.add(self.basis_inv[file_id].copy())
 
567
 
 
568
    def _report_deletes(self):
 
569
        for file_id in self.basis_inv:
 
570
            if file_id not in self.new_inv:
 
571
                self.reporter.deleted(self.basis_inv.id2path(file_id))
 
572
 
 
573
def _gen_revision_id(config, when):
 
574
    """Return new revision-id."""
 
575
    s = '%s-%s-' % (config.user_email(), compact_date(when))
 
576
    s += hexlify(rand_bytes(8))
 
577
    return s