exception.py 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185
  1. import logging
  2. import sys
  3. from functools import wraps
  4. from asgiref.sync import iscoroutinefunction, sync_to_async
  5. from django.conf import settings
  6. from django.core import signals
  7. from django.core.exceptions import (
  8. BadRequest,
  9. PermissionDenied,
  10. RequestDataTooBig,
  11. SuspiciousOperation,
  12. TooManyFieldsSent,
  13. TooManyFilesSent,
  14. )
  15. from django.http import Http404
  16. from django.http.multipartparser import MultiPartParserError
  17. from django.urls import get_resolver, get_urlconf
  18. from django.utils.log import log_response
  19. from django.views import debug
  20. def convert_exception_to_response(get_response):
  21. """
  22. Wrap the given get_response callable in exception-to-response conversion.
  23. All exceptions will be converted. All known 4xx exceptions (Http404,
  24. PermissionDenied, MultiPartParserError, SuspiciousOperation) will be
  25. converted to the appropriate response, and all other exceptions will be
  26. converted to 500 responses.
  27. This decorator is automatically applied to all middleware to ensure that
  28. no middleware leaks an exception and that the next middleware in the stack
  29. can rely on getting a response instead of an exception.
  30. """
  31. if iscoroutinefunction(get_response):
  32. @wraps(get_response)
  33. async def inner(request):
  34. try:
  35. response = await get_response(request)
  36. except Exception as exc:
  37. response = await sync_to_async(
  38. response_for_exception, thread_sensitive=False
  39. )(request, exc)
  40. return response
  41. return inner
  42. else:
  43. @wraps(get_response)
  44. def inner(request):
  45. try:
  46. response = get_response(request)
  47. except Exception as exc:
  48. response = response_for_exception(request, exc)
  49. return response
  50. return inner
  51. def response_for_exception(request, exc):
  52. if isinstance(exc, Http404):
  53. if settings.DEBUG:
  54. response = debug.technical_404_response(request, exc)
  55. else:
  56. response = get_exception_response(
  57. request, get_resolver(get_urlconf()), 404, exc
  58. )
  59. elif isinstance(exc, PermissionDenied):
  60. response = get_exception_response(
  61. request, get_resolver(get_urlconf()), 403, exc
  62. )
  63. log_response(
  64. "Forbidden (Permission denied): %s",
  65. request.path,
  66. response=response,
  67. request=request,
  68. exception=exc,
  69. )
  70. elif isinstance(exc, MultiPartParserError):
  71. response = get_exception_response(
  72. request, get_resolver(get_urlconf()), 400, exc
  73. )
  74. log_response(
  75. "Bad request (Unable to parse request body): %s",
  76. request.path,
  77. response=response,
  78. request=request,
  79. exception=exc,
  80. )
  81. elif isinstance(exc, BadRequest):
  82. if settings.DEBUG:
  83. response = debug.technical_500_response(
  84. request, *sys.exc_info(), status_code=400
  85. )
  86. else:
  87. response = get_exception_response(
  88. request, get_resolver(get_urlconf()), 400, exc
  89. )
  90. log_response(
  91. "%s: %s",
  92. str(exc),
  93. request.path,
  94. response=response,
  95. request=request,
  96. exception=exc,
  97. )
  98. elif isinstance(exc, SuspiciousOperation):
  99. if isinstance(exc, (RequestDataTooBig, TooManyFieldsSent, TooManyFilesSent)):
  100. # POST data can't be accessed again, otherwise the original
  101. # exception would be raised.
  102. request._mark_post_parse_error()
  103. # The request logger receives events for any problematic request
  104. # The security logger receives events for all SuspiciousOperations
  105. security_logger = logging.getLogger(
  106. "django.security.%s" % exc.__class__.__name__
  107. )
  108. security_logger.error(
  109. str(exc),
  110. exc_info=exc,
  111. extra={"status_code": 400, "request": request},
  112. )
  113. if settings.DEBUG:
  114. response = debug.technical_500_response(
  115. request, *sys.exc_info(), status_code=400
  116. )
  117. else:
  118. response = get_exception_response(
  119. request, get_resolver(get_urlconf()), 400, exc
  120. )
  121. else:
  122. signals.got_request_exception.send(sender=None, request=request)
  123. response = handle_uncaught_exception(
  124. request, get_resolver(get_urlconf()), sys.exc_info()
  125. )
  126. log_response(
  127. "%s: %s",
  128. response.reason_phrase,
  129. request.path,
  130. response=response,
  131. request=request,
  132. exception=exc,
  133. )
  134. # Force a TemplateResponse to be rendered.
  135. if not getattr(response, "is_rendered", True) and callable(
  136. getattr(response, "render", None)
  137. ):
  138. response = response.render()
  139. return response
  140. def get_exception_response(request, resolver, status_code, exception):
  141. try:
  142. callback = resolver.resolve_error_handler(status_code)
  143. response = callback(request, exception=exception)
  144. except Exception:
  145. signals.got_request_exception.send(sender=None, request=request)
  146. response = handle_uncaught_exception(request, resolver, sys.exc_info())
  147. return response
  148. def handle_uncaught_exception(request, resolver, exc_info):
  149. """
  150. Processing for any otherwise uncaught exceptions (those that will
  151. generate HTTP 500 responses).
  152. """
  153. if settings.DEBUG_PROPAGATE_EXCEPTIONS:
  154. raise
  155. if settings.DEBUG:
  156. return debug.technical_500_response(request, *exc_info)
  157. # Return an HttpResponse that displays a friendly error message.
  158. callback = resolver.resolve_error_handler(500)
  159. return callback(request)