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