Update app.py

app.py

@@ -100,10 +100,6 @@ h1{{color:#4a90d9;}} .ok{{color:#00ff88;}} .info{{color:#888;font-size:13px;}}</
 </body></html>"""
 
 active_connections: list[WebSocket] = []
-stream_active = False
-stream_fps = 3
-stream_quality = 60
-stream_scale = 0.5
 
 # ─── CURL HEADERS ────────────────────────────────────
 CURL_HEADERS = (
@@ -496,7 +492,25 @@ def capture_screen_with_grid(scale=0.65, quality=72,
 
 # ─── Command Runner ──────────────────────────────────
 
+_PKILL_SELF_MATCH_RE = re.compile(r"\b(pkill|killall)\s+(-9\s+)?-f\s+(['\"]?)([a-zA-Z0-9_./-]+)\3")
+
+def _sanitize_pkill_self_match(cmd: str) -> str:
+    """
+    يحوّل أنماط pkill -f الخطيرة (مثل: pkill -f firefox) إلى صيغة آمنة
+    لا تطابق سطر الأمر الخاص بـ pkill نفسه — لأن pkill -f يبحث في كامل سطر
+    الأمر لكل العمليات، فيُطابق سطره الخاص ويقتل نفسه، فيُعيد returncode=-15
+    وكأن الأمر "فشل" بينما هو فعلياً نجح (أو لم يكن هناك شيء لقتله من الأساس).
+    """
+    def _fix(m):
+        tool, dash9, _q, pattern = m.group(1), m.group(2) or "", m.group(3), m.group(4)
+        # استبعد سطر أمر pkill/killall نفسه من المطابقة بإضافة [^k]
+        safe_pattern = f"[{pattern[0]}]{pattern[1:]}" if len(pattern) > 1 else pattern
+        return f"{tool} {dash9}-f '{safe_pattern}'"
+    return _PKILL_SELF_MATCH_RE.sub(_fix, cmd)
+
+
 def run_raw_command(cmd: str, timeout: int = 60) -> dict:
+    cmd = _sanitize_pkill_self_match(cmd)
     env = {**os.environ, "DISPLAY": DISPLAY,
            "PYTHONIOENCODING": "utf-8", "LANG": "en_US.UTF-8"}
     try:
@@ -758,19 +772,6 @@ async def broadcast(msg: dict):
             active_connections.remove(ws)
 
 
-async def screen_stream_loop():
-    global stream_active
-    interval = 1.0 / max(1, stream_fps)
-    while stream_active and active_connections:
-        try:
-            frame = capture_screen(scale=stream_scale, quality=stream_quality)
-            if frame:
-                await broadcast({"type": "frame", "data": frame})
-        except: pass
-        await asyncio.sleep(interval)
-    stream_active = False
-
-
 # ─── Action Handler ──────────────────────────────────
 
 async def handle_action(ws: WebSocket, msg: dict):
@@ -997,21 +998,8 @@ async def handle_action(ws: WebSocket, msg: dict):
         # cursor ينتهي عند x2,y2
         await auto_shot_grid("بعد السحب", delay=0.4, force_mx=x2, force_my=y2)
 
-    # ── start_stream ──────────────────────────────────
-    elif action == "start_stream":
-        global stream_active, stream_fps, stream_quality, stream_scale
-        stream_fps = int(data.get("fps", 3))
-        stream_quality = int(data.get("quality", 60))
-        stream_scale = float(data.get("scale", 0.5))
-        if not stream_active:
-            stream_active = True
-            asyncio.create_task(screen_stream_loop())
-        await send({"type": "ack", "action": "start_stream"})
-
-    # ── stop_stream ───────────────────────────────────
-    elif action == "stop_stream":
-        stream_active = False
-        await send({"type": "ack", "action": "stop_stream"})
+    # ── start_stream / stop_stream: غير مستخدمة من الواجهة الحالية، أُزيلت لمنع
+    # تشغيل حلقة تصوير مستمرة في الخلفية بلا داعٍ (كانت تستهلك موارد حتى بعد إغلاق الاتصال) ──
 
     # ── screen_info ───────────────────────────────────
     elif action == "screen_info":
@@ -1045,7 +1033,7 @@ async def handle_action(ws: WebSocket, msg: dict):
     else:
         await send({
             "type": "error",
-            "msg": f"Unknown action: '{action}'. Available: screenshot, terminal, mouse_move, mouse_click, mouse_drag, keyboard_type, keyboard_hotkey, keyboard_press, clipboard_write, clipboard_read, scroll, open_app, open_browser, paste, simple_command, screen_info, start_stream, stop_stream"
+            "msg": f"Unknown action: '{action}'. Available: screenshot, terminal, mouse_move, mouse_click, mouse_drag, keyboard_type, keyboard_hotkey, keyboard_press, clipboard_write, clipboard_read, scroll, open_app, open_browser, paste, simple_command, screen_info"
         })