App Server 层的
turn_start_inner

你已经知道 submit_op 成功不等于任务完成。今天只补上中间这一站：App Server 收到 turn/start 后，怎样检查、整理并把工作交给 Core。

先把它放回你每天使用的动作里

submit_op 先回到 TUI 应用协调层，是因为 ChatWidget 只是一个子组件；TUI 应用层接住内部命令后，才调用 App Server。到了 turn_start_inner，我们才真正站在 App Server 层。

源码依据：ChatWidget 组装并提交命令 · TUI 调用 turn/start · 组装 TurnStartParams

四个动作，先看整个函数的鸟瞰图

鸟瞰图：先把 140 多行压缩成 9 行

// 1. 找到要继续的 Thread
let (thread_id, thread) = self.load_thread(&params.thread_id).await?;

// 2. 检查输入，并整理本次设置
validate_input(...)?;

// 3. 把 App Server 输入转换成 Core 输入，再交给 Core
let mapped_items = params.input.map(UserInput::into_core);
let submission = thread.start_or_steer_turn(...).await?;

// 4. 返回“已受理、进行中”
Ok(TurnStartResponse { turn: Turn { status: InProgress, ... } })

这不是原代码逐字复制，只用于先建立地图。下面开始读真实代码；职责压缩图不能代替源码精读。

源码依据：turn_start_inner 完整实现 · 请求与响应类型 · 官方生命周期说明

真实代码精读 ①：先拆函数签名

async fn turn_start_inner(
    &self,
    request_id: ConnectionRequestId,
    params: TurnStartParams,
    app_server_client_name: Option<String>,
    app_server_client_version: Option<String>,
) -> Result<TurnStartResponse, JSONRPCErrorError> {

params 到底是什么？

只有 thread_id 和 input 是非 Option 字段。源码用 snake_case 写 thread_id，JSON 因 serde(rename_all = "camelCase") 使用 threadId。

{
  "threadId": "019...",
  "input": [
    { "type": "text", "text": "解释这张图", "textElements": [] },
    { "type": "localImage", "path": "C:\\Temp\\diagram.png" }
  ],
  "cwd": "C:\\Users\\admin\\project",
  "model": "gpt-5.6-sol"
}

源码依据：TurnStartParams · UserInput 类型

真实代码精读 ②：逐词拆 load_thread 这一句

let (thread_id, thread) =
    self.load_thread(&params.thread_id)
        .await
        .inspect_err(|error| {
            self.track_error_response(&request_id, error, None);
        })?;

load_thread 内部实际做了什么？

async fn load_thread(
    &self,
    thread_id: &str,
) -> Result<(ThreadId, Arc<CodexThread>), JSONRPCErrorError> {
    let thread_id = ThreadId::from_string(thread_id)
        .map_err(|err| invalid_request(format!("invalid thread id: {err}")))?;

    let thread = self.thread_manager
        .get_thread(thread_id)
        .await
        .map_err(|_| invalid_request(format!("thread not found: {thread_id}")))?;

    Ok((thread_id, thread))
}

1. ThreadId::from_string：把普通字符串校验并转换成专门的 ThreadId 类型；格式不合法就返回 invalid thread id。
2. thread_manager.get_thread：拿强类型 ID 去当前内存中的 Thread 表查找；找不到就返回 thread not found。
3. Arc<CodexThread>：返回可在异步代码间安全共享所有权的 Thread 句柄。Arc 是原子引用计数智能指针。
4. Ok((thread_id, thread))：成功时同时返回强类型 ID 和 Thread 句柄，供后续检查、配置和提交 Turn 使用。

源码依据：load_thread · ThreadManager::get_thread

面向最终目标：GEODYNA 对应哪一层？

只读源码已经显示，GEODYNA 现有 useSmartCommandApplication.ts 会准备上下文、生成预览、校验计划、编译命令并提供执行/撤销入口；domain/project/scriptApi.ts 会通过 runWorkflow 执行正式的原子命令事务。这些是未来 Harness 可以复用的基础，但它们还不等于完整智能体。

GEODYNA 只读依据：D:\GEODAMNEW\features\smartCommand\useSmartCommandApplication.ts:277 · D:\GEODAMNEW\domain\project\scriptApi.ts:221。本课没有修改 GEODYNA。

产品经理应该从这一站带走什么？

今天明确不学

不展开环境覆盖、Memory 启动、Realtime transcript、Responses API metadata、Start/Steer 的具体判断，也不学习 Rust 的 await、map_err 和所有权。它们分别属于后续数据轮、状态轮和运行机制轮。

即时小测

最后用一句话交作业

你已经通过本课，可以进入第一轮第 3 站：start_or_steer_turn 源码精读。