##// END OF EJS Templates
request: use trivial iterator over dictionary keys...
Augie Fackler -
r34514:34fcb0f6 default
parent child Browse files
Show More
@@ -1,152 +1,152 b''
1 1 # hgweb/request.py - An http request from either CGI or the standalone server.
2 2 #
3 3 # Copyright 21 May 2005 - (c) 2005 Jake Edge <jake@edge2.net>
4 4 # Copyright 2005, 2006 Matt Mackall <mpm@selenic.com>
5 5 #
6 6 # This software may be used and distributed according to the terms of the
7 7 # GNU General Public License version 2 or any later version.
8 8
9 9 from __future__ import absolute_import
10 10
11 11 import cgi
12 12 import errno
13 13 import socket
14 14
15 15 from .common import (
16 16 ErrorResponse,
17 17 HTTP_NOT_MODIFIED,
18 18 statusmessage,
19 19 )
20 20
21 21 from .. import (
22 22 util,
23 23 )
24 24
25 25 shortcuts = {
26 26 'cl': [('cmd', ['changelog']), ('rev', None)],
27 27 'sl': [('cmd', ['shortlog']), ('rev', None)],
28 28 'cs': [('cmd', ['changeset']), ('node', None)],
29 29 'f': [('cmd', ['file']), ('filenode', None)],
30 30 'fl': [('cmd', ['filelog']), ('filenode', None)],
31 31 'fd': [('cmd', ['filediff']), ('node', None)],
32 32 'fa': [('cmd', ['annotate']), ('filenode', None)],
33 33 'mf': [('cmd', ['manifest']), ('manifest', None)],
34 34 'ca': [('cmd', ['archive']), ('node', None)],
35 35 'tags': [('cmd', ['tags'])],
36 36 'tip': [('cmd', ['changeset']), ('node', ['tip'])],
37 37 'static': [('cmd', ['static']), ('file', None)]
38 38 }
39 39
40 40 def normalize(form):
41 41 # first expand the shortcuts
42 for k in shortcuts.iterkeys():
42 for k in shortcuts:
43 43 if k in form:
44 44 for name, value in shortcuts[k]:
45 45 if value is None:
46 46 value = form[k]
47 47 form[name] = value
48 48 del form[k]
49 49 # And strip the values
50 50 for k, v in form.iteritems():
51 51 form[k] = [i.strip() for i in v]
52 52 return form
53 53
54 54 class wsgirequest(object):
55 55 """Higher-level API for a WSGI request.
56 56
57 57 WSGI applications are invoked with 2 arguments. They are used to
58 58 instantiate instances of this class, which provides higher-level APIs
59 59 for obtaining request parameters, writing HTTP output, etc.
60 60 """
61 61 def __init__(self, wsgienv, start_response):
62 62 version = wsgienv[r'wsgi.version']
63 63 if (version < (1, 0)) or (version >= (2, 0)):
64 64 raise RuntimeError("Unknown and unsupported WSGI version %d.%d"
65 65 % version)
66 66 self.inp = wsgienv[r'wsgi.input']
67 67 self.err = wsgienv[r'wsgi.errors']
68 68 self.threaded = wsgienv[r'wsgi.multithread']
69 69 self.multiprocess = wsgienv[r'wsgi.multiprocess']
70 70 self.run_once = wsgienv[r'wsgi.run_once']
71 71 self.env = wsgienv
72 72 self.form = normalize(cgi.parse(self.inp,
73 73 self.env,
74 74 keep_blank_values=1))
75 75 self._start_response = start_response
76 76 self.server_write = None
77 77 self.headers = []
78 78
79 79 def __iter__(self):
80 80 return iter([])
81 81
82 82 def read(self, count=-1):
83 83 return self.inp.read(count)
84 84
85 85 def drain(self):
86 86 '''need to read all data from request, httplib is half-duplex'''
87 87 length = int(self.env.get('CONTENT_LENGTH') or 0)
88 88 for s in util.filechunkiter(self.inp, limit=length):
89 89 pass
90 90
91 91 def respond(self, status, type, filename=None, body=None):
92 92 if self._start_response is not None:
93 93 self.headers.append(('Content-Type', type))
94 94 if filename:
95 95 filename = (filename.rpartition('/')[-1]
96 96 .replace('\\', '\\\\').replace('"', '\\"'))
97 97 self.headers.append(('Content-Disposition',
98 98 'inline; filename="%s"' % filename))
99 99 if body is not None:
100 100 self.headers.append(('Content-Length', str(len(body))))
101 101
102 102 for k, v in self.headers:
103 103 if not isinstance(v, str):
104 104 raise TypeError('header value must be string: %r' % (v,))
105 105
106 106 if isinstance(status, ErrorResponse):
107 107 self.headers.extend(status.headers)
108 108 if status.code == HTTP_NOT_MODIFIED:
109 109 # RFC 2616 Section 10.3.5: 304 Not Modified has cases where
110 110 # it MUST NOT include any headers other than these and no
111 111 # body
112 112 self.headers = [(k, v) for (k, v) in self.headers if
113 113 k in ('Date', 'ETag', 'Expires',
114 114 'Cache-Control', 'Vary')]
115 115 status = statusmessage(status.code, str(status))
116 116 elif status == 200:
117 117 status = '200 Script output follows'
118 118 elif isinstance(status, int):
119 119 status = statusmessage(status)
120 120
121 121 self.server_write = self._start_response(status, self.headers)
122 122 self._start_response = None
123 123 self.headers = []
124 124 if body is not None:
125 125 self.write(body)
126 126 self.server_write = None
127 127
128 128 def write(self, thing):
129 129 if thing:
130 130 try:
131 131 self.server_write(thing)
132 132 except socket.error as inst:
133 133 if inst[0] != errno.ECONNRESET:
134 134 raise
135 135
136 136 def writelines(self, lines):
137 137 for line in lines:
138 138 self.write(line)
139 139
140 140 def flush(self):
141 141 return None
142 142
143 143 def close(self):
144 144 return None
145 145
146 146 def wsgiapplication(app_maker):
147 147 '''For compatibility with old CGI scripts. A plain hgweb() or hgwebdir()
148 148 can and should now be used as a WSGI application.'''
149 149 application = app_maker()
150 150 def run_wsgi(env, respond):
151 151 return application(env, respond)
152 152 return run_wsgi
General Comments 0
You need to be logged in to leave comments. Login now