Update app.py

app.py

@@ -201,6 +201,22 @@ def execute_tool(name: str, inp: Dict[str, Any]) -> str:
 # G4F CALL  —  sync، يُشغَّل في thread pool
 # =========================================================
 
+def _is_invalid_response(text: str) -> bool:
+    """تحليل النص والتحقق مما إذا كان يمثل رسالة خطأ داخلية من g4f أو HTML تالف."""
+    if not text or len(text) <= 2:
+        return True
+    lower_text = text.lower()
+    if "choices" in lower_text and "nonetype" in lower_text:
+        return True
+    if "object has no attribute" in lower_text:
+        return True
+    if "color-red-500" in lower_text or "var(--color-red-500)" in lower_text:
+        return True
+    if "error" in lower_text and "style=" in lower_text:
+        return True
+    return False
+
+
 def _g4f_call_sync(messages: List[Dict], target_model: str) -> str:
     """
     محاولة g4f مع كل providers بالترتيب.
@@ -208,7 +224,9 @@ def _g4f_call_sync(messages: List[Dict], target_model: str) -> str:
     """
     mapped = CLAUDE_TO_G4F.get(target_model, target_model)
 
+    # ── 1. محاولة استخدام السلسلة المحددة للمزودين أولاً ──
     for pobj, pmodels in PROVIDER_CHAIN:
+        pname = pobj.__name__ if hasattr(pobj, "__name__") else type(pobj).__name__
         try_models = [mapped] + [m for m in pmodels if m != mapped]
 
         for model in try_models[:4]:  # max 4 per provider
@@ -225,28 +243,47 @@ def _g4f_call_sync(messages: List[Dict], target_model: str) -> str:
                     text = str(result or "")
                 text = text.strip()
 
-                # ── التعديل الجراحي: كشف وتصفية استجابات الخطأ الوهمية ──
-                lower_text = text.lower()
-                if (
-                    not text or 
-                    len(text) <= 2 or 
-                    ("choices" in lower_text and "nonetype" in lower_text) or
-                    "object has no attribute" in lower_text or
-                    "color-red-500" in lower_text or
-                    "var(--color-red-500)" in lower_text
-                ):
-                    logger.warning("Rejected invalid/error response from provider %s (model: %s): %s", 
-                                   type(pobj).__name__, model, text[:150])
-                    continue  # تخطي هذا المزود فوراً وجرب التالي في السلسلة
+                # التحقق الجراحي من الاستجابة التالفة
+                if _is_invalid_response(text):
+                    logger.warning("Rejected invalid response from provider %s (model: %s): %s", 
+                                   pname, model, text[:150])
+                    continue
 
                 logger.info("Success: provider=%s model=%s len=%d",
-                            type(pobj).__name__, model, len(text))
+                            pname, model, len(text))
                 return text
             except Exception as e:
-                logger.debug("Failed %s/%s: %s", type(pobj).__name__, model, e)
+                logger.debug("Failed %s/%s: %s", pname, model, e)
                 continue
 
-    raise RuntimeError("All providers failed")
+    # ── 2. الإنقاذ التلقائي الفوري (Auto-Routing Fallback) في حال تعطل السلسلة بالكامل ──
+    logger.warning("All explicit providers failed. Attempting automatic fallback routing...")
+    fallback_models = [mapped, "qwen-3-235b", "qwen-3-32b"]
+    
+    for model in fallback_models:
+        try:
+            # هنا نقوم بالاستدعاء بدون تحديد مزود (provider) لندع g4f يوجه الطلب ذاتياً لأي مزود عالمي شغال
+            result = g4f.ChatCompletion.create(
+                model=model,
+                messages=messages,
+                stream=False,
+            )
+            if hasattr(result, "__iter__") and not isinstance(result, str):
+                text = "".join(str(c) for c in result if c)
+            else:
+                text = str(result or "")
+            text = text.strip()
+
+            if not _is_invalid_response(text):
+                logger.info("Auto-routing Fallback SUCCESS: model=%s len=%d", model, len(text))
+                return text
+            else:
+                logger.warning("Auto-routing Fallback rejected invalid response for model %s", model)
+        except Exception as e:
+            logger.debug("Auto-routing fallback failed for model %s: %s", model, e)
+            continue
+
+    raise RuntimeError("All providers and automatic fallbacks failed")
 
 
 async def g4f_call(messages: List[Dict], model: str) -> str:
@@ -347,7 +384,7 @@ async def health():
     return {
         "status": "ok",
         "cookies": COOKIE_STATUS,
-        "providers": [type(p).__name__ for p, _ in PROVIDER_CHAIN],
+        "providers": [p.__name__ if hasattr(p, "__name__") else type(p).__name__ for p, _ in PROVIDER_CHAIN],
     }