File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -114,11 +114,12 @@ async def checkup(req: Request):
114114 "answer_last_message" : req .app .state .websocket_client .answer_last_message ,
115115 "no_answer_last_message_time" : req .app .state .websocket_client .no_answer_last_message_time ,
116116 "no_answer_last_message" : req .app .state .websocket_client .no_answer_last_message ,
117- "last_connected_time" : req .app .state .websocket_client .last_connected_time ,
118117 "last_try_connected_time" : req .app .state .websocket_client .last_try_connected_time ,
118+ "last_connected_time" : req .app .state .websocket_client .last_connected_time ,
119119 "connected" : req .app .state .websocket_client .connected ,
120120 "disconnected_time" : req .app .state .websocket_client .disconnected_time ,
121121 "disconnected_reason" : req .app .state .websocket_client .disconnected_reason ,
122+ "disconnect_count" : req .app .state .websocket_client .disconnect_count ,
122123 }
123124 if not req .app .state .websocket_client .connected :
124125 result ["status" ]["checkup_websocket" ] = "error"
Original file line number Diff line number Diff line change @@ -32,6 +32,7 @@ class WebsocketEvents:
3232 connected = False
3333 disconnected_reason = ""
3434 disconnected_time = ""
35+ disconnect_count = 0
3536
3637 def __init__ (
3738 self ,
@@ -220,6 +221,7 @@ async def start_consumer(self):
220221 except Exception as exc :
221222 log .exception ("Unknown start_consumer error: %s" , exc )
222223 self .connected = False
224+ self .disconnect_count += 1
223225 self .disconnected_reason = str (exc )
224226 self .disconnected_time = str (datetime .datetime .now ())
225227 await asyncio .sleep (self .timeout )
You can’t perform that action at this time.
0 commit comments