Add a test program

bin/dul-daemon

@@ -0,0 +1,44 @@
+#!/usr/bin/python
+# dul-daemon - Simple git-daemon a like
+# Copyright (C) 2008 John Carr <john.carr@unrouted.co.uk>
+# 
+# This program is free software; you can redistribute it and/or
+# modify it under the terms of the GNU General Public License
+# as published by the Free Software Foundation; version 2
+# of the License.
+# 
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU General Public License for more details.
+# 
+# You should have received a copy of the GNU General Public License
+# along with this program; if not, write to the Free Software
+# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
+# MA  02110-1301, USA.
+
+import sys
+from dulwich.server import Backend, TCPGitServer
+
+class GitBackend(Backend):
+
+    def __init__(self, gitdir):
+        self.gitdir = gitdir
+
+    def get_refs(self):
+        return [['refs/heads/foo', '768fbb786f3a0a2a97ed980f3ce730e9e984f436']]
+
+    def has_revision(self, sha):
+        return False
+
+    def apply_pack(self, refs, read):
+        read()
+
+    def generate_pack(self, want, have, write, progress):
+        pass
+
+
+if __name__ == "__main__":
+    backend = GitBackend(sys.argv[1])
+    server = TCPGitServer(backend, ('localhost', 9418))
+    server.serve_forever()

dulwich/__init__.py

@@ -17,3 +17,4 @@
 # MA  02110-1301, USA.
 
 import repo
+import server

dulwich/server.py

@@ -131,7 +131,7 @@ class UploadPackHandler(Handler):
         #        self.write_sideband(2, "Compressiong objects: %d (%d/%d)\x0d" % (x, x*2, 200))
         #    self.write_sideband(2, "Compressing objects: 100% (200/200), done.\n")
 
-        self.backend.generate_pack(want, need, self.write)
+        self.backend.generate_pack(want_revs, have_revs, self.write, None)
 
 
 class ReceivePackHandler(Handler):
@@ -159,9 +159,12 @@ class TCPGitRequestHandler(SocketServer.StreamRequestHandler, Handler):
 
     def __init__(self, request, client_address, server):
         SocketServer.StreamRequestHandler.__init__(self, request, client_address, server)
-        Handler.__init__(self, server.backend, self.rfile.read, self.wfile.write)
 
     def handle(self):
+        #FIXME: StreamRequestHandler seems to be the thing that calls handle(),
+        #so we can't call this in a sane place??
+        Handler.__init__(self, self.server.backend, self.rfile.read, self.wfile.write)
+
         request = self.read_pkt_line()
 
         # up until the space is the command to run, everything after is parameters