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 remote.py
- browse files at revision 0.200.1
- compare with another revision
- download diff
- download tarball
- view history from revision 0.200.1
- Committer: Robert Collins
- Date: 2006-07-15 12:25:27 UTC
- mto: (0.312.1 master) (6883.23.1 bundle-git)
- mto: This revision was merged to the branch mainline in revision 6960.
- Revision ID: robertc@robertcollins.net-20060715122527-6c66f16cfa459341
Commit initial content.
- files added:
- INSTALL
- files removed:
- HACKING
- notes
- tests
- files modified:
- .bzrignore
added
removed
remote.py
1
# Copyright (C) 2007-2009 Jelmer Vernooij <jelmer@samba.org>
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
import bzrlib
18
from bzrlib import (
19
branch,
20
tag,
21
ui,
22
urlutils,
23
)
24
from bzrlib.errors import (
25
BzrError,
26
InvalidRevisionId,
27
NoSuchFile,
28
NoSuchRevision,
29
NotLocalUrl,
30
)
31
from bzrlib.trace import (
32
info,
33
)
34
from bzrlib.transport import (
35
Transport,
36
)
37
38
from bzrlib.plugins.git import (
39
lazy_check_versions,
40
)
41
lazy_check_versions()
42
43
from bzrlib.plugins.git.branch import (
44
GitBranch,
45
extract_tags,
46
)
47
from bzrlib.plugins.git.errors import (
48
GitSmartRemoteNotSupported,
49
NoSuchRef,
50
)
51
from bzrlib.plugins.git.dir import (
52
GitDir,
53
)
54
from bzrlib.plugins.git.mapping import (
55
mapping_registry,
56
)
57
from bzrlib.plugins.git.repository import (
58
GitRepositoryFormat,
59
GitRepository,
60
)
61
62
import dulwich as git
63
from dulwich.errors import (
64
GitProtocolError,
65
)
66
from dulwich.pack import (
67
Pack,
68
PackData,
69
)
70
import os
71
import tempfile
72
import urllib
73
import urlparse
74
75
try:
76
from dulwich.pack import load_pack_index
77
except ImportError:
78
from dulwich.pack import PackIndex as load_pack_index
79
80
81
# Don't run any tests on GitSmartTransport as it is not intended to be
82
# a full implementation of Transport
83
def get_test_permutations():
84
return []
85
86
87
class GitSmartTransport(Transport):
88
89
def __init__(self, url, _client=None):
90
Transport.__init__(self, url)
91
(scheme, _, loc, _, _) = urlparse.urlsplit(url)
92
hostport, self._path = urllib.splithost(loc)
93
(self._username, hostport) = urllib.splituser(hostport)
94
(self._host, self._port) = urllib.splitnport(hostport, None)
95
self._client = _client
96
97
def external_url(self):
98
return self.base
99
100
def has(self, relpath):
101
return False
102
103
def _get_client(self):
104
raise NotImplementedError(self._get_client)
105
106
def _get_path(self):
107
return self._path
108
109
def fetch_pack(self, determine_wants, graph_walker, pack_data, progress=None):
110
if progress is None:
111
def progress(text):
112
info("git: %s" % text)
113
client = self._get_client()
114
try:
115
return client.fetch_pack(self._get_path(), determine_wants,
116
graph_walker, pack_data, progress)
117
except GitProtocolError, e:
118
raise BzrError(e)
119
120
def send_pack(self, get_changed_refs, generate_pack_contents):
121
client = self._get_client()
122
try:
123
return client.send_pack(self._get_path(), get_changed_refs,
124
generate_pack_contents)
125
except GitProtocolError, e:
126
raise BzrError(e)
127
128
def get(self, path):
129
raise NoSuchFile(path)
130
131
def abspath(self, relpath):
132
return urlutils.join(self.base, relpath)
133
134
def clone(self, offset=None):
135
"""See Transport.clone()."""
136
if offset is None:
137
newurl = self.base
138
else:
139
newurl = urlutils.join(self.base, offset)
140
141
return self.__class__(newurl, self._client)
142
143
144
class TCPGitSmartTransport(GitSmartTransport):
145
146
_scheme = 'git'
147
148
def _get_client(self):
149
if self._client is not None:
150
ret = self._client
151
self._client = None
152
return ret
153
return git.client.TCPGitClient(self._host, self._port, thin_packs=False,
154
report_activity=self._report_activity)
155
156
157
class SSHGitSmartTransport(GitSmartTransport):
158
159
_scheme = 'git+ssh'
160
161
def _get_path(self):
162
if self._path.startswith("/~/"):
163
return self._path[3:]
164
return self._path
165
166
def _get_client(self):
167
if self._client is not None:
168
ret = self._client
169
self._client = None
170
return ret
171
return git.client.SSHGitClient(self._host, self._port, self._username,
172
thin_packs=False, report_activity=self._report_activity)
173
174
175
class RemoteGitDir(GitDir):
176
177
def __init__(self, transport, lockfiles, format):
178
self._format = format
179
self.root_transport = transport
180
self.transport = transport
181
self._lockfiles = lockfiles
182
self._mode_check_done = None
183
184
def open_repository(self):
185
return RemoteGitRepository(self, self._lockfiles)
186
187
def open_branch(self, ignore_fallbacks=False):
188
repo = self.open_repository()
189
# TODO: Support for multiple branches in one bzrdir in bzrlib!
190
return RemoteGitBranch(self, repo, "HEAD", self._lockfiles)
191
192
def open_workingtree(self):
193
raise NotLocalUrl(self.transport.base)
194
195
196
class EmptyObjectStoreIterator(dict):
197
198
def iterobjects(self):
199
return []
200
201
202
class TemporaryPackIterator(Pack):
203
204
def __init__(self, path, resolve_ext_ref):
205
super(TemporaryPackIterator, self).__init__(path)
206
self.resolve_ext_ref = resolve_ext_ref
207
208
@property
209
def index(self):
210
if self._idx is None:
211
pb = ui.ui_factory.nested_progress_bar()
212
try:
213
def report_progress(cur, total):
214
pb.update("generating index", cur, total)
215
self.data.create_index(self._idx_path, self.resolve_ext_ref,
216
progress=report_progress)
217
finally:
218
pb.finished()
219
self._idx = load_pack_index(self._idx_path)
220
return self._idx
221
222
def __del__(self):
223
os.remove(self._data_path)
224
os.remove(self._idx_path)
225
226
227
class RemoteGitRepository(GitRepository):
228
229
def __init__(self, gitdir, lockfiles):
230
GitRepository.__init__(self, gitdir, lockfiles)
231
self._refs = None
232
233
@property
234
def inventories(self):
235
raise GitSmartRemoteNotSupported()
236
237
@property
238
def revisions(self):
239
raise GitSmartRemoteNotSupported()
240
241
@property
242
def texts(self):
243
raise GitSmartRemoteNotSupported()
244
245
def get_refs(self):
246
if self._refs is not None:
247
return self._refs
248
self._refs = self.bzrdir.root_transport.fetch_pack(lambda x: [], None,
249
lambda x: None, lambda x: mutter("git: %s" % x))
250
return self._refs
251
252
def fetch_pack(self, determine_wants, graph_walker, pack_data,
253
progress=None):
254
return self._transport.fetch_pack(determine_wants, graph_walker,
255
pack_data, progress)
256
257
def send_pack(self, get_changed_refs, generate_pack_contents):
258
return self._transport.send_pack(get_changed_refs, generate_pack_contents)
259
260
def fetch_objects(self, determine_wants, graph_walker, resolve_ext_ref, progress=None):
261
fd, path = tempfile.mkstemp(suffix=".pack")
262
self.fetch_pack(determine_wants, graph_walker, lambda x: os.write(fd, x), progress)
263
os.close(fd)
264
if os.path.getsize(path) == 0:
265
return EmptyObjectStoreIterator()
266
return TemporaryPackIterator(path[:-len(".pack")], resolve_ext_ref)
267
268
def lookup_git_revid(self, bzr_revid):
269
# This won't work for any round-tripped bzr revisions, but it's a start..
270
try:
271
return mapping_registry.revision_id_bzr_to_foreign(bzr_revid)
272
except InvalidRevisionId:
273
raise NoSuchRevision(self, bzr_revid)
274
275
276
class RemoteGitTagDict(tag.BasicTags):
277
278
def __init__(self, branch):
279
self.branch = branch
280
self.repository = branch.repository
281
282
def get_tag_dict(self):
283
return extract_tags(self.repository.get_refs(), self.branch.mapping)
284
285
def set_tag(self, name, revid):
286
# FIXME: Not supported yet, should do a push of a new ref
287
raise NotImplementedError(self.set_tag)
288
289
290
class RemoteGitBranch(GitBranch):
291
292
def __init__(self, bzrdir, repository, name, lockfiles):
293
self._ref = None
294
super(RemoteGitBranch, self).__init__(bzrdir, repository, name,
295
lockfiles)
296
297
def revision_history(self):
298
raise GitSmartRemoteNotSupported()
299
300
def last_revision(self):
301
return self.mapping.revision_id_foreign_to_bzr(self.head)
302
303
@property
304
def head(self):
305
if self._ref is not None:
306
return self._ref
307
heads = self.repository.get_refs()
308
if not self.name in heads:
309
raise NoSuchRef(name)
310
self._ref = heads[self.name]
311
return self._ref
312
313
def _synchronize_history(self, destination, revision_id):
314
"""See Branch._synchronize_history()."""
315
destination.generate_revision_history(self.last_revision())
316
317
def get_push_location(self):
318
return None
319
320
def set_push_location(self, url):
321
pass
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0