sync: 192 file da Baida98/AI@3608369b (2026-08-26 20:24 UTC) [deploy-all]

api/agent.py

@@ -1155,13 +1155,19 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                 # soltanto quelli con contenuto così il commit atomico può avvenire
                 # una sola volta dopo un task riuscito.
                 _vfs_written_paths: set[str] = set()
+                # Accumula soltanto i token realmente emessi per poter riconciliare
+                # il testo in streaming con l'output autorevole del finalizer.
+                _streamed_chunks: list[str] = []
 
                 async def step_cb(step_data: dict) -> None:
                     step_idx[0] += 1
                     _action = step_data.get('action', f'Step {step_idx[0]}')
                     # S420: streaming token — emetti direttamente senza passare dal buffer step
                     if _action == 'text_chunk':
-                        _sse('text_chunk', {'taskId': task_id, 'token': _ss(step_data.get('token', ''))})
+                        _token = _ss(step_data.get('token', ''))
+                        if _token:
+                            _streamed_chunks.append(_token)
+                        _sse('text_chunk', {'taskId': task_id, 'token': _token})
                         return
                     # RECOV-P1: engineering_state event — forward projection to frontend
                     if _action == 'engineering_state':
@@ -1481,6 +1487,16 @@ async def stream_agent_task(task_id: str, request: Request, resume: int = 0, rol
                         'status': 'QUALITY_CHECK_PENDING',
                         'primaryStatus': 'COMPLETED',
                     })
+                _streamed_text = ''.join(_streamed_chunks)
+                if _streamed_text and _result_text != _streamed_text:
+                    # Il finalizer può riparare/normalizzare la risposta dopo gli
+                    # ultimi chunk. Notifica esplicitamente la sostituzione così il
+                    # client non mostra un testo parziale o divergente.
+                    _sse('text_replace', {
+                        'taskId': task_id,
+                        'text': _result_text[:8000],
+                        'reason': 'authoritative_finalizer_output',
+                    })
                 _sse('task_done', {
                     'taskId': task_id,
                     'result': _result_text[:8000],