49
def validate_token(self, token):
56
48
class GitLockableFiles(lockable_files.LockableFiles):
57
49
"""Git specific lockable files abstraction."""
59
def __init__(self, transport, lock):
51
def __init__(self, lock):
61
53
self._transaction = None
62
54
self._lock_mode = None
63
self._transport = transport
64
if LockWarner is None:
68
self._lock_warner = LockWarner(repr(self))
71
58
class GitDir(bzrdir.BzrDir):
72
59
"""An adapter to the '.git' dir used by git."""
74
def is_supported(self):
77
def cloning_metadir(self, stacked=False):
78
return get_rich_root_format(stacked)
81
class LocalGitDir(GitDir):
82
"""An adapter to the '.git' dir used by git."""
84
def _get_gitrepository_class(self):
85
from bzrlib.plugins.git.repository import LocalGitRepository
86
return LocalGitRepository
88
_gitrepository_class = property(_get_gitrepository_class)
90
def __init__(self, transport, lockfiles, gitrepo, format):
61
def __init__(self, transport, lockfiles, format):
91
62
self._format = format
92
63
self.root_transport = transport
95
self.transport = transport
97
self.transport = transport.clone('.git')
64
self.transport = transport.clone('.git')
98
65
self._lockfiles = lockfiles
99
self._mode_check_done = None
101
def is_control_filename(self, filename):
102
return filename == '.git' or filename.startswith('.git/')
104
67
def get_branch_transport(self, branch_format):
105
68
if branch_format is None:
106
69
return self.transport
107
if isinstance(branch_format, LocalGitBzrDirFormat):
70
if isinstance(branch_format, GitBzrDirFormat):
108
71
return self.transport
109
raise bzr_errors.IncompatibleFormat(branch_format, self._format)
72
raise errors.bzr_errors.IncompatibleFormat(branch_format, self._format)
111
74
get_repository_transport = get_branch_transport
112
75
get_workingtree_transport = get_branch_transport
114
def open_branch(self, ignore_fallbacks=None):
115
"""'create' a branch for this dir."""
116
repo = self.open_repository()
117
from bzrlib.plugins.git.branch import LocalGitBranch
118
return LocalGitBranch(self, repo, "HEAD", self._lockfiles)
77
def is_supported(self):
80
def open_branch(self, ignored=None):
81
"""'crate' a branch for this dir."""
82
return git_branch.GitBranch(self, self._lockfiles)
120
84
def open_repository(self, shared=False):
121
85
"""'open' a repository for this dir."""
122
return self._gitrepository_class(self, self._lockfiles)
86
return git_repository.GitRepository(self, self._lockfiles)
124
def open_workingtree(self, recommend_upgrade=True):
125
if not self._git.bare and self._git.has_index():
126
from bzrlib.plugins.git.workingtree import GitWorkingTree
127
return GitWorkingTree(self, self.open_repository(),
88
def open_workingtree(self):
129
89
loc = urlutils.unescape_for_display(self.root_transport.base, 'ascii')
130
raise bzr_errors.NoWorkingTree(loc)
132
def create_repository(self, shared=False):
133
return self.open_repository()
135
def create_branch(self):
136
return self.open_branch()
138
def backup_bzrdir(self):
140
self.root_transport.copy_tree(".git", ".git.backup")
141
return (self.root_transport.abspath(".git"),
142
self.root_transport.abspath(".git.backup"))
144
raise bzr_errors.BzrError("Unable to backup bare repositories")
146
def create_workingtree(self, revision_id=None, from_branch=None,
147
accelerator_tree=None, hardlink=False):
149
raise bzr_errors.BzrError("Can't create working tree in a bare repo")
150
from dulwich.index import write_index
151
from dulwich.pack import SHA1Writer
152
f = open(self.transport.local_abspath("index"), 'w+')
90
raise errors.bzr_errors.NoWorkingTree(loc)
93
class GitBzrDirFormat(bzrdir.BzrDirFormat):
94
"""The .git directory control format."""
97
def _known_formats(self):
98
return set([GitBzrDirFormat()])
100
def open(self, transport, _create=False, _found=None):
101
"""Open this directory.
103
:param _create: create the git dir on the fly. private to GitDirFormat.
105
# we dont grok readonly - git isn't integrated with transport.
107
if url.startswith('readonly+'):
108
url = url[len('readonly+'):]
109
path = urlutils.local_path_from_url(url)
110
if not transport.has('.git'):
111
raise errors.bzr_errors.NotBranchError(path=transport.base)
112
lockfiles = GitLockableFiles(GitLock())
113
return GitDir(transport, lockfiles, self)
116
def probe_transport(klass, transport):
117
"""Our format is present if the transport ends in '.not/'."""
118
# little ugly, but works
120
# delegate to the main opening code. This pays a double rtt cost at the
121
# moment, so perhaps we want probe_transport to return the opened thing
122
# rather than an openener ? or we could return a curried thing with the
123
# dir to open already instantiated ? Needs more thought.
158
return self.open_workingtree()
125
format.open(transport)
128
raise errors.bzr_errors.NotBranchError(path=transport.base)
129
raise errors.bzr_errors.NotBranchError(path=transport.base)
132
bzrdir.BzrDirFormat.register_control_format(GitBzrDirFormat)