61
def validate_token(self, token):
65
54
class GitLockableFiles(lockable_files.LockableFiles):
66
55
"""Git specific lockable files abstraction."""
68
def __init__(self, transport, lock):
57
def __init__(self, lock):
70
59
self._transaction = None
71
60
self._lock_mode = None
72
self._transport = transport
73
61
self._lock_count = 0
76
64
class GitDir(bzrdir.BzrDir):
77
65
"""An adapter to the '.git' dir used by git."""
79
def is_supported(self):
82
def cloning_metadir(self, stacked=False):
83
return get_rich_root_format()
86
class LocalGitDir(GitDir):
87
"""An adapter to the '.git' dir used by git."""
89
_gitrepository_class = repository.LocalGitRepository
67
_gitrepository_class = repository.GitRepository
91
69
def __init__(self, transport, lockfiles, gitrepo, format):
92
70
self._format = format
101
79
def get_branch_transport(self, branch_format):
102
80
if branch_format is None:
103
81
return self.transport
104
if isinstance(branch_format, LocalGitBzrDirFormat):
82
if isinstance(branch_format, GitBzrDirFormat):
105
83
return self.transport
106
84
raise errors.bzr_errors.IncompatibleFormat(branch_format, self._format)
108
86
get_repository_transport = get_branch_transport
109
87
get_workingtree_transport = get_branch_transport
89
def is_supported(self):
111
92
def open_branch(self, ignored=None):
112
93
"""'create' a branch for this dir."""
113
94
repo = self.open_repository()
114
return branch.LocalGitBranch(self, repo, "HEAD", repo._git.head(),
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)
117
102
def open_repository(self, shared=False):
118
103
"""'open' a repository for this dir."""
119
104
return self._gitrepository_class(self, self._lockfiles)
121
106
def open_workingtree(self, recommend_upgrade=True):
122
loc = urlutils.unescape_for_display(self.root_transport.base, 'ascii')
123
raise errors.bzr_errors.NoWorkingTree(loc)
124
if (not self._git.bare and
125
os.path.exists(os.path.join(self._git.controldir(), "index"))):
108
loc = urlutils.unescape_for_display(self.root_transport.base, 'ascii')
109
raise errors.bzr_errors.NoWorkingTree(loc)
126
111
return workingtree.GitWorkingTree(self, self.open_repository(),
127
112
self.open_branch())
129
def create_repository(self, shared=False):
130
return self.open_repository()
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)