sync: 181 file da Baida98/AI@a636f462 (2026-08-25 13:51 UTC) [deploy-all]

agents/unified_loop_tools.py

@@ -11,6 +11,7 @@ Python MRO garantisce che self.xxx funzioni per attr definite su UnifiedAgentLoo
 """
 from __future__ import annotations
 import asyncio
+import hashlib
 import os
 import re
 from typing import Any
@@ -370,11 +371,27 @@ class DirectToolsMixin:
                     f"https://image.pollinations.ai/prompt/{quote(_img_prompt, safe='')}"
                     f"?width=512&height=512&seed={_img_seed}&nologo=true&enhance=true"
                 )
+                # L'URL viene materializzato dal client nel VFS come data URI JPEG
+                # durante il commit atomico del task. Il nome è derivato dal prompt
+                # normalizzato: è sicuro, ripetibile e non contiene input utente.
+                _artifact_id = hashlib.sha256(_img_prompt.encode("utf-8")).hexdigest()[:12]
+                _artifact_path = f"generated-image-{_artifact_id}.jpg"
+                if on_step:
+                    await _maybe_await(on_step({
+                        "action": "file_written",
+                        "status": "done",
+                        "path": _artifact_path,
+                        "source_url": img_url,
+                        "mime_type": "image/jpeg",
+                        "title": "Immagine salvata nel workspace",
+                        "explanation": f"Salvo {_artifact_path} nel VFS…",
+                    }))
                 return (
                     "[DIRECT_TERMINAL]\n"
                     f"![Immagine generata]({img_url})\n\n"
-                    "E2E_IMAGE_OK: immagine generata e visualizzata qui sopra. "
+                    "E2E_IMAGE_OK: immagine generata, visualizzata e salvata nel workspace. "
                     f"[Apri o scarica l’immagine]({img_url}).\n\n"
+                    f"File VFS: `{_artifact_path}`\n"
                     f"Prompt usato: {_img_prompt[:200]}\n"
                     "Dimensioni: 512x512 px"
                 )

api/agent.py

@@ -1222,11 +1222,21 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                                      step_data.get('output', '')[:500])
                         _vfs_op = 'delete' if 'delete' in _action else 'write'
                         _vfs_evt: dict = {'taskId': task_id, 'file': str(_vfs_file)[:500], 'op': _vfs_op}
-                        # SYNC-1: includi content nel SSE event per file_written (≤60KB)
-                        # Frontend scrive direttamente nel VFS locale senza fetch aggiuntivo
+                        # SYNC-1: includi content nel SSE event per file_written (≤60KB).
+                        # Per immagini dirette il backend non serializza byte nell'SSE:
+                        # inoltra soltanto l'URL HTTPS generato internamente, che il client
+                        # materializza come data URI nel proprio VFS prima del commit atomico.
                         if _action == 'file_written' and step_data.get('content'):
                             _vfs_evt['content'] = str(step_data['content'])[:60_000]
                             _vfs_written_paths.add(str(_vfs_file)[:500])
+                        elif _action == 'file_written':
+                            _source_url = str(step_data.get('source_url') or '')
+                            _mime_type = str(step_data.get('mime_type') or '')
+                            if (_source_url.startswith('https://image.pollinations.ai/') and
+                                    _mime_type in {'image/jpeg', 'image/png', 'image/webp'}):
+                                _vfs_evt['sourceUrl'] = _source_url[:2_000]
+                                _vfs_evt['mimeType'] = _mime_type
+                                _vfs_written_paths.add(str(_vfs_file)[:500])
                         _sse('vfs_update', _vfs_evt)
 
                     # S363-UI: thought event — emitted when planner completes

tests/test_direct_file_conversion.py

@@ -76,15 +76,27 @@ def test_direct_image_returns_renderable_terminal_markdown_without_llm():
         def _max_tokens_for_goal(self, _goal):
             return 4096
 
+    events = []
+
+    async def on_step(event):
+        events.append(event)
+
     output, called, succeeded, errors = asyncio.run(
         Harness()._run_direct_tools(
-            "Genera un’immagine quadrata di un aeroplanino arancione su fondo blu notte."
+            "Genera un’immagine quadrata di un aeroplanino arancione su fondo blu notte.",
+            on_step=on_step,
         )
     )
 
     assert output.startswith("[DIRECT_TERMINAL]\n![Immagine generata](https://image.pollinations.ai/prompt/")
     assert "E2E_IMAGE_OK" in output
     assert "aeroplanino%20arancione" in output
+    assert "File VFS: `generated-image-" in output
+    image_event = next(event for event in events if event.get("action") == "file_written")
+    assert image_event["path"].startswith("generated-image-")
+    assert image_event["path"].endswith(".jpg")
+    assert image_event["source_url"].startswith("https://image.pollinations.ai/prompt/")
+    assert image_event["mime_type"] == "image/jpeg"
     assert called == 1
     assert succeeded == 1
     assert errors == 0