/brz/remove-bazaar

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

« back to all changes in this revision

Viewing changes to bzrlib/bzrdir.py

Fix formatting, remove catch-all for exceptions when opening local repositories.

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/packrepo.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('pack-0.92')