xfy/yggdrasil
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix(tasks): skip symlinks during image disk cache cleanup

Browse Source
This commit is contained in:
xfy 2026-06-18 10:10:51 +08:00
parent a71da7473d
commit 12355b7859
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/tasks/image_cache_cleanup.rs
View File

@ -113,6 +113,8 @@ pub async fn cleanup_image_cache_at(
} }
/// 递归收集目录下的所有常规文件，返回路径、大小与修改时间。 /// 递归收集目录下的所有常规文件，返回路径、大小与修改时间。
///
/// 跳过符号链接，避免 traversal 到 `uploads/.cache/` 外部。
async fn collect_files( async fn collect_files(
base: &Path, base: &Path,
entries: &mut Vec<(PathBuf, u64, SystemTime)>, entries: &mut Vec<(PathBuf, u64, SystemTime)>,
@ -121,11 +123,14 @@ async fn collect_files(
while let Some(dir) = stack.pop() { while let Some(dir) = stack.pop() {
let mut reader = tokio::fs::read_dir(&dir).await?; let mut reader = tokio::fs::read_dir(&dir).await?;
while let Some(entry) = reader.next_entry().await? { while let Some(entry) = reader.next_entry().await? {
let metadata = entry.metadata().await?; let file_type = entry.file_type().await?;
if metadata.is_file() { if file_type.is_symlink() {
continue;
} else if file_type.is_file() {
let metadata = entry.metadata().await?;
let mtime = metadata.modified()?; let mtime = metadata.modified()?;
entries.push((entry.path(), metadata.len(), mtime)); entries.push((entry.path(), metadata.len(), mtime));
} else if metadata.is_dir() { } else if file_type.is_dir() {
stack.push(entry.path()); stack.push(entry.path());
} }
} }