新增 DirectProject 原始 Responses item 历史格式与异常收尾规则

明确 thread/inject_items 恢复流程及半成品处理边界

不涉及旧格式迁移、DirectHome 或审计账本

@@ -2115,3 +2122,3 @@
         request: LlmRunRequest,
         direct_history_root: Option<&std::path::Path>,
-        direct_client_turn_id: Option<&str>,
+        _direct_client_turn_id: Option<&str>,

@@ -0,0 +124,4 @@
+        .get("payload")
+        .cloned()
+        .ok_or_else(|| format!("DirectProject 历史记录缺少 payload：{}", path.display()))?;
+    if is_direct_project_internal_context_item(&item) {

@@ -0,0 +146,4 @@
+    let _append_guard = lock.lock("DirectProject 历史追加写")?;
+    if history_exists {
+        if let Some(item_id) = item.get("id").and_then(Value::as_str) {
+            if let Some(existing) = find_direct_project_history_item_by_id_at(&path, item_id)? {

@@ -2575,1 +2606,3 @@
-                message.content = history_prompt;
+        if self.inner.workspace_mode == CodexAppServerWorkspaceMode::DirectProject {
+            if thread_created {
+                let items = match read_direct_project_history_items_at(history_root) {

@@ -2575,1 +2606,3 @@
-                message.content = history_prompt;
+        if self.inner.workspace_mode == CodexAppServerWorkspaceMode::DirectProject {
+            if thread_created {
+                let items = match read_direct_project_history_items_at(history_root) {

@@ -0,0 +126,4 @@
+        let mut line_end = combined.len();
+        while let Some(newline) = combined[..line_end].iter().rposition(|byte| *byte == b'\n') {
+            let line = &combined[newline + 1..line_end];
+            if !line.is_empty() {

@@ -5462,0 +5432,4 @@
+          projectConversationWriteConfirmedRef.current !== directProjectPath
+        ) {
+          try {
+            const policyPaused = await queueProjectPolicyConfirmationIfNeeded(