Unlucky-Launcher/crates/presenter/src/host/logs.rs

//! 日志 / 诊断：会话索引 → 会话列表，事件 JSONL → 日志行，规则引擎 → 诊断卡片。
//!
//! 与 CLI `ull logs` / `ull diagnose` 同源（`launch::session_index` + `diagnose` 规则引擎）：
//! 「同一份 jsonl 的两种读法」只有这一处实现（M39 ports/events.rs 的设计）。
//! 实时滚动 = host 每拍尾随启动会话的 JSONL（只读新增字节），不额外开第二条事件通道。

use std::io::{Read, Seek, SeekFrom};
use std::path::{Path, PathBuf};

use serde_json::Value;
use unlucky_core::diagnose::collectors::{ExitSignal, SignalOrigin};
use unlucky_core::diagnose::engine::{Diagnoser, DiagnosisInput};
use unlucky_core::diagnose::loader::RuleLoader;
use unlucky_core::launch::session_index::{self, SessionIndexEntry};

use crate::dto::{
    Diagnosis, DiagnosisReport, LogLevel, LogLine, LogOutcome, LogSession, SessionId,
};

use super::env::HostEnv;

/// 送进规则引擎的默认尾巴行数（与 CLI 同值，避免两条路看到不同证据）。
pub const DEFAULT_TAIL: usize = 2000;

/// 日志页一次最多渲染的行数（超出的截断，避免大文件把 UI 拖死）。
pub const MAX_RENDERED_LINES: usize = 2_000;

/// 会话索引目录（`.ULL/data/agent/sessions`）。
pub fn root(env: &HostEnv) -> PathBuf {
    env.sessions_root()
}

/// 会话列表（新→旧）。
pub fn sessions(env: &HostEnv) -> Vec<LogSession> {
    let index = session_index::index_path(&root(env));
    let mut entries = session_index::read_all(&index).unwrap_or_default();
    entries.sort_by(|a, b| b.started_at.cmp(&a.started_at));
    entries.iter().map(session_of).collect()
}

/// 索引条目 → 左栏会话行。
pub fn session_of(entry: &SessionIndexEntry) -> LogSession {
    LogSession {
        id: entry.session_id.clone(),
        instance: if entry.instance_name.is_empty() {
            entry.instance_id.clone()
        } else {
            entry.instance_name.clone()
        },
        when: display_time(&entry.started_at),
        outcome: outcome_of(entry),
        duration_secs: entry.duration_ms / 1000,
    }
}

/// 结局：静默失败 > 崩溃（非 0 / crash_found） > 正常。
pub fn outcome_of(entry: &SessionIndexEntry) -> LogOutcome {
    if entry.silent_failure {
        LogOutcome::SilentFail
    } else if entry.crash_found
        || entry.exit_code.is_some_and(|code| code != 0)
        || (entry.exit_code.is_none() && !entry.ended_at.is_empty())
    {
        LogOutcome::Crashed
    } else {
        LogOutcome::Ok
    }
}

/// `2026-10-29T19:22:45.123Z` → `10-29 19:22`。
pub fn display_time(started_at: &str) -> String {
    let body = started_at.trim_end_matches('Z');
    let Some((date, time)) = body.split_once('T') else {
        return started_at.to_string();
    };
    let date = date.get(5..).unwrap_or(date);
    let time = time.get(..5).unwrap_or(time);
    format!("{date} {time}")
}

/// 事件流文件路径（`<sessions>/game/<log_path>`）。
pub fn event_path(env: &HostEnv, entry: &SessionIndexEntry) -> PathBuf {
    root(env).join("game").join(&entry.log_path)
}

/// 会话 id 或唯一前缀 → 索引条目。
fn find(env: &HostEnv, key: &str) -> Option<SessionIndexEntry> {
    let index = session_index::index_path(&root(env));
    let entries = session_index::read_all(&index).ok()?;
    if let Some(exact) = entries.iter().find(|entry| entry.session_id == key) {
        return Some(exact.clone());
    }
    entries
        .iter()
        .find(|entry| entry.session_id.starts_with(key))
        .cloned()
}

/// 事件 JSON → 一行日志（`stdout`/`stderr` 的 `payload.line`）。
pub fn line_of(event: &Value) -> Option<LogLine> {
    let text = event.pointer("/payload/line").and_then(Value::as_str)?;
    let kind = event
        .get("kind")
        .and_then(Value::as_str)
        .unwrap_or_default();
    let level = match event
        .pointer("/payload/level")
        .and_then(Value::as_str)
        .unwrap_or_default()
    {
        "error" => LogLevel::Error,
        "warn" | "warning" => LogLevel::Warn,
        "debug" | "trace" => LogLevel::Debug,
        _ => {
            if kind == "stderr" {
                LogLevel::Warn
            } else {
                LogLevel::Info
            }
        }
    };
    Some(LogLine {
        text: text.to_string(),
        level,
    })
}

/// 整个事件流 → 日志行（解析失败的行跳过，容忍被 kill 时截断的尾行）。
pub fn read_lines(path: &Path) -> Vec<LogLine> {
    let Ok(text) = std::fs::read_to_string(path) else {
        return Vec::new();
    };
    text.lines()
        .filter(|line| !line.trim().is_empty())
        .filter_map(|line| serde_json::from_str::<Value>(line).ok())
        .filter_map(|event| line_of(&event))
        .collect()
}

/// 打开一个会话：日志行 + 规则引擎结论。
pub fn open(env: &HostEnv, key: &str) -> (Vec<LogLine>, Option<DiagnosisReport>) {
    let Some(entry) = find(env, key) else {
        return (Vec::new(), None);
    };
    let path = event_path(env, &entry);
    let lines = read_lines(&path);
    let diagnosis = diagnose_lines(&entry, &lines);
    (lines, diagnosis)
}

/// 规则引擎跑一遍（**规则先跑，模型补位**：这里只出规则结论）。
pub fn diagnose_lines(entry: &SessionIndexEntry, lines: &[LogLine]) -> Option<DiagnosisReport> {
    let stderr_text: String = lines
        .iter()
        .filter(|line| line.level == LogLevel::Error || line.level == LogLevel::Warn)
        .map(|line| line.text.as_str())
        .collect::<Vec<_>>()
        .join("\n");
    let body: String = lines
        .iter()
        .rev()
        .take(DEFAULT_TAIL)
        .map(|line| line.text.as_str())
        .collect::<Vec<_>>()
        .into_iter()
        .rev()
        .collect::<Vec<_>>()
        .join("\n");
    if body.is_empty() {
        return None;
    }
    let error_lines = u32::try_from(
        lines
            .iter()
            .filter(|line| line.level == LogLevel::Error)
            .count(),
    )
    .unwrap_or(u32::MAX);
    let exit = ExitSignal::classify(
        entry.exit_code,
        Some(entry.duration_ms),
        error_lines,
        &stderr_text,
    );
    let mut input = DiagnosisInput::new().with_exit(exit);
    input.push_text(SignalOrigin::Stderr, body);
    let loader = RuleLoader::embedded();
    let report = Diagnoser::new(loader.rule_set().rules().to_vec()).analyze(&input);
    let finding = report
        .findings
        .first()
        .or_else(|| report.secondary.first())?;
    Some(DiagnosisReport {
        session: entry.session_id.clone(),
        diagnosis: Diagnosis {
            rule: finding.rule_id.clone(),
            title: finding.message.clone(),
            confidence: confidence_percent(finding.confidence),
            hint: finding.detail.clone().unwrap_or_else(|| {
                report
                    .exit
                    .as_ref()
                    .map(|exit| exit.exit_type.as_str().to_string())
                    .unwrap_or_else(|| "未知退出".to_string())
            }),
            fix: finding
                .materialized_actions()
                .first()
                .map(|action| action.tool.to_string()),
        },
    })
}

/// 0.0~1.0 → 0~100（四舍五入）。
pub fn confidence_percent(confidence: f32) -> u8 {
    let percent = (confidence.clamp(0.0, 1.0) * 100.0).round();
    u8::try_from(percent as u32).unwrap_or(100)
}

/// 导入崩溃日志（`hs_err_pid*.log` / `crash-*.txt` / `latest.log`）做规则分析。
///
/// 文件名含 `hs_err` 时先走 `hs_err::parse`（结构化字段进规则引擎），否则整份文本当信号喂进去。
pub fn analyze_crash_file(path: &str) -> Result<(String, DiagnosisReport), String> {
    let path = Path::new(path);
    if !path.is_file() {
        return Err(format!("找不到崩溃日志：{}", path.display()));
    }
    let text = std::fs::read_to_string(path).map_err(|error| format!("读崩溃日志失败：{error}"))?;
    let name = path
        .file_name()
        .map(|name| name.to_string_lossy().to_string())
        .unwrap_or_else(|| "crash.log".to_string());
    let is_hs_err = name.contains("hs_err");
    let mut input = DiagnosisInput::new();
    if is_hs_err {
        input.push_hs_err(unlucky_core::diagnose::hs_err::parse(&text));
    }
    input.push_text(
        if is_hs_err {
            SignalOrigin::HsErr
        } else if name.contains("crash") {
            SignalOrigin::CrashReport
        } else {
            SignalOrigin::LatestLog
        },
        text,
    );
    let loader = RuleLoader::embedded();
    let report = Diagnoser::new(loader.rule_set().rules().to_vec()).analyze(&input);
    let finding = report
        .findings
        .first()
        .or_else(|| report.secondary.first())
        .ok_or_else(|| "规则引擎没有从这份日志里认出已知问题".to_string())?;
    Ok((
        format!("导入的日志：{name}"),
        DiagnosisReport {
            session: format!("file:{name}"),
            diagnosis: Diagnosis {
                rule: finding.rule_id.clone(),
                title: finding.message.clone(),
                confidence: confidence_percent(finding.confidence),
                hint: finding
                    .detail
                    .clone()
                    .unwrap_or_else(|| "规则引擎命中（详见证据行）".to_string()),
                fix: finding
                    .materialized_actions()
                    .first()
                    .map(|action| action.tool.to_string()),
            },
        },
    ))
}

/// 实时尾随器：只读文件新增的字节，解析出完整的 JSON 行。
#[derive(Debug, Default)]
pub struct Tail {
    path: Option<PathBuf>,
    session: Option<SessionId>,
    offset: u64,
}

impl Tail {
    /// 开始尾随一个会话。
    pub fn attach(&mut self, path: PathBuf, session: &str) {
        self.path = Some(path);
        self.session = Some(session.to_string());
        self.offset = 0;
    }

    /// 停止尾随。
    pub fn detach(&mut self) {
        self.path = None;
        self.session = None;
        self.offset = 0;
    }

    /// 当前尾随的会话。
    pub fn session(&self) -> Option<&str> {
        self.session.as_deref()
    }

    /// 读新行（返回 `(会话 id, 新行)`；没有新内容返回 `None`）。
    pub fn poll(&mut self) -> Option<(String, Vec<LogLine>)> {
        let path = self.path.clone()?;
        let session = self.session.clone()?;
        let file = std::fs::File::open(&path).ok()?;
        let len = file.metadata().ok()?.len();
        if len <= self.offset {
            return None;
        }
        let mut file = file;
        file.seek(SeekFrom::Start(self.offset)).ok()?;
        let mut buffer = String::new();
        file.read_to_string(&mut buffer).ok()?;
        // 只吃到最后一个换行：半行留到下一拍（避免把 JSON 截断解析成脏行）
        let last_newline = buffer.rfind('\n')?;
        let complete = &buffer[..=last_newline];
        self.offset += u64::try_from(complete.len()).unwrap_or(u64::MAX);
        let lines: Vec<LogLine> = complete
            .lines()
            .filter(|line| !line.trim().is_empty())
            .filter_map(|line| serde_json::from_str::<Value>(line).ok())
            .filter_map(|event| line_of(&event))
            .collect();
        Some((session, lines))
    }
}

/// 会话是否已收尾（索引里出现 `ended_at` 或文件停止增长超过一拍）。
pub fn session_finished(env: &HostEnv, session: &str) -> bool {
    let index = session_index::index_path(&root(env));
    session_index::read_all(&index)
        .unwrap_or_default()
        .iter()
        .any(|entry| entry.session_id == session && !entry.ended_at.is_empty())
}

#[cfg(test)]
#[path = "logs_tests.rs"]
mod tests;