diff --git a/src/service/media/mod.rs b/src/service/media/mod.rs index 3cb8fda8..9b1cbe06 100644 --- a/src/service/media/mod.rs +++ b/src/service/media/mod.rs @@ -3,6 +3,7 @@ mod tests; use std::{collections::HashMap, io::Cursor, num::Saturating as Sat, path::PathBuf, sync::Arc, time::SystemTime}; +use async_trait::async_trait; use base64::{engine::general_purpose, Engine as _}; use conduit::{checked, debug, debug_error, error, utils, Error, Result, Server}; use data::Data; @@ -47,6 +48,7 @@ pub struct Service { pub url_preview_mutex: RwLock>>>, } +#[async_trait] impl crate::Service for Service { fn build(args: crate::Args<'_>) -> Result> { Ok(Arc::new(Self { @@ -56,6 +58,12 @@ impl crate::Service for Service { })) } + async fn worker(self: Arc) -> Result<()> { + self.create_media_dir().await?; + + Ok(()) + } + fn name(&self) -> &str { crate::service::make_name(std::module_path!()) } } diff --git a/src/service/services.rs b/src/service/services.rs index 62e73fd1..88b58299 100644 --- a/src/service/services.rs +++ b/src/service/services.rs @@ -93,7 +93,6 @@ impl Services { pub(super) async fn start(&self) -> Result<()> { debug_info!("Starting services..."); - self.media.create_media_dir().await?; globals::migrations::migrations(&self.db, &self.globals.config).await?; globals::emerg_access::init_emergency_access();