Skip to content
This repository was archived by the owner on Aug 23, 2024. It is now read-only.

Commit 384eda0

Browse files
Add async def async_on_request_complete to RequestResponseDTOBase class
More information, see bobbui#84 With this patch, I can execute await self._request.body()
1 parent 5769f51 commit 384eda0

File tree

2 files changed

+4
-1
lines changed

2 files changed

+4
-1
lines changed

json_logging/dto.py

+3
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,9 @@ def on_request_complete(self, response):
2424
"""
2525
self._response = response
2626

27+
async def async_on_request_complete(self, response):
28+
self.on_request_complete(response)
29+
2730

2831
class DefaultRequestResponseDTO(RequestResponseDTOBase):
2932
"""

json_logging/framework/fastapi/implementation.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ async def dispatch(self, request: Request, call_next: RequestResponseEndpoint) -
3434

3535
request_response_data = _request_config_class(request)
3636
response = await call_next(request)
37-
request_response_data.on_request_complete(response)
37+
await request_response_data.async_on_request_complete(response)
3838
self.request_logger.info(
3939
"", extra={"request_response_data": request_response_data, "type": "request"}
4040
)

0 commit comments

Comments
 (0)