use crate::application::error::ApplicationError;
use crate::domain::aggregates::resource_usage::entity::ResourceUsage;
use crate::domain::ports::repositories::ResourceUsageRepository;
use std::sync::Arc;
pub struct ListAllFutureResourceUsagesUseCase<R: ResourceUsageRepository> {
repository: Arc<R>,
}
impl<R: ResourceUsageRepository> ListAllFutureResourceUsagesUseCase<R> {
pub fn new(repository: Arc<R>) -> Self {
Self { repository }
}
pub async fn execute(&self) -> Result<Vec<ResourceUsage>, ApplicationError> {
let mut usages = self.repository.find_future().await?;
usages.sort_by_key(|a| a.time_period().start());
Ok(usages)
}
}