Struct NotifyFutureResourceUsageChangesUseCase 

pub struct NotifyFutureResourceUsageChangesUseCase<R, N>
where
    R: ResourceUsageRepository,
    N: Notifier,
{ /* private fields */ }

未来および進行中のリソース使用状況の変更を監視し、通知するユースケース

このユースケースは以下の変更を検知して通知します:

• 新規作成: 新しいリソース使用予約が追加された
• 更新: 既存の予約内容が変更された
• 削除: 未来の予約がキャンセル/削除された

スコープ

このユースケースは「未来および進行中」のリソース使用のみを監視対象とします。 予約期間が終了したリソースは自然に監視対象外となり、削除通知は送信されません。

Implementations

impl<R, N> NotifyFutureResourceUsageChangesUseCase<R, N>

where R: ResourceUsageRepository, N: Notifier,

pub async fn new( repository: Arc<R>, notifier: N, ) -> Result<Self, ApplicationError>

新しいインスタンスを作成し、初期状態を取得する

Arguments

• repository - リソース使用リポジトリ（Arc で共有）
• notifier - 通知サービス

Errors

リポジトリから初期状態の取得に失敗した場合

Examples found in repository

examples/mock_usage.rs (line 37)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🚀 Starting resource usage watcher (mock example)");
    println!("This example uses mock implementations - no credentials required!\n");

    // Load configuration
    let config = load_config("config/resources.toml")?;

    // Create identity link repository
    let identity_repo = Arc::new(JsonFileIdentityLinkRepository::new(
        "data/identity_links.json".into(),
    ));

    // Create mock repository and notification router
    let repository = Arc::new(MockUsageRepository::new());
    let notifier = NotificationRouter::new(config, identity_repo);

    println!("✅ Mock repository and notification router initialized");

    // Create use case
    let usecase = NotifyFutureResourceUsageChangesUseCase::new(repository, notifier).await?;

    // Poll once to demonstrate
    println!("📊 Polling for changes...\n");
    usecase.poll_once().await?;

    println!("\n✅ Example completed successfully!");
    println!("💡 Note: Mock repository returns empty results by default.");
    println!(
        "   To see actual notifications, configure mock notifications in config/resources.toml"
    );

    Ok(())
}

examples/basic_usage.rs (line 59)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🚀 Starting resource usage watcher (basic example)");

    // Load resource configuration
    let config_path =
        std::env::var("RESOURCE_CONFIG").unwrap_or_else(|_| "config/resources.toml".to_string());

    let config = load_config(&config_path)?;
    println!("✅ Configuration loaded");

    // Create repository
    let service_account_key = std::env::var("GOOGLE_SERVICE_ACCOUNT_KEY")
        .expect("GOOGLE_SERVICE_ACCOUNT_KEY must be set");

    let id_mappings_path = std::env::var("GOOGLE_CALENDAR_MAPPINGS_FILE")
        .unwrap_or_else(|_| "data/google_calendar_mappings.json".to_string());

    let repository = Arc::new(
        GoogleCalendarUsageRepository::new(
            &service_account_key,
            config.clone(),
            PathBuf::from(&id_mappings_path),
        )
        .await?,
    );
    println!("✅ Google Calendar repository initialized");

    // Create identity link repository
    let identity_links_path = std::env::var("IDENTITY_LINKS_FILE")
        .unwrap_or_else(|_| "data/identity_links.json".to_string());
    let identity_repo = Arc::new(JsonFileIdentityLinkRepository::new(PathBuf::from(
        identity_links_path,
    )));

    // Create notification router (uses configured notification destinations and identity_repo)
    let notifier = NotificationRouter::new(config, identity_repo);
    println!("✅ Notification router initialized (using configured destinations)");

    // Create use case
    let usecase = NotifyFutureResourceUsageChangesUseCase::new(repository, notifier).await?;

    // Run polling loop
    let interval = Duration::from_secs(60);
    println!("🔍 Starting monitoring loop (interval: {:?})", interval);
    println!("Press Ctrl+C to stop\n");

    loop {
        match usecase.poll_once().await {
            Ok(_) => {
                println!("✅ Poll completed successfully");
            }
            Err(e) => {
                eprintln!("❌ Polling error: {}", e);
            }
        }

        tokio::time::sleep(interval).await;
    }
}

pub async fn poll_once(&self) -> Result<(), ApplicationError>

一度だけポーリングを実行し、変更を検知して通知する

前回の状態と現在の状態を比較し、作成・更新・削除された予約を検知して通知します。

Errors

リポジトリアクセスまたは通知送信に失敗した場合

Examples found in repository

examples/mock_usage.rs (line 41)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🚀 Starting resource usage watcher (mock example)");
    println!("This example uses mock implementations - no credentials required!\n");

    // Load configuration
    let config = load_config("config/resources.toml")?;

    // Create identity link repository
    let identity_repo = Arc::new(JsonFileIdentityLinkRepository::new(
        "data/identity_links.json".into(),
    ));

    // Create mock repository and notification router
    let repository = Arc::new(MockUsageRepository::new());
    let notifier = NotificationRouter::new(config, identity_repo);

    println!("✅ Mock repository and notification router initialized");

    // Create use case
    let usecase = NotifyFutureResourceUsageChangesUseCase::new(repository, notifier).await?;

    // Poll once to demonstrate
    println!("📊 Polling for changes...\n");
    usecase.poll_once().await?;

    println!("\n✅ Example completed successfully!");
    println!("💡 Note: Mock repository returns empty results by default.");
    println!(
        "   To see actual notifications, configure mock notifications in config/resources.toml"
    );

    Ok(())
}

examples/basic_usage.rs (line 67)

async fn main() -> Result<(), Box<dyn std::error::Error>> {
    println!("🚀 Starting resource usage watcher (basic example)");

    // Load resource configuration
    let config_path =
        std::env::var("RESOURCE_CONFIG").unwrap_or_else(|_| "config/resources.toml".to_string());

    let config = load_config(&config_path)?;
    println!("✅ Configuration loaded");

    // Create repository
    let service_account_key = std::env::var("GOOGLE_SERVICE_ACCOUNT_KEY")
        .expect("GOOGLE_SERVICE_ACCOUNT_KEY must be set");

    let id_mappings_path = std::env::var("GOOGLE_CALENDAR_MAPPINGS_FILE")
        .unwrap_or_else(|_| "data/google_calendar_mappings.json".to_string());

    let repository = Arc::new(
        GoogleCalendarUsageRepository::new(
            &service_account_key,
            config.clone(),
            PathBuf::from(&id_mappings_path),
        )
        .await?,
    );
    println!("✅ Google Calendar repository initialized");

    // Create identity link repository
    let identity_links_path = std::env::var("IDENTITY_LINKS_FILE")
        .unwrap_or_else(|_| "data/identity_links.json".to_string());
    let identity_repo = Arc::new(JsonFileIdentityLinkRepository::new(PathBuf::from(
        identity_links_path,
    )));

    // Create notification router (uses configured notification destinations and identity_repo)
    let notifier = NotificationRouter::new(config, identity_repo);
    println!("✅ Notification router initialized (using configured destinations)");

    // Create use case
    let usecase = NotifyFutureResourceUsageChangesUseCase::new(repository, notifier).await?;

    // Run polling loop
    let interval = Duration::from_secs(60);
    println!("🔍 Starting monitoring loop (interval: {:?})", interval);
    println!("Press Ctrl+C to stop\n");

    loop {
        match usecase.poll_once().await {
            Ok(_) => {
                println!("✅ Poll completed successfully");
            }
            Err(e) => {
                eprintln!("❌ Polling error: {}", e);
            }
        }

        tokio::time::sleep(interval).await;
    }
}