fix(app-iced): M90 r2 —— 找回窗口装饰 + 按需节拍 + 数据根一致 + 假绿守卫
复审 P1-1（产品页丢窗口装饰）：shell 加内容槽位 view_with_content(ui, nav, title, content, forced)，
app/view.rs 把 pages::page(...) 塞进真外壳；shell::view 保留给 Route::Agent 回落（删了会让私有
view/nav::rail 变死代码，-D warnings 红）。content() 拆到 shell/fallback.rs 让 mod.rs 回到 365 行。
1180 浅/深新图右上角三个 caption 键实测：ink 中心 y=23.5（栏高 48 的一半）、x 中心 1064.5/1110.5/
1156.5 = 46px 分档的 1065/1111/1157（±0.5px），close 命中区右缘 = 1180 窗角。
偏离 #7 改写成「交互面缺失」并注明本轮已修。
P1-2（harness.rs 402 行）：tests 外置到 pages/harness/tests.rs（343 + 64 行）；
components/gate.rs 的行数守门从走查 components/ 扩到 src/**（新测试当场抓出 app/tests.rs 416 行，
已按同样办法拆成 app/tests.rs + app/tests/presenter.rs）。
P2-1（常驻重绘 + 每拍重建模型）：subscription 只在「截图 / 有 Busy-Running / 有 toast / 3 s 派发
观察窗」时订阅 window::frames()；refresh_view 加 view_dirty 门。实测交互模式 9 s：只有 2 行 tick
trace（n=30/60，观察窗内），之后 6.5 s 一条都没有；refreshes 全程停在 7。
P2-2（两个数据根）：--data-dir 时 SettingsBridge::with_path(config_path(root))，与后端同根。
P3-2（假绿）：新增 RecorderBackend（dispatch 只记账、drain_events 恒空）+ launching_only_dispatches
_and_never_echoes_locally；植入本地回显后该测试实测转红（status 变 Downloading · 0%、can_stop 翻
true），撤回后转绿。
P3-3：尺寸字面量守门目录加 app；P3-1：--force-state 经 pages::Model::forced 作用到产品页控件
（hover 图里页头/列表/动作行/rail/caption 全部可见状态层）；视觉 P2-2：加载器名统一走 badge()。
gallery 回归改口径：r2 与「主线 + r1」的 gallery 逐字节相同（cmp IDENTICAL）；与 r1 记的
c825e1a 基线不同，差异来自主线 M86/M88 的令牌收口，不是本 mission。
This commit is contained in:
AskaEth committed
1 parent
b484998fc9
commit
022778a5a7
17 files changed
+980
-496
No files matched your search
@@ -69,3 +69,16 @@ pub(super) fn route_of(nav: NavItem) -> Route {
|
||||
NavItem::Ai => Route::Agent,
|
||||
}
|
||||
}
|
||||
|
||||
/// 路由 → 外壳导航项（[`route_of`] 的逆；外壳 rail 与 caption 键都按它高亮）。
|
||||
///
|
||||
/// `Route::Detail(_)` 高亮「实例」（与 `Route::nav()` 同源）。
|
||||
pub(super) fn nav_item_of(route: &Route) -> NavItem {
|
||||
match route {
|
||||
Route::Instances | Route::Detail(_) => NavItem::Instances,
|
||||
Route::Download => NavItem::Download,
|
||||
Route::Logs => NavItem::Logs,
|
||||
Route::Settings => NavItem::Settings,
|
||||
Route::Agent => NavItem::Ai,
|
||||
}
|
||||
}
|
||||
@@ -19,7 +19,7 @@ use std::time::Instant;
|
||||
use iced::window;
|
||||
|
||||
use unlucky_design::color::SchemeFlavor;
|
||||
use unlucky_presenter::backend::{build_backend, AppOptions};
|
||||
use unlucky_presenter::backend::{build_backend, config_path, AppOptions};
|
||||
use unlucky_presenter::dto::Backend;
|
||||
use unlucky_presenter::prefs::ThemeMode;
|
||||
use unlucky_presenter::settings_bridge::SettingsBridge;
|
||||
@@ -37,6 +37,11 @@ use super::WINDOW_SIZE;
|
||||
/// `theme::config_poll_due` 的计数都按这个节拍走，两个 UI 版的时间语义因此一致。
|
||||
pub(super) const TICK: std::time::Duration = std::time::Duration::from_millis(33);
|
||||
|
||||
/// 派发指令后保持帧订阅的观察窗（见 [`App::watch_until`]）。
|
||||
///
|
||||
/// 3 秒够真 host 把「命令已受理」的第一条事件交回来；之后由「有 Busy/Running 实例」这个条件续订。
|
||||
pub(super) const WATCH_WINDOW: std::time::Duration = std::time::Duration::from_secs(3);
|
||||
|
||||
/// 进程内「run() 开始」的时刻（首帧耗时基线）。
|
||||
pub(super) static STARTED: OnceLock<Instant> = OnceLock::new();
|
||||
/// 首帧日志只打一次。
|
||||
@@ -64,10 +69,20 @@ pub struct App {
|
||||
pub(super) width: f32,
|
||||
/// 展示转换缓存（presenter 快照 → 页面视图模型）。
|
||||
pub(super) view: pages::Model,
|
||||
/// 视图模型是否过期（P2-1）：只有 `apply` / `navigate` / resize / 主题这类**真的改了状态**
|
||||
/// 的事情才置位，`advance()` 每拍只在置位时重建模型（否则 30 Hz × N 实例的白克隆）。
|
||||
pub(super) view_dirty: bool,
|
||||
/// 「刚派发过指令，等后端回事件」的观察窗（P2-1）。
|
||||
///
|
||||
/// 空闲态不订阅帧事件（不点亮窗口重绘），但派发之后必须有一段短窗口保持节拍，
|
||||
/// 否则真 host 的异步事件永远抽不出来（`LaunchInstance` 之后状态还是 Idle ⇒ 帧订阅永不开启）。
|
||||
pub(super) watch_until: Option<Instant>,
|
||||
/// 窗口句柄（`window::latest()` 之后才有）。
|
||||
pub(super) window: Option<window::Id>,
|
||||
/// 已画的帧数（截图闸门用）。
|
||||
pub(super) frames: u32,
|
||||
/// 视图模型重建次数（P2-1 的可观测计数：空闲态 100 拍里必须是 0 增长）。
|
||||
pub(super) refreshes: u64,
|
||||
/// 首屏快照到位后是否已经自动选中过第一行（list-detail 的桌面惯例，见 `update::auto_select`）。
|
||||
pub(super) auto_selected: bool,
|
||||
}
|
||||
@@ -80,7 +95,14 @@ impl App {
|
||||
/// [`build_backend`] 自己退回 mock）。
|
||||
pub(super) fn new(options: Options, families: Families, flavor: SchemeFlavor) -> Self {
|
||||
let backend = build_backend(&app_options(&options));
|
||||
let bridge = SettingsBridge::open();
|
||||
// P2-2：设置桥必须与后端指向**同一个数据根**。早先这里无条件 `SettingsBridge::open()`
|
||||
// （按便携配置解析），于是 `--data-dir X` 会出现「实例来自 X、主题/设置读写默认根」的一进程
|
||||
// 两个数据根。Slint 版是同一条口径：`app/src/ui_bind.rs` 的
|
||||
// `Some(root) => SettingsBridge::with_path(config_path(root))`。
|
||||
let bridge = match &options.data_dir {
|
||||
Some(root) => SettingsBridge::with_path(config_path(root)),
|
||||
None => SettingsBridge::open(),
|
||||
};
|
||||
Self::with_presenter(options, families, flavor, backend, bridge)
|
||||
}
|
||||
|
||||
@@ -110,8 +132,11 @@ impl App {
|
||||
last_tick: Instant::now(),
|
||||
width,
|
||||
view,
|
||||
view_dirty: false,
|
||||
watch_until: None,
|
||||
window: None,
|
||||
frames: 0,
|
||||
refreshes: 0,
|
||||
auto_selected: false,
|
||||
}
|
||||
}
|
||||
@@ -137,8 +162,12 @@ impl App {
|
||||
}
|
||||
|
||||
/// 把 presenter 的快照转换成页面视图模型（**展示转换在 UI 侧做**）。
|
||||
///
|
||||
/// 代价是「克隆 N 个实例的名字/版本串」，所以只在 [`App::view_dirty`] 置位时调用（P2-1）。
|
||||
pub(super) fn refresh_view(&mut self) {
|
||||
self.view = super::view::model(&self.state, self.width);
|
||||
self.view = super::view::model(&self.state, self.width, self.options.force_state);
|
||||
self.view_dirty = false;
|
||||
self.refreshes += 1;
|
||||
}
|
||||
|
||||
/// 按设置文件里的主题模式切一次外观；`--theme` 显式给了就不动。
|
||||
|
||||
@@ -1,17 +1,26 @@
|
||||
//! 订阅：帧事件（截图闸门 + presenter 的 TICK 节拍）与窗口尺寸事件。
|
||||
//! 订阅：**按需**帧节拍（presenter 的 TICK）+ 窗口尺寸事件。
|
||||
//!
|
||||
//! ## 为什么节拍挂在帧事件上，而不是 `iced::time::every`
|
||||
//! ## 为什么要「按需」
|
||||
//!
|
||||
//! `iced::time::every` 只有 `tokio` / `smol` 两个异步后端提供；本 crate 关掉了 iced 的默认 features，
|
||||
//! 执行器是 `thread-pool`（M60 踩坑 Q2），拿不到那个函数。想用它就得改 `Cargo.toml` 开一个异步
|
||||
//! 运行时（不在本 mission 的 scope 内，已报 finding）。
|
||||
//! iced_winit 在处理完任何一条消息后都会 `request_redraw()`，而 `window::frames()` 监听的是
|
||||
//! `RedrawRequested` —— 于是「订阅帧 → 收 Frame → update → 再触发重绘」是一条**自持循环**：
|
||||
//! 只要订阅着，窗口就永远在重绘（M90 r1 就是这样，CPU 空转）。
|
||||
//!
|
||||
//! 所以节拍走**帧事件 + 时间闸门**：`window::frames()` 每帧给一条 `Frame`，app 侧按真实流逝时间
|
||||
//! 判断「够不够 33 ms」，够了才推进一拍 presenter（`backend.tick(elapsed)` / `drain_events`）。
|
||||
//! 好处是**按真实时间推进**（不是「数了多少帧 × 33 ms」，掉帧也不会把游戏启动进度拖慢），
|
||||
//! 代价是交互模式下窗口会持续重绘（30 帧的活干在 vsync 的节拍上）。
|
||||
//! 现在只在**真的需要时钟**的时候订阅（[`App::needs_frames`]）：
|
||||
//!
|
||||
//! 截图模式下这条订阅原本就在（第 3 帧落盘），合并之后两条路径共用同一个计时器。
|
||||
//! | 条件 | 为什么需要 33 ms 节拍 |
|
||||
//! |---|---|
|
||||
//! | 截图通道 | 第 3 帧要落盘 |
|
||||
//! | 有 `Busy` / `Running` 实例 | 启动进度、日志尾随都靠 `backend.tick` 推进 |
|
||||
//! | 有未过期的 toast | toast 按毫秒倒计时 |
|
||||
//! | 刚派发过指令（3 s 观察窗） | 真 host 的异步事件要靠节拍抽出来 |
|
||||
//!
|
||||
//! 空闲态**一条帧消息都不来** ⇒ 窗口不重绘、`refresh_view` 不跑（配合 `view_dirty`）。
|
||||
//! 已知代价：空闲态不再按 `config_poll_due` 轮询设置文件（外部 AI/CLI 改主题要等下次交互才生效）。
|
||||
//! 要同时拿回「省 CPU」与「后台轮询」，得用 `iced::time::every`，而它需要 Cargo.toml 开
|
||||
//! tokio/smol（不在本 mission 的 scope，已报 finding）。
|
||||
|
||||
use std::time::Instant;
|
||||
|
||||
use iced::{window, Subscription};
|
||||
|
||||
@@ -21,18 +30,34 @@ use super::state::App;
|
||||
impl App {
|
||||
/// 本次进程的订阅表。
|
||||
pub(super) fn subscription(&self) -> Subscription<Message> {
|
||||
let mut subscriptions = vec![window::frames().map(|_| Message::Frame)];
|
||||
let frames = if self.needs_frames() {
|
||||
window::frames().map(|_| Message::Frame)
|
||||
} else {
|
||||
Subscription::none()
|
||||
};
|
||||
|
||||
// 断点 600 / 840 要跟着真窗口宽度走；截图模式的窗口尺寸由参数钉死，不吃 resize。
|
||||
if !self.has_screenshot() {
|
||||
subscriptions.push(window::events().map(|(_, event)| Message::Window(event)));
|
||||
}
|
||||
let events = if self.has_screenshot() {
|
||||
Subscription::none()
|
||||
} else {
|
||||
window::events().map(|(_, event)| Message::Window(event))
|
||||
};
|
||||
|
||||
Subscription::batch(subscriptions)
|
||||
Subscription::batch([frames, events])
|
||||
}
|
||||
|
||||
/// 是否订阅帧事件（= 截图模式要帧数闸门）。
|
||||
pub(super) fn wants_frames(&self) -> bool {
|
||||
self.has_screenshot()
|
||||
}
|
||||
|
||||
/// 现在要不要**时钟**（见模块文档的表）。
|
||||
pub(super) fn needs_frames(&self) -> bool {
|
||||
self.has_screenshot()
|
||||
|| !self.state.toasts.is_empty()
|
||||
|| !self.state.running().is_empty()
|
||||
|| self
|
||||
.watch_until
|
||||
.is_some_and(|deadline| Instant::now() < deadline)
|
||||
}
|
||||
}
|
||||
@@ -9,6 +9,9 @@ use unlucky_presenter::mock::MockBackend;
|
||||
use unlucky_presenter::router::Route;
|
||||
use unlucky_presenter::settings_bridge::SettingsBridge;
|
||||
|
||||
#[cfg(test)]
|
||||
mod presenter;
|
||||
|
||||
use super::message::Message;
|
||||
use super::state::App;
|
||||
use super::{APP_TITLE, WINDOW_SIZE};
|
||||
@@ -96,145 +99,71 @@ fn frames_are_only_requested_in_screenshot_mode() {
|
||||
);
|
||||
}
|
||||
|
||||
// --------------------------------------------------------------- presenter 闭环
|
||||
// --------------------------------------------------------------- P2-1 按需节拍
|
||||
|
||||
/// **首屏快照在 Boot 就到位**（截图在第 3 帧落盘，等 30 fps 的 tick 会拍进空页面）。
|
||||
/// 空闲态**不要时钟**：没有忙碌实例、没有 toast、没有观察窗 ⇒ 不订阅帧事件。
|
||||
///
|
||||
/// 抓得住：`needs_frames()` 的三条触发条件（这也是 `subscription()` 的唯一判据）——
|
||||
/// 谁把「无条件订阅帧」改回来，这条立刻红。
|
||||
/// 抓不住：真实窗口的重绘次数（那要 `ULL_TICK_TRACE=1` 跑一次交互模式看日志，见报告）。
|
||||
#[test]
|
||||
fn boot_drains_the_first_snapshot_before_the_first_frame() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
assert!(app.view.instances.rows.is_empty(), "还没 Boot");
|
||||
fn an_idle_app_asks_for_no_clock() {
|
||||
let app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
assert!(app.needs_frames(), "截图通道永远要帧（第 3 帧落盘）");
|
||||
|
||||
let _ = app.update(Message::Boot);
|
||||
|
||||
assert_eq!(
|
||||
app.view.instances.rows.len(),
|
||||
4,
|
||||
"mock 的四个实例已进视图模型"
|
||||
);
|
||||
assert_eq!(app.view.screen, pages::Screen::Instances);
|
||||
}
|
||||
|
||||
/// 首屏自动选中第一行（右栏不该开局空白），且**只做一次**：返回列表后再刷新不弹回详情。
|
||||
#[test]
|
||||
fn the_first_snapshot_selects_the_first_instance_once() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
assert_eq!(
|
||||
app.state.route(),
|
||||
&Route::Detail("survival".to_string()),
|
||||
"首屏快照到位后自动选中第一行"
|
||||
let mut idle = headless(Options::default(), SchemeFlavor::Light);
|
||||
let _ = idle.update(Message::Boot);
|
||||
assert!(
|
||||
idle.needs_frames(),
|
||||
"Boot 刚派发过 RefreshAll：3 秒观察窗内要节拍（等真 host 的首批事件）"
|
||||
);
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Instances)));
|
||||
assert_eq!(app.state.route(), &Route::Instances);
|
||||
// 观察窗过期、也没有忙碌实例 ⇒ 空闲态不再要时钟
|
||||
idle.watch_until = None;
|
||||
assert!(!idle.needs_frames(), "空闲交互态：不订阅帧事件");
|
||||
|
||||
// 再推进一拍（会 drain_events + auto_select）：不该把他弹回详情页
|
||||
app.advance(super::state::TICK);
|
||||
assert_eq!(app.state.route(), &Route::Instances, "自动选中只做一次");
|
||||
}
|
||||
|
||||
/// **点 Play → 命令真的派发出去 → 事件回流 → 页面真的变**（不做乐观回显）。
|
||||
#[test]
|
||||
fn launching_goes_through_the_backend_and_comes_back_as_events() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
// 派发之后观察窗重新打开
|
||||
let _ = idle.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
|
||||
let detail = app.view.instances.detail.as_ref().expect("有选中项");
|
||||
assert!(
|
||||
detail.can_launch && !detail.can_stop,
|
||||
"空闲：可启动不可停止"
|
||||
);
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Launch(
|
||||
let _ = idle.update(Message::Page(pages::Message::Launch(
|
||||
"survival".to_string(),
|
||||
)));
|
||||
assert!(idle.needs_frames(), "派发后观察窗内要有节拍");
|
||||
|
||||
let detail = app.view.instances.detail.as_ref().expect("有选中项");
|
||||
// 进入 Busy 之后由「忙碌实例」这个条件自己续订（不靠观察窗）
|
||||
idle.watch_until = None;
|
||||
assert!(
|
||||
!detail.can_launch && detail.can_stop,
|
||||
"派发 LaunchInstance 后后端发回了 Busy 事件：按钮组合必须已经翻转"
|
||||
);
|
||||
assert_eq!(
|
||||
detail.status.as_deref(),
|
||||
Some("Downloading · 0%"),
|
||||
"状态行来自事件里的进度，不是本地假造"
|
||||
idle.needs_frames(),
|
||||
"有 Busy 实例时即便观察窗过期也要继续 tick"
|
||||
);
|
||||
}
|
||||
|
||||
/// 时间推进真的把状态往前推（后端的脚本按 tick 的累计时长走）。
|
||||
/// 空闲态每拍**不再重建视图模型**（P2-1 的另一半：`refresh_view` 的 30 Hz × N 实例白克隆）。
|
||||
///
|
||||
/// 抓得住：把 `advance()` 里的 `if self.view_dirty` 去掉（改回无条件 `refresh_view()`）时，
|
||||
/// 这条断言里的 `refreshes` 会从「不增长」变成「每拍 +1」。
|
||||
/// 抓不住：「重建一次花了多少微秒」（没有基准测试；量级判断见报告）。
|
||||
#[test]
|
||||
fn ticks_advance_the_backend_script() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
fn idle_ticks_do_not_rebuild_the_view_model() {
|
||||
let mut app = headless(Options::default(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
let _ = app.update(Message::Page(pages::Message::Launch(
|
||||
"survival".to_string(),
|
||||
)));
|
||||
|
||||
// 33 ms × 50 ≈ 1.65 s：mock 的脚本在 1.5 s 从 Download 切到 Verify
|
||||
for _ in 0..50 {
|
||||
let before = app.refreshes;
|
||||
for _ in 0..100 {
|
||||
app.advance(super::state::TICK);
|
||||
}
|
||||
|
||||
let detail = app.view.instances.detail.as_ref().expect("有选中项");
|
||||
let status = detail.status.as_deref().unwrap_or_default();
|
||||
assert!(
|
||||
status.starts_with("Verifying") || status.starts_with("Starting"),
|
||||
"50 拍之后应已过下载阶段，实际 {status:?}"
|
||||
);
|
||||
}
|
||||
|
||||
/// 停止也是真命令：`StopInstance` 让 mock 直接回一条 Idle 事件。
|
||||
#[test]
|
||||
fn stopping_returns_to_idle_through_an_event() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
let _ = app.update(Message::Page(pages::Message::Launch(
|
||||
"survival".to_string(),
|
||||
)));
|
||||
let _ = app.update(Message::Page(pages::Message::Stop("survival".to_string())));
|
||||
|
||||
let detail = app.view.instances.detail.as_ref().expect("有选中项");
|
||||
assert!(detail.can_launch && !detail.can_stop, "停下来回到空闲");
|
||||
assert!(detail.status.is_none(), "空闲没有状态行");
|
||||
}
|
||||
|
||||
/// 导航：一级页替换、详情压栈、返回出栈——页面换的是 `Route`，不是页面自己的选中项。
|
||||
#[test]
|
||||
fn navigation_follows_the_presenter_router() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
assert_eq!(app.view.screen, pages::Screen::Instances, "详情仍是实例页");
|
||||
assert!(app.state.router.can_go_back());
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Settings)));
|
||||
assert_eq!(app.view.screen, pages::Screen::Settings);
|
||||
assert_eq!(
|
||||
app.view.active,
|
||||
Some(pages::Screen::Settings.nav()),
|
||||
"导航轨高亮跟着路由走"
|
||||
);
|
||||
assert!(
|
||||
!app.state.router.can_go_back(),
|
||||
"一级页互相替换，不进栈（presenter::router 的语义）"
|
||||
app.refreshes,
|
||||
before,
|
||||
"空闲 100 拍：视图模型一次都不该重建（实际 +{}）",
|
||||
app.refreshes - before
|
||||
);
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Instances)));
|
||||
assert_eq!(app.view.screen, pages::Screen::Instances);
|
||||
// 有事件进来时仍然要重建（否则页面不刷新）
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Logs)));
|
||||
assert!(app.refreshes > before, "导航之后必须重建一次");
|
||||
}
|
||||
|
||||
/// 视图模型跟着窗口宽度走（交互模式下 600 / 840 两条断点靠 resize 事件生效）。
|
||||
#[test]
|
||||
fn resizing_the_window_rebuilds_the_view_model() {
|
||||
|
||||
@@ -0,0 +1,238 @@
|
||||
//! presenter 闭环与节拍的断言（M90 r2 从 `app/tests.rs` 外置：那边 416 行会被 file-size 判红）。
|
||||
//!
|
||||
//! 这里的每条都依赖一个可注入的 `Backend`：
|
||||
//! - `MockBackend`（presenter 自带）验「命令 → 事件 → 状态」的闭环；
|
||||
//! - `RecorderBackend`（本文件，只记账不回事件）验「UI 侧不做乐观回显」——用 MockBackend 验这条
|
||||
//! 会得到**假绿**，因为它是同步发事件的，本地回显与事件回流终态相同（P3-2 的教训）。
|
||||
|
||||
use std::cell::RefCell;
|
||||
use std::rc::Rc;
|
||||
|
||||
use unlucky_presenter::dto::{AppCommand, AppEvent, Backend, CoreEvent};
|
||||
use unlucky_presenter::mock_data::mock_instances;
|
||||
|
||||
use super::*;
|
||||
|
||||
// --------------------------------------------------------------- presenter 闭环
|
||||
|
||||
/// **首屏快照在 Boot 就到位**（截图在第 3 帧落盘，等 30 fps 的 tick 会拍进空页面）。
|
||||
#[test]
|
||||
fn boot_drains_the_first_snapshot_before_the_first_frame() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
assert!(app.view.instances.rows.is_empty(), "还没 Boot");
|
||||
|
||||
let _ = app.update(Message::Boot);
|
||||
|
||||
assert_eq!(
|
||||
app.view.instances.rows.len(),
|
||||
4,
|
||||
"mock 的四个实例已进视图模型"
|
||||
);
|
||||
assert_eq!(app.view.screen, pages::Screen::Instances);
|
||||
}
|
||||
|
||||
/// 首屏自动选中第一行（右栏不该开局空白），且**只做一次**：返回列表后再刷新不弹回详情。
|
||||
#[test]
|
||||
fn the_first_snapshot_selects_the_first_instance_once() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
assert_eq!(
|
||||
app.state.route(),
|
||||
&Route::Detail("survival".to_string()),
|
||||
"首屏快照到位后自动选中第一行"
|
||||
);
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Instances)));
|
||||
assert_eq!(app.state.route(), &Route::Instances);
|
||||
|
||||
// 再推进一拍（会 drain_events + auto_select）：不该把他弹回详情页
|
||||
app.advance(super::super::state::TICK);
|
||||
assert_eq!(app.state.route(), &Route::Instances, "自动选中只做一次");
|
||||
}
|
||||
|
||||
/// 只记账、**不回任何事件**的后端（P3-2）。
|
||||
///
|
||||
/// 为什么需要它：`MockBackend::dispatch` 是**同步**发事件的，于是「UI 本地回显」与「事件回流」
|
||||
/// 在 dispatch 之后终态相同——拿 MockBackend 测「不乐观回显」是假绿（r1 就是栽在这条上）。
|
||||
/// 这个后端把两件事分开：命令只进 `dispatched`，`drain_events` 永远空 ⇒ 状态**不可能**变；
|
||||
/// 一旦有人在 `update` 里偷偷改本地状态，下面那条断言立刻红（实测见报告「P3-2 取证」）。
|
||||
#[derive(Debug, Default)]
|
||||
struct RecorderBackend {
|
||||
dispatched: Rc<RefCell<Vec<AppCommand>>>,
|
||||
seeded: Vec<AppEvent>,
|
||||
}
|
||||
|
||||
impl Backend for RecorderBackend {
|
||||
fn drain_events(&mut self) -> Vec<AppEvent> {
|
||||
std::mem::take(&mut self.seeded)
|
||||
}
|
||||
|
||||
fn dispatch(&mut self, command: AppCommand) {
|
||||
self.dispatched.borrow_mut().push(command);
|
||||
}
|
||||
}
|
||||
|
||||
/// 用 recorder 后端造一个 App（首屏快照靠 `seeded` 一次性喂进去）。
|
||||
fn recording(options: Options, flavor: SchemeFlavor) -> (App, Rc<RefCell<Vec<AppCommand>>>) {
|
||||
let recorded = Rc::new(RefCell::new(Vec::new()));
|
||||
// 注意：`InstancesChanged` 是**整体替换**，所以四条必须合成一条事件；
|
||||
// 分开发的话最后只会剩一个实例（r1 在这条上踩过）。
|
||||
let backend = RecorderBackend {
|
||||
dispatched: Rc::clone(&recorded),
|
||||
seeded: vec![AppEvent::Core(
|
||||
CoreEvent::InstancesChanged(mock_instances()),
|
||||
)],
|
||||
};
|
||||
let app = App::with_presenter(
|
||||
options,
|
||||
FAMILIES,
|
||||
flavor,
|
||||
Box::new(backend),
|
||||
SettingsBridge::memory_only(),
|
||||
);
|
||||
(app, recorded)
|
||||
}
|
||||
|
||||
/// **P3-2：不做乐观回显**——命令必须真的出 UI 层，而状态在后端回事件之前**一个字节都不许变**。
|
||||
///
|
||||
/// 抓得住：`update` 里出现「本地先改状态」的写法（recorder 永远不回事件，本地一改这里就红）。
|
||||
/// 抓不住：「命令有没有真的到达 host」——那由 `MockBackend` 的闭环测试与真机验证负责。
|
||||
#[test]
|
||||
fn launching_only_dispatches_and_never_echoes_locally() {
|
||||
let mut options = screenshot_options();
|
||||
options.screenshot = None; // recorder 不依赖截图通道
|
||||
let (mut app, recorded) = recording(options, SchemeFlavor::Light);
|
||||
|
||||
let _ = app.update(Message::Boot);
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
|
||||
// Boot 自己发过一条 RefreshAll，先把账本清掉，下面只看「点 Play」这一个动作
|
||||
recorded.borrow_mut().clear();
|
||||
|
||||
let before = app.view.instances.detail.clone().expect("有选中项");
|
||||
assert!(before.can_launch && !before.can_stop && before.status.is_none());
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Launch(
|
||||
"survival".to_string(),
|
||||
)));
|
||||
|
||||
// ① 命令真的出 UI 层了
|
||||
assert_eq!(
|
||||
*recorded.borrow(),
|
||||
vec![AppCommand::LaunchInstance("survival".to_string())],
|
||||
"Launch 必须翻成一条 AppCommand::LaunchInstance 并交给 Backend::dispatch"
|
||||
);
|
||||
|
||||
// ② 后端一条事件都没回 ⇒ 视图模型必须**原样不动**（任何本地回显都会让这条红）
|
||||
let after = app.view.instances.detail.clone().expect("有选中项");
|
||||
assert_eq!(
|
||||
after, before,
|
||||
"没有事件回流时页面不许自己变（乐观回显）；现在的差异是 {after:?}"
|
||||
);
|
||||
assert!(!after.can_stop, "不许因为点了 Play 就本地切成「可停止」");
|
||||
assert!(after.status.is_none(), "不许本地造一条进度文案");
|
||||
}
|
||||
|
||||
/// **点 Play → 命令真的派发出去 → 事件回流 → 页面真的变**（真后端的闭环）。
|
||||
#[test]
|
||||
fn launching_goes_through_the_backend_and_comes_back_as_events() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
|
||||
let detail = app.view.instances.detail.as_ref().expect("有选中项");
|
||||
assert!(
|
||||
detail.can_launch && !detail.can_stop,
|
||||
"空闲：可启动不可停止"
|
||||
);
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Launch(
|
||||
"survival".to_string(),
|
||||
)));
|
||||
|
||||
let detail = app.view.instances.detail.as_ref().expect("有选中项");
|
||||
assert!(
|
||||
!detail.can_launch && detail.can_stop,
|
||||
"派发 LaunchInstance 后后端发回了 Busy 事件：按钮组合必须已经翻转"
|
||||
);
|
||||
assert_eq!(
|
||||
detail.status.as_deref(),
|
||||
Some("Downloading · 0%"),
|
||||
"状态行来自事件里的进度，不是本地假造"
|
||||
);
|
||||
}
|
||||
|
||||
/// 时间推进真的把状态往前推（后端的脚本按 tick 的累计时长走）。
|
||||
#[test]
|
||||
fn ticks_advance_the_backend_script() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
let _ = app.update(Message::Page(pages::Message::Launch(
|
||||
"survival".to_string(),
|
||||
)));
|
||||
|
||||
// 33 ms × 50 ≈ 1.65 s：mock 的脚本在 1.5 s 从 Download 切到 Verify
|
||||
for _ in 0..50 {
|
||||
app.advance(super::super::state::TICK);
|
||||
}
|
||||
|
||||
let detail = app.view.instances.detail.as_ref().expect("有选中项");
|
||||
let status = detail.status.as_deref().unwrap_or_default();
|
||||
assert!(
|
||||
status.starts_with("Verifying") || status.starts_with("Starting"),
|
||||
"50 拍之后应已过下载阶段，实际 {status:?}"
|
||||
);
|
||||
}
|
||||
|
||||
/// 停止也是真命令：`StopInstance` 让 mock 直接回一条 Idle 事件。
|
||||
#[test]
|
||||
fn stopping_returns_to_idle_through_an_event() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
let _ = app.update(Message::Page(pages::Message::Launch(
|
||||
"survival".to_string(),
|
||||
)));
|
||||
let _ = app.update(Message::Page(pages::Message::Stop("survival".to_string())));
|
||||
|
||||
let detail = app.view.instances.detail.as_ref().expect("有选中项");
|
||||
assert!(detail.can_launch && !detail.can_stop, "停下来回到空闲");
|
||||
assert!(detail.status.is_none(), "空闲没有状态行");
|
||||
}
|
||||
|
||||
/// 导航：一级页替换、详情压栈、返回出栈——页面换的是 `Route`，不是页面自己的选中项。
|
||||
#[test]
|
||||
fn navigation_follows_the_presenter_router() {
|
||||
let mut app = headless(screenshot_options(), SchemeFlavor::Light);
|
||||
let _ = app.update(Message::Boot);
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Detail(
|
||||
"survival".to_string(),
|
||||
))));
|
||||
assert_eq!(app.view.screen, pages::Screen::Instances, "详情仍是实例页");
|
||||
assert!(app.state.router.can_go_back());
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Settings)));
|
||||
assert_eq!(app.view.screen, pages::Screen::Settings);
|
||||
assert_eq!(
|
||||
app.view.active,
|
||||
Some(pages::Screen::Settings.nav()),
|
||||
"导航轨高亮跟着路由走"
|
||||
);
|
||||
assert!(
|
||||
!app.state.router.can_go_back(),
|
||||
"一级页互相替换，不进栈（presenter::router 的语义）"
|
||||
);
|
||||
|
||||
let _ = app.update(Message::Page(pages::Message::Navigate(Route::Instances)));
|
||||
assert_eq!(app.view.screen, pages::Screen::Instances);
|
||||
}
|
||||
@@ -27,7 +27,7 @@ use unlucky_presenter::theme::config_poll_due;
|
||||
use crate::pages;
|
||||
|
||||
use super::message::{route_of, Message};
|
||||
use super::state::{App, TICK};
|
||||
use super::state::{App, TICK, WATCH_WINDOW};
|
||||
use super::CAPTURE_AT_FRAME;
|
||||
|
||||
impl App {
|
||||
@@ -52,6 +52,7 @@ impl App {
|
||||
Message::Window(event) => {
|
||||
if let window::Event::Resized(size) = event {
|
||||
self.width = size.width;
|
||||
self.view_dirty = true;
|
||||
self.refresh_view();
|
||||
}
|
||||
Task::none()
|
||||
@@ -63,6 +64,7 @@ impl App {
|
||||
// 外壳导航轨（`src/shell/nav.rs`）发来的点选：翻成同一次路由跳转
|
||||
Message::Select(nav) => {
|
||||
self.state.navigate(route_of(nav));
|
||||
self.view_dirty = true;
|
||||
self.refresh_view();
|
||||
Task::none()
|
||||
}
|
||||
@@ -111,6 +113,7 @@ impl App {
|
||||
// 「重新扫描实例目录 + 全部页面快照」：真 host 在这里发首批事件，mock 在构造时已预置
|
||||
self.dispatch(AppCommand::RefreshAll);
|
||||
self.auto_select();
|
||||
self.view_dirty = true;
|
||||
self.refresh_view();
|
||||
|
||||
Task::batch(tasks)
|
||||
@@ -162,7 +165,21 @@ impl App {
|
||||
self.apply_config_theme();
|
||||
}
|
||||
|
||||
self.refresh_view();
|
||||
if self.view_dirty {
|
||||
self.refresh_view();
|
||||
}
|
||||
|
||||
// 取证开关（`ULL_TICK_TRACE=1`）：每 30 拍打一行。**空闲态应当打完一阵就彻底安静**
|
||||
// —— 那正是「不再订阅帧事件」的可观测形式（没有 Frame ⇒ 这里根本不会被调用）。
|
||||
if self.ticks.is_multiple_of(30) && std::env::var_os("ULL_TICK_TRACE").is_some() {
|
||||
eprintln!(
|
||||
"[tick] n={} frames={} refreshes={} frames_wanted={}",
|
||||
self.ticks,
|
||||
self.frames,
|
||||
self.refreshes,
|
||||
self.needs_frames()
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
/// 页面消息：导航走路由栈，动作翻成 `AppCommand`。
|
||||
@@ -170,6 +187,7 @@ impl App {
|
||||
match message {
|
||||
pages::Message::Navigate(route) => {
|
||||
self.state.navigate(route);
|
||||
self.view_dirty = true;
|
||||
self.refresh_view();
|
||||
}
|
||||
pages::Message::Launch(id) => self.dispatch(AppCommand::LaunchInstance(id)),
|
||||
@@ -184,6 +202,9 @@ impl App {
|
||||
/// 派发一条指令并**立刻**抽干它带出来的事件（不本地回显，等价于 Slint 版的 `dispatch`）。
|
||||
fn dispatch(&mut self, command: AppCommand) {
|
||||
self.backend.dispatch(command);
|
||||
// 观察窗：命令发出后 3 秒内保持帧订阅，等后端把第一条事件交回来
|
||||
// （真 host 是异步的，派发瞬间状态还没变；不设这个窗口，空闲态的帧订阅永远不会打开）。
|
||||
self.watch_until = Some(Instant::now() + WATCH_WINDOW);
|
||||
self.pump();
|
||||
}
|
||||
|
||||
@@ -196,6 +217,7 @@ impl App {
|
||||
for event in events {
|
||||
self.state.apply(event);
|
||||
}
|
||||
self.view_dirty = true;
|
||||
self.auto_select();
|
||||
self.refresh_view();
|
||||
}
|
||||
@@ -219,6 +241,7 @@ impl App {
|
||||
};
|
||||
self.auto_selected = true;
|
||||
self.state.navigate(Route::Detail(first));
|
||||
self.view_dirty = true;
|
||||
}
|
||||
|
||||
/// 截图回来了：落盘 + 打一行取证日志，然后退出。
|
||||
|
||||
@@ -4,15 +4,16 @@
|
||||
|
||||
use iced::{Element, Theme};
|
||||
|
||||
use unlucky_presenter::dto::{InstanceRuntime, InstanceSummary, LaunchStage, LoaderKind};
|
||||
use unlucky_presenter::dto::{InstanceRuntime, InstanceSummary, LaunchStage};
|
||||
use unlucky_presenter::router::Route;
|
||||
use unlucky_presenter::state::AppState;
|
||||
|
||||
use crate::app::components::interaction::Interaction;
|
||||
use crate::cli::Screen;
|
||||
use crate::pages::{self, Detail, Meta, Row};
|
||||
use crate::shell::{self, NavItem};
|
||||
|
||||
use super::message::Message;
|
||||
use super::message::{nav_item_of, Message};
|
||||
use super::state::{log_first_frame, App};
|
||||
use super::APP_TITLE;
|
||||
|
||||
@@ -37,10 +38,19 @@ impl App {
|
||||
return super::components::gallery::view(&self.ui).map(Message::Demo);
|
||||
}
|
||||
|
||||
// 产品页走**内容槽位**：外壳（标题栏 / 拖动与缩放热区 / 三个 caption 键 / rail）由
|
||||
// `shell` 画，中间那块才是页面。M90 r2 之前这里用的是 `pages::app`（自带一条**没有任何
|
||||
// 控件**的标题栏留白带），而 `DragWindow` / `ResizeStart` / `Minimize` / `ToggleMaximize` /
|
||||
// `Close` 五个消息只在外壳里构造 ⇒ 产品页「拖不动、缩不了、点不到关闭」。
|
||||
match pages::Screen::of(self.state.route()) {
|
||||
Some(_) => pages::app(&self.ui, &self.view).map(Message::Page),
|
||||
// `Route::Agent`：AI 独立页还没有页面实现（P1），暂时回退到 M68 的外壳卡。
|
||||
// 这条回退也是 `src/shell/` 目前唯一的调用点——见报告里的「谁该补」。
|
||||
Some(_) => shell::view_with_content(
|
||||
&self.ui,
|
||||
nav_item_of(self.state.route()),
|
||||
APP_TITLE,
|
||||
pages::page(&self.ui, &self.view).map(Message::Page),
|
||||
self.options.force_state,
|
||||
),
|
||||
// `Route::Agent`：AI 独立页还没有页面实现（P1），回退到 M68 的外壳卡（同一套装饰）。
|
||||
None => shell::view(
|
||||
&self.ui,
|
||||
NavItem::Ai,
|
||||
@@ -57,7 +67,13 @@ impl App {
|
||||
// --------------------------------------------------------------- 快照 → 视图模型
|
||||
|
||||
/// 把 presenter 的快照转成页面视图模型（**唯一**的展示转换点）。
|
||||
pub(super) fn model(state: &AppState, width: f32) -> pages::Model {
|
||||
///
|
||||
/// `forced` 是 `--force-state` 的落点（P3-1）：它只影响**画出来的**状态层，不改任何状态机。
|
||||
pub(super) fn model(
|
||||
state: &AppState,
|
||||
width: f32,
|
||||
forced: Option<crate::cli::ForcedState>,
|
||||
) -> pages::Model {
|
||||
let route = state.route().clone();
|
||||
let screen = pages::Screen::of(&route).unwrap_or(pages::Screen::Instances);
|
||||
|
||||
@@ -86,6 +102,10 @@ pub(super) fn model(state: &AppState, width: f32) -> pages::Model {
|
||||
window_width: width,
|
||||
active: route.nav(),
|
||||
instances: pages::Instances { rows, detail },
|
||||
forced: forced.map(|state| match state {
|
||||
crate::cli::ForcedState::Hover => Interaction::Hovered,
|
||||
crate::cli::ForcedState::Pressed => Interaction::Pressed,
|
||||
}),
|
||||
}
|
||||
}
|
||||
|
||||
@@ -123,11 +143,10 @@ fn stage_label(stage: LaunchStage) -> &'static str {
|
||||
|
||||
/// 详情列的内容（字段全部来自 [`InstanceSummary`]）。
|
||||
fn detail_of(instance: &InstanceSummary) -> Detail {
|
||||
let loader = if instance.loader.kind == LoaderKind::Vanilla {
|
||||
"Vanilla".to_string()
|
||||
} else {
|
||||
instance.loader.badge()
|
||||
};
|
||||
// 视觉 P2-2（M90 r2）：列表行与详情曾经「同物两名」（列表 `badge()` 出「原版」、详情硬编码
|
||||
// 「Vanilla」）。现在两边都走 `LoaderInfo::badge()` 这一个入口；等 i18n 落地后由词表统一，
|
||||
// 届时两处会同时变——这正是要的。
|
||||
let loader = instance.loader.badge();
|
||||
|
||||
Detail {
|
||||
id: instance.id.clone(),
|
||||
@@ -217,7 +236,7 @@ mod tests {
|
||||
));
|
||||
state.navigate(Route::Detail("survival".to_string()));
|
||||
|
||||
let model = model(&state, 1180.0);
|
||||
let model = model(&state, 1180.0, None);
|
||||
assert_eq!(model.screen, pages::Screen::Instances);
|
||||
assert_eq!(model.active, Some(pages::Screen::Instances.nav()));
|
||||
assert_eq!(model.window_width, 1180.0);
|
||||
@@ -248,7 +267,7 @@ mod tests {
|
||||
));
|
||||
state.navigate(Route::Detail("survival".to_string()));
|
||||
|
||||
let model = model(&state, 1180.0);
|
||||
let model = model(&state, 1180.0, None);
|
||||
assert_eq!(
|
||||
model.instances.rows[0].status.as_deref(),
|
||||
Some("Downloading · 50%")
|
||||
@@ -286,7 +305,7 @@ mod tests {
|
||||
fn the_agent_route_has_no_page() {
|
||||
let mut state = AppState::new();
|
||||
state.navigate(Route::Agent);
|
||||
let model = model(&state, 1180.0);
|
||||
let model = model(&state, 1180.0, None);
|
||||
// Agent 没有页面：模型退回实例页的空壳，view 会走外壳回退（`None` 分支）
|
||||
assert_eq!(pages::Screen::of(state.route()), None);
|
||||
assert!(model.instances.detail.is_none());
|
||||
|
||||
Reference in new issue
Block a user