~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/bzrdir.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
2
 
#
 
1
# Copyright (C) 2005, 2006 Canonical Ltd
 
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
5
5
# the Free Software Foundation; either version 2 of the License, or
6
6
# (at your option) any later version.
7
 
#
 
7
 
8
8
# This program is distributed in the hope that it will be useful,
9
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11
11
# GNU General Public License for more details.
12
 
#
 
12
 
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
20
20
directories.
21
21
"""
22
22
 
23
 
# TODO: Can we move specific formats into separate modules to make this file
24
 
# smaller?
25
 
 
 
23
from copy import deepcopy
 
24
import os
26
25
from cStringIO import StringIO
27
 
import os
28
 
import textwrap
29
 
 
30
 
from bzrlib.lazy_import import lazy_import
31
 
lazy_import(globals(), """
32
 
from stat import S_ISDIR
 
26
from unittest import TestSuite
33
27
 
34
28
import bzrlib
35
 
from bzrlib import (
36
 
    errors,
37
 
    lockable_files,
38
 
    lockdir,
39
 
    registry,
40
 
    remote,
41
 
    revision as _mod_revision,
42
 
    symbol_versioning,
43
 
    ui,
44
 
    urlutils,
45
 
    xml4,
46
 
    xml5,
47
 
    workingtree,
48
 
    workingtree_4,
49
 
    )
 
29
import bzrlib.errors as errors
 
30
from bzrlib.lockable_files import LockableFiles, TransportLock
 
31
from bzrlib.lockdir import LockDir
 
32
from bzrlib.osutils import safe_unicode
50
33
from bzrlib.osutils import (
51
 
    sha_strings,
52
 
    sha_string,
53
 
    )
54
 
from bzrlib.smart.client import _SmartClient
55
 
from bzrlib.smart import protocol
 
34
                            abspath,
 
35
                            pathjoin,
 
36
                            safe_unicode,
 
37
                            sha_strings,
 
38
                            sha_string,
 
39
                            )
56
40
from bzrlib.store.revision.text import TextRevisionStore
57
41
from bzrlib.store.text import TextStore
58
42
from bzrlib.store.versioned import WeaveStore
 
43
from bzrlib.symbol_versioning import *
 
44
from bzrlib.trace import mutter
59
45
from bzrlib.transactions import WriteTransaction
60
 
from bzrlib.transport import (
61
 
    do_catching_redirections,
62
 
    get_transport,
63
 
    )
 
46
from bzrlib.transport import get_transport, urlunescape
 
47
from bzrlib.transport.local import LocalTransport
64
48
from bzrlib.weave import Weave
65
 
""")
66
 
 
67
 
from bzrlib.trace import (
68
 
    mutter,
69
 
    note,
70
 
    )
71
 
from bzrlib.transport.local import LocalTransport
 
49
from bzrlib.xml4 import serializer_v4
 
50
from bzrlib.xml5 import serializer_v5
72
51
 
73
52
 
74
53
class BzrDir(object):
83
62
        a transport connected to the directory this bzr was opened from.
84
63
    """
85
64
 
86
 
    def break_lock(self):
87
 
        """Invoke break_lock on the first object in the bzrdir.
88
 
 
89
 
        If there is a tree, the tree is opened and break_lock() called.
90
 
        Otherwise, branch is tried, and finally repository.
91
 
        """
92
 
        # XXX: This seems more like a UI function than something that really
93
 
        # belongs in this class.
94
 
        try:
95
 
            thing_to_unlock = self.open_workingtree()
96
 
        except (errors.NotLocalUrl, errors.NoWorkingTree):
97
 
            try:
98
 
                thing_to_unlock = self.open_branch()
99
 
            except errors.NotBranchError:
100
 
                try:
101
 
                    thing_to_unlock = self.open_repository()
102
 
                except errors.NoRepositoryPresent:
103
 
                    return
104
 
        thing_to_unlock.break_lock()
105
 
 
106
65
    def can_convert_format(self):
107
66
        """Return true if this bzrdir is one whose format we can convert from."""
108
67
        return True
109
68
 
110
 
    def check_conversion_target(self, target_format):
111
 
        target_repo_format = target_format.repository_format
112
 
        source_repo_format = self._format.repository_format
113
 
        source_repo_format.check_conversion_target(target_repo_format)
114
 
 
115
69
    @staticmethod
116
 
    def _check_supported(format, allow_unsupported,
117
 
        recommend_upgrade=True,
118
 
        basedir=None):
119
 
        """Give an error or warning on old formats.
120
 
 
121
 
        :param format: may be any kind of format - workingtree, branch, 
122
 
        or repository.
123
 
 
124
 
        :param allow_unsupported: If true, allow opening 
125
 
        formats that are strongly deprecated, and which may 
126
 
        have limited functionality.
127
 
 
128
 
        :param recommend_upgrade: If true (default), warn
129
 
        the user through the ui object that they may wish
130
 
        to upgrade the object.
 
70
    def _check_supported(format, allow_unsupported):
 
71
        """Check whether format is a supported format.
 
72
 
 
73
        If allow_unsupported is True, this is a no-op.
131
74
        """
132
 
        # TODO: perhaps move this into a base Format class; it's not BzrDir
133
 
        # specific. mbp 20070323
134
75
        if not allow_unsupported and not format.is_supported():
135
76
            # see open_downlevel to open legacy branches.
136
 
            raise errors.UnsupportedFormatError(format=format)
137
 
        if recommend_upgrade \
138
 
            and getattr(format, 'upgrade_recommended', False):
139
 
            ui.ui_factory.recommend_upgrade(
140
 
                format.get_format_description(),
141
 
                basedir)
 
77
            raise errors.UnsupportedFormatError(
 
78
                    'sorry, format %s not supported' % format,
 
79
                    ['use a different bzr version',
 
80
                     'or remove the .bzr directory'
 
81
                     ' and "bzr init" again'])
142
82
 
143
 
    def clone(self, url, revision_id=None, force_new_repo=False):
 
83
    def clone(self, url, revision_id=None, basis=None, force_new_repo=False):
144
84
        """Clone this bzrdir and its contents to url verbatim.
145
85
 
146
86
        If urls last component does not exist, it will be created.
150
90
        :param force_new_repo: Do not use a shared repository for the target 
151
91
                               even if one is available.
152
92
        """
153
 
        return self.clone_on_transport(get_transport(url),
154
 
                                       revision_id=revision_id,
155
 
                                       force_new_repo=force_new_repo)
156
 
 
157
 
    def clone_on_transport(self, transport, revision_id=None,
158
 
                           force_new_repo=False):
159
 
        """Clone this bzrdir and its contents to transport verbatim.
160
 
 
161
 
        If the target directory does not exist, it will be created.
162
 
 
163
 
        if revision_id is not None, then the clone operation may tune
164
 
            itself to download less data.
165
 
        :param force_new_repo: Do not use a shared repository for the target 
166
 
                               even if one is available.
167
 
        """
168
 
        transport.ensure_base()
169
 
        result = self._format.initialize_on_transport(transport)
 
93
        self._make_tail(url)
 
94
        basis_repo, basis_branch, basis_tree = self._get_basis_components(basis)
 
95
        result = self._format.initialize(url)
170
96
        try:
171
97
            local_repo = self.find_repository()
172
98
        except errors.NoRepositoryPresent:
174
100
        if local_repo:
175
101
            # may need to copy content in
176
102
            if force_new_repo:
177
 
                result_repo = local_repo.clone(
178
 
                    result,
179
 
                    revision_id=revision_id)
180
 
                result_repo.set_make_working_trees(local_repo.make_working_trees())
 
103
                local_repo.clone(result, revision_id=revision_id, basis=basis_repo)
181
104
            else:
182
105
                try:
183
106
                    result_repo = result.find_repository()
184
107
                    # fetch content this dir needs.
 
108
                    if basis_repo:
 
109
                        # XXX FIXME RBC 20060214 need tests for this when the basis
 
110
                        # is incomplete
 
111
                        result_repo.fetch(basis_repo, revision_id=revision_id)
185
112
                    result_repo.fetch(local_repo, revision_id=revision_id)
186
113
                except errors.NoRepositoryPresent:
187
114
                    # needed to make one anyway.
188
 
                    result_repo = local_repo.clone(
189
 
                        result,
190
 
                        revision_id=revision_id)
191
 
                    result_repo.set_make_working_trees(local_repo.make_working_trees())
 
115
                    local_repo.clone(result, revision_id=revision_id, basis=basis_repo)
192
116
        # 1 if there is a branch present
193
117
        #   make sure its content is available in the target repository
194
118
        #   clone it.
197
121
        except errors.NotBranchError:
198
122
            pass
199
123
        try:
200
 
            self.open_workingtree().clone(result)
 
124
            self.open_workingtree().clone(result, basis=basis_tree)
201
125
        except (errors.NoWorkingTree, errors.NotLocalUrl):
202
126
            pass
203
127
        return result
204
128
 
205
 
    # TODO: This should be given a Transport, and should chdir up; otherwise
206
 
    # this will open a new connection.
 
129
    def _get_basis_components(self, basis):
 
130
        """Retrieve the basis components that are available at basis."""
 
131
        if basis is None:
 
132
            return None, None, None
 
133
        try:
 
134
            basis_tree = basis.open_workingtree()
 
135
            basis_branch = basis_tree.branch
 
136
            basis_repo = basis_branch.repository
 
137
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
138
            basis_tree = None
 
139
            try:
 
140
                basis_branch = basis.open_branch()
 
141
                basis_repo = basis_branch.repository
 
142
            except errors.NotBranchError:
 
143
                basis_branch = None
 
144
                try:
 
145
                    basis_repo = basis.open_repository()
 
146
                except errors.NoRepositoryPresent:
 
147
                    basis_repo = None
 
148
        return basis_repo, basis_branch, basis_tree
 
149
 
207
150
    def _make_tail(self, url):
208
 
        t = get_transport(url)
209
 
        t.ensure_base()
 
151
        segments = url.split('/')
 
152
        if segments and segments[-1] not in ('', '.'):
 
153
            parent = '/'.join(segments[:-1])
 
154
            t = bzrlib.transport.get_transport(parent)
 
155
            try:
 
156
                t.mkdir(segments[-1])
 
157
            except errors.FileExists:
 
158
                pass
210
159
 
211
160
    @classmethod
212
 
    def create(cls, base, format=None, possible_transports=None):
 
161
    def create(cls, base):
213
162
        """Create a new BzrDir at the url 'base'.
214
163
        
215
164
        This will call the current default formats initialize with base
216
165
        as the only parameter.
217
166
 
218
 
        :param format: If supplied, the format of branch to create.  If not
219
 
            supplied, the default is used.
220
 
        :param possible_transports: If supplied, a list of transports that 
221
 
            can be reused to share a remote connection.
 
167
        If you need a specific format, consider creating an instance
 
168
        of that and calling initialize().
222
169
        """
223
170
        if cls is not BzrDir:
224
 
            raise AssertionError("BzrDir.create always creates the default"
225
 
                " format, not one of %r" % cls)
226
 
        t = get_transport(base, possible_transports)
227
 
        t.ensure_base()
228
 
        if format is None:
229
 
            format = BzrDirFormat.get_default_format()
230
 
        return format.initialize(base, possible_transports)
 
171
            raise AssertionError("BzrDir.create always creates the default format, "
 
172
                    "not one of %r" % cls)
 
173
        segments = base.split('/')
 
174
        if segments and segments[-1] not in ('', '.'):
 
175
            parent = '/'.join(segments[:-1])
 
176
            t = bzrlib.transport.get_transport(parent)
 
177
            try:
 
178
                t.mkdir(segments[-1])
 
179
            except errors.FileExists:
 
180
                pass
 
181
        return BzrDirFormat.get_default_format().initialize(safe_unicode(base))
231
182
 
232
183
    def create_branch(self):
233
184
        """Create a branch in this BzrDir.
238
189
        raise NotImplementedError(self.create_branch)
239
190
 
240
191
    @staticmethod
241
 
    def create_branch_and_repo(base, force_new_repo=False, format=None):
 
192
    def create_branch_and_repo(base, force_new_repo=False):
242
193
        """Create a new BzrDir, Branch and Repository at the url 'base'.
243
194
 
244
195
        This will use the current default BzrDirFormat, and use whatever 
251
202
        :param base: The URL to create the branch at.
252
203
        :param force_new_repo: If True a new repository is always created.
253
204
        """
254
 
        bzrdir = BzrDir.create(base, format)
 
205
        bzrdir = BzrDir.create(base)
255
206
        bzrdir._find_or_create_repository(force_new_repo)
256
207
        return bzrdir.create_branch()
257
208
 
266
217
        
267
218
    @staticmethod
268
219
    def create_branch_convenience(base, force_new_repo=False,
269
 
                                  force_new_tree=None, format=None,
270
 
                                  possible_transports=None):
 
220
                                  force_new_tree=None, format=None):
271
221
        """Create a new BzrDir, Branch and Repository at the url 'base'.
272
222
 
273
223
        This is a convenience function - it will use an existing repository
289
239
        :param force_new_repo: If True a new repository is always created.
290
240
        :param force_new_tree: If True or False force creation of a tree or 
291
241
                               prevent such creation respectively.
292
 
        :param format: Override for the for the bzrdir format to create.
293
 
        :param possible_transports: An optional reusable transports list.
 
242
        :param format: Override for the for the bzrdir format to create
294
243
        """
295
244
        if force_new_tree:
296
245
            # check for non local urls
297
 
            t = get_transport(base, possible_transports)
 
246
            t = get_transport(safe_unicode(base))
298
247
            if not isinstance(t, LocalTransport):
299
248
                raise errors.NotLocalUrl(base)
300
 
        bzrdir = BzrDir.create(base, format, possible_transports)
 
249
        if format is None:
 
250
            bzrdir = BzrDir.create(base)
 
251
        else:
 
252
            bzrdir = format.initialize(base)
301
253
        repo = bzrdir._find_or_create_repository(force_new_repo)
302
254
        result = bzrdir.create_branch()
303
 
        if force_new_tree or (repo.make_working_trees() and
 
255
        if force_new_tree or (repo.make_working_trees() and 
304
256
                              force_new_tree is None):
305
257
            try:
306
258
                bzrdir.create_workingtree()
307
259
            except errors.NotLocalUrl:
308
260
                pass
309
261
        return result
310
 
 
 
262
        
311
263
    @staticmethod
312
 
    def create_repository(base, shared=False, format=None):
 
264
    def create_repository(base, shared=False):
313
265
        """Create a new BzrDir and Repository at the url 'base'.
314
266
 
315
 
        If no format is supplied, this will default to the current default
316
 
        BzrDirFormat by default, and use whatever repository format that that
317
 
        uses for bzrdirformat.create_repository.
 
267
        This will use the current default BzrDirFormat, and use whatever 
 
268
        repository format that that uses for bzrdirformat.create_repository.
318
269
 
319
 
        :param shared: Create a shared repository rather than a standalone
 
270
        ;param shared: Create a shared repository rather than a standalone
320
271
                       repository.
321
272
        The Repository object is returned.
322
273
 
324
275
        it should take no parameters and construct whatever repository format
325
276
        that child class desires.
326
277
        """
327
 
        bzrdir = BzrDir.create(base, format)
328
 
        return bzrdir.create_repository(shared)
 
278
        bzrdir = BzrDir.create(base)
 
279
        return bzrdir.create_repository()
329
280
 
330
281
    @staticmethod
331
 
    def create_standalone_workingtree(base, format=None):
 
282
    def create_standalone_workingtree(base):
332
283
        """Create a new BzrDir, WorkingTree, Branch and Repository at 'base'.
333
284
 
334
285
        'base' must be a local path or a file:// url.
337
288
        repository format that that uses for bzrdirformat.create_workingtree,
338
289
        create_branch and create_repository.
339
290
 
340
 
        :return: The WorkingTree object.
 
291
        The WorkingTree object is returned.
341
292
        """
342
 
        t = get_transport(base)
 
293
        t = get_transport(safe_unicode(base))
343
294
        if not isinstance(t, LocalTransport):
344
295
            raise errors.NotLocalUrl(base)
345
 
        bzrdir = BzrDir.create_branch_and_repo(base,
346
 
                                               force_new_repo=True,
347
 
                                               format=format).bzrdir
 
296
        bzrdir = BzrDir.create_branch_and_repo(safe_unicode(base),
 
297
                                               force_new_repo=True).bzrdir
348
298
        return bzrdir.create_workingtree()
349
299
 
350
300
    def create_workingtree(self, revision_id=None):
354
304
        """
355
305
        raise NotImplementedError(self.create_workingtree)
356
306
 
357
 
    def retire_bzrdir(self):
358
 
        """Permanently disable the bzrdir.
359
 
 
360
 
        This is done by renaming it to give the user some ability to recover
361
 
        if there was a problem.
362
 
 
363
 
        This will have horrible consequences if anyone has anything locked or
364
 
        in use.
365
 
        """
366
 
        for i in xrange(10000):
367
 
            try:
368
 
                to_path = '.bzr.retired.%d' % i
369
 
                self.root_transport.rename('.bzr', to_path)
370
 
                note("renamed %s to %s"
371
 
                    % (self.root_transport.abspath('.bzr'), to_path))
372
 
                break
373
 
            except (errors.TransportError, IOError, errors.PathError):
374
 
                pass
375
 
 
376
 
    def destroy_workingtree(self):
377
 
        """Destroy the working tree at this BzrDir.
378
 
 
379
 
        Formats that do not support this may raise UnsupportedOperation.
380
 
        """
381
 
        raise NotImplementedError(self.destroy_workingtree)
382
 
 
383
 
    def destroy_workingtree_metadata(self):
384
 
        """Destroy the control files for the working tree at this BzrDir.
385
 
 
386
 
        The contents of working tree files are not affected.
387
 
        Formats that do not support this may raise UnsupportedOperation.
388
 
        """
389
 
        raise NotImplementedError(self.destroy_workingtree_metadata)
390
 
 
391
307
    def find_repository(self):
392
308
        """Find the repository that should be used for a_bzrdir.
393
309
 
401
317
            pass
402
318
        next_transport = self.root_transport.clone('..')
403
319
        while True:
404
 
            # find the next containing bzrdir
405
320
            try:
406
321
                found_bzrdir = BzrDir.open_containing_from_transport(
407
322
                    next_transport)[0]
408
323
            except errors.NotBranchError:
409
 
                # none found
410
324
                raise errors.NoRepositoryPresent(self)
411
 
            # does it have a repository ?
412
325
            try:
413
326
                repository = found_bzrdir.open_repository()
414
327
            except errors.NoRepositoryPresent:
415
328
                next_transport = found_bzrdir.root_transport.clone('..')
416
 
                if (found_bzrdir.root_transport.base == next_transport.base):
417
 
                    # top of the file system
418
 
                    break
419
 
                else:
420
 
                    continue
421
 
            if ((found_bzrdir.root_transport.base ==
 
329
                continue
 
330
            if ((found_bzrdir.root_transport.base == 
422
331
                 self.root_transport.base) or repository.is_shared()):
423
332
                return repository
424
333
            else:
425
334
                raise errors.NoRepositoryPresent(self)
426
335
        raise errors.NoRepositoryPresent(self)
427
336
 
428
 
    def get_branch_reference(self):
429
 
        """Return the referenced URL for the branch in this bzrdir.
430
 
 
431
 
        :raises NotBranchError: If there is no Branch.
432
 
        :return: The URL the branch in this bzrdir references if it is a
433
 
            reference branch, or None for regular branches.
434
 
        """
435
 
        return None
436
 
 
437
337
    def get_branch_transport(self, branch_format):
438
338
        """Get the transport for use by branch format in this BzrDir.
439
339
 
440
340
        Note that bzr dirs that do not support format strings will raise
441
341
        IncompatibleFormat if the branch format they are given has
442
 
        a format string, and vice versa.
 
342
        a format string, and vice verca.
443
343
 
444
344
        If branch_format is None, the transport is returned with no 
445
345
        checking. if it is not None, then the returned transport is
452
352
 
453
353
        Note that bzr dirs that do not support format strings will raise
454
354
        IncompatibleFormat if the repository format they are given has
455
 
        a format string, and vice versa.
 
355
        a format string, and vice verca.
456
356
 
457
357
        If repository_format is None, the transport is returned with no 
458
358
        checking. if it is not None, then the returned transport is
464
364
        """Get the transport for use by workingtree format in this BzrDir.
465
365
 
466
366
        Note that bzr dirs that do not support format strings will raise
467
 
        IncompatibleFormat if the workingtree format they are given has a
468
 
        format string, and vice versa.
 
367
        IncompatibleFormat if the workingtree format they are given has
 
368
        a format string, and vice verca.
469
369
 
470
370
        If workingtree_format is None, the transport is returned with no 
471
371
        checking. if it is not None, then the returned transport is
486
386
        self.transport = _transport.clone('.bzr')
487
387
        self.root_transport = _transport
488
388
 
489
 
    def is_control_filename(self, filename):
490
 
        """True if filename is the name of a path which is reserved for bzrdir's.
491
 
        
492
 
        :param filename: A filename within the root transport of this bzrdir.
493
 
 
494
 
        This is true IF and ONLY IF the filename is part of the namespace reserved
495
 
        for bzr control dirs. Currently this is the '.bzr' directory in the root
496
 
        of the root_transport. it is expected that plugins will need to extend
497
 
        this in the future - for instance to make bzr talk with svn working
498
 
        trees.
499
 
        """
500
 
        # this might be better on the BzrDirFormat class because it refers to 
501
 
        # all the possible bzrdir disk formats. 
502
 
        # This method is tested via the workingtree is_control_filename tests- 
503
 
        # it was extracted from WorkingTree.is_control_filename. If the methods
504
 
        # contract is extended beyond the current trivial  implementation please
505
 
        # add new tests for it to the appropriate place.
506
 
        return filename == '.bzr' or filename.startswith('.bzr/')
507
 
 
508
389
    def needs_format_conversion(self, format=None):
509
390
        """Return true if this bzrdir needs convert_format run on it.
510
391
        
528
409
        _unsupported is a private parameter to the BzrDir class.
529
410
        """
530
411
        t = get_transport(base)
531
 
        return BzrDir.open_from_transport(t, _unsupported=_unsupported)
532
 
 
533
 
    @staticmethod
534
 
    def open_from_transport(transport, _unsupported=False,
535
 
                            _server_formats=True):
536
 
        """Open a bzrdir within a particular directory.
537
 
 
538
 
        :param transport: Transport containing the bzrdir.
539
 
        :param _unsupported: private.
540
 
        """
541
 
        base = transport.base
542
 
 
543
 
        def find_format(transport):
544
 
            return transport, BzrDirFormat.find_format(
545
 
                transport, _server_formats=_server_formats)
546
 
 
547
 
        def redirected(transport, e, redirection_notice):
548
 
            qualified_source = e.get_source_url()
549
 
            relpath = transport.relpath(qualified_source)
550
 
            if not e.target.endswith(relpath):
551
 
                # Not redirected to a branch-format, not a branch
552
 
                raise errors.NotBranchError(path=e.target)
553
 
            target = e.target[:-len(relpath)]
554
 
            note('%s is%s redirected to %s',
555
 
                 transport.base, e.permanently, target)
556
 
            # Let's try with a new transport
557
 
            qualified_target = e.get_target_url()[:-len(relpath)]
558
 
            # FIXME: If 'transport' has a qualifier, this should
559
 
            # be applied again to the new transport *iff* the
560
 
            # schemes used are the same. It's a bit tricky to
561
 
            # verify, so I'll punt for now
562
 
            # -- vila20070212
563
 
            return get_transport(target)
564
 
 
565
 
        try:
566
 
            transport, format = do_catching_redirections(find_format,
567
 
                                                         transport,
568
 
                                                         redirected)
569
 
        except errors.TooManyRedirections:
570
 
            raise errors.NotBranchError(base)
571
 
 
 
412
        mutter("trying to open %r with transport %r", base, t)
 
413
        format = BzrDirFormat.find_format(t)
572
414
        BzrDir._check_supported(format, _unsupported)
573
 
        return format.open(transport, _found=True)
 
415
        return format.open(t, _found=True)
574
416
 
575
417
    def open_branch(self, unsupported=False):
576
418
        """Open the branch object at this BzrDir if one is present.
583
425
        raise NotImplementedError(self.open_branch)
584
426
 
585
427
    @staticmethod
586
 
    def open_containing(url, possible_transports=None):
 
428
    def open_containing(url):
587
429
        """Open an existing branch which contains url.
588
430
        
589
431
        :param url: url to search from.
590
432
        See open_containing_from_transport for more detail.
591
433
        """
592
 
        transport = get_transport(url, possible_transports)
593
 
        return BzrDir.open_containing_from_transport(transport)
 
434
        return BzrDir.open_containing_from_transport(get_transport(url))
594
435
    
595
436
    @staticmethod
596
437
    def open_containing_from_transport(a_transport):
603
444
        If there is one and it is either an unrecognised format or an unsupported 
604
445
        format, UnknownFormatError or UnsupportedFormatError are raised.
605
446
        If there is one, it is returned, along with the unused portion of url.
606
 
 
607
 
        :return: The BzrDir that contains the path, and a Unicode path 
608
 
                for the rest of the URL.
609
447
        """
610
448
        # this gets the normalised url back. I.e. '.' -> the full path.
611
449
        url = a_transport.base
612
450
        while True:
613
451
            try:
614
 
                result = BzrDir.open_from_transport(a_transport)
615
 
                return result, urlutils.unescape(a_transport.relpath(url))
 
452
                format = BzrDirFormat.find_format(a_transport)
 
453
                BzrDir._check_supported(format, False)
 
454
                return format.open(a_transport), a_transport.relpath(url)
616
455
            except errors.NotBranchError, e:
617
 
                pass
618
 
            try:
619
 
                new_t = a_transport.clone('..')
620
 
            except errors.InvalidURLJoin:
621
 
                # reached the root, whatever that may be
622
 
                raise errors.NotBranchError(path=url)
 
456
                mutter('not a branch in: %r %s', a_transport.base, e)
 
457
            new_t = a_transport.clone('..')
623
458
            if new_t.base == a_transport.base:
624
459
                # reached the root, whatever that may be
625
460
                raise errors.NotBranchError(path=url)
626
461
            a_transport = new_t
627
462
 
628
 
    @classmethod
629
 
    def open_containing_tree_or_branch(klass, location):
630
 
        """Return the branch and working tree contained by a location.
631
 
 
632
 
        Returns (tree, branch, relpath).
633
 
        If there is no tree at containing the location, tree will be None.
634
 
        If there is no branch containing the location, an exception will be
635
 
        raised
636
 
        relpath is the portion of the path that is contained by the branch.
637
 
        """
638
 
        bzrdir, relpath = klass.open_containing(location)
639
 
        try:
640
 
            tree = bzrdir.open_workingtree()
641
 
        except (errors.NoWorkingTree, errors.NotLocalUrl):
642
 
            tree = None
643
 
            branch = bzrdir.open_branch()
644
 
        else:
645
 
            branch = tree.branch
646
 
        return tree, branch, relpath
647
 
 
648
463
    def open_repository(self, _unsupported=False):
649
464
        """Open the repository object at this BzrDir if one is present.
650
465
 
657
472
        """
658
473
        raise NotImplementedError(self.open_repository)
659
474
 
660
 
    def open_workingtree(self, _unsupported=False,
661
 
            recommend_upgrade=True):
 
475
    def open_workingtree(self, _unsupported=False):
662
476
        """Open the workingtree object at this BzrDir if one is present.
663
 
 
664
 
        :param recommend_upgrade: Optional keyword parameter, when True (the
665
 
            default), emit through the ui module a recommendation that the user
666
 
            upgrade the working tree when the workingtree being opened is old
667
 
            (but still fully supported).
 
477
        
 
478
        TODO: static convenience version of this?
668
479
        """
669
480
        raise NotImplementedError(self.open_workingtree)
670
481
 
671
 
    def has_branch(self):
672
 
        """Tell if this bzrdir contains a branch.
673
 
        
674
 
        Note: if you're going to open the branch, you should just go ahead
675
 
        and try, and not ask permission first.  (This method just opens the 
676
 
        branch and discards it, and that's somewhat expensive.) 
677
 
        """
678
 
        try:
679
 
            self.open_branch()
680
 
            return True
681
 
        except errors.NotBranchError:
682
 
            return False
683
 
 
684
 
    def has_workingtree(self):
685
 
        """Tell if this bzrdir contains a working tree.
686
 
 
687
 
        This will still raise an exception if the bzrdir has a workingtree that
688
 
        is remote & inaccessible.
689
 
        
690
 
        Note: if you're going to open the working tree, you should just go ahead
691
 
        and try, and not ask permission first.  (This method just opens the 
692
 
        workingtree and discards it, and that's somewhat expensive.) 
693
 
        """
694
 
        try:
695
 
            self.open_workingtree(recommend_upgrade=False)
696
 
            return True
697
 
        except errors.NoWorkingTree:
698
 
            return False
699
 
 
700
 
    def _cloning_metadir(self):
701
 
        """Produce a metadir suitable for cloning with"""
702
 
        result_format = self._format.__class__()
703
 
        try:
704
 
            try:
705
 
                branch = self.open_branch()
706
 
                source_repository = branch.repository
707
 
            except errors.NotBranchError:
708
 
                source_branch = None
709
 
                source_repository = self.open_repository()
710
 
        except errors.NoRepositoryPresent:
711
 
            source_repository = None
712
 
        else:
713
 
            # XXX TODO: This isinstance is here because we have not implemented
714
 
            # the fix recommended in bug # 103195 - to delegate this choice the
715
 
            # repository itself.
716
 
            repo_format = source_repository._format
717
 
            if not isinstance(repo_format, remote.RemoteRepositoryFormat):
718
 
                result_format.repository_format = repo_format
719
 
        try:
720
 
            # TODO: Couldn't we just probe for the format in these cases,
721
 
            # rather than opening the whole tree?  It would be a little
722
 
            # faster. mbp 20070401
723
 
            tree = self.open_workingtree(recommend_upgrade=False)
724
 
        except (errors.NoWorkingTree, errors.NotLocalUrl):
725
 
            result_format.workingtree_format = None
726
 
        else:
727
 
            result_format.workingtree_format = tree._format.__class__()
728
 
        return result_format, source_repository
729
 
 
730
 
    def cloning_metadir(self):
731
 
        """Produce a metadir suitable for cloning or sprouting with.
732
 
 
733
 
        These operations may produce workingtrees (yes, even though they're
734
 
        "cloning" something that doesn't have a tree, so a viable workingtree
735
 
        format must be selected.
736
 
        """
737
 
        format, repository = self._cloning_metadir()
738
 
        if format._workingtree_format is None:
739
 
            if repository is None:
740
 
                return format
741
 
            tree_format = repository._format._matchingbzrdir.workingtree_format
742
 
            format.workingtree_format = tree_format.__class__()
743
 
        return format
744
 
 
745
 
    def checkout_metadir(self):
746
 
        return self.cloning_metadir()
747
 
 
748
 
    def sprout(self, url, revision_id=None, force_new_repo=False,
749
 
               recurse='down', possible_transports=None):
 
482
    def sprout(self, url, revision_id=None, basis=None, force_new_repo=False):
750
483
        """Create a copy of this bzrdir prepared for use as a new line of
751
484
        development.
752
485
 
760
493
        if revision_id is not None, then the clone operation may tune
761
494
            itself to download less data.
762
495
        """
763
 
        target_transport = get_transport(url, possible_transports)
764
 
        target_transport.ensure_base()
765
 
        cloning_format = self.cloning_metadir()
766
 
        result = cloning_format.initialize_on_transport(target_transport)
 
496
        self._make_tail(url)
 
497
        result = self._format.initialize(url)
 
498
        basis_repo, basis_branch, basis_tree = self._get_basis_components(basis)
767
499
        try:
768
500
            source_branch = self.open_branch()
769
501
            source_repository = source_branch.repository
772
504
            try:
773
505
                source_repository = self.open_repository()
774
506
            except errors.NoRepositoryPresent:
775
 
                source_repository = None
 
507
                # copy the entire basis one if there is one
 
508
                # but there is no repository.
 
509
                source_repository = basis_repo
776
510
        if force_new_repo:
777
511
            result_repo = None
778
512
        else:
786
520
            # no repo available, make a new one
787
521
            result.create_repository()
788
522
        elif source_repository is not None and result_repo is None:
789
 
            # have source, and want to make a new target repo
790
 
            result_repo = source_repository.sprout(result,
791
 
                                                   revision_id=revision_id)
 
523
            # have soure, and want to make a new target repo
 
524
            source_repository.clone(result,
 
525
                                    revision_id=revision_id,
 
526
                                    basis=basis_repo)
792
527
        else:
793
528
            # fetch needed content into target.
794
 
            if source_repository is not None:
795
 
                # would rather do 
796
 
                # source_repository.copy_content_into(result_repo,
797
 
                #                                     revision_id=revision_id)
798
 
                # so we can override the copy method
799
 
                result_repo.fetch(source_repository, revision_id=revision_id)
 
529
            if basis_repo:
 
530
                # XXX FIXME RBC 20060214 need tests for this when the basis
 
531
                # is incomplete
 
532
                result_repo.fetch(basis_repo, revision_id=revision_id)
 
533
            result_repo.fetch(source_repository, revision_id=revision_id)
800
534
        if source_branch is not None:
801
535
            source_branch.sprout(result, revision_id=revision_id)
802
536
        else:
803
537
            result.create_branch()
804
 
        if isinstance(target_transport, LocalTransport) and (
805
 
            result_repo is None or result_repo.make_working_trees()):
806
 
            wt = result.create_workingtree()
807
 
            wt.lock_write()
808
 
            try:
809
 
                if wt.path2id('') is None:
810
 
                    try:
811
 
                        wt.set_root_id(self.open_workingtree.get_root_id())
812
 
                    except errors.NoWorkingTree:
813
 
                        pass
814
 
            finally:
815
 
                wt.unlock()
816
 
        else:
817
 
            wt = None
818
 
        if recurse == 'down':
819
 
            if wt is not None:
820
 
                basis = wt.basis_tree()
821
 
                basis.lock_read()
822
 
                subtrees = basis.iter_references()
823
 
                recurse_branch = wt.branch
824
 
            elif source_branch is not None:
825
 
                basis = source_branch.basis_tree()
826
 
                basis.lock_read()
827
 
                subtrees = basis.iter_references()
828
 
                recurse_branch = source_branch
829
 
            else:
830
 
                subtrees = []
831
 
                basis = None
832
 
            try:
833
 
                for path, file_id in subtrees:
834
 
                    target = urlutils.join(url, urlutils.escape(path))
835
 
                    sublocation = source_branch.reference_parent(file_id, path)
836
 
                    sublocation.bzrdir.sprout(target,
837
 
                        basis.get_reference_revision(file_id, path),
838
 
                        force_new_repo=force_new_repo, recurse=recurse)
839
 
            finally:
840
 
                if basis is not None:
841
 
                    basis.unlock()
 
538
        if result_repo is None or result_repo.make_working_trees():
 
539
            result.create_workingtree()
842
540
        return result
843
541
 
844
542
 
848
546
    def __init__(self, _transport, _format):
849
547
        """See BzrDir.__init__."""
850
548
        super(BzrDirPreSplitOut, self).__init__(_transport, _format)
851
 
        assert self._format._lock_class == lockable_files.TransportLock
 
549
        assert self._format._lock_class == TransportLock
852
550
        assert self._format._lock_file_name == 'branch-lock'
853
 
        self._control_files = lockable_files.LockableFiles(
854
 
                                            self.get_branch_transport(None),
 
551
        self._control_files = LockableFiles(self.get_branch_transport(None),
855
552
                                            self._format._lock_file_name,
856
553
                                            self._format._lock_class)
857
554
 
858
 
    def break_lock(self):
859
 
        """Pre-splitout bzrdirs do not suffer from stale locks."""
860
 
        raise NotImplementedError(self.break_lock)
861
 
 
862
 
    def clone(self, url, revision_id=None, force_new_repo=False):
 
555
    def clone(self, url, revision_id=None, basis=None, force_new_repo=False):
863
556
        """See BzrDir.clone()."""
864
557
        from bzrlib.workingtree import WorkingTreeFormat2
865
558
        self._make_tail(url)
866
 
        result = self._format._initialize_for_clone(url)
867
 
        self.open_repository().clone(result, revision_id=revision_id)
868
 
        from_branch = self.open_branch()
869
 
        from_branch.clone(result, revision_id=revision_id)
 
559
        result = self._format.initialize(url, _cloning=True)
 
560
        basis_repo, basis_branch, basis_tree = self._get_basis_components(basis)
 
561
        self.open_repository().clone(result, revision_id=revision_id, basis=basis_repo)
 
562
        self.open_branch().clone(result, revision_id=revision_id)
870
563
        try:
871
 
            self.open_workingtree().clone(result)
 
564
            self.open_workingtree().clone(result, basis=basis_tree)
872
565
        except errors.NotLocalUrl:
873
566
            # make a new one, this format always has to have one.
874
567
            try:
875
568
                WorkingTreeFormat2().initialize(result)
876
569
            except errors.NotLocalUrl:
877
 
                # but we cannot do it for remote trees.
878
 
                to_branch = result.open_branch()
879
 
                WorkingTreeFormat2().stub_initialize_remote(to_branch.control_files)
 
570
                # but we canot do it for remote trees.
 
571
                pass
880
572
        return result
881
573
 
882
574
    def create_branch(self):
892
584
    def create_workingtree(self, revision_id=None):
893
585
        """See BzrDir.create_workingtree."""
894
586
        # this looks buggy but is not -really-
895
 
        # because this format creates the workingtree when the bzrdir is
896
 
        # created
897
587
        # clone and sprout will have set the revision_id
898
588
        # and that will have set it for us, its only
899
589
        # specific uses of create_workingtree in isolation
900
590
        # that can do wonky stuff here, and that only
901
591
        # happens for creating checkouts, which cannot be 
902
592
        # done on this format anyway. So - acceptable wart.
903
 
        result = self.open_workingtree(recommend_upgrade=False)
 
593
        result = self.open_workingtree()
904
594
        if revision_id is not None:
905
 
            if revision_id == _mod_revision.NULL_REVISION:
906
 
                result.set_parent_ids([])
907
 
            else:
908
 
                result.set_parent_ids([revision_id])
 
595
            result.set_last_revision(revision_id)
909
596
        return result
910
597
 
911
 
    def destroy_workingtree(self):
912
 
        """See BzrDir.destroy_workingtree."""
913
 
        raise errors.UnsupportedOperation(self.destroy_workingtree, self)
914
 
 
915
 
    def destroy_workingtree_metadata(self):
916
 
        """See BzrDir.destroy_workingtree_metadata."""
917
 
        raise errors.UnsupportedOperation(self.destroy_workingtree_metadata, 
918
 
                                          self)
919
 
 
920
598
    def get_branch_transport(self, branch_format):
921
599
        """See BzrDir.get_branch_transport()."""
922
600
        if branch_format is None:
962
640
        self._check_supported(format, unsupported)
963
641
        return format.open(self, _found=True)
964
642
 
965
 
    def sprout(self, url, revision_id=None, force_new_repo=False,
966
 
               possible_transports=None):
 
643
    def sprout(self, url, revision_id=None, basis=None):
967
644
        """See BzrDir.sprout()."""
968
645
        from bzrlib.workingtree import WorkingTreeFormat2
969
646
        self._make_tail(url)
970
 
        result = self._format._initialize_for_clone(url)
 
647
        result = self._format.initialize(url, _cloning=True)
 
648
        basis_repo, basis_branch, basis_tree = self._get_basis_components(basis)
971
649
        try:
972
 
            self.open_repository().clone(result, revision_id=revision_id)
 
650
            self.open_repository().clone(result, revision_id=revision_id, basis=basis_repo)
973
651
        except errors.NoRepositoryPresent:
974
652
            pass
975
653
        try:
997
675
 
998
676
    def open_repository(self):
999
677
        """See BzrDir.open_repository."""
1000
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat4
 
678
        from bzrlib.repository import RepositoryFormat4
1001
679
        return RepositoryFormat4().open(self, _found=True)
1002
680
 
1003
681
 
1009
687
 
1010
688
    def open_repository(self):
1011
689
        """See BzrDir.open_repository."""
1012
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
 
690
        from bzrlib.repository import RepositoryFormat5
1013
691
        return RepositoryFormat5().open(self, _found=True)
1014
692
 
1015
 
    def open_workingtree(self, _unsupported=False,
1016
 
            recommend_upgrade=True):
 
693
    def open_workingtree(self, _unsupported=False):
1017
694
        """See BzrDir.create_workingtree."""
1018
695
        from bzrlib.workingtree import WorkingTreeFormat2
1019
 
        wt_format = WorkingTreeFormat2()
1020
 
        # we don't warn here about upgrades; that ought to be handled for the
1021
 
        # bzrdir as a whole
1022
 
        return wt_format.open(self, _found=True)
 
696
        return WorkingTreeFormat2().open(self, _found=True)
1023
697
 
1024
698
 
1025
699
class BzrDir6(BzrDirPreSplitOut):
1030
704
 
1031
705
    def open_repository(self):
1032
706
        """See BzrDir.open_repository."""
1033
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
 
707
        from bzrlib.repository import RepositoryFormat6
1034
708
        return RepositoryFormat6().open(self, _found=True)
1035
709
 
1036
 
    def open_workingtree(self, _unsupported=False,
1037
 
        recommend_upgrade=True):
 
710
    def open_workingtree(self, _unsupported=False):
1038
711
        """See BzrDir.create_workingtree."""
1039
 
        # we don't warn here about upgrades; that ought to be handled for the
1040
 
        # bzrdir as a whole
1041
712
        from bzrlib.workingtree import WorkingTreeFormat2
1042
713
        return WorkingTreeFormat2().open(self, _found=True)
1043
714
 
1057
728
 
1058
729
    def create_branch(self):
1059
730
        """See BzrDir.create_branch."""
1060
 
        return self._format.get_branch_format().initialize(self)
 
731
        from bzrlib.branch import BranchFormat
 
732
        return BranchFormat.get_default_format().initialize(self)
1061
733
 
1062
734
    def create_repository(self, shared=False):
1063
735
        """See BzrDir.create_repository."""
1066
738
    def create_workingtree(self, revision_id=None):
1067
739
        """See BzrDir.create_workingtree."""
1068
740
        from bzrlib.workingtree import WorkingTreeFormat
1069
 
        return self._format.workingtree_format.initialize(self, revision_id)
1070
 
 
1071
 
    def destroy_workingtree(self):
1072
 
        """See BzrDir.destroy_workingtree."""
1073
 
        wt = self.open_workingtree(recommend_upgrade=False)
1074
 
        repository = wt.branch.repository
1075
 
        empty = repository.revision_tree(_mod_revision.NULL_REVISION)
1076
 
        wt.revert([], old_tree=empty)
1077
 
        self.destroy_workingtree_metadata()
1078
 
 
1079
 
    def destroy_workingtree_metadata(self):
1080
 
        self.transport.delete_tree('checkout')
1081
 
 
1082
 
    def find_branch_format(self):
1083
 
        """Find the branch 'format' for this bzrdir.
1084
 
 
1085
 
        This might be a synthetic object for e.g. RemoteBranch and SVN.
1086
 
        """
1087
 
        from bzrlib.branch import BranchFormat
1088
 
        return BranchFormat.find_format(self)
1089
 
 
1090
 
    def _get_mkdir_mode(self):
1091
 
        """Figure out the mode to use when creating a bzrdir subdir."""
1092
 
        temp_control = lockable_files.LockableFiles(self.transport, '',
1093
 
                                     lockable_files.TransportLock)
1094
 
        return temp_control._dir_mode
1095
 
 
1096
 
    def get_branch_reference(self):
1097
 
        """See BzrDir.get_branch_reference()."""
1098
 
        from bzrlib.branch import BranchFormat
1099
 
        format = BranchFormat.find_format(self)
1100
 
        return format.get_reference(self)
 
741
        return WorkingTreeFormat.get_default_format().initialize(self, revision_id)
1101
742
 
1102
743
    def get_branch_transport(self, branch_format):
1103
744
        """See BzrDir.get_branch_transport()."""
1108
749
        except NotImplementedError:
1109
750
            raise errors.IncompatibleFormat(branch_format, self._format)
1110
751
        try:
1111
 
            self.transport.mkdir('branch', mode=self._get_mkdir_mode())
 
752
            self.transport.mkdir('branch')
1112
753
        except errors.FileExists:
1113
754
            pass
1114
755
        return self.transport.clone('branch')
1122
763
        except NotImplementedError:
1123
764
            raise errors.IncompatibleFormat(repository_format, self._format)
1124
765
        try:
1125
 
            self.transport.mkdir('repository', mode=self._get_mkdir_mode())
 
766
            self.transport.mkdir('repository')
1126
767
        except errors.FileExists:
1127
768
            pass
1128
769
        return self.transport.clone('repository')
1136
777
        except NotImplementedError:
1137
778
            raise errors.IncompatibleFormat(workingtree_format, self._format)
1138
779
        try:
1139
 
            self.transport.mkdir('checkout', mode=self._get_mkdir_mode())
 
780
            self.transport.mkdir('checkout')
1140
781
        except errors.FileExists:
1141
782
            pass
1142
783
        return self.transport.clone('checkout')
1156
797
                return True
1157
798
        except errors.NoRepositoryPresent:
1158
799
            pass
1159
 
        try:
1160
 
            if not isinstance(self.open_branch()._format,
1161
 
                              format.get_branch_format().__class__):
1162
 
                # the branch needs an upgrade.
1163
 
                return True
1164
 
        except errors.NotBranchError:
1165
 
            pass
1166
 
        try:
1167
 
            my_wt = self.open_workingtree(recommend_upgrade=False)
1168
 
            if not isinstance(my_wt._format,
1169
 
                              format.workingtree_format.__class__):
1170
 
                # the workingtree needs an upgrade.
1171
 
                return True
1172
 
        except (errors.NoWorkingTree, errors.NotLocalUrl):
1173
 
            pass
 
800
        # currently there are no other possible conversions for meta1 formats.
1174
801
        return False
1175
802
 
1176
803
    def open_branch(self, unsupported=False):
1177
804
        """See BzrDir.open_branch."""
1178
 
        format = self.find_branch_format()
 
805
        from bzrlib.branch import BranchFormat
 
806
        format = BranchFormat.find_format(self)
1179
807
        self._check_supported(format, unsupported)
1180
808
        return format.open(self, _found=True)
1181
809
 
1186
814
        self._check_supported(format, unsupported)
1187
815
        return format.open(self, _found=True)
1188
816
 
1189
 
    def open_workingtree(self, unsupported=False,
1190
 
            recommend_upgrade=True):
 
817
    def open_workingtree(self, unsupported=False):
1191
818
        """See BzrDir.open_workingtree."""
1192
819
        from bzrlib.workingtree import WorkingTreeFormat
1193
820
        format = WorkingTreeFormat.find_format(self)
1194
 
        self._check_supported(format, unsupported,
1195
 
            recommend_upgrade,
1196
 
            basedir=self.root_transport.base)
 
821
        self._check_supported(format, unsupported)
1197
822
        return format.open(self, _found=True)
1198
823
 
1199
824
 
1220
845
    _formats = {}
1221
846
    """The known formats."""
1222
847
 
1223
 
    _control_formats = []
1224
 
    """The registered control formats - .bzr, ....
1225
 
    
1226
 
    This is a list of BzrDirFormat objects.
1227
 
    """
1228
 
 
1229
 
    _control_server_formats = []
1230
 
    """The registered control server formats, e.g. RemoteBzrDirs.
1231
 
 
1232
 
    This is a list of BzrDirFormat objects.
1233
 
    """
1234
 
 
1235
848
    _lock_file_name = 'branch-lock'
1236
849
 
1237
850
    # _lock_class must be set in subclasses to the lock type, typ.
1238
851
    # TransportLock or LockDir
1239
852
 
1240
853
    @classmethod
1241
 
    def find_format(klass, transport, _server_formats=True):
1242
 
        """Return the format present at transport."""
1243
 
        if _server_formats:
1244
 
            formats = klass._control_server_formats + klass._control_formats
1245
 
        else:
1246
 
            formats = klass._control_formats
1247
 
        for format in formats:
1248
 
            try:
1249
 
                return format.probe_transport(transport)
1250
 
            except errors.NotBranchError:
1251
 
                # this format does not find a control dir here.
1252
 
                pass
1253
 
        raise errors.NotBranchError(path=transport.base)
1254
 
 
1255
 
    @classmethod
1256
 
    def probe_transport(klass, transport):
1257
 
        """Return the .bzrdir style format present in a directory."""
 
854
    def find_format(klass, transport):
 
855
        """Return the format registered for URL."""
1258
856
        try:
1259
857
            format_string = transport.get(".bzr/branch-format").read()
1260
 
        except errors.NoSuchFile:
1261
 
            raise errors.NotBranchError(path=transport.base)
1262
 
 
1263
 
        try:
1264
858
            return klass._formats[format_string]
 
859
        except errors.NoSuchFile:
 
860
            raise errors.NotBranchError(path=transport.base)
1265
861
        except KeyError:
1266
 
            raise errors.UnknownFormatError(format=format_string)
 
862
            raise errors.UnknownFormatError(format_string)
1267
863
 
1268
864
    @classmethod
1269
865
    def get_default_format(klass):
1274
870
        """Return the ASCII format string that identifies this format."""
1275
871
        raise NotImplementedError(self.get_format_string)
1276
872
 
1277
 
    def get_format_description(self):
1278
 
        """Return the short description for this format."""
1279
 
        raise NotImplementedError(self.get_format_description)
1280
 
 
1281
873
    def get_converter(self, format=None):
1282
874
        """Return the converter to use to convert bzrdirs needing converts.
1283
875
 
1284
876
        This returns a bzrlib.bzrdir.Converter object.
1285
877
 
1286
878
        This should return the best upgrader to step this format towards the
1287
 
        current default format. In the case of plugins we can/should provide
 
879
        current default format. In the case of plugins we can/shouold provide
1288
880
        some means for them to extend the range of returnable converters.
1289
881
 
1290
 
        :param format: Optional format to override the default format of the 
 
882
        :param format: Optional format to override the default foramt of the 
1291
883
                       library.
1292
884
        """
1293
885
        raise NotImplementedError(self.get_converter)
1294
886
 
1295
 
    def initialize(self, url, possible_transports=None):
1296
 
        """Create a bzr control dir at this url and return an opened copy.
1297
 
        
1298
 
        Subclasses should typically override initialize_on_transport
1299
 
        instead of this method.
1300
 
        """
1301
 
        return self.initialize_on_transport(get_transport(url,
1302
 
                                                          possible_transports))
1303
 
 
1304
 
    def initialize_on_transport(self, transport):
1305
 
        """Initialize a new bzrdir in the base directory of a Transport."""
 
887
    def initialize(self, url):
 
888
        """Create a bzr control dir at this url and return an opened copy."""
1306
889
        # Since we don't have a .bzr directory, inherit the
1307
890
        # mode from the root directory
1308
 
        temp_control = lockable_files.LockableFiles(transport,
1309
 
                            '', lockable_files.TransportLock)
 
891
        t = get_transport(url)
 
892
        temp_control = LockableFiles(t, '', TransportLock)
1310
893
        temp_control._transport.mkdir('.bzr',
1311
 
                                      # FIXME: RBC 20060121 don't peek under
 
894
                                      # FIXME: RBC 20060121 dont peek under
1312
895
                                      # the covers
1313
896
                                      mode=temp_control._dir_mode)
1314
897
        file_mode = temp_control._file_mode
1315
898
        del temp_control
1316
 
        mutter('created control directory in ' + transport.base)
1317
 
        control = transport.clone('.bzr')
 
899
        mutter('created control directory in ' + t.base)
 
900
        control = t.clone('.bzr')
1318
901
        utf8_files = [('README', 
1319
902
                       "This is a Bazaar-NG control directory.\n"
1320
903
                       "Do not change any files in this directory.\n"),
1321
904
                      ('branch-format', self.get_format_string()),
1322
905
                      ]
1323
906
        # NB: no need to escape relative paths that are url safe.
1324
 
        control_files = lockable_files.LockableFiles(control,
1325
 
                            self._lock_file_name, self._lock_class)
 
907
        control_files = LockableFiles(control, self._lock_file_name, self._lock_class)
1326
908
        control_files.create_lock()
1327
909
        control_files.lock_write()
1328
910
        try:
1330
912
                control_files.put_utf8(file, content)
1331
913
        finally:
1332
914
            control_files.unlock()
1333
 
        return self.open(transport, _found=True)
 
915
        return self.open(t, _found=True)
1334
916
 
1335
917
    def is_supported(self):
1336
918
        """Is this format supported?
1341
923
        """
1342
924
        return True
1343
925
 
1344
 
    def same_model(self, target_format):
1345
 
        return (self.repository_format.rich_root_data == 
1346
 
            target_format.rich_root_data)
1347
 
 
1348
 
    @classmethod
1349
 
    def known_formats(klass):
1350
 
        """Return all the known formats.
1351
 
        
1352
 
        Concrete formats should override _known_formats.
1353
 
        """
1354
 
        # There is double indirection here to make sure that control 
1355
 
        # formats used by more than one dir format will only be probed 
1356
 
        # once. This can otherwise be quite expensive for remote connections.
1357
 
        result = set()
1358
 
        for format in klass._control_formats:
1359
 
            result.update(format._known_formats())
1360
 
        return result
1361
 
    
1362
 
    @classmethod
1363
 
    def _known_formats(klass):
1364
 
        """Return the known format instances for this control format."""
1365
 
        return set(klass._formats.values())
1366
 
 
1367
926
    def open(self, transport, _found=False):
1368
927
        """Return an instance of this format for the dir transport points at.
1369
928
        
1370
929
        _found is a private parameter, do not use it.
1371
930
        """
1372
931
        if not _found:
1373
 
            found_format = BzrDirFormat.find_format(transport)
1374
 
            if not isinstance(found_format, self.__class__):
1375
 
                raise AssertionError("%s was asked to open %s, but it seems to need "
1376
 
                        "format %s" 
1377
 
                        % (self, transport, found_format))
 
932
            assert isinstance(BzrDirFormat.find_format(transport),
 
933
                              self.__class__)
1378
934
        return self._open(transport)
1379
935
 
1380
936
    def _open(self, transport):
1390
946
        klass._formats[format.get_format_string()] = format
1391
947
 
1392
948
    @classmethod
1393
 
    def register_control_format(klass, format):
1394
 
        """Register a format that does not use '.bzr' for its control dir.
1395
 
 
1396
 
        TODO: This should be pulled up into a 'ControlDirFormat' base class
1397
 
        which BzrDirFormat can inherit from, and renamed to register_format 
1398
 
        there. It has been done without that for now for simplicity of
1399
 
        implementation.
1400
 
        """
1401
 
        klass._control_formats.append(format)
1402
 
 
1403
 
    @classmethod
1404
 
    def register_control_server_format(klass, format):
1405
 
        """Register a control format for client-server environments.
1406
 
 
1407
 
        These formats will be tried before ones registered with
1408
 
        register_control_format.  This gives implementations that decide to the
1409
 
        chance to grab it before anything looks at the contents of the format
1410
 
        file.
1411
 
        """
1412
 
        klass._control_server_formats.append(format)
1413
 
 
1414
 
    @classmethod
1415
 
    @symbol_versioning.deprecated_method(symbol_versioning.zero_fourteen)
1416
949
    def set_default_format(klass, format):
1417
 
        klass._set_default_format(format)
1418
 
 
1419
 
    @classmethod
1420
 
    def _set_default_format(klass, format):
1421
 
        """Set default format (for testing behavior of defaults only)"""
1422
950
        klass._default_format = format
1423
951
 
1424
952
    def __str__(self):
1429
957
        assert klass._formats[format.get_format_string()] is format
1430
958
        del klass._formats[format.get_format_string()]
1431
959
 
1432
 
    @classmethod
1433
 
    def unregister_control_format(klass, format):
1434
 
        klass._control_formats.remove(format)
1435
 
 
1436
960
 
1437
961
class BzrDirFormat4(BzrDirFormat):
1438
962
    """Bzr dir format 4.
1447
971
    removed in format 5; write support for this format has been removed.
1448
972
    """
1449
973
 
1450
 
    _lock_class = lockable_files.TransportLock
 
974
    _lock_class = TransportLock
1451
975
 
1452
976
    def get_format_string(self):
1453
977
        """See BzrDirFormat.get_format_string()."""
1454
978
        return "Bazaar-NG branch, format 0.0.4\n"
1455
979
 
1456
 
    def get_format_description(self):
1457
 
        """See BzrDirFormat.get_format_description()."""
1458
 
        return "All-in-one format 4"
1459
 
 
1460
980
    def get_converter(self, format=None):
1461
981
        """See BzrDirFormat.get_converter()."""
1462
982
        # there is one and only one upgrade path here.
1463
983
        return ConvertBzrDir4To5()
1464
984
        
1465
 
    def initialize_on_transport(self, transport):
 
985
    def initialize(self, url):
1466
986
        """Format 4 branches cannot be created."""
1467
987
        raise errors.UninitializableFormat(self)
1468
988
 
1481
1001
 
1482
1002
    def __return_repository_format(self):
1483
1003
        """Circular import protection."""
1484
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat4
1485
 
        return RepositoryFormat4()
 
1004
        from bzrlib.repository import RepositoryFormat4
 
1005
        return RepositoryFormat4(self)
1486
1006
    repository_format = property(__return_repository_format)
1487
1007
 
1488
1008
 
1497
1017
       Unhashed stores in the repository.
1498
1018
    """
1499
1019
 
1500
 
    _lock_class = lockable_files.TransportLock
 
1020
    _lock_class = TransportLock
1501
1021
 
1502
1022
    def get_format_string(self):
1503
1023
        """See BzrDirFormat.get_format_string()."""
1504
1024
        return "Bazaar-NG branch, format 5\n"
1505
1025
 
1506
 
    def get_format_description(self):
1507
 
        """See BzrDirFormat.get_format_description()."""
1508
 
        return "All-in-one format 5"
1509
 
 
1510
1026
    def get_converter(self, format=None):
1511
1027
        """See BzrDirFormat.get_converter()."""
1512
1028
        # there is one and only one upgrade path here.
1513
1029
        return ConvertBzrDir5To6()
1514
 
 
1515
 
    def _initialize_for_clone(self, url):
1516
 
        return self.initialize_on_transport(get_transport(url), _cloning=True)
1517
1030
        
1518
 
    def initialize_on_transport(self, transport, _cloning=False):
 
1031
    def initialize(self, url, _cloning=False):
1519
1032
        """Format 5 dirs always have working tree, branch and repository.
1520
1033
        
1521
1034
        Except when they are being cloned.
1522
1035
        """
1523
1036
        from bzrlib.branch import BzrBranchFormat4
1524
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
 
1037
        from bzrlib.repository import RepositoryFormat5
1525
1038
        from bzrlib.workingtree import WorkingTreeFormat2
1526
 
        result = (super(BzrDirFormat5, self).initialize_on_transport(transport))
 
1039
        result = super(BzrDirFormat5, self).initialize(url)
1527
1040
        RepositoryFormat5().initialize(result, _internal=True)
1528
1041
        if not _cloning:
1529
 
            branch = BzrBranchFormat4().initialize(result)
1530
 
            try:
1531
 
                WorkingTreeFormat2().initialize(result)
1532
 
            except errors.NotLocalUrl:
1533
 
                # Even though we can't access the working tree, we need to
1534
 
                # create its control files.
1535
 
                WorkingTreeFormat2().stub_initialize_remote(branch.control_files)
 
1042
            BzrBranchFormat4().initialize(result)
 
1043
            WorkingTreeFormat2().initialize(result)
1536
1044
        return result
1537
1045
 
1538
1046
    def _open(self, transport):
1541
1049
 
1542
1050
    def __return_repository_format(self):
1543
1051
        """Circular import protection."""
1544
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
1545
 
        return RepositoryFormat5()
 
1052
        from bzrlib.repository import RepositoryFormat5
 
1053
        return RepositoryFormat5(self)
1546
1054
    repository_format = property(__return_repository_format)
1547
1055
 
1548
1056
 
1556
1064
     - Format 6 repositories [always]
1557
1065
    """
1558
1066
 
1559
 
    _lock_class = lockable_files.TransportLock
 
1067
    _lock_class = TransportLock
1560
1068
 
1561
1069
    def get_format_string(self):
1562
1070
        """See BzrDirFormat.get_format_string()."""
1563
1071
        return "Bazaar-NG branch, format 6\n"
1564
1072
 
1565
 
    def get_format_description(self):
1566
 
        """See BzrDirFormat.get_format_description()."""
1567
 
        return "All-in-one format 6"
1568
 
 
1569
1073
    def get_converter(self, format=None):
1570
1074
        """See BzrDirFormat.get_converter()."""
1571
1075
        # there is one and only one upgrade path here.
1572
1076
        return ConvertBzrDir6ToMeta()
1573
1077
        
1574
 
    def _initialize_for_clone(self, url):
1575
 
        return self.initialize_on_transport(get_transport(url), _cloning=True)
1576
 
 
1577
 
    def initialize_on_transport(self, transport, _cloning=False):
 
1078
    def initialize(self, url, _cloning=False):
1578
1079
        """Format 6 dirs always have working tree, branch and repository.
1579
1080
        
1580
1081
        Except when they are being cloned.
1581
1082
        """
1582
1083
        from bzrlib.branch import BzrBranchFormat4
1583
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
 
1084
        from bzrlib.repository import RepositoryFormat6
1584
1085
        from bzrlib.workingtree import WorkingTreeFormat2
1585
 
        result = super(BzrDirFormat6, self).initialize_on_transport(transport)
 
1086
        result = super(BzrDirFormat6, self).initialize(url)
1586
1087
        RepositoryFormat6().initialize(result, _internal=True)
1587
1088
        if not _cloning:
1588
 
            branch = BzrBranchFormat4().initialize(result)
 
1089
            BzrBranchFormat4().initialize(result)
1589
1090
            try:
1590
1091
                WorkingTreeFormat2().initialize(result)
1591
1092
            except errors.NotLocalUrl:
1592
 
                # Even though we can't access the working tree, we need to
1593
 
                # create its control files.
1594
 
                WorkingTreeFormat2().stub_initialize_remote(branch.control_files)
 
1093
                # emulate pre-check behaviour for working tree and silently 
 
1094
                # fail.
 
1095
                pass
1595
1096
        return result
1596
1097
 
1597
1098
    def _open(self, transport):
1600
1101
 
1601
1102
    def __return_repository_format(self):
1602
1103
        """Circular import protection."""
1603
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
1604
 
        return RepositoryFormat6()
 
1104
        from bzrlib.repository import RepositoryFormat6
 
1105
        return RepositoryFormat6(self)
1605
1106
    repository_format = property(__return_repository_format)
1606
1107
 
1607
1108
 
1616
1117
     - Format 7 repositories [optional]
1617
1118
    """
1618
1119
 
1619
 
    _lock_class = lockdir.LockDir
1620
 
 
1621
 
    def __init__(self):
1622
 
        self._workingtree_format = None
1623
 
        self._branch_format = None
1624
 
 
1625
 
    def __eq__(self, other):
1626
 
        if other.__class__ is not self.__class__:
1627
 
            return False
1628
 
        if other.repository_format != self.repository_format:
1629
 
            return False
1630
 
        if other.workingtree_format != self.workingtree_format:
1631
 
            return False
1632
 
        return True
1633
 
 
1634
 
    def __ne__(self, other):
1635
 
        return not self == other
1636
 
 
1637
 
    def get_branch_format(self):
1638
 
        if self._branch_format is None:
1639
 
            from bzrlib.branch import BranchFormat
1640
 
            self._branch_format = BranchFormat.get_default_format()
1641
 
        return self._branch_format
1642
 
 
1643
 
    def set_branch_format(self, format):
1644
 
        self._branch_format = format
 
1120
    _lock_class = LockDir
1645
1121
 
1646
1122
    def get_converter(self, format=None):
1647
1123
        """See BzrDirFormat.get_converter()."""
1656
1132
        """See BzrDirFormat.get_format_string()."""
1657
1133
        return "Bazaar-NG meta directory, format 1\n"
1658
1134
 
1659
 
    def get_format_description(self):
1660
 
        """See BzrDirFormat.get_format_description()."""
1661
 
        return "Meta directory format 1"
1662
 
 
1663
1135
    def _open(self, transport):
1664
1136
        """See BzrDirFormat._open."""
1665
1137
        return BzrDirMeta1(transport, self)
1677
1149
 
1678
1150
    repository_format = property(__return_repository_format, __set_repository_format)
1679
1151
 
1680
 
    def __get_workingtree_format(self):
1681
 
        if self._workingtree_format is None:
1682
 
            from bzrlib.workingtree import WorkingTreeFormat
1683
 
            self._workingtree_format = WorkingTreeFormat.get_default_format()
1684
 
        return self._workingtree_format
1685
 
 
1686
 
    def __set_workingtree_format(self, wt_format):
1687
 
        self._workingtree_format = wt_format
1688
 
 
1689
 
    workingtree_format = property(__get_workingtree_format,
1690
 
                                  __set_workingtree_format)
1691
 
 
1692
 
 
1693
 
# Register bzr control format
1694
 
BzrDirFormat.register_control_format(BzrDirFormat)
1695
 
 
1696
 
# Register bzr formats
 
1152
 
1697
1153
BzrDirFormat.register_format(BzrDirFormat4())
1698
1154
BzrDirFormat.register_format(BzrDirFormat5())
1699
 
BzrDirFormat.register_format(BzrDirFormat6())
1700
 
__default_format = BzrDirMetaFormat1()
 
1155
BzrDirFormat.register_format(BzrDirMetaFormat1())
 
1156
__default_format = BzrDirFormat6()
1701
1157
BzrDirFormat.register_format(__default_format)
1702
 
BzrDirFormat._default_format = __default_format
 
1158
BzrDirFormat.set_default_format(__default_format)
 
1159
 
 
1160
 
 
1161
class BzrDirTestProviderAdapter(object):
 
1162
    """A tool to generate a suite testing multiple bzrdir formats at once.
 
1163
 
 
1164
    This is done by copying the test once for each transport and injecting
 
1165
    the transport_server, transport_readonly_server, and bzrdir_format
 
1166
    classes into each copy. Each copy is also given a new id() to make it
 
1167
    easy to identify.
 
1168
    """
 
1169
 
 
1170
    def __init__(self, transport_server, transport_readonly_server, formats):
 
1171
        self._transport_server = transport_server
 
1172
        self._transport_readonly_server = transport_readonly_server
 
1173
        self._formats = formats
 
1174
    
 
1175
    def adapt(self, test):
 
1176
        result = TestSuite()
 
1177
        for format in self._formats:
 
1178
            new_test = deepcopy(test)
 
1179
            new_test.transport_server = self._transport_server
 
1180
            new_test.transport_readonly_server = self._transport_readonly_server
 
1181
            new_test.bzrdir_format = format
 
1182
            def make_new_test_id():
 
1183
                new_id = "%s(%s)" % (new_test.id(), format.__class__.__name__)
 
1184
                return lambda: new_id
 
1185
            new_test.id = make_new_test_id()
 
1186
            result.addTest(new_test)
 
1187
        return result
 
1188
 
 
1189
 
 
1190
class ScratchDir(BzrDir6):
 
1191
    """Special test class: a bzrdir that cleans up itself..
 
1192
 
 
1193
    >>> d = ScratchDir()
 
1194
    >>> base = d.transport.base
 
1195
    >>> isdir(base)
 
1196
    True
 
1197
    >>> b.transport.__del__()
 
1198
    >>> isdir(base)
 
1199
    False
 
1200
    """
 
1201
 
 
1202
    def __init__(self, files=[], dirs=[], transport=None):
 
1203
        """Make a test branch.
 
1204
 
 
1205
        This creates a temporary directory and runs init-tree in it.
 
1206
 
 
1207
        If any files are listed, they are created in the working copy.
 
1208
        """
 
1209
        if transport is None:
 
1210
            transport = bzrlib.transport.local.ScratchTransport()
 
1211
            # local import for scope restriction
 
1212
            BzrDirFormat6().initialize(transport.base)
 
1213
            super(ScratchDir, self).__init__(transport, BzrDirFormat6())
 
1214
            self.create_repository()
 
1215
            self.create_branch()
 
1216
            self.create_workingtree()
 
1217
        else:
 
1218
            super(ScratchDir, self).__init__(transport, BzrDirFormat6())
 
1219
 
 
1220
        # BzrBranch creates a clone to .bzr and then forgets about the
 
1221
        # original transport. A ScratchTransport() deletes itself and
 
1222
        # everything underneath it when it goes away, so we need to
 
1223
        # grab a local copy to prevent that from happening
 
1224
        self._transport = transport
 
1225
 
 
1226
        for d in dirs:
 
1227
            self._transport.mkdir(d)
 
1228
            
 
1229
        for f in files:
 
1230
            self._transport.put(f, 'content of %s' % f)
 
1231
 
 
1232
    def clone(self):
 
1233
        """
 
1234
        >>> orig = ScratchDir(files=["file1", "file2"])
 
1235
        >>> os.listdir(orig.base)
 
1236
        [u'.bzr', u'file1', u'file2']
 
1237
        >>> clone = orig.clone()
 
1238
        >>> if os.name != 'nt':
 
1239
        ...   os.path.samefile(orig.base, clone.base)
 
1240
        ... else:
 
1241
        ...   orig.base == clone.base
 
1242
        ...
 
1243
        False
 
1244
        >>> os.listdir(clone.base)
 
1245
        [u'.bzr', u'file1', u'file2']
 
1246
        """
 
1247
        from shutil import copytree
 
1248
        from bzrlib.osutils import mkdtemp
 
1249
        base = mkdtemp()
 
1250
        os.rmdir(base)
 
1251
        copytree(self.base, base, symlinks=True)
 
1252
        return ScratchDir(
 
1253
            transport=bzrlib.transport.local.ScratchTransport(base))
1703
1254
 
1704
1255
 
1705
1256
class Converter(object):
1792
1343
        self.bzrdir.transport.delete_tree('text-store')
1793
1344
 
1794
1345
    def _convert_working_inv(self):
1795
 
        inv = xml4.serializer_v4.read_inventory(
1796
 
                    self.branch.control_files.get('inventory'))
1797
 
        new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv)
 
1346
        inv = serializer_v4.read_inventory(self.branch.control_files.get('inventory'))
 
1347
        new_inv_xml = serializer_v5.write_inventory_to_string(inv)
1798
1348
        # FIXME inventory is a working tree change.
1799
 
        self.branch.control_files.put('inventory', StringIO(new_inv_xml))
 
1349
        self.branch.control_files.put('inventory', new_inv_xml)
1800
1350
 
1801
1351
    def _write_all_weaves(self):
1802
1352
        controlweaves = WeaveStore(self.bzrdir.transport, prefixed=False)
1826
1376
                                                      prefixed=False,
1827
1377
                                                      compressed=True))
1828
1378
        try:
1829
 
            transaction = WriteTransaction()
 
1379
            transaction = bzrlib.transactions.WriteTransaction()
1830
1380
            for i, rev_id in enumerate(self.converted_revs):
1831
1381
                self.pb.update('write revision', i, len(self.converted_revs))
1832
1382
                _revision_store.add_revision(self.revisions[rev_id], transaction)
1858
1408
    def _load_old_inventory(self, rev_id):
1859
1409
        assert rev_id not in self.converted_revs
1860
1410
        old_inv_xml = self.branch.repository.inventory_store.get(rev_id).read()
1861
 
        inv = xml4.serializer_v4.read_inventory_from_string(old_inv_xml)
1862
 
        inv.revision_id = rev_id
 
1411
        inv = serializer_v4.read_inventory_from_string(old_inv_xml)
1863
1412
        rev = self.revisions[rev_id]
1864
1413
        if rev.inventory_sha1:
1865
1414
            assert rev.inventory_sha1 == sha_string(old_inv_xml), \
1869
1418
    def _load_updated_inventory(self, rev_id):
1870
1419
        assert rev_id in self.converted_revs
1871
1420
        inv_xml = self.inv_weave.get_text(rev_id)
1872
 
        inv = xml5.serializer_v5.read_inventory_from_string(inv_xml)
 
1421
        inv = serializer_v5.read_inventory_from_string(inv_xml)
1873
1422
        return inv
1874
1423
 
1875
1424
    def _convert_one_rev(self, rev_id):
1885
1434
    def _store_new_weave(self, rev, inv, present_parents):
1886
1435
        # the XML is now updated with text versions
1887
1436
        if __debug__:
1888
 
            entries = inv.iter_entries()
1889
 
            entries.next()
1890
 
            for path, ie in entries:
1891
 
                assert getattr(ie, 'revision', None) is not None, \
 
1437
            for file_id in inv:
 
1438
                ie = inv[file_id]
 
1439
                if ie.kind == 'root_directory':
 
1440
                    continue
 
1441
                assert hasattr(ie, 'revision'), \
1892
1442
                    'no revision on {%s} in {%s}' % \
1893
1443
                    (file_id, rev.revision_id)
1894
 
        new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv)
 
1444
        new_inv_xml = serializer_v5.write_inventory_to_string(inv)
1895
1445
        new_inv_sha1 = sha_string(new_inv_xml)
1896
1446
        self.inv_weave.add_lines(rev.revision_id, 
1897
1447
                                 present_parents,
1906
1456
        mutter('converting texts of revision {%s}',
1907
1457
               rev_id)
1908
1458
        parent_invs = map(self._load_updated_inventory, present_parents)
1909
 
        entries = inv.iter_entries()
1910
 
        entries.next()
1911
 
        for path, ie in entries:
 
1459
        for file_id in inv:
 
1460
            ie = inv[file_id]
1912
1461
            self._convert_file_version(rev, ie, parent_invs)
1913
1462
 
1914
1463
    def _convert_file_version(self, rev, ie, parent_invs):
1917
1466
        The file needs to be added into the weave if it is a merge
1918
1467
        of >=2 parents or if it's changed from its parent.
1919
1468
        """
 
1469
        if ie.kind == 'root_directory':
 
1470
            return
1920
1471
        file_id = ie.file_id
1921
1472
        rev_id = rev.revision_id
1922
1473
        w = self.text_weaves.get(file_id)
1930
1481
                                                  entry_vf=w)
1931
1482
        for old_revision in previous_entries:
1932
1483
                # if this fails, its a ghost ?
1933
 
                assert old_revision in self.converted_revs, \
1934
 
                    "Revision {%s} not in converted_revs" % old_revision
 
1484
                assert old_revision in self.converted_revs 
1935
1485
        self.snapshot_ie(previous_entries, ie, w, rev_id)
1936
1486
        del ie.text_id
1937
1487
        assert getattr(ie, 'revision', None) is not None
1995
1545
        return BzrDir.open(self.bzrdir.root_transport.base)
1996
1546
 
1997
1547
    def _convert_to_prefixed(self):
1998
 
        from bzrlib.store import TransportStore
 
1548
        from bzrlib.store import hash_prefix
1999
1549
        self.bzrdir.transport.delete('branch-format')
2000
1550
        for store_name in ["weaves", "revision-store"]:
2001
 
            self.pb.note("adding prefixes to %s" % store_name)
 
1551
            self.pb.note("adding prefixes to %s" % store_name) 
2002
1552
            store_transport = self.bzrdir.transport.clone(store_name)
2003
 
            store = TransportStore(store_transport, prefixed=True)
2004
1553
            for urlfilename in store_transport.list_dir('.'):
2005
 
                filename = urlutils.unescape(urlfilename)
 
1554
                filename = urlunescape(urlfilename)
2006
1555
                if (filename.endswith(".weave") or
2007
1556
                    filename.endswith(".gz") or
2008
1557
                    filename.endswith(".sig")):
2009
1558
                    file_id = os.path.splitext(filename)[0]
2010
1559
                else:
2011
1560
                    file_id = filename
2012
 
                prefix_dir = store.hash_prefix(file_id)
 
1561
                prefix_dir = hash_prefix(file_id)
2013
1562
                # FIXME keep track of the dirs made RBC 20060121
2014
1563
                try:
2015
1564
                    store_transport.move(filename, prefix_dir + '/' + filename)
2024
1573
 
2025
1574
    def convert(self, to_convert, pb):
2026
1575
        """See Converter.convert()."""
2027
 
        from bzrlib.repofmt.weaverepo import RepositoryFormat7
2028
 
        from bzrlib.branch import BzrBranchFormat5
2029
1576
        self.bzrdir = to_convert
2030
1577
        self.pb = pb
2031
1578
        self.count = 0
2043
1590
            pass
2044
1591
        # find out whats there
2045
1592
        self.step('Finding branch files')
2046
 
        last_revision = self.bzrdir.open_branch().last_revision()
 
1593
        last_revision = self.bzrdir.open_workingtree().last_revision()
2047
1594
        bzrcontents = self.bzrdir.transport.list_dir('.')
2048
1595
        for name in bzrcontents:
2049
1596
            if name.startswith('basis-inventory.'):
2060
1607
        # we hard code the formats here because we are converting into
2061
1608
        # the meta format. The meta format upgrader can take this to a 
2062
1609
        # future format within each component.
2063
 
        self.put_format('repository', RepositoryFormat7())
 
1610
        self.put_format('repository', bzrlib.repository.RepositoryFormat7())
2064
1611
        for entry in repository_names:
2065
1612
            self.move_entry('repository', entry)
2066
1613
 
2067
1614
        self.step('Upgrading branch      ')
2068
1615
        self.bzrdir.transport.mkdir('branch', mode=self.dir_mode)
2069
1616
        self.make_lock('branch')
2070
 
        self.put_format('branch', BzrBranchFormat5())
 
1617
        self.put_format('branch', bzrlib.branch.BzrBranchFormat5())
2071
1618
        branch_files = [('revision-history', True),
2072
1619
                        ('branch-name', True),
2073
1620
                        ('parent', False)]
2074
1621
        for entry in branch_files:
2075
1622
            self.move_entry('branch', entry)
2076
1623
 
 
1624
        self.step('Upgrading working tree')
 
1625
        self.bzrdir.transport.mkdir('checkout', mode=self.dir_mode)
 
1626
        self.make_lock('checkout')
 
1627
        self.put_format('checkout', bzrlib.workingtree.WorkingTreeFormat3())
 
1628
        self.bzrdir.transport.delete_multi(self.garbage_inventories, self.pb)
2077
1629
        checkout_files = [('pending-merges', True),
2078
1630
                          ('inventory', True),
2079
1631
                          ('stat-cache', False)]
2080
 
        # If a mandatory checkout file is not present, the branch does not have
2081
 
        # a functional checkout. Do not create a checkout in the converted
2082
 
        # branch.
2083
 
        for name, mandatory in checkout_files:
2084
 
            if mandatory and name not in bzrcontents:
2085
 
                has_checkout = False
2086
 
                break
2087
 
        else:
2088
 
            has_checkout = True
2089
 
        if not has_checkout:
2090
 
            self.pb.note('No working tree.')
2091
 
            # If some checkout files are there, we may as well get rid of them.
2092
 
            for name, mandatory in checkout_files:
2093
 
                if name in bzrcontents:
2094
 
                    self.bzrdir.transport.delete(name)
2095
 
        else:
2096
 
            from bzrlib.workingtree import WorkingTreeFormat3
2097
 
            self.step('Upgrading working tree')
2098
 
            self.bzrdir.transport.mkdir('checkout', mode=self.dir_mode)
2099
 
            self.make_lock('checkout')
2100
 
            self.put_format(
2101
 
                'checkout', WorkingTreeFormat3())
2102
 
            self.bzrdir.transport.delete_multi(
2103
 
                self.garbage_inventories, self.pb)
2104
 
            for entry in checkout_files:
2105
 
                self.move_entry('checkout', entry)
2106
 
            if last_revision is not None:
2107
 
                self.bzrdir._control_files.put_utf8(
2108
 
                    'checkout/last-revision', last_revision)
2109
 
        self.bzrdir._control_files.put_utf8(
2110
 
            'branch-format', BzrDirMetaFormat1().get_format_string())
 
1632
        for entry in checkout_files:
 
1633
            self.move_entry('checkout', entry)
 
1634
        if last_revision is not None:
 
1635
            self.bzrdir._control_files.put_utf8('checkout/last-revision',
 
1636
                                                last_revision)
 
1637
        self.bzrdir._control_files.put_utf8('branch-format', BzrDirMetaFormat1().get_format_string())
2111
1638
        return BzrDir.open(self.bzrdir.root_transport.base)
2112
1639
 
2113
1640
    def make_lock(self, name):
2114
1641
        """Make a lock for the new control dir name."""
2115
1642
        self.step('Make %s lock' % name)
2116
 
        ld = lockdir.LockDir(self.bzrdir.transport,
2117
 
                             '%s/lock' % name,
2118
 
                             file_modebits=self.file_mode,
2119
 
                             dir_modebits=self.dir_mode)
 
1643
        ld = LockDir(self.bzrdir.transport, 
 
1644
                     '%s/lock' % name,
 
1645
                     file_modebits=self.file_mode,
 
1646
                     dir_modebits=self.dir_mode)
2120
1647
        ld.create()
2121
1648
 
2122
1649
    def move_entry(self, new_dir, entry):
2161
1688
                self.pb.note('starting repository conversion')
2162
1689
                converter = CopyConverter(self.target_format.repository_format)
2163
1690
                converter.convert(repo, pb)
2164
 
        try:
2165
 
            branch = self.bzrdir.open_branch()
2166
 
        except errors.NotBranchError:
2167
 
            pass
2168
 
        else:
2169
 
            # TODO: conversions of Branch and Tree should be done by
2170
 
            # InterXFormat lookups
2171
 
            # Avoid circular imports
2172
 
            from bzrlib import branch as _mod_branch
2173
 
            if (branch._format.__class__ is _mod_branch.BzrBranchFormat5 and
2174
 
                self.target_format.get_branch_format().__class__ is
2175
 
                _mod_branch.BzrBranchFormat6):
2176
 
                branch_converter = _mod_branch.Converter5to6()
2177
 
                branch_converter.convert(branch)
2178
 
        try:
2179
 
            tree = self.bzrdir.open_workingtree(recommend_upgrade=False)
2180
 
        except (errors.NoWorkingTree, errors.NotLocalUrl):
2181
 
            pass
2182
 
        else:
2183
 
            # TODO: conversions of Branch and Tree should be done by
2184
 
            # InterXFormat lookups
2185
 
            if (isinstance(tree, workingtree.WorkingTree3) and
2186
 
                not isinstance(tree, workingtree_4.WorkingTree4) and
2187
 
                isinstance(self.target_format.workingtree_format,
2188
 
                    workingtree_4.WorkingTreeFormat4)):
2189
 
                workingtree_4.Converter3to4().convert(tree)
2190
1691
        return to_convert
2191
 
 
2192
 
 
2193
 
# This is not in remote.py because it's small, and needs to be registered.
2194
 
# Putting it in remote.py creates a circular import problem.
2195
 
# we can make it a lazy object if the control formats is turned into something
2196
 
# like a registry.
2197
 
class RemoteBzrDirFormat(BzrDirMetaFormat1):
2198
 
    """Format representing bzrdirs accessed via a smart server"""
2199
 
 
2200
 
    def get_format_description(self):
2201
 
        return 'bzr remote bzrdir'
2202
 
    
2203
 
    @classmethod
2204
 
    def probe_transport(klass, transport):
2205
 
        """Return a RemoteBzrDirFormat object if it looks possible."""
2206
 
        try:
2207
 
            client = transport.get_smart_client()
2208
 
        except (NotImplementedError, AttributeError,
2209
 
                errors.TransportNotPossible):
2210
 
            # no smart server, so not a branch for this format type.
2211
 
            raise errors.NotBranchError(path=transport.base)
2212
 
        else:
2213
 
            # Send a 'hello' request in protocol version one, and decline to
2214
 
            # open it if the server doesn't support our required version (2) so
2215
 
            # that the VFS-based transport will do it.
2216
 
            request = client.get_request()
2217
 
            smart_protocol = protocol.SmartClientRequestProtocolOne(request)
2218
 
            server_version = smart_protocol.query_version()
2219
 
            if server_version != 2:
2220
 
                raise errors.NotBranchError(path=transport.base)
2221
 
            return klass()
2222
 
 
2223
 
    def initialize_on_transport(self, transport):
2224
 
        try:
2225
 
            # hand off the request to the smart server
2226
 
            shared_medium = transport.get_shared_medium()
2227
 
        except errors.NoSmartMedium:
2228
 
            # TODO: lookup the local format from a server hint.
2229
 
            local_dir_format = BzrDirMetaFormat1()
2230
 
            return local_dir_format.initialize_on_transport(transport)
2231
 
        client = _SmartClient(shared_medium)
2232
 
        path = client.remote_path_from_transport(transport)
2233
 
        response = _SmartClient(shared_medium).call('BzrDirFormat.initialize',
2234
 
                                                    path)
2235
 
        assert response[0] in ('ok', ), 'unexpected response code %s' % (response,)
2236
 
        return remote.RemoteBzrDir(transport)
2237
 
 
2238
 
    def _open(self, transport):
2239
 
        return remote.RemoteBzrDir(transport)
2240
 
 
2241
 
    def __eq__(self, other):
2242
 
        if not isinstance(other, RemoteBzrDirFormat):
2243
 
            return False
2244
 
        return self.get_format_description() == other.get_format_description()
2245
 
 
2246
 
 
2247
 
BzrDirFormat.register_control_server_format(RemoteBzrDirFormat)
2248
 
 
2249
 
 
2250
 
class BzrDirFormatInfo(object):
2251
 
 
2252
 
    def __init__(self, native, deprecated, hidden):
2253
 
        self.deprecated = deprecated
2254
 
        self.native = native
2255
 
        self.hidden = hidden
2256
 
 
2257
 
 
2258
 
class BzrDirFormatRegistry(registry.Registry):
2259
 
    """Registry of user-selectable BzrDir subformats.
2260
 
    
2261
 
    Differs from BzrDirFormat._control_formats in that it provides sub-formats,
2262
 
    e.g. BzrDirMeta1 with weave repository.  Also, it's more user-oriented.
2263
 
    """
2264
 
 
2265
 
    def register_metadir(self, key,
2266
 
             repository_format, help, native=True, deprecated=False,
2267
 
             branch_format=None,
2268
 
             tree_format=None,
2269
 
             hidden=False):
2270
 
        """Register a metadir subformat.
2271
 
 
2272
 
        These all use a BzrDirMetaFormat1 bzrdir, but can be parameterized
2273
 
        by the Repository format.
2274
 
 
2275
 
        :param repository_format: The fully-qualified repository format class
2276
 
            name as a string.
2277
 
        :param branch_format: Fully-qualified branch format class name as
2278
 
            a string.
2279
 
        :param tree_format: Fully-qualified tree format class name as
2280
 
            a string.
2281
 
        """
2282
 
        # This should be expanded to support setting WorkingTree and Branch
2283
 
        # formats, once BzrDirMetaFormat1 supports that.
2284
 
        def _load(full_name):
2285
 
            mod_name, factory_name = full_name.rsplit('.', 1)
2286
 
            try:
2287
 
                mod = __import__(mod_name, globals(), locals(),
2288
 
                        [factory_name])
2289
 
            except ImportError, e:
2290
 
                raise ImportError('failed to load %s: %s' % (full_name, e))
2291
 
            try:
2292
 
                factory = getattr(mod, factory_name)
2293
 
            except AttributeError:
2294
 
                raise AttributeError('no factory %s in module %r'
2295
 
                    % (full_name, mod))
2296
 
            return factory()
2297
 
 
2298
 
        def helper():
2299
 
            bd = BzrDirMetaFormat1()
2300
 
            if branch_format is not None:
2301
 
                bd.set_branch_format(_load(branch_format))
2302
 
            if tree_format is not None:
2303
 
                bd.workingtree_format = _load(tree_format)
2304
 
            if repository_format is not None:
2305
 
                bd.repository_format = _load(repository_format)
2306
 
            return bd
2307
 
        self.register(key, helper, help, native, deprecated, hidden)
2308
 
 
2309
 
    def register(self, key, factory, help, native=True, deprecated=False,
2310
 
                 hidden=False):
2311
 
        """Register a BzrDirFormat factory.
2312
 
        
2313
 
        The factory must be a callable that takes one parameter: the key.
2314
 
        It must produce an instance of the BzrDirFormat when called.
2315
 
 
2316
 
        This function mainly exists to prevent the info object from being
2317
 
        supplied directly.
2318
 
        """
2319
 
        registry.Registry.register(self, key, factory, help, 
2320
 
            BzrDirFormatInfo(native, deprecated, hidden))
2321
 
 
2322
 
    def register_lazy(self, key, module_name, member_name, help, native=True,
2323
 
                      deprecated=False, hidden=False):
2324
 
        registry.Registry.register_lazy(self, key, module_name, member_name, 
2325
 
            help, BzrDirFormatInfo(native, deprecated, hidden))
2326
 
 
2327
 
    def set_default(self, key):
2328
 
        """Set the 'default' key to be a clone of the supplied key.
2329
 
        
2330
 
        This method must be called once and only once.
2331
 
        """
2332
 
        registry.Registry.register(self, 'default', self.get(key), 
2333
 
            self.get_help(key), info=self.get_info(key))
2334
 
 
2335
 
    def set_default_repository(self, key):
2336
 
        """Set the FormatRegistry default and Repository default.
2337
 
        
2338
 
        This is a transitional method while Repository.set_default_format
2339
 
        is deprecated.
2340
 
        """
2341
 
        if 'default' in self:
2342
 
            self.remove('default')
2343
 
        self.set_default(key)
2344
 
        format = self.get('default')()
2345
 
        assert isinstance(format, BzrDirMetaFormat1)
2346
 
 
2347
 
    def make_bzrdir(self, key):
2348
 
        return self.get(key)()
2349
 
 
2350
 
    def help_topic(self, topic):
2351
 
        output = textwrap.dedent("""\
2352
 
            Bazaar directory formats
2353
 
            ------------------------
2354
 
 
2355
 
            These formats can be used for creating branches, working trees, and
2356
 
            repositories.
2357
 
 
2358
 
            """)
2359
 
        default_help = self.get_help('default')
2360
 
        help_pairs = []
2361
 
        for key in self.keys():
2362
 
            if key == 'default':
2363
 
                continue
2364
 
            help = self.get_help(key)
2365
 
            if help == default_help:
2366
 
                default_realkey = key
2367
 
            else:
2368
 
                help_pairs.append((key, help))
2369
 
 
2370
 
        def wrapped(key, help, info):
2371
 
            if info.native:
2372
 
                help = '(native) ' + help
2373
 
            return '  %s:\n%s\n\n' % (key, 
2374
 
                    textwrap.fill(help, initial_indent='    ', 
2375
 
                    subsequent_indent='    '))
2376
 
        output += wrapped('%s/default' % default_realkey, default_help,
2377
 
                          self.get_info('default'))
2378
 
        deprecated_pairs = []
2379
 
        for key, help in help_pairs:
2380
 
            info = self.get_info(key)
2381
 
            if info.hidden:
2382
 
                continue
2383
 
            elif info.deprecated:
2384
 
                deprecated_pairs.append((key, help))
2385
 
            else:
2386
 
                output += wrapped(key, help, info)
2387
 
        if len(deprecated_pairs) > 0:
2388
 
            output += "Deprecated formats\n------------------\n\n"
2389
 
            for key, help in deprecated_pairs:
2390
 
                info = self.get_info(key)
2391
 
                output += wrapped(key, help, info)
2392
 
 
2393
 
        return output
2394
 
 
2395
 
 
2396
 
format_registry = BzrDirFormatRegistry()
2397
 
format_registry.register('weave', BzrDirFormat6,
2398
 
    'Pre-0.8 format.  Slower than knit and does not'
2399
 
    ' support checkouts or shared repositories.',
2400
 
    deprecated=True)
2401
 
format_registry.register_metadir('knit',
2402
 
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
2403
 
    'Format using knits.  Recommended for interoperation with bzr <= 0.14.',
2404
 
    branch_format='bzrlib.branch.BzrBranchFormat5',
2405
 
    tree_format='bzrlib.workingtree.WorkingTreeFormat3')
2406
 
format_registry.register_metadir('metaweave',
2407
 
    'bzrlib.repofmt.weaverepo.RepositoryFormat7',
2408
 
    'Transitional format in 0.8.  Slower than knit.',
2409
 
    branch_format='bzrlib.branch.BzrBranchFormat5',
2410
 
    tree_format='bzrlib.workingtree.WorkingTreeFormat3',
2411
 
    deprecated=True)
2412
 
format_registry.register_metadir('dirstate',
2413
 
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
2414
 
    help='New in 0.15: Fast local operations. Compatible with bzr 0.8 and '
2415
 
        'above when accessed over the network.',
2416
 
    branch_format='bzrlib.branch.BzrBranchFormat5',
2417
 
    # this uses bzrlib.workingtree.WorkingTreeFormat4 because importing
2418
 
    # directly from workingtree_4 triggers a circular import.
2419
 
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2420
 
    )
2421
 
format_registry.register_metadir('dirstate-tags',
2422
 
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
2423
 
    help='New in 0.15: Fast local operations and improved scaling for '
2424
 
        'network operations. Additionally adds support for tags.'
2425
 
        ' Incompatible with bzr < 0.15.',
2426
 
    branch_format='bzrlib.branch.BzrBranchFormat6',
2427
 
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2428
 
    )
2429
 
format_registry.register_metadir('dirstate-with-subtree',
2430
 
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit3',
2431
 
    help='New in 0.15: Fast local operations and improved scaling for '
2432
 
        'network operations. Additionally adds support for versioning nested '
2433
 
        'bzr branches. Incompatible with bzr < 0.15.',
2434
 
    branch_format='bzrlib.branch.BzrBranchFormat6',
2435
 
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
2436
 
    hidden=True,
2437
 
    )
2438
 
format_registry.set_default('dirstate')