LEFT | RIGHT |
1 # This file is part of the Adblock Plus web scripts, | 1 # This file is part of the Adblock Plus web scripts, |
2 # Copyright (C) 2006-present eyeo GmbH | 2 # Copyright (C) 2006-present eyeo GmbH |
3 # | 3 # |
4 # Adblock Plus is free software: you can redistribute it and/or modify | 4 # Adblock Plus is free software: you can redistribute it and/or modify |
5 # it under the terms of the GNU General Public License version 3 as | 5 # it under the terms of the GNU General Public License version 3 as |
6 # published by the Free Software Foundation. | 6 # published by the Free Software Foundation. |
7 # | 7 # |
8 # Adblock Plus is distributed in the hope that it will be useful, | 8 # Adblock Plus is distributed in the hope that it will be useful, |
9 # but WITHOUT ANY WARRANTY; without even the implied warranty of | 9 # but WITHOUT ANY WARRANTY; without even the implied warranty of |
10 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 10 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
11 # GNU General Public License for more details. | 11 # GNU General Public License for more details. |
12 # | 12 # |
13 # You should have received a copy of the GNU General Public License | 13 # You should have received a copy of the GNU General Public License |
14 # along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. | 14 # along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
15 | 15 |
16 from __future__ import print_function | 16 from __future__ import print_function |
17 | 17 |
18 import os | 18 import os |
19 import mimetypes | 19 import mimetypes |
20 from argparse import ArgumentParser | 20 import argparse |
21 | 21 |
22 import jinja2 | 22 import jinja2 |
23 | 23 |
24 from cms.converters import converters | 24 from cms.converters import converters |
25 from cms.utils import process_page | 25 from cms.utils import process_page |
26 from cms.sources import create_source | 26 from cms.sources import create_source |
27 | 27 |
28 UNICODE_ENCODING = 'utf-8' | 28 UNICODE_ENCODING = 'utf-8' |
29 | 29 |
30 ERROR_TEMPLATE = ''' | 30 ERROR_TEMPLATE = ''' |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
72 def _get_data(self, path): | 72 def _get_data(self, path): |
73 """Read the data corresponding to a website path. | 73 """Read the data corresponding to a website path. |
74 | 74 |
75 Parameters | 75 Parameters |
76 ---------- | 76 ---------- |
77 path: str | 77 path: str |
78 The path to the page to get the data for. | 78 The path to the page to get the data for. |
79 | 79 |
80 Returns | 80 Returns |
81 ------- | 81 ------- |
82 str/ bytes | 82 str or bytes |
83 The data corresponding to the path we're trying to access. | 83 The data corresponding to the path we're trying to access. |
84 | 84 |
85 """ | 85 """ |
86 if self.source.has_static(path): | 86 if self.source.has_static(path): |
87 return self.source.read_static(path) | 87 return self.source.read_static(path) |
88 | 88 |
89 page, data = self._get_page(path) | 89 page, data = self._get_page(path) |
90 | 90 |
91 if page and self._has_conflicts(page): | 91 if page and self._has_conflicts(page): |
92 raise Exception('The requested page conflicts with another page.') | 92 raise Exception('The requested page conflicts with another page.') |
93 | 93 |
94 return data | 94 return data |
95 | 95 |
96 def _get_page(self, path): | 96 def _get_page(self, path): |
97 """Construct a page and return its contents. | 97 """Construct a page and return its contents. |
98 | 98 |
99 Parameters | 99 Parameters |
100 ---------- | 100 ---------- |
101 path: str | 101 path: str |
102 The path of the page we want to construct. | 102 The path of the page we want to construct. |
103 | 103 |
104 Returns | 104 Returns |
105 ------- | 105 ------- |
106 (str, str) | 106 (page_name, page_contents): (str, str) |
107 With the following format: | |
108 <page_name, page_contents> | |
109 | 107 |
110 """ | 108 """ |
111 path = path.strip('/') | 109 path = path.strip('/') |
112 if path == '': | 110 if path == '': |
113 locale, page = self.source.read_config().get('general', | 111 locale, page = self.source.read_config().get('general', |
114 'defaultlocale'), '' | 112 'defaultlocale'), '' |
115 elif '/' in path: | 113 elif '/' in path: |
116 locale, page = path.split('/', 1) | 114 locale, page = path.split('/', 1) |
117 else: | 115 else: |
118 locale, page = path, '' | 116 locale, page = path, '' |
119 | 117 |
120 default_page = self.source.read_config().get('general', 'defaultpage') | 118 default_page = self.source.read_config().get('general', 'defaultpage') |
121 possible_pages = [page, '/'.join([page, default_page]).lstrip('/')] | 119 possible_pages = [page, '/'.join([page, default_page]).lstrip('/')] |
122 | 120 |
123 for page_format in converters.iterkeys(): | 121 for page_format in converters.iterkeys(): |
124 for p in possible_pages: | 122 for p in possible_pages: |
125 if self.source.has_page(p, page_format): | 123 if self.source.has_page(p, page_format): |
126 return p, process_page(self.source, locale, p, page_format, | 124 return p, process_page(self.source, locale, p, page_format, |
127 self.full_url) | 125 self.full_url) |
128 | 126 |
129 if self.source.has_localizable_file(locale, page): | 127 if self.source.has_localizable_file(locale, page): |
130 return page, self.source.read_localizable_file(locale, page) | 128 return page, self.source.read_localizable_file(locale, page) |
131 | 129 |
132 return None, None | 130 return None, None |
133 | 131 |
134 def _has_conflicts(self, page): | 132 def _has_conflicts(self, page): |
135 """Check if a page has conflicts. | 133 """Check if a page has conflicts. |
136 | 134 |
137 A page has conflicts if there are other pages with the same name. | 135 A page has conflicts if there are other pages with the same name. |
| 136 |
138 Parameters | 137 Parameters |
139 ---------- | 138 ---------- |
140 page: str | 139 page: str |
141 The path of the page we're checking for conflicts. | 140 The path of the page we're checking for conflicts. |
142 | 141 |
143 Returns | 142 Returns |
144 ------- | 143 ------- |
145 bool | 144 bool |
146 True - if the page has conflicts | 145 True - if the page has conflicts |
147 False - otherwise | 146 False - otherwise |
(...skipping 12 matching lines...) Expand all Loading... |
160 def get_error_page(self, start_response, status, **kw): | 159 def get_error_page(self, start_response, status, **kw): |
161 """Create and display an error page. | 160 """Create and display an error page. |
162 | 161 |
163 Parameters | 162 Parameters |
164 ---------- | 163 ---------- |
165 start_response: function | 164 start_response: function |
166 It will be called before constructing the error page, to setup | 165 It will be called before constructing the error page, to setup |
167 things like the status of the response and the headers. | 166 things like the status of the response and the headers. |
168 status: str | 167 status: str |
169 The status of the response we're sending the error page with. | 168 The status of the response we're sending the error page with. |
170 Needs to have the following format: "<status_code> | 169 Needs to have the following format: |
171 <status_message>" | 170 "<status_code> <status_message>" |
172 kw: dict | 171 kw: dict |
173 Any additional arguments that will be passed onto the `stream` | 172 Any additional arguments that will be passed onto the `stream` |
174 method | 173 method of a `jinja2 Template`. |
175 of a `jinja2 Template`. | 174 |
176 | 175 Returns |
177 Returns | 176 ------- |
178 ------- | 177 generator of utf8 strings |
179 generator | 178 Fragments of the corresponding error HTML template. |
180 of utf8 strings - fragments of the corresponding error HTML | |
181 template. | |
182 | 179 |
183 """ | 180 """ |
184 env = jinja2.Environment(autoescape=True) | 181 env = jinja2.Environment(autoescape=True) |
185 page_template = env.from_string(ERROR_TEMPLATE) | 182 page_template = env.from_string(ERROR_TEMPLATE) |
186 mime = 'text/html; encoding={}'.format(UNICODE_ENCODING) | 183 mime = 'text/html; encoding={}'.format(UNICODE_ENCODING) |
187 | 184 |
188 start_response(status, [('Content-Type', mime)]) | 185 start_response(status, [('Content-Type', mime)]) |
189 | 186 |
190 for fragment in page_template.stream(status=status, **kw): | 187 for fragment in page_template.stream(status=status, **kw): |
191 yield fragment.encode(UNICODE_ENCODING) | 188 yield fragment.encode(UNICODE_ENCODING) |
192 | 189 |
193 def __call__(self, environ, start_response): | 190 def __call__(self, environ, start_response): |
194 """Execute the handler, according with the WSGI standards. | 191 """Execute the handler, according to the WSGI standards. |
195 | 192 |
196 Parameters | 193 Parameters |
197 --------- | 194 --------- |
198 environ: dict | 195 environ: dict |
199 The environment under which the page is requested. | 196 The environment under which the page is requested. |
200 The requested page must be under the `PATH_INFO` key. | 197 The requested page must be under the `PATH_INFO` key. |
201 start_response: function | 198 start_response: function |
202 Used to initiate a response. Must take two arguments, in this | 199 Used to initiate a response. Must take two arguments, in this |
203 order: | 200 order: |
204 - Response status, in the format "<code> <message>". | 201 - Response status, in the format "<code> <message>". |
205 - Response headers, as a list of tuples. | 202 - Response headers, as a list of tuples. |
206 | 203 |
207 Returns | 204 Returns |
208 ------- | 205 ------- |
209 list | 206 list of str |
210 With the data for a specific page. | 207 With the data for a specific page. |
211 | 208 |
212 """ | 209 """ |
213 path = environ.get('PATH_INFO') | 210 path = environ.get('PATH_INFO') |
214 | 211 |
215 data = self._get_data(path) | 212 data = self._get_data(path) |
216 | 213 |
217 if data is None: | 214 if data is None: |
218 return self.get_error_page(start_response, '404 Not Found', | 215 return self.get_error_page(start_response, '404 Not Found', |
219 uri=path) | 216 uri=path) |
220 | 217 |
221 mime = mimetypes.guess_type(path)[0] or 'text/html' | 218 mime = mimetypes.guess_type(path)[0] or 'text/html' |
222 | 219 |
223 if isinstance(data, unicode): | 220 if isinstance(data, unicode): |
224 data = data.encode(UNICODE_ENCODING) | 221 data = data.encode(UNICODE_ENCODING) |
225 mime = '{0}; charset={1}'.format(mime, UNICODE_ENCODING) | 222 mime = '{0}; charset={1}'.format(mime, UNICODE_ENCODING) |
226 | 223 |
227 start_response('200 OK', [('Content-Type', mime)]) | 224 start_response('200 OK', [('Content-Type', mime)]) |
228 return [data] | 225 return [data] |
229 | 226 |
230 | 227 |
231 def get_handler(): | 228 def parse_arguments(): |
232 """Set the arguments required to run the script. | 229 """Set up and parse the arguments required by the script. |
233 | 230 |
234 Returns | 231 Returns |
235 ------- | 232 ------- |
236 TestServerHandler | 233 argparse.Namespace |
237 Initialised with the script parameters. | 234 With the script arguments, as parsed. |
238 | 235 |
239 """ | 236 """ |
240 parser = ArgumentParser(description='CMS development server created to ' | 237 parser = argparse.ArgumentParser( |
241 'test pages locally and on-the-fly') | 238 description='CMS development server created to test pages locally and ' |
| 239 'on-the-fly.', |
| 240 ) |
242 | 241 |
243 parser.add_argument('path', default=os.curdir, nargs='?', | 242 parser.add_argument('path', default=os.curdir, nargs='?', |
244 help='Path to the website we intend to run. If not ' | 243 help='Path to the website we intend to run. If not ' |
245 'provided, defaults, to the current directory.') | 244 'provided, defaults, to the current directory.') |
246 parser.add_argument('--host', default='localhost', | 245 parser.add_argument('--host', default='localhost', |
247 help='Address of the host the server will listen on. ' | 246 help='Address of the host the server will listen on. ' |
248 'Defaults to "localhost".') | 247 'Defaults to "localhost".') |
249 parser.add_argument('--port', default=5000, type=int, | 248 parser.add_argument('--port', default=5000, type=int, |
250 help='TCP port the server will listen on. Default ' | 249 help='TCP port the server will listen on. Default ' |
251 '5000.') | 250 '5000.') |
252 | 251 |
253 args = parser.parse_args() | 252 return parser.parse_args() |
254 | |
255 return DynamicServerHandler(args.host, args.port, args.path) | |
256 | 253 |
257 | 254 |
258 def run_werkzeug_server(handler, **kw): | 255 def run_werkzeug_server(handler, **kw): |
259 """Set up a server that uses `werkzeug`. | 256 """Set up a server that uses `werkzeug`. |
260 | 257 |
261 Parameters | 258 Parameters |
262 ---------- | 259 ---------- |
263 handler: DynamicServerHandler | 260 handler: DynamicServerHandler |
264 Defines the parameters and methods required to handle requests. | 261 Defines the parameters and methods required to handle requests. |
265 | 262 |
266 Raises | 263 Raises |
267 ------ | 264 ------ |
268 ImportError | 265 ImportError |
269 If the package `werkzeug` is not installed | 266 If the package `werkzeug` is not installed |
270 | 267 |
271 """ | 268 """ |
272 from werkzeug.serving import run_simple | 269 from werkzeug.serving import run_simple |
| 270 import logging |
273 | 271 |
274 def run(*args, **kwargs): | 272 def run(*args, **kwargs): |
275 # The werkzeug logger must be configured before the | 273 # The werkzeug logger must be configured before the |
276 # root logger. Also we must prevent it from propagating | 274 # root logger. Also we must prevent it from propagating |
277 # messages, otherwise messages are logged twice. | 275 # messages, otherwise messages are logged twice. |
278 import logging | |
279 logger = logging.getLogger('werkzeug') | 276 logger = logging.getLogger('werkzeug') |
280 logger.propagate = False | 277 logger.propagate = False |
281 logger.setLevel(logging.INFO) | 278 logger.setLevel(logging.INFO) |
282 logger.addHandler(logging.StreamHandler()) | 279 logger.addHandler(logging.StreamHandler()) |
283 | 280 |
284 run_simple(threaded=True, *args, **kwargs) | 281 run_simple(threaded=True, *args, **kwargs) |
285 | 282 |
286 run(handler.host, handler.port, handler, **kw) | 283 run(handler.host, handler.port, handler, **kw) |
287 | 284 |
288 | 285 |
(...skipping 23 matching lines...) Expand all Loading... |
312 ) | 309 ) |
313 | 310 |
314 server = make_server(host, port, wrapper, ThreadedWSGIServer) | 311 server = make_server(host, port, wrapper, ThreadedWSGIServer) |
315 print(' * Running on {0}:{1}'.format(*server.server_address)) | 312 print(' * Running on {0}:{1}'.format(*server.server_address)) |
316 server.serve_forever() | 313 server.serve_forever() |
317 | 314 |
318 run(handler.host, handler.port, handler, **kw) | 315 run(handler.host, handler.port, handler, **kw) |
319 | 316 |
320 | 317 |
321 def main(): | 318 def main(): |
322 handler = get_handler() | 319 args = parse_arguments() |
| 320 handler = DynamicServerHandler(args.host, args.port, args.path) |
323 | 321 |
324 try: | 322 try: |
325 run_werkzeug_server(handler, use_reloader=True, use_debugger=True) | 323 run_werkzeug_server(handler, use_reloader=True, use_debugger=True) |
326 except ImportError: | 324 except ImportError: |
327 run_builtins_server(handler) | 325 run_builtins_server(handler) |
328 | 326 |
329 | 327 |
330 if __name__ == '__main__': | 328 if __name__ == '__main__': |
331 main() | 329 main() |
LEFT | RIGHT |