Mountain/Environment/

MountainEnvironment.rs

//! # MountainEnvironment (Environment)
//!
//! The primary dependency injection (DI) container for the Mountain
//! application. It implements all provider traits defined in the Common crate,
//! acting as the central orchestrator that provides access to all platform
//! services.
//!
//! ## RESPONSIBILITIES
//!
//! ### 1. Dependency Injection Container
//! - Implements `Requires<T>` for all 25+ provider traits via macro
//! - Enable other components to request dependencies through `Require()` method
//! - Provide lazy initialization with proper lifetime management
//! - Support circular dependencies via `Arc`-wrapped self-references
//!
//! ### 2. Application Lifecycle Management
//! - Hold references to Tauri `AppHandle` and `ApplicationState`
//! - Manage the core application context and state
//! - Coordinate initialization sequence for all providers
//! - Support graceful shutdown and cleanup
//!
//! ### 3. Air Integration (Optional)
//! - Manage the Air gRPC client for cloud-based services when `AirIntegration`
//!   feature enabled
//! - Enable dynamic switching between local and cloud services
//! - Provide health checking for Air daemon availability
//! - Support fallback to local services when Air unavailable
//!
//! ### 4. Extension Management
//! - Implement `ExtensionManagementService` for discovering extensions
//! - Scan registered paths for valid extensions
//! - Manage extension metadata in `ApplicationState`
//! - Provide extension list to extension host (Cocoon)
//!
//! ### 5. Service Orchestration
//! - Act as central coordinator between all providers (FileSystem, Document,
//!   Command, etc.)
//! - Ensure proper initialization order and dependency resolution
//! - Facilitate inter-provider communication via IPC or direct calls
//! - Provide capability resolution through `Requires<T>` trait
//!
//! ## ARCHITECTURAL ROLE
//!
//! MountainEnvironment is the **central DI container and service locator** for
//! the entire application:
//!
//! ```text
//! Component ──► Requires<T> ──► MountainEnvironment ──► Arc<dyn T>
//! ```
//!
//! ### Position in Mountain
//! - `Environment` module: Root of the dependency injection system
//! - Implements Common crate's `Environment` and `Requires` traits
//! - All providers accessed through capability-based lookups
//! - Created early in startup and shared via `Arc<MountainEnvironment>`
//!
//! ### Dependencies (Incoming)
//! - `CommonLibrary::*` provider traits (25+ interfaces)
//! - `tauri::AppHandle`: UI and platform integration
//! - `ApplicationState`: Shared application state
//! - `AirServiceClient` (optional): Cloud service integration
//!
//! ### Dependents (Outgoing)
//! - All command handlers: Require capabilities from environment
//! - `ApplicationRunTime`: Uses environment for effect execution
//! - Provider implementations: self-referencing via `Arc<dyn Trait>`
//! - `InitializationData`: Uses environment to gather extensions and workspace
//!   data
//!
//! ## DEPENDENCY INJECTION PATTERN
//!
//! Mountain uses a **service locator pattern** with trait-based lookup:
//!
//! ```rust,ignore
//! impl Requires<dyn FileSystemReader> for MountainEnvironment {
//!     fn Require(&self) -> Arc<dyn FileSystemReader> {
//!         Arc::new(self.clone()) // Self implements FileSystemReader
//!     }
//! }
//! ```
//!
//! This enables:
//! - **Loose coupling**: Components depend on traits, not concrete types
//! - **Circular dependencies**: All providers can require each other through
//!   Environment
//! - **Testability**: Environment can be mocked or stubbed for tests
//! - **Flexibility**: New providers added without changing dependents
//!
//! ## INITIALIZATION SEQUENCE
//!
//! 1. **Create Environment**: `MountainEnvironment::Create(app_handle, app_state)`
//! 2. **Provider Instantiation**: Lazy through `Requires<T>` trait calls
//! 3. **State Access**: Each provider can access `ApplicationState` and
//!    `AppHandle` via self
//! 4. **Inter-Provider Communication**: Via trait methods (direct Rust calls)
//!    or IPC
//!
//! Note: Provider implementations are separate modules in `Environment/`
//! directory. Each module implements a specific trait and can be
//! included/excluded via feature flags.
//!
//! ## AIR INTEGRATION
//!
//! When `AirIntegration` feature is enabled:
//! - `AirClient` field is
//!   `Option<Arc<AirServiceClient<tonic::transport::Channel>>>`
//! - `CreateWithAir()` allows passing pre-configured Air client
//! - `SetAirClient()` allows dynamic switching at runtime
//! - `IsAirAvailable()` performs health check on Air daemon
//! - Providers like `SecretProvider` and `UpdateService` can delegate to Air
//!
//! When feature is disabled:
//! - `AirClient` field is absent
//! - `IsAirAvailable()` always returns `false`
//! - Local-only service implementations are used
//!
//! ## VS CODE REFERENCE
//!
//! Patterns borrowed from VS Code's service architecture:
//! - `vs/platform/instantiation/common/instantiation.ts` - Service collection
//!   and instantiation
//! - `vs/platform/workspace/common/workspace.ts` - Service locator pattern
//! - `vs/workbench/services/extensions/common/extensions.ts` - Extension point
//!   management
//!
//! Key concepts:
//! - Service lifetime management through `Arc` reference counting
//! - Trait-based service definitions for loose coupling
//! - Lazy initialization on first use
//! - Thread-safe service access
//!
//! ## PROVIDER TRAITS IMPLEMENTED
//!
//! The following 25+ provider traits are implemented using the
//! `impl_provider!` macro:
//! - `CommandExecutor` - Execute commands and actions
//! - `ConfigurationProvider` - Access application configuration
//! - `ConfigurationInspector` - Inspect configuration values
//! - `CustomEditorProvider` - Custom document editor support
//! - `DebugService` - Debug adapter protocol integration
//! - `DiagnosticManager` - Diagnostic/lint/error management
//! - `DocumentProvider` - Document lifecycle and content access
//! - `FileSystemReader` / `FileSystemWriter` - File system operations
//! - `IPCProvider` - Inter-process communication
//! - `KeybindingProvider` - Keybinding resolution and execution
//! - `LanguageFeatureProviderRegistry` - LSP and language features
//! - `OutputChannelManager` - Output panel channel management
//! - `SecretProvider` - Credential and secret storage
//! - `SourceControlManagementProvider` - Git/SCM integration
//! - `StatusBarProvider` - Status bar item management
//! - `StorageProvider` - Key-value storage
//! - `SynchronizationProvider` - Remote sync and collaboration
//! - `TerminalProvider` - Integrated terminal management
//! - `TestController` - Test discovery and execution
//! - `TreeViewProvider` - Tree view UI components
//! - `UserInterfaceProvider` - UI dialog and interaction services
//! - `WebviewProvider` - Webview panel management
//! - `WorkspaceProvider` - Workspace and folder management
//! - `WorkspaceEditApplier` - Workspace edit application (text changes)
//! - `ExtensionManagementService` - Extension scanning and metadata
//! - `SearchProvider` - Search and replace functionality
//!
//! ## TODO
//! - [ ] Add telemetry integration for performance monitoring
//! - [ ] Implement proper provider health checking
//! - [ ] Add provider dependency validation on initialization
//! - [ ] Consider async initialization for providers
//! - [ ] Add circuit breaker pattern for external service calls (Air)
//! - [ ] Implement graceful degradation when providers fail
//! - [ ] Add metrics collection for provider usage
//! - [ ] Consider provider initialization order dependencies

use std::sync::Arc;

// Import Air service client when Air integration is enabled
#[cfg(feature = "AirIntegration")]
use AirLibrary::Vine::Generated::air::air_service_client::AirServiceClient;
#[cfg(feature = "AirIntegration")]
use AirLibrary::Vine::Generated::air::HealthCheckRequest;
use CommonLibrary::{
	Command::CommandExecutor::CommandExecutor,
	Configuration::{ConfigurationInspector::ConfigurationInspector, ConfigurationProvider::ConfigurationProvider},
	CustomEditor::CustomEditorProvider::CustomEditorProvider,
	Debug::DebugService::DebugService,
	Diagnostic::DiagnosticManager::DiagnosticManager,
	Document::DocumentProvider::DocumentProvider,
	Environment::{Environment::Environment, Requires::Requires},
	Error::CommonError::CommonError,
	ExtensionManagement::ExtensionManagementService::ExtensionManagementService,
	FileSystem::{FileSystemReader::FileSystemReader, FileSystemWriter::FileSystemWriter},
	IPC::IPCProvider::IPCProvider,
	Keybinding::KeybindingProvider::KeybindingProvider,
	LanguageFeature::LanguageFeatureProviderRegistry::LanguageFeatureProviderRegistry,
	Output::OutputChannelManager::OutputChannelManager,
	Search::SearchProvider::SearchProvider,
	Secret::SecretProvider::SecretProvider,
	SourceControlManagement::SourceControlManagementProvider::SourceControlManagementProvider,
	StatusBar::StatusBarProvider::StatusBarProvider,
	Storage::StorageProvider::StorageProvider,
	Synchronization::SynchronizationProvider::SynchronizationProvider,
	Terminal::TerminalProvider::TerminalProvider,
	Testing::TestController::TestController,
	TreeView::TreeViewProvider::TreeViewProvider,
	UserInterface::UserInterfaceProvider::UserInterfaceProvider,
	Webview::WebviewProvider::WebviewProvider,
	Workspace::{WorkspaceEditApplier::WorkspaceEditApplier, WorkspaceProvider::WorkspaceProvider},
};
use async_trait::async_trait;
use log::{info, warn};
use serde_json::Value;
use tauri::{AppHandle, Manager, Wry};

use crate::ApplicationState::{ApplicationState, DTO::ExtensionDescriptionStateDTO::ExtensionDescriptionStateDTO};
// Import the macro for generating trait implementations
// Note: Macros annotated with #[macro_export] are available at crate root
use crate::impl_provider;

/// The concrete `Environment` for the Mountain application.
#[derive(Clone)]
pub struct MountainEnvironment {
	pub ApplicationHandle:AppHandle<Wry>,

	pub ApplicationState:Arc<ApplicationState>,

	/// Optional Air client for cloud-based services.
	/// When provided, providers like SecretProvider and UpdateService can
	/// delegate to Air.
	#[cfg(feature = "AirIntegration")]
	pub AirClient:Option<AirServiceClient<tonic::transport::Channel>>,
}

impl MountainEnvironment {
	/// Creates a new `MountainEnvironment` instance.
	#[allow(unused_mut)]
	pub fn Create(ApplicationHandle:AppHandle<Wry>, ApplicationState:Arc<ApplicationState>) -> Self {
		info!("[MountainEnvironment] New instance created.");

		#[cfg(feature = "AirIntegration")]
		{
			Self { ApplicationHandle, ApplicationState, AirClient:None }
		}

		#[cfg(not(feature = "AirIntegration"))]
		{
			Self { ApplicationHandle, ApplicationState }
		}
	}

	/// Creates a new `MountainEnvironment` instance with an optional Air
	/// client. When AirClient is provided, providers can delegate to Air for
	/// cloud-based services.
	#[cfg(feature = "AirIntegration")]
	pub fn CreateWithAir(
		ApplicationHandle:AppHandle<Wry>,
		ApplicationState:Arc<ApplicationState>,
		AirClient:Option<AirServiceClient<tonic::transport::Channel>>,
	) -> Self {
		info!(
			"[MountainEnvironment] New instance created with Air client: {}",
			AirClient.is_some()
		);

		Self { ApplicationHandle, ApplicationState, AirClient }
	}

	/// Updates the Air client for this environment.
	/// This allows dynamically switching between Air and local services.
	#[cfg(feature = "AirIntegration")]
	pub fn SetAirClient(&mut self, AirClient:Option<AirServiceClient<tonic::transport::Channel>>) {
		info!("[MountainEnvironment] Air client updated: {}", AirClient.is_some());

		self.AirClient = AirClient;
	}

	/// Returns whether Air is available and ready.
	#[cfg(feature = "AirIntegration")]
	pub async fn IsAirAvailable(&self) -> bool {
		// TODO: Implement proper health check when AirClient wrapper is available
		// The raw gRPC client requires &mut self for health_check, but MountainEnvironment
		// stores an immutable reference. This will be fixed when the AirClient wrapper
		// is properly integrated.
		if let Some(_AirClient) = &self.AirClient {
			// For now, assume Air is available if the client exists
			info!("[MountainEnvironment] Air client configured (health check disabled pending integration)");
			true
		} else {
			info!("[MountainEnvironment] No Air client configured");
			false
		}
	}

	/// Returns whether Air is available and ready.
	#[cfg(not(feature = "AirIntegration"))]
	pub async fn IsAirAvailable(&self) -> bool { false }

	/// Scans a directory for extensions and returns their package.json data
	async fn ScanExtensionDirectory(&self, path:&std::path::PathBuf) -> Result<Vec<serde_json::Value>, CommonError> {
		use std::fs;

		let mut extensions = Vec::new();

		// Check if directory exists
		if !path.exists() || !path.is_dir() {
			warn!("[ExtensionManagementService] Extension directory does not exist: {:?}", path);
			return Ok(extensions);
		}

		// Read directory contents
		let entries = fs::read_dir(path).map_err(|error| {
			CommonError::FileSystemIO {
				Path:path.clone(),
				Description:format!("Failed to read extension directory: {}", error),
			}
		})?;

		for entry in entries {
			let entry = entry.map_err(|error| {
				CommonError::FileSystemIO {
					Path:path.clone(),
					Description:format!("Failed to read directory entry: {}", error),
				}
			})?;

			let entry_path = entry.path();
			if entry_path.is_dir() {
				// Look for package.json in the extension directory
				let package_json_path = entry_path.join("package.json");
				if package_json_path.exists() {
					match fs::read_to_string(&package_json_path) {
						Ok(content) => {
							match serde_json::from_str::<Value>(&content) {
								Ok(mut package_json) => {
									// Add extension location information
									if let Some(obj) = package_json.as_object_mut() {
										obj.insert(
											"ExtensionLocation".to_string(),
											Value::String(entry_path.to_string_lossy().to_string()),
										);
									}
									extensions.push(package_json);
									info!("[ExtensionManagementService] Found extension at: {:?}", entry_path);
								},
								Err(error) => {
									warn!(
										"[ExtensionManagementService] Failed to parse package.json at {:?}: {}",
										package_json_path, error
									);
								},
							}
						},
						Err(error) => {
							warn!(
								"[ExtensionManagementService] Failed to read package.json at {:?}: {}",
								package_json_path, error
							);
						},
					}
				}
			}
		}

		Ok(extensions)
	}
}

impl Environment for MountainEnvironment {}

#[async_trait]
impl ExtensionManagementService for MountainEnvironment {
	async fn ScanForExtensions(&self) -> Result<(), CommonError> {
		info!("[ExtensionManagementService] Scanning for extensions...");

		// Get the extension scan paths from ApplicationState
		let ScanPaths:Vec<std::path::PathBuf> = {
			let ScanPathsGuard = self
				.ApplicationState
				.Extension
				.Registry
				.ExtensionScanPaths
				.lock()
				.map_err(|Error| CommonError::StateLockPoisoned { Context:Error.to_string() })?;
			ScanPathsGuard.clone()
		};

		let mut extensions = Vec::new();

		// Scan each extension directory
		for path in ScanPaths {
			if let Ok(mut scan_result) = self.ScanExtensionDirectory(&path).await {
				extensions.append(&mut scan_result);
			}
		}

		// Update ApplicationState with scanned extensions
		let mut ScannedExtensionsGuard = self
			.ApplicationState
			.Extension
			.ScannedExtensions
			.ScannedExtensions
			.lock()
			.map_err(|Error| CommonError::StateLockPoisoned { Context:Error.to_string() })?;

		ScannedExtensionsGuard.clear();

		for extension in extensions {
			if let Some(identifier) = extension.get("Identifier").and_then(|v| v.as_str()) {
				// Convert the extension DTO to ExtensionDescriptionStateDTO
				let extension_dto = ExtensionDescriptionStateDTO {
					Identifier:serde_json::Value::String(identifier.to_string()),
					Name:extension.get("Name").and_then(|v| v.as_str()).unwrap_or("Unknown").to_string(),
					Version:extension.get("Version").and_then(|v| v.as_str()).unwrap_or("0.0.0").to_string(),
					Publisher:extension
						.get("Publisher")
						.and_then(|v| v.as_str())
						.unwrap_or("Unknown")
						.to_string(),
					Engines:extension.get("Engines").cloned().unwrap_or(serde_json::Value::Null),
					Main:extension.get("Main").and_then(|v| v.as_str()).map(|s| s.to_string()),
					Browser:extension.get("Browser").and_then(|v| v.as_str()).map(|s| s.to_string()),
					ModuleType:extension.get("ModuleType").and_then(|v| v.as_str()).map(|s| s.to_string()),
					IsBuiltin:extension.get("IsBuiltin").and_then(|v| v.as_bool()).unwrap_or(false),
					IsUnderDevelopment:extension.get("IsUnderDevelopment").and_then(|v| v.as_bool()).unwrap_or(false),
					ExtensionLocation:extension.get("ExtensionLocation").cloned().unwrap_or(serde_json::Value::Null),
					ActivationEvents:extension
						.get("ActivationEvents")
						.and_then(|v| v.as_array())
						.map(|arr| arr.iter().filter_map(|v| v.as_str().map(|s| s.to_string())).collect()),
					Contributes:extension.get("Contributes").cloned(),
				};

				ScannedExtensionsGuard.insert(identifier.to_string(), extension_dto);
			}
		}

		info!("[ExtensionManagementService] Found {} extensions", ScannedExtensionsGuard.len());
		Ok(())
	}

	async fn GetExtensions(&self) -> Result<Vec<Value>, CommonError> {
		let ScannedExtensionsGuard = self
			.ApplicationState
			.Extension
			.ScannedExtensions
			.ScannedExtensions
			.lock()
			.map_err(|Error| CommonError::StateLockPoisoned { Context:Error.to_string() })?;

		let Extensions:Vec<Value> = ScannedExtensionsGuard
			.values()
			.map(|ext| serde_json::to_value(ext).unwrap_or(Value::Null))
			.collect();

		Ok(Extensions)
	}

	async fn GetExtension(&self, id:String) -> Result<Option<Value>, CommonError> {
		let ScannedExtensionsGuard = self
			.ApplicationState
			.Extension
			.ScannedExtensions
			.ScannedExtensions
			.lock()
			.map_err(|Error| CommonError::StateLockPoisoned { Context:Error.to_string() })?;

		if let Some(extension_dto) = ScannedExtensionsGuard.get(&id) {
			// Convert ExtensionDescriptionStateDTO back to JSON Value
			let mut extension_value = serde_json::Map::new();
			extension_value.insert("Identifier".to_string(), extension_dto.Identifier.clone());
			extension_value.insert("Name".to_string(), Value::String(extension_dto.Name.clone()));
			extension_value.insert("Version".to_string(), Value::String(extension_dto.Version.clone()));
			extension_value.insert("Publisher".to_string(), Value::String(extension_dto.Publisher.clone()));
			extension_value.insert("Engines".to_string(), extension_dto.Engines.clone());

			if let Some(main) = &extension_dto.Main {
				extension_value.insert("Main".to_string(), Value::String(main.clone()));
			}

			if let Some(browser) = &extension_dto.Browser {
				extension_value.insert("Browser".to_string(), Value::String(browser.clone()));
			}

			if let Some(module_type) = &extension_dto.ModuleType {
				extension_value.insert("ModuleType".to_string(), Value::String(module_type.clone()));
			}

			extension_value.insert("IsBuiltin".to_string(), Value::Bool(extension_dto.IsBuiltin));
			extension_value.insert("IsUnderDevelopment".to_string(), Value::Bool(extension_dto.IsUnderDevelopment));
			extension_value.insert("ExtensionLocation".to_string(), extension_dto.ExtensionLocation.clone());

			if let Some(activation_events) = &extension_dto.ActivationEvents {
				let events:Vec<Value> = activation_events.iter().map(|e| Value::String(e.clone())).collect();
				extension_value.insert("ActivationEvents".to_string(), Value::Array(events));
			}

			if let Some(contributes) = &extension_dto.Contributes {
				extension_value.insert("Contributes".to_string(), contributes.clone());
			}

			Ok(Some(Value::Object(extension_value)))
		} else {
			Ok(None)
		}
	}
}

// --- Capability Requirement Implementations (DI) ---
// All trait implementations are generated using the impl_provider! macro

// Command and Configuration
impl_provider!(CommandExecutor);
impl_provider!(ConfigurationProvider);
impl_provider!(ConfigurationInspector);

// Custom Editor and Debug
impl_provider!(CustomEditorProvider);
impl_provider!(DebugService);

// Document and Diagnostic
impl_provider!(DocumentProvider);
impl_provider!(DiagnosticManager);

// File System
impl_provider!(FileSystemReader);
impl_provider!(FileSystemWriter);

// IPC and Keybinding
impl_provider!(IPCProvider);
impl_provider!(KeybindingProvider);

// Language Features and Output
impl_provider!(LanguageFeatureProviderRegistry);
impl_provider!(OutputChannelManager);

// Secret and SCM
impl_provider!(SecretProvider);
impl_provider!(SourceControlManagementProvider);

// Status Bar and Storage
impl_provider!(StatusBarProvider);
impl_provider!(StorageProvider);

// Synchronization and Terminal
impl_provider!(SynchronizationProvider);
impl_provider!(TerminalProvider);

// Test and Tree View
impl_provider!(TestController);
impl_provider!(TreeViewProvider);

// UI and Webview
impl_provider!(UserInterfaceProvider);
impl_provider!(WebviewProvider);

// Workspace
impl_provider!(WorkspaceProvider);
impl_provider!(WorkspaceEditApplier);

// Extension Management and Search
impl_provider!(ExtensionManagementService);
impl_provider!(SearchProvider);