44
46
# clients that don't anticipate errors from this method.
47
default_format = BzrDirFormat.get_default_format()
48
real_bzrdir = default_format.open(t, _found=True)
49
bzr_prober = BzrProber()
50
real_bzrdir._format.probe_transport(t)
51
bzr_prober.probe_transport(t)
51
52
except (errors.NotBranchError, errors.UnknownFormatError):
84
85
class SmartServerRequestBzrDir(SmartServerRequest):
86
87
def do(self, path, *args):
87
"""Open a BzrDir at path, and return self.do_bzrdir_request(*args)."""
88
"""Open a BzrDir at path, and return `self.do_bzrdir_request(*args)`."""
89
90
self._bzrdir = BzrDir.open_from_transport(
90
91
self.transport_from_client_path(path))
119
120
return '/'.join(segments)
123
class SmartServerBzrDirRequestDestroyBranch(SmartServerRequestBzrDir):
125
def do_bzrdir_request(self, name=None):
126
"""Destroy the branch with the specified name.
129
:return: On success, 'ok'.
132
self._bzrdir.destroy_branch(name)
133
except errors.NotBranchError, e:
134
return FailedSmartServerResponse(('nobranch',))
135
return SuccessfulSmartServerResponse(('ok',))
138
class SmartServerBzrDirRequestHasWorkingTree(SmartServerRequestBzrDir):
140
def do_bzrdir_request(self, name=None):
141
"""Check whether there is a working tree present.
145
:return: If there is a working tree present, 'yes'.
148
if self._bzrdir.has_workingtree():
149
return SuccessfulSmartServerResponse(('yes', ))
151
return SuccessfulSmartServerResponse(('no', ))
154
class SmartServerBzrDirRequestDestroyRepository(SmartServerRequestBzrDir):
156
def do_bzrdir_request(self, name=None):
157
"""Destroy the repository.
161
:return: On success, 'ok'.
164
self._bzrdir.destroy_repository()
165
except errors.NoRepositoryPresent, e:
166
return FailedSmartServerResponse(('norepository',))
167
return SuccessfulSmartServerResponse(('ok',))
122
170
class SmartServerBzrDirRequestCloningMetaDir(SmartServerRequestBzrDir):
124
172
def do_bzrdir_request(self, require_stacking):
148
196
control_format = self._bzrdir.cloning_metadir(
149
197
require_stacking=require_stacking)
150
198
control_name = control_format.network_name()
151
# XXX: There should be a method that tells us that the format does/does
152
# not have subformats.
153
if isinstance(control_format, BzrDirMetaFormat1):
199
if not control_format.fixed_components:
154
200
branch_name = ('branch',
155
201
control_format.get_branch_format().network_name())
156
202
repository_name = control_format.repository_format.network_name()
211
class SmartServerBzrDirRequestCheckoutMetaDir(SmartServerRequestBzrDir):
212
"""Get the format to use for checkouts.
216
:return: on success, a 3-tuple of network names for (control,
217
repository, branch) directories, where '' signifies "not present".
218
If this BzrDir contains a branch reference then this will fail with
219
BranchReference; clients should resolve branch references before
220
calling this RPC (they should not try to create a checkout of a
224
def do_bzrdir_request(self):
226
branch_ref = self._bzrdir.get_branch_reference()
227
except errors.NotBranchError:
229
if branch_ref is not None:
230
# The server shouldn't try to resolve references, and it quite
231
# possibly can't reach them anyway. The client needs to resolve
232
# the branch reference to determine the cloning_metadir.
233
return FailedSmartServerResponse(('BranchReference',))
234
control_format = self._bzrdir.checkout_metadir()
235
control_name = control_format.network_name()
236
if not control_format.fixed_components:
237
branch_name = control_format.get_branch_format().network_name()
238
repo_name = control_format.repository_format.network_name()
242
return SuccessfulSmartServerResponse(
243
(control_name, repo_name, branch_name))
165
246
class SmartServerRequestCreateBranch(SmartServerRequestBzrDir):
167
248
def do(self, path, network_name):
180
261
:param path: The path to the bzrdir.
181
262
:param network_name: The network name of the branch type to create.
182
:return: (ok, network_name)
263
:return: ('ok', branch_format, repo_path, rich_root, tree_ref,
264
external_lookup, repo_format)
184
266
bzrdir = BzrDir.open_from_transport(
185
267
self.transport_from_client_path(path))
429
511
# It is returned locked, but we need to do the lock to get the lock
432
repo_lock_token = repo.lock_write() or ''
514
repo_lock_token = repo.lock_write().repository_token or ''
433
515
if repo_lock_token:
434
516
repo.leave_lock_in_place()