AskaEth
a183adc072
主线六条合入后，四个被我碰过的文件越过 400 行；按模块拆开，只搬不改： - `presenter/host/mod.rs` 421→366：账户刷新/皮肤三段（refresh_accounts / attach_skins / request_skins）搬进 `host/accounts/refresh.rs`（`impl CoreHost`，pub(in crate::host)） - `presenter/state.rs` 410→392：`TileCell` + `grid_positions` 搬进 `state/tiles.rs`， `state.rs` 用 `pub use` 再导出，老路径不变 - `app-iced/app/state.rs` 401→394：账户页重建那一段搬进 `app/view/account_page.rs` 的 `App::rebuild_account_page` - `app-iced/app/update.rs` 407→388：`ULL_START_ROUTE` 取值表搬进 `app/update/boot_env.rs` （纯函数、无状态）
339 lines
13 KiB
Rust
339 lines
13 KiB
Rust
//! 事件与指令：core/agent → app 的事件队列，app → core/agent 的用户意图。
|
||
//!
|
||
//! 三条通道（01c §5）：①不可变快照发布（`*Changed` 整体替换）②事件流（`LogAppended` /
|
||
//! `InstallProgress` / `DeviceLoginChanged`）③注入的显示服务（先落成事件，见 `DialogRequested`）。
|
||
//! 全部类型 `Serialize + Deserialize`：这是 IPC 契约（AGENTS §6）。
|
||
|
||
use serde::{Deserialize, Serialize};
|
||
|
||
use crate::dialogs::{DialogId, DialogRequest};
|
||
use crate::dto::CreateRequest;
|
||
use crate::dto::{
|
||
// 主线（M109 的 Content* / M113 的 Pack*）与 M114 的 Authlib*/AccountNotice 的并集。
|
||
AccountNotice,
|
||
AccountView,
|
||
AgentEvent,
|
||
AuthlibLoginView,
|
||
AuthlibRequest,
|
||
ContentInstallRequest,
|
||
ContentQuery,
|
||
ContentResults,
|
||
DeviceLoginView,
|
||
DiagnosisReport,
|
||
InstallProgressView,
|
||
InstanceId,
|
||
InstanceRuntime,
|
||
InstanceSummary,
|
||
JavaPageView,
|
||
LoaderKind,
|
||
LogLine,
|
||
LogOutcome,
|
||
LogSession,
|
||
NoticeView,
|
||
PackCommand,
|
||
PackEvent,
|
||
SessionId,
|
||
SettingGroupView,
|
||
VersionCategory,
|
||
VersionSummary,
|
||
};
|
||
use crate::toast::Toast;
|
||
|
||
/// 启动会话的一段实时日志（host 尾随 JSONL 后按批次发）。
|
||
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
|
||
pub struct LiveLogBatch {
|
||
/// 会话 id
|
||
pub session: SessionId,
|
||
/// 新增行
|
||
pub lines: Vec<LogLine>,
|
||
/// 会话是否还在跑（false = 收尾，可以触发诊断/刷新列表）
|
||
pub running: bool,
|
||
}
|
||
|
||
/// 一次启动收尾（磁贴状态回写 + 日志页会话列表刷新）。
|
||
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
|
||
pub struct LaunchFinished {
|
||
/// 实例 id
|
||
pub id: InstanceId,
|
||
/// 会话 id
|
||
pub session: SessionId,
|
||
/// 结局
|
||
pub outcome: LogOutcome,
|
||
/// 一句人读结论（`正常退出` / `崩溃（exit 1）` / `启动失败：…`）
|
||
pub summary: String,
|
||
}
|
||
|
||
/// core 侧事件（不可变快照发布 + 事件流，01c §5 的三条通道之二）。
|
||
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
|
||
pub enum CoreEvent {
|
||
/// 实例列表整体刷新
|
||
InstancesChanged(Vec<InstanceSummary>),
|
||
/// 单个实例运行时状态变化（启动进度/运行中/失败）
|
||
InstanceRuntimeChanged {
|
||
/// 实例 id
|
||
id: InstanceId,
|
||
/// 新状态
|
||
runtime: InstanceRuntime,
|
||
},
|
||
/// 下载页版本列表刷新
|
||
VersionListChanged(Vec<VersionSummary>),
|
||
/// 日志会话列表刷新
|
||
LogSessionsChanged(Vec<LogSession>),
|
||
/// 当前会话日志行刷新（整批替换）
|
||
LogLinesChanged(Vec<LogLine>),
|
||
/// 实时日志增量（启动中尾随 JSONL；`running=false` 表示会话收尾）
|
||
LogAppended(LiveLogBatch),
|
||
/// 启动收尾（磁贴状态回写 + toast）
|
||
LaunchFinished(LaunchFinished),
|
||
/// 诊断结论产出
|
||
DiagnosisReady(DiagnosisReport),
|
||
/// 账户列表刷新
|
||
AccountsChanged(Vec<AccountView>),
|
||
/// 微软登录状态刷新
|
||
DeviceLoginChanged(DeviceLoginView),
|
||
/// 第三方轨（authlib-injector）登录/校验状态刷新
|
||
AuthlibLoginChanged(AuthlibLoginView),
|
||
/// 账户页横幅（添加/删除/切换的结果；`None` = 清掉横幅）
|
||
AccountNoticeChanged(Option<AccountNotice>),
|
||
/// Java 页快照（发行版/回退链/运行时）
|
||
JavaChanged(JavaPageView),
|
||
/// 安装进度（`None` = 清掉进度面板）
|
||
InstallProgress(Option<InstallProgressView>),
|
||
/// 用户取消了安装（**不带人读文案**）
|
||
///
|
||
/// 为什么只有信号没有文本：`presenter` 不依赖 `unlucky-i18n`，任何写死的中文都会和
|
||
/// 页面语言打架（下载页目前渲染英文，一条中文 Toast 会**同屏一中一英**，复审 P2-2）。
|
||
/// 文案由 app 层按 `Key` 现求：见 `pages::download::cancelled_toast`。
|
||
InstallCancelled,
|
||
/// 某 (加载器, 原版版本) 可用的加载器版本列表（下载页「安装选项」的版本下拉）。
|
||
///
|
||
/// `result` 用 `Result` 而不是空列表：**取不到**与**确实没有**是两件事，
|
||
/// 前者要给具名错误（不许让下拉显示成空还以为能装），后者是「这个组合官方就没有版本」。
|
||
LoaderVersions {
|
||
/// 加载器种类
|
||
kind: LoaderKind,
|
||
/// 目标原版版本
|
||
mc_version: String,
|
||
/// `Ok(最新在前)` / `Err(人读原因)`
|
||
result: Result<Vec<String>, String>,
|
||
},
|
||
/// 设置分组刷新（设置页右栏）
|
||
SettingsChanged(Vec<SettingGroupView>),
|
||
/// 横幅通知刷新（隔离切换提示/启动失败等）
|
||
NoticesChanged(Vec<NoticeView>),
|
||
/// 内容库检索结果（M109）：**整批替换**（同一份 `query` 的命中项，含分页游标）
|
||
ContentResults(Box<ContentResults>),
|
||
/// 内容库检索失败（M109）：一句人读原因（没网 / 站点限速 / 缺密钥）
|
||
ContentFailed(String),
|
||
// M113: import/export
|
||
/// 导入/导出（M113）：进度、结果、探测诊断、导出预检（子枚举见 [`PackEvent`]）
|
||
Pack(Box<PackEvent>),
|
||
}
|
||
|
||
/// 统一事件队列的元素：core / agent / UI 自产（对话框、Toast）都走这一条路，
|
||
/// 这样 [`crate::state::AppState::apply`] 是唯一的状态变更入口。
|
||
#[derive(Debug, Clone, PartialEq, Serialize, Deserialize)]
|
||
pub enum AppEvent {
|
||
/// 来自 core
|
||
Core(CoreEvent),
|
||
/// 来自 agent
|
||
Agent(AgentEvent),
|
||
/// core/agent 请求弹对话框（会进队列，一次一条）
|
||
DialogRequested(DialogRequest),
|
||
/// 关闭指定对话框（任务完成收起进度条）
|
||
DialogClosed(DialogId),
|
||
/// 右下角 Toast
|
||
Toast(Toast),
|
||
}
|
||
|
||
/// app → core/agent 的用户意图。
|
||
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
|
||
pub enum AppCommand {
|
||
/// 重新扫描实例目录 + 全部页面快照（启动时与手改文件后）
|
||
RefreshAll,
|
||
/// 启动实例
|
||
LaunchInstance(InstanceId),
|
||
/// 停止实例（含取消启动中的管线）
|
||
StopInstance(InstanceId),
|
||
/// 拉取某分类的版本列表
|
||
ListVersions(VersionCategory),
|
||
/// 安装指定版本（下载页行内「安装」按钮；原版）
|
||
InstallVersion(String),
|
||
/// 取消安装（阶段边界生效：当前阶段跑完就停，不再进下一阶段）
|
||
CancelInstall,
|
||
/// 新建实例（向导提交：版本 + 加载器 + 名字）
|
||
CreateInstance(CreateRequest),
|
||
/// 拉取某原版版本可用的加载器版本（下载页「安装选项」的版本下拉）
|
||
ListLoaderVersions {
|
||
/// 加载器种类
|
||
kind: LoaderKind,
|
||
/// 目标原版版本（`1.20.1`）
|
||
mc_version: String,
|
||
},
|
||
/// 修改实例隔离档位（写实例设置文件）
|
||
SetIsolation {
|
||
/// 实例 id
|
||
id: InstanceId,
|
||
/// `isolated` / `shared`
|
||
mode: String,
|
||
},
|
||
/// 刷新日志会话列表
|
||
RefreshLogSessions,
|
||
/// 打开某个会话（拉取日志行 + 触发诊断）
|
||
OpenLogSession(SessionId),
|
||
/// 导入崩溃日志文件做规则分析（`hs_err_pid*.log` / `latest.log`）
|
||
ImportCrashLog(String),
|
||
/// 加一个离线账户
|
||
AddOfflineAccount(String),
|
||
/// 删除账户（按 id 或名字）
|
||
RemoveAccount(String),
|
||
/// 切换当前启动账户
|
||
SwitchAccount(String),
|
||
/// 开始微软设备码登录（CLI/无浏览器场景、备用通道）
|
||
StartDeviceLogin,
|
||
/// 开始微软授权码登录（拉起系统默认浏览器 + 本地回调，GUI 的默认入口）
|
||
StartBrowserLogin,
|
||
/// 取消/关掉微软登录面板（已发出的请求会在收尾时丢弃结果）
|
||
CancelDeviceLogin,
|
||
/// 加一个第三方皮肤站（authlib-injector）账户：校验服务器 + 密码登录
|
||
///
|
||
/// **凭据红线**：`request.password` 只是这一次的请求值，host 用完即弃，绝不进回程 DTO。
|
||
AddAuthlibAccount(AuthlibRequest),
|
||
/// 只校验第三方皮肤站地址（服务发现）：结果走 `AuthlibLoginChanged`
|
||
ProbeAuthlibServer(String),
|
||
/// 关掉账户页横幅（页面上的 × / Dismiss）
|
||
DismissAccountNotice,
|
||
/// 安装指定发行版的托管 JDK（`temurin` / `oracle` / `microsoft` / `zulu`）
|
||
InstallJava(String),
|
||
/// 写一条设置（`key` 必须是 core schema 里的键）
|
||
SetSetting {
|
||
/// schema 键
|
||
key: String,
|
||
/// 新值（字符串形态；host 按 schema 类型转换）
|
||
value: String,
|
||
},
|
||
/// 关掉一条横幅通知
|
||
DismissNotice(String),
|
||
/// 向 AI 提问（会话状态在 app 侧，agent 只回事件）
|
||
AskAgent(String),
|
||
/// 中断当前 AI 流
|
||
StopAgent,
|
||
/// YOLO 开关（跳过确认，审计照记）
|
||
SetYolo(bool),
|
||
/// 检索内容库（M109；结果经 [`CoreEvent::ContentResults`] 回来）
|
||
SearchContent(ContentQuery),
|
||
/// 把某个内容项目装进指定实例（M109；整合包不支持，host 会拒绝并给原因）
|
||
InstallContent(Box<ContentInstallRequest>),
|
||
// M113: import/export
|
||
/// 整合包导入/导出（M113）：导入 / 预检 / 确认写盘 / 关面板（子枚举见 [`PackCommand`]）
|
||
Pack(Box<PackCommand>),
|
||
}
|
||
|
||
impl AppCommand {
|
||
/// 构造「切换隔离档位」指令（磁贴/详情页共用）。
|
||
pub fn set_isolation(id: &str, mode: &str) -> Self {
|
||
Self::SetIsolation {
|
||
id: id.to_string(),
|
||
mode: mode.to_string(),
|
||
}
|
||
}
|
||
}
|
||
|
||
/// 后端通道：core/agent host 实现它；[`crate::mock::MockBackend`] 验证通道语义。
|
||
///
|
||
/// 轮询模型（而非回调）是为了让 Slint 的定时器成为唯一调度者，
|
||
/// 避免跨线程回调里碰 Slint 模型。
|
||
pub trait Backend {
|
||
/// 取走自上次调用以来积压的事件（FIFO，不可丢序号）。
|
||
fn drain_events(&mut self) -> Vec<AppEvent>;
|
||
|
||
/// 下发一条用户意图。
|
||
fn dispatch(&mut self, command: AppCommand);
|
||
|
||
/// 时间推进（真实后端在这里收后台线程的结果并尾随日志）。
|
||
fn tick(&mut self, elapsed: std::time::Duration) {
|
||
let _ = elapsed;
|
||
}
|
||
}
|
||
|
||
#[cfg(test)]
|
||
mod tests {
|
||
use super::*;
|
||
use crate::dto::{AccountKind, DeviceLoginPhase, InstallStage};
|
||
|
||
#[test]
|
||
fn events_are_serializable_ipc_contracts() {
|
||
let event = AppEvent::Core(CoreEvent::InstallProgress(Some(InstallProgressView {
|
||
stage: InstallStage::Downloading,
|
||
files_done: 3,
|
||
files_total: 9,
|
||
..InstallProgressView::new()
|
||
})));
|
||
let text = serde_json::to_string(&event).expect("序列化");
|
||
let back: AppEvent = serde_json::from_str(&text).expect("反序列化");
|
||
assert_eq!(back, event);
|
||
|
||
let account = AppEvent::Core(CoreEvent::AccountsChanged(vec![AccountView {
|
||
id: "account:1".to_string(),
|
||
name: "Steve".to_string(),
|
||
kind: AccountKind::Offline,
|
||
profile_id: "0f8f".to_string(),
|
||
login_name: String::new(),
|
||
created: "2026-10-31 20:12".to_string(),
|
||
active: true,
|
||
server_url: String::new(),
|
||
skin: None,
|
||
}]));
|
||
let text = serde_json::to_string(&account).expect("序列化");
|
||
let back: AppEvent = serde_json::from_str(&text).expect("反序列化");
|
||
assert_eq!(back, account);
|
||
// 凭据永不跨界：序列化文本里没有 token 类字段
|
||
assert!(!text.to_lowercase().contains("token"));
|
||
}
|
||
|
||
#[test]
|
||
fn commands_round_trip() {
|
||
let command = AppCommand::CreateInstance(CreateRequest {
|
||
version: "1.20.4".to_string(),
|
||
loader: crate::dto::LoaderKind::Fabric,
|
||
loader_version: "0.16.5".to_string(),
|
||
name: "生存".to_string(),
|
||
});
|
||
let text = serde_json::to_string(&command).expect("序列化");
|
||
let back: AppCommand = serde_json::from_str(&text).expect("反序列化");
|
||
assert_eq!(back, command);
|
||
|
||
let login = AppCommand::StartDeviceLogin;
|
||
assert_eq!(
|
||
serde_json::from_str::<AppCommand>(&serde_json::to_string(&login).expect("序列化"))
|
||
.expect("反序列化"),
|
||
login
|
||
);
|
||
assert!(DeviceLoginPhase::Waiting.busy());
|
||
|
||
// 第三方轨（M114）：请求进、状态出，两边都不带 token 字段
|
||
let authlib = AppCommand::AddAuthlibAccount(AuthlibRequest::new(
|
||
"https://littleskin.cn/api/yggdrasil/",
|
||
"me@example.com",
|
||
"hunter2",
|
||
));
|
||
let text = serde_json::to_string(&authlib).expect("序列化");
|
||
assert_eq!(
|
||
serde_json::from_str::<AppCommand>(&text).expect("反序列化"),
|
||
authlib
|
||
);
|
||
|
||
let view = AppEvent::Core(CoreEvent::AuthlibLoginChanged(AuthlibLoginView::reachable(
|
||
"https://littleskin.cn/api/yggdrasil/",
|
||
"LittleSkin",
|
||
)));
|
||
let text = serde_json::to_string(&view).expect("序列化");
|
||
let back: AppEvent = serde_json::from_str(&text).expect("反序列化");
|
||
assert_eq!(back, view);
|
||
assert!(
|
||
!text.to_lowercase().contains("token"),
|
||
"回程视图里不该有 token"
|
||
);
|
||
}
|
||
}
|