55
def validate_token(self, token):
54
59
class GitLockableFiles(lockable_files.LockableFiles):
55
60
"""Git specific lockable files abstraction."""
57
def __init__(self, lock):
62
def __init__(self, transport, lock):
59
64
self._transaction = None
60
65
self._lock_mode = None
66
self._transport = transport
67
if LockWarner is None:
71
self._lock_warner = LockWarner(repr(self))
64
74
class GitDir(bzrdir.BzrDir):
65
75
"""An adapter to the '.git' dir used by git."""
67
_gitrepository_class = git_repository.GitRepository
77
def is_supported(self):
80
def cloning_metadir(self, stacked=False):
81
return get_rich_root_format(stacked)
84
class LocalGitDir(GitDir):
85
"""An adapter to the '.git' dir used by git."""
87
_gitrepository_class = repository.LocalGitRepository
69
89
def __init__(self, transport, lockfiles, gitrepo, format):
70
90
self._format = format
76
96
self.transport = transport.clone('.git')
77
97
self._lockfiles = lockfiles
98
self._mode_check_done = None
100
def is_control_filename(self, filename):
101
return filename == '.git' or filename.startswith('.git/')
79
103
def get_branch_transport(self, branch_format):
80
104
if branch_format is None:
81
105
return self.transport
82
if isinstance(branch_format, GitBzrDirFormat):
106
if isinstance(branch_format, LocalGitBzrDirFormat):
83
107
return self.transport
84
108
raise errors.bzr_errors.IncompatibleFormat(branch_format, self._format)
86
110
get_repository_transport = get_branch_transport
87
111
get_workingtree_transport = get_branch_transport
89
def is_supported(self):
92
def open_branch(self, ignored=None):
113
def open_branch(self, ignore_fallbacks=None):
93
114
"""'create' a branch for this dir."""
94
115
repo = self.open_repository()
95
if repo._git.heads == []:
98
head = repo._git.heads[0].commit.id
99
return git_branch.GitBranch(self, repo, head,
100
self.root_transport.base, self._lockfiles)
116
return branch.LocalGitBranch(self, repo, "HEAD", self._lockfiles)
102
118
def open_repository(self, shared=False):
103
119
"""'open' a repository for this dir."""
104
120
return self._gitrepository_class(self, self._lockfiles)
106
122
def open_workingtree(self, recommend_upgrade=True):
108
loc = urlutils.unescape_for_display(self.root_transport.base, 'ascii')
109
raise errors.bzr_errors.NoWorkingTree(loc)
111
return git_workingtree.GitWorkingTree(self, self.open_repository(),
123
if not self._git.bare and self._git.has_index():
124
return workingtree.GitWorkingTree(self, self.open_repository(),
112
125
self.open_branch())
114
def cloning_metadir(self):
115
return bzrdir.BzrDirFormat.get_default_format()
118
class GitBzrDirFormat(bzrdir.BzrDirFormat):
119
"""The .git directory control format."""
121
_gitdir_class = GitDir
124
def _known_formats(self):
125
return set([GitBzrDirFormat()])
127
def open(self, transport, _found=None):
128
"""Open this directory.
131
# we dont grok readonly - git isn't integrated with transport.
133
if url.startswith('readonly+'):
134
url = url[len('readonly+'):]
137
gitrepo = git.repo.Repo(transport.local_abspath("."))
138
except errors.bzr_errors.NotLocalUrl:
139
raise errors.bzr_errors.NotBranchError(path=transport.base)
140
lockfiles = GitLockableFiles(GitLock())
141
return self._gitdir_class(transport, lockfiles, gitrepo, self)
144
def probe_transport(klass, transport):
145
"""Our format is present if the transport ends in '.not/'."""
146
# little ugly, but works
148
# delegate to the main opening code. This pays a double rtt cost at the
149
# moment, so perhaps we want probe_transport to return the opened thing
150
# rather than an openener ? or we could return a curried thing with the
151
# dir to open already instantiated ? Needs more thought.
153
format.open(transport)
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)
126
loc = urlutils.unescape_for_display(self.root_transport.base, 'ascii')
127
raise errors.bzr_errors.NoWorkingTree(loc)
129
def create_repository(self, shared=False):
130
return self.open_repository()
132
def create_branch(self):
133
return self.open_branch()
135
def backup_bzrdir(self):
137
self.root_transport.copy_tree(".git", ".git.backup")
138
return (self.root_transport.abspath(".git"),
139
self.root_transport.abspath(".git.backup"))
141
raise errors.bzr_errors.BzrError("Unable to backup bare repositories")
143
def create_workingtree(self, revision_id=None, from_branch=None,
144
accelerator_tree=None, hardlink=False):
146
raise errors.bzr_errors.BzrError("Can't create working tree in a bare repo")
147
from dulwich.index import write_index
148
write_index(self.root_transport.abspath(".git/index"), [])
149
return self.open_workingtree()