|
1 | 1 | import dataclasses |
| 2 | +import logging |
2 | 3 | import types |
3 | 4 | from typing import Type |
4 | 5 |
|
|
12 | 13 | from .requests import PreparedRequestHook, RequestHook, ResponseHook |
13 | 14 |
|
14 | 15 |
|
15 | | -class RequestDebugLoggingHook(RequestHook): |
16 | | - formatter = "Request {req.method} {req.url} {req.data}" |
| 16 | +class BaseLogging: |
| 17 | + formatter = None |
| 18 | + logging_level = logging.NOTSET |
17 | 19 |
|
18 | | - def run(self, request: Request) -> Request: |
| 20 | + def get_formatter(self, data): |
19 | 21 | formatter = self.formatter |
20 | | - if request.name: |
21 | | - formatter = self.formatter.replace("req.url", "req.name", 1) |
22 | | - Logging.logger.debug(formatter.format(req=request)) |
| 22 | + if getattr(data, "name"): |
| 23 | + formatter = self.formatter.replace("data.url", "data.name", 1) |
| 24 | + return formatter |
| 25 | + |
| 26 | + def log(self, data): |
| 27 | + Logging.logger.log( |
| 28 | + self.logging_level, self.get_formatter(data).format(data=data) |
| 29 | + ) |
| 30 | + |
| 31 | + |
| 32 | +class RequestDebugLoggingHook(RequestHook, BaseLogging): |
| 33 | + formatter = "Request {data.method} {data.url} {data.data}" |
| 34 | + logging_level = logging.DEBUG |
| 35 | + |
| 36 | + def run(self, request: Request) -> Request: |
| 37 | + self.log(request) |
23 | 38 | return request |
24 | 39 |
|
25 | 40 |
|
26 | | -class RequestInfoLoggingHook(RequestHook): |
27 | | - formatter = "Request {req.method} {req.url} {req.data}" |
| 41 | +class RequestInfoLoggingHook(RequestHook, BaseLogging): |
| 42 | + formatter = "Request {data.method} {data.url} {data.data}" |
| 43 | + logging_level = logging.INFO |
28 | 44 |
|
29 | 45 | def run(self, request: Request) -> Request: |
30 | | - formatter = self.formatter |
31 | | - if request.name: |
32 | | - formatter = self.formatter.replace("req.url", "req.name", 1) |
33 | | - Logging.logger.info(formatter.format(req=request)) |
| 46 | + self.log(request) |
34 | 47 | return request |
35 | 48 |
|
36 | 49 |
|
37 | | -class PrepRequestDebugLoggingHook(PreparedRequestHook): |
38 | | - formatter = "Request {req.method} {req.url} {req.body}" |
| 50 | +class PrepRequestDebugLoggingHook(PreparedRequestHook, BaseLogging): |
| 51 | + formatter = "Request {data.method} {data.url} {data.body}" |
| 52 | + logging_level = logging.DEBUG |
39 | 53 |
|
40 | 54 | def run(self, request: PreparedRequest) -> PreparedRequest: |
41 | | - formatter = self.formatter |
42 | | - if request.name: |
43 | | - formatter = self.formatter.replace("req.url", "req.name", 1) |
44 | | - Logging.logger.debug(formatter.format(req=request)) |
| 55 | + self.log(request) |
45 | 56 | return request |
46 | 57 |
|
47 | 58 |
|
48 | | -class PrepRequestInfoLoggingHook(PreparedRequestHook): |
49 | | - formatter = "Request {req.method} {req.url} {req.body}" |
| 59 | +class PrepRequestInfoLoggingHook(PreparedRequestHook, BaseLogging): |
| 60 | + formatter = "Request {data.method} {data.url} {data.body}" |
| 61 | + logging_level = logging.INFO |
50 | 62 |
|
51 | 63 | def run(self, request: PreparedRequest) -> PreparedRequest: |
52 | | - formatter = self.formatter |
53 | | - if request.name: |
54 | | - formatter = self.formatter.replace("req.url", "req.name", 1) |
55 | | - Logging.logger.info(formatter.format(req=request)) |
| 64 | + self.log(request) |
56 | 65 | return request |
57 | 66 |
|
58 | 67 |
|
59 | | -class ResponseDebugLoggingHook(ResponseHook): |
| 68 | +class ResponseDebugLoggingHook(ResponseHook, BaseLogging): |
60 | 69 | formatter = ( |
61 | | - "Response {res.status_code} {res.request.method} " |
62 | | - "{res.url} {res.content}" |
| 70 | + "Response {data.status_code} {data.request.method} " |
| 71 | + "{data.url} {data.content}" |
63 | 72 | ) |
| 73 | + logging_level = logging.DEBUG |
64 | 74 |
|
65 | 75 | def run(self, response: Response) -> Response: |
66 | | - formatter = self.formatter |
67 | | - if response.name: |
68 | | - formatter = self.formatter.replace("res.url", "res.name", 1) |
69 | | - Logging.logger.debug(formatter.format(res=response)) |
| 76 | + self.log(response) |
70 | 77 | return response |
71 | 78 |
|
72 | 79 |
|
73 | | -class ResponseInfoLoggingHook(ResponseHook): |
| 80 | +class ResponseInfoLoggingHook(ResponseHook, BaseLogging): |
74 | 81 | formatter = ( |
75 | | - "Response {res.status_code} {res.request.method} " |
76 | | - "{res.url} {res.content}" |
| 82 | + "Response {data.status_code} {data.request.method} " |
| 83 | + "{data.url} {data.content}" |
77 | 84 | ) |
| 85 | + logging_level = logging.INFO |
78 | 86 |
|
79 | 87 | def run(self, response: Response) -> Response: |
80 | | - formatter = self.formatter |
81 | | - if response.name: |
82 | | - formatter = self.formatter.replace("res.url", "res.name", 1) |
83 | | - Logging.logger.info(formatter.format(res=response)) |
| 88 | + self.log(response) |
84 | 89 | return response |
85 | 90 |
|
86 | 91 |
|
|
0 commit comments