Author: NikolaRHristov

Source/ApplicationState/ApplicationState.rs

@@ -1,8 +1,10 @@
 // File: Mountain/Source/ApplicationState/ApplicationState.rs
 // Role: Defines the main `ApplicationState` struct, which is the central,
+
 // shared,       thread-safe state container for the entire Mountain
 // application. Responsibilities:
 //   - Hold all runtime state for services like configuration, extensions,
+
 //     documents, and UI.
 //   - Provide thread-safe access to this state via `Arc<Mutex<...>>`.
 //   - Be managed by Tauri and accessible to all command handlers and
@@ -11,6 +13,7 @@
 //! # ApplicationState Struct
 //!
 //! Defines the main `ApplicationState` struct, which is the central, shared,
+
 //! thread-safe state container for the entire Mountain application. It is
 //! managed by Tauri and is accessible to all command handlers and Environment
 //! providers.
@@ -62,39 +65,66 @@ use crate::Environment::CommandProvider::CommandHandler;
 pub struct ApplicationState {
 	// --- WorkSpace State ---
 	pub WorkSpaceFolders:Arc<StandardMutex<Vec<WorkSpaceFolderStateDTO>>>,
+
 	pub WorkSpaceConfigurationPath:Arc<StandardMutex<Option<PathBuf>>>,
+
 	pub IsTrusted:Arc<AtomicBool>,
+
 	pub WindowState:Arc<StandardMutex<WindowStateDTO>>,
+
 	pub ActiveDocumentURI:Arc<StandardMutex<Option<String>>>,
 
 	// --- Configuration & Storage ---
 	pub Configuration:Arc<StandardMutex<MergedConfigurationStateDTO>>,
+
 	pub GlobalMemento:Arc<StandardMutex<HashMap<String, serde_json::Value>>>,
+
 	pub GlobalMementoPath:PathBuf,
+
 	pub WorkSpaceMemento:Arc<StandardMutex<HashMap<String, serde_json::Value>>>,
+
 	pub WorkSpaceMementoPath:Arc<StandardMutex<Option<PathBuf>>>,
 
 	// --- Extension & Provider Management ---
 	pub CommandRegistry:Arc<StandardMutex<HashMap<String, CommandHandler<Wry>>>>,
+
 	pub LanguageProviders:Arc<StandardMutex<HashMap<u32, ProviderRegistrationDTO>>>,
+
 	pub NextProviderHandle:Arc<AtomicU32>,
+
 	pub ScannedExtensions:Arc<StandardMutex<HashMap<String, ExtensionDescriptionStateDTO>>>,
+
 	pub EnabledProposedAPIs:Arc<StandardMutex<HashMap<String, Vec<String>>>>,
+
 	pub ExtensionScanPaths:Arc<StandardMutex<Vec<PathBuf>>>,
 
 	// --- Feature-specific State ---
 	pub DiagnosticsMap:Arc<StandardMutex<HashMap<String, HashMap<String, Vec<MarkerDataDTO>>>>>,
+
 	pub OpenDocuments:Arc<StandardMutex<HashMap<String, DocumentStateDTO>>>,
+
 	pub OutputChannels:Arc<StandardMutex<HashMap<String, OutputChannelStateDTO>>>,
+
 	pub ActiveTerminals:Arc<StandardMutex<HashMap<u64, Arc<StandardMutex<TerminalStateDTO>>>>>,
+
 	pub NextTerminalIdentifier:Arc<AtomicU64>,
+
 	pub ActiveWebViews:Arc<StandardMutex<HashMap<String, WebViewStateDTO>>>,
+
 	pub ActiveCustomDocuments:Arc<StandardMutex<HashMap<String, CustomDocumentStateDTO>>>,
+
 	pub ActiveStatusBarItems:Arc<StandardMutex<HashMap<String, StatusBarEntryDTO>>>,
+
 	pub ActiveTreeViews:Arc<StandardMutex<HashMap<String, TreeViewStateDTO>>>,
+
 	pub SourceControlManagementProviders:Arc<StandardMutex<HashMap<u32, SourceControlManagementProviderDTO>>>,
-	pub SourceControlManagementGroups:Arc<StandardMutex<HashMap<u32, HashMap<String, SourceControlManagementGroupDTO>>>>,
-	pub SourceControlManagementResources:Arc<StandardMutex<HashMap<u32, HashMap<String, Vec<SourceControlManagementResourceDTO>>>>>,
+
+	pub SourceControlManagementGroups:
+		Arc<StandardMutex<HashMap<u32, HashMap<String, SourceControlManagementGroupDTO>>>>,
+
+	pub SourceControlManagementResources:
+		Arc<StandardMutex<HashMap<u32, HashMap<String, Vec<SourceControlManagementResourceDTO>>>>>,
+
 	pub NextSourceControlManagementProviderHandle:Arc<AtomicU32>,
 
 	// --- IPC & User Interface State ---
@@ -107,13 +137,16 @@ fn map_lock_error<T>(e:PoisonError<T>) -> CommonError { CommonError::StateLockPo
 impl Default for ApplicationState {
 	fn default() -> Self {
 		info!("[ApplicationState] Initializing default application state...");
+
 		let ApplicationNameForPaths = env!("CARGO_PKG_NAME");
+
 		let ApplicationDataDirectoryPath =
 			dirs::config_dir().map(|p| p.join(ApplicationNameForPaths)).unwrap_or_else(|| {
 				warn!(
 					"[ApplicationState] Could not get config dir. Using relative path '.{}-appdata'.",
 					ApplicationNameForPaths
 				);
+
 				PathBuf::from(format!(".{}-appdata", ApplicationNameForPaths))
 			});
 
@@ -129,39 +162,70 @@ impl Default for ApplicationState {
 		}
 
 		let GlobalMementoFilePath = Internal::ResolveMementoStorageFilePath(&ApplicationDataDirectoryPath, true, "");
+
 		let InitialGlobalMementoMap = Internal::LoadInitialMementoFromDisk(&GlobalMementoFilePath);
 
 		info!("[ApplicationState] Default state initialization complete.");
+
 		Self {
 			WorkSpaceFolders:Arc::new(StandardMutex::new(Vec::new())),
+
 			WorkSpaceConfigurationPath:Arc::new(StandardMutex::new(None)),
+
 			IsTrusted:Arc::new(AtomicBool::new(false)),
+
 			WindowState:Arc::new(StandardMutex::new(Default::default())),
+
 			ActiveDocumentURI:Arc::new(StandardMutex::new(None)),
+
 			Configuration:Arc::new(StandardMutex::new(MergedConfigurationStateDTO::default())),
+
 			GlobalMemento:Arc::new(StandardMutex::new(InitialGlobalMementoMap)),
+
 			GlobalMementoPath:GlobalMementoFilePath,
+
 			WorkSpaceMemento:Arc::new(StandardMutex::new(HashMap::new())),
+
 			WorkSpaceMementoPath:Arc::new(StandardMutex::new(None)),
+
 			CommandRegistry:Arc::new(StandardMutex::new(HashMap::new())),
+
 			LanguageProviders:Arc::new(StandardMutex::new(HashMap::new())),
+
 			NextProviderHandle:Arc::new(AtomicU32::new(1)),
+
 			ScannedExtensions:Arc::new(StandardMutex::new(HashMap::new())),
+
 			EnabledProposedAPIs:Arc::new(StandardMutex::new(HashMap::new())),
+
 			ExtensionScanPaths:Arc::new(StandardMutex::new(Vec::new())),
+
 			DiagnosticsMap:Arc::new(StandardMutex::new(HashMap::new())),
+
 			OpenDocuments:Arc::new(StandardMutex::new(HashMap::new())),
+
 			OutputChannels:Arc::new(StandardMutex::new(HashMap::new())),
+
 			ActiveTerminals:Arc::new(StandardMutex::new(HashMap::new())),
+
 			NextTerminalIdentifier:Arc::new(AtomicU64::new(1)),
+
 			ActiveWebViews:Arc::new(StandardMutex::new(HashMap::new())),
+
 			ActiveCustomDocuments:Arc::new(StandardMutex::new(HashMap::new())),
+
 			ActiveStatusBarItems:Arc::new(StandardMutex::new(HashMap::new())),
+
 			ActiveTreeViews:Arc::new(StandardMutex::new(HashMap::new())),
+
 			SourceControlManagementProviders:Arc::new(StandardMutex::new(HashMap::new())),
+
 			SourceControlManagementGroups:Arc::new(StandardMutex::new(HashMap::new())),
+
 			SourceControlManagementResources:Arc::new(StandardMutex::new(HashMap::new())),
+
 			NextSourceControlManagementProviderHandle:Arc::new(AtomicU32::new(1)),
+
 			PendingUserInterfaceRequests:Arc::new(StandardMutex::new(HashMap::new())),
 		}
 	}
@@ -172,16 +236,21 @@ impl ApplicationState {
 	/// workspace.
 	pub fn GetWorkSpaceIdentifier(&self) -> Result<String, CommonError> {
 		let ConfigurationPathGuard = self.WorkSpaceConfigurationPath.lock().map_err(map_lock_error)?;
+
 		if let Some(ConfigurationPath) = ConfigurationPathGuard.as_ref() {
 			return Ok(ConfigurationPath.file_name().unwrap_or_default().to_string_lossy().into_owned());
 		}
+
 		drop(ConfigurationPathGuard);
 
 		let FoldersGuard = self.WorkSpaceFolders.lock().map_err(map_lock_error)?;
+
 		if let Some(FirstFolder) = FoldersGuard.first() {
 			let PathString = FirstFolder.URI.path();
+
 			// Create a more stable hash for the identifier.
 			let Hash = format!("{:x}", md5::compute(PathString));
+
 			return Ok(format!(
 				"{}-{}",
 				FirstFolder.Name.replace(|c:char| !c.is_alphanumeric(), "_"),
@@ -199,36 +268,47 @@ impl ApplicationState {
 	/// Returns the next available unique identifier for a terminal instance.
 	pub fn GetNextTerminalIdentifier(&self) -> u64 { self.NextTerminalIdentifier.fetch_add(1, AtomicOrdering::Relaxed) }
 
-	/// Returns the next available unique identifier for an SourceControlManagement provider
-	/// instance.
-	pub fn GetNextSourceControlManagementProviderHandle(&self) -> u32 { self.NextSourceControlManagementProviderHandle.fetch_add(1, AtomicOrdering::Relaxed) }
+	/// Returns the next available unique identifier for an
+	/// SourceControlManagement provider instance.
+	pub fn GetNextSourceControlManagementProviderHandle(&self) -> u32 {
+		self.NextSourceControlManagementProviderHandle
+			.fetch_add(1, AtomicOrdering::Relaxed)
+	}
 
 	/// Updates the path to the workspace memento file and reloads its content
 	/// from disk.
 	pub fn UpdateWorkSpaceMementoPathAndReload(&self, ApplicationDataDirectory:&Path) -> Result<(), String> {
 		let WorkSpaceIdentifier = self.GetWorkSpaceIdentifier().map_err(|e| e.to_string())?;
+
 		let mut PathGuard = self.WorkSpaceMementoPath.lock().map_err(|e| e.to_string())?;
 
 		if WorkSpaceIdentifier == "NO_WORKSPACE" {
 			if PathGuard.is_some() {
 				*PathGuard = None;
+
 				self.WorkSpaceMemento.lock().map_err(|e| e.to_string())?.clear();
 			}
+
 			return Ok(());
 		}
 
 		let NewMementoPath =
 			Internal::ResolveMementoStorageFilePath(ApplicationDataDirectory, false, &WorkSpaceIdentifier);
+
 		if PathGuard.as_ref() != Some(&NewMementoPath) {
 			if let Some(Parent) = NewMementoPath.parent() {
 				if !Parent.exists() {
 					std::fs::create_dir_all(Parent).map_err(|e| e.to_string())?;
 				}
 			}
+
 			*PathGuard = Some(NewMementoPath.clone());
+
 			let NewMementoContent = Internal::LoadInitialMementoFromDisk(&NewMementoPath);
+
 			*self.WorkSpaceMemento.lock().map_err(|e| e.to_string())? = NewMementoContent;
 		}
+
 		Ok(())
 	}
 }

Source/ApplicationState/DTO/DocumentStateDTO.rs

@@ -17,18 +17,25 @@ pub struct DocumentStateDTO {
 	/// The unique resource identifier for this document.
 	#[serde(with = "URLSerializationHelper")]
 	pub URI:Url,
+
 	/// The VS Code language identifier (e.g., "rust", "typescript").
 	pub LanguageIdentifier:String,
+
 	/// The version number, incremented on each change from the client.
 	pub Version:i64,
+
 	/// The content of the document, split into lines.
 	pub Lines:Vec<String>,
+
 	/// The detected end-of-line sequence (e.g., `\n` or `\r\n`).
 	pub EOL:String,
+
 	/// A flag indicating if the in-memory version has unsaved changes.
 	pub IsDirty:bool,
+
 	/// The detected file encoding (e.g., "utf8").
 	pub Encoding:String,
+
 	/// An internal version number, used for tracking changes within the host.
 	pub VersionIdentifier:i64,
 }
@@ -37,17 +44,26 @@ impl DocumentStateDTO {
 	/// Creates a new `DocumentStateDTO` from its initial content.
 	pub fn Create(URI:Url, LanguageIdentifier:Option<String>, Content:String) -> Self {
 		let (Lines, EOL) = AnalyzeTextLinesAndEOL(&Content);
+
 		let LanguageID = LanguageIdentifier.unwrap_or_else(|| "plaintext".to_string());
+
 		let Encoding = "utf8".to_string();
 
 		Self {
 			URI,
+
 			LanguageIdentifier:LanguageID,
+
 			Version:1,
+
 			Lines,
+
 			EOL,
+
 			IsDirty:false,
+
 			Encoding,
+
 			VersionIdentifier:1,
 		}
 	}
@@ -67,17 +83,25 @@ impl DocumentStateDTO {
 
 		let _RPCChanges:Vec<RPCModelContentChangeDTO> = match serde_json::from_value(ChangesValue.clone()) {
 			Ok(changes) => changes,
+
 			Err(_) => {
 				if let Some(FullText) = ChangesValue.as_str() {
 					let (NewLines, NewEOL) = AnalyzeTextLinesAndEOL(FullText);
+
 					self.Lines = NewLines;
+
 					self.EOL = NewEOL;
+
 					self.Version = NewVersion;
+
 					// Increment internal version
 					self.VersionIdentifier += 1;
+
 					self.IsDirty = true;
+
 					return Ok(());
 				}
+
 				return Err(format!("Invalid RPCModelContentChangeDTO for {}", self.URI));
 			},
 		};
@@ -88,9 +112,12 @@ impl DocumentStateDTO {
 		);
 
 		self.Version = NewVersion;
+
 		// Increment internal version
 		self.VersionIdentifier += 1;
+
 		self.IsDirty = true;
+
 		Ok(())
 	}
 }

Source/ApplicationState/DTO/ExtensionDescriptionStateDTO.rs

@@ -9,6 +9,7 @@ use serde::{Deserialize, Serialize};
 use serde_json::Value;
 
 /// Represents the deserialized content of an extension's `package.json` file,
+
 /// augmented with location information and other metadata.
 ///
 /// This is stored in `ApplicationState` to provide the extension host with the
@@ -19,29 +20,37 @@ pub struct ExtensionDescriptionStateDTO {
 	// --- Core Metadata ---
 	// DTO: { value: string, uuid?: string }
 	pub Identifier:Value,
+
 	pub Name:String,
+
 	pub Version:String,
+
 	pub Publisher:String,
+
 	// DTO: { vscode: string }
 	pub Engines:Value,
 
 	// --- Entry Points ---
 	#[serde(skip_serializing_if = "Option::is_none")]
 	pub Main:Option<String>,
+
 	#[serde(skip_serializing_if = "Option::is_none")]
 	pub Browser:Option<String>,
 
 	// --- Type & Flags ---
 	#[serde(rename = "Type", skip_serializing_if = "Option::is_none")]
 	pub ModuleType:Option<String>,
+
 	#[serde(default)]
 	pub IsBuiltin:bool,
+
 	#[serde(default)]
 	pub IsUnderDevelopment:bool,
 
 	// --- Location & Activation ---
 	// Serialized UriComponents DTO
 	pub ExtensionLocation:Value,
+
 	#[serde(skip_serializing_if = "Option::is_none")]
 	pub ActivationEvents:Option<Vec<String>>,