1
# Copyright (C) 2010 Jelmer Vernooij <jelmer@samba.org>
3
# This program is free software; you can redistribute it and/or modify
4
# it under the terms of the GNU General Public License as published by
5
# the Free Software Foundation; either version 2 of the License, or
6
# (at your option) any later version.
8
# This program is distributed in the hope that it will be useful,
9
# but WITHOUT ANY WARRANTY; without even the implied warranty of
10
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11
# GNU General Public License for more details.
13
# You should have received a copy of the GNU General Public License
14
# along with this program; if not, write to the Free Software
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
17
"""A Git repository implementation that uses a Bazaar transport."""
20
from dulwich.errors import (
24
from dulwich.objects import (
27
from dulwich.object_store import (
31
from dulwich.pack import (
38
from dulwich.repo import (
45
from bzrlib.errors import (
51
class TransportRepo(BaseRepo):
53
def __init__(self, transport):
54
self.transport = transport
56
if self.transport.has(".git/info/refs"):
58
self._controltransport = self.transport.clone('.git')
59
elif self.transport.has("info/refs"):
61
self._controltransport = self.transport
63
raise NotGitRepository(self.transport)
65
raise NotGitRepository(self.transport)
66
object_store = TransportObjectStore(
67
self._controltransport.clone(OBJECTDIR))
69
refs["HEAD"] = self._controltransport.get_bytes("HEAD").rstrip("\n")
70
refs.update(read_info_refs(self._controltransport.get('info/refs')))
71
super(TransportRepo, self).__init__(object_store,
72
DictRefsContainer(refs))
74
def get_named_file(self, path):
75
"""Get a file from the control dir with a specific name.
77
Although the filename should be interpreted as a filename relative to
78
the control dir in a disk-baked Repo, the object returned need not be
79
pointing to a file in that location.
81
:param path: The path to the file, relative to the control dir.
82
:return: An open file object, or None if the file does not exist.
85
return self._controltransport.get(path.lstrip('/'))
90
"""Open the index for this repository."""
91
raise NoIndexPresent()
94
return "<TransportRepo for %r>" % self.transport
97
class TransportObjectStore(PackBasedObjectStore):
98
"""Git-style object store that exists on disk."""
100
def __init__(self, transport):
101
"""Open an object store.
103
:param transport: Transport to open data from
105
super(TransportObjectStore, self).__init__()
106
self.transport = transport
107
self.pack_transport = self.transport.clone(PACKDIR)
109
def _pack_cache_stale(self):
112
def _pack_names(self):
114
f = self.transport.get('info/packs')
116
return self.pack_transport.list_dir(".")
119
for line in f.readlines():
120
line = line.rstrip("\n")
123
(kind, name) = line.split(" ", 1)
129
def _load_packs(self):
131
for name in self._pack_names():
132
if name.startswith("pack-") and name.endswith(".pack"):
133
size = self.pack_transport.stat(name).st_size
134
pd = PackData(name, self.pack_transport.get(name), size=size)
135
idxname = name.replace(".pack", ".idx")
136
idx = load_pack_index_file(idxname, self.pack_transport.get(idxname))
137
ret.append(Pack.from_objects(pd, idx))
140
def _iter_loose_objects(self):
141
for base in self.transport.list_dir('.'):
144
for rest in self.transport.list_dir(base):
147
def _split_loose_object(self, sha):
148
return (sha[:2], sha[2:])
150
def _get_loose_object(self, sha):
151
path = '%s/%s' % self._split_loose_object(sha)
153
return ShaFile.from_file(self.transport.get(path))
157
def add_object(self, obj):
158
"""Add a single object to this object store.
160
:param obj: Object to add
162
(dir, file) = self._split_loose_object(obj.id)
164
self.transport.mkdir(dir)
167
path = "%s/%s" % (dir, file)
168
if self.transport.has(path):
169
return # Already there, no need to write again
170
self.transport.put_bytes(path, obj.as_legacy_object())
172
def move_in_pack(self, f):
173
"""Move a specific file containing a pack into the pack directory.
175
:note: The file should be on the same file system as the
178
:param path: Path to the pack file.
181
p = PackData(None, f, len(f.getvalue()))
182
entries = p.sorted_entries()
183
basename = "pack-%s" % iter_sha1(entry[0] for entry in entries)
185
self.pack_transport.put_file(basename + ".pack", f)
186
index_path = self.pack_transport.local_abspath(basename+".idx")
187
write_pack_index_v2(index_path, entries, p.get_stored_checksum())
188
idx = load_pack_index_file(basename+".idx",
189
self.pack_transport.get(basename+".idx"))
190
final_pack = Pack.from_objects(p, idx)
191
self._add_known_pack(final_pack)
195
"""Add a new pack to this object store.
197
:return: Fileobject to write to and a commit function to
198
call when the pack is finished.
200
from cStringIO import StringIO
203
if len(f.getvalue()) > 0:
204
return self.move_in_pack(f)
210
def init(cls, transport):
211
transport.mkdir('info')
212
transport.mkdir(PACKDIR)
213
return cls(transport)
added
removed
transportgit.py
