From 1db60294e1818019d09794dad6032cc1376dcf52 Mon Sep 17 00:00:00 2001
From: ianb <devnull@localhost>
Date: Sun, 3 Jul 2005 00:07:20 +0000
Subject: Added new function capture_output

---
 paste/wsgilib.py | 43 ++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 42 insertions(+), 1 deletion(-)

diff --git a/paste/wsgilib.py b/paste/wsgilib.py
index aa42dd1..54f3cdf 100644
--- a/paste/wsgilib.py
+++ b/paste/wsgilib.py
@@ -11,7 +11,7 @@ import cgi
 __all__ = ['get_cookies', 'add_close', 'raw_interactive',
            'interactive', 'construct_url', 'error_body_response',
            'error_response', 'send_file', 'has_header', 'header_value',
-           'path_info_split', 'path_info_pop']
+           'path_info_split', 'path_info_pop', 'capture_output']
 
 def get_cookies(environ):
     """
@@ -353,6 +353,47 @@ def path_info_pop(environ):
         environ['SCRIPT_NAME'] += segment
         return segment
 
+def capture_output(environ, start_response, application):
+    """
+    Runs application with environ and start_response, and captures
+    status, headers, and body.  Sends status and header, but *not*
+    body.  Returns (status, headers, body).  Typically this is used
+    like::
+
+        def dehtmlifying_middleware(application):
+            def replacement_app(environ, start_response):
+                status, headers, body = capture_output(
+                    environ, start_response, application)
+                content_type = header_value(headers, 'content-type')
+                if (not content_type
+                    or not content_type.startswith('text/html')):
+                    return [body]
+                body = re.sub(r'<.*?>', '', body)
+                return [body]
+            return replacement_app
+    """
+    data = []
+    output = StringIO()
+    def replacement_start_response(status, headers, exc_info=None):
+        data.append(status)
+        data.append(headers)
+        start_response(status, headers, exc_info)
+        return output
+    app_iter = application(environ, replacement_start_response)
+    try:
+        for item in app_iter:
+            output.write(item)
+    finally:
+        if hasattr(app_iter, 'close'):
+            app_iter.close()
+    if not data:
+        data.append(None)
+    if len(data) < 2:
+        data.append(None)
+    data.append(output.getvalue())
+    return data
+        
+
 if __name__ == '__main__':
     import doctest
     doctest.testmod()
-- 
cgit v1.2.1