lab-resource-manager 1.1.0

use crate::application::error::ApplicationError;
use crate::domain::aggregates::resource_usage::{
    entity::ResourceUsage,
    value_objects::{Resource, TimePeriod, UsageId},
};
use crate::domain::common::EmailAddress;
use crate::domain::ports::repositories::ResourceUsageRepository;
use crate::domain::services::ResourceConflictChecker;
use std::sync::Arc;

/// リソース使用予定を作成するユースケース
pub struct CreateResourceUsageUseCase<R: ResourceUsageRepository> {
    repository: Arc<R>,
    conflict_checker: ResourceConflictChecker,
}

impl<R: ResourceUsageRepository> CreateResourceUsageUseCase<R> {
    /// 新しいCreateResourceUsageUseCaseインスタンスを作成
    ///
    /// # Arguments
    /// * `repository` - ResourceUsageリポジトリ
    pub fn new(repository: Arc<R>) -> Self {
        let conflict_checker = ResourceConflictChecker::new();
        Self {
            repository,
            conflict_checker,
        }
    }

    /// リソース使用予定を作成
    ///
    /// # Arguments
    /// * `owner_email` - 所有者のメールアドレス
    /// * `time_period` - 使用期間
    /// * `resources` - 使用するリソースのリスト
    /// * `notes` - 備考（オプション）
    ///
    /// # Returns
    /// 作成されたResourceUsageのID
    ///
    /// # Errors
    /// - 指定期間と重複するリソース使用がある場合
    /// - リポジトリエラー
    pub async fn execute(
        &self,
        owner_email: EmailAddress,
        time_period: TimePeriod,
        resources: Vec<Resource>,
        notes: Option<String>,
    ) -> Result<UsageId, ApplicationError> {
        // 競合チェック
        self.conflict_checker
            .check_conflicts(self.repository.as_ref(), &time_period, &resources, None)
            .await
            .map_err(|e| match e {
                crate::domain::services::resource_usage::errors::ConflictCheckError::Conflict(
                    conflict_err,
                ) => ApplicationError::ResourceConflict {
                    resource_description: conflict_err.resource_description.clone(),
                    conflicting_usage_id: conflict_err.conflicting_usage_id.as_str().to_string(),
                },
                crate::domain::services::resource_usage::errors::ConflictCheckError::Repository(
                    repo_err,
                ) => ApplicationError::Repository(repo_err),
            })?;

        // 新しいResourceUsageを作成（UUID自動生成）
        let usage = ResourceUsage::new(owner_email, time_period, resources, notes)?;

        // 保存
        self.repository.save(&usage).await?;

        // 生成されたIDを返す
        Ok(usage.id().clone())
    }
}