fix job remove

bot/websocket_helper.py

@@ -443,8 +443,15 @@ async def run_forever_async(self):
             try:
                 self._ws = websocket
                 self._scheduler.add_job(self.reshedule, "interval", seconds=2, id="ws_reschedule", replace_existing=True)
-                async for message in self._ws:
-                    await self.websocket_to_message(message)
+                # async for message in self._ws:
+                #     await self.websocket_to_message(message)
+
+                while True:
+                    res = await self._ws.recv(decode=False)
+                    await self.websocket_to_message(res)
+
             except Exception as ex:
+                # Todo: add some TG notification?
                 logger.error(ex)
-                self._scheduler.remove_job("ws_reschedule")
+                if self._scheduler.get_job("ws_reschedule"):
+                    self._scheduler.remove_job("ws_reschedule")

scripts/requirements.txt

@@ -9,4 +9,4 @@ psutil==6.1.0
 python-telegram-bot[socks,http2,rate-limiter,callback-data,job-queue]==21.7
 tzlocal==2.1
 uvloop==0.20.0 ; platform_system != "Windows"
-websockets==13.1
+websockets==14.0