Author: NikolaRHristov

Cargo.toml

@@ -71,6 +71,7 @@ ring = { workspace = true }
 bincode = { workspace = true }
 brotli = { workspace = true }
 hex = { workspace = true }
+opentelemetry = { workspace = true }
 
 [features]
 default = ["ExtensionHostCocoon", "MistNative", "AirIntegration"]
@@ -83,6 +84,17 @@ Debug = []
 
 AirIntegration = ["Air"]
 
+# Feature flags for conditional compilation
+grove = []
+cocoon = []
+terminals = []
+debug-protocol = []
+scm-support = []
+child-processes = []
+Telemetry = []
+Development = []
+Test = []
+
 [lib]
 name = "Mountain"
 path = "Source/Library.rs"

README.md

@@ -120,9 +120,10 @@ frontend and the `Cocoon` extension host.
 
 To understand how `Mountain`'s internal components are structured and how they
 implement the application's core logic, please refer to the detailed technical
-breakdown in [`Documentation/GitHub/DeepDive.md`](https://github.com/CodeEditorLand/Mountain/tree/Current/Documentation/GitHub/DeepDive.md). This document explains
-the roles of the `ApplicationRunTime`, `ApplicationState`, `Handler`,
-`Environment`, and the `Vine` gRPC layer.
+breakdown in
+[`Documentation/GitHub/DeepDive.md`](https://github.com/CodeEditorLand/Mountain/tree/Current/Documentation/GitHub/DeepDive.md).
+This document explains the roles of the `ApplicationRunTime`,
+`ApplicationState`, `Handler`, `Environment`, and the `Vine` gRPC layer.
 
 ---
 
@@ -224,14 +225,16 @@ set up, build, and run the entire application.
 This project is released into the public domain under the **Creative Commons CC0
 Universal** license. You are free to use, modify, distribute, and build upon
 this work for any purpose, without any restrictions. For the full legal text,
-see the [`LICENSE`](https://github.com/CodeEditorLand/Mountain/tree/Current/) file.
+see the [`LICENSE`](https://github.com/CodeEditorLand/Mountain/tree/Current/)
+file.
 
 ---
 
 ## Changelog 📜
 
-Stay updated with our progress! See [`CHANGELOG.md`](https://github.com/CodeEditorLand/Mountain/tree/Current/) for a history
-of changes specific to **Mountain**.
+Stay updated with our progress! See
+[`CHANGELOG.md`](https://github.com/CodeEditorLand/Mountain/tree/Current/) for a
+history of changes specific to **Mountain**.
 
 ---
 

SECURITY.md

@@ -59,8 +59,8 @@ not limited to):**
 - **Denial of Service (DoS):** If an Element can be made unresponsive or crash
   due to specially crafted input or excessive resource consumption.
 - **Path Traversal/Arbitrary File Access:** For Elements interacting with the
-  filesystem (like `Mountain`'s FS Handler), ensuring that
-  path inputs are properly sanitized.
+  filesystem (like `Mountain`'s FS Handler), ensuring that path inputs are
+  properly sanitized.
 - **Insecure IPC/Communication:** For Elements involved in inter-process
   communication (`Vine`, `Track`, `Echo`, `Mist`), vulnerabilities in the
   protocol or handling of messages.

Source/Air/AirClient.rs

@@ -21,7 +21,7 @@
 //! AirClient serves as the primary interface between Mountain and the Air
 //! backend service:
 //!
-//! ```
+//! ```text
 //! Mountain (Frontend) ──► AirClient ──► gRPC ──► Air Daemon (Backend)
 //! ```
 //!
@@ -114,15 +114,15 @@ impl AirClient {
 	/// Creates a new AirClient and connects to the Air daemon service.
 	///
 	/// # Arguments
-	/// * `address` - The gRPC server address (e.g., "http://[::1]:50053")
+	/// * `address` - The gRPC server address (e.g., "http://\\[::1\\]:50053")
 	///
 	/// # Returns
 	/// * `Ok(Self)` - Successfully created client
 	/// * `Err(CommonError)` - Connection failure with descriptive error
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// use Mountain::Air::AirClient::{AirClient, DEFAULT_AIR_SERVER_ADDRESS};
 	///
 	/// # #[tokio::main]
@@ -490,7 +490,7 @@ impl AirClient {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// use Mountain::Air::AirClient::AirClient;
 	/// use CommonLibrary::Error::CommonError::CommonError;
 	///
@@ -1180,7 +1180,7 @@ pub struct DownloadStreamChunk {
 ///
 /// # Example
 ///
-/// ```rust,no_run
+/// ```text
 /// use Mountain::Air::AirClient::DownloadStream;
 /// use CommonLibrary::Error::CommonError::CommonError;
 ///

Source/Air/AirServiceProvider.rs

@@ -19,7 +19,7 @@
 //! - Request ID generation for tracing
 //! - Connection state management
 //!
-//! ```
+//! ```text
 //! Application ──► AirServiceProvider ──► AirClient ──► gRPC ──► Air Daemon
 //! ```
 //!
@@ -47,7 +47,7 @@
 //! ## PERFORMANCE
 //!
 //! - Request ID generation uses UUID v4 (cryptographically random)
-//! - Thread-safe operations via Arc<AirClient>
+//! - Thread-safe operations via `Arc<AirClient>`
 //! - Non-blocking async operations via tokio
 //!
 //! ## VSCODE REFERENCE
@@ -100,7 +100,7 @@ use super::{
 ///
 /// # Example
 ///
-/// ```rust,no_run
+/// ```text
 /// use Mountain::Air::AirServiceProvider::{AirServiceProvider, DEFAULT_AIR_SERVER_ADDRESS};
 /// use CommonLibrary::Error::CommonError::CommonError;
 ///
@@ -140,7 +140,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// use CommonLibrary::Error::CommonError::CommonError;
 	///
@@ -170,7 +170,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// use CommonLibrary::Error::CommonError::CommonError;
 	///
@@ -239,7 +239,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// # use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// # use CommonLibrary::Error::CommonError::CommonError;
 	/// # #[tokio::main]
@@ -278,7 +278,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// # use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// # use CommonLibrary::Error::CommonError::CommonError;
 	/// # #[tokio::main]
@@ -389,7 +389,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// # use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// # use CommonLibrary::Error::CommonError::CommonError;
 	/// # #[tokio::main]
@@ -447,7 +447,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// # use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// # use CommonLibrary::Error::CommonError::CommonError;
 	/// # #[tokio::main]
@@ -493,7 +493,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// # use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// # use CommonLibrary::Error::CommonError::CommonError;
 	/// # #[tokio::main]
@@ -565,7 +565,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// # use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// # use CommonLibrary::Error::CommonError::CommonError;
 	/// # #[tokio::main]
@@ -654,7 +654,7 @@ impl AirServiceProvider {
 	///
 	/// # Example
 	///
-	/// ```rust,no_run
+	/// ```text
 	/// # use Mountain::Air::AirServiceProvider::AirServiceProvider;
 	/// # use CommonLibrary::Error::CommonError::CommonError;
 	/// # #[tokio::main]
@@ -715,7 +715,7 @@ impl AirServiceProvider {
 ///
 /// # Example
 ///
-/// ```rust
+/// ```text
 /// use Mountain::Air::AirServiceProvider::generate_request_id;
 ///
 /// let id = generate_request_id();

Source/Air/mod.rs

@@ -7,13 +7,13 @@
 //!   - Authentication and credential management
 //!   - File indexing and search operations
 //!   - System monitoring and metrics collection
-//! - Handles connection management and error translation to [`CommonError`]
-//! - Wraps client in [`Arc`] for shared access across the application
+//! - Handles connection management and error translation to `CommonError`
+//! - Wraps client in `Arc` for shared access across the application
 //!
 //! ARCHITECTURAL ROLE:
 //! - Integration point with the Air background service (daemon)
 //! - Used by multiple Mountain components:
-//!   - [`UpdateService`](crate::Update::UpdateService) for self-updates
+//! - `UpdateService` for self-updates
 //!   - [`SearchProvider`](crate::Environment::SearchProvider) for file search
 //!   - [`SecretProvider`](crate::Environment::SecretProvider) for secret
 //!     storage
@@ -32,7 +32,7 @@
 //! - Uses tonic gRPC client for transport
 //! - Connection establishment via `connect()` method
 //! - Health checking with timeout protection
-//! - Thread-safe operations via Arc<AirClient>
+//! - Thread-safe operations via `Arc<AirClient>`
 //!
 //! ERROR HANDLING:
 //! - All gRPC errors translated to
@@ -42,7 +42,7 @@
 //!   fallback)
 //!
 //! PERFORMANCE:
-//! - gRPC channels are expensive; reuse via Arc<AirClient>
+//! - gRPC channels are expensive; reuse via `Arc<AirClient>`
 //! - Non-blocking async operations via tokio
 //! - Request ID generation for tracing
 //!

Source/ApplicationState/Internal/TextProcessing/AnalyzeTextLinesAndEOL.rs

@@ -36,7 +36,7 @@ use log::debug;
 /// * `TextContent` - The text content to analyze
 ///
 /// # Returns
-/// Tuple containing (Vec<String> of lines, String of detected EOL)
+/// Tuple containing (`Vec<String>` of lines, String of detected EOL)
 ///
 /// # Behavior
 /// - Detects CRLF ("\r\n") or LF ("\n") line endings

Source/Binary/Build/WindowBuild.rs

@@ -23,9 +23,9 @@ use tauri::{App, WebviewUrl, WebviewWindowBuilder, Wry};
 pub fn WindowBuild(Application:&mut App, LocalhostUrl:String) -> tauri::WebviewWindow<Wry> {
 	// Create the window URL pointing to the application
 	let WindowUrl = WebviewUrl::External(
-		format!("{}/Application/index.html", LocalhostUrl)
-			.parse()
-			.expect("FATAL: Failed to parse localhost URL"),
+	        format!("{}/index.html", LocalhostUrl)
+	        .parse()
+	        .expect("FATAL: Failed to parse localhost URL"),
 	);
 
 	// Configure window builder with base settings

Source/Binary/Initialize/StateBuild.rs

@@ -21,6 +21,10 @@ use log::{debug, error, info, warn};
 // ============ Feature Flags ============
 #[cfg(feature = "Telemetry")]
 use opentelemetry::{KeyValue, global};
+#[cfg(feature = "Telemetry")]
+use opentelemetry::trace::Tracer;
+#[cfg(feature = "Telemetry")]
+use opentelemetry::trace::Span;
 
 use crate::{ApplicationState::ApplicationState, Environment::MountainEnvironment::MountainEnvironment};
 

Source/Binary/Service/VineStart.rs

@@ -9,8 +9,8 @@ use log::{error, info};
 /// # Arguments
 ///
 /// * `ApplicationHandle` - The Tauri application handle
-/// * `PrimaryAddress` - The primary server address (e.g., "[::1]:50051")
-/// * `SecondaryAddress` - The secondary server address (e.g., "[::1]:50052")
+/// * `PrimaryAddress` - The primary server address (e.g., "\\[::1\\]:50051")
+/// * `SecondaryAddress` - The secondary server address (e.g., "\\[::1\\]:50052")
 ///
 /// # Returns
 ///