diff options
| author | metamuffin <metamuffin@disroot.org> | 2025-12-11 01:20:17 +0100 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2025-12-11 01:20:17 +0100 |
| commit | 6e5f6d9b9c6fedb4ab80190c156595d321d33bbf (patch) | |
| tree | b6c2140e744fc3018ad08975afefad40386ebbc6 /logic/src | |
| parent | e4f865e9da9d6660399e22a6fbeb5b84a749b07a (diff) | |
| download | jellything-6e5f6d9b9c6fedb4ab80190c156595d321d33bbf.tar jellything-6e5f6d9b9c6fedb4ab80190c156595d321d33bbf.tar.bz2 jellything-6e5f6d9b9c6fedb4ab80190c156595d321d33bbf.tar.zst | |
refactor import plugins part 3
Diffstat (limited to 'logic/src')
| -rw-r--r-- | logic/src/admin/mod.rs | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/logic/src/admin/mod.rs b/logic/src/admin/mod.rs index 2877299..fb1e59f 100644 --- a/logic/src/admin/mod.rs +++ b/logic/src/admin/mod.rs @@ -11,8 +11,7 @@ use crate::{DATABASE, session::Session}; use anyhow::{Result, anyhow}; use jellyimport::{import_wrap, reporting::IMPORT_ERRORS}; use rand::Rng; -use std::time::{Duration, Instant}; -use tokio::task::spawn_blocking; +use tokio::{spawn, task::spawn_blocking}; pub async fn get_import_errors(_session: &Session) -> Vec<String> { IMPORT_ERRORS.read().await.to_owned() @@ -39,12 +38,11 @@ pub async fn update_search_index(session: &Session) -> Result<()> { session.assert_admin()?; spawn_blocking(move || DATABASE.search_create_index()).await? } -pub async fn do_import(session: &Session, incremental: bool) -> Result<(Duration, Result<()>)> { +pub async fn do_import(session: &Session, incremental: bool) -> Result<()> { session.assert_admin()?; - let t = Instant::now(); if !incremental { DATABASE.clear_nodes()?; } - let r = import_wrap((*DATABASE).clone(), incremental).await; - Ok((t.elapsed(), r)) + spawn(import_wrap((*DATABASE).clone(), incremental)); + Ok(()) } |