Mountain/

Binary.rs

// File: Mountain/Source/Binary.rs
// Role: Main entry point for the Mountain native host application.
// Responsibilities:
//   - Orchestrate the entire application lifecycle.
//   - Initialize logging (via Tauri plugin), the Echo scheduler,
// 	 ApplicationState, and ApplicationRunTime.
//   - Serve assets via http://localhost (determined by portpicker) to support
// 	 Service Workers.
//   - Parse command-line arguments to open a workspace.
//   - Bootstrap native command registration.
//   - Set up the Vine gRPC server and spawn the Cocoon sidecar process.
//   - Create and customize the main Tauri application window.
//   - Manage the main application event loop and graceful shutdown.
//
// Logging strategy:
//   - Release default: Info (low noise) unless RUST_LOG overrides.
//   - Debug default: Debug (high fidelity) unless RUST_LOG overrides.
//   - Very noisy deps are capped using level_for(...) and filter(...).
//
//
// NOTE (Webview logs):
//   - To see Rust logs in the Webview console, enable TargetKind::Webview and
// 	 call attachConsole() in the frontend.

//! # Mountain Binary Entry Point
//!
//! This file orchestrates the entire application lifecycle. It is responsible
//! for setting up logging, initializing the `Echo` scheduler, the core
//! `ApplicationState`, the `ApplicationRunTime`, the `Vine` gRPC server, the
//! `Cocoon` sidecar process, and the Tauri application window and event loop.

#![allow(non_snake_case, non_camel_case_types)]

use std::{
	path::PathBuf,
	sync::{Arc, Mutex},
};

use Echo::Scheduler::SchedulerBuilder::SchedulerBuilder;
use log::{LevelFilter, debug, error, info, trace, warn};
use tauri::{AppHandle, Manager, RunEvent, Wry};
use tauri_plugin_log::{RotationStrategy, Target, TargetKind, TimezoneStrategy};

use crate::{
	ApplicationState::{
		ApplicationState::{ApplicationState, MapLockError},
		Internal::ScanAndPopulateExtensions,
	},
	Command,
	Environment::{ConfigurationProvider::InitializeAndMergeConfigurations, MountainEnvironment::MountainEnvironment},
	ProcessManagement::{CocoonManagement::InitializeCocoon, InitializationData},
	RunTime::ApplicationRunTime::ApplicationRunTime,
	Vine,
};

// =============================================================================
// Debug Helpers (Highly Verbose, Low Intrusion)
// =============================================================================

/// Logs a checkpoint message at TRACE level (for "every step" tracing).
macro_rules! TraceStep {
	($($arg:tt)*) => {{
		trace!($($arg)*);
	}};
}

// =============================================================================
// IPC Bridge Commands
// =============================================================================

/// A Tauri command to provide the initial workbench configuration to the Sky
/// frontend.
#[tauri::command]
async fn MountainGetWorkbenchConfiguration(
	ApplicationHandle:AppHandle<Wry>,
	State:tauri::State<'_, Arc<ApplicationState>>,
) -> Result<serde_json::Value, String> {
	info!("[IPC] [WorkbenchConfig] Request received.");

	debug!("[IPC] [WorkbenchConfig] Constructing sandbox configuration...");

	let Config = InitializationData::ConstructSandboxConfiguration(&ApplicationHandle, &State)
		.await
		.map_err(|Error| {
			error!("[IPC] [WorkbenchConfig] Failed: {}", Error);

			Error.to_string()
		})?;

	debug!("[IPC] [WorkbenchConfig] Success. Returning payload.");

	Ok(Config)
}

// =============================================================================
// Binary Entrypoint
// =============================================================================

/// The main asynchronous function that sets up and runs the application.
pub fn Fn() {
	// -------------------------------------------------------------------------
	// [Boot] [Runtime] Tokio runtime creation
	// -------------------------------------------------------------------------
	TraceStep!("[Boot] [Runtime] Building Tokio runtime...");

	let Runtime = tokio::runtime::Builder::new_multi_thread()
		.enable_all()
		.build()
		.expect("FATAL: Cannot build Tokio runtime.");

	TraceStep!("[Boot] [Runtime] Tokio runtime built.");

	Runtime.block_on(async {
		// ---------------------------------------------------------------------
		// [Boot] [Args] CLI parsing
		// ---------------------------------------------------------------------
		debug!("[Boot] [Args] Collecting CLI args...");

		let CliArgs:Vec<String> = std::env::args().collect();

		debug!("[Boot] [Args] CLI Args: {:?}", CliArgs);

		let WorkSpacePathArgument = CliArgs.iter().find(|Arg| Arg.ends_with(".code-workspace"));

		TraceStep!("[Boot] [Args] Workspace arg present: {}", WorkSpacePathArgument.is_some());

		let (InitialFolders, WorkSpaceConfigurationPath) = if let Some(PathString) = WorkSpacePathArgument {
			let Path = PathBuf::from(PathString);

			println!("[Boot] [Args] Found workspace argument: {}", Path.display());

			debug!("[Boot] [Workspace] Reading workspace file: {}", Path.display());

			match std::fs::read_to_string(&Path) {
				Ok(Content) => {
					debug!("[Boot] [Workspace] Workspace file read ok ({} bytes).", Content.len());

					crate::WorkSpace::WorkSpaceFileService::ParseWorkSpaceFile(&Path, &Content)
						.map(|Folders| {
							debug!("[Boot] [Workspace] Parsed workspace ok. folder_count={}", Folders.len());

							(Folders, Some(Path))
						})
						.unwrap_or_else(|Error| {
							error!("[Boot] [Workspace] Parse failed: {}. Continuing without workspace.", Error);

							(Vec::new(), None)
						})
				},
				Err(Error) => {
					error!("[Boot] [Workspace] Read failed: {}. Continuing without workspace.", Error);

					(Vec::new(), None)
				},
			}
		} else {
			debug!("[Boot] [Workspace] No workspace provided. Starting empty.");

			(Vec::new(), None)
		};

		// ---------------------------------------------------------------------
		// [Boot] [State] ApplicationState
		// ---------------------------------------------------------------------
		debug!("[Boot] [State] Building ApplicationState...");

		let AppState = Arc::new(ApplicationState {
			WorkSpaceFolders:Arc::new(Mutex::new(InitialFolders)),
			WorkSpaceConfigurationPath:Arc::new(Mutex::new(WorkSpaceConfigurationPath)),
			..ApplicationState::default()
		});

		debug!("[Boot] [State] ApplicationState created and managed.");

		// ---------------------------------------------------------------------
		// [Boot] [Echo] Scheduler
		// ---------------------------------------------------------------------
		let NumberOfWorkers = num_cpus::get().max(2);

		debug!("[Boot] [Echo] Creating scheduler. workers={}", NumberOfWorkers);

		let Scheduler = SchedulerBuilder::Create().WithWorkerCount(NumberOfWorkers).Build();

		debug!("[Boot] [Echo] Scheduler built.");

		let SchedulerForShutdown = Arc::new(Scheduler);

		let SchedulerForRunTime = SchedulerForShutdown.clone();

		TraceStep!("[Boot] [Echo] Scheduler handles prepared.");

		// ---------------------------------------------------------------------
		// [Boot] [Localhost] Port selection (for Service Workers & stable origin)
		// ---------------------------------------------------------------------
		debug!("[Boot] [Localhost] Selecting unused port...");

		let ServerPort =
			portpicker::pick_unused_port().expect("FATAL: Failed to find a free port for Localhost Server");

		debug!("[Boot] [Localhost] Selected port={}", ServerPort);

		let LocalhostUrl = format!("http://localhost:{}", ServerPort);

		println!("[Boot] [Localhost] Selected: {} ({})", ServerPort, LocalhostUrl);

		// ---------------------------------------------------------------------
		// [Boot] [Logging] Log level resolution
		// ---------------------------------------------------------------------
		// Supported by tauri_plugin_log:
		// - level(...) sets the max log level
		// - level_for(...) overrides max level per module
		// - filter(...) discards by metadata
		// - format(...) custom line formatting
		// - targets([...]) configures outputs (Stdout/Webview/File)
		// - timezone_strategy/rotation_strategy for file behavior
		let EnvLogLevel = std::env::var("RUST_LOG").ok().and_then(|s| s.parse::<LevelFilter>().ok());

		let DefaultLogLevel = if cfg!(debug_assertions) { LevelFilter::Debug } else { LevelFilter::Info };

		let LogLevel = EnvLogLevel.unwrap_or(DefaultLogLevel);

		// Log *very early* using stderr/stdout (logger not yet installed).
		// Once the plugin is installed, subsequent logs will go through it.
		eprintln!(
			"[Boot] [Logging] Resolved LogLevel={:?} (env={:?}, default={:?})",
			LogLevel, EnvLogLevel, DefaultLogLevel
		);

		// ---------------------------------------------------------------------
		// [Boot] [Tauri] Builder
		// ---------------------------------------------------------------------
		#[allow(unused_mut)]
		let mut Builder = tauri::Builder::default();

		#[cfg(any(windows, target_os = "linux"))]
		{
			Builder = Builder.any_thread();
		}

		Builder
			// -----------------------------------------------------------------
			// [Boot] [Tauri] [Plugins] Logging
			// -----------------------------------------------------------------
			.plugin(
				tauri_plugin_log::Builder::new()
					.targets([
						Target::new(TargetKind::Stdout),
						Target::new(TargetKind::LogDir {
							file_name: Some("Mountain.log".into()),
						}),
						Target::new(TargetKind::Webview),
					])
					.timezone_strategy(TimezoneStrategy::UseLocal)
					.rotation_strategy(RotationStrategy::KeepAll)
					.level(LogLevel)
					// Cap common noisy deps even when RUST_LOG=trace.
					.level_for("hyper", LevelFilter::Info)
					.level_for("mio", LevelFilter::Info)
					.level_for("tao", LevelFilter::Info)
					.level_for("tracing", LevelFilter::Info)
					// Drop noise by target metadata.
					.filter(|Metadata| {
						!Metadata.target().starts_with("polling")
							&& !Metadata.target().starts_with("tokio_reactor")
							&& !Metadata.target().starts_with("want")
					})
					// Add category-like formatting: DATE [LEVEL] [TARGET] message.
					.format(|out, message, record| {
						out.finish(format_args!(
							"[{:<5}] [{}] {}",
							record.level(),
							record.target(),
							message
						))
					})
					.build(),
			)
			// -----------------------------------------------------------------
			// [Boot] [Tauri] [Plugins] Localhost server (pre-selected port)
			// -----------------------------------------------------------------
			.plugin(tauri_plugin_localhost::Builder::new(ServerPort)
			.on_request(|_, Response| {
				Response.add_header("Access-Control-Allow-Origin", "*");
				Response.add_header("Access-Control-Allow-Methods", "GET, POST, OPTIONS, HEAD");
				Response.add_header("Access-Control-Allow-Headers", "Content-Type, Authorization, Origin, Accept");
			})
			.build())
			// -----------------------------------------------------------------
			// [Boot] [DI] Global state
			// -----------------------------------------------------------------
			.manage(AppState.clone())
			// -----------------------------------------------------------------
			// [Lifecycle] Setup hook
			// -----------------------------------------------------------------
			.setup({
				let LocalhostUrl = LocalhostUrl.clone();

				move |Application| {
					info!("[Lifecycle] [Setup] Setup hook started.");

					debug!("[Lifecycle] [Setup] LocalhostUrl={}", LocalhostUrl);

					let ApplicationHandle = Application.handle().clone();

					TraceStep!("[Lifecycle] [Setup] AppHandle acquired.");

					// ---------------------------------------------------------
					// [Lifecycle] [Commands] Bootstrap native commands
					// ---------------------------------------------------------
					debug!("[Lifecycle] [Commands] Registering native commands...");

					Command::Bootstrap::RegisterNativeCommands(&ApplicationHandle, &AppState)
						.expect("FATAL: Failed to register native commands.");

					debug!("[Lifecycle] [Commands] Native commands registered.");

					// ---------------------------------------------------------
					// [UI] [Window] Main window creation
					// ---------------------------------------------------------
					debug!("[UI] [Window] Building init script...");

					let InitScript = format!("window.__MOUNTAIN_BASE_URL__ = '{}';", LocalhostUrl);

					TraceStep!("[UI] [Window] InitScript bytes={}", InitScript.len());

					debug!("[UI] [Window] Creating window builder...");

					let mut WindowBuilder = tauri::WebviewWindowBuilder::new(
						Application,
						"main",
						tauri::WebviewUrl::External(
							format!("{}/Application/index.html", LocalhostUrl).parse().unwrap(),
						),
					)
					.use_https_scheme(false)
					.initialization_script(&InitScript)
					.zoom_hotkeys_enabled(true)
					.browser_extensions_enabled(false);

					#[cfg(any(target_os = "windows", target_os = "macos", target_os = "linux"))]
					{
						WindowBuilder = WindowBuilder
							.title("Mountain")
							.maximized(true)
							.decorations(false)
							.shadow(true);
					}

					debug!("[UI] [Window] Building main window...");

					#[allow(unused_variables)]
					let MainWindow = WindowBuilder.build().expect("FATAL: Main window build failed");

					info!("[UI] [Window] Main window ready.");

					#[cfg(debug_assertions)]
					{
						debug!("[UI] [Window] Debug build: opening DevTools.");

						MainWindow.open_devtools();
					}

					// ---------------------------------------------------------
					// [Backend] [Env] Mountain environment
					// ---------------------------------------------------------
					debug!("[Backend] [Env] Creating MountainEnvironment...");

					let Environment = Arc::new(MountainEnvironment::Create(ApplicationHandle.clone()));

					info!("[Backend] [Env] MountainEnvironment ready.");

					// ---------------------------------------------------------
					// [Backend] [Runtime] ApplicationRunTime
					// ---------------------------------------------------------
					debug!("[Backend] [Runtime] Creating ApplicationRunTime...");

					let RunTime = Arc::new(ApplicationRunTime::Create(
						SchedulerForRunTime.clone(),
						Environment.clone(),
					));

					ApplicationHandle.manage(RunTime);

					info!("[Backend] [Runtime] ApplicationRunTime managed.");

					// ---------------------------------------------------------
					// [Lifecycle] [PostSetup] Async initialization work
					// ---------------------------------------------------------
					let PostSetupApplicationHandle = ApplicationHandle.clone();

					let PostSetupEnvironment = Environment.clone();

					tauri::async_runtime::spawn(async move {
						info!("[Lifecycle] [PostSetup] Starting...");

						let AppStateForSetup = PostSetupEnvironment.ApplicationState.clone();

						TraceStep!("[Lifecycle] [PostSetup] AppState cloned.");

						// [Config]
						debug!("[Config] InitializeAndMergeConfigurations starting...");

						if let Err(Error) = InitializeAndMergeConfigurations(&PostSetupEnvironment).await {
							error!("[Config] InitializeAndMergeConfigurations failed: {}", Error);
						} else {
							info!("[Config] InitializeAndMergeConfigurations done.");
						}

						// [Extensions] [ScanPaths]
						{
							debug!("[Extensions] [ScanPaths] Locking ExtensionScanPaths...");

							let mut ScanPathsGuard = AppStateForSetup
								.ExtensionScanPaths
								.lock()
								.map_err(MapLockError)
								.expect("FATAL: Failed to lock ExtensionScanPaths");

							debug!("[Extensions] [ScanPaths] Adding default scan paths...");

							if let Ok(ExecutableDirectory) = std::env::current_exe() {
								if let Some(Parent) = ExecutableDirectory.parent() {
									let ResourcesPath = Parent.join("../Resources/extensions");

									let LocalPath = Parent.join("extensions");

									debug!(
										"[Extensions] [ScanPaths] + {}",
										ResourcesPath.display()
									);

									ScanPathsGuard.push(ResourcesPath);

									debug!(
										"[Extensions] [ScanPaths] + {}",
										LocalPath.display()
									);

									ScanPathsGuard.push(LocalPath);
								}
							}

							info!(
								"[Extensions] [ScanPaths] Initialized: {:?}",
								*ScanPathsGuard
							);
						}

						// [Extensions] [Scan]
						debug!("[Extensions] [Scan] ScanAndPopulateExtensions starting...");

						if let Err(Error) =
							ScanAndPopulateExtensions(PostSetupApplicationHandle.clone(), &AppStateForSetup).await
						{
							error!("[Extensions] [Scan] Failed: {}", Error);
						} else {
							info!("[Extensions] [Scan] Completed.");
						}

						// [Vine] [gRPC]
						debug!("[Vine] [Init] Starting Vine gRPC server...");

						if let Err(Error) = Vine::Server::Initialize::Initialize(
							PostSetupApplicationHandle.clone(),
							"[::1]:50051".to_string(),
						) {
							error!("[Vine] [Init] Failed: {}", Error);
						} else {
							info!("[Vine] [Init] Ready.");
						}

						// [Cocoon] [Sidecar]
						debug!("[Cocoon] [Init] InitializeCocoon starting...");

						if let Err(Error) = InitializeCocoon(&PostSetupApplicationHandle, &PostSetupEnvironment).await {
							error!("[Cocoon] [Init] Failed: {}", Error);
						} else {
							info!("[Cocoon] [Init] Ready.");
						}

						info!("[Lifecycle] [PostSetup] Complete. System ready.");
					});

					Ok(())
				}
			})
			// ---------------------------------------------------------------------
			// [Tauri] [Plugins] Standard
			// ---------------------------------------------------------------------
			.plugin(tauri_plugin_dialog::init())
			.plugin(tauri_plugin_fs::init())
			// ---------------------------------------------------------------------
			// [IPC] Command routing
			// ---------------------------------------------------------------------
			.invoke_handler(tauri::generate_handler![
				MountainGetWorkbenchConfiguration,
				Command::TreeView::GetTreeViewChildren,
				Command::LanguageFeature::MountainProvideHover,
				Command::LanguageFeature::MountainProvideCompletions,
				Command::LanguageFeature::MountainProvideDefinition,
				Command::LanguageFeature::MountainProvideReferences,
				Command::SourceControlManagement::GetAllSourceControlManagementState,
				Command::Keybinding::GetResolvedKeybinding,
				crate::Track::DispatchLogic::DispatchFrontendCommand,
				crate::Track::DispatchLogic::ResolveUIRequest,
			])
			// ---------------------------------------------------------------------
			// [Tauri] Build & run loop
			// ---------------------------------------------------------------------
			.build(tauri::generate_context!())
			.expect("FATAL: Error while building Mountain Tauri application")
			.run(move |ApplicationHandle, Event| {
				// Debug-only: log selected lifecycle events (but avoid super-noisy ones).
				if cfg!(debug_assertions) {
					match &Event {
						RunEvent::MainEventsCleared => {},
						RunEvent::WindowEvent { .. } => {},
						_ => debug!("[Lifecycle] [RunEvent] {:?}", Event),
					}
				}

				if let RunEvent::ExitRequested { api, .. } = Event {
					warn!("[Lifecycle] [Shutdown] Exit requested. Starting graceful shutdown...");

					api.prevent_exit();

					let SchedulerHandle = SchedulerForShutdown.clone();

					let ApplicationHandleClone = ApplicationHandle.clone();

					tokio::spawn(async move {
						debug!("[Lifecycle] [Shutdown] Shutting down ApplicationRunTime...");

						if let Some(RunTime) = ApplicationHandleClone.try_state::<Arc<ApplicationRunTime>>() {
							RunTime.inner().clone().Shutdown().await;

							info!("[Lifecycle] [Shutdown] ApplicationRunTime stopped.");

						} else {
							error!("[Lifecycle] [Shutdown] ApplicationRunTime not found.");

						}

						debug!("[Lifecycle] [Shutdown] Stopping Echo scheduler...");

						if let Ok(mut Scheduler) = Arc::try_unwrap(SchedulerHandle) {
							Scheduler.Stop().await;

							info!("[Lifecycle] [Shutdown] Echo scheduler stopped.");
						} else {
							error!("[Lifecycle] [Shutdown] Scheduler not exclusively owned; cannot stop cleanly.");
						}

						info!("[Lifecycle] [Shutdown] Done. Exiting process.");

						ApplicationHandleClone.exit(0);
					});
				}
			});

		info!("[Lifecycle] [Exit] Mountain application has shut down.");
	});
}