class BackendRepo(object):
"""Repository abstraction used by the Git server.
- Eventually this should become just a subset of Repo.
+ Please note that the methods required here are a
+ subset of those provided by dulwich.repo.Repo.
"""
+ object_store = None
+ refs = None
+
def get_refs(self):
"""
Get all the refs in the repository
"""
return None
- def apply_pack(self, refs, read, delete_refs=True):
- """ Import a set of changes into a repository and update the refs
-
- :param refs: list of tuple(name, sha)
- :param read: callback to read from the incoming pack
- :param delete_refs: whether to allow deleting refs
- """
- raise NotImplementedError
-
def fetch_objects(self, determine_wants, graph_walker, progress,
get_tagged=None):
"""
raise NotImplementedError
-class GitBackendRepo(BackendRepo):
-
- def __init__(self, repo):
- self.repo = repo
- self.refs = self.repo.refs
- self.object_store = self.repo.object_store
- self.fetch_objects = self.repo.fetch_objects
- self.get_refs = self.repo.get_refs
- self.get_peeled = self.repo.get_peeled
-
- def apply_pack(self, refs, read, delete_refs=True):
- f, commit = self.repo.object_store.add_thin_pack()
- all_exceptions = (IOError, OSError, ChecksumMismatch, ApplyDeltaError)
- status = []
- unpack_error = None
- # TODO: more informative error messages than just the exception string
- try:
- # TODO: decode the pack as we stream to avoid blocking reads beyond
- # the end of data (when using HTTP/1.1 chunked encoding)
- while True:
- data = read(10240)
- if not data:
- break
- f.write(data)
- except all_exceptions, e:
- unpack_error = str(e).replace('\n', '')
- try:
- commit()
- except all_exceptions, e:
- if not unpack_error:
- unpack_error = str(e).replace('\n', '')
-
- if unpack_error:
- status.append(('unpack', unpack_error))
- else:
- status.append(('unpack', 'ok'))
-
- for oldsha, sha, ref in refs:
- ref_error = None
- try:
- if sha == ZERO_SHA:
- if not delete_refs:
- raise GitProtocolError(
- 'Attempted to delete refs without delete-refs '
- 'capability.')
- try:
- del self.repo.refs[ref]
- except all_exceptions:
- ref_error = 'failed to delete'
- else:
- try:
- self.repo.refs[ref] = sha
- except all_exceptions:
- ref_error = 'failed to write'
- except KeyError, e:
- ref_error = 'bad ref'
- if ref_error:
- status.append((ref, ref_error))
- else:
- status.append((ref, 'ok'))
-
- print "pack applied"
- return status
-
-
class DictBackend(Backend):
"""Trivial backend that looks up Git repositories in a dictionary."""
class ProtocolGraphWalker(object):
"""A graph walker that knows the git protocol.
- As a graph walker, this class implements ack(), next(), and reset(). It also
- contains some base methods for interacting with the wire and walking the
- commit tree.
+ As a graph walker, this class implements ack(), next(), and reset(). It
+ also contains some base methods for interacting with the wire and walking
+ the commit tree.
The work of determining which acks to send is passed on to the
implementation instance stored in _impl. The reason for this is that we do
commit = pending.popleft()
if commit.id in haves:
return True
- if not getattr(commit, 'get_parents', None):
+ if commit.type_name != "commit":
# non-commit wants are assumed to be satisfied
continue
- for parent in commit.get_parents():
+ for parent in commit.parents:
parent_obj = self.store[parent]
# TODO: handle parents with later commit times than children
if parent_obj.commit_time >= earliest:
def capabilities(self):
return ("report-status", "delete-refs")
+ def _apply_pack(self, refs, read):
+ f, commit = self.repo.object_store.add_thin_pack()
+ all_exceptions = (IOError, OSError, ChecksumMismatch, ApplyDeltaError)
+ status = []
+ unpack_error = None
+ # TODO: more informative error messages than just the exception string
+ try:
+ # TODO: decode the pack as we stream to avoid blocking reads beyond
+ # the end of data (when using HTTP/1.1 chunked encoding)
+ while True:
+ data = read(10240)
+ if not data:
+ break
+ f.write(data)
+ except all_exceptions, e:
+ unpack_error = str(e).replace('\n', '')
+ try:
+ commit()
+ except all_exceptions, e:
+ if not unpack_error:
+ unpack_error = str(e).replace('\n', '')
+
+ if unpack_error:
+ status.append(('unpack', unpack_error))
+ else:
+ status.append(('unpack', 'ok'))
+
+ for oldsha, sha, ref in refs:
+ ref_error = None
+ try:
+ if sha == ZERO_SHA:
+ if not self.has_capability('delete-refs'):
+ raise GitProtocolError(
+ 'Attempted to delete refs without delete-refs '
+ 'capability.')
+ try:
+ del self.repo.refs[ref]
+ except all_exceptions:
+ ref_error = 'failed to delete'
+ else:
+ try:
+ self.repo.refs[ref] = sha
+ except all_exceptions:
+ ref_error = 'failed to write'
+ except KeyError, e:
+ ref_error = 'bad ref'
+ if ref_error:
+ status.append((ref, ref_error))
+ else:
+ status.append((ref, 'ok'))
+
+ print "pack applied"
+ return status
+
def handle(self):
refs = self.repo.get_refs().items()
ref = self.proto.read_pkt_line()
# backend can now deal with this refs and read a pack using self.read
- status = self.repo.apply_pack(client_refs, self.proto.read,
- self.has_capability('delete-refs'))
+ status = self.repo._apply_pack(client_refs, self.proto.read)
# when we have read all the pack from the client, send a status report
# if the client asked for it
git.samba.org / jelmer / dulwich-libgit2.git / blobdiff