~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/bzrdir.py

  • Committer: Aaron Bentley
  • Date: 2007-12-12 15:17:13 UTC
  • mto: This revision was merged to the branch mainline in revision 3113.
  • Revision ID: abentley@panoramicfeedback.com-20071212151713-ox5n8rlx8m3nsspy
Add support for reconfiguring repositories into branches or trees

Show diffs side-by-side

added added

removed removed

Lines of Context:
 
1
# Copyright (C) 2005, 2006, 2007 Canonical Ltd
 
2
#
 
3
# This program is free software; you can redistribute it and/or modify
 
4
# it under the terms of the GNU General Public License as published by
 
5
# the Free Software Foundation; either version 2 of the License, or
 
6
# (at your option) any later version.
 
7
#
 
8
# This program is distributed in the hope that it will be useful,
 
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
 
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 
11
# GNU General Public License for more details.
 
12
#
 
13
# You should have received a copy of the GNU General Public License
 
14
# along with this program; if not, write to the Free Software
 
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 
16
 
 
17
"""BzrDir logic. The BzrDir is the basic control directory used by bzr.
 
18
 
 
19
At format 7 this was split out into Branch, Repository and Checkout control
 
20
directories.
 
21
 
 
22
Note: This module has a lot of ``open`` functions/methods that return
 
23
references to in-memory objects. As a rule, there are no matching ``close``
 
24
methods. To free any associated resources, simply stop referencing the
 
25
objects returned.
 
26
"""
 
27
 
 
28
# TODO: Move old formats into a plugin to make this file smaller.
 
29
 
 
30
from cStringIO import StringIO
 
31
import os
 
32
import sys
 
33
 
 
34
from bzrlib.lazy_import import lazy_import
 
35
lazy_import(globals(), """
 
36
from stat import S_ISDIR
 
37
import textwrap
 
38
from warnings import warn
 
39
 
 
40
import bzrlib
 
41
from bzrlib import (
 
42
    errors,
 
43
    graph,
 
44
    lockable_files,
 
45
    lockdir,
 
46
    registry,
 
47
    remote,
 
48
    revision as _mod_revision,
 
49
    symbol_versioning,
 
50
    ui,
 
51
    urlutils,
 
52
    win32utils,
 
53
    workingtree,
 
54
    workingtree_4,
 
55
    xml4,
 
56
    xml5,
 
57
    )
 
58
from bzrlib.osutils import (
 
59
    sha_strings,
 
60
    sha_string,
 
61
    )
 
62
from bzrlib.smart.client import _SmartClient
 
63
from bzrlib.smart import protocol
 
64
from bzrlib.store.revision.text import TextRevisionStore
 
65
from bzrlib.store.text import TextStore
 
66
from bzrlib.store.versioned import WeaveStore
 
67
from bzrlib.transactions import WriteTransaction
 
68
from bzrlib.transport import (
 
69
    do_catching_redirections,
 
70
    get_transport,
 
71
    )
 
72
from bzrlib.weave import Weave
 
73
""")
 
74
 
 
75
from bzrlib.trace import (
 
76
    mutter,
 
77
    note,
 
78
    )
 
79
from bzrlib.transport.local import LocalTransport
 
80
from bzrlib.symbol_versioning import (
 
81
    deprecated_function,
 
82
    deprecated_method,
 
83
    zero_ninetyone,
 
84
    )
 
85
 
 
86
 
 
87
class BzrDir(object):
 
88
    """A .bzr control diretory.
 
89
    
 
90
    BzrDir instances let you create or open any of the things that can be
 
91
    found within .bzr - checkouts, branches and repositories.
 
92
    
 
93
    transport
 
94
        the transport which this bzr dir is rooted at (i.e. file:///.../.bzr/)
 
95
    root_transport
 
96
        a transport connected to the directory this bzr was opened from
 
97
        (i.e. the parent directory holding the .bzr directory).
 
98
    """
 
99
 
 
100
    def break_lock(self):
 
101
        """Invoke break_lock on the first object in the bzrdir.
 
102
 
 
103
        If there is a tree, the tree is opened and break_lock() called.
 
104
        Otherwise, branch is tried, and finally repository.
 
105
        """
 
106
        # XXX: This seems more like a UI function than something that really
 
107
        # belongs in this class.
 
108
        try:
 
109
            thing_to_unlock = self.open_workingtree()
 
110
        except (errors.NotLocalUrl, errors.NoWorkingTree):
 
111
            try:
 
112
                thing_to_unlock = self.open_branch()
 
113
            except errors.NotBranchError:
 
114
                try:
 
115
                    thing_to_unlock = self.open_repository()
 
116
                except errors.NoRepositoryPresent:
 
117
                    return
 
118
        thing_to_unlock.break_lock()
 
119
 
 
120
    def can_convert_format(self):
 
121
        """Return true if this bzrdir is one whose format we can convert from."""
 
122
        return True
 
123
 
 
124
    def check_conversion_target(self, target_format):
 
125
        target_repo_format = target_format.repository_format
 
126
        source_repo_format = self._format.repository_format
 
127
        source_repo_format.check_conversion_target(target_repo_format)
 
128
 
 
129
    @staticmethod
 
130
    def _check_supported(format, allow_unsupported,
 
131
        recommend_upgrade=True,
 
132
        basedir=None):
 
133
        """Give an error or warning on old formats.
 
134
 
 
135
        :param format: may be any kind of format - workingtree, branch, 
 
136
        or repository.
 
137
 
 
138
        :param allow_unsupported: If true, allow opening 
 
139
        formats that are strongly deprecated, and which may 
 
140
        have limited functionality.
 
141
 
 
142
        :param recommend_upgrade: If true (default), warn
 
143
        the user through the ui object that they may wish
 
144
        to upgrade the object.
 
145
        """
 
146
        # TODO: perhaps move this into a base Format class; it's not BzrDir
 
147
        # specific. mbp 20070323
 
148
        if not allow_unsupported and not format.is_supported():
 
149
            # see open_downlevel to open legacy branches.
 
150
            raise errors.UnsupportedFormatError(format=format)
 
151
        if recommend_upgrade \
 
152
            and getattr(format, 'upgrade_recommended', False):
 
153
            ui.ui_factory.recommend_upgrade(
 
154
                format.get_format_description(),
 
155
                basedir)
 
156
 
 
157
    def clone(self, url, revision_id=None, force_new_repo=False):
 
158
        """Clone this bzrdir and its contents to url verbatim.
 
159
 
 
160
        If url's last component does not exist, it will be created.
 
161
 
 
162
        if revision_id is not None, then the clone operation may tune
 
163
            itself to download less data.
 
164
        :param force_new_repo: Do not use a shared repository for the target 
 
165
                               even if one is available.
 
166
        """
 
167
        return self.clone_on_transport(get_transport(url),
 
168
                                       revision_id=revision_id,
 
169
                                       force_new_repo=force_new_repo)
 
170
 
 
171
    def clone_on_transport(self, transport, revision_id=None,
 
172
                           force_new_repo=False):
 
173
        """Clone this bzrdir and its contents to transport verbatim.
 
174
 
 
175
        If the target directory does not exist, it will be created.
 
176
 
 
177
        if revision_id is not None, then the clone operation may tune
 
178
            itself to download less data.
 
179
        :param force_new_repo: Do not use a shared repository for the target 
 
180
                               even if one is available.
 
181
        """
 
182
        transport.ensure_base()
 
183
        result = self._format.initialize_on_transport(transport)
 
184
        try:
 
185
            local_repo = self.find_repository()
 
186
        except errors.NoRepositoryPresent:
 
187
            local_repo = None
 
188
        if local_repo:
 
189
            # may need to copy content in
 
190
            if force_new_repo:
 
191
                result_repo = local_repo.clone(
 
192
                    result,
 
193
                    revision_id=revision_id)
 
194
                result_repo.set_make_working_trees(local_repo.make_working_trees())
 
195
            else:
 
196
                try:
 
197
                    result_repo = result.find_repository()
 
198
                    # fetch content this dir needs.
 
199
                    result_repo.fetch(local_repo, revision_id=revision_id)
 
200
                except errors.NoRepositoryPresent:
 
201
                    # needed to make one anyway.
 
202
                    result_repo = local_repo.clone(
 
203
                        result,
 
204
                        revision_id=revision_id)
 
205
                    result_repo.set_make_working_trees(local_repo.make_working_trees())
 
206
        # 1 if there is a branch present
 
207
        #   make sure its content is available in the target repository
 
208
        #   clone it.
 
209
        try:
 
210
            self.open_branch().clone(result, revision_id=revision_id)
 
211
        except errors.NotBranchError:
 
212
            pass
 
213
        try:
 
214
            result_repo = result.find_repository()
 
215
        except errors.NoRepositoryPresent:
 
216
            result_repo = None
 
217
        if result_repo is None or result_repo.make_working_trees():
 
218
            try:
 
219
                self.open_workingtree().clone(result)
 
220
            except (errors.NoWorkingTree, errors.NotLocalUrl):
 
221
                pass
 
222
        return result
 
223
 
 
224
    # TODO: This should be given a Transport, and should chdir up; otherwise
 
225
    # this will open a new connection.
 
226
    def _make_tail(self, url):
 
227
        t = get_transport(url)
 
228
        t.ensure_base()
 
229
 
 
230
    @classmethod
 
231
    def create(cls, base, format=None, possible_transports=None):
 
232
        """Create a new BzrDir at the url 'base'.
 
233
        
 
234
        :param format: If supplied, the format of branch to create.  If not
 
235
            supplied, the default is used.
 
236
        :param possible_transports: If supplied, a list of transports that 
 
237
            can be reused to share a remote connection.
 
238
        """
 
239
        if cls is not BzrDir:
 
240
            raise AssertionError("BzrDir.create always creates the default"
 
241
                " format, not one of %r" % cls)
 
242
        t = get_transport(base, possible_transports)
 
243
        t.ensure_base()
 
244
        if format is None:
 
245
            format = BzrDirFormat.get_default_format()
 
246
        return format.initialize_on_transport(t)
 
247
 
 
248
    def destroy_repository(self):
 
249
        """Destroy the repository in this BzrDir"""
 
250
        raise NotImplementedError(self.destroy_repository)
 
251
 
 
252
    def create_branch(self):
 
253
        """Create a branch in this BzrDir.
 
254
 
 
255
        The bzrdir's format will control what branch format is created.
 
256
        For more control see BranchFormatXX.create(a_bzrdir).
 
257
        """
 
258
        raise NotImplementedError(self.create_branch)
 
259
 
 
260
    def destroy_branch(self):
 
261
        """Destroy the branch in this BzrDir"""
 
262
        raise NotImplementedError(self.destroy_branch)
 
263
 
 
264
    @staticmethod
 
265
    def create_branch_and_repo(base, force_new_repo=False, format=None):
 
266
        """Create a new BzrDir, Branch and Repository at the url 'base'.
 
267
 
 
268
        This will use the current default BzrDirFormat unless one is
 
269
        specified, and use whatever 
 
270
        repository format that that uses via bzrdir.create_branch and
 
271
        create_repository. If a shared repository is available that is used
 
272
        preferentially.
 
273
 
 
274
        The created Branch object is returned.
 
275
 
 
276
        :param base: The URL to create the branch at.
 
277
        :param force_new_repo: If True a new repository is always created.
 
278
        :param format: If supplied, the format of branch to create.  If not
 
279
            supplied, the default is used.
 
280
        """
 
281
        bzrdir = BzrDir.create(base, format)
 
282
        bzrdir._find_or_create_repository(force_new_repo)
 
283
        return bzrdir.create_branch()
 
284
 
 
285
    def _find_or_create_repository(self, force_new_repo):
 
286
        """Create a new repository if needed, returning the repository."""
 
287
        if force_new_repo:
 
288
            return self.create_repository()
 
289
        try:
 
290
            return self.find_repository()
 
291
        except errors.NoRepositoryPresent:
 
292
            return self.create_repository()
 
293
        
 
294
    @staticmethod
 
295
    def create_branch_convenience(base, force_new_repo=False,
 
296
                                  force_new_tree=None, format=None,
 
297
                                  possible_transports=None):
 
298
        """Create a new BzrDir, Branch and Repository at the url 'base'.
 
299
 
 
300
        This is a convenience function - it will use an existing repository
 
301
        if possible, can be told explicitly whether to create a working tree or
 
302
        not.
 
303
 
 
304
        This will use the current default BzrDirFormat unless one is
 
305
        specified, and use whatever 
 
306
        repository format that that uses via bzrdir.create_branch and
 
307
        create_repository. If a shared repository is available that is used
 
308
        preferentially. Whatever repository is used, its tree creation policy
 
309
        is followed.
 
310
 
 
311
        The created Branch object is returned.
 
312
        If a working tree cannot be made due to base not being a file:// url,
 
313
        no error is raised unless force_new_tree is True, in which case no 
 
314
        data is created on disk and NotLocalUrl is raised.
 
315
 
 
316
        :param base: The URL to create the branch at.
 
317
        :param force_new_repo: If True a new repository is always created.
 
318
        :param force_new_tree: If True or False force creation of a tree or 
 
319
                               prevent such creation respectively.
 
320
        :param format: Override for the bzrdir format to create.
 
321
        :param possible_transports: An optional reusable transports list.
 
322
        """
 
323
        if force_new_tree:
 
324
            # check for non local urls
 
325
            t = get_transport(base, possible_transports)
 
326
            if not isinstance(t, LocalTransport):
 
327
                raise errors.NotLocalUrl(base)
 
328
        bzrdir = BzrDir.create(base, format, possible_transports)
 
329
        repo = bzrdir._find_or_create_repository(force_new_repo)
 
330
        result = bzrdir.create_branch()
 
331
        if force_new_tree or (repo.make_working_trees() and
 
332
                              force_new_tree is None):
 
333
            try:
 
334
                bzrdir.create_workingtree()
 
335
            except errors.NotLocalUrl:
 
336
                pass
 
337
        return result
 
338
 
 
339
    @staticmethod
 
340
    @deprecated_function(zero_ninetyone)
 
341
    def create_repository(base, shared=False, format=None):
 
342
        """Create a new BzrDir and Repository at the url 'base'.
 
343
 
 
344
        If no format is supplied, this will default to the current default
 
345
        BzrDirFormat by default, and use whatever repository format that that
 
346
        uses for bzrdirformat.create_repository.
 
347
 
 
348
        :param shared: Create a shared repository rather than a standalone
 
349
                       repository.
 
350
        The Repository object is returned.
 
351
 
 
352
        This must be overridden as an instance method in child classes, where
 
353
        it should take no parameters and construct whatever repository format
 
354
        that child class desires.
 
355
 
 
356
        This method is deprecated, please call create_repository on a bzrdir
 
357
        instance instead.
 
358
        """
 
359
        bzrdir = BzrDir.create(base, format)
 
360
        return bzrdir.create_repository(shared)
 
361
 
 
362
    @staticmethod
 
363
    def create_standalone_workingtree(base, format=None):
 
364
        """Create a new BzrDir, WorkingTree, Branch and Repository at 'base'.
 
365
 
 
366
        'base' must be a local path or a file:// url.
 
367
 
 
368
        This will use the current default BzrDirFormat unless one is
 
369
        specified, and use whatever 
 
370
        repository format that that uses for bzrdirformat.create_workingtree,
 
371
        create_branch and create_repository.
 
372
 
 
373
        :param format: Override for the bzrdir format to create.
 
374
        :return: The WorkingTree object.
 
375
        """
 
376
        t = get_transport(base)
 
377
        if not isinstance(t, LocalTransport):
 
378
            raise errors.NotLocalUrl(base)
 
379
        bzrdir = BzrDir.create_branch_and_repo(base,
 
380
                                               force_new_repo=True,
 
381
                                               format=format).bzrdir
 
382
        return bzrdir.create_workingtree()
 
383
 
 
384
    def create_workingtree(self, revision_id=None, from_branch=None):
 
385
        """Create a working tree at this BzrDir.
 
386
        
 
387
        :param revision_id: create it as of this revision id.
 
388
        :param from_branch: override bzrdir branch (for lightweight checkouts)
 
389
        """
 
390
        raise NotImplementedError(self.create_workingtree)
 
391
 
 
392
    def retire_bzrdir(self, limit=10000):
 
393
        """Permanently disable the bzrdir.
 
394
 
 
395
        This is done by renaming it to give the user some ability to recover
 
396
        if there was a problem.
 
397
 
 
398
        This will have horrible consequences if anyone has anything locked or
 
399
        in use.
 
400
        :param limit: number of times to retry
 
401
        """
 
402
        i  = 0
 
403
        while True:
 
404
            try:
 
405
                to_path = '.bzr.retired.%d' % i
 
406
                self.root_transport.rename('.bzr', to_path)
 
407
                note("renamed %s to %s"
 
408
                    % (self.root_transport.abspath('.bzr'), to_path))
 
409
                return
 
410
            except (errors.TransportError, IOError, errors.PathError):
 
411
                i += 1
 
412
                if i > limit:
 
413
                    raise
 
414
                else:
 
415
                    pass
 
416
 
 
417
    def destroy_workingtree(self):
 
418
        """Destroy the working tree at this BzrDir.
 
419
 
 
420
        Formats that do not support this may raise UnsupportedOperation.
 
421
        """
 
422
        raise NotImplementedError(self.destroy_workingtree)
 
423
 
 
424
    def destroy_workingtree_metadata(self):
 
425
        """Destroy the control files for the working tree at this BzrDir.
 
426
 
 
427
        The contents of working tree files are not affected.
 
428
        Formats that do not support this may raise UnsupportedOperation.
 
429
        """
 
430
        raise NotImplementedError(self.destroy_workingtree_metadata)
 
431
 
 
432
    def find_repository(self):
 
433
        """Find the repository that should be used.
 
434
 
 
435
        This does not require a branch as we use it to find the repo for
 
436
        new branches as well as to hook existing branches up to their
 
437
        repository.
 
438
        """
 
439
        try:
 
440
            return self.open_repository()
 
441
        except errors.NoRepositoryPresent:
 
442
            pass
 
443
        next_transport = self.root_transport.clone('..')
 
444
        while True:
 
445
            # find the next containing bzrdir
 
446
            try:
 
447
                found_bzrdir = BzrDir.open_containing_from_transport(
 
448
                    next_transport)[0]
 
449
            except errors.NotBranchError:
 
450
                # none found
 
451
                raise errors.NoRepositoryPresent(self)
 
452
            # does it have a repository ?
 
453
            try:
 
454
                repository = found_bzrdir.open_repository()
 
455
            except errors.NoRepositoryPresent:
 
456
                next_transport = found_bzrdir.root_transport.clone('..')
 
457
                if (found_bzrdir.root_transport.base == next_transport.base):
 
458
                    # top of the file system
 
459
                    break
 
460
                else:
 
461
                    continue
 
462
            if ((found_bzrdir.root_transport.base ==
 
463
                 self.root_transport.base) or repository.is_shared()):
 
464
                return repository
 
465
            else:
 
466
                raise errors.NoRepositoryPresent(self)
 
467
        raise errors.NoRepositoryPresent(self)
 
468
 
 
469
    def get_branch_reference(self):
 
470
        """Return the referenced URL for the branch in this bzrdir.
 
471
 
 
472
        :raises NotBranchError: If there is no Branch.
 
473
        :return: The URL the branch in this bzrdir references if it is a
 
474
            reference branch, or None for regular branches.
 
475
        """
 
476
        return None
 
477
 
 
478
    def get_branch_transport(self, branch_format):
 
479
        """Get the transport for use by branch format in this BzrDir.
 
480
 
 
481
        Note that bzr dirs that do not support format strings will raise
 
482
        IncompatibleFormat if the branch format they are given has
 
483
        a format string, and vice versa.
 
484
 
 
485
        If branch_format is None, the transport is returned with no 
 
486
        checking. If it is not None, then the returned transport is
 
487
        guaranteed to point to an existing directory ready for use.
 
488
        """
 
489
        raise NotImplementedError(self.get_branch_transport)
 
490
        
 
491
    def get_repository_transport(self, repository_format):
 
492
        """Get the transport for use by repository format in this BzrDir.
 
493
 
 
494
        Note that bzr dirs that do not support format strings will raise
 
495
        IncompatibleFormat if the repository format they are given has
 
496
        a format string, and vice versa.
 
497
 
 
498
        If repository_format is None, the transport is returned with no 
 
499
        checking. If it is not None, then the returned transport is
 
500
        guaranteed to point to an existing directory ready for use.
 
501
        """
 
502
        raise NotImplementedError(self.get_repository_transport)
 
503
        
 
504
    def get_workingtree_transport(self, tree_format):
 
505
        """Get the transport for use by workingtree format in this BzrDir.
 
506
 
 
507
        Note that bzr dirs that do not support format strings will raise
 
508
        IncompatibleFormat if the workingtree format they are given has a
 
509
        format string, and vice versa.
 
510
 
 
511
        If workingtree_format is None, the transport is returned with no 
 
512
        checking. If it is not None, then the returned transport is
 
513
        guaranteed to point to an existing directory ready for use.
 
514
        """
 
515
        raise NotImplementedError(self.get_workingtree_transport)
 
516
        
 
517
    def __init__(self, _transport, _format):
 
518
        """Initialize a Bzr control dir object.
 
519
        
 
520
        Only really common logic should reside here, concrete classes should be
 
521
        made with varying behaviours.
 
522
 
 
523
        :param _format: the format that is creating this BzrDir instance.
 
524
        :param _transport: the transport this dir is based at.
 
525
        """
 
526
        self._format = _format
 
527
        self.transport = _transport.clone('.bzr')
 
528
        self.root_transport = _transport
 
529
 
 
530
    def is_control_filename(self, filename):
 
531
        """True if filename is the name of a path which is reserved for bzrdir's.
 
532
        
 
533
        :param filename: A filename within the root transport of this bzrdir.
 
534
 
 
535
        This is true IF and ONLY IF the filename is part of the namespace reserved
 
536
        for bzr control dirs. Currently this is the '.bzr' directory in the root
 
537
        of the root_transport. it is expected that plugins will need to extend
 
538
        this in the future - for instance to make bzr talk with svn working
 
539
        trees.
 
540
        """
 
541
        # this might be better on the BzrDirFormat class because it refers to 
 
542
        # all the possible bzrdir disk formats. 
 
543
        # This method is tested via the workingtree is_control_filename tests- 
 
544
        # it was extracted from WorkingTree.is_control_filename. If the method's
 
545
        # contract is extended beyond the current trivial implementation, please
 
546
        # add new tests for it to the appropriate place.
 
547
        return filename == '.bzr' or filename.startswith('.bzr/')
 
548
 
 
549
    def needs_format_conversion(self, format=None):
 
550
        """Return true if this bzrdir needs convert_format run on it.
 
551
        
 
552
        For instance, if the repository format is out of date but the 
 
553
        branch and working tree are not, this should return True.
 
554
 
 
555
        :param format: Optional parameter indicating a specific desired
 
556
                       format we plan to arrive at.
 
557
        """
 
558
        raise NotImplementedError(self.needs_format_conversion)
 
559
 
 
560
    @staticmethod
 
561
    def open_unsupported(base):
 
562
        """Open a branch which is not supported."""
 
563
        return BzrDir.open(base, _unsupported=True)
 
564
        
 
565
    @staticmethod
 
566
    def open(base, _unsupported=False, possible_transports=None):
 
567
        """Open an existing bzrdir, rooted at 'base' (url).
 
568
        
 
569
        :param _unsupported: a private parameter to the BzrDir class.
 
570
        """
 
571
        t = get_transport(base, possible_transports=possible_transports)
 
572
        return BzrDir.open_from_transport(t, _unsupported=_unsupported)
 
573
 
 
574
    @staticmethod
 
575
    def open_from_transport(transport, _unsupported=False,
 
576
                            _server_formats=True):
 
577
        """Open a bzrdir within a particular directory.
 
578
 
 
579
        :param transport: Transport containing the bzrdir.
 
580
        :param _unsupported: private.
 
581
        """
 
582
        base = transport.base
 
583
 
 
584
        def find_format(transport):
 
585
            return transport, BzrDirFormat.find_format(
 
586
                transport, _server_formats=_server_formats)
 
587
 
 
588
        def redirected(transport, e, redirection_notice):
 
589
            qualified_source = e.get_source_url()
 
590
            relpath = transport.relpath(qualified_source)
 
591
            if not e.target.endswith(relpath):
 
592
                # Not redirected to a branch-format, not a branch
 
593
                raise errors.NotBranchError(path=e.target)
 
594
            target = e.target[:-len(relpath)]
 
595
            note('%s is%s redirected to %s',
 
596
                 transport.base, e.permanently, target)
 
597
            # Let's try with a new transport
 
598
            # FIXME: If 'transport' has a qualifier, this should
 
599
            # be applied again to the new transport *iff* the
 
600
            # schemes used are the same. Uncomment this code
 
601
            # once the function (and tests) exist.
 
602
            # -- vila20070212
 
603
            #target = urlutils.copy_url_qualifiers(original, target)
 
604
            return get_transport(target)
 
605
 
 
606
        try:
 
607
            transport, format = do_catching_redirections(find_format,
 
608
                                                         transport,
 
609
                                                         redirected)
 
610
        except errors.TooManyRedirections:
 
611
            raise errors.NotBranchError(base)
 
612
 
 
613
        BzrDir._check_supported(format, _unsupported)
 
614
        return format.open(transport, _found=True)
 
615
 
 
616
    def open_branch(self, unsupported=False):
 
617
        """Open the branch object at this BzrDir if one is present.
 
618
 
 
619
        If unsupported is True, then no longer supported branch formats can
 
620
        still be opened.
 
621
        
 
622
        TODO: static convenience version of this?
 
623
        """
 
624
        raise NotImplementedError(self.open_branch)
 
625
 
 
626
    @staticmethod
 
627
    def open_containing(url, possible_transports=None):
 
628
        """Open an existing branch which contains url.
 
629
        
 
630
        :param url: url to search from.
 
631
        See open_containing_from_transport for more detail.
 
632
        """
 
633
        transport = get_transport(url, possible_transports)
 
634
        return BzrDir.open_containing_from_transport(transport)
 
635
    
 
636
    @staticmethod
 
637
    def open_containing_from_transport(a_transport):
 
638
        """Open an existing branch which contains a_transport.base.
 
639
 
 
640
        This probes for a branch at a_transport, and searches upwards from there.
 
641
 
 
642
        Basically we keep looking up until we find the control directory or
 
643
        run into the root.  If there isn't one, raises NotBranchError.
 
644
        If there is one and it is either an unrecognised format or an unsupported 
 
645
        format, UnknownFormatError or UnsupportedFormatError are raised.
 
646
        If there is one, it is returned, along with the unused portion of url.
 
647
 
 
648
        :return: The BzrDir that contains the path, and a Unicode path 
 
649
                for the rest of the URL.
 
650
        """
 
651
        # this gets the normalised url back. I.e. '.' -> the full path.
 
652
        url = a_transport.base
 
653
        while True:
 
654
            try:
 
655
                result = BzrDir.open_from_transport(a_transport)
 
656
                return result, urlutils.unescape(a_transport.relpath(url))
 
657
            except errors.NotBranchError, e:
 
658
                pass
 
659
            try:
 
660
                new_t = a_transport.clone('..')
 
661
            except errors.InvalidURLJoin:
 
662
                # reached the root, whatever that may be
 
663
                raise errors.NotBranchError(path=url)
 
664
            if new_t.base == a_transport.base:
 
665
                # reached the root, whatever that may be
 
666
                raise errors.NotBranchError(path=url)
 
667
            a_transport = new_t
 
668
 
 
669
    @classmethod
 
670
    def open_containing_tree_or_branch(klass, location):
 
671
        """Return the branch and working tree contained by a location.
 
672
 
 
673
        Returns (tree, branch, relpath).
 
674
        If there is no tree at containing the location, tree will be None.
 
675
        If there is no branch containing the location, an exception will be
 
676
        raised
 
677
        relpath is the portion of the path that is contained by the branch.
 
678
        """
 
679
        bzrdir, relpath = klass.open_containing(location)
 
680
        try:
 
681
            tree = bzrdir.open_workingtree()
 
682
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
683
            tree = None
 
684
            branch = bzrdir.open_branch()
 
685
        else:
 
686
            branch = tree.branch
 
687
        return tree, branch, relpath
 
688
 
 
689
    def open_repository(self, _unsupported=False):
 
690
        """Open the repository object at this BzrDir if one is present.
 
691
 
 
692
        This will not follow the Branch object pointer - it's strictly a direct
 
693
        open facility. Most client code should use open_branch().repository to
 
694
        get at a repository.
 
695
 
 
696
        :param _unsupported: a private parameter, not part of the api.
 
697
        TODO: static convenience version of this?
 
698
        """
 
699
        raise NotImplementedError(self.open_repository)
 
700
 
 
701
    def open_workingtree(self, _unsupported=False,
 
702
                         recommend_upgrade=True, from_branch=None):
 
703
        """Open the workingtree object at this BzrDir if one is present.
 
704
 
 
705
        :param recommend_upgrade: Optional keyword parameter, when True (the
 
706
            default), emit through the ui module a recommendation that the user
 
707
            upgrade the working tree when the workingtree being opened is old
 
708
            (but still fully supported).
 
709
        :param from_branch: override bzrdir branch (for lightweight checkouts)
 
710
        """
 
711
        raise NotImplementedError(self.open_workingtree)
 
712
 
 
713
    def has_branch(self):
 
714
        """Tell if this bzrdir contains a branch.
 
715
        
 
716
        Note: if you're going to open the branch, you should just go ahead
 
717
        and try, and not ask permission first.  (This method just opens the 
 
718
        branch and discards it, and that's somewhat expensive.) 
 
719
        """
 
720
        try:
 
721
            self.open_branch()
 
722
            return True
 
723
        except errors.NotBranchError:
 
724
            return False
 
725
 
 
726
    def has_workingtree(self):
 
727
        """Tell if this bzrdir contains a working tree.
 
728
 
 
729
        This will still raise an exception if the bzrdir has a workingtree that
 
730
        is remote & inaccessible.
 
731
        
 
732
        Note: if you're going to open the working tree, you should just go ahead
 
733
        and try, and not ask permission first.  (This method just opens the 
 
734
        workingtree and discards it, and that's somewhat expensive.) 
 
735
        """
 
736
        try:
 
737
            self.open_workingtree(recommend_upgrade=False)
 
738
            return True
 
739
        except errors.NoWorkingTree:
 
740
            return False
 
741
 
 
742
    def _cloning_metadir(self):
 
743
        """Produce a metadir suitable for cloning with."""
 
744
        result_format = self._format.__class__()
 
745
        try:
 
746
            try:
 
747
                branch = self.open_branch()
 
748
                source_repository = branch.repository
 
749
            except errors.NotBranchError:
 
750
                source_branch = None
 
751
                source_repository = self.open_repository()
 
752
        except errors.NoRepositoryPresent:
 
753
            source_repository = None
 
754
        else:
 
755
            # XXX TODO: This isinstance is here because we have not implemented
 
756
            # the fix recommended in bug # 103195 - to delegate this choice the
 
757
            # repository itself.
 
758
            repo_format = source_repository._format
 
759
            if not isinstance(repo_format, remote.RemoteRepositoryFormat):
 
760
                result_format.repository_format = repo_format
 
761
        try:
 
762
            # TODO: Couldn't we just probe for the format in these cases,
 
763
            # rather than opening the whole tree?  It would be a little
 
764
            # faster. mbp 20070401
 
765
            tree = self.open_workingtree(recommend_upgrade=False)
 
766
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
767
            result_format.workingtree_format = None
 
768
        else:
 
769
            result_format.workingtree_format = tree._format.__class__()
 
770
        return result_format, source_repository
 
771
 
 
772
    def cloning_metadir(self):
 
773
        """Produce a metadir suitable for cloning or sprouting with.
 
774
 
 
775
        These operations may produce workingtrees (yes, even though they're
 
776
        "cloning" something that doesn't have a tree), so a viable workingtree
 
777
        format must be selected.
 
778
        """
 
779
        format, repository = self._cloning_metadir()
 
780
        if format._workingtree_format is None:
 
781
            if repository is None:
 
782
                return format
 
783
            tree_format = repository._format._matchingbzrdir.workingtree_format
 
784
            format.workingtree_format = tree_format.__class__()
 
785
        return format
 
786
 
 
787
    def checkout_metadir(self):
 
788
        return self.cloning_metadir()
 
789
 
 
790
    def sprout(self, url, revision_id=None, force_new_repo=False,
 
791
               recurse='down', possible_transports=None):
 
792
        """Create a copy of this bzrdir prepared for use as a new line of
 
793
        development.
 
794
 
 
795
        If url's last component does not exist, it will be created.
 
796
 
 
797
        Attributes related to the identity of the source branch like
 
798
        branch nickname will be cleaned, a working tree is created
 
799
        whether one existed before or not; and a local branch is always
 
800
        created.
 
801
 
 
802
        if revision_id is not None, then the clone operation may tune
 
803
            itself to download less data.
 
804
        """
 
805
        target_transport = get_transport(url, possible_transports)
 
806
        target_transport.ensure_base()
 
807
        cloning_format = self.cloning_metadir()
 
808
        result = cloning_format.initialize_on_transport(target_transport)
 
809
        try:
 
810
            source_branch = self.open_branch()
 
811
            source_repository = source_branch.repository
 
812
        except errors.NotBranchError:
 
813
            source_branch = None
 
814
            try:
 
815
                source_repository = self.open_repository()
 
816
            except errors.NoRepositoryPresent:
 
817
                source_repository = None
 
818
        if force_new_repo:
 
819
            result_repo = None
 
820
        else:
 
821
            try:
 
822
                result_repo = result.find_repository()
 
823
            except errors.NoRepositoryPresent:
 
824
                result_repo = None
 
825
        if source_repository is None and result_repo is not None:
 
826
            pass
 
827
        elif source_repository is None and result_repo is None:
 
828
            # no repo available, make a new one
 
829
            result.create_repository()
 
830
        elif source_repository is not None and result_repo is None:
 
831
            # have source, and want to make a new target repo
 
832
            result_repo = source_repository.sprout(result,
 
833
                                                   revision_id=revision_id)
 
834
        else:
 
835
            # fetch needed content into target.
 
836
            if source_repository is not None:
 
837
                # would rather do 
 
838
                # source_repository.copy_content_into(result_repo,
 
839
                #                                     revision_id=revision_id)
 
840
                # so we can override the copy method
 
841
                result_repo.fetch(source_repository, revision_id=revision_id)
 
842
        if source_branch is not None:
 
843
            source_branch.sprout(result, revision_id=revision_id)
 
844
        else:
 
845
            result.create_branch()
 
846
        if isinstance(target_transport, LocalTransport) and (
 
847
            result_repo is None or result_repo.make_working_trees()):
 
848
            wt = result.create_workingtree()
 
849
            wt.lock_write()
 
850
            try:
 
851
                if wt.path2id('') is None:
 
852
                    try:
 
853
                        wt.set_root_id(self.open_workingtree.get_root_id())
 
854
                    except errors.NoWorkingTree:
 
855
                        pass
 
856
            finally:
 
857
                wt.unlock()
 
858
        else:
 
859
            wt = None
 
860
        if recurse == 'down':
 
861
            if wt is not None:
 
862
                basis = wt.basis_tree()
 
863
                basis.lock_read()
 
864
                subtrees = basis.iter_references()
 
865
                recurse_branch = wt.branch
 
866
            elif source_branch is not None:
 
867
                basis = source_branch.basis_tree()
 
868
                basis.lock_read()
 
869
                subtrees = basis.iter_references()
 
870
                recurse_branch = source_branch
 
871
            else:
 
872
                subtrees = []
 
873
                basis = None
 
874
            try:
 
875
                for path, file_id in subtrees:
 
876
                    target = urlutils.join(url, urlutils.escape(path))
 
877
                    sublocation = source_branch.reference_parent(file_id, path)
 
878
                    sublocation.bzrdir.sprout(target,
 
879
                        basis.get_reference_revision(file_id, path),
 
880
                        force_new_repo=force_new_repo, recurse=recurse)
 
881
            finally:
 
882
                if basis is not None:
 
883
                    basis.unlock()
 
884
        return result
 
885
 
 
886
 
 
887
class BzrDirPreSplitOut(BzrDir):
 
888
    """A common class for the all-in-one formats."""
 
889
 
 
890
    def __init__(self, _transport, _format):
 
891
        """See BzrDir.__init__."""
 
892
        super(BzrDirPreSplitOut, self).__init__(_transport, _format)
 
893
        assert self._format._lock_class == lockable_files.TransportLock
 
894
        assert self._format._lock_file_name == 'branch-lock'
 
895
        self._control_files = lockable_files.LockableFiles(
 
896
                                            self.get_branch_transport(None),
 
897
                                            self._format._lock_file_name,
 
898
                                            self._format._lock_class)
 
899
 
 
900
    def break_lock(self):
 
901
        """Pre-splitout bzrdirs do not suffer from stale locks."""
 
902
        raise NotImplementedError(self.break_lock)
 
903
 
 
904
    def clone(self, url, revision_id=None, force_new_repo=False):
 
905
        """See BzrDir.clone()."""
 
906
        from bzrlib.workingtree import WorkingTreeFormat2
 
907
        self._make_tail(url)
 
908
        result = self._format._initialize_for_clone(url)
 
909
        self.open_repository().clone(result, revision_id=revision_id)
 
910
        from_branch = self.open_branch()
 
911
        from_branch.clone(result, revision_id=revision_id)
 
912
        try:
 
913
            self.open_workingtree().clone(result)
 
914
        except errors.NotLocalUrl:
 
915
            # make a new one, this format always has to have one.
 
916
            try:
 
917
                WorkingTreeFormat2().initialize(result)
 
918
            except errors.NotLocalUrl:
 
919
                # but we cannot do it for remote trees.
 
920
                to_branch = result.open_branch()
 
921
                WorkingTreeFormat2().stub_initialize_remote(to_branch.control_files)
 
922
        return result
 
923
 
 
924
    def create_branch(self):
 
925
        """See BzrDir.create_branch."""
 
926
        return self.open_branch()
 
927
 
 
928
    def destroy_branch(self):
 
929
        """See BzrDir.destroy_branch."""
 
930
        raise errors.UnsupportedOperation(self.destroy_branch, self)
 
931
 
 
932
    def create_repository(self, shared=False):
 
933
        """See BzrDir.create_repository."""
 
934
        if shared:
 
935
            raise errors.IncompatibleFormat('shared repository', self._format)
 
936
        return self.open_repository()
 
937
 
 
938
    def destroy_repository(self):
 
939
        """See BzrDir.destroy_repository."""
 
940
        raise errors.UnsupportedOperation(self.destroy_repository, self)
 
941
 
 
942
    def create_workingtree(self, revision_id=None, from_branch=None):
 
943
        """See BzrDir.create_workingtree."""
 
944
        # this looks buggy but is not -really-
 
945
        # because this format creates the workingtree when the bzrdir is
 
946
        # created
 
947
        # clone and sprout will have set the revision_id
 
948
        # and that will have set it for us, its only
 
949
        # specific uses of create_workingtree in isolation
 
950
        # that can do wonky stuff here, and that only
 
951
        # happens for creating checkouts, which cannot be 
 
952
        # done on this format anyway. So - acceptable wart.
 
953
        result = self.open_workingtree(recommend_upgrade=False)
 
954
        if revision_id is not None:
 
955
            if revision_id == _mod_revision.NULL_REVISION:
 
956
                result.set_parent_ids([])
 
957
            else:
 
958
                result.set_parent_ids([revision_id])
 
959
        return result
 
960
 
 
961
    def destroy_workingtree(self):
 
962
        """See BzrDir.destroy_workingtree."""
 
963
        raise errors.UnsupportedOperation(self.destroy_workingtree, self)
 
964
 
 
965
    def destroy_workingtree_metadata(self):
 
966
        """See BzrDir.destroy_workingtree_metadata."""
 
967
        raise errors.UnsupportedOperation(self.destroy_workingtree_metadata, 
 
968
                                          self)
 
969
 
 
970
    def get_branch_transport(self, branch_format):
 
971
        """See BzrDir.get_branch_transport()."""
 
972
        if branch_format is None:
 
973
            return self.transport
 
974
        try:
 
975
            branch_format.get_format_string()
 
976
        except NotImplementedError:
 
977
            return self.transport
 
978
        raise errors.IncompatibleFormat(branch_format, self._format)
 
979
 
 
980
    def get_repository_transport(self, repository_format):
 
981
        """See BzrDir.get_repository_transport()."""
 
982
        if repository_format is None:
 
983
            return self.transport
 
984
        try:
 
985
            repository_format.get_format_string()
 
986
        except NotImplementedError:
 
987
            return self.transport
 
988
        raise errors.IncompatibleFormat(repository_format, self._format)
 
989
 
 
990
    def get_workingtree_transport(self, workingtree_format):
 
991
        """See BzrDir.get_workingtree_transport()."""
 
992
        if workingtree_format is None:
 
993
            return self.transport
 
994
        try:
 
995
            workingtree_format.get_format_string()
 
996
        except NotImplementedError:
 
997
            return self.transport
 
998
        raise errors.IncompatibleFormat(workingtree_format, self._format)
 
999
 
 
1000
    def needs_format_conversion(self, format=None):
 
1001
        """See BzrDir.needs_format_conversion()."""
 
1002
        # if the format is not the same as the system default,
 
1003
        # an upgrade is needed.
 
1004
        if format is None:
 
1005
            format = BzrDirFormat.get_default_format()
 
1006
        return not isinstance(self._format, format.__class__)
 
1007
 
 
1008
    def open_branch(self, unsupported=False):
 
1009
        """See BzrDir.open_branch."""
 
1010
        from bzrlib.branch import BzrBranchFormat4
 
1011
        format = BzrBranchFormat4()
 
1012
        self._check_supported(format, unsupported)
 
1013
        return format.open(self, _found=True)
 
1014
 
 
1015
    def sprout(self, url, revision_id=None, force_new_repo=False,
 
1016
               possible_transports=None):
 
1017
        """See BzrDir.sprout()."""
 
1018
        from bzrlib.workingtree import WorkingTreeFormat2
 
1019
        self._make_tail(url)
 
1020
        result = self._format._initialize_for_clone(url)
 
1021
        try:
 
1022
            self.open_repository().clone(result, revision_id=revision_id)
 
1023
        except errors.NoRepositoryPresent:
 
1024
            pass
 
1025
        try:
 
1026
            self.open_branch().sprout(result, revision_id=revision_id)
 
1027
        except errors.NotBranchError:
 
1028
            pass
 
1029
        # we always want a working tree
 
1030
        WorkingTreeFormat2().initialize(result)
 
1031
        return result
 
1032
 
 
1033
 
 
1034
class BzrDir4(BzrDirPreSplitOut):
 
1035
    """A .bzr version 4 control object.
 
1036
    
 
1037
    This is a deprecated format and may be removed after sept 2006.
 
1038
    """
 
1039
 
 
1040
    def create_repository(self, shared=False):
 
1041
        """See BzrDir.create_repository."""
 
1042
        return self._format.repository_format.initialize(self, shared)
 
1043
 
 
1044
    def needs_format_conversion(self, format=None):
 
1045
        """Format 4 dirs are always in need of conversion."""
 
1046
        return True
 
1047
 
 
1048
    def open_repository(self):
 
1049
        """See BzrDir.open_repository."""
 
1050
        from bzrlib.repofmt.weaverepo import RepositoryFormat4
 
1051
        return RepositoryFormat4().open(self, _found=True)
 
1052
 
 
1053
 
 
1054
class BzrDir5(BzrDirPreSplitOut):
 
1055
    """A .bzr version 5 control object.
 
1056
 
 
1057
    This is a deprecated format and may be removed after sept 2006.
 
1058
    """
 
1059
 
 
1060
    def open_repository(self):
 
1061
        """See BzrDir.open_repository."""
 
1062
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
 
1063
        return RepositoryFormat5().open(self, _found=True)
 
1064
 
 
1065
    def open_workingtree(self, _unsupported=False,
 
1066
            recommend_upgrade=True):
 
1067
        """See BzrDir.create_workingtree."""
 
1068
        from bzrlib.workingtree import WorkingTreeFormat2
 
1069
        wt_format = WorkingTreeFormat2()
 
1070
        # we don't warn here about upgrades; that ought to be handled for the
 
1071
        # bzrdir as a whole
 
1072
        return wt_format.open(self, _found=True)
 
1073
 
 
1074
 
 
1075
class BzrDir6(BzrDirPreSplitOut):
 
1076
    """A .bzr version 6 control object.
 
1077
 
 
1078
    This is a deprecated format and may be removed after sept 2006.
 
1079
    """
 
1080
 
 
1081
    def open_repository(self):
 
1082
        """See BzrDir.open_repository."""
 
1083
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
 
1084
        return RepositoryFormat6().open(self, _found=True)
 
1085
 
 
1086
    def open_workingtree(self, _unsupported=False,
 
1087
        recommend_upgrade=True):
 
1088
        """See BzrDir.create_workingtree."""
 
1089
        # we don't warn here about upgrades; that ought to be handled for the
 
1090
        # bzrdir as a whole
 
1091
        from bzrlib.workingtree import WorkingTreeFormat2
 
1092
        return WorkingTreeFormat2().open(self, _found=True)
 
1093
 
 
1094
 
 
1095
class BzrDirMeta1(BzrDir):
 
1096
    """A .bzr meta version 1 control object.
 
1097
    
 
1098
    This is the first control object where the 
 
1099
    individual aspects are really split out: there are separate repository,
 
1100
    workingtree and branch subdirectories and any subset of the three can be
 
1101
    present within a BzrDir.
 
1102
    """
 
1103
 
 
1104
    def can_convert_format(self):
 
1105
        """See BzrDir.can_convert_format()."""
 
1106
        return True
 
1107
 
 
1108
    def create_branch(self):
 
1109
        """See BzrDir.create_branch."""
 
1110
        return self._format.get_branch_format().initialize(self)
 
1111
 
 
1112
    def destroy_branch(self):
 
1113
        """See BzrDir.create_branch."""
 
1114
        self.transport.delete_tree('branch')
 
1115
 
 
1116
    def create_repository(self, shared=False):
 
1117
        """See BzrDir.create_repository."""
 
1118
        return self._format.repository_format.initialize(self, shared)
 
1119
 
 
1120
    def destroy_repository(self):
 
1121
        """See BzrDir.destroy_repository."""
 
1122
        self.transport.delete_tree('repository')
 
1123
 
 
1124
    def create_workingtree(self, revision_id=None, from_branch=None):
 
1125
        """See BzrDir.create_workingtree."""
 
1126
        return self._format.workingtree_format.initialize(
 
1127
            self, revision_id, from_branch=from_branch)
 
1128
 
 
1129
    def destroy_workingtree(self):
 
1130
        """See BzrDir.destroy_workingtree."""
 
1131
        wt = self.open_workingtree(recommend_upgrade=False)
 
1132
        repository = wt.branch.repository
 
1133
        empty = repository.revision_tree(_mod_revision.NULL_REVISION)
 
1134
        wt.revert(old_tree=empty)
 
1135
        self.destroy_workingtree_metadata()
 
1136
 
 
1137
    def destroy_workingtree_metadata(self):
 
1138
        self.transport.delete_tree('checkout')
 
1139
 
 
1140
    def find_branch_format(self):
 
1141
        """Find the branch 'format' for this bzrdir.
 
1142
 
 
1143
        This might be a synthetic object for e.g. RemoteBranch and SVN.
 
1144
        """
 
1145
        from bzrlib.branch import BranchFormat
 
1146
        return BranchFormat.find_format(self)
 
1147
 
 
1148
    def _get_mkdir_mode(self):
 
1149
        """Figure out the mode to use when creating a bzrdir subdir."""
 
1150
        temp_control = lockable_files.LockableFiles(self.transport, '',
 
1151
                                     lockable_files.TransportLock)
 
1152
        return temp_control._dir_mode
 
1153
 
 
1154
    def get_branch_reference(self):
 
1155
        """See BzrDir.get_branch_reference()."""
 
1156
        from bzrlib.branch import BranchFormat
 
1157
        format = BranchFormat.find_format(self)
 
1158
        return format.get_reference(self)
 
1159
 
 
1160
    def get_branch_transport(self, branch_format):
 
1161
        """See BzrDir.get_branch_transport()."""
 
1162
        if branch_format is None:
 
1163
            return self.transport.clone('branch')
 
1164
        try:
 
1165
            branch_format.get_format_string()
 
1166
        except NotImplementedError:
 
1167
            raise errors.IncompatibleFormat(branch_format, self._format)
 
1168
        try:
 
1169
            self.transport.mkdir('branch', mode=self._get_mkdir_mode())
 
1170
        except errors.FileExists:
 
1171
            pass
 
1172
        return self.transport.clone('branch')
 
1173
 
 
1174
    def get_repository_transport(self, repository_format):
 
1175
        """See BzrDir.get_repository_transport()."""
 
1176
        if repository_format is None:
 
1177
            return self.transport.clone('repository')
 
1178
        try:
 
1179
            repository_format.get_format_string()
 
1180
        except NotImplementedError:
 
1181
            raise errors.IncompatibleFormat(repository_format, self._format)
 
1182
        try:
 
1183
            self.transport.mkdir('repository', mode=self._get_mkdir_mode())
 
1184
        except errors.FileExists:
 
1185
            pass
 
1186
        return self.transport.clone('repository')
 
1187
 
 
1188
    def get_workingtree_transport(self, workingtree_format):
 
1189
        """See BzrDir.get_workingtree_transport()."""
 
1190
        if workingtree_format is None:
 
1191
            return self.transport.clone('checkout')
 
1192
        try:
 
1193
            workingtree_format.get_format_string()
 
1194
        except NotImplementedError:
 
1195
            raise errors.IncompatibleFormat(workingtree_format, self._format)
 
1196
        try:
 
1197
            self.transport.mkdir('checkout', mode=self._get_mkdir_mode())
 
1198
        except errors.FileExists:
 
1199
            pass
 
1200
        return self.transport.clone('checkout')
 
1201
 
 
1202
    def needs_format_conversion(self, format=None):
 
1203
        """See BzrDir.needs_format_conversion()."""
 
1204
        if format is None:
 
1205
            format = BzrDirFormat.get_default_format()
 
1206
        if not isinstance(self._format, format.__class__):
 
1207
            # it is not a meta dir format, conversion is needed.
 
1208
            return True
 
1209
        # we might want to push this down to the repository?
 
1210
        try:
 
1211
            if not isinstance(self.open_repository()._format,
 
1212
                              format.repository_format.__class__):
 
1213
                # the repository needs an upgrade.
 
1214
                return True
 
1215
        except errors.NoRepositoryPresent:
 
1216
            pass
 
1217
        try:
 
1218
            if not isinstance(self.open_branch()._format,
 
1219
                              format.get_branch_format().__class__):
 
1220
                # the branch needs an upgrade.
 
1221
                return True
 
1222
        except errors.NotBranchError:
 
1223
            pass
 
1224
        try:
 
1225
            my_wt = self.open_workingtree(recommend_upgrade=False)
 
1226
            if not isinstance(my_wt._format,
 
1227
                              format.workingtree_format.__class__):
 
1228
                # the workingtree needs an upgrade.
 
1229
                return True
 
1230
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
1231
            pass
 
1232
        return False
 
1233
 
 
1234
    def open_branch(self, unsupported=False):
 
1235
        """See BzrDir.open_branch."""
 
1236
        format = self.find_branch_format()
 
1237
        self._check_supported(format, unsupported)
 
1238
        return format.open(self, _found=True)
 
1239
 
 
1240
    def open_repository(self, unsupported=False):
 
1241
        """See BzrDir.open_repository."""
 
1242
        from bzrlib.repository import RepositoryFormat
 
1243
        format = RepositoryFormat.find_format(self)
 
1244
        self._check_supported(format, unsupported)
 
1245
        return format.open(self, _found=True)
 
1246
 
 
1247
    def open_workingtree(self, unsupported=False,
 
1248
            recommend_upgrade=True):
 
1249
        """See BzrDir.open_workingtree."""
 
1250
        from bzrlib.workingtree import WorkingTreeFormat
 
1251
        format = WorkingTreeFormat.find_format(self)
 
1252
        self._check_supported(format, unsupported,
 
1253
            recommend_upgrade,
 
1254
            basedir=self.root_transport.base)
 
1255
        return format.open(self, _found=True)
 
1256
 
 
1257
 
 
1258
class BzrDirFormat(object):
 
1259
    """An encapsulation of the initialization and open routines for a format.
 
1260
 
 
1261
    Formats provide three things:
 
1262
     * An initialization routine,
 
1263
     * a format string,
 
1264
     * an open routine.
 
1265
 
 
1266
    Formats are placed in a dict by their format string for reference 
 
1267
    during bzrdir opening. These should be subclasses of BzrDirFormat
 
1268
    for consistency.
 
1269
 
 
1270
    Once a format is deprecated, just deprecate the initialize and open
 
1271
    methods on the format class. Do not deprecate the object, as the 
 
1272
    object will be created every system load.
 
1273
    """
 
1274
 
 
1275
    _default_format = None
 
1276
    """The default format used for new .bzr dirs."""
 
1277
 
 
1278
    _formats = {}
 
1279
    """The known formats."""
 
1280
 
 
1281
    _control_formats = []
 
1282
    """The registered control formats - .bzr, ....
 
1283
    
 
1284
    This is a list of BzrDirFormat objects.
 
1285
    """
 
1286
 
 
1287
    _control_server_formats = []
 
1288
    """The registered control server formats, e.g. RemoteBzrDirs.
 
1289
 
 
1290
    This is a list of BzrDirFormat objects.
 
1291
    """
 
1292
 
 
1293
    _lock_file_name = 'branch-lock'
 
1294
 
 
1295
    # _lock_class must be set in subclasses to the lock type, typ.
 
1296
    # TransportLock or LockDir
 
1297
 
 
1298
    @classmethod
 
1299
    def find_format(klass, transport, _server_formats=True):
 
1300
        """Return the format present at transport."""
 
1301
        if _server_formats:
 
1302
            formats = klass._control_server_formats + klass._control_formats
 
1303
        else:
 
1304
            formats = klass._control_formats
 
1305
        for format in formats:
 
1306
            try:
 
1307
                return format.probe_transport(transport)
 
1308
            except errors.NotBranchError:
 
1309
                # this format does not find a control dir here.
 
1310
                pass
 
1311
        raise errors.NotBranchError(path=transport.base)
 
1312
 
 
1313
    @classmethod
 
1314
    def probe_transport(klass, transport):
 
1315
        """Return the .bzrdir style format present in a directory."""
 
1316
        try:
 
1317
            format_string = transport.get(".bzr/branch-format").read()
 
1318
        except errors.NoSuchFile:
 
1319
            raise errors.NotBranchError(path=transport.base)
 
1320
 
 
1321
        try:
 
1322
            return klass._formats[format_string]
 
1323
        except KeyError:
 
1324
            raise errors.UnknownFormatError(format=format_string)
 
1325
 
 
1326
    @classmethod
 
1327
    def get_default_format(klass):
 
1328
        """Return the current default format."""
 
1329
        return klass._default_format
 
1330
 
 
1331
    def get_format_string(self):
 
1332
        """Return the ASCII format string that identifies this format."""
 
1333
        raise NotImplementedError(self.get_format_string)
 
1334
 
 
1335
    def get_format_description(self):
 
1336
        """Return the short description for this format."""
 
1337
        raise NotImplementedError(self.get_format_description)
 
1338
 
 
1339
    def get_converter(self, format=None):
 
1340
        """Return the converter to use to convert bzrdirs needing converts.
 
1341
 
 
1342
        This returns a bzrlib.bzrdir.Converter object.
 
1343
 
 
1344
        This should return the best upgrader to step this format towards the
 
1345
        current default format. In the case of plugins we can/should provide
 
1346
        some means for them to extend the range of returnable converters.
 
1347
 
 
1348
        :param format: Optional format to override the default format of the 
 
1349
                       library.
 
1350
        """
 
1351
        raise NotImplementedError(self.get_converter)
 
1352
 
 
1353
    def initialize(self, url, possible_transports=None):
 
1354
        """Create a bzr control dir at this url and return an opened copy.
 
1355
        
 
1356
        Subclasses should typically override initialize_on_transport
 
1357
        instead of this method.
 
1358
        """
 
1359
        return self.initialize_on_transport(get_transport(url,
 
1360
                                                          possible_transports))
 
1361
 
 
1362
    def initialize_on_transport(self, transport):
 
1363
        """Initialize a new bzrdir in the base directory of a Transport."""
 
1364
        # Since we don't have a .bzr directory, inherit the
 
1365
        # mode from the root directory
 
1366
        temp_control = lockable_files.LockableFiles(transport,
 
1367
                            '', lockable_files.TransportLock)
 
1368
        temp_control._transport.mkdir('.bzr',
 
1369
                                      # FIXME: RBC 20060121 don't peek under
 
1370
                                      # the covers
 
1371
                                      mode=temp_control._dir_mode)
 
1372
        if sys.platform == 'win32' and isinstance(transport, LocalTransport):
 
1373
            win32utils.set_file_attr_hidden(transport._abspath('.bzr'))
 
1374
        file_mode = temp_control._file_mode
 
1375
        del temp_control
 
1376
        mutter('created control directory in ' + transport.base)
 
1377
        control = transport.clone('.bzr')
 
1378
        utf8_files = [('README', 
 
1379
                       "This is a Bazaar-NG control directory.\n"
 
1380
                       "Do not change any files in this directory.\n"),
 
1381
                      ('branch-format', self.get_format_string()),
 
1382
                      ]
 
1383
        # NB: no need to escape relative paths that are url safe.
 
1384
        control_files = lockable_files.LockableFiles(control,
 
1385
                            self._lock_file_name, self._lock_class)
 
1386
        control_files.create_lock()
 
1387
        control_files.lock_write()
 
1388
        try:
 
1389
            for file, content in utf8_files:
 
1390
                control_files.put_utf8(file, content)
 
1391
        finally:
 
1392
            control_files.unlock()
 
1393
        return self.open(transport, _found=True)
 
1394
 
 
1395
    def is_supported(self):
 
1396
        """Is this format supported?
 
1397
 
 
1398
        Supported formats must be initializable and openable.
 
1399
        Unsupported formats may not support initialization or committing or 
 
1400
        some other features depending on the reason for not being supported.
 
1401
        """
 
1402
        return True
 
1403
 
 
1404
    def same_model(self, target_format):
 
1405
        return (self.repository_format.rich_root_data == 
 
1406
            target_format.rich_root_data)
 
1407
 
 
1408
    @classmethod
 
1409
    def known_formats(klass):
 
1410
        """Return all the known formats.
 
1411
        
 
1412
        Concrete formats should override _known_formats.
 
1413
        """
 
1414
        # There is double indirection here to make sure that control 
 
1415
        # formats used by more than one dir format will only be probed 
 
1416
        # once. This can otherwise be quite expensive for remote connections.
 
1417
        result = set()
 
1418
        for format in klass._control_formats:
 
1419
            result.update(format._known_formats())
 
1420
        return result
 
1421
    
 
1422
    @classmethod
 
1423
    def _known_formats(klass):
 
1424
        """Return the known format instances for this control format."""
 
1425
        return set(klass._formats.values())
 
1426
 
 
1427
    def open(self, transport, _found=False):
 
1428
        """Return an instance of this format for the dir transport points at.
 
1429
        
 
1430
        _found is a private parameter, do not use it.
 
1431
        """
 
1432
        if not _found:
 
1433
            found_format = BzrDirFormat.find_format(transport)
 
1434
            if not isinstance(found_format, self.__class__):
 
1435
                raise AssertionError("%s was asked to open %s, but it seems to need "
 
1436
                        "format %s" 
 
1437
                        % (self, transport, found_format))
 
1438
        return self._open(transport)
 
1439
 
 
1440
    def _open(self, transport):
 
1441
        """Template method helper for opening BzrDirectories.
 
1442
 
 
1443
        This performs the actual open and any additional logic or parameter
 
1444
        passing.
 
1445
        """
 
1446
        raise NotImplementedError(self._open)
 
1447
 
 
1448
    @classmethod
 
1449
    def register_format(klass, format):
 
1450
        klass._formats[format.get_format_string()] = format
 
1451
 
 
1452
    @classmethod
 
1453
    def register_control_format(klass, format):
 
1454
        """Register a format that does not use '.bzr' for its control dir.
 
1455
 
 
1456
        TODO: This should be pulled up into a 'ControlDirFormat' base class
 
1457
        which BzrDirFormat can inherit from, and renamed to register_format 
 
1458
        there. It has been done without that for now for simplicity of
 
1459
        implementation.
 
1460
        """
 
1461
        klass._control_formats.append(format)
 
1462
 
 
1463
    @classmethod
 
1464
    def register_control_server_format(klass, format):
 
1465
        """Register a control format for client-server environments.
 
1466
 
 
1467
        These formats will be tried before ones registered with
 
1468
        register_control_format.  This gives implementations that decide to the
 
1469
        chance to grab it before anything looks at the contents of the format
 
1470
        file.
 
1471
        """
 
1472
        klass._control_server_formats.append(format)
 
1473
 
 
1474
    @classmethod
 
1475
    @symbol_versioning.deprecated_method(symbol_versioning.zero_fourteen)
 
1476
    def set_default_format(klass, format):
 
1477
        klass._set_default_format(format)
 
1478
 
 
1479
    @classmethod
 
1480
    def _set_default_format(klass, format):
 
1481
        """Set default format (for testing behavior of defaults only)"""
 
1482
        klass._default_format = format
 
1483
 
 
1484
    def __str__(self):
 
1485
        # Trim the newline
 
1486
        return self.get_format_string().rstrip()
 
1487
 
 
1488
    @classmethod
 
1489
    def unregister_format(klass, format):
 
1490
        assert klass._formats[format.get_format_string()] is format
 
1491
        del klass._formats[format.get_format_string()]
 
1492
 
 
1493
    @classmethod
 
1494
    def unregister_control_format(klass, format):
 
1495
        klass._control_formats.remove(format)
 
1496
 
 
1497
 
 
1498
class BzrDirFormat4(BzrDirFormat):
 
1499
    """Bzr dir format 4.
 
1500
 
 
1501
    This format is a combined format for working tree, branch and repository.
 
1502
    It has:
 
1503
     - Format 1 working trees [always]
 
1504
     - Format 4 branches [always]
 
1505
     - Format 4 repositories [always]
 
1506
 
 
1507
    This format is deprecated: it indexes texts using a text it which is
 
1508
    removed in format 5; write support for this format has been removed.
 
1509
    """
 
1510
 
 
1511
    _lock_class = lockable_files.TransportLock
 
1512
 
 
1513
    def get_format_string(self):
 
1514
        """See BzrDirFormat.get_format_string()."""
 
1515
        return "Bazaar-NG branch, format 0.0.4\n"
 
1516
 
 
1517
    def get_format_description(self):
 
1518
        """See BzrDirFormat.get_format_description()."""
 
1519
        return "All-in-one format 4"
 
1520
 
 
1521
    def get_converter(self, format=None):
 
1522
        """See BzrDirFormat.get_converter()."""
 
1523
        # there is one and only one upgrade path here.
 
1524
        return ConvertBzrDir4To5()
 
1525
        
 
1526
    def initialize_on_transport(self, transport):
 
1527
        """Format 4 branches cannot be created."""
 
1528
        raise errors.UninitializableFormat(self)
 
1529
 
 
1530
    def is_supported(self):
 
1531
        """Format 4 is not supported.
 
1532
 
 
1533
        It is not supported because the model changed from 4 to 5 and the
 
1534
        conversion logic is expensive - so doing it on the fly was not 
 
1535
        feasible.
 
1536
        """
 
1537
        return False
 
1538
 
 
1539
    def _open(self, transport):
 
1540
        """See BzrDirFormat._open."""
 
1541
        return BzrDir4(transport, self)
 
1542
 
 
1543
    def __return_repository_format(self):
 
1544
        """Circular import protection."""
 
1545
        from bzrlib.repofmt.weaverepo import RepositoryFormat4
 
1546
        return RepositoryFormat4()
 
1547
    repository_format = property(__return_repository_format)
 
1548
 
 
1549
 
 
1550
class BzrDirFormat5(BzrDirFormat):
 
1551
    """Bzr control format 5.
 
1552
 
 
1553
    This format is a combined format for working tree, branch and repository.
 
1554
    It has:
 
1555
     - Format 2 working trees [always] 
 
1556
     - Format 4 branches [always] 
 
1557
     - Format 5 repositories [always]
 
1558
       Unhashed stores in the repository.
 
1559
    """
 
1560
 
 
1561
    _lock_class = lockable_files.TransportLock
 
1562
 
 
1563
    def get_format_string(self):
 
1564
        """See BzrDirFormat.get_format_string()."""
 
1565
        return "Bazaar-NG branch, format 5\n"
 
1566
 
 
1567
    def get_format_description(self):
 
1568
        """See BzrDirFormat.get_format_description()."""
 
1569
        return "All-in-one format 5"
 
1570
 
 
1571
    def get_converter(self, format=None):
 
1572
        """See BzrDirFormat.get_converter()."""
 
1573
        # there is one and only one upgrade path here.
 
1574
        return ConvertBzrDir5To6()
 
1575
 
 
1576
    def _initialize_for_clone(self, url):
 
1577
        return self.initialize_on_transport(get_transport(url), _cloning=True)
 
1578
        
 
1579
    def initialize_on_transport(self, transport, _cloning=False):
 
1580
        """Format 5 dirs always have working tree, branch and repository.
 
1581
        
 
1582
        Except when they are being cloned.
 
1583
        """
 
1584
        from bzrlib.branch import BzrBranchFormat4
 
1585
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
 
1586
        from bzrlib.workingtree import WorkingTreeFormat2
 
1587
        result = (super(BzrDirFormat5, self).initialize_on_transport(transport))
 
1588
        RepositoryFormat5().initialize(result, _internal=True)
 
1589
        if not _cloning:
 
1590
            branch = BzrBranchFormat4().initialize(result)
 
1591
            try:
 
1592
                WorkingTreeFormat2().initialize(result)
 
1593
            except errors.NotLocalUrl:
 
1594
                # Even though we can't access the working tree, we need to
 
1595
                # create its control files.
 
1596
                WorkingTreeFormat2().stub_initialize_remote(branch.control_files)
 
1597
        return result
 
1598
 
 
1599
    def _open(self, transport):
 
1600
        """See BzrDirFormat._open."""
 
1601
        return BzrDir5(transport, self)
 
1602
 
 
1603
    def __return_repository_format(self):
 
1604
        """Circular import protection."""
 
1605
        from bzrlib.repofmt.weaverepo import RepositoryFormat5
 
1606
        return RepositoryFormat5()
 
1607
    repository_format = property(__return_repository_format)
 
1608
 
 
1609
 
 
1610
class BzrDirFormat6(BzrDirFormat):
 
1611
    """Bzr control format 6.
 
1612
 
 
1613
    This format is a combined format for working tree, branch and repository.
 
1614
    It has:
 
1615
     - Format 2 working trees [always] 
 
1616
     - Format 4 branches [always] 
 
1617
     - Format 6 repositories [always]
 
1618
    """
 
1619
 
 
1620
    _lock_class = lockable_files.TransportLock
 
1621
 
 
1622
    def get_format_string(self):
 
1623
        """See BzrDirFormat.get_format_string()."""
 
1624
        return "Bazaar-NG branch, format 6\n"
 
1625
 
 
1626
    def get_format_description(self):
 
1627
        """See BzrDirFormat.get_format_description()."""
 
1628
        return "All-in-one format 6"
 
1629
 
 
1630
    def get_converter(self, format=None):
 
1631
        """See BzrDirFormat.get_converter()."""
 
1632
        # there is one and only one upgrade path here.
 
1633
        return ConvertBzrDir6ToMeta()
 
1634
        
 
1635
    def _initialize_for_clone(self, url):
 
1636
        return self.initialize_on_transport(get_transport(url), _cloning=True)
 
1637
 
 
1638
    def initialize_on_transport(self, transport, _cloning=False):
 
1639
        """Format 6 dirs always have working tree, branch and repository.
 
1640
        
 
1641
        Except when they are being cloned.
 
1642
        """
 
1643
        from bzrlib.branch import BzrBranchFormat4
 
1644
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
 
1645
        from bzrlib.workingtree import WorkingTreeFormat2
 
1646
        result = super(BzrDirFormat6, self).initialize_on_transport(transport)
 
1647
        RepositoryFormat6().initialize(result, _internal=True)
 
1648
        if not _cloning:
 
1649
            branch = BzrBranchFormat4().initialize(result)
 
1650
            try:
 
1651
                WorkingTreeFormat2().initialize(result)
 
1652
            except errors.NotLocalUrl:
 
1653
                # Even though we can't access the working tree, we need to
 
1654
                # create its control files.
 
1655
                WorkingTreeFormat2().stub_initialize_remote(branch.control_files)
 
1656
        return result
 
1657
 
 
1658
    def _open(self, transport):
 
1659
        """See BzrDirFormat._open."""
 
1660
        return BzrDir6(transport, self)
 
1661
 
 
1662
    def __return_repository_format(self):
 
1663
        """Circular import protection."""
 
1664
        from bzrlib.repofmt.weaverepo import RepositoryFormat6
 
1665
        return RepositoryFormat6()
 
1666
    repository_format = property(__return_repository_format)
 
1667
 
 
1668
 
 
1669
class BzrDirMetaFormat1(BzrDirFormat):
 
1670
    """Bzr meta control format 1
 
1671
 
 
1672
    This is the first format with split out working tree, branch and repository
 
1673
    disk storage.
 
1674
    It has:
 
1675
     - Format 3 working trees [optional]
 
1676
     - Format 5 branches [optional]
 
1677
     - Format 7 repositories [optional]
 
1678
    """
 
1679
 
 
1680
    _lock_class = lockdir.LockDir
 
1681
 
 
1682
    def __init__(self):
 
1683
        self._workingtree_format = None
 
1684
        self._branch_format = None
 
1685
 
 
1686
    def __eq__(self, other):
 
1687
        if other.__class__ is not self.__class__:
 
1688
            return False
 
1689
        if other.repository_format != self.repository_format:
 
1690
            return False
 
1691
        if other.workingtree_format != self.workingtree_format:
 
1692
            return False
 
1693
        return True
 
1694
 
 
1695
    def __ne__(self, other):
 
1696
        return not self == other
 
1697
 
 
1698
    def get_branch_format(self):
 
1699
        if self._branch_format is None:
 
1700
            from bzrlib.branch import BranchFormat
 
1701
            self._branch_format = BranchFormat.get_default_format()
 
1702
        return self._branch_format
 
1703
 
 
1704
    def set_branch_format(self, format):
 
1705
        self._branch_format = format
 
1706
 
 
1707
    def get_converter(self, format=None):
 
1708
        """See BzrDirFormat.get_converter()."""
 
1709
        if format is None:
 
1710
            format = BzrDirFormat.get_default_format()
 
1711
        if not isinstance(self, format.__class__):
 
1712
            # converting away from metadir is not implemented
 
1713
            raise NotImplementedError(self.get_converter)
 
1714
        return ConvertMetaToMeta(format)
 
1715
 
 
1716
    def get_format_string(self):
 
1717
        """See BzrDirFormat.get_format_string()."""
 
1718
        return "Bazaar-NG meta directory, format 1\n"
 
1719
 
 
1720
    def get_format_description(self):
 
1721
        """See BzrDirFormat.get_format_description()."""
 
1722
        return "Meta directory format 1"
 
1723
 
 
1724
    def _open(self, transport):
 
1725
        """See BzrDirFormat._open."""
 
1726
        return BzrDirMeta1(transport, self)
 
1727
 
 
1728
    def __return_repository_format(self):
 
1729
        """Circular import protection."""
 
1730
        if getattr(self, '_repository_format', None):
 
1731
            return self._repository_format
 
1732
        from bzrlib.repository import RepositoryFormat
 
1733
        return RepositoryFormat.get_default_format()
 
1734
 
 
1735
    def __set_repository_format(self, value):
 
1736
        """Allow changing the repository format for metadir formats."""
 
1737
        self._repository_format = value
 
1738
 
 
1739
    repository_format = property(__return_repository_format, __set_repository_format)
 
1740
 
 
1741
    def __get_workingtree_format(self):
 
1742
        if self._workingtree_format is None:
 
1743
            from bzrlib.workingtree import WorkingTreeFormat
 
1744
            self._workingtree_format = WorkingTreeFormat.get_default_format()
 
1745
        return self._workingtree_format
 
1746
 
 
1747
    def __set_workingtree_format(self, wt_format):
 
1748
        self._workingtree_format = wt_format
 
1749
 
 
1750
    workingtree_format = property(__get_workingtree_format,
 
1751
                                  __set_workingtree_format)
 
1752
 
 
1753
 
 
1754
# Register bzr control format
 
1755
BzrDirFormat.register_control_format(BzrDirFormat)
 
1756
 
 
1757
# Register bzr formats
 
1758
BzrDirFormat.register_format(BzrDirFormat4())
 
1759
BzrDirFormat.register_format(BzrDirFormat5())
 
1760
BzrDirFormat.register_format(BzrDirFormat6())
 
1761
__default_format = BzrDirMetaFormat1()
 
1762
BzrDirFormat.register_format(__default_format)
 
1763
BzrDirFormat._default_format = __default_format
 
1764
 
 
1765
 
 
1766
class Converter(object):
 
1767
    """Converts a disk format object from one format to another."""
 
1768
 
 
1769
    def convert(self, to_convert, pb):
 
1770
        """Perform the conversion of to_convert, giving feedback via pb.
 
1771
 
 
1772
        :param to_convert: The disk object to convert.
 
1773
        :param pb: a progress bar to use for progress information.
 
1774
        """
 
1775
 
 
1776
    def step(self, message):
 
1777
        """Update the pb by a step."""
 
1778
        self.count +=1
 
1779
        self.pb.update(message, self.count, self.total)
 
1780
 
 
1781
 
 
1782
class ConvertBzrDir4To5(Converter):
 
1783
    """Converts format 4 bzr dirs to format 5."""
 
1784
 
 
1785
    def __init__(self):
 
1786
        super(ConvertBzrDir4To5, self).__init__()
 
1787
        self.converted_revs = set()
 
1788
        self.absent_revisions = set()
 
1789
        self.text_count = 0
 
1790
        self.revisions = {}
 
1791
        
 
1792
    def convert(self, to_convert, pb):
 
1793
        """See Converter.convert()."""
 
1794
        self.bzrdir = to_convert
 
1795
        self.pb = pb
 
1796
        self.pb.note('starting upgrade from format 4 to 5')
 
1797
        if isinstance(self.bzrdir.transport, LocalTransport):
 
1798
            self.bzrdir.get_workingtree_transport(None).delete('stat-cache')
 
1799
        self._convert_to_weaves()
 
1800
        return BzrDir.open(self.bzrdir.root_transport.base)
 
1801
 
 
1802
    def _convert_to_weaves(self):
 
1803
        self.pb.note('note: upgrade may be faster if all store files are ungzipped first')
 
1804
        try:
 
1805
            # TODO permissions
 
1806
            stat = self.bzrdir.transport.stat('weaves')
 
1807
            if not S_ISDIR(stat.st_mode):
 
1808
                self.bzrdir.transport.delete('weaves')
 
1809
                self.bzrdir.transport.mkdir('weaves')
 
1810
        except errors.NoSuchFile:
 
1811
            self.bzrdir.transport.mkdir('weaves')
 
1812
        # deliberately not a WeaveFile as we want to build it up slowly.
 
1813
        self.inv_weave = Weave('inventory')
 
1814
        # holds in-memory weaves for all files
 
1815
        self.text_weaves = {}
 
1816
        self.bzrdir.transport.delete('branch-format')
 
1817
        self.branch = self.bzrdir.open_branch()
 
1818
        self._convert_working_inv()
 
1819
        rev_history = self.branch.revision_history()
 
1820
        # to_read is a stack holding the revisions we still need to process;
 
1821
        # appending to it adds new highest-priority revisions
 
1822
        self.known_revisions = set(rev_history)
 
1823
        self.to_read = rev_history[-1:]
 
1824
        while self.to_read:
 
1825
            rev_id = self.to_read.pop()
 
1826
            if (rev_id not in self.revisions
 
1827
                and rev_id not in self.absent_revisions):
 
1828
                self._load_one_rev(rev_id)
 
1829
        self.pb.clear()
 
1830
        to_import = self._make_order()
 
1831
        for i, rev_id in enumerate(to_import):
 
1832
            self.pb.update('converting revision', i, len(to_import))
 
1833
            self._convert_one_rev(rev_id)
 
1834
        self.pb.clear()
 
1835
        self._write_all_weaves()
 
1836
        self._write_all_revs()
 
1837
        self.pb.note('upgraded to weaves:')
 
1838
        self.pb.note('  %6d revisions and inventories', len(self.revisions))
 
1839
        self.pb.note('  %6d revisions not present', len(self.absent_revisions))
 
1840
        self.pb.note('  %6d texts', self.text_count)
 
1841
        self._cleanup_spare_files_after_format4()
 
1842
        self.branch.control_files.put_utf8('branch-format', BzrDirFormat5().get_format_string())
 
1843
 
 
1844
    def _cleanup_spare_files_after_format4(self):
 
1845
        # FIXME working tree upgrade foo.
 
1846
        for n in 'merged-patches', 'pending-merged-patches':
 
1847
            try:
 
1848
                ## assert os.path.getsize(p) == 0
 
1849
                self.bzrdir.transport.delete(n)
 
1850
            except errors.NoSuchFile:
 
1851
                pass
 
1852
        self.bzrdir.transport.delete_tree('inventory-store')
 
1853
        self.bzrdir.transport.delete_tree('text-store')
 
1854
 
 
1855
    def _convert_working_inv(self):
 
1856
        inv = xml4.serializer_v4.read_inventory(
 
1857
                    self.branch.control_files.get('inventory'))
 
1858
        new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv, working=True)
 
1859
        # FIXME inventory is a working tree change.
 
1860
        self.branch.control_files.put('inventory', StringIO(new_inv_xml))
 
1861
 
 
1862
    def _write_all_weaves(self):
 
1863
        controlweaves = WeaveStore(self.bzrdir.transport, prefixed=False)
 
1864
        weave_transport = self.bzrdir.transport.clone('weaves')
 
1865
        weaves = WeaveStore(weave_transport, prefixed=False)
 
1866
        transaction = WriteTransaction()
 
1867
 
 
1868
        try:
 
1869
            i = 0
 
1870
            for file_id, file_weave in self.text_weaves.items():
 
1871
                self.pb.update('writing weave', i, len(self.text_weaves))
 
1872
                weaves._put_weave(file_id, file_weave, transaction)
 
1873
                i += 1
 
1874
            self.pb.update('inventory', 0, 1)
 
1875
            controlweaves._put_weave('inventory', self.inv_weave, transaction)
 
1876
            self.pb.update('inventory', 1, 1)
 
1877
        finally:
 
1878
            self.pb.clear()
 
1879
 
 
1880
    def _write_all_revs(self):
 
1881
        """Write all revisions out in new form."""
 
1882
        self.bzrdir.transport.delete_tree('revision-store')
 
1883
        self.bzrdir.transport.mkdir('revision-store')
 
1884
        revision_transport = self.bzrdir.transport.clone('revision-store')
 
1885
        # TODO permissions
 
1886
        _revision_store = TextRevisionStore(TextStore(revision_transport,
 
1887
                                                      prefixed=False,
 
1888
                                                      compressed=True))
 
1889
        try:
 
1890
            transaction = WriteTransaction()
 
1891
            for i, rev_id in enumerate(self.converted_revs):
 
1892
                self.pb.update('write revision', i, len(self.converted_revs))
 
1893
                _revision_store.add_revision(self.revisions[rev_id], transaction)
 
1894
        finally:
 
1895
            self.pb.clear()
 
1896
            
 
1897
    def _load_one_rev(self, rev_id):
 
1898
        """Load a revision object into memory.
 
1899
 
 
1900
        Any parents not either loaded or abandoned get queued to be
 
1901
        loaded."""
 
1902
        self.pb.update('loading revision',
 
1903
                       len(self.revisions),
 
1904
                       len(self.known_revisions))
 
1905
        if not self.branch.repository.has_revision(rev_id):
 
1906
            self.pb.clear()
 
1907
            self.pb.note('revision {%s} not present in branch; '
 
1908
                         'will be converted as a ghost',
 
1909
                         rev_id)
 
1910
            self.absent_revisions.add(rev_id)
 
1911
        else:
 
1912
            rev = self.branch.repository._revision_store.get_revision(rev_id,
 
1913
                self.branch.repository.get_transaction())
 
1914
            for parent_id in rev.parent_ids:
 
1915
                self.known_revisions.add(parent_id)
 
1916
                self.to_read.append(parent_id)
 
1917
            self.revisions[rev_id] = rev
 
1918
 
 
1919
    def _load_old_inventory(self, rev_id):
 
1920
        assert rev_id not in self.converted_revs
 
1921
        old_inv_xml = self.branch.repository.inventory_store.get(rev_id).read()
 
1922
        inv = xml4.serializer_v4.read_inventory_from_string(old_inv_xml)
 
1923
        inv.revision_id = rev_id
 
1924
        rev = self.revisions[rev_id]
 
1925
        if rev.inventory_sha1:
 
1926
            assert rev.inventory_sha1 == sha_string(old_inv_xml), \
 
1927
                'inventory sha mismatch for {%s}' % rev_id
 
1928
        return inv
 
1929
 
 
1930
    def _load_updated_inventory(self, rev_id):
 
1931
        assert rev_id in self.converted_revs
 
1932
        inv_xml = self.inv_weave.get_text(rev_id)
 
1933
        inv = xml5.serializer_v5.read_inventory_from_string(inv_xml)
 
1934
        return inv
 
1935
 
 
1936
    def _convert_one_rev(self, rev_id):
 
1937
        """Convert revision and all referenced objects to new format."""
 
1938
        rev = self.revisions[rev_id]
 
1939
        inv = self._load_old_inventory(rev_id)
 
1940
        present_parents = [p for p in rev.parent_ids
 
1941
                           if p not in self.absent_revisions]
 
1942
        self._convert_revision_contents(rev, inv, present_parents)
 
1943
        self._store_new_inv(rev, inv, present_parents)
 
1944
        self.converted_revs.add(rev_id)
 
1945
 
 
1946
    def _store_new_inv(self, rev, inv, present_parents):
 
1947
        # the XML is now updated with text versions
 
1948
        if __debug__:
 
1949
            entries = inv.iter_entries()
 
1950
            entries.next()
 
1951
            for path, ie in entries:
 
1952
                assert getattr(ie, 'revision', None) is not None, \
 
1953
                    'no revision on {%s} in {%s}' % \
 
1954
                    (file_id, rev.revision_id)
 
1955
        new_inv_xml = xml5.serializer_v5.write_inventory_to_string(inv)
 
1956
        new_inv_sha1 = sha_string(new_inv_xml)
 
1957
        self.inv_weave.add_lines(rev.revision_id,
 
1958
                                 present_parents,
 
1959
                                 new_inv_xml.splitlines(True))
 
1960
        rev.inventory_sha1 = new_inv_sha1
 
1961
 
 
1962
    def _convert_revision_contents(self, rev, inv, present_parents):
 
1963
        """Convert all the files within a revision.
 
1964
 
 
1965
        Also upgrade the inventory to refer to the text revision ids."""
 
1966
        rev_id = rev.revision_id
 
1967
        mutter('converting texts of revision {%s}',
 
1968
               rev_id)
 
1969
        parent_invs = map(self._load_updated_inventory, present_parents)
 
1970
        entries = inv.iter_entries()
 
1971
        entries.next()
 
1972
        for path, ie in entries:
 
1973
            self._convert_file_version(rev, ie, parent_invs)
 
1974
 
 
1975
    def _convert_file_version(self, rev, ie, parent_invs):
 
1976
        """Convert one version of one file.
 
1977
 
 
1978
        The file needs to be added into the weave if it is a merge
 
1979
        of >=2 parents or if it's changed from its parent.
 
1980
        """
 
1981
        file_id = ie.file_id
 
1982
        rev_id = rev.revision_id
 
1983
        w = self.text_weaves.get(file_id)
 
1984
        if w is None:
 
1985
            w = Weave(file_id)
 
1986
            self.text_weaves[file_id] = w
 
1987
        text_changed = False
 
1988
        parent_candiate_entries = ie.parent_candidates(parent_invs)
 
1989
        for old_revision in parent_candiate_entries.keys():
 
1990
            # if this fails, its a ghost ?
 
1991
            assert old_revision in self.converted_revs, \
 
1992
                "Revision {%s} not in converted_revs" % old_revision
 
1993
        heads = graph.Graph(self).heads(parent_candiate_entries.keys())
 
1994
        # XXX: Note that this is unordered - and this is tolerable because 
 
1995
        # the previous code was also unordered.
 
1996
        previous_entries = dict((head, parent_candiate_entries[head]) for head
 
1997
            in heads)
 
1998
        self.snapshot_ie(previous_entries, ie, w, rev_id)
 
1999
        del ie.text_id
 
2000
        assert getattr(ie, 'revision', None) is not None
 
2001
 
 
2002
    def get_parents(self, revision_ids):
 
2003
        for revision_id in revision_ids:
 
2004
            yield self.revisions[revision_id].parent_ids
 
2005
 
 
2006
    def snapshot_ie(self, previous_revisions, ie, w, rev_id):
 
2007
        # TODO: convert this logic, which is ~= snapshot to
 
2008
        # a call to:. This needs the path figured out. rather than a work_tree
 
2009
        # a v4 revision_tree can be given, or something that looks enough like
 
2010
        # one to give the file content to the entry if it needs it.
 
2011
        # and we need something that looks like a weave store for snapshot to 
 
2012
        # save against.
 
2013
        #ie.snapshot(rev, PATH, previous_revisions, REVISION_TREE, InMemoryWeaveStore(self.text_weaves))
 
2014
        if len(previous_revisions) == 1:
 
2015
            previous_ie = previous_revisions.values()[0]
 
2016
            if ie._unchanged(previous_ie):
 
2017
                ie.revision = previous_ie.revision
 
2018
                return
 
2019
        if ie.has_text():
 
2020
            text = self.branch.repository.weave_store.get(ie.text_id)
 
2021
            file_lines = text.readlines()
 
2022
            assert sha_strings(file_lines) == ie.text_sha1
 
2023
            assert sum(map(len, file_lines)) == ie.text_size
 
2024
            w.add_lines(rev_id, previous_revisions, file_lines)
 
2025
            self.text_count += 1
 
2026
        else:
 
2027
            w.add_lines(rev_id, previous_revisions, [])
 
2028
        ie.revision = rev_id
 
2029
 
 
2030
    def _make_order(self):
 
2031
        """Return a suitable order for importing revisions.
 
2032
 
 
2033
        The order must be such that an revision is imported after all
 
2034
        its (present) parents.
 
2035
        """
 
2036
        todo = set(self.revisions.keys())
 
2037
        done = self.absent_revisions.copy()
 
2038
        order = []
 
2039
        while todo:
 
2040
            # scan through looking for a revision whose parents
 
2041
            # are all done
 
2042
            for rev_id in sorted(list(todo)):
 
2043
                rev = self.revisions[rev_id]
 
2044
                parent_ids = set(rev.parent_ids)
 
2045
                if parent_ids.issubset(done):
 
2046
                    # can take this one now
 
2047
                    order.append(rev_id)
 
2048
                    todo.remove(rev_id)
 
2049
                    done.add(rev_id)
 
2050
        return order
 
2051
 
 
2052
 
 
2053
class ConvertBzrDir5To6(Converter):
 
2054
    """Converts format 5 bzr dirs to format 6."""
 
2055
 
 
2056
    def convert(self, to_convert, pb):
 
2057
        """See Converter.convert()."""
 
2058
        self.bzrdir = to_convert
 
2059
        self.pb = pb
 
2060
        self.pb.note('starting upgrade from format 5 to 6')
 
2061
        self._convert_to_prefixed()
 
2062
        return BzrDir.open(self.bzrdir.root_transport.base)
 
2063
 
 
2064
    def _convert_to_prefixed(self):
 
2065
        from bzrlib.store import TransportStore
 
2066
        self.bzrdir.transport.delete('branch-format')
 
2067
        for store_name in ["weaves", "revision-store"]:
 
2068
            self.pb.note("adding prefixes to %s" % store_name)
 
2069
            store_transport = self.bzrdir.transport.clone(store_name)
 
2070
            store = TransportStore(store_transport, prefixed=True)
 
2071
            for urlfilename in store_transport.list_dir('.'):
 
2072
                filename = urlutils.unescape(urlfilename)
 
2073
                if (filename.endswith(".weave") or
 
2074
                    filename.endswith(".gz") or
 
2075
                    filename.endswith(".sig")):
 
2076
                    file_id = os.path.splitext(filename)[0]
 
2077
                else:
 
2078
                    file_id = filename
 
2079
                prefix_dir = store.hash_prefix(file_id)
 
2080
                # FIXME keep track of the dirs made RBC 20060121
 
2081
                try:
 
2082
                    store_transport.move(filename, prefix_dir + '/' + filename)
 
2083
                except errors.NoSuchFile: # catches missing dirs strangely enough
 
2084
                    store_transport.mkdir(prefix_dir)
 
2085
                    store_transport.move(filename, prefix_dir + '/' + filename)
 
2086
        self.bzrdir._control_files.put_utf8('branch-format', BzrDirFormat6().get_format_string())
 
2087
 
 
2088
 
 
2089
class ConvertBzrDir6ToMeta(Converter):
 
2090
    """Converts format 6 bzr dirs to metadirs."""
 
2091
 
 
2092
    def convert(self, to_convert, pb):
 
2093
        """See Converter.convert()."""
 
2094
        from bzrlib.repofmt.weaverepo import RepositoryFormat7
 
2095
        from bzrlib.branch import BzrBranchFormat5
 
2096
        self.bzrdir = to_convert
 
2097
        self.pb = pb
 
2098
        self.count = 0
 
2099
        self.total = 20 # the steps we know about
 
2100
        self.garbage_inventories = []
 
2101
 
 
2102
        self.pb.note('starting upgrade from format 6 to metadir')
 
2103
        self.bzrdir._control_files.put_utf8('branch-format', "Converting to format 6")
 
2104
        # its faster to move specific files around than to open and use the apis...
 
2105
        # first off, nuke ancestry.weave, it was never used.
 
2106
        try:
 
2107
            self.step('Removing ancestry.weave')
 
2108
            self.bzrdir.transport.delete('ancestry.weave')
 
2109
        except errors.NoSuchFile:
 
2110
            pass
 
2111
        # find out whats there
 
2112
        self.step('Finding branch files')
 
2113
        last_revision = self.bzrdir.open_branch().last_revision()
 
2114
        bzrcontents = self.bzrdir.transport.list_dir('.')
 
2115
        for name in bzrcontents:
 
2116
            if name.startswith('basis-inventory.'):
 
2117
                self.garbage_inventories.append(name)
 
2118
        # create new directories for repository, working tree and branch
 
2119
        self.dir_mode = self.bzrdir._control_files._dir_mode
 
2120
        self.file_mode = self.bzrdir._control_files._file_mode
 
2121
        repository_names = [('inventory.weave', True),
 
2122
                            ('revision-store', True),
 
2123
                            ('weaves', True)]
 
2124
        self.step('Upgrading repository  ')
 
2125
        self.bzrdir.transport.mkdir('repository', mode=self.dir_mode)
 
2126
        self.make_lock('repository')
 
2127
        # we hard code the formats here because we are converting into
 
2128
        # the meta format. The meta format upgrader can take this to a 
 
2129
        # future format within each component.
 
2130
        self.put_format('repository', RepositoryFormat7())
 
2131
        for entry in repository_names:
 
2132
            self.move_entry('repository', entry)
 
2133
 
 
2134
        self.step('Upgrading branch      ')
 
2135
        self.bzrdir.transport.mkdir('branch', mode=self.dir_mode)
 
2136
        self.make_lock('branch')
 
2137
        self.put_format('branch', BzrBranchFormat5())
 
2138
        branch_files = [('revision-history', True),
 
2139
                        ('branch-name', True),
 
2140
                        ('parent', False)]
 
2141
        for entry in branch_files:
 
2142
            self.move_entry('branch', entry)
 
2143
 
 
2144
        checkout_files = [('pending-merges', True),
 
2145
                          ('inventory', True),
 
2146
                          ('stat-cache', False)]
 
2147
        # If a mandatory checkout file is not present, the branch does not have
 
2148
        # a functional checkout. Do not create a checkout in the converted
 
2149
        # branch.
 
2150
        for name, mandatory in checkout_files:
 
2151
            if mandatory and name not in bzrcontents:
 
2152
                has_checkout = False
 
2153
                break
 
2154
        else:
 
2155
            has_checkout = True
 
2156
        if not has_checkout:
 
2157
            self.pb.note('No working tree.')
 
2158
            # If some checkout files are there, we may as well get rid of them.
 
2159
            for name, mandatory in checkout_files:
 
2160
                if name in bzrcontents:
 
2161
                    self.bzrdir.transport.delete(name)
 
2162
        else:
 
2163
            from bzrlib.workingtree import WorkingTreeFormat3
 
2164
            self.step('Upgrading working tree')
 
2165
            self.bzrdir.transport.mkdir('checkout', mode=self.dir_mode)
 
2166
            self.make_lock('checkout')
 
2167
            self.put_format(
 
2168
                'checkout', WorkingTreeFormat3())
 
2169
            self.bzrdir.transport.delete_multi(
 
2170
                self.garbage_inventories, self.pb)
 
2171
            for entry in checkout_files:
 
2172
                self.move_entry('checkout', entry)
 
2173
            if last_revision is not None:
 
2174
                self.bzrdir._control_files.put_utf8(
 
2175
                    'checkout/last-revision', last_revision)
 
2176
        self.bzrdir._control_files.put_utf8(
 
2177
            'branch-format', BzrDirMetaFormat1().get_format_string())
 
2178
        return BzrDir.open(self.bzrdir.root_transport.base)
 
2179
 
 
2180
    def make_lock(self, name):
 
2181
        """Make a lock for the new control dir name."""
 
2182
        self.step('Make %s lock' % name)
 
2183
        ld = lockdir.LockDir(self.bzrdir.transport,
 
2184
                             '%s/lock' % name,
 
2185
                             file_modebits=self.file_mode,
 
2186
                             dir_modebits=self.dir_mode)
 
2187
        ld.create()
 
2188
 
 
2189
    def move_entry(self, new_dir, entry):
 
2190
        """Move then entry name into new_dir."""
 
2191
        name = entry[0]
 
2192
        mandatory = entry[1]
 
2193
        self.step('Moving %s' % name)
 
2194
        try:
 
2195
            self.bzrdir.transport.move(name, '%s/%s' % (new_dir, name))
 
2196
        except errors.NoSuchFile:
 
2197
            if mandatory:
 
2198
                raise
 
2199
 
 
2200
    def put_format(self, dirname, format):
 
2201
        self.bzrdir._control_files.put_utf8('%s/format' % dirname, format.get_format_string())
 
2202
 
 
2203
 
 
2204
class ConvertMetaToMeta(Converter):
 
2205
    """Converts the components of metadirs."""
 
2206
 
 
2207
    def __init__(self, target_format):
 
2208
        """Create a metadir to metadir converter.
 
2209
 
 
2210
        :param target_format: The final metadir format that is desired.
 
2211
        """
 
2212
        self.target_format = target_format
 
2213
 
 
2214
    def convert(self, to_convert, pb):
 
2215
        """See Converter.convert()."""
 
2216
        self.bzrdir = to_convert
 
2217
        self.pb = pb
 
2218
        self.count = 0
 
2219
        self.total = 1
 
2220
        self.step('checking repository format')
 
2221
        try:
 
2222
            repo = self.bzrdir.open_repository()
 
2223
        except errors.NoRepositoryPresent:
 
2224
            pass
 
2225
        else:
 
2226
            if not isinstance(repo._format, self.target_format.repository_format.__class__):
 
2227
                from bzrlib.repository import CopyConverter
 
2228
                self.pb.note('starting repository conversion')
 
2229
                converter = CopyConverter(self.target_format.repository_format)
 
2230
                converter.convert(repo, pb)
 
2231
        try:
 
2232
            branch = self.bzrdir.open_branch()
 
2233
        except errors.NotBranchError:
 
2234
            pass
 
2235
        else:
 
2236
            # TODO: conversions of Branch and Tree should be done by
 
2237
            # InterXFormat lookups
 
2238
            # Avoid circular imports
 
2239
            from bzrlib import branch as _mod_branch
 
2240
            if (branch._format.__class__ is _mod_branch.BzrBranchFormat5 and
 
2241
                self.target_format.get_branch_format().__class__ is
 
2242
                _mod_branch.BzrBranchFormat6):
 
2243
                branch_converter = _mod_branch.Converter5to6()
 
2244
                branch_converter.convert(branch)
 
2245
        try:
 
2246
            tree = self.bzrdir.open_workingtree(recommend_upgrade=False)
 
2247
        except (errors.NoWorkingTree, errors.NotLocalUrl):
 
2248
            pass
 
2249
        else:
 
2250
            # TODO: conversions of Branch and Tree should be done by
 
2251
            # InterXFormat lookups
 
2252
            if (isinstance(tree, workingtree.WorkingTree3) and
 
2253
                not isinstance(tree, workingtree_4.WorkingTree4) and
 
2254
                isinstance(self.target_format.workingtree_format,
 
2255
                    workingtree_4.WorkingTreeFormat4)):
 
2256
                workingtree_4.Converter3to4().convert(tree)
 
2257
        return to_convert
 
2258
 
 
2259
 
 
2260
# This is not in remote.py because it's small, and needs to be registered.
 
2261
# Putting it in remote.py creates a circular import problem.
 
2262
# we can make it a lazy object if the control formats is turned into something
 
2263
# like a registry.
 
2264
class RemoteBzrDirFormat(BzrDirMetaFormat1):
 
2265
    """Format representing bzrdirs accessed via a smart server"""
 
2266
 
 
2267
    def get_format_description(self):
 
2268
        return 'bzr remote bzrdir'
 
2269
    
 
2270
    @classmethod
 
2271
    def probe_transport(klass, transport):
 
2272
        """Return a RemoteBzrDirFormat object if it looks possible."""
 
2273
        try:
 
2274
            client = transport.get_smart_client()
 
2275
        except (NotImplementedError, AttributeError,
 
2276
                errors.TransportNotPossible):
 
2277
            # no smart server, so not a branch for this format type.
 
2278
            raise errors.NotBranchError(path=transport.base)
 
2279
        else:
 
2280
            # Send a 'hello' request in protocol version one, and decline to
 
2281
            # open it if the server doesn't support our required version (2) so
 
2282
            # that the VFS-based transport will do it.
 
2283
            request = client.get_request()
 
2284
            smart_protocol = protocol.SmartClientRequestProtocolOne(request)
 
2285
            server_version = smart_protocol.query_version()
 
2286
            if server_version != 2:
 
2287
                raise errors.NotBranchError(path=transport.base)
 
2288
            return klass()
 
2289
 
 
2290
    def initialize_on_transport(self, transport):
 
2291
        try:
 
2292
            # hand off the request to the smart server
 
2293
            shared_medium = transport.get_shared_medium()
 
2294
        except errors.NoSmartMedium:
 
2295
            # TODO: lookup the local format from a server hint.
 
2296
            local_dir_format = BzrDirMetaFormat1()
 
2297
            return local_dir_format.initialize_on_transport(transport)
 
2298
        client = _SmartClient(shared_medium)
 
2299
        path = client.remote_path_from_transport(transport)
 
2300
        response = _SmartClient(shared_medium).call('BzrDirFormat.initialize',
 
2301
                                                    path)
 
2302
        assert response[0] in ('ok', ), 'unexpected response code %s' % (response,)
 
2303
        return remote.RemoteBzrDir(transport)
 
2304
 
 
2305
    def _open(self, transport):
 
2306
        return remote.RemoteBzrDir(transport)
 
2307
 
 
2308
    def __eq__(self, other):
 
2309
        if not isinstance(other, RemoteBzrDirFormat):
 
2310
            return False
 
2311
        return self.get_format_description() == other.get_format_description()
 
2312
 
 
2313
 
 
2314
BzrDirFormat.register_control_server_format(RemoteBzrDirFormat)
 
2315
 
 
2316
 
 
2317
class BzrDirFormatInfo(object):
 
2318
 
 
2319
    def __init__(self, native, deprecated, hidden, experimental):
 
2320
        self.deprecated = deprecated
 
2321
        self.native = native
 
2322
        self.hidden = hidden
 
2323
        self.experimental = experimental
 
2324
 
 
2325
 
 
2326
class BzrDirFormatRegistry(registry.Registry):
 
2327
    """Registry of user-selectable BzrDir subformats.
 
2328
    
 
2329
    Differs from BzrDirFormat._control_formats in that it provides sub-formats,
 
2330
    e.g. BzrDirMeta1 with weave repository.  Also, it's more user-oriented.
 
2331
    """
 
2332
 
 
2333
    def register_metadir(self, key,
 
2334
             repository_format, help, native=True, deprecated=False,
 
2335
             branch_format=None,
 
2336
             tree_format=None,
 
2337
             hidden=False,
 
2338
             experimental=False):
 
2339
        """Register a metadir subformat.
 
2340
 
 
2341
        These all use a BzrDirMetaFormat1 bzrdir, but can be parameterized
 
2342
        by the Repository format.
 
2343
 
 
2344
        :param repository_format: The fully-qualified repository format class
 
2345
            name as a string.
 
2346
        :param branch_format: Fully-qualified branch format class name as
 
2347
            a string.
 
2348
        :param tree_format: Fully-qualified tree format class name as
 
2349
            a string.
 
2350
        """
 
2351
        # This should be expanded to support setting WorkingTree and Branch
 
2352
        # formats, once BzrDirMetaFormat1 supports that.
 
2353
        def _load(full_name):
 
2354
            mod_name, factory_name = full_name.rsplit('.', 1)
 
2355
            try:
 
2356
                mod = __import__(mod_name, globals(), locals(),
 
2357
                        [factory_name])
 
2358
            except ImportError, e:
 
2359
                raise ImportError('failed to load %s: %s' % (full_name, e))
 
2360
            try:
 
2361
                factory = getattr(mod, factory_name)
 
2362
            except AttributeError:
 
2363
                raise AttributeError('no factory %s in module %r'
 
2364
                    % (full_name, mod))
 
2365
            return factory()
 
2366
 
 
2367
        def helper():
 
2368
            bd = BzrDirMetaFormat1()
 
2369
            if branch_format is not None:
 
2370
                bd.set_branch_format(_load(branch_format))
 
2371
            if tree_format is not None:
 
2372
                bd.workingtree_format = _load(tree_format)
 
2373
            if repository_format is not None:
 
2374
                bd.repository_format = _load(repository_format)
 
2375
            return bd
 
2376
        self.register(key, helper, help, native, deprecated, hidden,
 
2377
            experimental)
 
2378
 
 
2379
    def register(self, key, factory, help, native=True, deprecated=False,
 
2380
                 hidden=False, experimental=False):
 
2381
        """Register a BzrDirFormat factory.
 
2382
        
 
2383
        The factory must be a callable that takes one parameter: the key.
 
2384
        It must produce an instance of the BzrDirFormat when called.
 
2385
 
 
2386
        This function mainly exists to prevent the info object from being
 
2387
        supplied directly.
 
2388
        """
 
2389
        registry.Registry.register(self, key, factory, help, 
 
2390
            BzrDirFormatInfo(native, deprecated, hidden, experimental))
 
2391
 
 
2392
    def register_lazy(self, key, module_name, member_name, help, native=True,
 
2393
                      deprecated=False, hidden=False, experimental=False):
 
2394
        registry.Registry.register_lazy(self, key, module_name, member_name, 
 
2395
            help, BzrDirFormatInfo(native, deprecated, hidden, experimental))
 
2396
 
 
2397
    def set_default(self, key):
 
2398
        """Set the 'default' key to be a clone of the supplied key.
 
2399
        
 
2400
        This method must be called once and only once.
 
2401
        """
 
2402
        registry.Registry.register(self, 'default', self.get(key), 
 
2403
            self.get_help(key), info=self.get_info(key))
 
2404
 
 
2405
    def set_default_repository(self, key):
 
2406
        """Set the FormatRegistry default and Repository default.
 
2407
        
 
2408
        This is a transitional method while Repository.set_default_format
 
2409
        is deprecated.
 
2410
        """
 
2411
        if 'default' in self:
 
2412
            self.remove('default')
 
2413
        self.set_default(key)
 
2414
        format = self.get('default')()
 
2415
        assert isinstance(format, BzrDirMetaFormat1)
 
2416
 
 
2417
    def make_bzrdir(self, key):
 
2418
        return self.get(key)()
 
2419
 
 
2420
    def help_topic(self, topic):
 
2421
        output = textwrap.dedent("""\
 
2422
            These formats can be used for creating branches, working trees, and
 
2423
            repositories.
 
2424
 
 
2425
            """)
 
2426
        default_realkey = None
 
2427
        default_help = self.get_help('default')
 
2428
        help_pairs = []
 
2429
        for key in self.keys():
 
2430
            if key == 'default':
 
2431
                continue
 
2432
            help = self.get_help(key)
 
2433
            if help == default_help:
 
2434
                default_realkey = key
 
2435
            else:
 
2436
                help_pairs.append((key, help))
 
2437
 
 
2438
        def wrapped(key, help, info):
 
2439
            if info.native:
 
2440
                help = '(native) ' + help
 
2441
            return ':%s:\n%s\n\n' % (key, 
 
2442
                    textwrap.fill(help, initial_indent='    ', 
 
2443
                    subsequent_indent='    '))
 
2444
        if default_realkey is not None:
 
2445
            output += wrapped(default_realkey, '(default) %s' % default_help,
 
2446
                              self.get_info('default'))
 
2447
        deprecated_pairs = []
 
2448
        experimental_pairs = []
 
2449
        for key, help in help_pairs:
 
2450
            info = self.get_info(key)
 
2451
            if info.hidden:
 
2452
                continue
 
2453
            elif info.deprecated:
 
2454
                deprecated_pairs.append((key, help))
 
2455
            elif info.experimental:
 
2456
                experimental_pairs.append((key, help))
 
2457
            else:
 
2458
                output += wrapped(key, help, info)
 
2459
        if len(experimental_pairs) > 0:
 
2460
            output += "Experimental formats are shown below.\n\n"
 
2461
            for key, help in experimental_pairs:
 
2462
                info = self.get_info(key)
 
2463
                output += wrapped(key, help, info)
 
2464
        if len(deprecated_pairs) > 0:
 
2465
            output += "Deprecated formats are shown below.\n\n"
 
2466
            for key, help in deprecated_pairs:
 
2467
                info = self.get_info(key)
 
2468
                output += wrapped(key, help, info)
 
2469
 
 
2470
        return output
 
2471
 
 
2472
 
 
2473
format_registry = BzrDirFormatRegistry()
 
2474
format_registry.register('weave', BzrDirFormat6,
 
2475
    'Pre-0.8 format.  Slower than knit and does not'
 
2476
    ' support checkouts or shared repositories.',
 
2477
    deprecated=True)
 
2478
format_registry.register_metadir('knit',
 
2479
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
 
2480
    'Format using knits.  Recommended for interoperation with bzr <= 0.14.',
 
2481
    branch_format='bzrlib.branch.BzrBranchFormat5',
 
2482
    tree_format='bzrlib.workingtree.WorkingTreeFormat3')
 
2483
format_registry.register_metadir('metaweave',
 
2484
    'bzrlib.repofmt.weaverepo.RepositoryFormat7',
 
2485
    'Transitional format in 0.8.  Slower than knit.',
 
2486
    branch_format='bzrlib.branch.BzrBranchFormat5',
 
2487
    tree_format='bzrlib.workingtree.WorkingTreeFormat3',
 
2488
    deprecated=True)
 
2489
format_registry.register_metadir('dirstate',
 
2490
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
 
2491
    help='New in 0.15: Fast local operations. Compatible with bzr 0.8 and '
 
2492
        'above when accessed over the network.',
 
2493
    branch_format='bzrlib.branch.BzrBranchFormat5',
 
2494
    # this uses bzrlib.workingtree.WorkingTreeFormat4 because importing
 
2495
    # directly from workingtree_4 triggers a circular import.
 
2496
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2497
    )
 
2498
format_registry.register_metadir('dirstate-tags',
 
2499
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit1',
 
2500
    help='New in 0.15: Fast local operations and improved scaling for '
 
2501
        'network operations. Additionally adds support for tags.'
 
2502
        ' Incompatible with bzr < 0.15.',
 
2503
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2504
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2505
    )
 
2506
format_registry.register_metadir('rich-root',
 
2507
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit4',
 
2508
    help='New in 1.0.  Better handling of tree roots.  Incompatible with'
 
2509
        ' bzr < 1.0',
 
2510
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2511
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2512
    hidden=False,
 
2513
    )
 
2514
format_registry.register_metadir('dirstate-with-subtree',
 
2515
    'bzrlib.repofmt.knitrepo.RepositoryFormatKnit3',
 
2516
    help='New in 0.15: Fast local operations and improved scaling for '
 
2517
        'network operations. Additionally adds support for versioning nested '
 
2518
        'bzr branches. Incompatible with bzr < 0.15.',
 
2519
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2520
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2521
    hidden=True,
 
2522
    )
 
2523
format_registry.register_metadir('pack-0.92',
 
2524
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack1',
 
2525
    help='New in 0.92: Pack-based format with data compatible with '
 
2526
        'dirstate-tags format repositories. Interoperates with '
 
2527
        'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
 
2528
        'Previously called knitpack-experimental.  '
 
2529
        'For more information, see '
 
2530
        'http://doc.bazaar-vcs.org/latest/developers/packrepo.html.',
 
2531
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2532
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2533
    experimental=True,
 
2534
    )
 
2535
format_registry.register_metadir('pack-0.92-subtree',
 
2536
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack3',
 
2537
    help='New in 0.92: Pack-based format with data compatible with '
 
2538
        'dirstate-with-subtree format repositories. Interoperates with '
 
2539
        'bzr repositories before 0.92 but cannot be read by bzr < 0.92. '
 
2540
        'Previously called knitpack-experimental.  '
 
2541
        'For more information, see '
 
2542
        'http://doc.bazaar-vcs.org/latest/developers/packrepo.html.',
 
2543
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2544
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2545
    hidden=True,
 
2546
    experimental=True,
 
2547
    )
 
2548
format_registry.register_metadir('rich-root-pack',
 
2549
    'bzrlib.repofmt.pack_repo.RepositoryFormatKnitPack4',
 
2550
    help='New in 1.0: Pack-based format with data compatible with '
 
2551
        'rich-root format repositories. Interoperates with '
 
2552
        'bzr repositories before 0.92 but cannot be read by bzr < 1.0. '
 
2553
        'NOTE: This format is experimental. Before using it, please read '
 
2554
        'http://doc.bazaar-vcs.org/latest/developers/knitpack.html.',
 
2555
    branch_format='bzrlib.branch.BzrBranchFormat6',
 
2556
    tree_format='bzrlib.workingtree.WorkingTreeFormat4',
 
2557
    hidden=False,
 
2558
    experimental=True,
 
2559
    )
 
2560
format_registry.set_default('dirstate-tags')