summaryrefslogtreecommitdiff
path: root/src/main.rs
diff options
context:
space:
mode:
authorjakka <jakka@jakka.su>2025-09-29 18:13:20 +0300
committerjakka <jakka@jakka.su>2025-09-29 18:13:20 +0300
commitea34fb1b99765a52da5c881c7cc14b1fd30a5c89 (patch)
treef4b6f33461c1b692438457e5894ff5659799d1de /src/main.rs
parenta55cafd74428531b7a1dad252ae1aa0c063db6e7 (diff)
rewrote everything in async. waiting for turso to support actual sql features
Diffstat (limited to 'src/main.rs')
-rw-r--r--src/main.rs10
1 files changed, 3 insertions, 7 deletions
diff --git a/src/main.rs b/src/main.rs
index 2ef2491..e9543f8 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -91,11 +91,7 @@ fn main() -> Result<()> {
})?;
smol::block_on(async move {
- let path = if let Some(path) = args.get_one::<PathBuf>("db") {
- Some(path.as_path())
- } else {
- None
- };
+ let path = args.get_one::<PathBuf>("db");
let db = db::init_db(path).await?;
if path.is_none() && !args.get_flag("clean") && !args.get_flag("doit") {
@@ -111,13 +107,13 @@ fn main() -> Result<()> {
if args.get_flag("clean") {
let handler = running.clone();
- files::clean_files(&db.connect()?, handler)?;
+ files::clean_files(&db.connect()?, handler).await?;
}
if args.get_flag("doit") {
let hanlder = running.clone();
let threads = *args.get_one::<usize>("threads").unwrap();
- files::reencode_files(db.connect()?, hanlder, threads).await?;
+ files::reencode_files(&db.connect()?, hanlder, threads).await?;
}
Ok::<(), anyhow::Error>(())