sync: 190 file da Baida98/AI@fe52a247 (2026-08-26 16:35 UTC) [deploy-all]

api/agent.py

@@ -1404,6 +1404,55 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                     allow_tools=not bool(task.get('forbid_tools', False)),
                     allow_local_csv_conversion=bool(task.get('allow_local_csv_conversion', False)),
                 )
+
+                # ARTIFACT-CONTRACT-FALLBACK: alcuni provider restituiscono codice HTML
+                # nella risposta finale dopo aver narrato una scrittura, senza produrre
+                # il tool event `file_written`. Non committiamo mai una falsa positività:
+                # se il goal è UI, proviamo solo a materializzare un documento HTML
+                # completo già presente nell'output, usando l'executor VFS autenticato.
+                # Se non troviamo un documento completo o la scrittura fallisce, il task
+                # resta senza artifact e il frontend non riceve alcun sync inventato.
+                if _artifact_goal and not _vfs_written_paths and getattr(loop, 'executor', None):
+                    _artifact_output = str(result.get('output', result) if isinstance(result, dict) else result)
+                    _html_match = re.search(r'(?is)(<!doctype\s+html\b.*?</html>)', _artifact_output)
+                    if not _html_match:
+                        _html_match = re.search(r'(?is)(<html(?:\s[^>]*)?>.*?</html>)', _artifact_output)
+                    if _html_match:
+                        _artifact_content = _html_match.group(1).strip()
+                        _artifact_path = 'index.html'
+                        _path_match = re.search(r'(?i)(?:/|\b)([\w.-]+\.html)\b', _artifact_output)
+                        if _path_match:
+                            _artifact_path = _path_match.group(1)
+                        try:
+                            _write_result = await asyncio.wait_for(
+                                loop.executor.run_tool('write_file', {
+                                    'path': _artifact_path,
+                                    'content': _artifact_content,
+                                }),
+                                timeout=25.0,
+                            )
+                            _write_ok = not (isinstance(_write_result, dict) and _write_result.get('error'))
+                            if _write_ok:
+                                _vfs_written_paths.add(_artifact_path)
+                                await step_cb({
+                                    'action': 'file_written', 'status': 'done',
+                                    'path': _artifact_path, 'content': _artifact_content,
+                                    'result': f'Artifact materializzato: {_artifact_path}',
+                                })
+                                _read_result = await asyncio.wait_for(
+                                    loop.executor.run_tool('read_file', {'path': _artifact_path}),
+                                    timeout=15.0,
+                                )
+                                _read_ok = not (isinstance(_read_result, dict) and _read_result.get('error'))
+                                await step_cb({
+                                    'action': 'read_file',
+                                    'status': 'done' if _read_ok else 'error',
+                                    'path': _artifact_path,
+                                    'result': f'Verifica artifact: {_artifact_path}' if _read_ok else str(_read_result)[:300],
+                                })
+                        except Exception as _artifact_exc:
+                            _logger.warning('[agent] artifact fallback failed: %s', type(_artifact_exc).__name__)
+
                 _agent_tasks[task_id]['status'] = 'SUCCESS'
                 asyncio.create_task(sb_update_status(task_id, 'SUCCESS')).add_done_callback(_log_task_exc)
                 # ARCH-K2.2: pubblica lifecycle event via Kernel