RTSDA/livestream-archiver
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Prevent reprocessing of old files by checking for existing output files

Browse source
This commit is contained in:
RTSDA 2025-04-20 10:05:16 -04:00
parent 6509ad8f58
commit bde1ca72c3
1 changed files with 31 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
src/main.rs
View file

@ -34,10 +34,38 @@ async fn main() -> Result<()> {
for entry in entries {
if let Ok(entry) = entry {
let path = entry.path();
println!("Found existing file: {}", path.display());
// Only process .mp4 files
if path.extension().and_then(|ext| ext.to_str()) == Some("mp4") {
// Extract date from filename to check if output exists
if let Some(filename) = path.file_name().and_then(|f| f.to_str()) {
if let Ok(date) = archiver.extract_date_from_filename(filename).await {
// Check if either Divine Worship or Afternoon Program exists for this date
let year_dir = output_path.join(date.format("%Y").to_string());
let month_dir = year_dir.join(format!("{}-{}",
date.format("%m"),
date.format("%B")
));
let divine_worship_file = month_dir.join(format!(
"Divine Worship Service - RTSDA | {}.mp4",
date.format("%B %d %Y")
));
let afternoon_program_file = month_dir.join(format!(
"Afternoon Program - RTSDA | {}.mp4",
date.format("%B %d %Y")
));
if !divine_worship_file.exists() && !afternoon_program_file.exists() {
println!("Found unprocessed file: {}", path.display());
if let Err(e) = archiver.process_file(path).await {
eprintln!("Error processing existing file: {}", e);
}
} else {
println!("Skipping already processed file: {}", path.display());
}
}
}
}
}
}
}