thegeneralist01/archivr
1
Fork 0
mirror of https://github.com/thegeneralist01/archivr synced 2026-05-30 08:36:47 +02:00
Code Issues Activity

Finalize archive runs at command level

Browse source
This commit is contained in:
TheGeneralist 2026-05-29 16:41:02 +02:00
parent c3c1b3d1e4
commit ce3aaa8b76
Signed by: thegeneralist01
SSH key fingerprint: SHA256:pp9qddbCNmVNoSjevdvQvM5z0DHN7LTa8qBMbcMq/R4
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
src/main.rs
View file

@ -518,7 +518,6 @@ fn record_media_entry(
}, },
)?; )?;
database::complete_archive_run_item(conn, item.id, entry.id)?; database::complete_archive_run_item(conn, item.id, entry.id)?;
database::finish_archive_run(conn, run.id)?;
Ok(entry) Ok(entry)
} }
@ -602,7 +601,6 @@ fn record_tweet_entry(
} }
database::complete_archive_run_item(conn, item.id, entry.id)?; database::complete_archive_run_item(conn, item.id, entry.id)?;
database::finish_archive_run(conn, run.id)?;
Ok(entry) Ok(entry)
} }
@ -719,6 +717,7 @@ fn main() -> Result<()> {
source, source,
&tweet_id, &tweet_id,
)?; )?;
database::finish_archive_run(&conn, run.id)?;
println!( println!(
"Tweet archived successfully to {}", "Tweet archived successfully to {}",
store_path.join("raw_tweets").display() store_path.join("raw_tweets").display()
@ -736,6 +735,7 @@ fn main() -> Result<()> {
source, source,
&tweet_id, &tweet_id,
)?; )?;
database::finish_archive_run(&conn, run.id)?;
println!( println!(
"Tweet already archived in {}", "Tweet already archived in {}",
store_path.join("raw_tweets").display() store_path.join("raw_tweets").display()
@ -856,6 +856,7 @@ fn main() -> Result<()> {
&file_extension, &file_extension,
byte_size, byte_size,
)?; )?;
database::finish_archive_run(&conn, run.id)?;
Ok(()) Ok(())
} }