Skip to content

Commit aa34daf

Browse files
committed
fix: ws on error 无法重新连接
1 parent 446c7ae commit aa34daf

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

botpy/gateway.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,7 @@ def __init__(self, session: Session, _connection: ConnectionSession):
5050
async def on_error(self, exception: BaseException):
5151
_log.error("[botpy] websocket连接: %s, 异常信息 : %s" % (self._conn, exception))
5252
traceback.print_exc()
53+
self._connection.add(self._session)
5354

5455
async def on_closed(self, close_status_code, close_msg):
5556
_log.info("[botpy] 关闭, 返回码: %s" % close_status_code + ", 返回信息: %s" % close_msg)
@@ -126,6 +127,7 @@ async def ws_connect(self):
126127
await self.on_message(ws_conn, msg.data)
127128
elif msg.type == WSMsgType.ERROR:
128129
await self.on_error(ws_conn.exception())
130+
await ws_conn.close()
129131
elif msg.type == WSMsgType.CLOSED or msg.type == WSMsgType.CLOSE:
130132
await self.on_closed(ws_conn.close_code, msg.extra)
131133
if ws_conn.closed:

0 commit comments

Comments
 (0)