43 lines
1.1 KiB
Rust
43 lines
1.1 KiB
Rust
mod backfill;
|
|
mod config;
|
|
mod handler;
|
|
|
|
pub use backfill::ConversionBackfillJob;
|
|
pub use config::{ConversionConfig, Format};
|
|
pub use handler::ImageConversionHandler;
|
|
|
|
use domain::ports::{
|
|
EventHandler, EventPublisher, ImageRefCommand, ImageRefQuery, ObjectStorage, PeriodicJob,
|
|
};
|
|
use std::sync::Arc;
|
|
|
|
type ConversionPair = (Arc<dyn EventHandler>, Arc<dyn PeriodicJob>);
|
|
|
|
pub fn build(
|
|
config: &::config::ImageConversionConfig,
|
|
object_storage: Arc<dyn ObjectStorage>,
|
|
image_ref_command: Arc<dyn ImageRefCommand>,
|
|
image_ref_query: Arc<dyn ImageRefQuery>,
|
|
event_publisher: Arc<dyn EventPublisher>,
|
|
) -> anyhow::Result<Option<ConversionPair>> {
|
|
let config = match ConversionConfig::from_config(config)? {
|
|
Some(c) => c,
|
|
None => return Ok(None),
|
|
};
|
|
|
|
let format = config.format;
|
|
|
|
let handler = Arc::new(ImageConversionHandler::new(
|
|
Arc::clone(&object_storage),
|
|
image_ref_command,
|
|
format,
|
|
)) as Arc<dyn EventHandler>;
|
|
|
|
let job = Arc::new(ConversionBackfillJob::new(
|
|
image_ref_query,
|
|
Arc::clone(&event_publisher),
|
|
)) as Arc<dyn PeriodicJob>;
|
|
|
|
Ok(Some((handler, job)))
|
|
}
|