diff options
| author | jakka <jakka@jakka.su> | 2025-09-29 18:13:20 +0300 |
|---|---|---|
| committer | jakka <jakka@jakka.su> | 2025-09-29 18:13:20 +0300 |
| commit | ea34fb1b99765a52da5c881c7cc14b1fd30a5c89 (patch) | |
| tree | f4b6f33461c1b692438457e5894ff5659799d1de /src/main.rs | |
| parent | a55cafd74428531b7a1dad252ae1aa0c063db6e7 (diff) | |
rewrote everything in async. waiting for turso to support actual sql features
Diffstat (limited to 'src/main.rs')
| -rw-r--r-- | src/main.rs | 10 |
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>(()) |
