worker-logplace
5fd5cd47dc
用户投诉原话：「我们的启动日志放在哪？…他找半天没找到崩溃日志」「只有一个安装日志」。 启动器运行日志（.ULL/logs/launcher.log） - presenter 构造 HostEnv 时就登记日志目录：启动早期缓冲的 200 行（[probe]/[font]/[theme]） 当场刷盘，不再是「只有开过一局游戏才有日志」。 - app/** 里所有 eprintln! 诊断改走 app::diag::diag!（stderr + 文件双写，行首 [tag] 即 scope）， 含 boot/boot::fallback/state/update 各线。 - boot 那一拍补一行后端事实（request/effective/fallback）。 - 滚动上限（1 MiB → launcher.1.log，只留一份）写进 README 与 docs/logs-location.md。 会话日志搬家：data/agent/sessions → logs - LauncherLayout: sessions_root()/game_logs() 新增，agent_sessions() 降级为只读兼容。 - host/logs 与 cli/commands/sessions 两个根合并（同 id 新根优先），event_path 回落旧家。 - 不搬不删；日志目录写一份 session-log-location.json 记录（moved=0, policy=read-only-compat）。 入口与文案 - 设置页「通用」新增「日志文件夹」行：路径 + 打开目录 + 复制路径（i18n 中英）。 - 日志页页头的「打开目录」不再是占位：走 M187 的 open_dir，失败文本带路径并送进剪贴板。 - README.md / README.zh-CN.md 新增「日志在哪」章节（含 crash-reports 只在游戏走到那一步才有）， docs/logs-location.md 给出上限、双写判据、迁移策略与没验的部分。 守门（每条都有变异证明，见报告） - 旧家会话仍列得出/打不开 ⇒ 只读新根变红；新会话写 logs/game ⇒ 只读旧根、写回旧家都变红。 - launcher.log 滚动 ⇒ 干掉 rename 变红。 - 打开日志文件夹指向真实目录 ⇒ 换成 cache/ 或去掉 create_dir_all 都变红。 - 日志根随三模式变化 ⇒ 把 HostEnv::logs_dir 写死成便携落点变红。
383 lines
19 KiB
Rust
383 lines
19 KiB
Rust
//! 助手栏消息的落点（M104 建，M119 接线）：三档状态迁移 / 输入 / 键盘 / **presenter 四契约**。
|
||
//!
|
||
//! ## 为什么单独一个文件
|
||
//!
|
||
//! `app/update.rs` 已经贴着 400 行硬上限（M94 也因此把下载页四支拆到 `update/download.rs`）。
|
||
//! 助手栏有十几个变体，塞回主文件必破线。
|
||
//!
|
||
//! ## 分工：视图态 vs presenter 契约（M119 之后的分界线）
|
||
//!
|
||
//! | 消息 | 落到哪 |
|
||
//! |---|---|
|
||
//! | `Expand` / `Collapse` / `Dock` / `Escape` | **只改视图态**（`AgentUi`）+ 路由栈（离开/进入 `Route::Agent`）+ `agent_mark_read` |
|
||
//! | `Detach` | 视图态 + `Route::Agent`（压栈，`back()` 能回去）+ `agent_mark_read` |
|
||
//! | `Edit` | 视图态（草稿），并同步进 presenter 的草稿（`agent_set_draft`） |
|
||
//! | `Submit` | [`AgentHost::submit`] → `agent_submit`；失败**不留白**（具名错误进横幅） |
|
||
//! | `Stop` | `AppCommand::StopAgent`（真后端才收敛得出结果；同步 rig 下是 no-op） |
|
||
//! | `Confirm(accept)` | [`AgentHost::confirm`] → `agent_confirm`（YOLO 下 presenter 自己放行并记审计） |
|
||
//! | `Events(..)` | [`AgentHost::apply`] → `AppState::apply`（**事件回流的唯一落点**） |
|
||
//! | `DragStart` / `DragTo` / `DragEnd` | 视图态：吸附宽度 |
|
||
//! | `Key` / `Tab` / `Activate` | 键盘路径（`Tab` 的环要在流式中多一格，`busy` 从 rail 取） |
|
||
//!
|
||
//! **会话内容一行都不在这里攒**：`transcript` / `busy` / `unread` / `confirm` 全在 presenter 的
|
||
//! `AgentRail` 上（M119 删掉了 M104 的自持副本）。
|
||
//!
|
||
//! ## 事件为什么绕一圈消息再回来
|
||
//!
|
||
//! `agent_submit` / `agent_confirm` 的端口是同步的，但**事件走队列**（见
|
||
//! `app/state/presenter/transport.rs`）：抽队列的那一步必须和用户点击走同一条漏斗，否则两处各改
|
||
//! 一次状态，流式标记与未读会打架。所以 [`App::drain_agent`] 抽出来之后立刻
|
||
//! `on_agent(agent::Message::Events(..))` —— 同一条 `Message::Agent(..)` 通道。
|
||
|
||
use crate::app::diag::diag;
|
||
use iced::keyboard::{key, Key};
|
||
use iced::Task;
|
||
|
||
use unlucky_i18n::{Catalog, Key as TextKey};
|
||
use unlucky_presenter::dto::AppCommand;
|
||
|
||
use crate::app::MIN_SIZE;
|
||
use crate::app::WINDOW_SIZE;
|
||
use crate::shell::agent::demo::{self, Fixture};
|
||
use crate::shell::agent::{self, Focus, RailState};
|
||
|
||
use super::super::state::presenter::agent::SubmitOutcome;
|
||
use super::*;
|
||
|
||
#[cfg(test)]
|
||
mod tests;
|
||
|
||
impl App {
|
||
/// 助手栏消息（`app::Message::Agent(..)` 的唯一落点）。
|
||
pub(super) fn on_agent(&mut self, message: agent::Message) -> Task<Message> {
|
||
// M106 口径：文案走**生效语言**的目录，不再恒英文
|
||
let catalog = Catalog::of(self.lang());
|
||
|
||
// 只有**几何**会变的几支才需要重建页面模型（`pages::Model` 里没有会话内容：会话在
|
||
// presenter 的 rail 上，右栗自己那棵树每次 `view()` 都从 rail 现读）。复审 P3-9 的教训：
|
||
// 每敲一个字符都重建整张模型是白克隆。
|
||
let geometry_changed = matches!(
|
||
message,
|
||
agent::Message::Expand
|
||
| agent::Message::Collapse
|
||
| agent::Message::Detach
|
||
| agent::Message::Dock
|
||
| agent::Message::DragTo(_)
|
||
| agent::Message::DragEnd
|
||
| agent::Message::Escape
|
||
| agent::Message::Activate
|
||
| agent::Message::Key(_)
|
||
);
|
||
|
||
match message {
|
||
agent::Message::Expand => {
|
||
self.agent.expand();
|
||
// 「展开即读」是 presenter 的语义（`agent_mark_read`），壳只负责在正确的时刻调它
|
||
self.agent_host.mark_read();
|
||
}
|
||
agent::Message::Collapse | agent::Message::Escape => self.collapse_agent(),
|
||
agent::Message::Detach => {
|
||
self.agent.detach();
|
||
self.agent_host.mark_read();
|
||
self.state.navigate(Route::Agent);
|
||
}
|
||
agent::Message::Dock => {
|
||
self.agent.dock();
|
||
self.agent_host.mark_read();
|
||
self.leave_agent_page();
|
||
}
|
||
agent::Message::DragStart => self.agent.drag_start(),
|
||
agent::Message::DragTo(x) => self.agent.drag_to(self.width, x),
|
||
agent::Message::DragEnd => self.agent.drag_end(),
|
||
agent::Message::Edit(action) => {
|
||
self.agent.edit(action);
|
||
// 草稿同步给 presenter（切形态不丢；它也是 rail 上唯一允许躺原文的字段）
|
||
self.agent_host.set_draft(self.agent.draft.text());
|
||
}
|
||
agent::Message::Submit => self.submit_agent(),
|
||
agent::Message::Stop => self.dispatch(AppCommand::StopAgent),
|
||
agent::Message::Confirm(accept) => {
|
||
self.agent_host.confirm(accept);
|
||
self.drain_agent();
|
||
}
|
||
agent::Message::Events(events) => {
|
||
for event in events {
|
||
self.agent_host.apply(event);
|
||
}
|
||
self.view_dirty = true;
|
||
}
|
||
agent::Message::Tab { shift } => {
|
||
let rail = self.agent_host.rail();
|
||
let (busy, pending) = (rail.busy, rail.confirm.is_some());
|
||
self.agent.step_focus(shift, busy, pending);
|
||
}
|
||
agent::Message::Activate => self.activate_focused(catalog),
|
||
agent::Message::Key(event) => return self.on_agent_key(event),
|
||
}
|
||
|
||
// 待确认请求出现/消失时，把键盘焦点挪到（或挪离）确认条的按钮上
|
||
self.sync_confirm_focus();
|
||
// 档位 / 路由变了就要把「栏可见吗」写回 presenter（未读口径的输入）
|
||
self.sync_agent_presenter();
|
||
if geometry_changed {
|
||
self.view_dirty = true;
|
||
self.refresh_view();
|
||
}
|
||
Task::none()
|
||
}
|
||
|
||
/// 发送：草稿 → `agent_submit` → 抽事件。
|
||
///
|
||
/// 三种结局各自有落点：发出去（清草稿）/ 后端失败（具名横幅，见 [`App::agent_failure`]）/
|
||
/// presenter 拒收（日志一行——这三种情形正常情况下被禁用态挡住，够不着）。
|
||
fn submit_agent(&mut self) {
|
||
let text = self.agent.draft.text();
|
||
if text.trim().is_empty() {
|
||
return;
|
||
}
|
||
match self.agent_host.submit(text) {
|
||
SubmitOutcome::Sent => {
|
||
self.agent.clear_draft();
|
||
self.agent_host.set_draft(String::new());
|
||
self.drain_agent();
|
||
}
|
||
SubmitOutcome::Failed(failure) => {
|
||
diag!("[agent] 提交失败（{}）", failure.code());
|
||
}
|
||
SubmitOutcome::Rejected => {
|
||
diag!("[agent] presenter 拒收：空文本 / 上一轮未完 / 待确认 三闸该先挡住");
|
||
}
|
||
}
|
||
}
|
||
|
||
/// 抽干 presenter 的事件队列，**经既有 Message 通道**回流（见模块文档末节）。
|
||
pub(crate) fn drain_agent(&mut self) {
|
||
let events = self.agent_host.drain();
|
||
if events.is_empty() {
|
||
return;
|
||
}
|
||
let _ = self.on_agent(agent::Message::Events(events));
|
||
}
|
||
|
||
/// 把「栏可见吗」写回 presenter（`navigate` + `prefs_mut` 两个窄入口，见 `AgentHost`）。
|
||
pub(crate) fn sync_agent_presenter(&mut self) {
|
||
let on_page = self.state.route() == &Route::Agent;
|
||
let collapsed = self.agent.rail == RailState::Collapsed;
|
||
self.agent_host.sync_visibility(on_page, collapsed);
|
||
}
|
||
|
||
/// 失败横幅要显示的东西（`None` = 没有错误）。
|
||
///
|
||
/// 两个来源都取**展示输入**：具名原因码 → catalog 译文；或 presenter 已脱敏的这一轮原因。
|
||
/// 壳在这一层不做任何脱敏（那是 presenter 的`scrub_text`），也不拼中英（那是 catalog 的事）。
|
||
pub(crate) fn agent_failure(&self) -> Option<agent::Failure<'_>> {
|
||
let catalog = self.lang().catalog();
|
||
if let Some(failure) = self.agent_host.last_failure() {
|
||
return Some(agent::Failure {
|
||
title: TextKey::AgentErrorTitle,
|
||
body: catalog.text(failure.body_key()),
|
||
});
|
||
}
|
||
self.agent_host
|
||
.rail()
|
||
.error
|
||
.as_deref()
|
||
.map(|body| agent::Failure {
|
||
title: TextKey::AgentErrorTitle,
|
||
body,
|
||
})
|
||
}
|
||
|
||
/// 待确认请求出现 ⇒ 焦点直接落在「允许」；消失 ⇒ 收回输入框。
|
||
///
|
||
/// **只挪焦点，不替用户打开键盘巡航**（M119 r2 / 复审 P2-2）：r1 在这里顺手把
|
||
/// `keyboard_mode` 置真，而 `sync_confirm_focus` 是 `on_agent` 的无条件尾巴、`Events` 又由心跳
|
||
/// 驱动——于是只要冒出待确认，全局键盘闸就被打开；用户发完那句话接着打下一句，第一个空格
|
||
/// 就成了「批准写操作」。现在那道闸只由真实的键盘表态打开（`Tab`，见 `AgentUi::step_focus`；
|
||
/// 或者 `on_agent_key` 把按键送进来时用户本来就在键盘巡航）。
|
||
///
|
||
/// 键盘用户怎么走到确认条：待确认时焦点已经在这两个按钮上，**按一次 `Tab` 点亮焦点环即是
|
||
/// 表态**（`step_focus` 里那条 arming 规则：这一次不移动焦点），之后 `Enter`/`Space` 就能裁决。
|
||
///
|
||
/// 唯一写入口：`on_agent` 末尾（任何会改动 rail 的分支之后都要经过它）。
|
||
fn sync_confirm_focus(&mut self) {
|
||
let pending = self.agent_host.rail().confirm.is_some();
|
||
let on_confirm = matches!(self.agent.focus, Focus::ConfirmAllow | Focus::ConfirmDeny);
|
||
if pending && !on_confirm {
|
||
self.agent.focus = Focus::ConfirmAllow;
|
||
diag!("[agent] 写操作待确认 → 焦点落到 Allow（Tab 点亮焦点环后 Enter/Space 裁决）");
|
||
} else if !pending && on_confirm {
|
||
self.agent.focus = Focus::Composer;
|
||
self.agent.keyboard_mode = false;
|
||
}
|
||
}
|
||
|
||
/// **不变式**：`route() == Route::Agent` ⟺ `agent.rail == RailState::Detached`（唯一同步点）。
|
||
///
|
||
/// 为什么需要它（复审 r1 的 P2-1，实测复现）：`agent.rail` 只在自己发 `Detach`/`Dock` 时变，
|
||
/// 而路由还能从三条**别的**路径进 `Route::Agent`——左侧导航第五项、`pages::Message::Navigate`、
|
||
/// `ULL_START_ROUTE=agent`。脱钩的后果：从导航进独立页时头部出现「Open assistant」（那是
|
||
/// 「展开右栗」的意思）、标题旁挂着不化的未读胶囊、`Esc` 也收不走页面。
|
||
///
|
||
/// 两条对向规则：
|
||
/// - **在**独立页上 ⇒ `Detached`（顺带按「拆出即读」清未读）；
|
||
/// - **不在**独立页上而档位还是 `Detached`（用户从页上点了别的导航）⇒ 会话收回右栗（`dock()`），
|
||
/// 否则会话会「两头都没有」：页走了、栏还是 0 宽。
|
||
///
|
||
/// 调用点只有一个：`App::refresh_view` 的开头。每一次路由变化都会经过它，于是**模型算宽度时**
|
||
/// 与**画头部动作时**读到的永远是同一份档位。
|
||
pub(crate) fn sync_agent_route(&mut self) {
|
||
let on_page = self.state.route() == &Route::Agent;
|
||
match (on_page, self.agent.rail) {
|
||
(true, RailState::Detached) | (false, RailState::Collapsed | RailState::Expanded) => {}
|
||
(true, _) => self.agent.detach(),
|
||
(false, RailState::Detached) => self.agent.dock(),
|
||
}
|
||
}
|
||
|
||
/// 启动时助手栏要做的三件事（从 `on_boot` 搬出来：那边只许留一行调用，复审 P3-6）。
|
||
///
|
||
/// 1. **窗口尺寸 adopt**：唯一真源是 `boot.rs` 开窗时用的那一个（`ULL_WINDOW_SIZE` + 最小尺寸
|
||
/// 钳位）。`App::with_presenter` 只认识常量 1180×760，不 adopt 的话验收矩阵开 900 / 1520 的窗
|
||
/// 时页面还按 1180 排版（窄窗里内容被裁）。
|
||
/// 2. **取证夹具**（`ULL_AGENT_*`）：先落档位，再**跑一轮真提交**——夹具不造消息，消息只能
|
||
/// 由 presenter 产生（M119 的口径，见 `pages/agent/demo.rs`）。
|
||
/// 3. **拆出档直接落到独立页**：`ULL_AGENT_RAIL=detached`（以及将来持久化的偏好）时，会话就在
|
||
/// 独立页里，启动后不该停在实例页。
|
||
pub(super) fn boot_agent(&mut self) {
|
||
let (window_size, _source) = crate::renderer::acceptance::window::window_size(
|
||
(WINDOW_SIZE.width, WINDOW_SIZE.height),
|
||
(MIN_SIZE.width, MIN_SIZE.height),
|
||
);
|
||
self.width = window_size.0;
|
||
self.height = window_size.1;
|
||
|
||
if let Some((ui, fixture)) = demo::from_env() {
|
||
self.agent = ui;
|
||
// 先让 presenter 知道「栏现在看得见吗」，再跑提交，未读口径才对
|
||
self.sync_agent_presenter();
|
||
match fixture {
|
||
Fixture::None => {}
|
||
Fixture::Turn | Fixture::Unread => {
|
||
let _ = self.agent_host.submit(demo::DEMO_QUESTION.to_string());
|
||
self.drain_agent();
|
||
}
|
||
Fixture::Armed => {
|
||
// 先跑一轮（写操作脚本会挂一个待确认），再按一次 `Tab`：
|
||
// 待确认时这一下只 arm、不移动焦点（见 `AgentUi::step_focus` 的 arming 规则）
|
||
let _ = self.agent_host.submit(demo::DEMO_QUESTION.to_string());
|
||
self.drain_agent();
|
||
let rail = self.agent_host.rail();
|
||
let (busy, pending) = (rail.busy, rail.confirm.is_some());
|
||
self.agent.step_focus(false, busy, pending);
|
||
}
|
||
Fixture::Focused => {
|
||
let rail = self.agent_host.rail();
|
||
let (busy, pending) = (rail.busy, rail.confirm.is_some());
|
||
self.agent.step_focus(false, busy, pending);
|
||
}
|
||
}
|
||
}
|
||
|
||
if self.agent.rail == RailState::Detached && self.state.route() != &Route::Agent {
|
||
diag!("[agent] rail=detached → Route::Agent");
|
||
self.state.navigate(Route::Agent);
|
||
// 直达独立页时不要再被「自动选中第一条实例」拉回详情页。
|
||
self.auto_selected = true;
|
||
}
|
||
}
|
||
|
||
/// 键盘订阅来的按键（`app/subscription.rs` 把整条键盘事件搬过来，解释权在这一层）。
|
||
///
|
||
/// 为什么不让订阅层直接翻成三个枚举：那样 `Escape`/`Tab`/`Enter` 的语义（什么状态下该做什么）
|
||
/// 会散在订阅表里；这里一眼能看完。
|
||
fn on_agent_key(&mut self, event: iced::keyboard::Event) -> Task<Message> {
|
||
let iced::keyboard::Event::KeyPressed { key, modifiers, .. } = event else {
|
||
return Task::none();
|
||
};
|
||
|
||
let message = match key {
|
||
Key::Named(key::Named::Escape) => agent::Message::Escape,
|
||
// 折叠档没有会话动作可巡航，`Tab` 不该被助手栏吃掉
|
||
Key::Named(key::Named::Tab) if self.agent.rail == RailState::Collapsed => {
|
||
return Task::none();
|
||
}
|
||
Key::Named(key::Named::Tab) => agent::Message::Tab {
|
||
shift: modifiers.shift(),
|
||
},
|
||
// `Activate` 只在软焦点落在**按钮**上时才动手（输入框的 Enter 由
|
||
// `text_editor::key_binding` 分流成「发送」，不能在这里重复发一次）。
|
||
//
|
||
// M119 r1 / P2-2：`Space` 与 `Enter` 等价（键盘用户对确认条的习惯动作是空格）。
|
||
// 它不会抢输入框里的空格：`activate_focused` 头一行就是 `keyboard_mode` 闸，
|
||
// 而用鼠标点进输入框时那道闸是关的（`AgentUi::edit` 的 `Click` 分支）。
|
||
Key::Named(key::Named::Enter | key::Named::Space) => agent::Message::Activate,
|
||
_ => return Task::none(),
|
||
};
|
||
|
||
self.on_agent(message)
|
||
}
|
||
|
||
/// `Esc` / `⌄`：展开 → 收起；独立页 → 收回右栗并离开 `Route::Agent`。
|
||
fn collapse_agent(&mut self) {
|
||
let was_detached = self.agent.rail == RailState::Detached;
|
||
self.agent.collapse();
|
||
if was_detached {
|
||
self.leave_agent_page();
|
||
}
|
||
}
|
||
|
||
/// 离开 AI 独立页：能回退就回退（`Detach` 是压栈的），否则回实例页。
|
||
fn leave_agent_page(&mut self) {
|
||
if self.state.route() != &Route::Agent {
|
||
return;
|
||
}
|
||
if !self.state.back() {
|
||
self.state.navigate(Route::Instances);
|
||
}
|
||
}
|
||
|
||
/// 键盘 `Enter`：激活软焦点上的按钮（`Tab` 环的顺序见 [`Focus`]）。
|
||
///
|
||
/// 焦点在 [`Focus::Composer`] 上时**什么都不做**：那一条路径由输入框自己的 `key_binding`
|
||
/// 负责（按 `Tab` 走到输入框并不等于真的把 iced 焦点交过去，两次发送会打架）。
|
||
fn activate_focused(&mut self, catalog: Catalog) {
|
||
// 鼠标刚点过输入框（或从没按过 `Tab`）⇒ 这个 Enter 不归助手栏管
|
||
if !self.agent.keyboard_mode {
|
||
return;
|
||
}
|
||
|
||
let intent = match (self.agent.rail, self.agent.focus) {
|
||
(RailState::Collapsed, Focus::Collapse) => Some(agent::Message::Expand),
|
||
(RailState::Expanded, Focus::Collapse) => Some(agent::Message::Collapse),
|
||
(RailState::Expanded, Focus::Detach) | (RailState::Detached, Focus::Detach) => {
|
||
Some(if self.agent.rail == RailState::Detached {
|
||
agent::Message::Dock
|
||
} else {
|
||
agent::Message::Detach
|
||
})
|
||
}
|
||
(_, Focus::ConfirmAllow) => Some(agent::Message::Confirm(true)),
|
||
(_, Focus::ConfirmDeny) => Some(agent::Message::Confirm(false)),
|
||
(_, Focus::Send) => Some(agent::Message::Submit),
|
||
(_, Focus::Stop) => Some(agent::Message::Stop),
|
||
// 折叠档没有「拆出」、独立页没有「收起」：焦点环按 `Focus::order` 不会落到这两格，
|
||
// 显式列成 None 只是为了让编译器确认这份 intent 表是穷尽的。
|
||
(RailState::Collapsed, Focus::Detach)
|
||
| (RailState::Detached, Focus::Collapse)
|
||
| (_, Focus::Composer) => None,
|
||
};
|
||
|
||
if let Some(message) = intent {
|
||
let _ = self.on_agent(message);
|
||
} else {
|
||
// 「不得静默无反应」：焦点在输入框上按 Enter 由输入框自己处理，这里只留一行日志。
|
||
diag!(
|
||
"[agent] Enter on focus={} handled by the composer",
|
||
self.agent.focus.name()
|
||
);
|
||
let _ = catalog;
|
||
}
|
||
}
|
||
}
|