sync: 181 file da Baida98/AI@0f8ce228 (2026-08-25 11:12 UTC) [deploy-all]

api/agent.py

@@ -51,6 +51,7 @@ from .state import (
     ReasonLoopIn, AgentTaskIn,
 )
 from .speculative import fire_speculative_tools
+from .vfs_sync import build_vfs_sync_complete
 try:
     from .quality_guardian import run_quality_check as _run_quality_check
 except Exception:
@@ -1092,6 +1093,10 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                 )
                 step_idx = [0]
                 _backend_steps: list[dict] = []  # GAP-SYNC-FIX: log step per resume preciso
+                # P34/SYNC-1: i file arrivano nel frontend in staging; raccogliamo
+                # soltanto quelli con contenuto così il commit atomico può avvenire
+                # una sola volta dopo un task riuscito.
+                _vfs_written_paths: set[str] = set()
 
                 async def step_cb(step_data: dict) -> None:
                     step_idx[0] += 1
@@ -1221,6 +1226,7 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                         # Frontend scrive direttamente nel VFS locale senza fetch aggiuntivo
                         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])
                         _sse('vfs_update', _vfs_evt)
 
                     # S363-UI: thought event — emitted when planner completes
@@ -1332,6 +1338,14 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                         payload={'task_id': task_id, 'status': 'SUCCESS'},
                     )).add_done_callback(_log_task_exc)
                 _result_text = str(result.get('output', result) if isinstance(result, dict) else result)
+                _vfs_commit = build_vfs_sync_complete(
+                    task_id, _vfs_written_paths, result,
+                )
+                if _vfs_commit is not None:
+                    # P34: completa l’atomic swap frontend solo dopo che il loop ha
+                    # confermato il task. Su errore/cancellazione lo staging rimane
+                    # intenzionalmente non committato.
+                    _sse('vfs_sync_complete', _vfs_commit)
                 _sse('task_done', {'taskId': task_id, 'result': _result_text[:8000]})
                 asyncio.create_task(_tg_done(task_id, task.get('goal', ''), _result_text[:500], _task_started_ms)).add_done_callback(_log_task_exc)
 

api/vfs_sync.py

@@ -0,0 +1,24 @@
+"""Contratto SSE per il commit atomico degli artefatti VFS lato frontend."""
+from __future__ import annotations
+
+from collections.abc import Iterable, Mapping
+from typing import Any
+
+
+def build_vfs_sync_complete(
+    task_id: str,
+    written_paths: Iterable[str],
+    result: Any,
+) -> dict[str, object] | None:
+    """Restituisce il payload di commit solo dopo un loop riuscito.
+
+    I contenuti viaggiano in eventi ``vfs_update`` separati e restano nello
+    staging del frontend. Questo segnale consente l'atomic swap esclusivamente
+    per i file effettivamente inoltrati dal backend.
+    """
+    files = sorted({path for path in written_paths if path})
+    if not files:
+        return None
+    if isinstance(result, Mapping) and not bool(result.get("success", True)):
+        return None
+    return {"taskId": task_id, "files": files}

tests/test_vfs_sync.py

@@ -0,0 +1,24 @@
+from api.vfs_sync import build_vfs_sync_complete
+
+
+def test_vfs_sync_commit_includes_sorted_unique_files_after_success():
+    event = build_vfs_sync_complete(
+        "task-123",
+        {"reports/data.json", "e2e_metrics.json", "reports/data.json"},
+        {"success": True, "output": "ok"},
+    )
+
+    assert event == {
+        "taskId": "task-123",
+        "files": ["e2e_metrics.json", "reports/data.json"],
+    }
+
+
+def test_vfs_sync_commit_is_omitted_without_files():
+    assert build_vfs_sync_complete("task-123", set(), {"success": True}) is None
+
+
+def test_vfs_sync_commit_is_omitted_after_failed_loop():
+    assert build_vfs_sync_complete(
+        "task-123", {"e2e_metrics.json"}, {"success": False, "error": "write failed"}
+    ) is None