[Checkins] SVN: hurry.resource/branches/janjaapdriessen-resource-publisher/src/hurry/resource/publisher.py Add hurry.resource publisher code. The publisher uses the *excellent* paste.fileapp.DirectoryApp code. The publisher knows about serving cache-forever resources.

[Jan-Jaap Driessen]

Log message for revision 118398:
  Add hurry.resource publisher code. The publisher uses the *excellent* paste.fileapp.DirectoryApp code. The publisher knows about serving cache-forever resources.

Changed:
  A   hurry.resource/branches/janjaapdriessen-resource-publisher/src/hurry/resource/publisher.py

-=-
Added: hurry.resource/branches/janjaapdriessen-resource-publisher/src/hurry/resource/publisher.py
===================================================================
--- hurry.resource/branches/janjaapdriessen-resource-publisher/src/hurry/resource/publisher.py	                        (rev 0)
+++ hurry.resource/branches/janjaapdriessen-resource-publisher/src/hurry/resource/publisher.py	2010-11-14 14:36:26 UTC (rev 118398)
@@ -0,0 +1,42 @@
+from paste.request import path_info_pop, path_info_split
+from paste.fileapp import DirectoryApp, CACHE_CONTROL, EXPIRES
+from paste.httpexceptions import HTTPNotFound
+
+import hurry.resource
+
+class Publisher(object):
+    def __init__(self):
+        self.dirapps = {}
+        for library in hurry.resource.libraries():
+            self.dirapps[library.name] = DirectoryApp(library.path)
+
+    def __call__(self, environ, start_response):
+        # When configured through Paste#urlmap, the WSGI environ['PATH_INFO']
+        # does not contain the mapping URL segment any more.
+
+        library_name = path_info_pop(environ)
+        try:
+            dirapp = self.dirapps[library_name]
+        except KeyError:
+            return HTTPNotFound()(environ, start_response)
+
+        def cache_header_start_response(status, headers, exc_info=None):
+            # XXX Don't set the cache control for 404's and friends.
+            expires = CACHE_CONTROL.apply(headers,
+                                          max_age=10*CACHE_CONTROL.ONE_YEAR)
+            EXPIRES.update(headers, delta=expires)
+            return start_response(status, headers, exc_info)
+
+        response = start_response
+
+        next_segment = path_info_split(environ['PATH_INFO'])[0]
+        if next_segment is not None and next_segment.startswith('hash:'):
+            # Our hashed urls start with 'hash:'. Skip these URL segments.
+            path_info_pop(environ)
+            response = cache_header_start_response
+
+        return dirapp(environ, response)
+
+
+def make_publisher(global_conf):
+    return Publisher()