Struct NotifyResourceUsageChangesUseCase 

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

Implementations

impl<R, N> NotifyResourceUsageChangesUseCase<R, N>

where R: ResourceUsageRepository, N: Notifier,

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

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 = MockUsageRepository::new();
    let notifier = NotificationRouter::new(config, identity_repo);

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

    // Create use case
    let usecase = NotifyResourceUsageChangesUseCase::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 64)

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

    // Load resource configuration
    let dotenv_path = dotenv::dotenv().ok();
    let project_root = dotenv_path
        .as_ref()
        .and_then(|p| p.parent())
        .map(|p| p.to_path_buf())
        .unwrap_or_else(|| std::env::current_dir().expect("Failed to get current directory"));

    let config_path =
        std::env::var("RESOURCE_CONFIG").unwrap_or_else(|_| "config/resources.toml".to_string());
    let absolute_config_path = project_root.join(&config_path);

    let config = load_config(
        absolute_config_path
            .to_str()
            .expect("Failed to convert 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 absolute_key_path = project_root.join(&service_account_key);

    let repository = GoogleCalendarUsageRepository::new(
        absolute_key_path.to_str().expect("Failed to convert path"),
        config.clone(),
    )
    .await?;
    println!("✅ Google Calendar repository initialized");

    // Create identity link repository
    let identity_links_path = std::env::var("IDENTITY_LINKS_FILE")
        .map(|p| project_root.join(p))
        .unwrap_or_else(|_| project_root.join("data/identity_links.json"));
    let identity_repo = Arc::new(JsonFileIdentityLinkRepository::new(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 = NotifyResourceUsageChangesUseCase::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>

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 = MockUsageRepository::new();
    let notifier = NotificationRouter::new(config, identity_repo);

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

    // Create use case
    let usecase = NotifyResourceUsageChangesUseCase::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 72)

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

    // Load resource configuration
    let dotenv_path = dotenv::dotenv().ok();
    let project_root = dotenv_path
        .as_ref()
        .and_then(|p| p.parent())
        .map(|p| p.to_path_buf())
        .unwrap_or_else(|| std::env::current_dir().expect("Failed to get current directory"));

    let config_path =
        std::env::var("RESOURCE_CONFIG").unwrap_or_else(|_| "config/resources.toml".to_string());
    let absolute_config_path = project_root.join(&config_path);

    let config = load_config(
        absolute_config_path
            .to_str()
            .expect("Failed to convert 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 absolute_key_path = project_root.join(&service_account_key);

    let repository = GoogleCalendarUsageRepository::new(
        absolute_key_path.to_str().expect("Failed to convert path"),
        config.clone(),
    )
    .await?;
    println!("✅ Google Calendar repository initialized");

    // Create identity link repository
    let identity_links_path = std::env::var("IDENTITY_LINKS_FILE")
        .map(|p| project_root.join(p))
        .unwrap_or_else(|_| project_root.join("data/identity_links.json"));
    let identity_repo = Arc::new(JsonFileIdentityLinkRepository::new(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 = NotifyResourceUsageChangesUseCase::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;
    }
}