diff --git a/sentry_sdk/integrations/starlette.py b/sentry_sdk/integrations/starlette.py index dbb47dff58..d0f0bf2045 100644 --- a/sentry_sdk/integrations/starlette.py +++ b/sentry_sdk/integrations/starlette.py @@ -3,6 +3,7 @@ import warnings from collections.abc import Set from copy import deepcopy +from json import JSONDecodeError import sentry_sdk from sentry_sdk.consts import OP @@ -680,8 +681,10 @@ async def json(self): # type: (StarletteRequestExtractor) -> Optional[Dict[str, Any]] if not self.is_json(): return None - - return await self.request.json() + try: + return await self.request.json() + except JSONDecodeError: + return None def _transaction_name_from_router(scope): diff --git a/tests/integrations/starlette/test_starlette.py b/tests/integrations/starlette/test_starlette.py index 3289f69ed6..bc445bf8f2 100644 --- a/tests/integrations/starlette/test_starlette.py +++ b/tests/integrations/starlette/test_starlette.py @@ -1354,3 +1354,28 @@ async def _error(_): client.get("/error") assert len(events) == int(expected_error) + + +@pytest.mark.asyncio +async def test_starletterequestextractor_malformed_json_error_handling(sentry_init): + scope = SCOPE.copy() + scope["headers"] = [ + [b"content-type", b"application/json"], + ] + starlette_request = starlette.requests.Request(scope) + + malformed_json = "{invalid json" + malformed_messages = [ + {"type": "http.request", "body": malformed_json.encode("utf-8")}, + {"type": "http.disconnect"}, + ] + + side_effect = [_mock_receive(msg) for msg in malformed_messages] + starlette_request._receive = mock.Mock(side_effect=side_effect) + + extractor = StarletteRequestExtractor(starlette_request) + + assert extractor.is_json() + + result = await extractor.json() + assert result is None