sync: 181 file da Baida98/AI@3bcaeb21 (2026-08-25 11:21 UTC) [deploy-all]

agents/unified_loop_tools.py

@@ -360,7 +360,16 @@ class DirectToolsMixin:
                 if _sc is not None:
                     return _sc
                 _t0 = asyncio.get_event_loop().time()
-                r = await asyncio.wait_for(TOOL_REGISTRY["generate_image"]["_fn"](prompt=_img_prompt[:600]), timeout=12)
+                # Nel percorso diretto privilegiamo l'URL keyless e renderizzabile
+                # subito: l'endpoint vision interno può richiedere un cold-start
+                # più lungo del timeout interattivo, facendo ricadere il task nel
+                # fallback LLM pur avendo un fallback immagine disponibile.
+                r = await asyncio.wait_for(
+                    TOOL_REGISTRY["generate_image"]["_fn"](
+                        prompt=_img_prompt[:600], prefer_internal=False,
+                    ),
+                    timeout=12,
+                )
                 try:
                     from api.state import record_timing as _rtc; _rtc("tool_call", (asyncio.get_event_loop().time() - _t0) * 1000)
                 except Exception as _e: _logger.debug('[timing/record_timing] %s', _e)

tests/test_direct_file_conversion.py

@@ -12,7 +12,10 @@ def _install_tool_stubs(writes, image_url="https://example.test/generated.png"):
         # Il registry reale usa il contratto `ok` per le operazioni filesystem.
         return {"ok": True, "path": path}
 
-    async def generate_image(prompt, width=512, height=512):
+    async def generate_image(prompt, width=512, height=512, prefer_internal=True):
+        # Il percorso interattivo deve ottenere un URL renderizzabile subito,
+        # senza attendere il cold-start del generatore interno.
+        assert prefer_internal is False
         return {"url": image_url, "prompt": prompt, "width": width, "height": height}
 
     registry.TOOL_REGISTRY = {

tools/registry.py

@@ -438,7 +438,12 @@ async def _run_python(code: str) -> dict:
 
 
 
-async def _generate_image(prompt: str, width: int = 512, height: int = 512) -> dict:
+async def _generate_image(
+    prompt: str,
+    width: int = 512,
+    height: int = 512,
+    prefer_internal: bool = True,
+) -> dict:
     """
     Genera immagine AI: FLUX.1-schnell via backend /api/vision/generate (HF Space, gratuito),
     fallback Pollinations AI se FLUX non disponibile.
@@ -446,29 +451,32 @@ async def _generate_image(prompt: str, width: int = 512, height: int = 512) -> d
     import urllib.parse
 
     # V001: Prova prima il backend interno FLUX (stesso processo, localhost)
-    _base_url = os.environ.get("BACKEND_BASE_URL", "http://localhost:7860")
-    _token    = os.environ.get("INTERNAL_TOKEN", "")
-    try:
-        async with httpx.AsyncClient(timeout=30.0) as c:
-            _r = await c.post(
-                f"{_base_url}/api/vision/generate",
-                json={"prompt": prompt.strip()[:600], "width": width, "height": height},
-                headers={**({"X-Internal-Token": _token} if _token else {})},
-            )
-            if _r.status_code == 200:
-                _data = _r.json()
-                if _data.get("ok") and _data.get("image_url"):
-                    return {
-                        "url":    _data["image_url"],
-                        "prompt": prompt,
-                        "width":  width,
-                        "height": height,
-                        "ready":  True,
-                        "source": "flux",
-                        "note":   "Immagine generata con FLUX.1-schnell via backend.",
-                    }
-    except Exception:
-        pass  # FLUX non raggiungibile → Pollinations fallback
+    # soltanto per chiamanti che possono attendere il cold-start. Il direct tool
+    # della chat privilegia invece il fallback URL immediato.
+    if prefer_internal:
+        _base_url = os.environ.get("BACKEND_BASE_URL", "http://localhost:7860")
+        _token    = os.environ.get("INTERNAL_TOKEN", "")
+        try:
+            async with httpx.AsyncClient(timeout=30.0) as c:
+                _r = await c.post(
+                    f"{_base_url}/api/vision/generate",
+                    json={"prompt": prompt.strip()[:600], "width": width, "height": height},
+                    headers={**({"X-Internal-Token": _token} if _token else {})},
+                )
+                if _r.status_code == 200:
+                    _data = _r.json()
+                    if _data.get("ok") and _data.get("image_url"):
+                        return {
+                            "url":    _data["image_url"],
+                            "prompt": prompt,
+                            "width":  width,
+                            "height": height,
+                            "ready":  True,
+                            "source": "flux",
+                            "note":   "Immagine generata con FLUX.1-schnell via backend.",
+                        }
+        except Exception:
+            pass  # FLUX non raggiungibile → Pollinations fallback
 
     # Fallback: Pollinations AI (gratuito, nessuna API key)
     encoded = urllib.parse.quote(prompt.strip(), safe="")