Update app.py

app.py

@@ -765,8 +765,10 @@ async def handle_action(ws: WebSocket, msg: dict):
         بدلاً من إعادة قراءته من X server — يُصلح race condition.
         """
         await asyncio.sleep(delay)
-        result = capture_screen_with_grid(scale=0.65, quality=72,
-                                          force_mx=force_mx, force_my=force_my)
+        # ── يعمل في thread منفصل حتى لا يُجمّد حلقة asyncio ──
+        result = await asyncio.to_thread(
+            capture_screen_with_grid, scale=0.65, quality=72,
+            force_mx=force_mx, force_my=force_my)
         if result["data"]:
             await send({
                 "type": "screenshot",
@@ -784,7 +786,7 @@ async def handle_action(ws: WebSocket, msg: dict):
 
     # ── screenshot ────────────────────────────────────
     if action == "screenshot":
-        result = capture_screen_with_grid(scale=0.65, quality=75)
+        result = await asyncio.to_thread(capture_screen_with_grid, scale=0.65, quality=75)
         await send({
             "type": "screenshot",
             "data": result["data"],
@@ -823,7 +825,7 @@ async def handle_action(ws: WebSocket, msg: dict):
             await send({"type": "terminal_result", "cmd": "", "stdout": "",
                         "stderr": "no command", "returncode": -1})
             return
-        res = run_command_smart(cmd, timeout=timeout)
+        res = await asyncio.to_thread(run_command_smart, cmd, timeout)
         await send({
             "type": "terminal_result",
             "cmd": cmd,
@@ -1040,7 +1042,7 @@ async def websocket_endpoint(ws: WebSocket):
         ]
     }, ensure_ascii=False))
     # أرسل screenshot أولية مع grid
-    result = capture_screen_with_grid(scale=0.65, quality=72)
+    result = await asyncio.to_thread(capture_screen_with_grid, scale=0.65, quality=72)
     if result["data"]:
         await ws.send_text(json.dumps({
             "type": "screenshot",