Update app.py

app.py

@@ -941,19 +941,15 @@ async def handle_action(ws: WebSocket, msg: dict, sess: dict):
 
     async def _safe_capture(scale, quality, force_mx=None, force_my=None):
         """
-        تُستخدم من shot_bg (التلقائية) — تنتظر القفل بسقف زمني 25 ثانية لتفادي
-        تراكم عدة عمليات capture تلقائية فوق بعضها.
+        تُستخدم من shot_bg (التلقائية) — تنتظر القفل ثم تنتظر التقاط الشاشة
+        حتى ينتهي فعلياً، بدون أي سقف زمني يقطعها. هذا يضمن أن العملية لن
+        تُقطع أبداً في منتصفها وتُرجع فراغاً؛ ستكمل حتى تنجح (أو تفشل كل
+        المحاولات الداخلية في capture_with_grid وتُرجع placeholder صريح).
         """
-        async def _do_capture():
-            async with _shot_lock:
-                return await asyncio.to_thread(
-                    capture_with_grid, display, scale, quality, force_mx, force_my
-                )
-        try:
-            return await asyncio.wait_for(_do_capture(), timeout=25)
-        except asyncio.TimeoutError:
-            print(f"[shot:{display}] ⚠️ capture timed out after 25s — skipping this frame")
-            return {"data": "", "width": 1920, "height": 1080, "mouse_x": 0, "mouse_y": 0}
+        async with _shot_lock:
+            return await asyncio.to_thread(
+                capture_with_grid, display, scale, quality, force_mx, force_my
+            )
 
     async def _priority_capture(scale, quality, force_mx=None, force_my=None):
         """
@@ -961,27 +957,23 @@ async def handle_action(ws: WebSocket, msg: dict, sess: dict):
         تحاول الحصول على القفل لمدة قصيرة (1 ثانية) فقط؛ إن لم تنجح (القفل
         محجوز من shot_bg تلقائية بطيئة)، تُنفَّذ التصوير فوراً بدون قفل بدل
         الانتظار خلف عملية أخرى — العميل يجب أن يحصل على رد سريع دائماً.
+        بعد الحصول على القفل (أو تجاوزه)، لا يوجد أي سقف زمني على عملية
+        الالتقاط نفسها — تنتظر حتى تكتمل فعلياً بدل أن تُقطع في المنتصف.
         """
         try:
             await asyncio.wait_for(_shot_lock.acquire(), timeout=1.0)
             try:
-                return await asyncio.wait_for(
-                    asyncio.to_thread(capture_with_grid, display, scale, quality, force_mx, force_my),
-                    timeout=20
+                return await asyncio.to_thread(
+                    capture_with_grid, display, scale, quality, force_mx, force_my
                 )
             finally:
                 _shot_lock.release()
         except asyncio.TimeoutError:
-            # لم نحصل على القفل بسرعة كافية، أو انتهت مهلة التصوير نفسه —
-            # ننفّذ التصوير مباشرة بدون قفل بدل ترك العميل بلا رد إطلاقاً
-            try:
-                return await asyncio.wait_for(
-                    asyncio.to_thread(capture_with_grid, display, scale, quality, force_mx, force_my),
-                    timeout=20
-                )
-            except asyncio.TimeoutError:
-                print(f"[shot:{display}] ⚠️ priority capture timed out — skipping this frame")
-                return {"data": "", "width": 1920, "height": 1080, "mouse_x": 0, "mouse_y": 0}
+            # لم نحصل على القفل بسرعة كافية — ننفّذ التصوير مباشرة بدون قفل
+            # بدل الانتظار خلف عملية أخرى، لكن بدون أي سقف زمني على الالتقاط
+            return await asyncio.to_thread(
+                capture_with_grid, display, scale, quality, force_mx, force_my
+            )
 
     async def shot_bg(label: str = "", delay: float = 0.5,
                       force_mx: int | None = None, force_my: int | None = None,