perf(sns): parse_post_xml 单走 roxmltree DOM,去掉 regex+DOM 双解析

之前一份 SnsTimeLine.content 在 q_sns_feed / q_sns_search 全表扫描时
要被解两次:extract_xml_text 走字符串扫描取 createTime / contentDesc
/ username,parse_post_media 再 build 一次完整 roxmltree DOM 取媒体
列表。10k+ 行扫描时是显式的工作浪费。

本次重构:

- parse_post_xml 一次性 Document::parse,定位到 TimelineObject 之后所有
  字段(createTime / contentDesc / username / media / location)共用同
  一个 doc,roxmltree 只 build 一次。
- 把 parse_post_media 拆成 parse_media_from_timeline(node),避免外部
  parse 之后又重新 parse;旧的 parse_post_media(&str) 单测专用,标
  #[cfg(test)]。
- 删除 sns_location_re(不再需要 regex 抽 poiName)。
- 副作用:roxmltree 自动解码 XML entity,所以 content / location /
  username 字段输出的是解码后文本(旧版字符串扫描原样保留 `<` 等)。
  对下游是更正确的语义;新增 parse_decodes_xml_entities_in_content 单
  测把行为锁住。
- 新增 parse_returns_defaults_for_malformed_xml 单测覆盖 DOM parse 失败
  时的 fallback 路径(不 panic、author 走 column fallback)。

q_sns_search 的 LIKE 预筛仍走 extract_xml_text(contentDesc) 字符串扫描
做 false-positive 过滤——这一步比 build 一棵 DOM 更快,是真优化,保
留。q_sns_notifications 也仍用 extract_xml_text,本 PR 不动(每次只跑
~limit 条,DOM 化收益小,避免扩大 scope)。

验证:
- cargo check ×3 target (darwin / windows-gnu / linux-gnu)
- cargo test 39 passed (37 → 39,新增 2 个)
pull/17/head
jackwener 2026-04-19 02:36:39 +08:00
parent 2b5d872f0b
commit d1b1f58d41
1 changed files with 72 additions and 26 deletions

View File

@ -1635,12 +1635,6 @@ pub async fn q_sns_notifications(
Ok(json!({ "notifications": out, "total": total }))
}
fn sns_location_re() -> &'static Regex {
static RE: OnceLock<Regex> = OnceLock::new();
// location 是自闭合标签poiName 在属性里
RE.get_or_init(|| Regex::new(r#"<location[^>]*poiName="([^"]*)""#).unwrap())
}
// 朋友圈扫描的硬上限:单次查询最多解析这么多行 SnsTimeLine
// 防止用户传超大 limit 或者底层数据异常时把 daemon 卡住。
// 当前账号 ~10k+ 帖子5w 上限留足缓冲。
@ -1686,20 +1680,11 @@ fn insert_media_i64(out: &mut serde_json::Map<String, Value>, key: &str, value:
}
}
/// 从 `SnsTimeLine.content` XML 里抽每个 `<media>` 的完整字段。
///
/// 从已经定位到的 `<TimelineObject>` 节点里抽 `<mediaList>/<media>` 数组。
/// 字段名与 artifacts 仓库 `wechat_sns_dump.py::_parse_media` 对齐,
/// 便于跨实现 diff。缺失字段直接省略不输出 null供下游代理图片 / 离线渲染。
fn parse_post_media(xml: &str) -> Vec<Value> {
let doc = match Document::parse(xml) {
Ok(doc) => doc,
Err(_) => return Vec::new(),
};
let Some(media_list) = doc
.descendants()
.find(|node| node.has_tag_name("TimelineObject"))
.and_then(|node| xml_child(node, "ContentObject"))
fn parse_media_from_timeline(timeline: Node) -> Vec<Value> {
let Some(media_list) = xml_child(timeline, "ContentObject")
.and_then(|node| xml_child(node, "mediaList"))
else {
return Vec::new();
@ -1756,6 +1741,17 @@ fn parse_post_media(xml: &str) -> Vec<Value> {
.collect()
}
/// 从 `SnsTimeLine.content` 整段 XML 抽 media[]。仅供单测使用 —— 生产路径走
/// `parse_post_xml`,那边已经把整份 doc parse 一次直接复用 timeline 节点。
#[cfg(test)]
fn parse_post_media(xml: &str) -> Vec<Value> {
let Ok(doc) = Document::parse(xml) else { return Vec::new(); };
let Some(timeline) = doc.descendants().find(|n| n.has_tag_name("TimelineObject")) else {
return Vec::new();
};
parse_media_from_timeline(timeline)
}
/// SnsTimeLine 行解析产物。不含 display name依赖 Names需要出 spawn_blocking 再补)。
struct ParsedPost {
tid: i64,
@ -1768,22 +1764,51 @@ struct ParsedPost {
/// 纯 XML 解析,无 Names 依赖,可以在 spawn_blocking 里跑。
/// user_name_column 为空时从 TimelineObject/<username> 兜底(转发帖)。
///
/// 单 roxmltree DOM 解析一次出全部字段createTime / contentDesc / username / media / location
/// 取代旧版 regex + DOM 双解析。XML entity 解码(`&lt;` / `&amp;` 等)由 roxmltree 自动处理,
/// 旧版 `extract_xml_text` 是字符串扫描不解码 —— 因此 `content` / `location` / `username` 字段
/// 现在会输出解码后的文本,对下游是更正确的语义。
fn parse_post_xml(tid: i64, user_name_column: &str, content: &str) -> ParsedPost {
let create_time = extract_xml_text(content, "createTime")
let fallback_author = || user_name_column.to_string();
let Ok(doc) = Document::parse(content) else {
return ParsedPost {
tid,
create_time: 0,
author_username: fallback_author(),
content: String::new(),
media: Vec::new(),
location: String::new(),
};
};
let Some(timeline) = doc.descendants().find(|n| n.has_tag_name("TimelineObject")) else {
return ParsedPost {
tid,
create_time: 0,
author_username: fallback_author(),
content: String::new(),
media: Vec::new(),
location: String::new(),
};
};
let create_time = xml_text(xml_child(timeline, "createTime"))
.and_then(|s| s.parse::<i64>().ok())
.unwrap_or(0);
let text = extract_xml_text(content, "contentDesc").unwrap_or_default();
let text = xml_text(xml_child(timeline, "contentDesc")).unwrap_or_default();
let author_username = if user_name_column.is_empty() {
extract_xml_text(content, "username").unwrap_or_default()
xml_text(xml_child(timeline, "username")).unwrap_or_default()
} else {
user_name_column.to_string()
};
let media = parse_post_media(content);
let location = sns_location_re()
.captures(content)
.and_then(|c| c.get(1))
.map(|m| m.as_str().to_string())
let media = parse_media_from_timeline(timeline);
let location = xml_child(timeline, "location")
.and_then(|n| n.attribute("poiName"))
.map(str::to_string)
.unwrap_or_default();
ParsedPost { tid, create_time, author_username, content: text, media, location }
}
@ -2009,6 +2034,27 @@ mod sns_tests {
assert_eq!(p.author_username, "");
}
#[test]
fn parse_decodes_xml_entities_in_content() {
// 单 DOM 解析的副作用roxmltree 自动把 &lt; / &amp; / &quot; 等还原成原字符;
// 旧版 extract_xml_text 字符串扫描不解码,会把 "&lt;world&gt;" 原样输出。
// 新版语义对下游更正确(拿到的就是用户真实内容),把这个行为锁进测试。
let xml = "<TimelineObject><contentDesc>Hello &lt;world&gt; &amp; friends</contentDesc></TimelineObject>";
let p = parse_post_xml(6, "wxid", xml);
assert_eq!(p.content, "Hello <world> & friends");
}
#[test]
fn parse_returns_defaults_for_malformed_xml() {
// DOM 解析失败时返回默认值(不 panic、不漏字段author 走 column fallback。
let p = parse_post_xml(7, "wxid_fallback", "<TimelineObject><not valid xml");
assert_eq!(p.create_time, 0);
assert_eq!(p.content, "");
assert_eq!(p.author_username, "wxid_fallback");
assert!(p.media.is_empty());
assert_eq!(p.location, "");
}
#[test]
fn escape_like_pattern_escapes_backslash_first() {
// 反斜杠必须在 % / _ 之前转义;否则后面塞进去的 \% / \_ 会被再次双转义吃掉