chiark / gitweb /
wip new packages download
[hippotat.git] / hippotatd
index 49521683b250d503f2e61dddf34f4ef70843134a..24aca7c41232dac2aee0cc487e499ba4c493afe1 100755 (executable)
--- a/hippotatd
+++ b/hippotatd
@@ -1,4 +1,27 @@
 #!/usr/bin/python3
+#
+# Hippotat - Asinine IP Over HTTP program
+# ./hippotatd - server main program
+#
+# Copyright 2017 Ian Jackson
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Affero General Public License as
+# published by the Free Software Foundation, either version 3 of the
+# License, or (at your option) any later version, with the "CAF Login
+# Exception" as published by Ian Jackson (version 2, or at your option
+# any later version) as an Additional Permission.
+#
+# 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 Affero General Public License for more details.
+#
+# You should have received a copy of the GNU Affero General Public
+# License and the CAF Login Exception along with this program, in the
+# file AGPLv3+CAFv2.  If not, email Ian Jackson
+# <ijackson@chiark.greenend.org.uk>.
+
 
 from hippotatlib import *
 
@@ -214,38 +237,38 @@ class IphttpResource(NotStupidResource):
 <html><body>
 hippotat
 <p>
-<a href="source">source</a> available
+<a href="source">source</a>
+(and that of dependency <a href="srcpkgs">packages</a>)
+available
 </body></html>
 '''
 
-class SourceResource(twisted.web.static.File):
-  def __init__(self):
-    td = tempfile.mkdtemp()
-
-    def cleanup():
-      try: shutil.rmtree(td)
-      except FileNotFoundError: pass
-
-    cleanups.append(cleanup)
-
-    self._ssp = SourceShipmentPreparer(td)
-    self._ssp.logger = self.log
-    self._ssp.generate()
-
-    super().__init__(self._ssp.output_path)
-
-  def log(self, m):
-    log_debug(DBG.OWNSOURCE, m)
-
 def start_http():
   resource = IphttpResource()
-  resource.putChild(b'source',SourceResource())
   site = twisted.web.server.Site(resource)
+
   for sa in c.saddrs:
     ep = sa.make_endpoint()
     crash_on_defer(ep.listen(site))
     log_debug(DBG.INIT, 'listening on %s' % sa)
 
+  td = tempfile.mkdtemp()
+
+  def cleanup():
+    try: shutil.rmtree(td)
+    except FileNotFoundError: pass
+    
+  cleanups.append(cleanup)
+
+  ssp = SourceShipmentPreparer(td)
+  ssp.logger = partial(log_debug, DBG.OWNSOURCE)
+  ssp.generate()
+
+  resource.putChild(b'source', twisted.web.static.File(ssp.output_paths[0]))
+  resource.putChild(b'srcpkgs', twisted.web.static.File(ssp.output_paths[0]))
+
+  reactor.callLater(0.1, (lambda: log.info('hippotatd started', dflag=False)))
+
 #---------- config and setup ----------
 
 def process_cfg(putative_servers, putative_clients):