@@ -21,31 +21,27 @@ class AioHttpPyctuator(PyctuatorRouter):
21
21
def __init__ (self , app : web .Application , pyctuator_impl : PyctuatorImpl , disabled_endpoints : Endpoints ) -> None :
22
22
super ().__init__ (app , pyctuator_impl )
23
23
24
- custom_dumps = partial (
25
- json .dumps , default = self ._custom_json_serializer
26
- )
27
-
28
24
async def empty_handler (request : web .Request ) -> web .Response :
29
25
return web .Response (text = '' )
30
26
31
27
async def get_endpoints (request : web .Request ) -> web .Response :
32
- return web .json_response (self .get_endpoints_data (), dumps = custom_dumps )
28
+ return web .json_response (self .get_endpoints_data )
33
29
34
30
async def get_environment (request : web .Request ) -> web .Response :
35
- return web .json_response (pyctuator_impl .get_environment (), dumps = custom_dumps )
31
+ return web .json_response (pyctuator_impl .get_environment )
36
32
37
33
async def get_info (request : web .Request ) -> web .Response :
38
- return web .json_response (pyctuator_impl .get_app_info (), dumps = custom_dumps )
34
+ return web .json_response (pyctuator_impl .get_app_info )
39
35
40
36
async def get_health (request : web .Request ) -> web .Response :
41
37
health = pyctuator_impl .get_health ()
42
- return web .json_response (health , status = health .http_status (), dumps = custom_dumps )
38
+ return web .json_response (health , status = health .http_status )
43
39
44
40
async def get_metric_names (request : web .Request ) -> web .Response :
45
- return web .json_response (pyctuator_impl .get_metric_names (), dumps = custom_dumps )
41
+ return web .json_response (pyctuator_impl .get_metric_names )
46
42
47
43
async def get_loggers (request : web .Request ) -> web .Response :
48
- return web .json_response (pyctuator_impl .logging .get_loggers (), dumps = custom_dumps )
44
+ return web .json_response (pyctuator_impl .logging .get_loggers )
49
45
50
46
async def set_logger_level (request : web .Request ) -> web .Response :
51
47
request_dict = await request .json ()
@@ -60,7 +56,7 @@ async def get_logger(request: web.Request) -> web.Response:
60
56
return web .json_response (pyctuator_impl .logging .get_logger (logger_name ), dumps = custom_dumps )
61
57
62
58
async def get_thread_dump (request : web .Request ) -> web .Response :
63
- return web .json_response (pyctuator_impl .get_thread_dump (), dumps = custom_dumps )
59
+ return web .json_response (pyctuator_impl .get_thread_dump )
64
60
65
61
async def get_httptrace (request : web .Request ) -> web .Response :
66
62
raw_data = pyctuator_impl .http_tracer .get_httptrace ()
@@ -153,14 +149,6 @@ async def intercept_requests_and_responses(request: web.Request, handler: Callab
153
149
app .add_routes (routes )
154
150
app .middlewares .append (intercept_requests_and_responses )
155
151
156
- def _custom_json_serializer (self , value : Any ) -> Any :
157
- if dataclasses .is_dataclass (value ):
158
- return dataclasses .asdict (value )
159
-
160
- if isinstance (value , datetime ):
161
- return str (value )
162
- return None
163
-
164
152
def _create_headers_dictionary (self , headers : CIMultiDictProxy [str ]) -> Mapping [str , List [str ]]:
165
153
headers_dict : Mapping [str , List [str ]] = defaultdict (list )
166
154
for (key , value ) in headers .items ():
0 commit comments