56
def validate_token(self, token):
60
54
class GitLockableFiles(lockable_files.LockableFiles):
61
55
"""Git specific lockable files abstraction."""
63
def __init__(self, transport, lock):
57
def __init__(self, lock):
65
59
self._transaction = None
66
60
self._lock_mode = None
67
61
self._lock_count = 0
68
self._transport = transport
71
64
class GitDir(bzrdir.BzrDir):
72
65
"""An adapter to the '.git' dir used by git."""
74
def is_supported(self):
77
def cloning_metadir(self, stacked=False):
79
return bzrlib.bzrdir.format_registry.make_bzrdir("pack-0.92")
81
return bzrlib.bzrdir.format_registry.make_bzrdir("1.6")
84
class LocalGitDir(GitDir):
85
"""An adapter to the '.git' dir used by git."""
87
_gitrepository_class = repository.LocalGitRepository
67
_gitrepository_class = repository.GitRepository
89
69
def __init__(self, transport, lockfiles, gitrepo, format):
90
70
self._format = format
99
79
def get_branch_transport(self, branch_format):
100
80
if branch_format is None:
101
81
return self.transport
102
if isinstance(branch_format, LocalGitBzrDirFormat):
82
if isinstance(branch_format, GitBzrDirFormat):
103
83
return self.transport
104
84
raise errors.bzr_errors.IncompatibleFormat(branch_format, self._format)
106
86
get_repository_transport = get_branch_transport
107
87
get_workingtree_transport = get_branch_transport
89
def is_supported(self):
109
92
def open_branch(self, ignored=None):
110
93
"""'create' a branch for this dir."""
111
94
repo = self.open_repository()
112
return branch.LocalGitBranch(self, repo, "HEAD", repo._git.head(), self._lockfiles)
95
if repo._git.heads == []:
98
head = repo._git.heads[0].commit.id
99
return branch.GitBranch(self, repo, head,
100
self.root_transport.base, self._lockfiles)
114
102
def open_repository(self, shared=False):
115
103
"""'open' a repository for this dir."""
123
111
return workingtree.GitWorkingTree(self, self.open_repository(),
124
112
self.open_branch())
126
def create_repository(self, shared=False):
127
return self.open_repository()
114
def cloning_metadir(self):
115
return bzrdir.BzrDirFormat.get_default_format()
130
118
class GitBzrDirFormat(bzrdir.BzrDirFormat):
131
_lock_class = TransportLock
133
def is_supported(self):
137
class LocalGitBzrDirFormat(GitBzrDirFormat):
138
119
"""The .git directory control format."""
140
_gitdir_class = LocalGitDir
121
_gitdir_class = GitDir
143
124
def _known_formats(self):
144
return set([LocalGitBzrDirFormat()])
125
return set([GitBzrDirFormat()])
146
127
def open(self, transport, _found=None):
147
128
"""Open this directory.
150
from bzrlib.plugins.git import git
151
131
# we dont grok readonly - git isn't integrated with transport.
152
132
url = transport.base
153
133
if url.startswith('readonly+'):
157
137
gitrepo = git.repo.Repo(transport.local_abspath("."))
158
138
except errors.bzr_errors.NotLocalUrl:
159
139
raise errors.bzr_errors.NotBranchError(path=transport.base)
160
lockfiles = GitLockableFiles(transport, GitLock())
140
lockfiles = GitLockableFiles(GitLock())
161
141
return self._gitdir_class(transport, lockfiles, gitrepo, self)
164
144
def probe_transport(klass, transport):
165
145
"""Our format is present if the transport ends in '.not/'."""
166
from bzrlib.plugins.git import git
167
146
# little ugly, but works
169
148
# delegate to the main opening code. This pays a double rtt cost at the
174
153
format.open(transport)
176
except git.errors.NotGitRepository, e:
177
raise errors.bzr_errors.NotBranchError(path=transport.base)
178
raise errors.bzr_errors.NotBranchError(path=transport.base)
180
def get_format_description(self):
181
return "Local Git Repository"
183
def get_format_string(self):
184
return "Local Git Repository"
186
def initialize_on_transport(self, transport):
187
from bzrlib.transport.local import LocalTransport
188
from bzrlib.plugins.git import git
190
if not isinstance(transport, LocalTransport):
191
raise NotImplementedError(self.initialize,
192
"Can't create Git Repositories/branches on "
193
"non-local transports")
195
git.repo.Repo.create(transport.local_abspath("."))
196
return self.open(transport)
198
def is_supported(self):
202
class RemoteGitBzrDirFormat(GitBzrDirFormat):
203
"""The .git directory control format."""
206
def _known_formats(self):
207
return set([RemoteGitBzrDirFormat()])
209
def open(self, transport, _found=None):
210
"""Open this directory.
213
from bzrlib.plugins.git.remote import RemoteGitDir, GitSmartTransport
214
if not isinstance(transport, GitSmartTransport):
215
raise errors.bzr_errors.NotBranchError(transport.base)
216
# we dont grok readonly - git isn't integrated with transport.
218
if url.startswith('readonly+'):
219
url = url[len('readonly+'):]
221
lockfiles = GitLockableFiles(transport, GitLock())
222
return RemoteGitDir(transport, lockfiles, self)
225
def probe_transport(klass, transport):
226
"""Our format is present if the transport ends in '.not/'."""
227
# little ugly, but works
229
from bzrlib.plugins.git.remote import GitSmartTransport
230
if not isinstance(transport, GitSmartTransport):
231
raise errors.bzr_errors.NotBranchError(transport.base)
232
# The only way to know a path exists and contains a valid repository
233
# is to do a request against it:
235
transport.fetch_pack(lambda x: [], None, lambda x: None,
236
lambda x: mutter("git: %s" % x))
237
except GitProtocolException, e:
238
raise errors.bzr_errors.NotBranchError(path=transport.base)
241
raise errors.bzr_errors.NotBranchError(path=transport.base)
243
def get_format_description(self):
244
return "Remote Git Repository"
246
def get_format_string(self):
247
return "Remote Git Repository"
249
def initialize_on_transport(self, transport):
250
raise errors.bzr_errors.UninitializableFormat(self)
156
raise errors.bzr_errors.NotBranchError(path=transport.base)
157
raise errors.bzr_errors.NotBranchError(path=transport.base)
159
def get_format_description(self):
160
return "Local Git Repository"
163
bzrdir.BzrDirFormat.register_control_format(GitBzrDirFormat)