96
114
self.transport = transport.clone('.git')
97
115
self._lockfiles = lockfiles
99
def get_branch_transport(self, branch_format):
116
self._mode_check_done = None
118
def _branch_name_to_ref(self, name):
119
from bzrlib.plugins.git.refs import branch_name_to_ref
120
ref = branch_name_to_ref(name, None)
122
from dulwich.repo import SYMREF
123
refcontents = self._git.refs.read_ref(ref)
124
if refcontents.startswith(SYMREF):
125
ref = refcontents[len(SYMREF):]
128
def is_control_filename(self, filename):
129
return filename == '.git' or filename.startswith('.git/')
131
def get_branch_transport(self, branch_format, name=None):
100
132
if branch_format is None:
101
133
return self.transport
102
134
if isinstance(branch_format, LocalGitBzrDirFormat):
103
135
return self.transport
104
raise errors.bzr_errors.IncompatibleFormat(branch_format, self._format)
106
get_repository_transport = get_branch_transport
107
get_workingtree_transport = get_branch_transport
109
def open_branch(self, ignored=None):
136
raise bzr_errors.IncompatibleFormat(branch_format, self._format)
138
def get_repository_transport(self, format):
140
return self.transport
141
if isinstance(format, LocalGitBzrDirFormat):
142
return self.transport
143
raise bzr_errors.IncompatibleFormat(format, self._format)
145
def get_workingtree_transport(self, format):
147
return self.transport
148
if isinstance(format, LocalGitBzrDirFormat):
149
return self.transport
150
raise bzr_errors.IncompatibleFormat(format, self._format)
152
def _open_branch(self, name=None, ignore_fallbacks=None, unsupported=False):
110
153
"""'create' a branch for this dir."""
111
154
repo = self.open_repository()
112
return branch.LocalGitBranch(self, repo, "HEAD", repo._git.head(), self._lockfiles)
155
from bzrlib.plugins.git.branch import LocalGitBranch
156
return LocalGitBranch(self, repo, self._branch_name_to_ref(name),
159
def destroy_branch(self, name=None):
160
refname = self._branch_name_to_ref(name)
161
if not refname in self._git.refs:
162
raise bzr_errors.NotBranchError(self.root_transport.base,
164
del self._git.refs[refname]
166
def destroy_repository(self):
167
raise bzr_errors.UnsupportedOperation(self.destroy_repository, self)
169
def destroy_workingtree(self):
170
raise bzr_errors.UnsupportedOperation(self.destroy_workingtree, self)
172
def needs_format_conversion(self, format=None):
173
return not isinstance(self._format, format.__class__)
175
def list_branches(self):
177
for name in self._git.get_refs():
178
if name.startswith("refs/heads/"):
179
ret.append(self.open_branch(name=name))
114
182
def open_repository(self, shared=False):
115
183
"""'open' a repository for this dir."""
116
184
return self._gitrepository_class(self, self._lockfiles)
118
186
def open_workingtree(self, recommend_upgrade=True):
120
loc = urlutils.unescape_for_display(self.root_transport.base, 'ascii')
121
raise errors.bzr_errors.NoWorkingTree(loc)
123
return workingtree.GitWorkingTree(self, self.open_repository(),
187
if not self._git.bare:
188
from dulwich.errors import NoIndexPresent
189
repo = self.open_repository()
191
index = repo._git.open_index()
192
except NoIndexPresent:
195
from bzrlib.plugins.git.workingtree import GitWorkingTree
197
branch = self.open_branch()
198
except bzr_errors.NotBranchError:
201
return GitWorkingTree(self, repo, branch, index)
202
loc = urlutils.unescape_for_display(self.root_transport.base, 'ascii')
203
raise bzr_errors.NoWorkingTree(loc)
126
205
def create_repository(self, shared=False):
127
206
return self.open_repository()
130
class GitBzrDirFormat(bzrdir.BzrDirFormat):
131
_lock_class = TransportLock
133
def is_supported(self):
137
class LocalGitBzrDirFormat(GitBzrDirFormat):
138
"""The .git directory control format."""
140
_gitdir_class = LocalGitDir
143
def _known_formats(self):
144
return set([LocalGitBzrDirFormat()])
146
def open(self, transport, _found=None):
147
"""Open this directory.
150
from bzrlib.plugins.git import git
151
# we dont grok readonly - git isn't integrated with transport.
153
if url.startswith('readonly+'):
154
url = url[len('readonly+'):]
157
gitrepo = git.repo.Repo(transport.local_abspath("."))
158
except errors.bzr_errors.NotLocalUrl:
159
raise errors.bzr_errors.NotBranchError(path=transport.base)
160
lockfiles = GitLockableFiles(transport, GitLock())
161
return self._gitdir_class(transport, lockfiles, gitrepo, self)
164
def probe_transport(klass, transport):
165
"""Our format is present if the transport ends in '.not/'."""
166
from bzrlib.plugins.git import git
167
# little ugly, but works
169
# delegate to the main opening code. This pays a double rtt cost at the
170
# moment, so perhaps we want probe_transport to return the opened thing
171
# rather than an openener ? or we could return a curried thing with the
172
# dir to open already instantiated ? Needs more thought.
174
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)
208
def create_branch(self, name=None):
209
refname = self._branch_name_to_ref(name)
210
from dulwich.protocol import ZERO_SHA
211
self._git.refs[refname or "HEAD"] = ZERO_SHA
212
return self.open_branch(name)
214
def backup_bzrdir(self):
216
self.root_transport.copy_tree(".git", ".git.backup")
217
return (self.root_transport.abspath(".git"),
218
self.root_transport.abspath(".git.backup"))
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)
220
raise bzr_errors.BzrError("Unable to backup bare repositories")
222
def create_workingtree(self, revision_id=None, from_branch=None,
223
accelerator_tree=None, hardlink=False):
225
raise bzr_errors.BzrError("Can't create working tree in a bare repo")
226
from dulwich.index import write_index
227
from dulwich.pack import SHA1Writer
228
f = open(self.transport.local_abspath("index"), 'w+')
234
return self.open_workingtree()