Mountain/ApplicationState/State/FeatureState/Debug/

DebugState.rs

//! # DebugState Module (ApplicationState)

//! ## RESPONSIBILITIES
//! Manages debug provider state including debug configuration providers and
//! adapter descriptor factories.

//! ## ARCHITECTURAL ROLE
//! DebugState is part of the **FeatureState** module, storing debug provider
//! registrations keyed by debug type.

//! ## KEY COMPONENTS
//! - DebugState: Main struct containing debug provider registrations
//! - Default: Initialization implementation
//! - Helper methods: Debug registration management

//! ## ERROR HANDLING
//! - Thread-safe access via `Arc<tokio::sync::RwLock<...>>`
//! - Proper lock error handling

//! ## LOGGING
//! State changes are logged at appropriate levels (debug, info, warn, error).

//! ## PERFORMANCE CONSIDERATIONS
//! - Lock mutexes briefly and release immediately
//! - Use Arc for shared ownership across threads

use std::{
	collections::HashMap,
	sync::{Arc, Mutex as StandardMutex},
};

use crate::dev_log;

/// Debug configuration provider registration info
#[derive(Clone, Debug)]
pub struct DebugConfigurationProviderRegistration {
	/// The provider handle
	pub ProviderHandle:u32,

	/// The sidecar identifier hosting this provider
	pub SideCarIdentifier:String,
}

/// Debug adapter descriptor factory registration info
#[derive(Clone, Debug)]
pub struct DebugAdapterDescriptorFactoryRegistration {
	/// The factory handle
	pub FactoryHandle:u32,

	/// The sidecar identifier hosting this factory
	pub SideCarIdentifier:String,
}

/// Active debug session entry. Lives in the `DebugSessions` map keyed by
/// session-id (`Uuid::new_v4()` allocated by `DebugProvider::StartDebugging`)
/// so subsequent `SendCommand` calls can resolve the writer end of the
/// spawned adapter's stdin pipe and `DisposeSession` can kill the process.
///
/// `StdinSender` is `None` for debug-types whose adapter descriptor wasn't
/// of the executable kind we know how to spawn (TCP `server` descriptors,
/// `inlineImplementation` descriptors handled entirely in Cocoon, etc.).
/// In those cases we still record the session so command routing can fall
/// through to a reverse-RPC into Cocoon instead of dropping silently.
#[derive(Clone)]
pub struct DebugSessionEntry {
	/// Session ID assigned at `StartDebugging` time.
	pub SessionId:String,

	/// Debug type (e.g. `"node"`, `"chrome"`) - mirrors the configuration
	/// `type` field, used for diagnostics and routing.
	pub DebugType:String,

	/// Sidecar that owns the configuration-provider / adapter-descriptor
	/// factory. Used for reverse-RPC dispatch when the adapter is not a
	/// spawned executable.
	pub SideCarIdentifier:String,

	/// Channel that writes raw DAP frame bytes to the adapter's stdin.
	/// `None` for non-executable adapter kinds.
	pub StdinSender:Option<tokio::sync::mpsc::UnboundedSender<Vec<u8>>>,

	/// PID of the spawned adapter process (when applicable). `None` for
	/// non-executable kinds. Mountain doesn't keep a live `Child` handle
	/// here because `Child` isn't `Clone`; the process termination is
	/// signalled via dropping `StdinSender`, which the spawn's
	/// stdout/stderr drain tasks treat as shutdown.
	pub ChildPid:Option<u32>,
}

/// Debug state containing debug provider registrations.
#[derive(Clone)]
pub struct DebugState {
	/// Debug configuration providers organized by debug type.
	pub DebugConfigurationProviders:Arc<StandardMutex<HashMap<String, DebugConfigurationProviderRegistration>>>,

	/// Debug adapter descriptor factories organized by debug type.
	pub DebugAdapterDescriptorFactories:Arc<StandardMutex<HashMap<String, DebugAdapterDescriptorFactoryRegistration>>>,

	/// Active debug sessions indexed by session-id. Populated by
	/// `DebugProvider::StartDebugging` after the adapter is resolved
	/// (and optionally spawned); removed by `DebugProvider::StopDebugging`
	/// or when the adapter exits. `SendCommand` reads this map to find
	/// the writer for the targeted session.
	pub DebugSessions:Arc<StandardMutex<HashMap<String, DebugSessionEntry>>>,
}

impl Default for DebugState {
	fn default() -> Self {
		dev_log!("exthost", "[DebugState] Initializing default debug state...");

		Self {
			DebugConfigurationProviders:Arc::new(StandardMutex::new(HashMap::new())),

			DebugAdapterDescriptorFactories:Arc::new(StandardMutex::new(HashMap::new())),

			DebugSessions:Arc::new(StandardMutex::new(HashMap::new())),
		}
	}
}

impl DebugState {
	/// Registers a debug configuration provider.
	pub fn RegisterDebugConfigurationProvider(
		&self,

		debug_type:String,

		provider_handle:u32,

		sidecar_identifier:String,
	) -> Result<(), String> {
		let mut guard = self
			.DebugConfigurationProviders
			.lock()
			.map_err(|e| format!("Failed to lock debug configuration providers: {}", e))?;

		guard.insert(
			debug_type,
			DebugConfigurationProviderRegistration {
				ProviderHandle:provider_handle,
				SideCarIdentifier:sidecar_identifier,
			},
		);

		Ok(())
	}

	/// Gets a debug configuration provider registration by debug type.
	pub fn GetDebugConfigurationProvider(&self, debug_type:&str) -> Option<DebugConfigurationProviderRegistration> {
		self.DebugConfigurationProviders
			.lock()
			.ok()
			.and_then(|guard| guard.get(debug_type).cloned())
	}

	/// Registers a debug adapter descriptor factory.
	pub fn RegisterDebugAdapterDescriptorFactory(
		&self,

		debug_type:String,

		factory_handle:u32,

		sidecar_identifier:String,
	) -> Result<(), String> {
		let mut guard = self
			.DebugAdapterDescriptorFactories
			.lock()
			.map_err(|e| format!("Failed to lock debug adapter descriptor factories: {}", e))?;

		guard.insert(
			debug_type,
			DebugAdapterDescriptorFactoryRegistration {
				FactoryHandle:factory_handle,
				SideCarIdentifier:sidecar_identifier,
			},
		);

		Ok(())
	}

	/// Gets a debug adapter descriptor factory registration by debug type.
	pub fn GetDebugAdapterDescriptorFactory(
		&self,

		debug_type:&str,
	) -> Option<DebugAdapterDescriptorFactoryRegistration> {
		self.DebugAdapterDescriptorFactories
			.lock()
			.ok()
			.and_then(|guard| guard.get(debug_type).cloned())
	}

	/// Gets all registered debug configuration providers.
	pub fn GetAllDebugConfigurationProviders(&self) -> HashMap<String, DebugConfigurationProviderRegistration> {
		self.DebugConfigurationProviders
			.lock()
			.ok()
			.map(|guard| guard.clone())
			.unwrap_or_default()
	}

	/// Gets all registered debug adapter descriptor factories.
	pub fn GetAllDebugAdapterDescriptorFactories(&self) -> HashMap<String, DebugAdapterDescriptorFactoryRegistration> {
		self.DebugAdapterDescriptorFactories
			.lock()
			.ok()
			.map(|guard| guard.clone())
			.unwrap_or_default()
	}

	/// Records an active debug session. Replaces any prior entry under the
	/// same `SessionId` (defensive: shouldn't happen since IDs are uuids).
	pub fn RegisterDebugSession(&self, Entry:DebugSessionEntry) -> Result<(), String> {
		let mut Guard = self
			.DebugSessions
			.lock()
			.map_err(|Error| format!("Failed to lock DebugSessions: {}", Error))?;

		Guard.insert(Entry.SessionId.clone(), Entry);

		Ok(())
	}

	/// Resolves an active session by id. Returns a `Clone` so the caller
	/// can drop the lock before doing IO with the entry's `StdinSender`.
	pub fn GetDebugSession(&self, SessionId:&str) -> Option<DebugSessionEntry> {
		self.DebugSessions.lock().ok().and_then(|Guard| Guard.get(SessionId).cloned())
	}

	/// Removes a session from the registry. Dropping the returned entry's
	/// `StdinSender` triggers the adapter-spawn drain tasks to wind down
	/// (their `recv()` returns `None`) which closes the adapter stdin and
	/// the adapter shuts itself down.
	pub fn UnregisterDebugSession(&self, SessionId:&str) -> Option<DebugSessionEntry> {
		self.DebugSessions.lock().ok().and_then(|mut Guard| Guard.remove(SessionId))
	}

	/// Snapshot of all active sessions. Used by diagnostic dev_log surfaces
	/// and the reverse-RPC dispatch when no session-id is supplied.
	pub fn GetAllDebugSessions(&self) -> HashMap<String, DebugSessionEntry> {
		self.DebugSessions.lock().ok().map(|Guard| Guard.clone()).unwrap_or_default()
	}
}