##// END OF EJS Templates
error-middleware: read title from cached rhodecode object....
marcink -
r1496:cf3f95ff default
parent child Browse files
Show More
@@ -1,499 +1,495 b''
1 1 # -*- coding: utf-8 -*-
2 2
3 3 # Copyright (C) 2010-2017 RhodeCode GmbH
4 4 #
5 5 # This program is free software: you can redistribute it and/or modify
6 6 # it under the terms of the GNU Affero General Public License, version 3
7 7 # (only), as published by the Free Software Foundation.
8 8 #
9 9 # This program is distributed in the hope that it will be useful,
10 10 # but WITHOUT ANY WARRANTY; without even the implied warranty of
11 11 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 12 # GNU General Public License for more details.
13 13 #
14 14 # You should have received a copy of the GNU Affero General Public License
15 15 # along with this program. If not, see <http://www.gnu.org/licenses/>.
16 16 #
17 17 # This program is dual-licensed. If you wish to learn more about the
18 18 # RhodeCode Enterprise Edition, including its added features, Support services,
19 19 # and proprietary license terms, please see https://rhodecode.com/licenses/
20 20
21 21 """
22 22 Pylons middleware initialization
23 23 """
24 24 import logging
25 25 from collections import OrderedDict
26 26
27 27 from paste.registry import RegistryManager
28 28 from paste.gzipper import make_gzip_middleware
29 29 from pylons.wsgiapp import PylonsApp
30 30 from pyramid.authorization import ACLAuthorizationPolicy
31 31 from pyramid.config import Configurator
32 32 from pyramid.settings import asbool, aslist
33 33 from pyramid.wsgi import wsgiapp
34 34 from pyramid.httpexceptions import (
35 35 HTTPError, HTTPInternalServerError, HTTPFound)
36 36 from pyramid.events import ApplicationCreated
37 37 from pyramid.renderers import render_to_response
38 38 from routes.middleware import RoutesMiddleware
39 39 import routes.util
40 40
41 41 import rhodecode
42 42 from rhodecode.model import meta
43 43 from rhodecode.config import patches
44 44 from rhodecode.config.routing import STATIC_FILE_PREFIX
45 45 from rhodecode.config.environment import (
46 46 load_environment, load_pyramid_environment)
47 47 from rhodecode.lib.middleware import csrf
48 48 from rhodecode.lib.middleware.appenlight import wrap_in_appenlight_if_enabled
49 49 from rhodecode.lib.middleware.error_handling import (
50 50 PylonsErrorHandlingMiddleware)
51 51 from rhodecode.lib.middleware.https_fixup import HttpsFixup
52 52 from rhodecode.lib.middleware.vcs import VCSMiddleware
53 53 from rhodecode.lib.plugins.utils import register_rhodecode_plugin
54 54 from rhodecode.lib.utils2 import aslist as rhodecode_aslist
55 55 from rhodecode.subscribers import (
56 56 scan_repositories_if_enabled, write_metadata_if_needed)
57 57
58 58
59 59 log = logging.getLogger(__name__)
60 60
61 61
62 62 # this is used to avoid avoid the route lookup overhead in routesmiddleware
63 63 # for certain routes which won't go to pylons to - eg. static files, debugger
64 64 # it is only needed for the pylons migration and can be removed once complete
65 65 class SkippableRoutesMiddleware(RoutesMiddleware):
66 66 """ Routes middleware that allows you to skip prefixes """
67 67
68 68 def __init__(self, *args, **kw):
69 69 self.skip_prefixes = kw.pop('skip_prefixes', [])
70 70 super(SkippableRoutesMiddleware, self).__init__(*args, **kw)
71 71
72 72 def __call__(self, environ, start_response):
73 73 for prefix in self.skip_prefixes:
74 74 if environ['PATH_INFO'].startswith(prefix):
75 75 # added to avoid the case when a missing /_static route falls
76 76 # through to pylons and causes an exception as pylons is
77 77 # expecting wsgiorg.routingargs to be set in the environ
78 78 # by RoutesMiddleware.
79 79 if 'wsgiorg.routing_args' not in environ:
80 80 environ['wsgiorg.routing_args'] = (None, {})
81 81 return self.app(environ, start_response)
82 82
83 83 return super(SkippableRoutesMiddleware, self).__call__(
84 84 environ, start_response)
85 85
86 86
87 87 def make_app(global_conf, static_files=True, **app_conf):
88 88 """Create a Pylons WSGI application and return it
89 89
90 90 ``global_conf``
91 91 The inherited configuration for this application. Normally from
92 92 the [DEFAULT] section of the Paste ini file.
93 93
94 94 ``app_conf``
95 95 The application's local configuration. Normally specified in
96 96 the [app:<name>] section of the Paste ini file (where <name>
97 97 defaults to main).
98 98
99 99 """
100 100 # Apply compatibility patches
101 101 patches.kombu_1_5_1_python_2_7_11()
102 102 patches.inspect_getargspec()
103 103
104 104 # Configure the Pylons environment
105 105 config = load_environment(global_conf, app_conf)
106 106
107 107 # The Pylons WSGI app
108 108 app = PylonsApp(config=config)
109 109 if rhodecode.is_test:
110 110 app = csrf.CSRFDetector(app)
111 111
112 112 expected_origin = config.get('expected_origin')
113 113 if expected_origin:
114 114 # The API can be accessed from other Origins.
115 115 app = csrf.OriginChecker(app, expected_origin,
116 116 skip_urls=[routes.util.url_for('api')])
117 117
118 118 # Establish the Registry for this application
119 119 app = RegistryManager(app)
120 120
121 121 app.config = config
122 122
123 123 return app
124 124
125 125
126 126 def make_pyramid_app(global_config, **settings):
127 127 """
128 128 Constructs the WSGI application based on Pyramid and wraps the Pylons based
129 129 application.
130 130
131 131 Specials:
132 132
133 133 * We migrate from Pylons to Pyramid. While doing this, we keep both
134 134 frameworks functional. This involves moving some WSGI middlewares around
135 135 and providing access to some data internals, so that the old code is
136 136 still functional.
137 137
138 138 * The application can also be integrated like a plugin via the call to
139 139 `includeme`. This is accompanied with the other utility functions which
140 140 are called. Changing this should be done with great care to not break
141 141 cases when these fragments are assembled from another place.
142 142
143 143 """
144 144 # The edition string should be available in pylons too, so we add it here
145 145 # before copying the settings.
146 146 settings.setdefault('rhodecode.edition', 'Community Edition')
147 147
148 148 # As long as our Pylons application does expect "unprepared" settings, make
149 149 # sure that we keep an unmodified copy. This avoids unintentional change of
150 150 # behavior in the old application.
151 151 settings_pylons = settings.copy()
152 152
153 153 sanitize_settings_and_apply_defaults(settings)
154 154 config = Configurator(settings=settings)
155 155 add_pylons_compat_data(config.registry, global_config, settings_pylons)
156 156
157 157 load_pyramid_environment(global_config, settings)
158 158
159 159 includeme_first(config)
160 160 includeme(config)
161 161 pyramid_app = config.make_wsgi_app()
162 162 pyramid_app = wrap_app_in_wsgi_middlewares(pyramid_app, config)
163 163 pyramid_app.config = config
164 164
165 165 # creating the app uses a connection - return it after we are done
166 166 meta.Session.remove()
167 167
168 168 return pyramid_app
169 169
170 170
171 171 def make_not_found_view(config):
172 172 """
173 173 This creates the view which should be registered as not-found-view to
174 174 pyramid. Basically it contains of the old pylons app, converted to a view.
175 175 Additionally it is wrapped by some other middlewares.
176 176 """
177 177 settings = config.registry.settings
178 178 vcs_server_enabled = settings['vcs.server.enable']
179 179
180 180 # Make pylons app from unprepared settings.
181 181 pylons_app = make_app(
182 182 config.registry._pylons_compat_global_config,
183 183 **config.registry._pylons_compat_settings)
184 184 config.registry._pylons_compat_config = pylons_app.config
185 185
186 186 # Appenlight monitoring.
187 187 pylons_app, appenlight_client = wrap_in_appenlight_if_enabled(
188 188 pylons_app, settings)
189 189
190 190 # The pylons app is executed inside of the pyramid 404 exception handler.
191 191 # Exceptions which are raised inside of it are not handled by pyramid
192 192 # again. Therefore we add a middleware that invokes the error handler in
193 193 # case of an exception or error response. This way we return proper error
194 194 # HTML pages in case of an error.
195 195 reraise = (settings.get('debugtoolbar.enabled', False) or
196 196 rhodecode.disable_error_handler)
197 197 pylons_app = PylonsErrorHandlingMiddleware(
198 198 pylons_app, error_handler, reraise)
199 199
200 200 # The VCSMiddleware shall operate like a fallback if pyramid doesn't find a
201 201 # view to handle the request. Therefore it is wrapped around the pylons
202 202 # app. It has to be outside of the error handling otherwise error responses
203 203 # from the vcsserver are converted to HTML error pages. This confuses the
204 204 # command line tools and the user won't get a meaningful error message.
205 205 if vcs_server_enabled:
206 206 pylons_app = VCSMiddleware(
207 207 pylons_app, settings, appenlight_client, registry=config.registry)
208 208
209 209 # Convert WSGI app to pyramid view and return it.
210 210 return wsgiapp(pylons_app)
211 211
212 212
213 213 def add_pylons_compat_data(registry, global_config, settings):
214 214 """
215 215 Attach data to the registry to support the Pylons integration.
216 216 """
217 217 registry._pylons_compat_global_config = global_config
218 218 registry._pylons_compat_settings = settings
219 219
220 220
221 221 def error_handler(exception, request):
222 from rhodecode.model.settings import SettingsModel
222 import rhodecode
223 223 from rhodecode.lib.utils2 import AttributeDict
224 224
225 try:
226 rc_config = SettingsModel().get_all_settings()
227 except Exception:
228 log.exception('failed to fetch settings')
229 rc_config = {}
225 rhodecode_title = rhodecode.CONFIG.get('rhodecode_title') or 'RhodeCode'
230 226
231 227 base_response = HTTPInternalServerError()
232 228 # prefer original exception for the response since it may have headers set
233 229 if isinstance(exception, HTTPError):
234 230 base_response = exception
235 231
236 232 def is_http_error(response):
237 233 # error which should have traceback
238 234 return response.status_code > 499
239 235
240 236 if is_http_error(base_response):
241 237 log.exception(
242 238 'error occurred handling this request for path: %s', request.path)
243 239
244 240 c = AttributeDict()
245 241 c.error_message = base_response.status
246 242 c.error_explanation = base_response.explanation or str(base_response)
247 243 c.visual = AttributeDict()
248 244
249 245 c.visual.rhodecode_support_url = (
250 246 request.registry.settings.get('rhodecode_support_url') or
251 247 request.route_url('rhodecode_support')
252 248 )
253 249 c.redirect_time = 0
254 c.rhodecode_name = rc_config.get('rhodecode_title', '')
250 c.rhodecode_name = rhodecode_title
255 251 if not c.rhodecode_name:
256 252 c.rhodecode_name = 'Rhodecode'
257 253
258 254 c.causes = []
259 255 if hasattr(base_response, 'causes'):
260 256 c.causes = base_response.causes
261 257
262 258 response = render_to_response(
263 259 '/errors/error_document.mako', {'c': c}, request=request,
264 260 response=base_response)
265 261
266 262 return response
267 263
268 264
269 265 def includeme(config):
270 266 settings = config.registry.settings
271 267
272 268 # plugin information
273 269 config.registry.rhodecode_plugins = OrderedDict()
274 270
275 271 config.add_directive(
276 272 'register_rhodecode_plugin', register_rhodecode_plugin)
277 273
278 274 if asbool(settings.get('appenlight', 'false')):
279 275 config.include('appenlight_client.ext.pyramid_tween')
280 276
281 277 # Includes which are required. The application would fail without them.
282 278 config.include('pyramid_mako')
283 279 config.include('pyramid_beaker')
284 280 config.include('rhodecode.channelstream')
285 281 config.include('rhodecode.admin')
286 282 config.include('rhodecode.authentication')
287 283 config.include('rhodecode.integrations')
288 284 config.include('rhodecode.login')
289 285 config.include('rhodecode.tweens')
290 286 config.include('rhodecode.api')
291 287 config.include('rhodecode.svn_support')
292 288 config.add_route(
293 289 'rhodecode_support', 'https://rhodecode.com/help/', static=True)
294 290
295 291 config.add_translation_dirs('rhodecode:i18n/')
296 292 settings['default_locale_name'] = settings.get('lang', 'en')
297 293
298 294 # Add subscribers.
299 295 config.add_subscriber(scan_repositories_if_enabled, ApplicationCreated)
300 296 config.add_subscriber(write_metadata_if_needed, ApplicationCreated)
301 297
302 298 # Set the authorization policy.
303 299 authz_policy = ACLAuthorizationPolicy()
304 300 config.set_authorization_policy(authz_policy)
305 301
306 302 # Set the default renderer for HTML templates to mako.
307 303 config.add_mako_renderer('.html')
308 304
309 305 # include RhodeCode plugins
310 306 includes = aslist(settings.get('rhodecode.includes', []))
311 307 for inc in includes:
312 308 config.include(inc)
313 309
314 310 # This is the glue which allows us to migrate in chunks. By registering the
315 311 # pylons based application as the "Not Found" view in Pyramid, we will
316 312 # fallback to the old application each time the new one does not yet know
317 313 # how to handle a request.
318 314 config.add_notfound_view(make_not_found_view(config))
319 315
320 316 if not settings.get('debugtoolbar.enabled', False):
321 317 # if no toolbar, then any exception gets caught and rendered
322 318 config.add_view(error_handler, context=Exception)
323 319
324 320 config.add_view(error_handler, context=HTTPError)
325 321
326 322
327 323 def includeme_first(config):
328 324 # redirect automatic browser favicon.ico requests to correct place
329 325 def favicon_redirect(context, request):
330 326 return HTTPFound(
331 327 request.static_path('rhodecode:public/images/favicon.ico'))
332 328
333 329 config.add_view(favicon_redirect, route_name='favicon')
334 330 config.add_route('favicon', '/favicon.ico')
335 331
336 332 def robots_redirect(context, request):
337 333 return HTTPFound(
338 334 request.static_path('rhodecode:public/robots.txt'))
339 335
340 336 config.add_view(robots_redirect, route_name='robots')
341 337 config.add_route('robots', '/robots.txt')
342 338
343 339 config.add_static_view(
344 340 '_static/deform', 'deform:static')
345 341 config.add_static_view(
346 342 '_static/rhodecode', path='rhodecode:public', cache_max_age=3600 * 24)
347 343
348 344
349 345 def wrap_app_in_wsgi_middlewares(pyramid_app, config):
350 346 """
351 347 Apply outer WSGI middlewares around the application.
352 348
353 349 Part of this has been moved up from the Pylons layer, so that the
354 350 data is also available if old Pylons code is hit through an already ported
355 351 view.
356 352 """
357 353 settings = config.registry.settings
358 354
359 355 # enable https redirects based on HTTP_X_URL_SCHEME set by proxy
360 356 pyramid_app = HttpsFixup(pyramid_app, settings)
361 357
362 358 # Add RoutesMiddleware to support the pylons compatibility tween during
363 359 # migration to pyramid.
364 360 pyramid_app = SkippableRoutesMiddleware(
365 361 pyramid_app, config.registry._pylons_compat_config['routes.map'],
366 362 skip_prefixes=(STATIC_FILE_PREFIX, '/_debug_toolbar'))
367 363
368 364 pyramid_app, _ = wrap_in_appenlight_if_enabled(pyramid_app, settings)
369 365
370 366 if settings['gzip_responses']:
371 367 pyramid_app = make_gzip_middleware(
372 368 pyramid_app, settings, compress_level=1)
373 369
374 370 # this should be the outer most middleware in the wsgi stack since
375 371 # middleware like Routes make database calls
376 372 def pyramid_app_with_cleanup(environ, start_response):
377 373 try:
378 374 return pyramid_app(environ, start_response)
379 375 finally:
380 376 # Dispose current database session and rollback uncommitted
381 377 # transactions.
382 378 meta.Session.remove()
383 379
384 380 # In a single threaded mode server, on non sqlite db we should have
385 381 # '0 Current Checked out connections' at the end of a request,
386 382 # if not, then something, somewhere is leaving a connection open
387 383 pool = meta.Base.metadata.bind.engine.pool
388 384 log.debug('sa pool status: %s', pool.status())
389 385
390 386
391 387 return pyramid_app_with_cleanup
392 388
393 389
394 390 def sanitize_settings_and_apply_defaults(settings):
395 391 """
396 392 Applies settings defaults and does all type conversion.
397 393
398 394 We would move all settings parsing and preparation into this place, so that
399 395 we have only one place left which deals with this part. The remaining parts
400 396 of the application would start to rely fully on well prepared settings.
401 397
402 398 This piece would later be split up per topic to avoid a big fat monster
403 399 function.
404 400 """
405 401
406 402 # Pyramid's mako renderer has to search in the templates folder so that the
407 403 # old templates still work. Ported and new templates are expected to use
408 404 # real asset specifications for the includes.
409 405 mako_directories = settings.setdefault('mako.directories', [
410 406 # Base templates of the original Pylons application
411 407 'rhodecode:templates',
412 408 ])
413 409 log.debug(
414 410 "Using the following Mako template directories: %s",
415 411 mako_directories)
416 412
417 413 # Default includes, possible to change as a user
418 414 pyramid_includes = settings.setdefault('pyramid.includes', [
419 415 'rhodecode.lib.middleware.request_wrapper',
420 416 ])
421 417 log.debug(
422 418 "Using the following pyramid.includes: %s",
423 419 pyramid_includes)
424 420
425 421 # TODO: johbo: Re-think this, usually the call to config.include
426 422 # should allow to pass in a prefix.
427 423 settings.setdefault('rhodecode.api.url', '/_admin/api')
428 424
429 425 # Sanitize generic settings.
430 426 _list_setting(settings, 'default_encoding', 'UTF-8')
431 427 _bool_setting(settings, 'is_test', 'false')
432 428 _bool_setting(settings, 'gzip_responses', 'false')
433 429
434 430 # Call split out functions that sanitize settings for each topic.
435 431 _sanitize_appenlight_settings(settings)
436 432 _sanitize_vcs_settings(settings)
437 433
438 434 return settings
439 435
440 436
441 437 def _sanitize_appenlight_settings(settings):
442 438 _bool_setting(settings, 'appenlight', 'false')
443 439
444 440
445 441 def _sanitize_vcs_settings(settings):
446 442 """
447 443 Applies settings defaults and does type conversion for all VCS related
448 444 settings.
449 445 """
450 446 _string_setting(settings, 'vcs.svn.compatible_version', '')
451 447 _string_setting(settings, 'git_rev_filter', '--all')
452 448 _string_setting(settings, 'vcs.hooks.protocol', 'http')
453 449 _string_setting(settings, 'vcs.scm_app_implementation', 'http')
454 450 _string_setting(settings, 'vcs.server', '')
455 451 _string_setting(settings, 'vcs.server.log_level', 'debug')
456 452 _string_setting(settings, 'vcs.server.protocol', 'http')
457 453 _bool_setting(settings, 'startup.import_repos', 'false')
458 454 _bool_setting(settings, 'vcs.hooks.direct_calls', 'false')
459 455 _bool_setting(settings, 'vcs.server.enable', 'true')
460 456 _bool_setting(settings, 'vcs.start_server', 'false')
461 457 _list_setting(settings, 'vcs.backends', 'hg, git, svn')
462 458 _int_setting(settings, 'vcs.connection_timeout', 3600)
463 459
464 460 # Support legacy values of vcs.scm_app_implementation. Legacy
465 461 # configurations may use 'rhodecode.lib.middleware.utils.scm_app_http'
466 462 # which is now mapped to 'http'.
467 463 scm_app_impl = settings['vcs.scm_app_implementation']
468 464 if scm_app_impl == 'rhodecode.lib.middleware.utils.scm_app_http':
469 465 settings['vcs.scm_app_implementation'] = 'http'
470 466
471 467
472 468 def _int_setting(settings, name, default):
473 469 settings[name] = int(settings.get(name, default))
474 470
475 471
476 472 def _bool_setting(settings, name, default):
477 473 input = settings.get(name, default)
478 474 if isinstance(input, unicode):
479 475 input = input.encode('utf8')
480 476 settings[name] = asbool(input)
481 477
482 478
483 479 def _list_setting(settings, name, default):
484 480 raw_value = settings.get(name, default)
485 481
486 482 old_separator = ','
487 483 if old_separator in raw_value:
488 484 # If we get a comma separated list, pass it to our own function.
489 485 settings[name] = rhodecode_aslist(raw_value, sep=old_separator)
490 486 else:
491 487 # Otherwise we assume it uses pyramids space/newline separation.
492 488 settings[name] = aslist(raw_value)
493 489
494 490
495 491 def _string_setting(settings, name, default, lower=True):
496 492 value = settings.get(name, default)
497 493 if lower:
498 494 value = value.lower()
499 495 settings[name] = value
General Comments 0
You need to be logged in to leave comments. Login now