1 | # (c) 2005 Ian Bicking and contributors; written for Paste (http://pythonpaste.org) |
---|
2 | # Licensed under the MIT license: http://www.opensource.org/licenses/mit-license.php |
---|
3 | """Routines to generate WSGI responses""" |
---|
4 | |
---|
5 | ############################################################ |
---|
6 | ## Headers |
---|
7 | ############################################################ |
---|
8 | import warnings |
---|
9 | |
---|
10 | class HeaderDict(dict): |
---|
11 | |
---|
12 | """ |
---|
13 | This represents response headers. It handles the headers as a |
---|
14 | dictionary, with case-insensitive keys. |
---|
15 | |
---|
16 | Also there is an ``.add(key, value)`` method, which sets the key, |
---|
17 | or adds the value to the current value (turning it into a list if |
---|
18 | necessary). |
---|
19 | |
---|
20 | For passing to WSGI there is a ``.headeritems()`` method which is |
---|
21 | like ``.items()`` but unpacks value that are lists. It also |
---|
22 | handles encoding -- all headers are encoded in ASCII (if they are |
---|
23 | unicode). |
---|
24 | |
---|
25 | @@: Should that encoding be ISO-8859-1 or UTF-8? I'm not sure |
---|
26 | what the spec says. |
---|
27 | """ |
---|
28 | |
---|
29 | def __getitem__(self, key): |
---|
30 | return dict.__getitem__(self, self.normalize(key)) |
---|
31 | |
---|
32 | def __setitem__(self, key, value): |
---|
33 | dict.__setitem__(self, self.normalize(key), value) |
---|
34 | |
---|
35 | def __delitem__(self, key): |
---|
36 | dict.__delitem__(self, self.normalize(key)) |
---|
37 | |
---|
38 | def __contains__(self, key): |
---|
39 | return dict.__contains__(self, self.normalize(key)) |
---|
40 | |
---|
41 | has_key = __contains__ |
---|
42 | |
---|
43 | def get(self, key, failobj=None): |
---|
44 | return dict.get(self, self.normalize(key), failobj) |
---|
45 | |
---|
46 | def setdefault(self, key, failobj=None): |
---|
47 | return dict.setdefault(self, self.normalize(key), failobj) |
---|
48 | |
---|
49 | def pop(self, key): |
---|
50 | return dict.pop(self, self.normalize(key)) |
---|
51 | |
---|
52 | def update(self, other): |
---|
53 | for key in other: |
---|
54 | self[self.normalize(key)] = other[key] |
---|
55 | |
---|
56 | def normalize(self, key): |
---|
57 | return str(key).lower().strip() |
---|
58 | |
---|
59 | def add(self, key, value): |
---|
60 | key = self.normalize(key) |
---|
61 | if key in self: |
---|
62 | if isinstance(self[key], list): |
---|
63 | self[key].append(value) |
---|
64 | else: |
---|
65 | self[key] = [self[key], value] |
---|
66 | else: |
---|
67 | self[key] = value |
---|
68 | |
---|
69 | def headeritems(self): |
---|
70 | result = [] |
---|
71 | for key, value in self.items(): |
---|
72 | if isinstance(value, list): |
---|
73 | for v in value: |
---|
74 | result.append((key, str(v))) |
---|
75 | else: |
---|
76 | result.append((key, str(value))) |
---|
77 | return result |
---|
78 | |
---|
79 | #@classmethod |
---|
80 | def fromlist(cls, seq): |
---|
81 | self = cls() |
---|
82 | for name, value in seq: |
---|
83 | self.add(name, value) |
---|
84 | return self |
---|
85 | |
---|
86 | fromlist = classmethod(fromlist) |
---|
87 | |
---|
88 | def has_header(headers, name): |
---|
89 | """ |
---|
90 | Is header named ``name`` present in headers? |
---|
91 | """ |
---|
92 | name = name.lower() |
---|
93 | for header, value in headers: |
---|
94 | if header.lower() == name: |
---|
95 | return True |
---|
96 | return False |
---|
97 | |
---|
98 | def header_value(headers, name): |
---|
99 | """ |
---|
100 | Returns the header's value, or None if no such header. If a |
---|
101 | header appears more than once, all the values of the headers |
---|
102 | are joined with ','. Note that this is consistent /w RFC 2616 |
---|
103 | section 4.2 which states: |
---|
104 | |
---|
105 | It MUST be possible to combine the multiple header fields |
---|
106 | into one "field-name: field-value" pair, without changing |
---|
107 | the semantics of the message, by appending each subsequent |
---|
108 | field-value to the first, each separated by a comma. |
---|
109 | |
---|
110 | However, note that the original netscape usage of 'Set-Cookie', |
---|
111 | especially in MSIE which contains an 'expires' date will is not |
---|
112 | compatible with this particular concatination method. |
---|
113 | """ |
---|
114 | name = name.lower() |
---|
115 | result = [value for header, value in headers |
---|
116 | if header.lower() == name] |
---|
117 | if result: |
---|
118 | return ','.join(result) |
---|
119 | else: |
---|
120 | return None |
---|
121 | |
---|
122 | def remove_header(headers, name): |
---|
123 | """ |
---|
124 | Removes the named header from the list of headers. Returns the |
---|
125 | value of that header, or None if no header found. If multiple |
---|
126 | headers are found, only the last one is returned. |
---|
127 | """ |
---|
128 | name = name.lower() |
---|
129 | i = 0 |
---|
130 | result = None |
---|
131 | while i < len(headers): |
---|
132 | if headers[i][0].lower() == name: |
---|
133 | result = headers[i][1] |
---|
134 | del headers[i] |
---|
135 | continue |
---|
136 | i += 1 |
---|
137 | return result |
---|
138 | |
---|
139 | def replace_header(headers, name, value): |
---|
140 | """ |
---|
141 | Updates the headers replacing the first occurance of the given name |
---|
142 | with the value provided; asserting that no further occurances |
---|
143 | happen. Note that this is _not_ the same as remove_header and then |
---|
144 | append, as two distinct operations (del followed by an append) are |
---|
145 | not atomic in a threaded environment. Returns the previous header |
---|
146 | value for the provided name, if any. Clearly one should not use |
---|
147 | this function with ``set-cookie`` or other names that may have more |
---|
148 | than one occurance in the headers. |
---|
149 | """ |
---|
150 | name = name.lower() |
---|
151 | i = 0 |
---|
152 | result = None |
---|
153 | while i < len(headers): |
---|
154 | if headers[i][0].lower() == name: |
---|
155 | assert not result, "two values for the header '%s' found" % name |
---|
156 | result = headers[i][1] |
---|
157 | headers[i] = (name, value) |
---|
158 | i += 1 |
---|
159 | if not result: |
---|
160 | headers.append((name, value)) |
---|
161 | return result |
---|
162 | |
---|
163 | |
---|
164 | ############################################################ |
---|
165 | ## Deprecated methods |
---|
166 | ############################################################ |
---|
167 | |
---|
168 | def error_body_response(error_code, message, __warn=True): |
---|
169 | """ |
---|
170 | Returns a standard HTML response page for an HTTP error. |
---|
171 | **Note:** Deprecated |
---|
172 | """ |
---|
173 | if __warn: |
---|
174 | warnings.warn( |
---|
175 | 'wsgilib.error_body_response is deprecated; use the ' |
---|
176 | 'wsgi_application method on an HTTPException object ' |
---|
177 | 'instead', DeprecationWarning, 2) |
---|
178 | return '''\ |
---|
179 | <html> |
---|
180 | <head> |
---|
181 | <title>%(error_code)s</title> |
---|
182 | </head> |
---|
183 | <body> |
---|
184 | <h1>%(error_code)s</h1> |
---|
185 | %(message)s |
---|
186 | </body> |
---|
187 | </html>''' % { |
---|
188 | 'error_code': error_code, |
---|
189 | 'message': message, |
---|
190 | } |
---|
191 | |
---|
192 | |
---|
193 | def error_response(environ, error_code, message, |
---|
194 | debug_message=None, __warn=True): |
---|
195 | """ |
---|
196 | Returns the status, headers, and body of an error response. |
---|
197 | |
---|
198 | Use like: |
---|
199 | |
---|
200 | .. code-block:: Python |
---|
201 | |
---|
202 | status, headers, body = wsgilib.error_response( |
---|
203 | '301 Moved Permanently', 'Moved to <a href="%s">%s</a>' |
---|
204 | % (url, url)) |
---|
205 | start_response(status, headers) |
---|
206 | return [body] |
---|
207 | |
---|
208 | **Note:** Deprecated |
---|
209 | """ |
---|
210 | if __warn: |
---|
211 | warnings.warn( |
---|
212 | 'wsgilib.error_response is deprecated; use the ' |
---|
213 | 'wsgi_application method on an HTTPException object ' |
---|
214 | 'instead', DeprecationWarning, 2) |
---|
215 | if debug_message and environ.get('paste.config', {}).get('debug'): |
---|
216 | message += '\n\n<!-- %s -->' % debug_message |
---|
217 | body = error_body_response(error_code, message, __warn=False) |
---|
218 | headers = [('content-type', 'text/html'), |
---|
219 | ('content-length', str(len(body)))] |
---|
220 | return error_code, headers, body |
---|
221 | |
---|
222 | def error_response_app(error_code, message, debug_message=None, |
---|
223 | __warn=True): |
---|
224 | """ |
---|
225 | An application that emits the given error response. |
---|
226 | |
---|
227 | **Note:** Deprecated |
---|
228 | """ |
---|
229 | if __warn: |
---|
230 | warnings.warn( |
---|
231 | 'wsgilib.error_response_app is deprecated; use the ' |
---|
232 | 'wsgi_application method on an HTTPException object ' |
---|
233 | 'instead', DeprecationWarning, 2) |
---|
234 | def application(environ, start_response): |
---|
235 | status, headers, body = error_response( |
---|
236 | environ, error_code, message, |
---|
237 | debug_message=debug_message, __warn=False) |
---|
238 | start_response(status, headers) |
---|
239 | return [body] |
---|
240 | return application |
---|