chore(format)

Signed-off-by: Nikola Hristov <Nikola@PlayForm.Cloud>

Author: NikolaRHristov

Source/Air/AirClient.rs

@@ -15,14 +15,18 @@
 //! - Used by multiple Mountain components:
 //!   - [`UpdateService`](crate::Update::UpdateService) for self-updates
 //!   - [`SearchProvider`](crate::Environment::SearchProvider) for file search
-//!   - [`SecretProvider`](crate::Environment::SecretProvider) for secret storage
-//! - Connection is optional; Mountain can function without Air (graceful degradation)
+//!   - [`SecretProvider`](crate::Environment::SecretProvider) for secret
+//!     storage
+//! - Connection is optional; Mountain can function without Air (graceful
+//!   degradation)
 //! - Service discovery and health checking via gRPC
 //!
 //! MODULE STRUCTURE:
 //! - `AirClient` - gRPC client wrapper with connection management
-//! - `AirServiceProvider` - high-level provider with automatic request ID generation
-//! - `AirServiceTypesStub` - stub types for when Air library is unavailable (legacy)
+//! - `AirServiceProvider` - high-level provider with automatic request ID
+//!   generation
+//! - `AirServiceTypesStub` - stub types for when Air library is unavailable
+//!   (legacy)
 //!
 //! CONNECTION PATTERNS:
 //! - Uses tonic gRPC client for transport
@@ -31,25 +35,30 @@
 //! - Thread-safe operations via Arc<AirClient>
 //!
 //! ERROR HANDLING:
-//! - All gRPC errors translated to [`CommonError::IPCError`](CommonLibrary::Error::CommonError)
+//! - All gRPC errors translated to
+//!   [`CommonError::IPCError`](CommonLibrary::Error::CommonError)
 //! - Connection failures logged and return error
-//! - Service unavailability handled gracefully (return error, caller decides fallback)
+//! - Service unavailability handled gracefully (return error, caller decides
+//!   fallback)
 //!
 //! PERFORMANCE:
 //! - gRPC channels are expensive; reuse via Arc<AirClient>
 //! - Non-blocking async operations via tokio
 //! - Request ID generation for tracing
 //!
 //! VS CODE REFERENCE:
-//! - `vs/platform/telemetry/common/telemetry.ts` - telemetry/analytics service pattern
+//! - `vs/platform/telemetry/common/telemetry.ts` - telemetry/analytics service
+//!   pattern
 //! - `vs/platform/update/common/update.ts` - update service integration
-//! - `vs/workbench/services/search/common/search.ts` - search service architecture
+//! - `vs/workbench/services/search/common/search.ts` - search service
+//!   architecture
 //!
 //! TODO:
 //! - Implement connection retry with exponential backoff
 //! - Add connection pooling for multiple concurrent requests
 //! - Implement request caching for frequently accessed data (auth tokens, etc.)
-//! - Add metrics collection for Air service calls (latency, success rate, errors)
+//! - Add metrics collection for Air service calls (latency, success rate,
+//!   errors)
 //! - Implement fallback strategies when Air unavailable (local search, etc.)
 //! - Support for multiple Air daemons (load balancing/failover)
 //! - Add request timeout configuration (configurable per operation type)
@@ -58,23 +67,35 @@
 //! - Implement bidirectional streaming for real-time updates
 //!
 //! MODULE CONTENTS:
-//! - Re-exports: `AirClient`, `AirServiceProvider`, response types, and helper functions
+//! - Re-exports: `AirClient`, `AirServiceProvider`, response types, and helper
+//!   functions
 
 // Module sub-modules
 pub mod AirClient;
 pub mod AirServiceProvider;
 
 // Access AirClient struct as: crate::Air::AirClient::AirClient
 pub use AirClient::{
-    AirMetrics, AirStatus, DownloadStream, DownloadStreamChunk, ExtendedFileInfo,
-    FileInfo, FileResult, IndexInfo, ResourceUsage, UpdateInfo, DEFAULT_AIR_SERVER_ADDRESS,
+	AirClient,
+	AirMetrics,
+	AirStatus,
+	DEFAULT_AIR_SERVER_ADDRESS,
+	DownloadStream,
+	DownloadStreamChunk,
+	ExtendedFileInfo,
+	FileInfo,
+	FileResult,
+	IndexInfo,
+	ResourceUsage,
+	UpdateInfo,
 };
-pub use AirClient::AirClient;
 pub use AirServiceProvider::generate_request_id;
 
-// Note: AirServiceProvider struct is available via crate::Air::AirServiceProvider::AirServiceProvider
+// Note: AirServiceProvider struct is available via
+// crate::Air::AirServiceProvider::AirServiceProvider
 
 // Stub types for Air integration when AirLibrary is not available (legacy)
-// Note: These are kept for backward compatibility but should not be used in new code
+// Note: These are kept for backward compatibility but should not be used in new
+// code
 #[deprecated(note = "Use AirClient and AirServiceProvider instead")]
 pub mod AirServiceTypesStub;

Source/Air/AirServiceProvider.rs

@@ -17,7 +17,6 @@ use std::collections::HashMap;
 
 use serde::{Deserialize, Serialize};
 use url::Url;
-
 use CommonLibrary::Utility::Serialization::URLSerializationHelper;
 
 /// Maximum length for ViewType string to prevent allocation attacks

Source/Air/mod.rs

@@ -20,14 +20,13 @@
 //! to Air. For now, Mountain handles this synchronously to ensure UI
 //! responsiveness.
 
-use CommonLibrary::Error::CommonError::CommonError;
+use CommonLibrary::{Error::CommonError::CommonError, Utility::Serialization::URLSerializationHelper};
 use serde::{Deserialize, Serialize};
 use serde_json::Value;
 use url::Url;
 
-use super::{RPCRangeDTO::RPCRangeDTO, RPCModelContentChangeDTO::RPCModelContentChangeDTO};
+use super::{RPCModelContentChangeDTO::RPCModelContentChangeDTO, RPCRangeDTO::RPCRangeDTO};
 use crate::ApplicationState::Internal::AnalyzeTextLinesAndEOL;
-use CommonLibrary::Utility::Serialization::URLSerializationHelper;
 
 /// Maximum line count for a document to prevent memory exhaustion
 const MAX_DOCUMENT_LINES:usize = 1_000_000;
@@ -238,7 +237,6 @@ impl DocumentStateDTO {
 /// # Returns
 /// Updated lines vector after applying all changes
 fn ApplyDeltaChanges(Lines:&[String], EOL:&str, RPCChange:&[RPCModelContentChangeDTO]) -> Vec<String> {
-
 	// Join lines into full text for offset-based manipulation
 	let mut ResultText = Lines.join(EOL);
 

Source/ApplicationState/DTO/CustomDocumentStateDTO.rs

@@ -16,10 +16,11 @@
 //! - RelatedInformation: Related diagnostic information
 //! - Tags: Additional marker tags (deprecated, unnecessary)
 
-use super::MarkerSeverity::MarkerSeverity;
 use serde::{Deserialize, Serialize};
 use serde_json::Value;
 
+use super::MarkerSeverity::MarkerSeverity;
+
 /// Maximum message length for a marker
 const MAX_MARKER_MESSAGE_LENGTH:usize = 10_000;
 

Source/ApplicationState/DTO/DocumentStateDTO.rs

@@ -10,9 +10,10 @@
 //! - Range: The range of text to replace
 //! - Text: The new text to insert
 
-use super::RPCRangeDTO::RPCRangeDTO;
 use serde::Deserialize;
 
+use super::RPCRangeDTO::RPCRangeDTO;
+
 /// Represents a single text change operation, including the range to be
 /// replaced and the new text to insert. This is part of a collection sent when
 /// a document is edited.

Source/ApplicationState/DTO/MarkerDataDTO.rs

@@ -11,7 +11,6 @@
 //! - Index: Zero-based position in workspace
 use serde::{Deserialize, Serialize};
 use url::Url;
-
 use CommonLibrary::Utility::Serialization::URLSerializationHelper;
 
 /// Maximum folder name length

Source/ApplicationState/DTO/RPCModelContentChangeDTO.rs

@@ -30,18 +30,14 @@
 //! - [ ] Implement extension caching
 //! - [ ] Add extension validation rules
 
-use std::collections::HashMap;
-use std::path::PathBuf;
+use std::{collections::HashMap, path::PathBuf};
 
 use CommonLibrary::Error::CommonError::CommonError;
 use log::{debug, error, info, trace, warn};
 use serde_json::Value;
 use tauri::AppHandle;
 
-use crate::{
-	ApplicationState::DTO::ExtensionDescriptionStateDTO::ExtensionDescriptionStateDTO,
-	ExtensionManagement,
-};
+use crate::{ApplicationState::DTO::ExtensionDescriptionStateDTO::ExtensionDescriptionStateDTO, ExtensionManagement};
 
 /// Scans all registered extension paths for valid extensions and populates the
 /// state.
@@ -59,16 +55,16 @@ use crate::{
 /// - Returns comprehensive scan statistics
 /// - Handles partial failures gracefully
 pub async fn ScanAndPopulateExtensions(
-	ApplicationHandle: AppHandle,
-	_State: &crate::ApplicationState::ExtensionState::State::State,
+	ApplicationHandle:AppHandle,
+	_State:&crate::ApplicationState::ExtensionState::State::State,
 ) -> Result<(), CommonError> {
 	info!("[ExtensionScanner] Starting extension scan...");
 
-	let mut all_found_extensions: HashMap<String, ExtensionDescriptionStateDTO> = HashMap::new();
+	let mut all_found_extensions:HashMap<String, ExtensionDescriptionStateDTO> = HashMap::new();
 
 	// Note: This would need to be adapted to the new state structure
 	// For now, this is a placeholder showing the structure
-	let scan_paths: Vec<PathBuf> = Vec::new(); // Would get from State.Registry.Extension.Registry.ExtensionScanPaths
+	let scan_paths:Vec<PathBuf> = Vec::new(); // Would get from State.Registry.Extension.Registry.ExtensionScanPaths
 
 	trace!("[ExtensionScanner] Scanning paths: {:?}", scan_paths);
 
@@ -77,12 +73,7 @@ pub async fn ScanAndPopulateExtensions(
 
 	for path in scan_paths {
 		let path_clone = path.clone();
-		match ExtensionManagement::Scanner::ScanDirectoryForExtensions(
-			ApplicationHandle.clone(),
-			path_clone,
-		)
-		.await
-		{
+		match ExtensionManagement::Scanner::ScanDirectoryForExtensions(ApplicationHandle.clone(), path_clone).await {
 			Ok(found_in_path) => {
 				successful_scans += 1;
 				for extension in found_in_path {
@@ -109,7 +100,8 @@ pub async fn ScanAndPopulateExtensions(
 		}
 	}
 
-	// Note: Would populate State.Extension.ScannedExtensions.Extension.ScannedExtensions
+	// Note: Would populate
+	// State.Extension.ScannedExtensions.Extension.ScannedExtensions
 	debug!(
 		"[ExtensionScanner] Extension scan complete. Found {} extensions ({} successful scans, {} failed scans).",
 		all_found_extensions.len(),
@@ -118,10 +110,7 @@ pub async fn ScanAndPopulateExtensions(
 	);
 
 	if failed_scans > 0 {
-		warn!(
-			"[ExtensionScanner] {} extension paths failed to scan",
-			failed_scans
-		);
+		warn!("[ExtensionScanner] {} extension paths failed to scan", failed_scans);
 	}
 
 	Ok(())
@@ -142,20 +131,19 @@ pub async fn ScanAndPopulateExtensions(
 /// - Retries once on failure
 /// - Comprehensive error logging
 pub async fn ScanExtensionsWithRecovery(
-	ApplicationHandle: AppHandle,
-	State: &crate::ApplicationState::ExtensionState::State::State,
+	ApplicationHandle:AppHandle,
+	State:&crate::ApplicationState::ExtensionState::State::State,
 ) -> Result<(), CommonError> {
 	info!("[ExtensionScanner] Starting robust extension scan with recovery...");
 
 	// Clear potentially corrupted extension state first
-	// Note: Would clear State.Extension.ScannedExtensions.Extension.ScannedExtensions
+	// Note: Would clear
+	// State.Extension.ScannedExtensions.Extension.ScannedExtensions
 
 	// Perform the scan
 	match ScanAndPopulateExtensions(ApplicationHandle.clone(), State).await {
 		Ok(()) => {
-			info!(
-				"[ExtensionScanner] Robust extension scan completed successfully"
-			);
+			info!("[ExtensionScanner] Robust extension scan completed successfully");
 			Ok(())
 		},
 		Err(error) => {
@@ -164,7 +152,8 @@ pub async fn ScanExtensionsWithRecovery(
 			warn!("[ExtensionScanner] Attempting recovery from extension scan failure...");
 
 			// Clear state again
-			// Note: Would clear State.Extension.ScannedExtensions.Extension.ScannedExtensions
+			// Note: Would clear
+			// State.Extension.ScannedExtensions.Extension.ScannedExtensions
 
 			// Retry the scan with a cloned handle
 			ScanAndPopulateExtensions(ApplicationHandle.clone(), State).await

Source/ApplicationState/DTO/WorkspaceFolderStateDTO.rs

@@ -29,6 +29,7 @@
 //! - [ ] Add cross-platform path handling
 
 use std::path::Path;
+
 use log::debug;
 
 /// Resolves the absolute path for a Memento storage file based on scope.
@@ -43,12 +44,13 @@ use log::debug;
 ///
 /// # Behavior
 /// - Global scope: `{AppData}/User/globalStorage.json`
-/// - Workspace scope: `{AppData}/User/workspaceStorage/{sanitized-id}/storage.json`
+/// - Workspace scope:
+///   `{AppData}/User/workspaceStorage/{sanitized-id}/storage.json`
 /// - Sanitizes workspace identifier (alphanumeric, hyphens, underscores only)
 pub fn ResolveMementoStorageFilePath(
-	ApplicationDataDirectory: &Path,
-	IsGlobalScope: bool,
-	WorkspaceIdentifier: &str,
+	ApplicationDataDirectory:&Path,
+	IsGlobalScope:bool,
+	WorkspaceIdentifier:&str,
 ) -> std::path::PathBuf {
 	let user_storage_base_path = ApplicationDataDirectory.join("User");
 
@@ -61,8 +63,7 @@ pub fn ResolveMementoStorageFilePath(
 		path
 	} else {
 		// Sanitize the workspace identifier to be a safe directory name
-		let segment =
-			WorkspaceIdentifier.replace(|c: char| !c.is_alphanumeric() && c != '-' && c != '_', "_");
+		let segment = WorkspaceIdentifier.replace(|c:char| !c.is_alphanumeric() && c != '-' && c != '_', "_");
 
 		let path = user_storage_base_path
 			.join("workspaceStorage")