Struct AirClient 

pub struct AirClient {
    client: Option<Arc<Mutex<AirServiceClient<Channel>>>>,
    address: String,
}

Air gRPC client wrapper that handles connection to the Air daemon service. This provides a clean interface for Mountain to interact with Air’s capabilities including update management, authentication, file indexing, and system monitoring.

Fields

client: Option<Arc<Mutex<AirServiceClient<Channel>>>>

The underlying tonic gRPC client wrapped in Arc<Mutex<>> for thread-safe access

address: String

Address of the Air daemon

Implementations

impl AirClient

pub async fn new(address: &str) -> Result<Self, CommonError>

Creates a new AirClient and connects to the Air daemon service.

Arguments

• address - The gRPC server address (e.g., “http://\[::1\]:50053”)

Returns

• Ok(Self) - Successfully created client
• Err(CommonError) - Connection failure with descriptive error

Example

use Mountain::Air::AirClient::{AirClient, DEFAULT_AIR_SERVER_ADDRESS};

# #[tokio::main]
# async fn main() -> Result<(), Box<dyn std::error::Error>> {
let client = AirClient::new(DEFAULT_AIR_SERVER_ADDRESS).await?;
# Ok(())
# }

pub fn is_connected(&self) -> bool

Checks if the client is connected to the Air daemon.

Returns

• true - Client is connected
• false - Client is not connected

pub fn address(&self) -> &str

Gets the address of the Air daemon.

Returns

The address string

pub async fn authenticate( &self, request_id: String, username: String, password: String, provider: String, ) -> Result<String, CommonError>

Authenticates a user with the Air daemon.

Arguments

• username - User’s username
• password - User’s password
• provider - Authentication provider (e.g., “github”, “gitlab”, “microsoft”)

Returns

• Ok(token) - Authentication token if successful
• Err(CommonError) - Authentication failure

pub async fn check_for_updates( &self, request_id: String, current_version: String, channel: String, ) -> Result<UpdateInfo, CommonError>

Checks for available updates.

Arguments

• current_version - Current application version
• channel - Update channel (e.g., “stable”, “beta”, “nightly”)

Returns

• Ok(update_info) - Update information if available
• Err(CommonError) - Check failure

pub async fn download_update( &self, request_id: String, url: String, destination_path: String, checksum: String, headers: HashMap<String, String>, ) -> Result<FileInfo, CommonError>

Downloads an update package.

Arguments

• url - URL of the update package
• destination_path - Local path to save the downloaded file
• checksum - Optional SHA256 checksum for verification
• headers - Optional HTTP headers

Returns

• Ok(file_info) - Downloaded file information
• Err(CommonError) - Download failure

pub async fn apply_update( &self, request_id: String, version: String, update_path: String, ) -> Result<(), CommonError>

Applies an update package.

Arguments

• version - Version of the update
• update_path - Path to the update package

Returns

• Ok(()) - Update applied successfully
• Err(CommonError) - Application failure

pub async fn download_file( &self, request_id: String, url: String, destination_path: String, checksum: String, headers: HashMap<String, String>, ) -> Result<FileInfo, CommonError>

Downloads a file.

Arguments

• url - URL of the file to download
• destination_path - Local path to save the downloaded file
• checksum - Optional SHA256 checksum for verification
• headers - Optional HTTP headers

Returns

• Ok(file_info) - Downloaded file information
• Err(CommonError) - Download failure

pub async fn download_stream( &self, request_id: String, url: String, headers: HashMap<String, String>, ) -> Result<DownloadStream, CommonError>

Downloads a file as a stream.

This method initiates a streaming download from the given URL, returning a stream of chunks that can be processed incrementally without loading the entire file into memory.

Arguments

• request_id - Unique request identifier
• url - URL of the file to download
• headers - Optional HTTP headers

Returns

• Ok(stream) - Stream that yields download chunks
• Err(CommonError) - Download initiation failure

Stream Chunk Information

Each chunk contains:

• chunk: The binary data chunk
• total_size: Total file size (if known)
• downloaded: Number of bytes downloaded so far
• completed: Whether this is the final chunk
• error: Error message if download failed

Example

use Mountain::Air::AirClient::AirClient;
use CommonLibrary::Error::CommonError::CommonError;

# #[tokio::main]
# async fn main() -> Result<(), CommonError> {
# let client = AirClient::new("http://[::1]:50053").await?;
let mut stream = client
	.download_stream(
		"req-123".to_string(),
		"https://example.com/large-file.zip".to_string(),
		std::collections::HashMap::new(),
	)
	.await?;

let mut buffer = Vec::new();
while let Some(chunk) = stream.next().await {
	let chunk = chunk?;
	buffer.extend_from_slice(&chunk.data);
	println!("Downloaded: {} / {} bytes", chunk.downloaded, chunk.total_size);
	if chunk.completed {
		break;
	}
}
# Ok(())
# }

pub async fn index_files( &self, request_id: String, path: String, patterns: Vec<String>, exclude_patterns: Vec<String>, max_depth: u32, ) -> Result<IndexInfo, CommonError>

Indexes files in a directory.

Arguments

• path - Path to the directory to index
• patterns - File patterns to include
• exclude_patterns - File patterns to exclude
• max_depth - Maximum depth for recursion

Returns

• Ok(index_info) - Index information
• Err(CommonError) - Indexing failure

pub async fn search_files( &self, request_id: String, query: String, path: String, max_results: u32, ) -> Result<Vec<FileResult>, CommonError>

Searches for files matching a query.

Arguments

• query - Search query string
• path - Path to search in
• max_results - Maximum number of results to return

Returns

• Ok(results) - Search results
• Err(CommonError) - Search failure

pub async fn get_file_info( &self, request_id: String, path: String, ) -> Result<ExtendedFileInfo, CommonError>

Gets file information.

Arguments

• path - Path to the file

Returns

• Ok(file_info) - File information
• Err(CommonError) - Request failure

pub async fn get_status( &self, request_id: String, ) -> Result<AirStatus, CommonError>

Gets the status of the Air daemon.

Returns

• Ok(status) - Air daemon status
• Err(CommonError) - Request failure

pub async fn health_check(&self) -> Result<bool, CommonError>

Performs a health check on the Air daemon.

Returns

• Ok(healthy) - Health status
• Err(CommonError) - Check failure

pub async fn get_metrics( &self, request_id: String, metric_type: Option<String>, ) -> Result<AirMetrics, CommonError>

Gets metrics from the Air daemon.

Arguments

• metric_type - Type of metrics (e.g., “performance”, “resources”, “requests”)

Returns

• Ok(metrics) - Metrics data
• Err(CommonError) - Request failure

pub async fn get_resource_usage( &self, request_id: String, ) -> Result<ResourceUsage, CommonError>

Gets resource usage information.

Arguments

• request_id - Unique request identifier

Returns

• Ok(usage) - Resource usage data
• Err(CommonError) - Request failure

pub async fn set_resource_limits( &self, request_id: String, memory_limit_mb: u32, cpu_limit_percent: u32, disk_limit_mb: u32, ) -> Result<(), CommonError>

Sets resource limits.

Arguments

• request_id - Unique request identifier
• memory_limit_mb - Memory limit in MB
• cpu_limit_percent - CPU limit as percentage
• disk_limit_mb - Disk limit in MB

Returns

• Ok(()) - Limits set successfully
• Err(CommonError) - Set failure

pub async fn get_configuration( &self, request_id: String, section: String, ) -> Result<HashMap<String, String>, CommonError>

Gets configuration.

Arguments

• section - Configuration section (e.g., “grpc”, “authentication”, “updates”)

Returns

• Ok(config) - Configuration data
• Err(CommonError) - Request failure

pub async fn update_configuration( &self, request_id: String, section: String, updates: HashMap<String, String>, ) -> Result<(), CommonError>

Updates configuration.

Arguments

• section - Configuration section
• updates - Configuration updates

Returns

• Ok(()) - Configuration updated successfully
• Err(CommonError) - Update failure

Trait Implementations

impl Clone for AirClient

fn clone(&self) -> AirClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AirClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.