Restore Space to commit 36e2e7f8

AUTO_CONTINUE_FEATURE.md

@@ -1,183 +0,0 @@
-# Auto-Continue Feature for Free Models
-
-## Tổng quan
-Khi model miễn phí dùng OpenRouter phản hồi bị dừng nhưng nhiệm vụ chưa hoàn thành, hệ thống sẽ:
-1. Phát hiện task incomplete dựa vào trạng thái plan
-2. Hiển thị 2 nút: "Tự động tiếp tục (10s)" và "Tạm dừng"
-
-## Các file cần sửa
-
-### 1. frontend/src/hooks/useAgentChat.ts
-
-```typescript
-// Thêm vào import
-import { useCallback, useEffect, useMemo, useRef, useState } from 'react';
-
-// Trong useAgentChat function, sau callbacksRef
-const autoContinueTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
-const [showAutoContinue, setShowAutoContinue] = useState(false);
-const [taskIncompleteInfo, setTaskIncompleteInfo] = useState<{
-  incompletePlan: Array<{ id: string; content: string; status: string }>;
-} | null>(null);
-
-// Thêm vào SideChannelCallbacks interface
-export interface SideChannelCallbacks {
-  // ... existing callbacks ...
-  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;
-}
-
-// Thêm vào sideChannel trong useMemo
-onTaskIncomplete: (incompletePlan) => {
-  setTaskIncompleteInfo({ incompletePlan });
-  setShowAutoContinue(true);
-  if (autoContinueTimerRef.current) {
-    clearTimeout(autoContinueTimerRef.current);
-  }
-  autoContinueTimerRef.current = setTimeout(() => {
-    startAutoContinue();
-  }, 10000);
-},
-
-// Thêm hàm mới
-const startAutoContinue = useCallback(() => {
-  setShowAutoContinue(false);
-  setTaskIncompleteInfo(null);
-  if (autoContinueTimerRef.current) {
-    clearTimeout(autoContinueTimerRef.current);
-    autoContinueTimerRef.current = null;
-  }
-  const incompleteItems = taskIncompleteInfo?.incompletePlan || [];
-  const continuationText = incompleteItems.length > 0
-    ? `Tiếp tục từ các task chưa hoàn thành: ${incompleteItems.map(i => `- ${i.content}`).join('\n')}`
-    : 'Tiếp tục nhiệm vụ.';
-  chat.sendMessage({ 
-    text: `[TỰ ĐỘNG TIẾP TỤC] ${continuationText}`, 
-    metadata: { createdAt: new Date().toISOString() } 
-  });
-}, [taskIncompleteInfo, chat]);
-
-const cancelAutoContinue = useCallback(() => {
-  setShowAutoContinue(false);
-  setTaskIncompleteInfo(null);
-  if (autoContinueTimerRef.current) {
-    clearTimeout(autoContinueTimerRef.current);
-    autoContinueTimerRef.current = null;
-  }
-}, []);
-
-// Thêm vào return
-return {
-  messages: chat.messages,
-  sendMessage: chat.sendMessage,
-  stop,
-  status: chat.status,
-  undoLastTurn,
-  editAndRegenerate,
-  approveTools,
-  refreshMessages,
-  showAutoContinue,
-  taskIncompleteInfo,
-  startAutoContinue,
-  cancelAutoContinue,
-};
-```
-
-### 2. frontend/src/components/Chat/ChatInput.tsx
-
-```typescript
-// Thêm import
-import { Box, IconButton, Stack, Tooltip, Button } from '@mui/material';
-
-// Thêm props
-interface ChatInputProps {
-  // ... existing props
-  showAutoContinue?: boolean;
-  taskIncompleteInfo?: { incompletePlan: Array<{ id: string; content: string; status: string }> } | null;
-  startAutoContinue?: () => void;
-  cancelAutoContinue?: () => void;
-}
-
-// Thêm UI buttons (trước hoặc sau input area)
-{showAutoContinue && taskIncompleteInfo && (
-  <Stack direction="row" spacing={1} sx={{ mb: 1, px: 2 }}>
-    <Button
-      variant="contained"
-      color="primary"
-      size="small"
-      onClick={startAutoContinue}
-      sx={{ textTransform: 'none' }}
-    >
-      Tự động tiếp tục (10s)
-    </Button>
-    <Button
-      variant="outlined"
-      color="secondary"
-      size="small"
-      onClick={cancelAutoContinue}
-      sx={{ textTransform: 'none' }}
-    >
-      Tạm dừng
-    </Button>
-  </Stack>
-)}
-```
-
-### 3. frontend/src/lib/sse-chat-transport.ts
-
-```typescript
-// Thêm vào case trong createEventToChunkStream
-case 'task_incomplete':
-  sideChannel.onTaskIncomplete(
-    (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-  );
-  break;
-```
-
-### 4. agent/core/agent_loop.py
-
-```python
-# Trong run_agent, sau khi xử lý LLM response
-def _check_task_incomplete(session: Session, llm_result: LLMResult) -> bool:
-    """Kiểm tra nếu model dừng nhưng task chưa hoàn thành."""
-    if llm_result.tool_calls_acc:
-        return False  # Có tool calls thì chưa incomplete
-    
-    plan = getattr(session, "current_plan", None) or []
-    unfinished = [item for item in plan if item.get("status") in ("pending", "in_progress")]
-    
-    return len(unfinished) > 0
-
-# Gọi sau khi nhận kết quả LLM:
-if _check_task_incomplete(session, llm_result):
-    unfinished = [item for item in plan if item.get("status") in ("pending", "in_progress")]
-    await session.send_event(
-        Event(
-            event_type="task_incomplete",
-            data={
-                "incomplete_plan": unfinished,
-                "message": "Model stopped streaming but task is incomplete."
-            }
-        )
-    )
-```
-
-## Logic hoạt động
-
-1. Khi agent loop phát hiện model trả lời không có tool calls nhưng plan còn incomplete
-2. Backend gửi event `task_incomplete` với danh sách task chưa hoàn thành
-3. Frontend nhận event qua `onTaskIncomplete` callback
-4. Hiển thị 2 nút:
-   - **Tự động tiếp tục (10s)**: Sau 10 giây sẽ tự động gửi tin nhắn tiếp tục
-   - **Tạm dừng**: Hủy timer, cho phép user nhập nội dung mới
-
-## Áp dụng patch
-
-```bash
-# Tải source
-git clone https://huggingface.co/spaces/smolagents/ml-intern /tmp/source
-
-# Sửa các file trên
-# Sau đó rebuild frontend
-cd /tmp/source/frontend
-npm install && npm run build
-```

BUILD_TRIGGER

@@ -1 +0,0 @@
-trigger

Dockerfile

@@ -1,57 +1,60 @@
-# Restore + patch frontend + backend models + auto-continue V17 + auto-approve
+# Stage 1: Build frontend
 FROM node:20-alpine AS frontend-builder
-RUN apk add --no-cache git python3
-RUN git clone --depth 1 https://huggingface.co/spaces/smolagents/ml-intern /source
-
-# Patch frontend: add OpenRouter models
-COPY patch_frontend.py /tmp/patch_frontend.py
-RUN python3 /tmp/patch_frontend.py
-
-# Patch auto-continue V17
-COPY patch_auto_continue_v17.py /tmp/patch_auto_continue_v17.py
-RUN python3 /tmp/patch_auto_continue_v17.py
-
-WORKDIR /source/frontend
-RUN npm config set fetch-timeout 120000 && \
-    npm config set fetch-retries 3 && \
-    npm install && \
-    npm run build
+WORKDIR /app/frontend
+COPY frontend/package.json frontend/package-lock.json ./
+RUN npm install
+COPY frontend/ ./
+RUN npm run build
 
 # Stage 2: Production
 FROM python:3.12-slim
+
+# Install uv directly from official image
 COPY --from=ghcr.io/astral-sh/uv:latest /uv /uvx /bin/
+
+# Create user with UID 1000 (required for HF Spaces)
 RUN useradd -m -u 1000 user
+
 WORKDIR /app
-RUN apt-get update && apt-get install -y --no-install-recommends git curl ca-certificates && rm -rf /var/lib/apt/lists/*
 
-RUN git clone --depth 1 https://huggingface.co/spaces/smolagents/ml-intern /tmp/source && \
-    cp /tmp/source/pyproject.toml /tmp/source/uv.lock ./ && \
-    cp -r /tmp/source/agent ./agent && \
-    cp -r /tmp/source/backend ./backend && \
-    cp -r /tmp/source/configs ./configs && \
-    rm -rf /tmp/source
+# Install system dependencies
+RUN apt-get update && apt-get install -y --no-install-recommends \
+    git \
+    curl \
+    bash \
+    && rm -rf /var/lib/apt/lists/*
 
-RUN uv sync --no-dev --frozen
+# Copy dependency files
+COPY pyproject.toml uv.lock ./
 
-COPY --from=frontend-builder /source/frontend/dist ./static/
-COPY configs/frontend_agent_config.json ./configs/frontend_agent_config.json
+# Install dependencies into /app/.venv
+# Use --frozen to ensure exact versions from uv.lock
+RUN uv sync --no-dev --frozen
 
-# Patch backend: accept new model IDs
-COPY patch_models.py /tmp/patch_models.py
-RUN python /tmp/patch_models.py
+# Copy application code
+COPY agent/ ./agent/
+COPY backend/ ./backend/
+COPY configs/ ./configs/
 
-# Patch backend: auto-continue detection + auto-approve
-COPY patch_agent_backend.py /tmp/patch_agent_backend.py
-RUN python /tmp/patch_agent_backend.py
+# Copy built frontend
+COPY --from=frontend-builder /app/frontend/dist ./static/
 
-RUN mkdir -p /app/session_logs && chown -R user:user /app
+# Create directories and set ownership
+RUN mkdir -p /app/session_logs && \
+    chown -R user:user /app
 
+# Switch to non-root user
 USER user
+
+# Set environment
 ENV HOME=/home/user \
     PYTHONUNBUFFERED=1 \
     PYTHONPATH=/app \
     PATH="/app/.venv/bin:$PATH"
 
+# Expose port
 EXPOSE 7860
+
+# Run the application from backend directory
 WORKDIR /app/backend
-CMD ["sh", "start.sh"]
+CMD ["bash", "start.sh"]

README.md

@@ -1,33 +1,340 @@
 ---
-title: Space Multiverse
+title: ML Intern
 emoji: 🤖
 colorFrom: yellow
 colorTo: blue
 sdk: docker
 app_port: 7860
-short_description: ML Intern V2 (FREE & SAVE MODEL)
 hf_oauth: true
 hf_oauth_expiration_minutes: 43200
 hf_oauth_scopes:
-- read-repos
-- write-repos
-- contribute-repos
-- manage-repos
-- write-collections
-- inference-api
-- jobs
-- write-discussions
-tags:
-- ml-intern
+  - read-repos
+  - write-repos
+  - contribute-repos
+  - manage-repos
+  - write-collections
+  - inference-api
+  - jobs
+  - write-discussions
 ---
 
-# Space Multiverse — ML Intern V2 (FREE & SAVE MODEL)
+<p align="center">
+  <img src="frontend/public/smolagents.webp" alt="smolagents logo" width="160" />
+</p>
 
-<!-- rebuild: add-deepseek-v4-flash-latest-2026-08-02T09:00:00Z -->
+# ML Intern
 
-- Added **DeepSeek V4 Flash latest** via OpenRouter (path: `openai/deepseek/deepseek-v4-flash-latest`)
-- Replaced GPT-5.5 model with **Laguna S 2.1:free** (path: `openai/poolside/laguna-s-2.1:free`)
-- Added OpenRouter routing (catch-all `openai/` prefix → OpenRouter API)
-- Default: `openai/tencent/hy3:free`
-- Models: Tencent HY3:free, Gemma 4 31B:free, Llama 3.3 70B:free, **Laguna M.1:free**, **Laguna S 2.1:free**, Llama 3.1 8B, DeepSeek V4 Flash latest
-- Ollama: không thể dùng cho HF Space (local inference, không có cloud API free cho use case này)
+An ML intern that autonomously researches, writes, and ships good quality ML related code using the Hugging Face ecosystem — with deep access to docs, papers, datasets, and cloud compute.
+
+## Quick Start
+
+### Installation
+
+```bash
+git clone git@github.com:huggingface/ml-intern.git
+cd ml-intern
+uv sync
+uv tool install -e .
+```
+
+#### That's it. Now `ml-intern` works from any directory:
+
+```bash
+ml-intern
+```
+
+Create a `.env` file in the project root (or export these in your shell):
+
+```bash
+ANTHROPIC_API_KEY=<your-anthropic-api-key> # if using anthropic models
+OPENAI_API_KEY=<your-openai-api-key> # if using openai models
+HF_TOKEN=<your-hugging-face-token>
+GITHUB_TOKEN=<github-personal-access-token> 
+```
+If no `HF_TOKEN` is set, the CLI will prompt you to paste one on first launch. To get a GITHUB_TOKEN follow the tutorial [here](https://docs.github.com/en/authentication/keeping-your-account-and-data-secure/managing-your-personal-access-tokens#creating-a-fine-grained-personal-access-token).
+
+### Usage
+
+**Interactive mode** (start a chat session):
+
+```bash
+ml-intern
+```
+
+**Headless mode** (single prompt, auto-approve):
+
+```bash
+ml-intern "fine-tune llama on my dataset"
+```
+
+**Options:**
+
+```bash
+ml-intern --model anthropic/claude-opus-4-6 "your prompt"
+ml-intern --model openai/gpt-5.5 "your prompt"
+ml-intern --max-iterations 100 "your prompt"
+ml-intern --no-stream "your prompt"
+```
+
+## Sharing Traces
+
+Every session is auto-uploaded to your **own private Hugging Face dataset**
+in [Claude Code JSONL format](https://huggingface.co/changelog/agent-trace-viewer),
+which the HF Agent Trace Viewer auto-detects so you can browse turns, tool
+calls, and model responses directly on the Hub.
+
+By default the dataset is named `{your-hf-username}/ml-intern-sessions` and is
+**created private**. You can flip it to public from inside the CLI:
+
+```bash
+/share-traces            # show current visibility + dataset URL
+/share-traces public     # publish (anyone can view)
+/share-traces private    # lock it back down
+```
+
+You can also flip visibility from the dataset page on huggingface.co — the
+agent honours whatever you set there for subsequent uploads.
+
+To opt out entirely, set in your CLI config (e.g. `configs/cli_agent_config.json`
+or `~/.config/ml-intern/cli_agent_config.json`):
+
+```json
+{ "share_traces": false }
+```
+
+To override the destination repo, set:
+
+```json
+{ "personal_trace_repo_template": "{hf_user}/my-custom-traces" }
+```
+
+The shared `smolagents/ml-intern-sessions` dataset is unrelated and only
+receives anonymized telemetry rows used by the backend KPI scheduler.
+
+## Supported Gateways
+
+ML Intern currently supports one-way notification gateways from CLI sessions.
+These gateways send out-of-band status updates; they do not accept inbound chat
+messages.
+
+### Slack
+
+Slack notifications use the Slack Web API to post messages when the agent needs
+approval, hits an error, or completes a turn. Create a Slack app with a bot token
+that has `chat:write`, invite the bot to the target channel, then set:
+
+```bash
+SLACK_BOT_TOKEN=xoxb-...
+SLACK_CHANNEL_ID=C...
+```
+
+The CLI automatically creates a `slack.default` destination when both variables
+are present. Optional environment variables for the env-only default:
+
+```bash
+ML_INTERN_SLACK_NOTIFICATIONS=false
+ML_INTERN_SLACK_DESTINATION=slack.ops
+ML_INTERN_SLACK_AUTO_EVENTS=approval_required,error,turn_complete
+ML_INTERN_SLACK_ALLOW_AGENT_TOOL=true
+ML_INTERN_SLACK_ALLOW_AUTO_EVENTS=true
+```
+
+For a persistent user-level config, put overrides in
+`~/.config/ml-intern/cli_agent_config.json` or point `ML_INTERN_CLI_CONFIG` at a
+JSON file:
+
+```json
+{
+  "messaging": {
+    "enabled": true,
+    "auto_event_types": ["approval_required", "error", "turn_complete"],
+    "destinations": {
+      "slack.ops": {
+        "provider": "slack",
+        "token": "${SLACK_BOT_TOKEN}",
+        "channel": "${SLACK_CHANNEL_ID}",
+        "allow_agent_tool": true,
+        "allow_auto_events": true
+      }
+    }
+  }
+}
+```
+
+## Architecture
+
+### Component Overview
+
+```
+┌─────────────────────────────────────────────────────────────┐
+│                         User/CLI                            │
+└────────────┬─────────────────────────────────────┬──────────┘
+             │ Operations                          │ Events
+             ↓ (user_input, exec_approval,         ↑
+      submission_queue  interrupt, compact, ...)  event_queue
+             │                                          │
+             ↓                                          │
+┌────────────────────────────────────────────────────┐  │
+│            submission_loop (agent_loop.py)         │  │
+│  ┌──────────────────────────────────────────────┐  │  │
+│  │  1. Receive Operation from queue                 │  │  │
+│  │  2. Route to handler (run_agent/compact/...) │  │  │
+│  └──────────────────────────────────────────────┘  │  │  │
+│                      ↓                             │  │
+│  ┌──────────────────────────────────────────────┐  │  │
+│  │         Handlers.run_agent()                 │  ├──┤
+│  │                                              │  │  │
+│  │  ┌────────────────────────────────────────┐  │  │  │
+│  │  │  Agentic Loop (max 300 iterations)     │  │  │  │
+│  │  │                                        │  │  │  │
+│  │  │  ┌──────────────────────────────────┐  │  │  │  │
+│  │  │  │ Session                          │  │  │  │  │
+│  │  │  │  ┌────────────────────────────┐  │  │  │  │  │
+│  │  │  │  │ ContextManager             │  │  │  │  │  │
+│  │  │  │  │ • Message history          │  │  │  │  │  │
+│  │  │  │  │   (litellm.Message[])      │  │  │  │  │  │
+│  │  │  │  │ • Auto-compaction (170k)   │  │  │  │  │  │
+│  │  │  │  │ • Session upload to HF     │  │  │  │  │  │
+│  │  │  │  └────────────────────────────┘  │  │  │  │  │
+│  │  │  │                                  │  │  │  │  │
+│  │  │  │  ┌────────────────────────────┐  │  │  │  │  │
+│  │  │  │  │ ToolRouter                 │  │  │  │  │  │
+│  │  │  │  │  ├─ HF docs & research     │  │  │  │  │  │
+│  │  │  │  │  ├─ HF repos, datasets,    │  │  │  │  │  │
+│  │  │  │  │  │  jobs, papers           │  │  │  │  │  │
+│  │  │  │  │  ├─ GitHub code search     │  │  │  │  │  │
+│  │  │  │  │  ├─ Sandbox & local tools  │  │  │  │  │  │
+│  │  │  │  │  ├─ Planning               │  │  │  │  │  │
+│  │  │  │  │  └─ MCP server tools       │  │  │  │  │  │
+│  │  │  │  └────────────────────────────┘  │  │  │  │  │
+│  │  │  └──────────────────────────────────┘  │  │  │  │
+│  │  │                                        │  │  │  │
+│  │  │  ┌──────────────────────────────────┐  │  │  │  │
+│  │  │  │ Doom Loop Detector               │  │  │  │  │
+│  │  │  │ • Detects repeated tool patterns │  │  │  │  │
+│  │  │  │ • Injects corrective prompts     │  │  │  │  ��
+│  │  │  └──────────────────────────────────┘  │  │  │  │
+│  │  │                                        │  │  │  │
+│  │  │  Loop:                                 │  │  │  │
+│  │  │    1. LLM call (litellm.acompletion)   │  │  │  │
+│  │  │       ↓                                │  │  │  │
+│  │  │    2. Parse tool_calls[]               │  │  │  │
+│  │  │       ↓                                │  │  │  │
+│  │  │    3. Approval check                     │  │  │  │
+│  │  │       (jobs, sandbox, destructive ops) │  │  │  │
+│  │  │       ↓                                │  │  │  │
+│  │  │    4. Execute via ToolRouter           │  │  │  │
+│  │  │       ↓                                │  │  │  │
+│  │  │    5. Add results to ContextManager      │  │  │  │
+│  │  │       ↓                                │  │  │  │
+│  │  │    6. Repeat if tool_calls exist       │  │  │  │
+│  │  └────────────────────────────────────────┘  │  │  │
+│  └──────────────────────────────────────────────┘  │  │
+└────────────────────────────────────────────────────┴──┘
+```
+
+### Agentic Loop Flow
+
+```
+User Message
+     ↓
+[Add to ContextManager]
+     ↓
+     ╔═══════════════════════════════════════════╗
+     ║      Iteration Loop (max 300)             ║
+     ║                                           ║
+     ║  Get messages + tool specs                ║
+     ║         ↓                                 ║
+     ║  litellm.acompletion()                    ║
+     ║         ↓                                 ║
+     ║  Has tool_calls? ──No──> Done             ║
+     ║         │                                 ║
+     ║        Yes                                ║
+     ║         ↓                                 ║
+     ║  Add assistant msg (with tool_calls)      ║
+     ║         ↓                                 ║
+     ║  Doom loop check                          ║
+     ║         ↓                                 ║
+     ║  For each tool_call:                      ║
+     ║    • Needs approval? ──Yes──> Wait for    ║
+     ║    │                         user confirm ║
+     ║    No                                     ║
+     ║    ↓                                      ║
+     ║    • ToolRouter.execute_tool()            ║
+     ║    • Add result to ContextManager         ║
+     ║         ↓                                 ║
+     ║  Continue loop ─────────────────┐         ║
+     ║         ↑                       │         ║
+     ║         └───────────────────────┘         ║
+     ╚═══════════════════════════════════════════╝
+```
+
+## Events
+
+The agent emits the following events via `event_queue`:
+
+- `processing` - Starting to process user input
+- `ready` - Agent is ready for input
+- `assistant_chunk` - Streaming token chunk
+- `assistant_message` - Complete LLM response text
+- `assistant_stream_end` - Token stream finished
+- `tool_call` - Tool being called with arguments
+- `tool_output` - Tool execution result
+- `tool_log` - Informational tool log message
+- `tool_state_change` - Tool execution state transition
+- `approval_required` - Requesting user approval for sensitive operations
+- `turn_complete` - Agent finished processing
+- `error` - Error occurred during processing
+- `interrupted` - Agent was interrupted
+- `compacted` - Context was compacted
+- `undo_complete` - Undo operation completed
+- `shutdown` - Agent shutting down
+
+## Development
+
+### Adding Built-in Tools
+
+Edit `agent/core/tools.py`:
+
+```python
+def create_builtin_tools() -> list[ToolSpec]:
+    return [
+        ToolSpec(
+            name="your_tool",
+            description="What your tool does",
+            parameters={
+                "type": "object",
+                "properties": {
+                    "param": {"type": "string", "description": "Parameter description"}
+                },
+                "required": ["param"]
+            },
+            handler=your_async_handler
+        ),
+        # ... existing tools
+    ]
+```
+
+### Adding MCP Servers
+
+Edit `configs/cli_agent_config.json` for CLI defaults, or
+`configs/frontend_agent_config.json` for web-session defaults:
+
+```json
+{
+  "model_name": "anthropic/claude-sonnet-4-5-20250929",
+  "mcpServers": {
+    "your-server-name": {
+      "transport": "http",
+      "url": "https://example.com/mcp",
+      "headers": {
+        "Authorization": "Bearer ${YOUR_TOKEN}"
+      }
+    }
+  }
+}
+```
+
+Note: Environment variables like `${YOUR_TOKEN}` are auto-substituted from `.env`.
+
+```

configs/cli_agent_config.json

@@ -0,0 +1,22 @@
+{
+  "model_name": "zai-org/GLM-5.2:novita",
+  "save_sessions": true,
+  "session_dataset_repo": "smolagents/ml-intern-sessions",
+  "share_traces": true,
+  "personal_trace_repo_template": "{hf_user}/ml-intern-sessions",
+  "yolo_mode": false,
+  "confirm_cpu_jobs": true,
+  "auto_file_upload": true,
+  "tool_runtime": "local",
+  "messaging": {
+    "enabled": false,
+    "auto_event_types": ["approval_required", "error", "turn_complete"],
+    "destinations": {}
+  },
+  "mcpServers": {
+    "hf-mcp-server": {
+      "transport": "http",
+      "url": "https://huggingface.co/mcp?login"
+    }
+  }
+}

configs/frontend_agent_config.json

@@ -1,16 +1,16 @@
 {
-  "model_name": "openai/tencent/hy3:free",
-  "api_base": "https://openrouter.ai/api/v1",
+  "model_name": "${ML_INTERN_DEFAULT_MODEL_ID:-zai-org/GLM-5.2:novita}",
   "save_sessions": true,
-  "personal_trace_repo_template": "{hf_user}/ml-intern-sessions",
+  "session_dataset_repo": "smolagents/ml-intern-sessions",
   "share_traces": true,
+  "personal_trace_repo_template": "{hf_user}/ml-intern-sessions",
   "yolo_mode": false,
   "confirm_cpu_jobs": true,
   "auto_file_upload": true,
   "mcpServers": {
     "hf-mcp-server": {
       "transport": "http",
-      "url": "https://openrouter.ai/mcp"
+      "url": "https://huggingface.co/mcp?login"
     }
   }
 }

fix_space_error_report.json

@@ -1,9 +0,0 @@
-{
-  "status": "fixed_uploaded",
-  "space": "bep40/ml-intern",
-  "space_url": "https://huggingface.co/spaces/bep40/ml-intern",
-  "root_cause": "Dockerfile runtime stage used CMD [\"bash\", \"start.sh\"] on python:3.12-slim, which does not include bash by default. This causes container startup failure and Space error after a successful build.",
-  "fix": "Changed Dockerfile CMD to [\"sh\", \"start.sh\"] and added ca-certificates to apt packages. start.sh is POSIX-compatible for this use.",
-  "files_changed": ["Dockerfile", "README.md"],
-  "verification": "Repo files updated and rebuild triggered. Live runtime verification via HF Jobs/sandbox was blocked by namespace credit/duplication limits in this session; check Space build logs if HF still reports error."
-}

patch_agent_backend.py

@@ -1,89 +0,0 @@
-"""Patch: agent_loop.py task detection + auto-approve for free models."""
-
-import os
-import ast
-
-AGENT_LOOP = "/app/agent/core/agent_loop.py"
-AGENT_FILE = "/app/backend/routes/agent.py"
-SESSION_FILE = "/app/agent/core/session.py"
-
-# ===== PATCH 1: agent_loop.py - detect model stopped mid-task =====
-with open(AGENT_LOOP) as f:
-    c = f.read()
-
-# Add helper function before class Handlers
-if "_unfinished_plan" not in c:
-    fn = (
-        "\n\ndef _unfinished_plan(s):\n"
-        "    p = getattr(s, 'current_plan', None) or []\n"
-        "    return [it for it in p if it.get('status') in ('pending', 'in_progress')]\n\n"
-    )
-    c = c.replace("class Handlers:", fn + "class Handlers:")
-    print("OK: Added _unfinished_plan()")
-
-# Add detection: if model produced no tool calls but content still exists,
-# and plan items are still pending/in_progress, send session_update event
-if "ac_plan" not in c:
-    check = (
-        "\n            # Auto-continue: detect model stopped mid-task\n"
-        "            if not llm_result.tool_calls_acc and llm_result.content:\n"
-        "                unfinished = _unfinished_plan(session)\n"
-        "                if unfinished:\n"
-        "                    await session.send_event(Event(event_type='session_update', data={\n"
-        "                        'ac_plan': unfinished,\n"
-        "                    }))\n"
-    )
-    c = c.replace("  # -- End of turn --", check + "  # -- End of turn --")
-    print("OK: Added mid-task detection")
-
-try:
-    ast.parse(c)
-    with open(AGENT_LOOP, "w") as f:
-        f.write(c)
-    print("OK: agent_loop.py patched")
-except SyntaxError as e:
-    print(f"FAIL: agent_loop.py syntax: {e}")
-
-# ===== PATCH 2: Enable auto_approval for ALL sessions by default =====
-# So free models don't block on user approval
-with open(SESSION_FILE) as f:
-    c = f.read()
-
-if "AUTO_APPROVE" not in c:
-    # Find where auto_approval is set on the session object
-    # Patch: when creating a new session, set auto_approval.enabled = True
-    auto_patch = (
-        "\n        # === PATCH: Auto-approve for free models ===\n"
-        "        self.auto_approval = {\n"
-        '            "enabled": True,\n'
-        '            "cost_cap_usd": None,\n'
-        '            "estimated_spend_usd": 0.0,\n'
-        '            "remaining_usd": None,\n'
-        "        }\n"
-    )
-    
-    # Find session init method
-    init_match = "class Session:"
-    if init_match in c:
-        # Insert after the class definition, find __init__
-        init_found = "def __init__"
-        if init_found in c:
-            # Find first line inside __init__ that's an assignment
-            init_start = c.find(init_found)
-            body_start = c.find("\n", init_start) + 1
-            body_start = c.find("        ", body_start)  # first indented line
-            c = c[:body_start] + auto_patch + c[body_start:]
-            print("OK: Added auto_approve default")
-    
-    try:
-        ast.parse(c)
-        with open(SESSION_FILE, "w") as f:
-            f.write(c)
-        print("OK: session.py patched")
-    except SyntaxError as e:
-        print(f"FAIL: session.py syntax: {e}")
-        # Don't block on this patch
-else:
-    print("OK: session.py already has auto_approve")
-
-print("DONE: Backend patches applied")

patch_agent_loop.py

@@ -1,74 +0,0 @@
-"""Patch agent_loop.py - detect task incomplete and send event."""
-
-AGENT_LOOP = "/app/agent/core/agent_loop.py"
-
-def patch():
-    import os
-    if not os.path.exists(AGENT_LOOP):
-        print(f"SKIP: {AGENT_LOOP} not found")
-        return
-        
-    with open(AGENT_LOOP, "r", encoding="utf-8") as f:
-        content = f.read()
-    
-    # Add _check_task_incomplete function before class Handlers
-    check_func = '''
-
-def _check_task_incomplete(session: Session, llm_result: LLMResult) -> bool:
-    """Check if model stopped streaming but task is incomplete."""
-    if llm_result.tool_calls_acc:
-        return False  # Has tool calls, task continues via tool execution
-    
-    plan = getattr(session, "current_plan", None) or []
-    unfinished = [item for item in plan if item.get("status") in ("pending", "in_progress")]
-    
-    return len(unfinished) > 0
-
-
-def _unfinished_plan_items(session: Session) -> list[dict[str, str]]:
-    """Helper to get unfinished plan items."""
-    plan = getattr(session, "current_plan", None) or []
-    return [item for item in plan if item.get("status") in ("pending", "in_progress")]
-
-'''
-    
-    if "_check_task_incomplete" not in content:
-        content = content.replace(
-            "class Handlers:",
-            check_func + "\n\nclass Handlers:"
-        )
-    
-    # Add the check after LLM response processing
-    check_call = '''
-            # === Check for incomplete task after LLM response ===
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan_items(session)
-                if unfinished:
-                    await session.send_event(
-                        Event(
-                            event_type="task_incomplete",
-                            data={
-                                "incomplete_plan": unfinished,
-                                "message": "Model phản hồi đã dừng nhưng nhiệm vụ chưa hoàn thành."
-                            }
-                        )
-                    )
-'''
-    
-    if "task_incomplete" not in content:
-        # Find a good insertion point - after tool calls processing
-        insert_marker = "  # -- End of turn --"
-        if insert_marker in content:
-            content = content.replace(insert_marker, check_call + "\n" + insert_marker)
-        else:
-            # Try another location
-            result_marker = "final_response = llm_result.content or None"
-            if result_marker in content:
-                content = content.replace(result_marker, result_marker + "\n" + check_call)
-    
-    with open(AGENT_LOOP, "w", encoding="utf-8") as f:
-        f.write(content)
-    print(f"OK: Patched {AGENT_LOOP}")
-
-if __name__ == "__main__":
-    patch()

patch_auto_continue.py

@@ -1,129 +0,0 @@
-"""Patch script: Add auto-continue feature for free models in ml-intern.
-
-Apply this script during Docker build to enable:
-1. Detection when streaming ends but task incomplete
-2. "Tự động tiếp tục (10s)" button - auto continues after 10s
-3. "Tạm dừng" button - lets user send different content
-
-Usage: Run this during Docker build after cloning source.
-"""
-
-import os
-import re
-
-# Paths - adjust if needed
-USE_AGENT_CHAT = "/source/frontend/src/hooks/useAgentChat.ts"
-SSE_TRANSPORT = "/source/frontend/src/lib/sse-chat-transport.ts"
-AGENT_LOOP = "/app/agent/core/agent_loop.py"
-
-# =============================================================================
-# Patch 1: useAgentChat.ts
-# =============================================================================
-def patch_use_agent_chat():
-    if not os.path.exists(USE_AGENT_CHAT):
-        print(f"SKIP: {USE_AGENT_CHAT} not found")
-        return
-        
-    with open(USE_AGENT_CHAT, "r", encoding="utf-8") as f:
-        content = f.read()
-    
-    # Add useState to imports if missing
-    if "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';" not in content:
-        content = content.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # Add auto-continue state after callbacksRef
-    state_code = '''
-  // Auto-continue state for free models when task incomplete
-  const autoContinueTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [showAutoContinue, setShowAutoContinue] = useState(false);
-  const [taskIncompleteInfo, setTaskIncompleteInfo] = useState<{
-    incompletePlan: Array<{ id: string; content: string; status: string }>;
-  } | null>(null);
-'''
-    if "autoContinueTimerRef" not in content and "callbacksRef.current = { onReady, onError, onSessionDead }" in content:
-        content = content.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state_code
-        )
-    
-    # Add onTaskIncomplete to SideChannelCallbacks interface
-    if "onTaskIncomplete" not in content:
-        content = content.replace(
-            "onInterrupted: () => void;",
-            "onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    with open(USE_AGENT_CHAT, "w", encoding="utf-8") as f:
-        f.write(content)
-    print(f"OK: Patched {USE_AGENT_CHAT}")
-
-# =============================================================================
-# Patch 2: sse-chat-transport.ts  
-# =============================================================================
-def patch_sse_transport():
-    if not os.path.exists(SSE_TRANSPORT):
-        print(f"SKIP: {SSE_TRANSPORT} not found")
-        return
-    
-    with open(SSE_TRANSPORT, "r", encoding="utf-8") as f:
-        content = f.read()
-    
-    # Add task_incomplete case
-    if "case 'task_incomplete'" not in content:
-        task_incomplete_case = '''      case 'task_incomplete':
-          sideChannel.onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-'''
-        # Insert before turn_complete case
-        content = content.replace(
-            "case 'turn_complete':",
-            task_incomplete_case + "\n        case 'turn_complete':"
-        )
-    
-    with open(SSE_TRANSPORT, "w", encoding="utf-8") as f:
-        f.write(content)
-    print(f"OK: Patched {SSE_TRANSPORT}")
-
-# =============================================================================
-# Patch 3: agent_loop.py
-# =============================================================================
-def patch_agent_loop():
-    if not os.path.exists(AGENT_LOOP):
-        print(f"SKIP: {AGENT_LOOP} not found")
-        return
-    
-    with open(AGENT_LOOP, "r", encoding="utf-8") as f:
-        content = f.read()
-    
-    # Add check function if not exists
-    check_func = '''
-def _check_task_incomplete(session: Session, llm_result: LLMResult) -> bool:
-    """Check if model stopped but task is incomplete (has unfinished plan items)."""
-    if llm_result.tool_calls_acc:
-        return False  # Has tool calls, not incomplete
-    plan = getattr(session, "current_plan", None) or []
-    unfinished = [item for item in plan if item.get("status") in ("pending", "in_progress")]
-    return len(unfinished) > 0
-'''
-    if "_check_task_incomplete" not in content:
-        # Insert after LLMResult dataclass
-        content = content.replace(
-            "class Handlers:",
-            check_func + "\n\nclass Handlers:"
-        )
-    
-    with open(AGENT_LOOP, "w", encoding="utf-8") as f:
-        f.write(content)
-    print(f"OK: Patched {AGENT_LOOP}")
-
-
-if __name__ == "__main__":
-    patch_use_agent_chat()
-    patch_sse_transport()
-    patch_agent_loop()
-    print("\nDONE: Auto-continue patches applied")

patch_auto_continue_v10.py

@@ -1,202 +0,0 @@
-"""V10: Fixes scope issue with chat.sendMessage. 
-
-Uses: ref to store plan, useEffect + chatActionsRef to send."""
-import os, re
-
-events_ts = "/source/frontend/src/types/events.ts"
-sse_ts = "/source/frontend/src/lib/sse-chat-transport.ts"
-hook_ts = "/source/frontend/src/hooks/useAgentChat.ts"
-input_tsx = "/source/frontend/src/components/Chat/ChatInput.tsx"
-session_tsx = "/source/frontend/src/components/SessionChat.tsx"
-agent_py = "/app/agent/core/agent_loop.py"
-
-def patch_events():
-    with open(events_ts) as f: c = f.read()
-    if "'task_incomplete'" not in c:
-        c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-        with open(events_ts, 'w') as f: f.write(c)
-    print("OK: events.ts")
-
-def patch_sse():
-    with open(sse_ts) as f: c = f.read()
-    if "case 'task_incomplete'" not in c:
-        case_block = """      case 'task_incomplete':
-          (sideChannel as any).onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-        c = c.replace("\n        default:", "\n" + case_block)
-    with open(sse_ts, 'w') as f: f.write(c)
-    print("OK: sse.ts")
-
-def patch_hook():
-    with open(hook_ts) as f:
-        lines = f.readlines()
-    
-    # Find key insertion points by line number
-    result = []
-    state_added = False
-    handler_added = False
-    effect_added = False
-    cancel_added = False
-    return_added = False
-    
-    for i, line in enumerate(lines):
-        # 1. Add useState import
-        if "import { useCallback, useEffect, useMemo, useRef } from 'react';" in line and "useState" not in line:
-            line = line.replace("useRef }", "useRef, useState }")
-        
-        # 2. Add state after callbacksRef
-        if "callbacksRef.current = { onReady, onError, onSessionDead };" in line and not state_added:
-            result.append(line)
-            result.append('  // Auto-continue for free models\n')
-            result.append('  const [_showAc, _setShowAc] = useState(false);\n')
-            result.append('  const _acRef = useRef<Array<{ id: string; content: string; status: string }>>([]);\n')
-            state_added = True
-            continue
-        
-        # 3. Add handler in sideChannel's onSessionUpdate
-        if "onSessionUpdate: (data) => {" in line and not handler_added:
-            result.append(line)
-            result.append('        // Auto-continue: check for ac_plan\n')
-            result.append('        if ((data as any).ac_plan) {\n')
-            result.append('          _acRef.current = (data as any).ac_plan;\n')
-            result.append('          _setShowAc(true);\n')
-            result.append('          return;\n')
-            result.append('        }\n')
-            handler_added = True
-            continue
-        
-        # 4. Add cancel function + effect before return
-        stripped = line.strip()
-        if stripped == "return {" and not cancel_added:
-            result.append('  // Auto-continue cancel\n')
-            result.append('  const _acCancel = useCallback(() => { _setShowAc(false); }, []);\n')
-            cancel_added = True
-            # Add effect that uses chatActionsRef to send message
-            result.append('\n')
-            result.append('  // Auto-continue effect: 10s timer, sends via chatActionsRef\n')
-            result.append('  useEffect(() => {\n')
-            result.append('    if (!_showAc) return;\n')
-            result.append('    const plan = _acRef.current;\n')
-            result.append('    const timer = setTimeout(() => {\n')
-            result.append('      const s = chatActionsRef.current.setMessages;\n')
-            result.append('      const m = chatActionsRef.current.messages;\n')
-            result.append('      if (s && plan.length > 0) {\n')
-            result.append("        const t = plan.map(i => `- ${i.content}`).join('\\\\n');\n")
-            result.append("        s([...m, { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: `[TIẾP TỤC] Task chưa hoàn thành:\\\\n${t}` }], content: '' }]);\n")
-            result.append('      }\n')
-            result.append('      _setShowAc(false);\n')
-            result.append('    }, 10000);\n')
-            result.append('    return () => clearTimeout(timer);\n')
-            result.append('  }, [_showAc]);\n')
-            effect_added = True
-        
-        # 5. Return values
-        if "refreshMessages," in line and not return_added:
-            result.append(line)
-            result.append('    _showAc,\n')
-            result.append('    _acCancel,\n')
-            return_added = True
-            continue
-        
-        result.append(line)
-    
-    with open(hook_ts, 'w') as f: f.writelines(result)
-    print(f"OK: useAgentChat.ts (added={state_added}/{handler_added}/{cancel_added}/{effect_added}/{return_added})")
-
-def patch_chat_input():
-    with open(input_tsx) as f: c = f.read()
-    if "Button" not in c:
-        c = c.replace("  Tooltip,", "  Tooltip,\n  Button,")
-    
-    if "_showAc" not in c:
-        old_iface = """interface ChatInputProps {
-  sessionId?: string;
-  initialModelPath?: string | null;
-  onSend: (text: string) => void;
-  onStop?: () => void;
-  onDatasetUploaded?: () => Promise<boolean> | boolean;
-  isProcessing?: boolean;
-  disabled?: boolean;
-  placeholder?: string;
-}"""
-        new_iface = """interface ChatInputProps {
-  sessionId?: string;
-  initialModelPath?: string | null;
-  onSend: (text: string) => void;
-  onStop?: () => void;
-  onDatasetUploaded?: () => Promise<boolean> | boolean;
-  isProcessing?: boolean;
-  disabled?: boolean;
-  placeholder?: string;
-  _showAc?: boolean;
-  _acCancel?: () => void;
-}"""
-        c = c.replace(old_iface, new_iface)
-        old_props = "placeholder = 'Ask anything...' }: ChatInputProps) {"
-        new_props = "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-        c = c.replace(old_props, new_props)
-    
-    if "T\u1ea1m d\u1eebng" not in c:
-        btn = """
-        {_showAc && _acCancel && (
-          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>
-            <Button variant="outlined" size="small" onClick={_acCancel}
-              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>
-              T\u1ea1m d\u1eebng t\u1ef1 \u0111\u1ed9ng ti\u1ebfp t\u1ee5c (10s)
-            </Button>
-          </Box>
-        )}
-"""
-        if "<JobsUpgradeDialog" in c:
-            c = c.replace("<JobsUpgradeDialog", btn + "\n        <JobsUpgradeDialog")
-    
-    with open(input_tsx, 'w') as f: f.write(c)
-    print("OK: ChatInput.tsx")
-
-def patch_session():
-    if not os.path.exists(session_tsx):
-        print(f"SKIP: {session_tsx}"); return
-    with open(session_tsx) as f: c = f.read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-    with open(session_tsx, 'w') as f: f.write(c)
-    print("OK: SessionChat.tsx")
-
-def patch_agent():
-    if not os.path.exists(agent_py):
-        print(f"SKIP: {agent_py}"); return
-    with open(agent_py) as f: c = f.read()
-    
-    if "_unfinished_plan" not in c:
-        fn = """
-def _unfinished_plan(s: Session) -> list[dict[str, str]]:
-    p = getattr(s, "current_plan", None) or []
-    return [it for it in p if it.get("status") in ("pending", "in_progress")]
-"""
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    if "ac_plan" not in c:
-        check = """
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    current_ac = getattr(session, "auto_approval", None)
-                    await session.send_event(Event(event_type="session_update", data={
-                        "ac_plan": unfinished,
-                        "auto_approval": current_ac,
-                    }))
-"""
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + "\n" + marker)
-    
-    with open(agent_py, 'w') as f: f.write(c)
-    print("OK: agent_loop.py")
-
-if __name__ == "__main__":
-    patch_events(); patch_sse(); patch_hook(); patch_chat_input(); patch_session(); patch_agent()
-    print("\nDONE: V10")

patch_auto_continue_v11.py

@@ -1,185 +0,0 @@
-"""V11: Auto-continue feature - clean single-file patch.
-
-Backend: agent_loop.py detects model stopped mid-task, sends event.
-Frontend: useAgentChat listens via onSessionUpdate, shows pause button.
-All TS errors avoided via (as any) casts where needed.
-"""
-import os
-
-ROOT = "/source/frontend/src"
-EVENTS = f"{ROOT}/types/events.ts"
-SSE = f"{ROOT}/lib/sse-chat-transport.ts"
-HOOK = f"{ROOT}/hooks/useAgentChat.ts"
-INPUT = f"{ROOT}/components/Chat/ChatInput.tsx"
-SESS = f"{ROOT}/components/SessionChat.tsx"
-AGENT_LOOP = "/app/agent/core/agent_loop.py"
-
-def p(f, s):
-    print(f"OK: {f}" if s else f"FAIL: {f}")
-
-# --- PATCH 1: events.ts ---
-with open(EVENTS) as f: c = f.read()
-r1 = "'task_incomplete'" not in c
-if r1:
-    c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-    with open(EVENTS, 'w') as f: f.write(c)
-p("events.ts", r1)
-
-# --- PATCH 2: sse-chat-transport.ts ---
-with open(SSE) as f: c = f.read()
-r2 = "case 'task_incomplete'" not in c
-if r2:
-    block = """      case 'task_incomplete':
-          (sideChannel as any).onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-    c = c.replace("\n        default:", "\n" + block)
-    with open(SSE, 'w') as f: f.write(c)
-p("sse.ts", r2)
-
-# --- PATCH 3: useAgentChat.ts ---
-with open(HOOK) as f: lines = f.readlines()
-r3 = True
-new_lines = []
-state_done = False
-handler_done = False
-efx_done = False
-ret_done = False
-
-for line in lines:
-    if "import { useCallback, useEffect, useMemo, useRef } from 'react';" in line:
-        line = line.replace("useRef }", "useRef, useState }")
-    
-    if "callbacksRef.current = { onReady, onError, onSessionDead };" in line and not state_done:
-        new_lines.append(line)
-        new_lines.append("  // Auto-continue state\n")
-        new_lines.append("  const [_showAc, _setShowAc] = useState(false);\n")
-        new_lines.append("  const _acRef = useRef<Array<{ id: string; content: string; status: string }>>([]);\n")
-        state_done = True
-        continue
-    
-    if "onSessionUpdate: (data) => {" in line and not handler_done:
-        new_lines.append(line)
-        new_lines.append("        // Auto-continue check\n")
-        new_lines.append("        if ((data as any).ac_plan) {\n")
-        new_lines.append("          _acRef.current = (data as any).ac_plan;\n")
-        new_lines.append("          _setShowAc(true);\n")
-        new_lines.append("          return;\n")
-        new_lines.append("        }\n")
-        handler_done = True
-        continue
-    
-    stripped = line.strip()
-    if stripped == "return {" and not efx_done:
-        new_lines.append("  const _acCancel = useCallback(() => { _setShowAc(false); }, []);\n")
-        new_lines.append("  useEffect(() => {\n")
-        new_lines.append("    if (!_showAc) return;\n")
-        new_lines.append("    const plan = _acRef.current;\n")
-        new_lines.append("    const timer = setTimeout(() => {\n")
-        new_lines.append("      const s = chatActionsRef.current.setMessages;\n")
-        new_lines.append("      const m = chatActionsRef.current.messages;\n")
-        new_lines.append("      if (s && plan.length > 0) {\n")
-        new_lines.append("        const t = plan.map(i => `- ${i.content}`).join('\\n');\n")
-        new_lines.append("        const nu = { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: `[TIEP TUC] Task chua hoan thanh:\\n${t}` }], content: '' };\n")
-        new_lines.append("        s([...m, nu]);\n")
-        new_lines.append("      }\n")
-        new_lines.append("      _setShowAc(false);\n")
-        new_lines.append("    }, 10000);\n")
-        new_lines.append("    return () => clearTimeout(timer);\n")
-        new_lines.append("  }, [_showAc]);\n")
-        efx_done = True
-    
-    if "refreshMessages," in line and not ret_done:
-        new_lines.append(line)
-        new_lines.append("    _showAc,\n")
-        new_lines.append("    _acCancel,\n")
-        ret_done = True
-        continue
-    
-    new_lines.append(line)
-
-if not all([state_done, handler_done, efx_done, ret_done]):
-    r3 = False
-    print(f"  MISSING: state={state_done} handler={handler_done} effect={efx_done} ret={ret_done}")
-else:
-    with open(HOOK, 'w') as f: f.writelines(new_lines)
-p("useAgentChat.ts", r3)
-
-# --- PATCH 4: ChatInput.tsx ---
-with open(INPUT) as f: c = f.read()
-r4 = True
-if "Button" not in c:
-    c = c.replace("  Tooltip,", "  Tooltip,\n  Button,")
-
-if "_showAc" not in c:
-    old = "placeholder?: string;"
-    new = "placeholder?: string;\n  _showAc?: boolean;\n  _acCancel?: () => void;"
-    c = c.replace(old, new)
-    
-    old2 = "placeholder = 'Ask anything...' }: ChatInputProps) {"
-    new2 = "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-    c = c.replace(old2, new2)
-    
-    btn = """
-        {_showAc && _acCancel && (
-          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>
-            <Button variant="outlined" size="small" onClick={_acCancel}
-              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>
-              Tam dung tu dong tiep tuc (10s)
-            </Button>
-          </Box>
-        )}
-"""
-    c = c.replace("<JobsUpgradeDialog", btn + "\n        <JobsUpgradeDialog")
-else:
-    r4 = False
-
-with open(INPUT, 'w') as f: f.write(c)
-p("ChatInput.tsx", r4)
-
-# --- PATCH 5: SessionChat.tsx ---
-if os.path.exists(SESS):
-    with open(SESS) as f: c = f.read()
-    r5 = "_showAc" not in c
-    if r5:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-        with open(SESS, 'w') as f: f.write(c)
-    p("SessionChat.tsx", r5)
-else:
-    print("SKIP: SessionChat.tsx")
-
-# --- PATCH 6: agent_loop.py ---
-if os.path.exists(AGENT_LOOP):
-    with open(AGENT_LOOP) as f: c = f.read()
-    r6 = True
-    if "_unfinished_plan" not in c:
-        fn = """
-def _unfinished_plan(s):
-    p = getattr(s, "current_plan", None) or []
-    return [it for it in p if it.get("status") in ("pending", "in_progress")]
-"""
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    if "ac_plan" not in c:
-        check = """
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    await session.send_event(Event(event_type="session_update", data={
-                        "ac_plan": unfinished,
-                    }))
-"""
-        marker = "  # -- End of turn --"
-        c = c.replace(marker, check + "\n" + marker)
-    else:
-        r6 = False
-    
-    with open(AGENT_LOOP, 'w') as f: f.write(c)
-    p("agent_loop.py", r6)
-else:
-    print("SKIP: agent_loop.py")
-
-print("\nDONE: V11")

patch_auto_continue_v12.py

@@ -1,209 +0,0 @@
-"""V12: Auto-continue feature - final fix.
-
-Key fixes for V11 bugs:
-1. Button import: check exact MUI import format
-2. useAgentChat: match two-line `return {\n    messages: chat.messages,` instead of bare `return {`
-3. Use \u unicode escapes for Vietnamese text
-"""
-
-import os
-
-ROOT = "/source/frontend/src"
-EVENTS = f"{ROOT}/types/events.ts"
-SSE = f"{ROOT}/lib/sse-chat-transport.ts"
-HOOK = f"{ROOT}/hooks/useAgentChat.ts"
-INPUT = f"{ROOT}/components/Chat/ChatInput.tsx"
-SESS = f"{ROOT}/components/SessionChat.tsx"
-AGENT = "/app/agent/core/agent_loop.py"
-
-def ok(f):
-    print(f"OK: {f}")
-
-# --- 1. events.ts: add task_incomplete ---
-with open(EVENTS) as f:
-    c = f.read()
-if "'task_incomplete'" not in c:
-    c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-    with open(EVENTS, 'w') as f:
-        f.write(c)
-ok("events.ts")
-
-# --- 2. sse-chat-transport.ts: add case handler ---
-with open(SSE) as f:
-    c = f.read()
-if "case 'task_incomplete'" not in c:
-    block = """      case 'task_incomplete':
-          (sideChannel as any).onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-    c = c.replace("\n        default:", "\n" + block)
-    with open(SSE, 'w') as f:
-        f.write(c)
-ok("sse.ts")
-
-# --- 3. useAgentChat.ts: add state, handler, effect, return ---
-with open(HOOK) as f:
-    content = f.read()
-
-# Add useState to import
-if "useState" not in content:
-    content = content.replace(
-        "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-        "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-    )
-
-# Add state after callbacksRef line
-state_block = """\
-  // Auto-continue state
-  const [_showAc, _setShowAc] = useState(false);
-  const _acRef = useRef<Array<{ id: string; content: string; status: string }>>([]);
-"""
-if "_showAc" not in content:
-    content = content.replace(
-        "callbacksRef.current = { onReady, onError, onSessionDead };",
-        "callbacksRef.current = { onReady, onError, onSessionDead };\n" + state_block
-    )
-
-# Add handler inside onSessionUpdate
-handler_code = """\
-        // Auto-continue check
-        if ((data as any).ac_plan) {
-          _acRef.current = (data as any).ac_plan;
-          _setShowAc(true);
-          return;
-        }
-"""
-if "ac_plan" not in content:
-    content = content.replace(
-        "onSessionUpdate: (data) => {",
-        "onSessionUpdate: (data) => {\n" + handler_code
-    )
-
-# Add cancel + effect BEFORE the two-line return marker
-cancel_effect = """\
-  const _acCancel = useCallback(() => { _setShowAc(false); }, []);
-  useEffect(() => {
-    if (!_showAc) return;
-    const plan = _acRef.current;
-    const timer = setTimeout(() => {
-      const s = chatActionsRef.current.setMessages;
-      const m = chatActionsRef.current.messages;
-      if (s && plan.length > 0) {
-        const t = plan.map((i: { content: string }) => `- ${i.content}`).join('\\n');
-        const nu = { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: `[TIEP TUC] Task chua hoan thanh:\\n${t}` }], content: '' };
-        s([...m, nu]);
-      }
-      _setShowAc(false);
-    }, 10000);
-    return () => clearTimeout(timer);
-  }, [_showAc]);
-
-"""
-if "_acCancel" not in content:
-    # Match the EXACT two-line return pattern
-    content = content.replace(
-        "  return {\n    messages: chat.messages,",
-        cancel_effect + "  return {\n    messages: chat.messages,"
-    )
-
-# Add return values
-if "_showAc," not in content:
-    content = content.replace(
-        "refreshMessages,\n  };",
-        "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-    )
-
-with open(HOOK, 'w') as f:
-    f.write(content)
-ok("useAgentChat.ts")
-
-# --- 4. ChatInput.tsx: add Button + props + pause button ---
-with open(INPUT) as f:
-    content = f.read()
-
-# Add Button to MUI imports - match the actual format
-if "Button" not in content:
-    content = content.replace(
-        "  Tooltip,",
-        "  Tooltip,\n  Button,"
-    )
-
-# Add props to interface
-if "_showAc" not in content:
-    content = content.replace(
-        "placeholder?: string;",
-        "placeholder?: string;\n  _showAc?: boolean;\n  _acCancel?: () => void;"
-    )
-
-# Add to destructured function params
-if "_showAc" not in content or "_acCancel" not in content:
-    content = content.replace(
-        "placeholder = 'Ask anything...' }: ChatInputProps) {",
-        "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-    )
-
-# Add pause button before JobsUpgradeDialog
-if "Tam dung" not in content:
-    btn = """
-        {_showAc && _acCancel && (
-          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>
-            <Button variant="outlined" size="small" onClick={_acCancel}
-              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>
-              T\u1ea1m d\u1eebng t\u1ef1 \u0111\u1ed9ng ti\u1ebfp t\u1ee5c (10s)
-            </Button>
-          </Box>
-        )}
-"""
-    content = content.replace("<JobsUpgradeDialog", btn + "\n        <JobsUpgradeDialog")
-
-with open(INPUT, 'w') as f:
-    f.write(content)
-ok("ChatInput.tsx")
-
-# --- 5. SessionChat.tsx: pass props ---
-if os.path.exists(SESS):
-    with open(SESS) as f:
-        c = f.read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-        with open(SESS, 'w') as f:
-            f.write(c)
-    ok("SessionChat.tsx")
-
-# --- 6. agent_loop.py: detection ---
-if os.path.exists(AGENT):
-    with open(AGENT) as f:
-        c = f.read()
-    
-    if "_unfinished_plan" not in c:
-        fn = """
-
-def _unfinished_plan(s):
-    p = getattr(s, "current_plan", None) or []
-    return [it for it in p if it.get("status") in ("pending", "in_progress")]
-"""
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    if "ac_plan" not in c:
-        check = """
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    await session.send_event(Event(event_type="session_update", data={
-                        "ac_plan": unfinished,
-                    }))
-"""
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + marker)
-    
-    with open(AGENT, 'w') as f:
-        f.write(c)
-    ok("agent_loop.py")
-else:
-    print("SKIP: agent_loop.py (backend)")
-
-print("\nDONE: V12")

patch_auto_continue_v13.py

@@ -1,197 +0,0 @@
-"""V13: Auto-continue feature - fixed SyntaxError, no raw \u in Python source"""
-
-import os
-
-ROOT = "/source/frontend/src"
-EVENTS = f"{ROOT}/types/events.ts"
-SSE = f"{ROOT}/lib/sse-chat-transport.ts"
-HOOK = f"{ROOT}/hooks/useAgentChat.ts"
-INPUT = f"{ROOT}/components/Chat/ChatInput.tsx"
-SESS = f"{ROOT}/components/SessionChat.tsx"
-AGENT = "/app/agent/core/agent_loop.py"
-
-# Vietnamese text as hex to avoid \u issues in Python source
-PAUSE_TEXT = "T\\u1ea1m d\\u1eebng t\\u1ef1 \\u0111\\u1ed9ng ti\\u1ebfp t\\u1ee5c (10s)"
-CONTINUE_TEXT = "[TIEP TUC] Task chua hoan thanh:"
-
-def ok(f):
-    print(f"OK: {f}")
-
-# --- 1. events.ts ---
-with open(EVENTS) as f:
-    c = f.read()
-if "'task_incomplete'" not in c:
-    c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-    with open(EVENTS, 'w') as f:
-        f.write(c)
-ok("events.ts")
-
-# --- 2. sse.ts ---
-with open(SSE) as f:
-    c = f.read()
-if "case 'task_incomplete'" not in c:
-    block = """      case 'task_incomplete':
-          (sideChannel as any).onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-    c = c.replace("\n        default:", "\n" + block)
-    with open(SSE, 'w') as f:
-        f.write(c)
-ok("sse.ts")
-
-# --- 3. useAgentChat.ts ---
-with open(HOOK) as f:
-    content = f.read()
-
-if "useState" not in content:
-    content = content.replace(
-        "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-        "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-    )
-
-state_block = """\
-  // Auto-continue state
-  const [_showAc, _setShowAc] = useState(false);
-  const _acRef = useRef<Array<{ id: string; content: string; status: string }>>([]);
-"""
-if "_showAc" not in content:
-    content = content.replace(
-        "callbacksRef.current = { onReady, onError, onSessionDead };",
-        "callbacksRef.current = { onReady, onError, onSessionDead };\n" + state_block
-    )
-
-handler_code = """\
-        // Auto-continue check
-        if ((data as any).ac_plan) {
-          _acRef.current = (data as any).ac_plan;
-          _setShowAc(true);
-          return;
-        }
-"""
-if "ac_plan" not in content:
-    content = content.replace(
-        "onSessionUpdate: (data) => {",
-        "onSessionUpdate: (data) => {\n" + handler_code
-    )
-
-cancel_effect = """\
-  const _acCancel = useCallback(() => { _setShowAc(false); }, []);
-  useEffect(() => {
-    if (!_showAc) return;
-    const plan = _acRef.current;
-    const timer = setTimeout(() => {
-      const s = chatActionsRef.current.setMessages;
-      const m = chatActionsRef.current.messages;
-      if (s && plan.length > 0) {
-        const t = plan.map((i: { content: string }) => '- ' + i.content).join('\\\\n');
-        const nu = { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: '""" + CONTINUE_TEXT + "\\\\n' + t }], content: '' };\n"
-cancel_effect += """\
-        s([...m, nu]);
-      }
-      _setShowAc(false);
-    }, 10000);
-    return () => clearTimeout(timer);
-  }, [_showAc]);
-
-"""
-if "_acCancel" not in content:
-    content = content.replace(
-        "  return {\n    messages: chat.messages,",
-        cancel_effect + "  return {\n    messages: chat.messages,"
-    )
-
-if "_showAc," not in content:
-    content = content.replace(
-        "refreshMessages,\n  };",
-        "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-    )
-
-with open(HOOK, 'w') as f:
-    f.write(content)
-ok("useAgentChat.ts")
-
-# --- 4. ChatInput.tsx ---
-with open(INPUT) as f:
-    content = f.read()
-
-if "Button" not in content:
-    content = content.replace(
-        "  Tooltip,",
-        "  Tooltip,\n  Button,"
-    )
-
-if "_showAc" not in content:
-    content = content.replace(
-        "placeholder?: string;",
-        "placeholder?: string;\n  _showAc?: boolean;\n  _acCancel?: () => void;"
-    )
-    content = content.replace(
-        "placeholder = 'Ask anything...' }: ChatInputProps) {",
-        "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-    )
-
-pause_marker = "TAM_DUNG"
-if pause_marker not in content:
-    btn = """
-        {_showAc && _acCancel && (
-          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>
-            <Button variant="outlined" size="small" onClick={_acCancel}
-              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>
-              """ + PAUSE_TEXT + """
-            </Button>
-          </Box>
-        )}
-"""
-    content = content.replace("<JobsUpgradeDialog", btn + "\n        <JobsUpgradeDialog")
-
-with open(INPUT, 'w') as f:
-    f.write(content)
-ok("ChatInput.tsx")
-
-# --- 5. SessionChat.tsx ---
-if os.path.exists(SESS):
-    with open(SESS) as f:
-        c = f.read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-        with open(SESS, 'w') as f:
-            f.write(c)
-    ok("SessionChat.tsx")
-
-# --- 6. agent_loop.py ---
-if os.path.exists(AGENT):
-    with open(AGENT) as f:
-        c = f.read()
-    
-    if "_unfinished_plan" not in c:
-        fn = """
-
-def _unfinished_plan(s):
-    p = getattr(s, "current_plan", None) or []
-    return [it for it in p if it.get("status") in ("pending", "in_progress")]
-"""
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    if "ac_plan" not in c:
-        check = """
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    await session.send_event(Event(event_type="session_update", data={
-                        "ac_plan": unfinished,
-                    }))
-"""
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + marker)
-    
-    with open(AGENT, 'w') as f:
-        f.write(c)
-    ok("agent_loop.py")
-else:
-    print("SKIP: agent_loop.py")
-
-print("\nDONE: V13")

patch_auto_continue_v14.py

@@ -1,166 +0,0 @@
-"""V14: Auto-continue. Use ASCII-only text for reliable build."""
-
-import os, sys
-
-ROOT = "/source/frontend/src"
-
-FILES = {
-    "events.ts": ROOT + "/types/events.ts",
-    "sse.ts": ROOT + "/lib/sse-chat-transport.ts",
-    "hook.ts": ROOT + "/hooks/useAgentChat.ts",
-    "input.tsx": ROOT + "/components/Chat/ChatInput.tsx",
-    "sess.tsx": ROOT + "/components/SessionChat.tsx",
-    "agent.py": "/app/agent/core/agent_loop.py",
-}
-
-# 1. events.ts
-c = open(FILES["events.ts"]).read()
-if "'task_incomplete'" not in c:
-    c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-    open(FILES["events.ts"], 'w').write(c)
-print("OK: events.ts")
-
-# 2. sse.ts
-c = open(FILES["sse.ts"]).read()
-if "case 'task_incomplete'" not in c:
-    block = """      case 'task_incomplete':
-          (sideChannel as any).onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-    c = c.replace("\n        default:", "\n" + block)
-    open(FILES["sse.ts"], 'w').write(c)
-print("OK: sse.ts")
-
-# 3. hook.ts - useAgentChat.ts
-c = open(FILES["hook.ts"]).read()
-
-# useState import
-if "useState" not in c:
-    c = c.replace(
-        "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-        "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-    )
-
-# State after callbacksRef
-if "_showAc" not in c:
-    state_block = (
-        "  // Auto-continue state\n"
-        "  const [_showAc, _setShowAc] = useState(false);\n"
-        "  const _acRef = useRef<Array<{ id: string; content: string; status: string }>>([]);\n"
-    )
-    c = c.replace(
-        "callbacksRef.current = { onReady, onError, onSessionDead };",
-        "callbacksRef.current = { onReady, onError, onSessionDead };\n" + state_block
-    )
-
-# Handler in onSessionUpdate
-if "ac_plan" not in c:
-    handler = (
-        "        // Auto-continue check\n"
-        "        if ((data as any).ac_plan) {\n"
-        "          _acRef.current = (data as any).ac_plan;\n"
-        "          _setShowAc(true);\n"
-        "          return;\n"
-        "        }\n"
-    )
-    c = c.replace("onSessionUpdate: (data) => {", "onSessionUpdate: (data) => {\n" + handler)
-
-# Cancel + effect before return
-if "_acCancel" not in c:
-    cancel = "  const _acCancel = useCallback(() => { _setShowAc(false); }, []);\n"
-    effect = (
-        "  useEffect(() => {\n"
-        "    if (!_showAc) return;\n"
-        "    const plan = _acRef.current;\n"
-        "    const timer = setTimeout(() => {\n"
-        "      const s = chatActionsRef.current.setMessages;\n"
-        "      const m = chatActionsRef.current.messages;\n"
-        "      if (s && plan.length > 0) {\n"
-        "        const t = plan.map((i: { content: string }) => '- ' + i.content).join('\\\\n');\n"
-        "        const nu = { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: '[TIEP TUC] Task chua hoan thanh:\\\\n' + t }], content: '' };\n"
-        "        s([...m, nu]);\n"
-        "      }\n"
-        "      _setShowAc(false);\n"
-        "    }, 10000);\n"
-        "    return () => clearTimeout(timer);\n"
-        "  }, [_showAc]);\n\n"
-    )
-    c = c.replace(
-        "  return {\n    messages: chat.messages,",
-        cancel + effect + "  return {\n    messages: chat.messages,"
-    )
-
-# Return values
-if "_showAc," not in c:
-    c = c.replace("refreshMessages,\n  };", "refreshMessages,\n    _showAc,\n    _acCancel,\n  };")
-
-open(FILES["hook.ts"], 'w').write(c)
-print("OK: useAgentChat.ts")
-
-# 4. input.tsx - ChatInput.tsx
-c = open(FILES["input.tsx"]).read()
-
-if "Button" not in c:
-    # Match the exact MUI import block
-    c = c.replace("import {\n  Alert,\n  Box,\n  TextField,\n  IconButton,\n  CircularProgress,\n  Typography,\n  Menu,\n  MenuItem,\n  ListItemIcon,\n  ListItemText,\n  Chip,\n  LinearProgress,\n  Snackbar,\n  Tooltip,\n} from '@mui/material';",
-        "import {\n  Alert,\n  Box,\n  TextField,\n  IconButton,\n  CircularProgress,\n  Typography,\n  Menu,\n  MenuItem,\n  ListItemIcon,\n  ListItemText,\n  Chip,\n  LinearProgress,\n  Snackbar,\n  Tooltip,\n  Button,\n} from '@mui/material';")
-
-if "_showAc" not in c:
-    c = c.replace("placeholder?: string;", "placeholder?: string;\n  _showAc?: boolean;\n  _acCancel?: () => void;")
-    c = c.replace("placeholder = 'Ask anything...' }: ChatInputProps) {",
-                  "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {")
-
-if "TAM_DUNG" not in c:
-    btn = (
-        "        {_showAc && _acCancel && (\n"
-        "          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>\n"
-        "            <Button variant=\"outlined\" size=\"small\" onClick={_acCancel}\n"
-        "              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>\n"
-        "              TAM_DUNG_TU_DONG_TIEP_TUC\n"
-        "            </Button>\n"
-        "          </Box>\n"
-        "        )}\n"
-    )
-    c = c.replace("<JobsUpgradeDialog", btn + "        <JobsUpgradeDialog")
-
-open(FILES["input.tsx"], 'w').write(c)
-print("OK: ChatInput.tsx")
-
-# 5. sess.tsx - SessionChat.tsx
-if os.path.exists(FILES["sess.tsx"]):
-    c = open(FILES["sess.tsx"]).read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-        open(FILES["sess.tsx"], 'w').write(c)
-    print("OK: SessionChat.tsx")
-
-# 6. agent.py
-if os.path.exists(FILES["agent.py"]):
-    c = open(FILES["agent.py"]).read()
-    
-    if "_unfinished_plan" not in c:
-        fn = "\n\ndef _unfinished_plan(s):\n    p = getattr(s, 'current_plan', None) or []\n    return [it for it in p if it.get('status') in ('pending', 'in_progress')]\n"
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    if "ac_plan" not in c:
-        check = (
-            "\n            if not llm_result.tool_calls_acc and llm_result.content:\n"
-            "                unfinished = _unfinished_plan(session)\n"
-            "                if unfinished:\n"
-            "                    await session.send_event(Event(event_type='session_update', data={\n"
-            "                        'ac_plan': unfinished,\n"
-            "                    }))\n"
-        )
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + marker)
-    
-    open(FILES["agent.py"], 'w').write(c)
-    print("OK: agent_loop.py")
-else:
-    print("SKIP: agent_loop.py")
-
-print("\nDONE: V14")

patch_auto_continue_v15.py

@@ -1,167 +0,0 @@
-"""V15: Auto-continue - fix Button import detection + return matching."""
-
-import os
-
-ROOT = "/source/frontend/src"
-EVENTS = ROOT + "/types/events.ts"
-SSE = ROOT + "/lib/sse-chat-transport.ts"
-HOOK = ROOT + "/hooks/useAgentChat.ts"
-INPUT = ROOT + "/components/Chat/ChatInput.tsx"
-SESS = ROOT + "/components/SessionChat.tsx"
-AGENT = "/app/agent/core/agent_loop.py"
-
-def ok(f): print(f"OK: {f}")
-
-# 1. events.ts
-with open(EVENTS) as f: c = f.read()
-if "'task_incomplete'" not in c:
-    c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-    with open(EVENTS, 'w') as f: f.write(c)
-ok("events.ts")
-
-# 2. sse.ts
-with open(SSE) as f: c = f.read()
-if "case 'task_incomplete'" not in c:
-    block = """      case 'task_incomplete':
-          (sideChannel as any).onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-    c = c.replace("\n        default:", "\n" + block)
-    with open(SSE, 'w') as f: f.write(c)
-ok("sse.ts")
-
-# 3. useAgentChat.ts
-with open(HOOK) as f:
-    lines = f.readlines()
-
-new_lines = []
-state_ok = hdl_ok = efx_ok = ret_ok = False
-
-for line in lines:
-    # Import useState
-    if "import { useCallback, useEffect, useMemo, useRef } from 'react';" in line:
-        line = line.replace("useRef }", "useRef, useState }")
-    
-    # State after callbacksRef
-    if "callbacksRef.current = { onReady, onError, onSessionDead };" in line and not state_ok:
-        new_lines.append(line)
-        new_lines.append("  const [_showAc, _setShowAc] = useState(false);\n")
-        new_lines.append("  const _acRef = useRef<Array<{ id: string; content: string; status: string }>>([]);\n")
-        state_ok = True
-        continue
-    
-    # Handler
-    if "onSessionUpdate: (data) => {" in line and not hdl_ok:
-        new_lines.append(line)
-        new_lines.append("        if ((data as any).ac_plan) {\n")
-        new_lines.append("          _acRef.current = (data as any).ac_plan;\n")
-        new_lines.append("          _setShowAc(true);\n")
-        new_lines.append("          return;\n")
-        new_lines.append("        }\n")
-        hdl_ok = True
-        continue
-    
-    # Cancel + effect BEFORE 'return {'
-    stripped = line.strip()
-    if stripped == "return {" and not efx_ok:
-        new_lines.append("  const _acCancel = useCallback(() => { _setShowAc(false); }, []);\n")
-        new_lines.append("  useEffect(() => {\n")
-        new_lines.append("    if (!_showAc) return;\n")
-        new_lines.append("    const plan = _acRef.current;\n")
-        new_lines.append("    const timer = setTimeout(() => {\n")
-        new_lines.append("      const s = chatActionsRef.current.setMessages;\n")
-        new_lines.append("      const m = chatActionsRef.current.messages;\n")
-        new_lines.append("      if (s && plan.length > 0) {\n")
-        new_lines.append("        const t = plan.map((i: { content: string }) => '- ' + i.content).join('\\\\n');\n")
-        new_lines.append("        const nu = { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: '[TIEP TUC] Task chua hoan thanh:\\\\n' + t }], content: '' };\n")
-        new_lines.append("        s([...m, nu]);\n")
-        new_lines.append("      }\n")
-        new_lines.append("      _setShowAc(false);\n")
-        new_lines.append("    }, 10000);\n")
-        new_lines.append("    return () => clearTimeout(timer);\n")
-        new_lines.append("  }, [_showAc]);\n\n")
-        efx_ok = True
-    
-    # Add return values after "refreshMessages,"
-    if "refreshMessages," in line and not ret_ok:
-        new_lines.append(line)
-        new_lines.append("    _showAc,\n")
-        new_lines.append("    _acCancel,\n")
-        ret_ok = True
-        continue
-    
-    new_lines.append(line)
-
-with open(HOOK, 'w') as f:
-    f.writelines(new_lines)
-ok(f"useAgentChat.ts (s={state_ok} h={hdl_ok} e={efx_ok} r={ret_ok})")
-
-# 4. ChatInput.tsx
-with open(INPUT) as f:
-    content = f.read()
-
-# Check for exact Button in MUI import (not "IconButton" which contains "Button")
-if "  Button,\n" not in content and "  Button\n" not in content:
-    content = content.replace(
-        "  Tooltip,",
-        "  Tooltip,\n  Button,"
-    )
-
-# Add props to interface
-if "_showAc" not in content:
-    content = content.replace("placeholder?: string;", "placeholder?: string;\n  _showAc?: boolean;\n  _acCancel?: () => void;")
-    content = content.replace("placeholder = 'Ask anything...' }: ChatInputProps) {",
-                             "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {")
-
-    # Add pause button before <JobsUpgradeDialog
-    btn = (
-        "        {_showAc && _acCancel && (\n"
-        "          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>\n"
-        "            <Button variant=\"outlined\" size=\"small\" onClick={_acCancel}\n"
-        "              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>\n"
-        "              TAM_DUNG_TU_DONG_TIEP_TUC (10s)\n"
-        "            </Button>\n"
-        "          </Box>\n"
-        "        )}\n"
-    )
-    content = content.replace("<JobsUpgradeDialog", btn + "        <JobsUpgradeDialog")
-
-with open(INPUT, 'w') as f:
-    f.write(content)
-ok("ChatInput.tsx")
-
-# 5. SessionChat.tsx
-if os.path.exists(SESS):
-    with open(SESS) as f: c = f.read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-        with open(SESS, 'w') as f: f.write(c)
-    ok("SessionChat.tsx")
-
-# 6. agent_loop.py
-if os.path.exists(AGENT):
-    with open(AGENT) as f: c = f.read()
-    if "_unfinished_plan" not in c:
-        fn = "\n\ndef _unfinished_plan(s):\n    p = getattr(s, 'current_plan', None) or []\n    return [it for it in p if it.get('status') in ('pending', 'in_progress')]\n"
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    if "ac_plan" not in c:
-        check = (
-            "\n            if not llm_result.tool_calls_acc and llm_result.content:\n"
-            "                unfinished = _unfinished_plan(session)\n"
-            "                if unfinished:\n"
-            "                    await session.send_event(Event(event_type='session_update', data={\n"
-            "                        'ac_plan': unfinished,\n"
-            "                    }))\n"
-        )
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + marker)
-    with open(AGENT, 'w') as f: f.write(c)
-    ok("agent_loop.py")
-else:
-    print("SKIP: agent_loop.py")
-
-print("\nDONE: V15")

patch_auto_continue_v16.py

@@ -1,142 +0,0 @@
-"""V16: Auto-continue - match exact 'return {\n    messages: chat.messages,' (only one in file)"""
-
-import os, sys
-
-F = lambda n: "/source/frontend/src/" + n
-EVENTS = F("types/events.ts")
-SSE = F("lib/sse-chat-transport.ts")
-HOOK = F("hooks/useAgentChat.ts")
-INPUT = F("components/Chat/ChatInput.tsx")
-SESS = F("components/SessionChat.tsx")
-AGENT = "/app/agent/core/agent_loop.py"
-
-def ok(f): print(f"OK: {f}")
-
-# --- events.ts ---
-with open(EVENTS) as f: c = f.read()
-if "'task_incomplete'" not in c:
-    c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-    open(EVENTS, 'w').write(c)
-ok("events.ts")
-
-# --- sse.ts ---
-with open(SSE) as f: c = f.read()
-if "case 'task_incomplete'" not in c:
-    c = c.replace("\n        default:", "\n      case 'task_incomplete':\n          (sideChannel as any).onTaskIncomplete(\n            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],\n          );\n          break;\n\n        default:")
-    open(SSE, 'w').write(c)
-ok("sse.ts")
-
-# --- useAgentChat.ts ---
-with open(HOOK) as f: content = f.read()
-
-# useState import
-if "useState" not in content:
-    content = content.replace("useRef }", "useRef, useState }")
-
-# State after callbacksRef (insert once)
-if "_showAc" not in content:
-    s = ("  // Auto-continue state\n"
-         "  const [_showAc, _setShowAc] = useState(false);\n"
-         "  const _acRef = useRef<Array<{ id: string; content: string; status: string }>>([]);\n")
-    content = content.replace(
-        "callbacksRef.current = { onReady, onError, onSessionDead };",
-        "callbacksRef.current = { onReady, onError, onSessionDead };\n" + s
-    )
-
-# Handler in onSessionUpdate
-if "ac_plan" not in content:
-    h = ("        // Auto-continue check\n"
-         "        if ((data as any).ac_plan) {\n"
-         "          _acRef.current = (data as any).ac_plan;\n"
-         "          _setShowAc(true);\n"
-         "          return;\n"
-         "        }\n")
-    content = content.replace("onSessionUpdate: (data) => {", "onSessionUpdate: (data) => {\n" + h)
-
-# CRITICAL: Only match the exact two-line return that has messages: chat.messages
-# Only ONE place in the file has this exact pattern
-marker = "  return {\n    messages: chat.messages,"
-if marker in content and "_acCancel" not in content:
-    cancel_effect = (
-        "  const _acCancel = useCallback(() => { _setShowAc(false); }, []);\n"
-        "  useEffect(() => {\n"
-        "    if (!_showAc) return;\n"
-        "    const plan = _acRef.current;\n"
-        "    const timer = setTimeout(() => {\n"
-        "      const s = chatActionsRef.current.setMessages;\n"
-        "      const m = chatActionsRef.current.messages;\n"
-        "      if (s && plan.length > 0) {\n"
-        "        const t = plan.map((i: { content: string }) => '- ' + i.content).join('\\\\n');\n"
-        "        const nu = { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: '[TIEP TUC] Task chua hoan thanh:\\\\n' + t }], content: '' };\n"
-        "        s([...m, nu]);\n"
-        "      }\n"
-        "      _setShowAc(false);\n"
-        "    }, 10000);\n"
-        "    return () => clearTimeout(timer);\n"
-        "  }, [_showAc]);\n\n"
-    )
-    content = content.replace(marker, cancel_effect + marker)
-    
-    # Add to return values
-    content = content.replace(
-        "refreshMessages,\n  };",
-        "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-    )
-    
-with open(HOOK, 'w').write(content)
-ok("useAgentChat.ts")
-
-# --- ChatInput.tsx ---
-with open(INPUT) as f: content = f.read()
-
-# Button: check for standalone ",  Button" or "  Button" NOT "IconButton"
-if ",  Button,\n" not in content and ",  Button\n" not in content:
-    content = content.replace(
-        "  Tooltip,",
-        "  Tooltip,\n  Button,"
-    )
-
-if "_showAc" not in content:
-    content = content.replace("placeholder?: string;", "placeholder?: string;\n  _showAc?: boolean;\n  _acCancel?: () => void;")
-    content = content.replace("placeholder = 'Ask anything...' }: ChatInputProps) {",
-                             "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {")
-    btn = ("        {_showAc && _acCancel && (\n"
-           "          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>\n"
-           "            <Button variant=\"outlined\" size=\"small\" onClick={_acCancel}\n"
-           "              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>\n"
-           "              TAM_DUNG_TU_DONG_TIEP_TUC (10s)\n"
-           "            </Button>\n"
-           "          </Box>\n"
-           "        )}\n")
-    content = content.replace("<JobsUpgradeDialog", btn + "        <JobsUpgradeDialog")
-
-open(INPUT, 'w').write((content).read() if hasattr(content, 'read') else content)
-ok("ChatInput.tsx")
-
-# --- SessionChat.tsx ---
-if os.path.exists(SESS):
-    with open(SESS) as f: c = f.read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-        open(SESS, 'w').write(c)
-    ok("SessionChat.tsx")
-
-# --- agent_loop.py ---
-if os.path.exists(AGENT):
-    with open(AGENT) as f: c = f.read()
-    if "_unfinished_plan" not in c:
-        c = c.replace("class Handlers:", "\n\ndef _unfinished_plan(s):\n    p = getattr(s, 'current_plan', None) or []\n    return [it for it in p if it.get('status') in ('pending', 'in_progress')]\n\n\nclass Handlers:")
-    if "ac_plan" not in c:
-        check = ("\n            if not llm_result.tool_calls_acc and llm_result.content:\n"
-                 "                unfinished = _unfinished_plan(session)\n"
-                 "                if unfinished:\n"
-                 "                    await session.send_event(Event(event_type='session_update', data={\n"
-                 "                        'ac_plan': unfinished,\n"
-                 "                    }))\n")
-        c = c.replace("  # -- End of turn --", check + "  # -- End of turn --")
-    open(AGENT, 'w').write(c)
-    ok("agent_loop.py")
-else:
-    print("SKIP: agent_loop.py")
-
-print("\nDONE: V16")

patch_auto_continue_v17.py

@@ -1,187 +0,0 @@
-"""V17: Auto-continue - perfect Python, exact marker matching"""
-
-import os
-
-EVENTS = "/source/frontend/src/types/events.ts"
-SSE = "/source/frontend/src/lib/sse-chat-transport.ts"
-HOOK = "/source/frontend/src/hooks/useAgentChat.ts"
-INPUT = "/source/frontend/src/components/Chat/ChatInput.tsx"
-SESS = "/source/frontend/src/components/SessionChat.tsx"
-AGENT = "/app/agent/core/agent_loop.py"
-
-print("Patching auto-continue V17...")
-
-# --- events.ts ---
-with open(EVENTS) as f:
-    c = f.read()
-if "'task_incomplete'" not in c:
-    c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-    with open(EVENTS, 'w') as f:
-        f.write(c)
-print("OK: events.ts")
-
-# --- sse.ts ---
-with open(SSE) as f:
-    c = f.read()
-if "case 'task_incomplete'" not in c:
-    block = (
-        "      case 'task_incomplete':\n"
-        "          (sideChannel as any).onTaskIncomplete(\n"
-        "            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],\n"
-        "          );\n"
-        "          break;\n\n"
-        "        default:"
-    )
-    c = c.replace("\n        default:", "\n" + block)
-    with open(SSE, 'w') as f:
-        f.write(c)
-print("OK: sse.ts")
-
-# --- useAgentChat.ts ---
-with open(HOOK) as f:
-    content = f.read()
-
-# Add useState import
-if "useState" not in content:
-    content = content.replace(
-        "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-        "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-    )
-
-# Add state after callbacksRef
-if "_showAc" not in content:
-    state_code = (
-        "  // Auto-continue state\n"
-        "  const [_showAc, _setShowAc] = useState(false);\n"
-        "  const _acRef = useRef<Array<{ id: string; content: string; status: string }>>([]);\n"
-    )
-    content = content.replace(
-        "callbacksRef.current = { onReady, onError, onSessionDead };",
-        "callbacksRef.current = { onReady, onError, onSessionDead };\n" + state_code
-    )
-
-# Add handler in onSessionUpdate
-if "ac_plan" not in content:
-    h = (
-        "        // Auto-continue check\n"
-        "        if ((data as any).ac_plan) {\n"
-        "          _acRef.current = (data as any).ac_plan;\n"
-        "          _setShowAc(true);\n"
-        "          return;\n"
-        "        }\n"
-    )
-    content = content.replace("onSessionUpdate: (data) => {", "onSessionUpdate: (data) => {\n" + h)
-
-# ONLY match the unique two-line pattern: "  return {\n    messages: chat.messages,"
-UNIQUE_MARKER = "  return {\n    messages: chat.messages,"
-if UNIQUE_MARKER in content and "_acCancel" not in content:
-    insert = (
-        "  const _acCancel = useCallback(() => { _setShowAc(false); }, []);\n"
-        "  useEffect(() => {\n"
-        "    if (!_showAc) return;\n"
-        "    const plan = _acRef.current;\n"
-        "    const timer = setTimeout(() => {\n"
-        "      const s = chatActionsRef.current.setMessages;\n"
-        "      const m = chatActionsRef.current.messages;\n"
-        "      if (s && plan.length > 0) {\n"
-        "        const t = plan.map((i: { content: string }) => '- ' + i.content).join('\\\\n');\n"
-        "        const nu = { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: '[TIEP TUC] Task chua hoan thanh:\\\\n' + t }], content: '' };\n"
-        "        s([...m, nu]);\n"
-        "      }\n"
-        "      _setShowAc(false);\n"
-        "    }, 10000);\n"
-        "    return () => clearTimeout(timer);\n"
-        "  }, [_showAc]);\n\n"
-    )
-    content = content.replace(UNIQUE_MARKER, insert + UNIQUE_MARKER)
-    
-    # Add to return
-    content = content.replace(
-        "refreshMessages,\n  };",
-        "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-    )
-
-with open(HOOK, 'w') as f:
-    f.write(content)
-print("OK: useAgentChat.ts")
-
-# --- ChatInput.tsx ---
-with open(INPUT) as f:
-    content = f.read()
-
-# Add Button (check exact substring, not "IconButton")
-if "  Button,\n" not in content and "  Button\n" not in content:
-    content = content.replace(
-        "  Tooltip,",
-        "  Tooltip,\n  Button,"
-    )
-
-if "_showAc" not in content:
-    content = content.replace(
-        "placeholder?: string;",
-        "placeholder?: string;\n  _showAc?: boolean;\n  _acCancel?: () => void;"
-    )
-    content = content.replace(
-        "placeholder = 'Ask anything...' }: ChatInputProps) {",
-        "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-    )
-    btn = (
-        "        {_showAc && _acCancel && (\n"
-        "          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>\n"
-        "            <Button variant=\"outlined\" size=\"small\" onClick={_acCancel}\n"
-        "              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>\n"
-        "              TAM_DUNG_TU_DONG_TIEP_TUC (10s)\n"
-        "            </Button>\n"
-        "          </Box>\n"
-        "        )}\n"
-    )
-    content = content.replace("<JobsUpgradeDialog", btn + "        <JobsUpgradeDialog")
-
-with open(INPUT, 'w') as f:
-    f.write(content)
-print("OK: ChatInput.tsx")
-
-# --- SessionChat.tsx ---
-if os.path.exists(SESS):
-    with open(SESS) as f:
-        c = f.read()
-    if "_showAc" not in c:
-        c = c.replace(
-            "<ChatInput ",
-            "<ChatInput _showAc={_showAc} _acCancel={_acCancel} "
-        )
-        with open(SESS, 'w') as f:
-            f.write(c)
-    print("OK: SessionChat.tsx")
-
-# --- agent_loop.py ---
-if os.path.exists(AGENT):
-    with open(AGENT) as f:
-        c = f.read()
-    
-    if "_unfinished_plan" not in c:
-        fn = (
-            "\n\ndef _unfinished_plan(s):\n"
-            "    p = getattr(s, 'current_plan', None) or []\n"
-            "    return [it for it in p if it.get('status') in ('pending', 'in_progress')]\n\n"
-        )
-        c = c.replace("class Handlers:", fn + "class Handlers:")
-    
-    if "ac_plan" not in c:
-        check = (
-            "\n            if not llm_result.tool_calls_acc and llm_result.content:\n"
-            "                unfinished = _unfinished_plan(session)\n"
-            "                if unfinished:\n"
-            "                    await session.send_event(Event(event_type='session_update', data={\n"
-            "                        'ac_plan': unfinished,\n"
-            "                    }))\n"
-        )
-        c = c.replace("  # -- End of turn --", check + "  # -- End of turn --")
-    
-    with open(AGENT, 'w') as f:
-        f.write(c)
-    print("OK: agent_loop.py")
-else:
-    print("SKIP: agent_loop.py")
-
-print("DONE: V17")

patch_auto_continue_v2.py

@@ -1,307 +0,0 @@
-"""V2: Fix all TypeScript errors for auto-continue feature.
-
-Errors fixed:
-1. 'startAutoContinue' used before declaration → use refs
-2. 'showAutoContinue'/'taskIncompleteInfo' never read → they're in return
-3. 'incompletePlan' implicit any → add type
-4. EventType missing 'task_incomplete' → add to events.ts
-5. DatasetUploadResponse not found → fix import path
-6. onTaskIncomplete not on SideChannelCallbacks → fix in SSE transport
-"""
-
-import os
-import re
-
-# =====================================================================
-# PATCH 1: events.ts - Add 'task_incomplete' to EventType
-# =====================================================================
-EVENTS_FILE = "/source/frontend/src/types/events.ts"
-
-def patch_events():
-    if not os.path.exists(EVENTS_FILE):
-        print(f"SKIP: {EVENTS_FILE} not found")
-        return
-    with open(EVENTS_FILE, "r") as f:
-        content = f.read()
-    if "'task_incomplete'" not in content:
-        content = content.replace(
-            "  | 'plan_update';",
-            "  | 'plan_update'\n  | 'task_incomplete';"
-        )
-        with open(EVENTS_FILE, "w") as f:
-            f.write(content)
-        print("OK: Added 'task_incomplete' to EventType")
-    else:
-        print("OK: EventType already has 'task_incomplete'")
-
-# =====================================================================
-# PATCH 2: useAgentChat.ts - Fix hoisting + type issues
-# =====================================================================
-USE_AGENT_CHAT = "/source/frontend/src/hooks/useAgentChat.ts"
-
-def patch_use_agent_chat():
-    if not os.path.exists(USE_AGENT_CHAT):
-        print(f"SKIP: {USE_AGENT_CHAT} not found")
-        return
-    
-    with open(USE_AGENT_CHAT, "r") as f:
-        content = f.read()
-    
-    # 1. Add useState to imports
-    if "useState" not in content:
-        content = content.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # 2. Add state + refs after callbacksRef
-    state_code = '''
-  // Auto-continue state for free models when task incomplete
-  const autoContinueTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [showAutoContinue, setShowAutoContinue] = useState(false);
-  const [taskIncompleteInfo, setTaskIncompleteInfo] = useState<{
-    incompletePlan: Array<{ id: string; content: string; status: string }>;
-  } | null>(null);
-  const startAutoContinueRef = useRef<() => void>(() => {});
-  const cancelAutoContinueRef = useRef<() => void>(() => {});
-'''
-    if "autoContinueTimerRef" not in content:
-        content = content.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state_code
-        )
-    
-    # 3. Add onTaskIncomplete to SideChannelCallbacks interface
-    if "onTaskIncomplete:" not in content and "onInterrupted:" in content:
-        content = content.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # 4. Replace onTaskIncomplete handler to use refs
-    old_handler = "onTaskIncomplete: (incompletePlan) => {"
-    new_handler = "onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => {"
-    if old_handler in content:
-        content = content.replace(old_handler, new_handler)
-    
-    # Fix the timer callback to use ref instead of direct call
-    old_timer = "autoContinueTimerRef.current = setTimeout(() => {\n          startAutoContinue();\n        }, 10000);"
-    new_timer = "autoContinueTimerRef.current = setTimeout(() => {\n          startAutoContinueRef.current();\n        }, 10000);"
-    if old_timer in content:
-        content = content.replace(old_timer, new_timer)
-    
-    # 5. Add auto-continue functions BEFORE return (but using refs pattern)
-    # Remove old startAutoContinue/cancelAutoContinue if they exist
-    old_funcs_start = "const startAutoContinue = useCallback"
-    if old_funcs_start in content:
-        # Find and remove the old function blocks
-        start_idx = content.find("const startAutoContinue = useCallback")
-        cancel_idx = content.find("const cancelAutoContinue = useCallback")
-        cleanup_idx = content.find("// Cleanup timer on unmount")
-        
-        # Remove from startAutoContinue to end of cleanup
-        if start_idx > 0 and cleanup_idx > start_idx:
-            # Find the end of cleanup effect
-            end_cleanup = content.find("\n", cleanup_idx)
-            # Find the closing of the useEffect
-            close_idx = content.find("}, []);", end_cleanup)
-            if close_idx > 0:
-                close_idx += len("}, []);")
-                content = content[:start_idx] + content[close_idx:]
-    
-    # 5b. Add new functions using ref pattern, before return
-    new_funcs = '''
-  // -- Auto-continue for free models when task incomplete -----------------
-  const startAutoContinue = useCallback(() => {
-    setShowAutoContinue(false);
-    setTaskIncompleteInfo(null);
-    if (autoContinueTimerRef.current) {
-      clearTimeout(autoContinueTimerRef.current);
-      autoContinueTimerRef.current = null;
-    }
-    const incompleteItems = taskIncompleteInfo?.incompletePlan || [];
-    const continuationText = incompleteItems.length > 0
-      ? `Tiếp tục từ các task chưa hoàn thành:\\n${incompleteItems.map(i => `- ${i.content}`).join('\\n')}`
-      : 'Tiếp tục nhiệm vụ.';
-    chat.sendMessage({
-      text: `[TỰ ĐỘNG TIẾP TỤC] ${continuationText}`,
-      metadata: { createdAt: new Date().toISOString() },
-    });
-  }, [taskIncompleteInfo, chat]);
-
-  const cancelAutoContinue = useCallback(() => {
-    setShowAutoContinue(false);
-    setTaskIncompleteInfo(null);
-    if (autoContinueTimerRef.current) {
-      clearTimeout(autoContinueTimerRef.current);
-      autoContinueTimerRef.current = null;
-    }
-  }, []);
-
-  // Keep refs in sync
-  startAutoContinueRef.current = startAutoContinue;
-  cancelAutoContinueRef.current = cancelAutoContinue;
-
-  // Cleanup timer on unmount
-  useEffect(() => {
-    return () => {
-      if (autoContinueTimerRef.current) {
-        clearTimeout(autoContinueTimerRef.current);
-      }
-    };
-  }, []);
-'''
-    
-    if "startAutoContinueRef.current" not in content:
-        content = content.replace(
-            '\n  return {\n    messages: chat.messages,',
-            new_funcs + '\n  return {\n    messages: chat.messages,'
-        )
-    
-    # 6. Update return to include new values
-    if "showAutoContinue," not in content:
-        content = content.replace(
-            "refreshMessages,\n  };",
-            "refreshMessages,\n    showAutoContinue,\n    taskIncompleteInfo,\n    startAutoContinue,\n    cancelAutoContinue,\n  };"
-        )
-    
-    with open(USE_AGENT_CHAT, "w") as f:
-        f.write(content)
-    print(f"OK: Patched {USE_AGENT_CHAT}")
-
-# =====================================================================
-# PATCH 3: ChatInput.tsx - Fix DatasetUploadResponse import
-# =====================================================================
-CHAT_INPUT = "/source/frontend/src/components/Chat/ChatInput.tsx"
-
-def patch_chat_input():
-    if not os.path.exists(CHAT_INPUT):
-        print(f"SKIP: {CHAT_INPUT} not found")
-        return
-    
-    with open(CHAT_INPUT, "r") as f:
-        content = f.read()
-    
-    # Fix DatasetUploadResponse import - try correct path
-    if "DatasetUploadResponse" in content:
-        # Check if it's imported from agent.ts
-        wrong_import = "import type { DatasetUploadResponse } from '@/types/agent';"
-        if wrong_import in content:
-            # Try to find the correct import - it's probably in the same file or from backend
-            # Replace with inline type or remove
-            content = content.replace(wrong_import, "")
-            # Add inline type
-            content = content.replace(
-                "import { apiFetch } from '@/utils/api';",
-                "import { apiFetch } from '@/utils/api';\n\ntype DatasetUploadResponse = { url: string; repo_id: string; filename: string; size: number; };"
-            )
-            print("OK: Fixed DatasetUploadResponse import")
-    
-    # Add Button to MUI imports
-    if "Button" not in content:
-        content = content.replace(
-            "import { Box, IconButton, Stack, Tooltip } from '@mui/material';",
-            "import { Box, IconButton, Stack, Tooltip, Button } from '@mui/material';"
-        )
-    
-    # Check if interface already has our props (from previous patch)
-    if "showAutoContinue" not in content:
-        # Find interface and replace with complete version
-        interface_match = re.search(r'interface ChatInputProps\s*\{[^}]*\}', content, re.DOTALL)
-        if interface_match:
-            props_code = '''
-interface ChatInputProps {
-  sessionId: string;
-  initialModelPath: string | null | undefined;
-  onSend: (text: string) => Promise<void>;
-  onStop: () => void;
-  onDatasetUploaded: () => Promise<boolean>;
-  isProcessing: boolean;
-  disabled: boolean;
-  placeholder?: string;
-  showAutoContinue?: boolean;
-  taskIncompleteInfo?: { incompletePlan: Array<{ id: string; content: string; status: string }> } | null;
-  startAutoContinue?: () => void;
-  cancelAutoContinue?: () => void;
-}
-'''
-            content = content.replace(interface_match.group(0), props_code)
-            print("OK: Updated ChatInputProps interface")
-    
-    # Add auto-continue buttons
-    buttons_code = '''
-      {/* Auto-continue controls for free models */}
-      {showAutoContinue && taskIncompleteInfo && (
-        <Stack direction="row" spacing={1} sx={{ mb: 1, px: 1 }}>
-          <Button
-            variant="contained"
-            color="primary"
-            size="small"
-            onClick={startAutoContinue}
-            sx={{ textTransform: 'none', fontSize: '0.75rem' }}
-          >
-            Tự động tiếp tục (10s)
-          </Button>
-          <Button
-            variant="outlined"
-            color="secondary"
-            size="small"
-            onClick={cancelAutoContinue}
-            sx={{ textTransform: 'none', fontSize: '0.75rem' }}
-          >
-            Tạm dừng
-          </Button>
-        </Stack>
-      )}
-'''
-    
-    if "Tự động tiếp tục" not in content:
-        content = content.replace(
-            "<Box sx={{ flex: 1 ",
-            buttons_code + "        <Box sx={{ flex: 1 "
-        )
-        print("OK: Added auto-continue buttons")
-    
-    with open(CHAT_INPUT, "w") as f:
-        f.write(content)
-    print(f"OK: Patched {CHAT_INPUT}")
-
-# =====================================================================
-# PATCH 4: sse-chat-transport.ts - Fix onTaskIncomplete reference
-# =====================================================================
-SSE_TRANSPORT = "/source/frontend/src/lib/sse-chat-transport.ts"
-
-def patch_sse_transport():
-    if not os.path.exists(SSE_TRANSPORT):
-        print(f"SKIP: {SSE_TRANSPORT} not found")
-        return
-    
-    with open(SSE_TRANSPORT, "r") as f:
-        content = f.read()
-    
-    # Add onTaskIncomplete to SideChannelCallbacks interface
-    if "onTaskIncomplete:" not in content and "onInterrupted:" in content:
-        content = content.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # Use @ts-ignore for the case since EventType union doesn't include 'task_incomplete'
-    # Or better: add the case with a type assertion
-    if "case 'task_incomplete'" in content:
-        # Already added, make sure it compiles
-        old_case = "case 'task_incomplete':\n          sideChannel.onTaskIncomplete("
-        new_case = "case 'task_incomplete' as const:\n          sideChannel.onTaskIncomplete("
-        content = content.replace(old_case, new_case)
-    
-    with open(SSE_TRANSPORT, "w") as f:
-        f.write(content)
-    print(f"OK: Patched {SSE_TRANSPORT}")
-
-
-if __name__ == "__main__":
-    patch_events()
-    patch_use_agent_chat()
-    patch_chat_input()
-    patch_sse_transport()
-    print("\nDONE: All V2 patches applied")

patch_auto_continue_v3.py

@@ -1,229 +0,0 @@
-"""V3: FINAL - Fix remaining TS errors for auto-continue feature.
-
-Errors fixed:
-1. TS6133: 'showAutoContinue'/'taskIncompleteInfo' never read → prefix with _
-2. TS2741: Property 'onTaskIncomplete' missing in sideChannel object → add implementation
-"""
-
-import os
-import re
-
-USE_AGENT_CHAT = "/source/frontend/src/hooks/useAgentChat.ts"
-EVENTS_FILE = "/source/frontend/src/types/events.ts"
-CHAT_INPUT = "/source/frontend/src/components/Chat/ChatInput.tsx"
-SSE_TRANSPORT = "/source/frontend/src/lib/sse-chat-transport.ts"
-
-def patch_events():
-    if not os.path.exists(EVENTS_FILE):
-        print(f"SKIP: {EVENTS_FILE} not found")
-        return
-    with open(EVENTS_FILE, "r") as f:
-        content = f.read()
-    if "'task_incomplete'" not in content:
-        content = content.replace(
-            "  | 'plan_update';",
-            "  | 'plan_update'\n  | 'task_incomplete';"
-        )
-        with open(EVENTS_FILE, "w") as f:
-            f.write(content)
-        print("OK: Added 'task_incomplete' to EventType")
-
-def patch_use_agent_chat():
-    if not os.path.exists(USE_AGENT_CHAT):
-        print(f"SKIP: {USE_AGENT_CHAT} not found")
-        return
-    
-    with open(USE_AGENT_CHAT, "r") as f:
-        content = f.read()
-    
-    # 1. Add useState import
-    if "useState" not in content:
-        content = content.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # 2. Add state after callbacksRef
-    state_block = '''
-  // Auto-continue state for free models when task incomplete
-  const autoContinueTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [_showAutoContinue, _setShowAutoContinue] = useState(false);
-  const [_taskIncompleteInfo, _setTaskIncompleteInfo] = useState<{
-    incompletePlan: Array<{ id: string; content: string; status: string }>;
-  } | null>(null);
-'''
-    if "autoContinueTimerRef" not in content:
-        content = content.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state_block
-        )
-    
-    # 3. Add onTaskIncomplete to interface
-    if "onTaskIncomplete:" not in content and "onInterrupted: () => void;" in content:
-        content = content.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # 4. Add onTaskIncomplete handler in sideChannel (BEFORE onInterrupted)
-    handler_block = '''      onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => {
-        _setTaskIncompleteInfo({ incompletePlan });
-        _setShowAutoContinue(true);
-        if (autoContinueTimerRef.current) {
-          clearTimeout(autoContinueTimerRef.current);
-        }
-        autoContinueTimerRef.current = setTimeout(() => {
-          _setShowAutoContinue(false);
-          _setTaskIncompleteInfo(null);
-          const plan = incompletePlan.map(i => `- ${i.content}`).join('\\n');
-          chat.sendMessage({
-            text: `[TỰ ĐỘNG TIẾP TỤC] Tiếp tục từ các task chưa hoàn thành:\\n${plan}`,
-            metadata: { createdAt: new Date().toISOString() },
-          });
-        }, 10000);
-      },
-      onInterrupted: () => { /* no-op */ },'''
-    
-    if "onTaskIncomplete: (incompletePlan" not in content:
-        old_interrupted = '      onInterrupted: () => { /* no-op — handled by stop() caller */ },'
-        if old_interrupted in content:
-            content = content.replace(old_interrupted, handler_block)
-        else:
-            # Try the simpler version
-            simple_interrupted = '      onInterrupted: () => { /* no-op */ },'
-            if simple_interrupted in content:
-                content = content.replace(simple_interrupted, handler_block)
-    
-    # 5. Add cleanup timer before return
-    cleanup = '''
-  // Cleanup auto-continue timer
-  useEffect(() => {
-    return () => {
-      if (autoContinueTimerRef.current) {
-        clearTimeout(autoContinueTimerRef.current);
-      }
-    };
-  }, []);
-'''
-    if "autoContinueTimerRef.current" in content and "Cleanup timer" not in content:
-        content = content.replace(
-            '\n  return {\n    messages: chat.messages,',
-            cleanup + '\n  return {\n    messages: chat.messages,'
-        )
-    
-    with open(USE_AGENT_CHAT, "w") as f:
-        f.write(content)
-    print(f"OK: Patched {USE_AGENT_CHAT}")
-
-def patch_chat_input():
-    if not os.path.exists(CHAT_INPUT):
-        print(f"SKIP: {CHAT_INPUT} not found")
-        return
-    
-    with open(CHAT_INPUT, "r") as f:
-        content = f.read()
-    
-    # Fix DatasetUploadResponse - define inline type
-    if "DatasetUploadResponse" in content and "type DatasetUploadResponse" not in content:
-        wrong = "import type { DatasetUploadResponse } from '@/types/agent';"
-        if wrong in content:
-            content = content.replace(wrong, "")
-            # Add inline type after apiFetch import
-            content = content.replace(
-                "import { apiFetch } from '@/utils/api';",
-                "import { apiFetch } from '@/utils/api';\ntype DatasetUploadResponse = { url: string; repo_id: string; filename: string; size: number; };"
-            )
-    
-    # Add Button import
-    if "Button" not in content:
-        content = content.replace(
-            "import { Box, IconButton, Stack, Tooltip } from '@mui/material';",
-            "import { Box, IconButton, Stack, Tooltip, Button } from '@mui/material';"
-        )
-    
-    # Fix interface - replace with complete version
-    if "_showAutoContinue" not in content:
-        interface_match = re.search(r'interface ChatInputProps\s*\{[^}]*\}', content, re.DOTALL)
-        if interface_match:
-            props_code = '''
-interface ChatInputProps {
-  sessionId: string;
-  initialModelPath: string | null | undefined;
-  onSend: (text: string) => Promise<void>;
-  onStop: () => void;
-  onDatasetUploaded: () => Promise<boolean>;
-  isProcessing: boolean;
-  disabled: boolean;
-  placeholder?: string;
-  _showAutoContinue?: boolean;
-  _taskIncompleteInfo?: { incompletePlan: Array<{ id: string; content: string; status: string }> } | null;
-  _onCancelAutoContinue?: () => void;
-}
-'''
-            content = content.replace(interface_match.group(0), props_code)
-    
-    # Add cancel button
-    buttons = '''
-      {/* Auto-continue cancel button for free models */}
-      {_showAutoContinue && _taskIncompleteInfo && _onCancelAutoContinue && (
-        <Stack direction="row" spacing={1} sx={{ mb: 1, px: 1 }}>
-          <Button
-            variant="outlined"
-            color="secondary"
-            size="small"
-            onClick={_onCancelAutoContinue}
-            sx={{ textTransform: 'none', fontSize: '0.75rem' }}
-          >
-            Tạm dừng (để nhập nội dung khác)
-          </Button>
-        </Stack>
-      )}
-'''
-    if "Tạm dừng" not in content:
-        content = content.replace(
-            "<Box sx={{ flex: 1 ",
-            buttons + "\n        <Box sx={{ flex: 1 "
-        )
-    
-    with open(CHAT_INPUT, "w") as f:
-        f.write(content)
-    print(f"OK: Patched {CHAT_INPUT}")
-
-def patch_sse_transport():
-    if not os.path.exists(SSE_TRANSPORT):
-        print(f"SKIP: {SSE_TRANSPORT} not found")
-        return
-    
-    with open(SSE_TRANSPORT, "r") as f:
-        content = f.read()
-    
-    # Add onTaskIncomplete to SideChannelCallbacks interface
-    if "onTaskIncomplete:" not in content and "onInterrupted: () => void;" in content:
-        content = content.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # Add case 'task_incomplete'
-    if "case 'task_incomplete'" not in content:
-        task_case = '''      case 'task_incomplete' as const:
-          sideChannel.onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-'''
-        content = content.replace(
-            "case 'turn_complete':",
-            task_case + "\n        case 'turn_complete':"
-        )
-    
-    with open(SSE_TRANSPORT, "w") as f:
-        f.write(content)
-    print(f"OK: Patched {SSE_TRANSPORT}")
-
-if __name__ == "__main__":
-    patch_events()
-    patch_use_agent_chat()
-    patch_chat_input()
-    patch_sse_transport()
-    print("\nDONE: V3 patches applied")

patch_auto_continue_v4.py

@@ -1,264 +0,0 @@
-"""V4: FINAL WORKING - Fix all TS errors for auto-continue feature.
-
-Strategy:
-- useAgentChat: return _showAutoContinue + _cancelAutoContinue (TS _ prefix suppresses "unused")
-- ChatInput.tsx: receive props and render "Tạm dừng" button  
-- SessionChat.tsx: pass props from hook to ChatInput
-- events.ts: add 'task_incomplete' to EventType union
-- sse-chat-transport.ts: add onTaskIncomplete + case handler
-- agent_loop.py: send task_incomplete event
-"""
-
-import os
-import re
-
-EVENTS = "/source/frontend/src/types/events.ts"
-USE_AGENT_CHAT = "/source/frontend/src/hooks/useAgentChat.ts"
-SSE = "/source/frontend/src/lib/sse-chat-transport.ts"
-CHAT_INPUT = "/source/frontend/src/components/Chat/ChatInput.tsx"
-SESSION_CHAT = "/source/frontend/src/components/SessionChat.tsx"
-
-
-def patch_events():
-    with open(EVENTS, "r") as f:
-        c = f.read()
-    if "'task_incomplete'" not in c:
-        c = c.replace("  | 'plan_update';", "  | 'plan_update'\n  | 'task_incomplete';")
-        with open(EVENTS, "w") as f: f.write(c)
-    print("OK: events.ts")
-
-
-def patch_sse():
-    with open(SSE, "r") as f:
-        c = f.read()
-    
-    # Add onTaskIncomplete to interface
-    if "onTaskIncomplete:" not in c:
-        c = c.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # Add case handler
-    if "case 'task_incomplete'" not in c:
-        case = """      case 'task_incomplete' as const:
-          sideChannel.onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-"""
-        c = c.replace("case 'turn_complete':", case + "\n        case 'turn_complete':")
-    
-    with open(SSE, "w") as f: f.write(c)
-    print("OK: sse-chat-transport.ts")
-
-
-def patch_use_agent_chat():
-    with open(USE_AGENT_CHAT, "r") as f:
-        c = f.read()
-    
-    # 1. Import useState
-    if "useState" not in c:
-        c = c.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # 2. State (TS _ prefix = unused ok)
-    state_block = '''
-  // Auto-continue for free models
-  const _autoContinueTimer = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [_showAutoContinue, _setShowAutoContinue] = useState(false);
-'''
-    if "_autoContinueTimer" not in c:
-        c = c.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state_block
-        )
-    
-    # 3. onTaskIncomplete in interface
-    if "onTaskIncomplete:" not in c:
-        c = c.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # 4. Cancel ref
-    cancel_ref = '  const _cancelAutoContinue = useRef(() => {});\n'
-    if "_cancelAutoContinue" not in c:
-        # Insert after callbacksRef.current = { ... } area
-        c = c.replace(
-            "  isActiveRef.current = isActive;",
-            "  isActiveRef.current = isActive;\n" + cancel_ref
-        )
-    
-    # 5. Handler in sideChannel - inline all logic
-    handler = """      onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => {
-        _setShowAutoContinue(true);
-        if (_autoContinueTimer.current) clearTimeout(_autoContinueTimer.current);
-        _autoContinueTimer.current = setTimeout(() => {
-          _setShowAutoContinue(false);
-          const plan = incompletePlan.map(i => `- ${i.content}`).join('\\\\n');
-          chat.sendMessage({
-            text: `[TỰ ĐỘNG TIẾP TỤC] Tiếp tục từ các task chưa hoàn thành:\\\\n${plan}`,
-            metadata: { createdAt: new Date().toISOString() },
-          });
-        }, 10000);
-      },
-      onInterrupted: () => { /* no-op */ },"""
-    
-    if "onTaskIncomplete: (incompletePlan" not in c:
-        old = '      onInterrupted: () => { /* no-op — handled by stop() caller */ },'
-        if old in c:
-            c = c.replace(old, handler)
-    
-    # 6. Set cancel ref function + cleanup  
-    cancel_func = """
-  _cancelAutoContinue.current = () => {
-    _setShowAutoContinue(false);
-    if (_autoContinueTimer.current) {
-      clearTimeout(_autoContinueTimer.current);
-      _autoContinueTimer.current = null;
-    }
-  };
-"""
-    if "_cancelAutoContinue.current = ()" not in c:
-        # Insert before return
-        c = c.replace(
-            "\n  return {\n    messages: chat.messages,",
-            cancel_func + "\n  return {\n    messages: chat.messages,"
-        )
-    
-    # 7. Return values
-    if "_showAutoContinue," not in c:
-        c = c.replace(
-            "refreshMessages,\n  };",
-            "refreshMessages,\n    _showAutoContinue,\n    _cancelAutoContinue,\n  };"
-        )
-    
-    with open(USE_AGENT_CHAT, "w") as f: f.write(c)
-    print("OK: useAgentChat.ts")
-
-
-def patch_chat_input():
-    with open(CHAT_INPUT, "r") as f:
-        c = f.read()
-    
-    # Fix DatasetUploadResponse
-    if "DatasetUploadResponse" in c and "inline" not in c:
-        wrong = "import type { DatasetUploadResponse } from '@/types/agent';"
-        if wrong in c:
-            c = c.replace(wrong, "")
-            c = c.replace(
-                "import { apiFetch } from '@/utils/api';",
-                "import { apiFetch } from '@/utils/api';\ntype DatasetUploadResponse = { url: string; repo_id: string; filename: string; size: number; };"
-            )
-    
-    # Add Button import
-    if "Button" not in c:
-        c = c.replace(
-            "import { Box, IconButton, Stack, Tooltip } from '@mui/material';",
-            "import { Box, IconButton, Stack, Tooltip, Button } from '@mui/material';"
-        )
-    
-    # Add props to interface
-    if "_showAutoContinue" not in c:
-        match = re.search(r'interface ChatInputProps\s*\{[^}]*\}', c, re.DOTALL)
-        if match:
-            new_iface = """interface ChatInputProps {
-  sessionId: string;
-  initialModelPath: string | null | undefined;
-  onSend: (text: string) => Promise<void>;
-  onStop: () => void;
-  onDatasetUploaded: () => Promise<boolean>;
-  isProcessing: boolean;
-  disabled: boolean;
-  placeholder?: string;
-  _showAutoContinue?: boolean;
-  _cancelAutoContinue?: React.RefObject<() => void>;
-}"""
-            c = c.replace(match.group(0), new_iface)
-    
-    # Add pause button  
-    btn = """
-      {/* Pause auto-continue for free models */}
-      {_showAutoContinue && _cancelAutoContinue?.current && (
-        <Stack direction="row" spacing={1} sx={{ mb: 1, px: 1 }}>
-          <Button
-            variant="outlined"
-            color="secondary"
-            size="small"
-            onClick={_cancelAutoContinue.current}
-            sx={{ textTransform: 'none', fontSize: '0.75rem' }}
-          >
-            Tạm dừng (để nhập nội dung khác)
-          </Button>
-        </Stack>
-      )}
-"""
-    if "Tạm dừng" not in c:
-        c = c.replace("<Box sx={{ flex: 1 ", btn + "\n        <Box sx={{ flex: 1 ")
-    
-    with open(CHAT_INPUT, "w") as f: f.write(c)
-    print("OK: ChatInput.tsx")
-
-
-def patch_session_chat():
-    with open(SESSION_CHAT, "r") as f:
-        c = f.read()
-    
-    # Find the ChatInput usage and add new props
-    if "_showAutoContinue" not in c:
-        chat_input_pattern = r'(<ChatInput[^>]*sessionId={sessionId}[^>]*initialModelPath={initialModelPath}[^>]*)(\s*/>)'
-        new_props = r'\1 _showAutoContinue={_showAutoContinue} _cancelAutoContinue={_cancelAutoContinue}\2'
-        c = re.sub(chat_input_pattern, new_props, c)
-    
-    with open(SESSION_CHAT, "w") as f: f.write(c)
-    print("OK: SessionChat.tsx")
-
-
-def patch_agent_loop():
-    agent_loop = "/app/agent/core/agent_loop.py"
-    if not os.path.exists(agent_loop):
-        print(f"SKIP: {agent_loop} not found (backend)")
-        return
-    
-    with open(agent_loop, "r") as f:
-        c = f.read()
-    
-    if "_check_task_incomplete" not in c:
-        func = '''
-
-def _unfinished_plan_items(session: Session) -> list[dict[str, str]]:
-    plan = getattr(session, "current_plan", None) or []
-    return [item for item in plan if item.get("status") in ("pending", "in_progress")]
-
-'''
-        c = c.replace("class Handlers:", func + "\n\nclass Handlers:")
-    
-    if "task_incomplete" not in c:
-        check = '''
-            # === Auto-continue: if model stopped but plan incomplete ===
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan_items(session)
-                if unfinished:
-                    await session.send_event(
-                        Event(event_type="task_incomplete", data={"incomplete_plan": unfinished})
-                    )
-'''
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + "\n" + marker)
-    
-    with open(agent_loop, "w") as f: f.write(c)
-    print("OK: agent_loop.py")
-
-
-if __name__ == "__main__":
-    patch_events()
-    patch_sse()
-    patch_use_agent_chat()
-    patch_chat_input()
-    patch_session_chat()
-    patch_agent_loop()
-    print("\nDONE: V4 - everything applied")

patch_auto_continue_v5.py

@@ -1,252 +0,0 @@
-"""V5: SIMPLEST approach - just show pause button with 10s auto-continue.
-
-Architecture:
-1. Agent loop detects model stopped mid-task → sends 'task_incomplete' event
-2. SSE transport receives it → calls sideChannel.onTaskIncomplete()
-3. useAgentChat: onTaskIncomplete sets _showAutoContinue=true, sends continue msg
-4. ChatInput shows "Tạm dừng" button if _showAutoContinue
-"""
-
-import os, re
-
-EVENTS = "/source/frontend/src/types/events.ts"
-SSE = "/source/frontend/src/lib/sse-chat-transport.ts"
-USE_AGENT_CHAT = "/source/frontend/src/hooks/useAgentChat.ts"
-CHAT_INPUT = "/source/frontend/src/components/Chat/ChatInput.tsx"
-AGENT_LOOP = "/app/agent/core/agent_loop.py"
-
-
-def patch_events():
-    with open(EVENTS, "r") as f:
-        c = f.read()
-    if "'task_incomplete'" not in c:
-        c = c.replace("  | 'plan_update';", "  | 'plan_update'\n  | 'task_incomplete';")
-        with open(EVENTS, "w") as f:
-            f.write(c)
-    print("OK: events.ts")
-
-
-def patch_sse():
-    with open(SSE, "r") as f:
-        c = f.read()
-    
-    if "onTaskIncomplete:" not in c:
-        c = c.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    if "case 'task_incomplete'" not in c:
-        case_block = """      case 'task_incomplete' as const:
-          sideChannel.onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-"""
-        c = c.replace("case 'turn_complete':", case_block + "\n        case 'turn_complete':")
-    
-    with open(SSE, "w") as f:
-        f.write(c)
-    print("OK: sse.ts")
-
-
-def patch_use_agent():
-    with open(USE_AGENT_CHAT, "r") as f:
-        c = f.read()
-    
-    # 1. Import useState
-    if "useState" not in c:
-        c = c.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # 2. State (prefixed with _ = TS allows unused)
-    state = '''
-  // Auto-continue state for free models
-  const _acTimer = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [_showAc, _setShowAc] = useState(false);'''
-    if "_acTimer" not in c:
-        c = c.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state
-        )
-    
-    # 3. Add onTaskIncomplete to interface
-    if "onTaskIncomplete:" not in c:
-        c = c.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # 4. Add onTaskIncomplete handler - uses chatActionsRef ref instead of chat directly
-    handler = '''      onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => {
-        _setShowAc(true);
-        if (_acTimer.current) clearTimeout(_acTimer.current);
-        _acTimer.current = setTimeout(() => {
-          _setShowAc(false);
-          // Auto-continue after 10s via chatActionsRef
-          const chatRef = chatActionsRef.current;
-          const sendMsg = (chatRef as any)?.sendMessage;
-          if (sendMsg) {
-            const planStr = incompletePlan.map(i => `- ${i.content}`).join('\\\\n');
-            sendMsg({ text: `[TIẾP TỤC] Tiếp tục task chưa hoàn thành:\\\\n${planStr}`, metadata: { createdAt: new Date().toISOString() } });
-          }
-        }, 10000);
-      },
-      onInterrupted: () => { /* no-op */ },'''
-    
-    if "onTaskIncomplete: (incompletePlan" not in c:
-        old = '      onInterrupted: () => { /* no-op — handled by stop() caller */ },'
-        if old in c:
-            c = c.replace(old, handler)
-        else:
-            old2 = '      onInterrupted: () => { /* no-op */ },'
-            c = c.replace(old2, handler)
-    
-    # 5. Cancel ref + return values
-    if "_showAc" not in content:
-        # Insert cancel before return
-        cancel = '''
-  // Expose auto-continue state
-  const _acCancel = useCallback(() => {
-    _setShowAc(false);
-    if (_acTimer.current) { clearTimeout(_acTimer.current); _acTimer.current = null; }
-  }, []);
-'''
-        if "_acCancel" not in c:
-            c = c.replace('\n  return {\n    messages: chat.messages,', cancel + '\n  return {\n    messages: chat.messages,')
-        
-        if "_showAc," not in c:
-            c = c.replace(
-                "refreshMessages,\n  };",
-                "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-            )
-    
-    with open(USE_AGENT_CHAT, "w") as f:
-        f.write(c)
-    print("OK: useAgentChat.ts")
-
-
-def patch_chat_input():
-    with open(CHAT_INPUT, "r") as f:
-        c = f.read()
-    
-    # DatasetUploadResponse fix
-    if "DatasetUploadResponse" in c and "type DatasetUploadResponse" not in c:
-        wrong = "import type { DatasetUploadResponse } from '@/types/agent';"
-        if wrong in c:
-            c = c.replace(wrong, "")
-            c = c.replace(
-                "import { apiFetch } from '@/utils/api';",
-                "import { apiFetch } from '@/utils/api';\ntype DatasetUploadResponse = { url: string; repo_id: string; filename: string; size: number; };"
-            )
-    
-    # Add Button
-    if "Button" not in c:
-        c = c.replace(
-            "import { Box, IconButton, Stack, Tooltip } from '@mui/material';",
-            "import { Box, IconButton, Stack, Tooltip, Button } from '@mui/material';"
-        )
-    
-    # Update interface
-    if "_showAc" not in c:
-        m = re.search(r'interface ChatInputProps\s*\{[^}]*\}', c, re.DOTALL)
-        if m:
-            iface = """interface ChatInputProps {
-  sessionId: string;
-  initialModelPath: string | null | undefined;
-  onSend: (text: string) => Promise<void>;
-  onStop: () => void;
-  onDatasetUploaded: () => Promise<boolean>;
-  isProcessing: boolean;
-  disabled: boolean;
-  placeholder?: string;
-  _showAc?: boolean;
-  _acCancel?: () => void;
-}"""
-            c = c.replace(m.group(0), iface)
-    
-    # Add button
-    btn = """
-      {/* Auto-continue pause button for free models */}
-      {_showAc && _acCancel && (
-        <Stack direction="row" spacing={1} sx={{ mb: 1, px: 1 }}>
-          <Button
-            variant="outlined"
-            color="secondary"
-            size="small"
-            onClick={_acCancel}
-            sx={{ textTransform: 'none', fontSize: '0.7rem' }}
-          >
-            Tạm dừng tự động tiếp tục (10s)
-          </Button>
-        </Stack>
-      )}
-"""
-    if "Tạm dừng" not in c:
-        c = c.replace("<Box sx={{ flex: 1 ", btn + "\n        <Box sx={{ flex: 1 ")
-    
-    with open(CHAT_INPUT, "w") as f:
-        f.write(c)
-    print("OK: ChatInput.tsx")
-
-
-def patch_session_chat():
-    sess = "/source/frontend/src/components/SessionChat.tsx"
-    if not os.path.exists(sess):
-        print(f"SKIP: {sess}")
-        return
-    with open(sess, "r") as f:
-        c = f.read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-    with open(sess, "w") as f:
-        f.write(c)
-    print("OK: SessionChat.tsx")
-
-
-def patch_agent_loop():
-    if not os.path.exists(AGENT_LOOP):
-        print(f"SKIP: {AGENT_LOOP}")
-        return
-    with open(AGENT_LOOP, "r") as f:
-        c = f.read()
-    
-    if "_unfinished_plan" not in c:
-        fn = '''
-
-def _unfinished_plan(session: Session) -> list[dict[str, str]]:
-    plan = getattr(session, "current_plan", None) or []
-    return [item for item in plan if item.get("status") in ("pending", "in_progress")]
-
-'''
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    if "task_incomplete" not in c:
-        check = '''
-            # === Auto-continue detection ===
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    await session.send_event(
-                        Event(event_type="task_incomplete", data={"incomplete_plan": unfinished})
-                    )
-'''
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + "\n" + marker)
-    
-    with open(AGENT_LOOP, "w") as f:
-        f.write(c)
-    print("OK: agent_loop.py")
-
-
-if __name__ == "__main__":
-    patch_events()
-    patch_sse()
-    patch_use_agent()
-    patch_chat_input()
-    patch_session_chat()
-    patch_agent_loop()
-    print("\nDONE: V5 - simple approach applied")

patch_auto_continue_v6.py

@@ -1,243 +0,0 @@
-"""V6: FIXED - Auto-continue with pause button for free models."""
-
-import os
-import re
-
-EVENTS_FILE = "/source/frontend/src/types/events.ts"
-SSE_TRANSPORT = "/source/frontend/src/lib/sse-chat-transport.ts"
-HOOK_FILE = "/source/frontend/src/hooks/useAgentChat.ts"
-CHAT_INPUT = "/source/frontend/src/components/Chat/ChatInput.tsx"
-SESSION_CHAT = "/source/frontend/src/components/SessionChat.tsx"
-AGENT_LOOP = "/app/agent/core/agent_loop.py"
-
-
-def fix_events():
-    with open(EVENTS_FILE, "r") as f:
-        content = f.read()
-    if "'task_incomplete'" not in content:
-        content = content.replace("  | 'plan_update';", "  | 'plan_update'\n  | 'task_incomplete';")
-        with open(EVENTS_FILE, "w") as f:
-            f.write(content)
-    print("OK: events.ts")
-
-
-def fix_sse():
-    with open(SSE_TRANSPORT, "r") as f:
-        content = f.read()
-
-    # Add onTaskIncomplete to interface
-    if "onTaskIncomplete:" not in content and "onInterrupted: () => void;" in content:
-        content = content.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-
-    # Add case handler  
-    if "case 'task_incomplete'" not in content:
-        case_code = """      case 'task_incomplete' as const:
-          sideChannel.onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-"""
-        content = content.replace("case 'turn_complete':", case_code + "\n        case 'turn_complete':")
-
-    with open(SSE_TRANSPORT, "w") as f:
-        f.write(content)
-    print("OK: sse-chat-transport.ts")
-
-
-def fix_hook():
-    with open(HOOK_FILE, "r") as f:
-        content = f.read()
-
-    # 1. Import useState
-    if "useState" not in content:
-        content = content.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-
-    # 2. Add state after callbacksRef block
-    state_block = """
-  // Auto-continue for free models
-  const _acTimer = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [_showAc, _setShowAc] = useState(false);
-  const _acCancel = useCallback(() => {
-    _setShowAc(false);
-    if (_acTimer.current) { clearTimeout(_acTimer.current); _acTimer.current = null; }
-  }, []);"""
-    
-    if "_acTimer" not in content:
-        content = content.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state_block
-        )
-
-    # 3. Add onTaskIncomplete to interface
-    if "onTaskIncomplete:" not in content and "onInterrupted: () => void;" in content:
-        content = content.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-
-    # 4. Add handler in sideChannel - uses chatActionsRef to avoid hoisting issues
-    handler_code = """      onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => {
-        _setShowAc(true);
-        if (_acTimer.current) clearTimeout(_acTimer.current);
-        _acTimer.current = setTimeout(() => {
-          _setShowAc(false);
-          const planStr = incompletePlan.map(i => `- ${i.content}`).join('\\\\n');
-          const msg = { text: `[TIẾP TỤC] Task chưa hoàn thành:\\\\n${planStr}`, metadata: { createdAt: new Date().toISOString() } };
-          const setMsgs = chatActionsRef.current.setMessages;
-          if (setMsgs) {
-            chatActionsRef.current.messages = [...chatActionsRef.current.messages, { id: 'ac-continue', role: 'user', parts: [{ type: 'text', text: msg.text }], content: msg.text }];
-          }
-        }, 10000);
-      },
-      onInterrupted: () => { /* no-op - handled by stop() */ },"""
-    
-    if "onTaskIncomplete: (incompletePlan" not in content:
-        old_handler = '      onInterrupted: () => { /* no-op \u2014 handled by stop() caller */ },'
-        if old_handler in content:
-            content = content.replace(old_handler, handler_code)
-        else:
-            old_handler2 = '      onInterrupted: () => { /* no-op */ },'
-            content = content.replace(old_handler2, handler_code)
-
-    # 5. Return values
-    if "_showAc" not in content:
-        # The _showAc and _acCancel need to be in the return
-        return_marker = "refreshMessages,\n  };"
-        if return_marker in content:
-            content = content.replace(
-                return_marker,
-                "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-            )
-
-    with open(HOOK_FILE, "w") as f:
-        f.write(content)
-    print("OK: useAgentChat.ts")
-
-
-def fix_chat_input():
-    with open(CHAT_INPUT, "r") as f:
-        content = f.read()
-
-    # Fix DatasetUploadResponse
-    wrong_import = "import type { DatasetUploadResponse } from '@/types/agent';"
-    if wrong_import in content:
-        content = content.replace(wrong_import, "")
-        content = content.replace(
-            "import { apiFetch } from '@/utils/api';",
-            "import { apiFetch } from '@/utils/api';\ntype DatasetUploadResponse = { url: string; repo_id: string; filename: string; size: number; };"
-        )
-
-    # Add Button import
-    if "Button" not in content:
-        content = content.replace(
-            "import { Box, IconButton, Stack, Tooltip } from '@mui/material';",
-            "import { Box, IconButton, Stack, Tooltip, Button } from '@mui/material';"
-        )
-
-    # Fix interface
-    if "_showAc" not in content:
-        iface_match = re.search(r'interface ChatInputProps\s*\{[^}]*\}', content, re.DOTALL)
-        if iface_match:
-            new_iface = """interface ChatInputProps {
-  sessionId: string;
-  initialModelPath: string | null | undefined;
-  onSend: (text: string) => Promise<void>;
-  onStop: () => void;
-  onDatasetUploaded: () => Promise<boolean>;
-  isProcessing: boolean;
-  disabled: boolean;
-  placeholder?: string;
-  _showAc?: boolean;
-  _acCancel?: () => void;
-}"""
-            content = content.replace(iface_match.group(0), new_iface)
-
-    # Add pause button
-    btn_code = """
-      {/* Auto-continue pause for free models */}
-      {_showAc && _acCancel && (
-        <Stack direction="row" spacing={1} sx={{ mb: 1, px: 1 }}>
-          <Button
-            variant="outlined"
-            color="secondary"
-            size="small"
-            onClick={_acCancel}
-            sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.8 }}
-          >
-            T\u1ea1m d\u1eebng t\u1ef1 \u0111\u1ed9ng ti\u1ebfp t\u1ee5c (10s)
-          </Button>
-        </Stack>
-      )}"""
-    
-    if "T\u1ea1m d\u1eebng" not in content and "free models" not in content:
-        content = content.replace("<Box sx={{ flex: 1 ", btn_code + "\n        <Box sx={{ flex: 1 ")
-
-    with open(CHAT_INPUT, "w") as f:
-        f.write(content)
-    print("OK: ChatInput.tsx")
-
-
-def fix_session_chat():
-    with open(SESSION_CHAT, "r") as f:
-        content = f.read()
-    
-    # Add props to ChatInput
-    if "_showAc" not in content:
-        content = content.replace(
-            "<ChatInput ",
-            "<ChatInput _showAc={_showAc} _acCancel={_acCancel} "
-        )
-
-    with open(SESSION_CHAT, "w") as f:
-        f.write(content)
-    print("OK: SessionChat.tsx")
-
-
-def fix_agent_loop():
-    if not os.path.exists(AGENT_LOOP):
-        print(f"SKIP: {AGENT_LOOP}")
-        return
-    with open(AGENT_LOOP, "r") as f:
-        content = f.read()
-
-    if "_unfinished_plan" not in content:
-        fn_block = '''
-
-def _unfinished_plan(s: Session) -> list[dict[str, str]]:
-    p = getattr(s, "current_plan", None) or []
-    return [it for it in p if it.get("status") in ("pending", "in_progress")]
-
-'''
-        content = content.replace("class Handlers:", fn_block + "\n\nclass Handlers:")
-
-    if "task_incomplete" not in content:
-        check_block = '''
-            # Auto-continue detect
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    await session.send_event(Event(event_type="task_incomplete", data={"incomplete_plan": unfinished}))
-'''
-        marker = "  # -- End of turn --"
-        if marker in content:
-            content = content.replace(marker, check_block + "\n" + marker)
-
-    with open(AGENT_LOOP, "w") as f:
-        f.write(content)
-    print("OK: agent_loop.py")
-
-
-if __name__ == "__main__":
-    fix_events()
-    fix_sse()
-    fix_hook()
-    fix_chat_input()
-    fix_session_chat()
-    fix_agent_loop()
-    print("\nDONE: V6 - all fixed")

patch_auto_continue_v7.py

@@ -1,255 +0,0 @@
-"""V7: PRECISE patch - exact string matching with source code.
-
-Adds auto-continue pause button for free models. All patches use exact 
-string content from the original source files for reliable replacement.
-"""
-
-import os, sys
-
-# ========== PATCH 1: events.ts - add 'task_incomplete' to EventType ==========
-events_ts = "/source/frontend/src/types/events.ts"
-def patch_events():
-    with open(events_ts) as f:
-        c = f.read()
-    if "'task_incomplete'" not in c:
-        c = c.replace(
-            "  | 'interrupted'",
-            "  | 'interrupted'\n  | 'task_incomplete'"
-        )
-        with open(events_ts, 'w') as f: f.write(c)
-    print("OK: events.ts")
-
-# ========== PATCH 2: SSE transport - add onTaskIncomplete to interface + handler ==========
-sse_ts = "/source/frontend/src/lib/sse-chat-transport.ts"
-def patch_sse():
-    with open(sse_ts) as f:
-        c = f.read()
-    
-    # Add to interface
-    if "onTaskIncomplete:" not in c:
-        c = c.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # Add case handler before default
-    if "case 'task_incomplete'" not in c:
-        case_handler = """      case 'task_incomplete':
-          sideChannel.onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-        c = c.replace("\n        default:", "\n" + case_handler)
-    
-    with open(sse_ts, 'w') as f: f.write(c)
-    print("OK: sse-chat-transport.ts")
-
-# ========== PATCH 3: useAgentChat.ts - add state + handler + return ==========
-hook_ts = "/source/frontend/src/hooks/useAgentChat.ts"
-def patch_hook():
-    with open(hook_ts) as f:
-        c = f.read()
-    
-    # 1. Add useState to imports
-    if "useState" not in c:
-        c = c.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # 2. Add state variables after callbacksRef
-    state_block = """
-  // Auto-continue state for free models
-  const _acTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [_showAc, _setShowAc] = useState(false);"""
-    if "_acTimerRef" not in c:
-        c = c.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state_block
-        )
-    
-    # 3. Add onTaskIncomplete to interface
-    if "onTaskIncomplete:" not in c:
-        c = c.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # 4. Add onTaskIncomplete handler in sideChannel object
-    # This inserts BEFORE the existing onInterrupted handler
-    handler = """      onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => {
-        _setShowAc(true);
-        if (_acTimerRef.current) clearTimeout(_acTimerRef.current);
-        _acTimerRef.current = setTimeout(() => {
-          _setShowAc(false);
-          const planStr = incompletePlan.map(i => `- ${i.content}`).join('\\\\n');
-          const setMsgs = chatActionsRef.current.setMessages;
-          if (setMsgs) {
-            const msgs = chatActionsRef.current.messages;
-            setMsgs([...msgs, { id: 'ac-'+Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: `[TIẾP TỤC] Task chưa hoàn thành:\\\\n${planStr}` }], content: '' }]);
-          }
-        }, 10000);
-      },
-      onInterrupted: () => { /* no-op */ },"""
-    
-    if "onTaskIncomplete: (incompletePlan" not in c:
-        old_interrupted = '      onInterrupted: () => { /* no-op \u2014 handled by stop() caller */ },'
-        if old_interrupted in c:
-            c = c.replace(old_interrupted, handler)
-        else:
-            # Try simpler version
-            old2 = '      onInterrupted: () => { /* no-op */ },'
-            c = c.replace(old2, handler)
-    
-    # 5. Add _acCancel function + return values
-    cancel_func = """
-  const _acCancel = useCallback(() => {
-    _setShowAc(false);
-    if (_acTimerRef.current) { clearTimeout(_acTimerRef.current); _acTimerRef.current = null; }
-  }, []);"""
-    if "_acCancel" not in c:
-        c = c.replace("\n  return {\n    messages: chat.messages,", cancel_func + "\n  return {\n    messages: chat.messages,")
-    
-    # 6. Return values
-    if "_showAc," not in c:
-        c = c.replace(
-            "refreshMessages,\n  };",
-            "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-        )
-    
-    with open(hook_ts, 'w') as f: f.write(c)
-    print("OK: useAgentChat.ts")
-
-# ========== PATCH 4: ChatInput.tsx - add pause button ==========
-input_tsx = "/source/frontend/src/components/Chat/ChatInput.tsx"
-def patch_chat_input():
-    with open(input_tsx) as f:
-        c = f.read()
-    
-    # 1. Add Button import (it's missing from the original imports)
-    if "Button" not in c:
-        c = c.replace(
-            "  Tooltip,",
-            "  Tooltip,\n  Button,"
-        )
-    
-    # 2. Add props to interface
-    if "_showAc" not in c:
-        old_interface_end = """interface ChatInputProps {
-  sessionId?: string;
-  initialModelPath?: string | null;
-  onSend: (text: string) => void;
-  onStop?: () => void;
-  onDatasetUploaded?: () => Promise<boolean> | boolean;
-  isProcessing?: boolean;
-  disabled?: boolean;
-  placeholder?: string;
-}"""
-        new_interface = """interface ChatInputProps {
-  sessionId?: string;
-  initialModelPath?: string | null;
-  onSend: (text: string) => void;
-  onStop?: () => void;
-  onDatasetUploaded?: () => Promise<boolean> | boolean;
-  isProcessing?: boolean;
-  disabled?: boolean;
-  placeholder?: string;
-  _showAc?: boolean;
-  _acCancel?: () => void;
-}"""
-        c = c.replace(old_interface_end, new_interface)
-    
-    # 3. Add destructured props in function signature
-    if "_showAc" not in c:
-        old_props = "placeholder = 'Ask anything...' }: ChatInputProps) {"
-        new_props = "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-        if old_props not in c:
-            old_props2 = "placeholder = 'Ask anything...' }: ChatInputProps) {"
-            new_props2 = "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-            c = c.replace(old_props2, new_props2)
-        else:
-            c = c.replace(old_props, new_props)
-    
-    # 4. Add pause button after the model badge area, before <JobsUpgradeDialog>
-    if "T\u1ea1m d\u1eebng" not in c:
-        btn = """
-        {/* Auto-continue pause for free models */}
-        {_showAc && _acCancel && (
-          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>
-            <Button
-              variant="outlined"
-              size="small"
-              onClick={_acCancel}
-              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}
-            >
-              T\u1ea1m d\u1eebng t\u1ef1 \u0111\u1ed9ng ti\u1ebfp t\u1ee5c (10s)
-            </Button>
-          </Box>
-        )}
-"""
-        if "<JobsUpgradeDialog" in c:
-            c = c.replace("<JobsUpgradeDialog", btn + "\n        <JobsUpgradeDialog")
-    
-    with open(input_tsx, 'w') as f: f.write(c)
-    print("OK: ChatInput.tsx")
-
-# ========== PATCH 5: SessionChat.tsx - pass props down ==========
-session_tsx = "/source/frontend/src/components/SessionChat.tsx"
-def patch_session():
-    if not os.path.exists(session_tsx):
-        print(f"SKIP: {session_tsx}")
-        return
-    with open(session_tsx) as f:
-        c = f.read()
-    if "_showAc" not in c:
-        old = "<ChatInput "
-        new = "<ChatInput _showAc={_showAc} _acCancel={_acCancel} "
-        c = c.replace(old, new)
-    with open(session_tsx, 'w') as f: f.write(c)
-    print("OK: SessionChat.tsx")
-
-# ========== PATCH 6: agent_loop.py - detection ==========
-agent_py = "/app/agent/core/agent_loop.py"
-def patch_agent():
-    if not os.path.exists(agent_py):
-        print(f"SKIP: {agent_py}")
-        return
-    with open(agent_py) as f:
-        c = f.read()
-    
-    # Add helper function
-    if "_unfinished_plan" not in c:
-        fn = """
-def _unfinished_plan(s: Session) -> list[dict[str, str]]:
-    p = getattr(s, "current_plan", None) or []
-    return [it for it in p if it.get("status") in ("pending", "in_progress")]
-
-"""
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    # Add detection
-    if "task_incomplete" not in c:
-        check = """
-            # Auto-continue detection
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    await session.send_event(Event(event_type="task_incomplete", data={"incomplete_plan": unfinished}))
-"""
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + "\n" + marker)
-    
-    with open(agent_py, 'w') as f: f.write(c)
-    print("OK: agent_loop.py")
-
-if __name__ == "__main__":
-    patch_events()
-    patch_sse()
-    patch_hook()
-    patch_chat_input()
-    patch_session()
-    patch_agent()
-    print("\nDONE: V7 - precise patches applied")

patch_auto_continue_v8.py

@@ -1,239 +0,0 @@
-"""V8: Safe auto-continue via useEffect pattern (no hoisting issues)."""
-
-import os
-
-events_ts = "/source/frontend/src/types/events.ts"
-sse_ts = "/source/frontend/src/lib/sse-chat-transport.ts"
-hook_ts = "/source/frontend/src/hooks/useAgentChat.ts"
-input_tsx = "/source/frontend/src/components/Chat/ChatInput.tsx"
-session_tsx = "/source/frontend/src/components/SessionChat.tsx"
-agent_py = "/app/agent/core/agent_loop.py"
-
-
-def patch_events():
-    with open(events_ts) as f:
-        c = f.read()
-    if "'task_incomplete'" not in c:
-        c = c.replace(
-            "  | 'interrupted'",
-            "  | 'interrupted'\n  | 'task_incomplete'"
-        )
-        with open(events_ts, 'w') as f: f.write(c)
-    print("OK: events.ts")
-
-
-def patch_sse():
-    with open(sse_ts) as f:
-        c = f.read()
-    
-    if "onTaskIncomplete:" not in c:
-        c = c.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    if "case 'task_incomplete'" not in c:
-        case_handler = """      case 'task_incomplete':
-          sideChannel.onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-        c = c.replace("\n        default:", "\n" + case_handler)
-    
-    with open(sse_ts, 'w') as f: f.write(c)
-    print("OK: sse.ts")
-
-
-def patch_hook():
-    with open(hook_ts) as f:
-        c = f.read()
-    
-    # 1. Import useState
-    if "useState" not in c:
-        c = c.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # 2. State after callbacksRef
-    state = """
-  // Auto-continue state for free models
-  const [_showAc, _setShowAc] = useState(false);
-  const _acPlanRef = useRef<Array<{ id: string; content: string; status: string }>>([]);"""
-    if "_showAc" not in c:
-        c = c.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state
-        )
-    
-    # 3. onTaskIncomplete in interface
-    if "onTaskIncomplete:" not in c:
-        c = c.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # 4. Handler in sideChannel (only set state + ref, no chat.sendMessage)
-    handler = """      onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => {
-        _acPlanRef.current = incompletePlan;
-        _setShowAc(true);
-      },
-      onInterrupted: () => { /* no-op */ },"""
-    
-    if "onTaskIncomplete: (incompletePlan" not in c:
-        old = '      onInterrupted: () => { /* no-op \u2014 handled by stop() caller */ },'
-        if old in c:
-            c = c.replace(old, handler)
-        else:
-            c = c.replace('      onInterrupted: () => { /* no-op */ },', handler)
-    
-    # 5. useEffect to watch _showAc - runs timer, calls chat.sendMessage via chatActionsRef
-    effect = """
-  // Auto-continue effect: when _showAc becomes true, start 10s timer
-  useEffect(() => {
-    if (!_showAc) return;
-    const timer = setTimeout(() => {
-      const plan = _acPlanRef.current;
-      const setMsgs = chatActionsRef.current.setMessages;
-      const msgs = chatActionsRef.current.messages;
-      if (setMsgs && plan.length > 0) {
-        const planStr = plan.map(i => `- ${i.content}`).join('\\\\n');
-        const newMsg = { id: 'ac-' + Date.now(), role: 'user' as const, parts: [{ type: 'text' as const, text: `[TIẾP TỤC] Task chưa hoàn thành:\\\\n${planStr}` }], content: '' };
-        setMsgs([...msgs, newMsg]);
-      }
-      _setShowAc(false);
-    }, 10000);
-    return () => clearTimeout(timer);
-  }, [_showAc]);
-"""
-    if "Auto-continue effect" not in c:
-        # Insert before return
-        c = c.replace("\n  return {\n    messages: chat.messages,", effect + "\n  return {\n    messages: chat.messages,")
-    
-    # 6. Cancel + return
-    cancel = """
-  const _acCancel = useCallback(() => { _setShowAc(false); }, []);"""
-    if "_acCancel" not in c:
-        c = c.replace("\n  return {\n    messages: chat.messages,", cancel + "\n  return {\n    messages: chat.messages,")
-    if "_showAc," not in c:
-        c = c.replace(
-            "refreshMessages,\n  };",
-            "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-        )
-    
-    with open(hook_ts, 'w') as f: f.write(c)
-    print("OK: useAgentChat.ts")
-
-
-def patch_chat_input():
-    with open(input_tsx) as f:
-        c = f.read()
-    
-    if "Button" not in c:
-        c = c.replace("  Tooltip,", "  Tooltip,\n  Button,")
-    
-    if "_showAc" not in c:
-        old_iface = """interface ChatInputProps {
-  sessionId?: string;
-  initialModelPath?: string | null;
-  onSend: (text: string) => void;
-  onStop?: () => void;
-  onDatasetUploaded?: () => Promise<boolean> | boolean;
-  isProcessing?: boolean;
-  disabled?: boolean;
-  placeholder?: string;
-}"""
-        new_iface = """interface ChatInputProps {
-  sessionId?: string;
-  initialModelPath?: string | null;
-  onSend: (text: string) => void;
-  onStop?: () => void;
-  onDatasetUploaded?: () => Promise<boolean> | boolean;
-  isProcessing?: boolean;
-  disabled?: boolean;
-  placeholder?: string;
-  _showAc?: boolean;
-  _acCancel?: () => void;
-}"""
-        c = c.replace(old_iface, new_iface)
-        
-        old_props = "placeholder = 'Ask anything...' }: ChatInputProps) {"
-        new_props = "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-        if old_props not in c:
-            old_props2 = "placeholder = 'Ask anything...' }: ChatInputProps) {"
-            new_props2 = "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-            c = c.replace(old_props2, new_props2)
-        else:
-            c = c.replace(old_props, new_props)
-    
-    if "T\u1ea1m d\u1eebng" not in c:
-        btn = """
-        {_showAc && _acCancel && (
-          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>
-            <Button variant="outlined" size="small" onClick={_acCancel}
-              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>
-              T\u1ea1m d\u1eebng t\u1ef1 \u0111\u1ed9ng ti\u1ebfp t\u1ee5c (10s)
-            </Button>
-          </Box>
-        )}
-"""
-        if "<JobsUpgradeDialog" in c:
-            c = c.replace("<JobsUpgradeDialog", btn + "\n        <JobsUpgradeDialog")
-    
-    with open(input_tsx, 'w') as f: f.write(c)
-    print("OK: ChatInput.tsx")
-
-
-def patch_session():
-    if not os.path.exists(session_tsx):
-        print(f"SKIP: {session_tsx}")
-        return
-    with open(session_tsx) as f:
-        c = f.read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-    with open(session_tsx, 'w') as f: f.write(c)
-    print("OK: SessionChat.tsx")
-
-
-def patch_agent():
-    if not os.path.exists(agent_py):
-        print(f"SKIP: {agent_py}")
-        return
-    with open(agent_py) as f:
-        c = f.read()
-    
-    if "_unfinished_plan" not in c:
-        fn = """
-def _unfinished_plan(s: Session) -> list[dict[str, str]]:
-    p = getattr(s, "current_plan", None) or []
-    return [it for it in p if it.get("status") in ("pending", "in_progress")]
-"""
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    if "task_incomplete" not in c:
-        check = """
-            # Auto-continue detection
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    await session.send_event(Event(event_type="task_incomplete", data={"incomplete_plan": unfinished}))
-"""
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + "\n" + marker)
-    
-    with open(agent_py, 'w') as f: f.write(c)
-    print("OK: agent_loop.py")
-
-
-if __name__ == "__main__":
-    patch_events()
-    patch_sse()
-    patch_hook()
-    patch_chat_input()
-    patch_session()
-    patch_agent()
-    print("\nDONE: V8 - safe useEffect pattern")

patch_auto_continue_v9.py

@@ -1,227 +0,0 @@
-"""V9: SIMPLEST approach - no interface changes, no props chain.
-
-Uses CustomEvent to communicate between sideChannel and React state.
-This avoids ALL TypeScript issues:
-- No interface changes needed
-- No hoisting issues
-- No unused variable warnings
-"""
-
-import os
-
-events_ts = "/source/frontend/src/types/events.ts"
-sse_ts = "/source/frontend/src/lib/sse-chat-transport.ts"
-hook_ts = "/source/frontend/src/hooks/useAgentChat.ts"
-input_tsx = "/source/frontend/src/components/Chat/ChatInput.tsx"
-agent_py = "/app/agent/core/agent_loop.py"
-
-
-def patch_events():
-    with open(events_ts) as f:
-        c = f.read()
-    if "'task_incomplete'" not in c:
-        c = c.replace("  | 'interrupted'", "  | 'interrupted'\n  | 'task_incomplete'")
-        with open(events_ts, 'w') as f: f.write(c)
-    print("OK: events.ts")
-
-
-def patch_sse():
-    with open(sse_ts) as f:
-        c = f.read()
-    
-    # Add case handler DIRECTLY without changing interface
-    # Use as any cast to bypass type checking
-    if "case 'task_incomplete'" not in c:
-        # Add handler before default, using (sideChannel as any) to avoid interface issue
-        case_block = """      case 'task_incomplete':
-          (sideChannel as any).onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-
-        default:"""
-        c = c.replace("\n        default:", "\n" + case_block)
-    
-    with open(sse_ts, 'w') as f: f.write(c)
-    print("OK: sse.ts")
-
-
-def patch_hook():
-    with open(hook_ts) as f:
-        c = f.read()
-    
-    # 1. Import useState
-    if "useState" not in c:
-        c = c.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # 2. Add state after callbacksRef - TS will complain "unused" but _ prefix helps
-    state_block = """
-  // Auto-continue for free models
-  const [_showAc, _setShowAc] = useState(false);"""
-    if "_showAc" not in c:
-        c = c.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state_block
-        )
-    
-    # 3. Add onTaskIncomplete to the sideChannel object via (sideChannel as any)
-    # We use the onSessionUpdate handler as injection point since it already exists
-    handler_block = """      onSessionUpdate: (data) => {
-        // Check for auto-continue trigger
-        if ((data as any).ac_plan) {
-          const plan = (data as any).ac_plan as Array<{ id: string; content: string; status: string }>;
-          _setShowAc(true);
-          setTimeout(() => {
-            _setShowAc(false);
-            if (plan.length > 0) {
-              const planStr = plan.map(i => `- ${i.content}`).join('\\\\n');
-              chat.sendMessage({ text: `[TIẾP TỤC] Task chưa hoàn thành:\\\\n${planStr}`, metadata: { createdAt: new Date().toISOString() } });
-            }
-          }, 10000);
-          return;
-        }
-        const autoApproval = data.auto_approval;"""
-    
-    if "_setShowAc" in c and "ac_plan" not in c:
-        # Find existing onSessionUpdate
-        old = """      onSessionUpdate: (data) => {
-        const autoApproval = data.auto_approval;"""
-        if old in c:
-            c = c.replace(old, handler_block)
-            print("OK: injected onSessionUpdate handler")
-    
-    # 4. Cancel function + return values
-    cancel = """
-  const _acCancel = useCallback(() => { _setShowAc(false); }, []);"""
-    if "_acCancel" not in c and "_showAc" in c:
-        c = c.replace("\n  return {\n    messages: chat.messages,", cancel + "\n  return {\n    messages: chat.messages,")
-        c = c.replace(
-            "refreshMessages,\n  };",
-            "refreshMessages,\n    _showAc,\n    _acCancel,\n  };"
-        )
-    
-    with open(hook_ts, 'w') as f: f.write(c)
-    print("OK: useAgentChat.ts")
-
-
-def patch_chat_input():
-    with open(input_tsx) as f:
-        c = f.read()
-    
-    if "Button" not in c:
-        c = c.replace("  Tooltip,", "  Tooltip,\n  Button,")
-    
-    if "_showAc" not in c:
-        old_iface = """interface ChatInputProps {
-  sessionId?: string;
-  initialModelPath?: string | null;
-  onSend: (text: string) => void;
-  onStop?: () => void;
-  onDatasetUploaded?: () => Promise<boolean> | boolean;
-  isProcessing?: boolean;
-  disabled?: boolean;
-  placeholder?: string;
-}"""
-        new_iface = """interface ChatInputProps {
-  sessionId?: string;
-  initialModelPath?: string | null;
-  onSend: (text: string) => void;
-  onStop?: () => void;
-  onDatasetUploaded?: () => Promise<boolean> | boolean;
-  isProcessing?: boolean;
-  disabled?: boolean;
-  placeholder?: string;
-  _showAc?: boolean;
-  _acCancel?: () => void;
-}"""
-        c = c.replace(old_iface, new_iface)
-        
-        # Add destructured props
-        old_props = "placeholder = 'Ask anything...' }: ChatInputProps) {"
-        new_props = "placeholder = 'Ask anything...', _showAc = false, _acCancel }: ChatInputProps) {"
-        c = c.replace(old_props, new_props)
-    
-    if "T\u1ea1m d\u1eebng" not in c:
-        btn = """
-        {_showAc && _acCancel && (
-          <Box sx={{ display: 'flex', justifyContent: 'center', mt: 1 }}>
-            <Button variant="outlined" size="small" onClick={_acCancel}
-              sx={{ textTransform: 'none', fontSize: '0.7rem', opacity: 0.7, '&:hover': { opacity: 1 } }}>
-              T\u1ea1m d\u1eebng t\u1ef1 \u0111\u1ed9ng ti\u1ebfp t\u1ee5c (10s)
-            </Button>
-          </Box>
-        )}
-"""
-        if "<JobsUpgradeDialog" in c:
-            c = c.replace("<JobsUpgradeDialog", btn + "\n        <JobsUpgradeDialog")
-    
-    with open(input_tsx, 'w') as f: f.write(c)
-    print("OK: ChatInput.tsx")
-
-
-def patch_session():
-    session_tsx = "/source/frontend/src/components/SessionChat.tsx"
-    if not os.path.exists(session_tsx):
-        print(f"SKIP: {session_tsx}")
-        return
-    with open(session_tsx) as f:
-        c = f.read()
-    if "_showAc" not in c:
-        c = c.replace("<ChatInput ", "<ChatInput _showAc={_showAc} _acCancel={_acCancel} ")
-    with open(session_tsx, 'w') as f: f.write(c)
-    print("OK: SessionChat.tsx")
-
-
-def patch_agent():
-    if not os.path.exists(agent_py):
-        print(f"SKIP: {agent_py}")
-        return
-    with open(agent_py) as f:
-        c = f.read()
-    
-    if "_unfinished_plan" not in c:
-        fn = """
-def _unfinished_plan(s: Session) -> list[dict[str, str]]:
-    p = getattr(s, "current_plan", None) or []
-    return [it for it in p if it.get("status") in ("pending", "in_progress")]
-"""
-        c = c.replace("class Handlers:", fn + "\n\nclass Handlers:")
-    
-    if "task_incomplete" not in c:
-        check = """
-            # Auto-continue detection
-            if not llm_result.tool_calls_acc and llm_result.content:
-                unfinished = _unfinished_plan(session)
-                if unfinished:
-                    # Use session_update event with ac_plan field to trigger auto-continue
-                    await session.send_event(Event(event_type="session_update", data={
-                        "ac_plan": unfinished,
-                        "auto_approval": getattr(session, "auto_approval", None),
-                    }))
-"""
-        marker = "  # -- End of turn --"
-        if marker in c:
-            c = c.replace(marker, check + "\n" + marker)
-        else:
-            print("WARN: Could not find -- End of turn -- marker")
-            # Try alternative: find where final_response is set
-            marker2 = "final_response = llm_result.content or None"
-            if marker2 in c:
-                c = c.replace(marker2, marker2 + "\n" + check)
-    
-    with open(agent_py, 'w') as f: f.write(c)
-    print("OK: agent_loop.py")
-
-
-if __name__ == "__main__":
-    patch_events()
-    patch_sse()
-    patch_hook()
-    patch_chat_input()
-    patch_session()
-    patch_agent()
-    print("\nDONE: V9 applied")
-    print("Strategy: Uses existing session_update event + (sideChannel as any) to avoid TS issues")

patch_chat_input.py

@@ -1,105 +0,0 @@
-"""Patch ChatInput.tsx - Fixed import for DatasetUploadResponse."""
-
-CHAT_INPUT = "/source/frontend/src/components/Chat/ChatInput.tsx"
-
-def patch():
-    import os, re
-    if not os.path.exists(CHAT_INPUT):
-        print(f"SKIP: {CHAT_INPUT} not found")
-        return
-        
-    with open(CHAT_INPUT, "r", encoding="utf-8") as f:
-        content = f.read()
-    
-    # 1. Add Button to MUI imports
-    if "Button" not in content and "@mui/material" in content:
-        content = content.replace(
-            "import { Box, IconButton, Stack, Tooltip } from '@mui/material';",
-            "import { Box, IconButton, Stack, Tooltip, Button } from '@mui/material';"
-        )
-    
-    # 2. Fix DatasetUploadResponse import - check existing imports
-    if "DatasetUploadResponse" not in content:
-        # Find existing import from types/agent
-        if "from '@/types/agent'" in content:
-            content = content.replace(
-                "from '@/types/agent'",
-                "from '@/types/agent'"
-            )
-            # Add DatasetUploadResponse to existing import
-            content = content.replace(
-                "import type { ",
-                "import type { DatasetUploadResponse, "
-            )
-        else:
-            content = content.replace(
-                "import { apiFetch } from '@/utils/api';",
-                "import { apiFetch } from '@/utils/api';\nimport type { DatasetUploadResponse } from '@/types/agent';"
-            )
-    
-    # 3. Add props to interface
-    if "showAutoContinue" not in content:
-        props_code = '''
-interface ChatInputProps {
-  sessionId: string;
-  initialModelPath: string | null | undefined;
-  onSend: (text: string) => Promise<void>;
-  onStop: () => void;
-  onDatasetUploaded: () => Promise<boolean>;
-  isProcessing: boolean;
-  disabled: boolean;
-  placeholder?: string;
-  showAutoContinue?: boolean;
-  taskIncompleteInfo?: { incompletePlan: Array<{ id: string; content: string; status: string }> } | null;
-  startAutoContinue?: () => void;
-  cancelAutoContinue?: () => void;
-}
-'''
-        match = re.search(r'interface ChatInputProps[^}]*[}][^}]*[}]', content, re.DOTALL)
-        if match:
-            content = content.replace(match.group(0), props_code)
-        else:
-            content = content.replace(
-                "export default function ChatInput",
-                props_code + "\nexport default function ChatInput"
-            )
-    
-    # 4. Add auto-continue buttons before the flex box
-    buttons_code = '''
-      {/* Auto-continue controls for free models */}
-      {showAutoContinue && taskIncompleteInfo && (
-        <Stack direction="row" spacing={1} sx={{ mb: 1, px: 1 }}>
-          <Button
-            variant="contained"
-            color="primary"
-            size="small"
-            onClick={startAutoContinue}
-            sx={{ textTransform: 'none', fontSize: '0.75rem' }}
-          >
-            Tự động tiếp tục (10s)
-          </Button>
-          <Button
-            variant="outlined"
-            color="secondary"
-            size="small"
-            onClick={cancelAutoContinue}
-            sx={{ textTransform: 'none', fontSize: '0.75rem' }}
-          >
-            Tạm dừng
-          </Button>
-        </Stack>
-      )}
-'''
-    
-    if "Tự động tiếp tục" not in content:
-        content = content.replace(
-            "<Box sx={{ flex: 1 ",
-            buttons_code + "        <Box sx={{ flex: 1 "
-        )
-    
-    with open(CHAT_INPUT, "w", encoding="utf-8") as f:
-        f.write(content)
-    print(f"OK: Patched {CHAT_INPUT}")
-
-if __name__ == "__main__":
-    patch()

patch_frontend.py

@@ -1,184 +0,0 @@
-"""Patch frontend: Replace DEFAULT_MODEL_OPTIONS with OpenRouter models."""
-
-import re
-import sys
-
-FILE = "/source/frontend/src/components/Chat/ChatInput.tsx"
-MODEL_FILE = "/source/frontend/src/utils/model.ts"
-
-# === Step 1: Patch model.ts ===
-with open(MODEL_FILE, "r") as f:
-    model_content = f.read()
-
-model_content = model_content.replace(
-    "export const KIMI_K27_CODE_MODEL_PATH = 'moonshotai/Kimi-K2.7-Code:novita';",
-    "export const KIMI_K27_CODE_MODEL_PATH = 'deepseek-ai/DeepSeek-V4-Pro';"
-)
-model_content = model_content.replace(
-    "export const MINIMAX_M3_MODEL_PATH = 'MiniMaxAI/MiniMax-M3:novita';",
-    "export const MINIMAX_M3_MODEL_PATH = 'deepseek-ai/DeepSeek-V4-Flash';"
-)
-model_content = model_content.replace(
-    "export const GLM_52_MODEL_PATH = 'zai-org/GLM-5.2:novita';",
-    "export const GLM_52_MODEL_PATH = 'deepseek/deepseek-v4-flash';"
-)
-model_content = model_content.replace(
-    "export const DEEPSEEK_V4_PRO_MODEL_PATH = 'deepseek-ai/DeepSeek-V4-Pro:novita';",
-    "export const DEEPSEEK_V4_PRO_MODEL_PATH = 'nvidia/nemotron-3-super-120b-a12b:free';"
-)
-
-# Add DeepSeek V4 Flash latest model path
-if "DEEPSEEK_V4_FLASH_LATEST_MODEL_PATH" not in model_content:
-    model_content = model_content.replace(
-        "export const LAGUNA_S21_MODEL_PATH",
-        "export const DEEPSEEK_V4_FLASH_LATEST_MODEL_PATH = '~deepseek/deepseek-v4-flash-latest';\n\nexport const LAGUNA_S21_MODEL_PATH"
-    )
-    print("OK: Added DEEPSEEK_V4_FLASH_LATEST_MODEL_PATH")
-
-# === PATCH: Add Laguna S 2.1 model path ===
-if "LAGUNA_S21_MODEL_PATH" not in model_content:
-    model_content = model_content.replace(
-        "export const LAGUNA_M1_MODEL_PATH",
-        "export const LAGUNA_S21_MODEL_PATH = 'openai/poolside/laguna-s-2.1:free';\n\nexport const LAGUNA_M1_MODEL_PATH"
-    )
-    print("OK: Added LAGUNA_S21_MODEL_PATH")
-
-with open(MODEL_FILE, "w") as f:
-    f.write(model_content)
-print("OK: model.ts constants updated")
-
-# === Step 2: Patch ChatInput.tsx ===
-with open(FILE, "r", encoding="utf-8") as f:
-    content = f.read()
-
-# Fix imports
-import_pattern = re.compile(
-    r'import\s*\{[^}]+\}\s*from\s*[\'"]@/utils/model[\'"];'
-)
-match = import_pattern.search(content)
-if match:
-    content = content.replace(match.group(0), "import { isClaudePath } from '@/utils/model';")
-    print("OK: Replaced imports")
-
-# Remove Owl Alpha references
-content = content.replace("'Owl Alpha'", "'Claude Opus 4.8'")
-content = content.replace('"Owl Alpha"', '"Claude Opus 4.8"')
-
-# Row 3: Kimi → DeepSeek V4 Pro
-content = content.replace("'Kimi K2.7 Code'", "'DeepSeek V4 Pro'")
-content = content.replace('"Kimi K2.7 Code"', '"DeepSeek V4 Pro"')
-
-# Row 4: MiniMax → DeepSeek V4 Flash
-content = content.replace("'MiniMax M3'", "'DeepSeek V4 Flash'")
-content = content.replace('"MiniMax M3"', '"DeepSeek V4 Flash"')
-
-# Row 5: GLM → DeepSeek V4 Flash
-content = content.replace("'GLM 5.2'", "'DeepSeek V4 Flash'")
-content = content.replace('"GLM 5.2"', '"DeepSeek V4 Flash"')
-
-# Row 6: DeepSeek V4 Pro → Nemotron
-content = content.replace(
-    "  {\n    id: 'deepseek-v4-pro',\n    name: 'DeepSeek V4 Pro',\n    modelPath: DEEPSEEK_V4_PRO_MODEL_PATH,\n    avatarUrl: getHfAvatarUrl('deepseek-ai/DeepSeek-V4-Pro'),\n  },",
-    "  {\n    id: 'nemotron-120b',\n    name: 'nvidia/nemotron-3-super-120b-a12b:free',\n    modelPath: DEEPSEEK_V4_PRO_MODEL_PATH,\n    avatarUrl: 'https://huggingface.co/api/avatars/nvidia',\n  },"
-)
-
-# Replace entire DEFAULT_MODEL_OPTIONS array
-pattern = r'const DEFAULT_MODEL_OPTIONS: ModelOption\[\] = \[.*?\];'
-match = re.search(pattern, content, re.DOTALL)
-
-if not match:
-    print("FAIL: Could not find DEFAULT_MODEL_OPTIONS array!")
-    sys.exit(1)
-
-NEW_MODELS = """const DEFAULT_MODEL_OPTIONS: ModelOption[] = [
-  {
-    id: 'tencent-hy3',
-    name: 'Tencent HY3:free',
-    modelPath: 'openai/tencent/hy3:free',
-    avatarUrl: 'https://huggingface.co/api/avatars/tencent',
-    recommended: true,
-  },
-  {
-    id: 'gemma-4-31b',
-    name: 'Gemma 4 31B:free',
-    modelPath: 'openai/google/gemma-4-31b-it:free',
-    avatarUrl: 'https://huggingface.co/api/avatars/google',
-    recommended: true,
-  },
-  {
-    id: 'llama-3.3-70b',
-    name: 'Llama 3.3 70B:free',
-    modelPath: 'openai/meta-llama/llama-3.3-70b-instruct:free',
-    avatarUrl: 'https://huggingface.co/api/avatars/meta-llama',
-    recommended: true,
-  },
-  {
-    id: 'laguna-m1',
-    name: 'Laguna M.1:free',
-    modelPath: 'openai/poolside/laguna-m.1:free',
-    avatarUrl: 'https://huggingface.co/api/avatars/poolside',
-    recommended: true,
-  },
-  {
-    id: 'laguna-s21',
-    name: 'Laguna S 2.1:free',
-    modelPath: 'openai/poolside/laguna-s-2.1:free',
-    avatarUrl: 'https://huggingface.co/api/avatars/poolside',
-    recommended: true,
-  },
-  {
-    id: 'nex-n2-mini',
-    name: 'nex-agi/nex-n2-mini',
-    modelPath: 'openai/nex-agi/nex-n2-mini',
-    avatarUrl: 'https://huggingface.co/api/avatars/nex-agi',
-    recommended: true,
-  },
-  {
-    id: 'ling-3.0-flash',
-    name: 'inclusionai/ling-3.0-flash:free',
-    modelPath: 'openai/inclusionai/ling-3.0-flash:free',
-    avatarUrl: 'https://huggingface.co/api/avatars/inclusionai',
-    recommended: true,
-  },
-  {
-    id: 'llama-3.1-8b',
-    name: 'Llama 3.1 8B',
-    modelPath: 'openai/meta-llama/llama-3.1-8b-instruct',
-    avatarUrl: 'https://huggingface.co/api/avatars/meta-llama',
-  },
-  {
-    id: 'qwen3-coder-next',
-    name: 'Qwen3 Coder Next',
-    modelPath: 'Qwen/Qwen3-Coder-Next',
-    avatarUrl: 'https://huggingface.co/api/avatars/Qwen',
-  },
-  {
-    id: 'gemini-2.0-flash',
-    name: 'Gemini 2.0 Flash',
-    modelPath: 'openai/google/gemini-2.0-flash-001',
-    avatarUrl: 'https://huggingface.co/api/avatars/google',
-  },
-  {
-    id: 'deepseek-v4-flash-latest',
-    name: 'DeepSeek V4 Flash latest',
-    modelPath: '~deepseek/deepseek-v4-flash-latest',
-    avatarUrl: 'https://huggingface.co/api/avatars/deepseek',
-    recommended: true,
-  },
-];"""
-
-content = content[:match.start()] + NEW_MODELS + content[match.end():]
-
-# Update DEFAULT_MODEL_PATH
-dm_path = re.search(r'const DEFAULT_MODEL_PATH\s*=.*?;', content)
-if dm_path:
-    content = content.replace(dm_path.group(0), "const DEFAULT_MODEL_PATH = 'openai/tencent/hy3:free';")
-    print("OK: Replaced DEFAULT_MODEL_PATH")
-else:
-    print("OK: DEFAULT_MODEL_PATH not found")
-
-with open(FILE, "w", encoding="utf-8") as f:
-    f.write(content)
-
-print("OK: Frontend patched - Tencent HY3:free DEFAULT")
-print("  Models: HY3:free, Gemma 4 31B:free, Llama 3.3 70B:free, Laguna M.1:free, Laguna S 2.1:free, Nex N2 Mini, Ling 3.0 Flash:free, Llama 3.1 8B, DeepSeek V4 Flash latest")

patch_models.py

@@ -1,212 +0,0 @@
-"""Patch backend: OpenRouter routing + DeepSeek V4 Flash 0731."""
-
-import ast
-import os
-import re
-
-AGENT_FILE = "/app/backend/routes/agent.py"
-LLM_PARAMS_FILE = "/app/agent/core/llm_params.py"
-IDS_FILE = "/app/agent/core/model_ids.py"
-
-with open(IDS_FILE) as f:
-    content = f.read()
-
-# Remove NO_TOOLS_MODELS if present from previous patches
-if "NO_TOOLS_MODELS" in content:
-    content = re.sub(r'NO_TOOLS_MODELS\s*=\s*\{[^}]*\}\n?', '', content)
-    print("OK: Removed old NO_TOOLS_MODELS")
-
-# Fix model IDs for OpenRouter - use exact full-line patterns to avoid accidental partial matches
-replacements = [
-    ('KIMI_K27_CODE_MODEL_ID = "moonshotai/Kimi-K2.7-Code:novita"',
-     'KIMI_K27_CODE_MODEL_ID = "deepseek-ai/DeepSeek-V4-Pro"'),
-    ('MINIMAX_M3_MODEL_ID = "MiniMaxAI/MiniMax-M3:novita"',
-     'MINIMAX_M3_MODEL_ID = "deepseek-ai/DeepSeek-V4-Flash"'),
-    ('GLM_52_MODEL_ID = "zai-org/GLM-5.2:novita"',
-     'GLM_52_MODEL_ID = "openai/deepseek/deepseek-v4-flash"'),
-    ('DEEPSEEK_V4_PRO_MODEL_ID = "deepseek-ai/DeepSeek-V4-Pro:novita"',
-     'DEEPSEEK_V4_PRO_MODEL_ID = "nvidia/nemotron-3-super-120b-a12b:free"'),
-]
-for old, new in replacements:
-    content = content.replace(old, new)
-print("OK: Model ID replacements applied")
-
-# Add missing constants BEFORE the specific line DEEPSEEK_V4_PRO_MODEL_ID = "..."
-if "TENCENT_HY3_FREE_MODEL_ID" not in content:
-    target_line = 'DEEPSEEK_V4_PRO_MODEL_ID = "nvidia/nemotron-3-super-120b-a12b:free"'
-    insert_block = '''TENCENT_HY3_FREE_MODEL_ID = "openai/tencent/hy3:free"
-GEMMA_4_31B_FREE_MODEL_ID = "openai/google/gemma-4-31b-it:free"
-LLAMA_3_3_70B_FREE_MODEL_ID = "openai/meta-llama/llama-3.3-70b-instruct:free"
-LLAMA_3_1_8B_MODEL_ID = "openai/meta-llama/llama-3.1-8b-instruct"
-LAGUNA_M1_FREE_MODEL_ID = "openai/poolside/laguna-m.1:free"
-LAGUNA_S21_FREE_MODEL_ID = "openai/poolside/laguna-s-2.1:free"
-NEX_N2_MINI_MODEL_ID = "openai/nex-agi/nex-n2-mini"
-LING_3_0_FLASH_FREE_MODEL_ID = "openai/inclusionai/ling-3.0-flash:free"
-'''
-    # Only replace the first occurrence (the variable definition)
-    if target_line in content:
-        content = content.replace(target_line, insert_block + target_line)
-        print("OK: Added missing constants")
-    else:
-        print("WARN: Could not find target line")
-
-# Replace all references to ~deepseek deepseek models with 0731 version (quoted strings only)
-content = content.replace('"~deepseek/deepseek-v4-flash-latest"', '"deepseek/deepseek-v4-flash-0731"')
-content = content.replace('"~deepseek/deepseek-v4-flash-0731"', '"deepseek/deepseek-v4-flash-0731"')
-
-with open(IDS_FILE, "w") as f:
-    f.write(content)
-print("OK: model_ids.py written")
-
-ast.parse(content)  # validate syntax
-print("OK: model_ids.py syntax OK")
-
-with open(AGENT_FILE) as f:
-    content = f.read()
-
-content = content.replace(
-    "DEFAULT_MODEL_ID = GLM_52_MODEL_ID",
-    'DEFAULT_MODEL_ID = "openai/tencent/hy3:free"'
-)
-content = content.replace(
-    "DEFAULT_GPT_MODEL_ID = GPT_55_MODEL_ID",
-    "DEFAULT_GPT_MODEL_ID = LAGUNA_S21_FREE_MODEL_ID"
-)
-
-# Update imports
-old_import = (
-    "from agent.core.model_ids import (\n"
-    "    CLAUDE_OPUS_48_MODEL_ID,\n"
-    "    DEEPSEEK_V4_PRO_MODEL_ID,\n"
-    "    GLM_52_MODEL_ID,\n"
-    "    GPT_55_MODEL_ID,\n"
-    "    KIMI_K27_CODE_MODEL_ID,\n"
-    "    MINIMAX_M3_MODEL_ID,\n"
-    "    strip_huggingface_model_prefix,\n"
-    ")"
-)
-new_import = (
-    "from agent.core.model_ids import (\n"
-    "    DEEPSEEK_V4_PRO_MODEL_ID,\n"
-    "    GLM_52_MODEL_ID,\n"
-    "    GPT_55_MODEL_ID,\n"
-    "    KIMI_K27_CODE_MODEL_ID,\n"
-    "    MINIMAX_M3_MODEL_ID,\n"
-    "    TENCENT_HY3_FREE_MODEL_ID,\n"
-    "    GEMMA_4_31B_FREE_MODEL_ID,\n"
-    "    LLAMA_3_3_70B_FREE_MODEL_ID,\n"
-    "    LLAMA_3_1_8B_MODEL_ID,\n"
-    "    LAGUNA_M1_FREE_MODEL_ID,\n"
-    "    LAGUNA_S21_FREE_MODEL_ID,\n"
-    "    NEX_N2_MINI_MODEL_ID,\n"
-    "    LING_3_0_FLASH_FREE_MODEL_ID,\n"
-    "    strip_huggingface_model_prefix,\n"
-    ")"
-)
-content = content.replace(old_import, new_import)
-
-# Update _available_models to include DeepSeek V4 Flash 0731
-new_func = '''def _available_models() -> list[dict[str, Any]]:
-    models = [
-        {"id": TENCENT_HY3_FREE_MODEL_ID, "label": "Tencent HY3:free", "recommended": True},
-        {"id": GEMMA_4_31B_FREE_MODEL_ID, "label": "Gemma 4 31B:free", "recommended": True},
-        {"id": LLAMA_3_3_70B_FREE_MODEL_ID, "label": "Llama 3.3 70B:free", "recommended": True},
-        {"id": LAGUNA_M1_FREE_MODEL_ID, "label": "Laguna M.1:free", "recommended": True},
-        {"id": DEFAULT_GPT_MODEL_ID, "label": "Laguna S 2.1:free", "recommended": True},
-        {"id": NEX_N2_MINI_MODEL_ID, "label": "nex-agi/nex-n2-mini", "recommended": True},
-        {"id": LING_3_0_FLASH_FREE_MODEL_ID, "label": "inclusionai/ling-3.0-flash:free", "recommended": True},
-        {"id": LLAMA_3_1_8B_MODEL_ID, "label": "Llama 3.1 8B"},
-        {"id": KIMI_K27_CODE_MODEL_ID, "label": "DeepSeek V4 Pro"},
-        {"id": MINIMAX_M3_MODEL_ID, "label": "DeepSeek V4 Flash"},
-        {"id": DEFAULT_MODEL_ID, "label": "DeepSeek V4 Flash"},
-        {"id": DEEPSEEK_V4_PRO_MODEL_ID, "label": "Nemotron 3 Super 120B"},
-        {"id": "deepseek/deepseek-v4-flash-0731", "label": "DeepSeek V4 Flash 0731", "recommended": True},
-    ]
-    return models'''
-
-func_match = re.search(
-    r"def _available_models\(\)\s*->\s*list\[dict\[str,\s*Any\]\]:.*?return models",
-    content, re.DOTALL
-)
-if func_match:
-    content = content[:func_match.start()] + new_func + content[func_match.end():]
-    print("OK: Replaced _available_models() with DeepSeek V4 Flash 0731")
-else:
-    old_func = (
-        "def _available_models() -> list[dict[str, Any]]:\n"
-        "    models = [\n"
-        '        {"id": CLAUDE_OPUS_48_MODEL_ID, "label": "Claude Opus 4.8"},\n'
-        '        {"id": DEFAULT_GPT_MODEL_ID, "label": "GPT-5.5"},\n'
-        '        {"id": KIMI_K27_CODE_MODEL_ID, "label": "Kimi K2.7 Code"},\n'
-        '        {"id": MINIMAX_M3_MODEL_ID, "label": "MiniMax M3"},\n'
-        '        {"id": DEFAULT_MODEL_ID, "label": "GLM 5.2", "recommended": True},\n'
-        '        {"id": DEEPSEEK_V4_PRO_MODEL_ID, "label": "DeepSeek V4 Pro"},\n'
-        "    ]\n"
-        "    return models"
-    )
-    if old_func in content:
-        content = content.replace(old_func, new_func)
-        print("OK: String replace of _available_models()")
-    else:
-        print("WARN: Could not find _available_models() pattern, searching...")
-        idx = content.find("def _available_models")
-        if idx >= 0:
-            print(f"Found at index {idx}, context: {content[idx:idx+400]}")
-
-content = content.replace(
-    '"openai/gpt-oss-120b:cerebras",',
-    '"huggingface/deepseek-ai/DeepSeek-V4-Pro",'
-)
-
-try:
-    ast.parse(content)
-    print("OK: agent.py syntax OK")
-except SyntaxError as e:
-    print(f"FAIL: agent.py syntax error: {e}")
-    raise
-
-with open(AGENT_FILE, "w") as f:
-    f.write(content)
-
-# Patch llm_params for OpenRouter routing
-with open(LLM_PARAMS_FILE) as f:
-    llm_content = f.read()
-
-if "normalized_model.startswith" not in llm_content:
-    api_key_find = "api_key = _resolve_hf_router_token(session_hf_token)"
-    if api_key_find in llm_content:
-        line_end = llm_content.find("\n", llm_content.find(api_key_find) + len(api_key_find)) + 1
-        routing_insert = (
-            '    # Route deepseek/ models to OpenRouter\n'
-            '    if normalized_model.startswith("deepseek/"):\n'
-            '        return {\n'
-            '            "model": normalized_model,\n'
-            '            "api_base": "https://openrouter.ai/api/v1",\n'
-            '            "api_key": os.environ.get("OPENROUTER_API_KEY") or api_key or "",\n'
-            '        }\n\n'
-            '    # Route openai/-prefixed models to OpenRouter\n'
-            '    if normalized_model.startswith("openai/"):\n'
-            '        return {\n'
-            '            "model": normalized_model,\n'
-            '            "api_base": "https://openrouter.ai/api/v1",\n'
-            '            "api_key": os.environ.get("OPENROUTER_API_KEY") or api_key or "",\n'
-            '        }\n\n'
-        )
-        llm_content = llm_content[:line_end] + routing_insert + llm_content[line_end:]
-        print("OK: Patched _resolve_llm_params with deepseek/ routing")
-    else:
-        print("WARN: Could not find api_key line")
-else:
-    print("OK: llm_params.py already patched")
-
-try:
-    ast.parse(llm_content)
-    print("OK: llm_params.py syntax OK")
-except SyntaxError as e:
-    print(f"FAIL: llm_params.py syntax error: {e}")
-    raise
-
-with open(LLM_PARAMS_FILE, "w") as f:
-    f.write(llm_content)
-
-print("OK: ALL BACKEND PATCHES APPLIED")

patch_sse_transport.py

@@ -1,32 +0,0 @@
-"""Patch sse-chat-transport.ts - handle task_incomplete event."""
-
-SSE_TRANSPORT = "/source/frontend/src/lib/sse-chat-transport.ts"
-
-def patch():
-    import os
-    if not os.path.exists(SSE_TRANSPORT):
-        print(f"SKIP: {SSE_TRANSPORT} not found")
-        return
-        
-    with open(SSE_TRANSPORT, "r", encoding="utf-8") as f:
-        content = f.read()
-    
-    # Add task_incomplete case in createEventToChunkStream
-    if "case 'task_incomplete'" not in content:
-        task_incomplete_case = '''      case 'task_incomplete':
-          sideChannel.onTaskIncomplete(
-            (event.data?.incomplete_plan as Array<{ id: string; content: string; status: string }>) || [],
-          );
-          break;
-'''
-        content = content.replace(
-            "case 'turn_complete':",
-            task_incomplete_case + "\n        case 'turn_complete':"
-        )
-    
-    with open(SSE_TRANSPORT, "w", encoding="utf-8") as f:
-        f.write(content)
-    print(f"OK: Patched {SSE_TRANSPORT}")
-
-if __name__ == "__main__":
-    patch()

patch_use_agent_chat_full.py

@@ -1,121 +0,0 @@
-"""Patch useAgentChat.ts - auto-continue feature."""
-
-USE_AGENT_CHAT = "/source/frontend/src/hooks/useAgentChat.ts"
-
-def patch():
-    import os
-    if not os.path.exists(USE_AGENT_CHAT):
-        print(f"SKIP: {USE_AGENT_CHAT} not found")
-        return
-        
-    with open(USE_AGENT_CHAT, "r", encoding="utf-8") as f:
-        content = f.read()
-    
-    # 1. Add useState to imports
-    if "useState" not in content:
-        content = content.replace(
-            "import { useCallback, useEffect, useMemo, useRef } from 'react';",
-            "import { useCallback, useEffect, useMemo, useRef, useState } from 'react';"
-        )
-    
-    # 2. Add state declarations after callbacksRef.current = { ... }
-    state_decl = '''
-  // Auto-continue state for free models when task incomplete
-  const autoContinueTimerRef = useRef<ReturnType<typeof setTimeout> | null>(null);
-  const [showAutoContinue, setShowAutoContinue] = useState(false);
-  const [taskIncompleteInfo, setTaskIncompleteInfo] = useState<{
-    incompletePlan: Array<{ id: string; content: string; status: string }>;
-  } | null>(null);
-'''
-    
-    if "autoContinueTimerRef" not in content:
-        content = content.replace(
-            "callbacksRef.current = { onReady, onError, onSessionDead };",
-            "callbacksRef.current = { onReady, onError, onSessionDead };" + state_decl
-        )
-    
-    # 3. Add onTaskIncomplete to SideChannelCallbacks interface
-    if "onTaskIncomplete:" not in content and "onInterrupted:" in content:
-        content = content.replace(
-            "  onInterrupted: () => void;",
-            "  onInterrupted: () => void;\n  onTaskIncomplete: (incompletePlan: Array<{ id: string; content: string; status: string }>) => void;"
-        )
-    
-    # 4. Add onTaskIncomplete handler in sideChannel
-    sidechannel_handler = '''      onTaskIncomplete: (incompletePlan) => {
-        setTaskIncompleteInfo({ incompletePlan });
-        setShowAutoContinue(true);
-        // Auto-start 10s timer for free models
-        if (autoContinueTimerRef.current) {
-          clearTimeout(autoContinueTimerRef.current);
-        }
-        autoContinueTimerRef.current = setTimeout(() => {
-          startAutoContinue();
-        }, 10000);
-      },'''
-    
-    if "onTaskIncomplete: (incompletePlan)" not in content:
-        content = content.replace(
-            "      onInterrupted: () => { /* no-op — handled by stop() caller */ },",
-            sidechannel_handler + "\n      onInterrupted: () => { /* no-op — handled by stop() caller */ },"
-        )
-    
-    # 5. Add auto-continue functions before return
-    auto_funcs = '''
-  // -- Auto-continue for free models when task incomplete -----------------
-  const startAutoContinue = useCallback(() => {
-    setShowAutoContinue(false);
-    setTaskIncompleteInfo(null);
-    if (autoContinueTimerRef.current) {
-      clearTimeout(autoContinueTimerRef.current);
-      autoContinueTimerRef.current = null;
-    }
-    // Build continuation message from incomplete plan
-    const incompleteItems = taskIncompleteInfo?.incompletePlan || [];
-    const continuationText = incompleteItems.length > 0
-      ? `Tiếp tục từ các task chưa hoàn thành:\\n${incompleteItems.map(i => `- ${i.content}`).join('\\n')}`
-      : 'Tiếp tục nhiệm vụ.';
-    chat.sendMessage({
-      text: `[TỰ ĐỘNG TIẾP TỤC] ${continuationText}`,
-      metadata: { createdAt: new Date().toISOString() },
-    });
-  }, [taskIncompleteInfo, chat]);
-
-  const cancelAutoContinue = useCallback(() => {
-    setShowAutoContinue(false);
-    setTaskIncompleteInfo(null);
-    if (autoContinueTimerRef.current) {
-      clearTimeout(autoContinueTimerRef.current);
-      autoContinueTimerRef.current = null;
-    }
-  }, []);
-
-  // Cleanup timer on unmount
-  useEffect(() => {
-    return () => {
-      if (autoContinueTimerRef.current) {
-        clearTimeout(autoContinueTimerRef.current);
-      }
-    };
-  }, []);
-'''
-    
-    if "startAutoContinue" not in content:
-        content = content.replace(
-            '\n  return {\n    messages: chat.messages,',
-            auto_funcs + '\n  return {\n    messages: chat.messages,'
-        )
-    
-    # 6. Update return to include new values
-    if "showAutoContinue," not in content:
-        content = content.replace(
-            "refreshMessages,\n  };",
-            "refreshMessages,\n    showAutoContinue,\n    taskIncompleteInfo,\n    startAutoContinue,\n    cancelAutoContinue,\n  };"
-        )
-    
-    with open(USE_AGENT_CHAT, "w", encoding="utf-8") as f:
-        f.write(content)
-    print(f"OK: Complete patch applied to {USE_AGENT_CHAT}")
-
-if __name__ == "__main__":
-    patch()