Skip to main content

Mountain/IPC/
ConfigurationBridge.rs

1//! # Configuration Bridge - Bidirectional Configuration Synchronization
2//!
3//! **File Responsibilities:**
4//! This module manages bidirectional synchronization of configuration between
5//! Mountain's Rust backend and Wind's TypeScript frontend. It ensures
6//! configuration consistency across the entire CodeEditorLand ecosystem while
7//! handling conflicts and updates gracefully.
8//!
9//! **Architectural Role in Wind-Mountain Connection:**
10//!
11//! The ConfigurationBridge is the synchronization layer that:
12//!
13//! 1. **Translates Configuration Formats:** Converts between Mountain's
14//!    internal config structure and Wind's desktop configuration interface
15//! 2. **Bidirectional Sync:** Maintains consistency in both directions
16//!    (Wind→Mountain and Mountain→Wind)
17//! 3. **Conflict Resolution:** Handles merge conflicts when multiple sources
18//!    update configuration simultaneously
19//! 4. **Validation:** Ensures all configuration changes are valid before
20//!    applying
21//! 5. **Identity Management:** Generates unique machine and session IDs for
22//!    multi- instance scenarios
23//!
24//! **Bidirectional Synchronization Flow:**
25//!
26//! **Mountain → Wind Sync:**
27//! ```
28//! Mountain Services (Internal Config)
29//!       |
30//!       | get_mountain_configuration()
31//!       v
32//! ConfigurationBridge
33//!       |
34//!       | WindServiceAdapter.convert_to_wind_configuration()
35//!       v
36//! Wind Desktop Configuration Format
37//!       |
38//!       | send_configuration_to_wind()
39//!       v
40//! Wind Frontend (via IPC)
41//! ```
42//!
43//! **Wind → Mountain Sync:**
44//! ```
45//! Wind Frontend (User Changes)
46//!       |
47//!       | WindConfigurationChange()
48//!       v
49//! ConfigurationBridge
50//!       |
51//!       | convert_to_mountain_configuration()
52//!       v
53//! Mountain Configuration Format
54//!       |
55//!       | update_mountain_configuration()
56//!       v
57//! Mountain Services (Internal Config)
58//! ```
59//!
60//! **Configuration Bridge Features:**
61//!
62//! **1. Format Translation:**
63//! - Mountain's internal JSON structure → Wind's desktop configuration
64//!   interface
65//! - Handles nested configuration objects
66//! - Type conversion between TypeScript and Rust types
67//!
68//! **2. Conflict Resolution Strategy:**
69//!
70//! **Current Implementation (Basic):**
71//! - Last-write-wins (most recent update takes precedence)
72//! - Configuration is validated before applying
73//! - Invalid changes are rejected entirely
74//!
75//! **Advanced Conflict Resolution (Future Enhancement):**
76//! - Detect conflicts based on modification timestamps
77//! - Provide conflict metadata (source, timestamp, value)
78//! - Support three-way merge strategies:
79//!   - **Ours:** Keep Mountain's version
80//!   - **Theirs:** Use Wind's version
81//!   - **Merge:** Attempt intelligent merge
82//! - Conflict UI prompts in Wind for user resolution
83//!
84//! **3. Validation Rules:**
85//!
86//! **Type Validation:**
87//! - `zoom_level`: Number, range -8.0 to 9.0
88//! - `font_size`: Number, range 6.0 to 100.0
89//! - `is_packaged`: Boolean
90//! - `theme`, `platform`, `arch`: String, non-empty
91//! - All other values: Not null
92//!
93//! **Key Validation:**
94//! - Configuration keys must not be empty or whitespace
95//! - Reserved keys cannot be modified
96//! - Nested paths use dot notation (e.g., "editor.theme")
97//!
98//! **Value Validation:**
99//! - Ranges checked for numeric values
100//! - Enum validation for predefined options
101//! - Pattern validation for string values (URLs, paths)
102//!
103//! **4. Identity Management:**
104//!
105//! **Machine ID Generation (Microsoft-Inspired):**
106//! - **macOS:** Get system serial number via `system_profiler`
107//! - **Windows:** Get machine UUID via `wmic csproduct get UUID`
108//! - **Linux:** Read from `/etc/machine-id` or `/var/lib/dbus/machine-id`
109//! - **Fallback:** Hash hostname + timestamp
110//!
111//! **Session ID Generation (Secure):**
112//! - Combine timestamp, random number, and process ID
113//! - Hash with SHA-256
114//! - Use first 16 characters of hex digest
115//! - Format: `session-{16-char-hash}`
116//!
117//! **5. Bidirectional Sync Triggers:**
118//!
119//! **Triggers for Mountain → Wind:**
120//! - Configuration changes from Mountain services
121//! - Periodic sync interval (configurable)
122//! - Manual sync request from Mountain
123//!
124//! **Triggers for Wind → Mountain:**
125//! - User changes configuration in Wind UI
126//! - Settings panel updates
127//! - Extension configuration changes
128//! - Command palette configuration commands
129//!
130//! **Key Structures:**
131//!
132//! **ConfigurationBridge:**
133//! Main synchronization orchestrator
134//! - `get_wind_desktop_configuration()` - Get config in Wind format
135//! - `update_configuration_from_wind()` - Apply Wind's config changes
136//! - `synchronize_configuration()` - Force bidirectional sync
137//! - `get_configuration_status()` - Get sync status info
138//!
139//! **ConfigurationStatus:**
140//! Current synchronization state
141//! - `is_valid` - Whether configuration is valid
142//! - `last_sync` - Timestamp of last successful sync
143//! - `configuration_keys` - List of all configuration keys
144//!
145//! **Tauri Commands:**
146//!
147//! The module provides Tauri commands for Wind to invoke:
148//!
149//! - `mountain_get_wind_desktop_configuration` - Get config for Wind UI
150//! - `get_configuration_data` - Get all configuration data
151//! - `save_configuration_data` - Save configuration from Wind
152//! - `mountain_update_configuration_from_wind` - Update config from Wind
153//! - `mountain_synchronize_configuration` - Force sync
154//! - `mountain_get_configuration_status` - Get sync status
155//!
156//! **Configuration Flow Examples:**
157//!
158//! **Example 1: Wind Initializing**
159//! ```typescript
160//! // Wind startup
161//! const config = await invoke('mountain_get_wind_desktop_configuration');
162//! applyConfiguration(config);
163//! ```
164//!
165//! **Example 2: User Changes Theme**
166//! ```typescript
167//! // User changes theme in Wind UI
168//! const newConfig = { theme: 'dark', 'editor.fontSize': 14 };
169//! await invoke('save_configuration_data', newConfig);
170//! ```
171//!
172//! **Example 3: Mountain Updates Setting**
173//! ```text
174//! // Mountain service updates configuration
175//! let bridge = ConfigurationBridge::new(runtime);
176//! bridge.synchronize_configuration().await?;
177//!
178//! // Result: Wind UI automatically updates via IPC event
179//! ```
180//!
181//! **Error Handling Strategy:**
182//!
183//! **Configuration Validation Errors:**
184//! - Reject entire invalid configuration
185//! - Return detailed validation error messages
186//! - List which keys/values failed validation
187//!
188//! **Format Conversion Errors:**
189//! - Log conversion errors with field names
190//! - Attempt graceful fallback for missing fields
191//! - Use defaults for conversion failures
192//!
193//! **Sync Errors:**
194//! - Log sync failures with timestamps
195//! - Queue sync for retry on transient errors
196//! - Alert monitoring system on persistent failures
197//!
198//! **Integration with Other Modules:**
199//!
200//! **WindServiceAdapters:**
201//! - Uses `WindServiceAdapter.convert_to_wind_configuration()`
202//! - Depends on `WindDesktopConfiguration` structure
203//!
204//! **TauriIPCServer:**
205//! - Sends configuration updates via IPC events
206//! - Receives configuration changes from Wind
207//!
208//! **Mountain Configuration Service:**
209//! - Delegates to `ConfigurationProvider` trait
210//! - Uses `ConfigurationTarget` for scoping
211//!
212//! **Best Practices:**
213//!
214//! 1. **Always Validate:** Never apply configuration without validation
215//! 2. **Atomic Updates:** Apply entire configuration atomically
216//! 3. **Versioning:** Consider adding configuration versioning
217//! 4. **Change Logging:** Log all configuration changes for audit
218//! 5. **Fallback Support:** Provide sensible defaults for all settings
219//! 6. **Conflict Detection:** Implement proper conflict detection before merges
220
221use std::sync::Arc;
222
223use serde::{Deserialize, Serialize};
224use tauri::Manager;
225// Type aliases for Configuration DTOs to simplify usage
226use CommonLibrary::Configuration::DTO::{
227	ConfigurationOverridesDTO as ConfigurationOverridesDTOModule,
228	ConfigurationTarget as ConfigurationTargetModule,
229};
230type ConfigurationOverridesDTO = ConfigurationOverridesDTOModule::ConfigurationOverridesDTO;
231type ConfigurationTarget = ConfigurationTargetModule::ConfigurationTarget;
232
233use CommonLibrary::{Configuration::ConfigurationProvider::ConfigurationProvider, Environment::Requires::Requires};
234use sha2::Digest;
235
236use crate::{
237	IPC::WindServiceAdapters::{
238		WindDesktopConfiguration::Struct as WindDesktopConfiguration,
239		WindServiceAdapter::Struct as WindServiceAdapter,
240	},
241	RunTime::ApplicationRunTime::ApplicationRunTime,
242	dev_log,
243};
244
245/// Configuration bridge that handles Wind's desktop configuration needs
246pub struct ConfigurationBridge {
247	runtime:Arc<ApplicationRunTime>,
248}
249
250impl ConfigurationBridge {
251	/// Create a new configuration bridge
252	pub fn new(runtime:Arc<ApplicationRunTime>) -> Self {
253		dev_log!("config", "[ConfigurationBridge] Creating configuration bridge");
254		Self { runtime }
255	}
256
257	/// Get Wind-compatible desktop configuration
258	pub async fn get_wind_desktop_configuration(&self) -> Result<WindDesktopConfiguration, String> {
259		dev_log!("config", "[ConfigurationBridge] Getting Wind desktop configuration");
260
261		// Get the current Mountain configuration
262		let mountain_config = self.get_mountain_configuration().await?;
263
264		// Convert to Wind format using the service adapter
265		let service_adapter = WindServiceAdapter::new(self.runtime.clone());
266		let wind_config = service_adapter.convert_to_wind_configuration(mountain_config).await?;
267
268		dev_log!("config", "[ConfigurationBridge] Wind configuration ready");
269		Ok(wind_config)
270	}
271
272	/// Update configuration from Wind frontend
273	pub async fn update_configuration_from_wind(&self, wind_config:WindDesktopConfiguration) -> Result<(), String> {
274		dev_log!("config", "[ConfigurationBridge] Updating configuration from Wind");
275
276		// Convert Wind configuration to Mountain format
277		let mountain_config = self.convert_to_mountain_configuration(wind_config).await?;
278
279		// Update Mountain's configuration system
280		self.update_mountain_configuration(mountain_config).await?;
281
282		dev_log!("config", "[ConfigurationBridge] Configuration updated successfully");
283		Ok(())
284	}
285
286	/// Get Mountain's current configuration
287	async fn get_mountain_configuration(&self) -> Result<serde_json::Value, String> {
288		dev_log!("config", "[ConfigurationBridge] Getting Mountain configuration");
289
290		let config_provider:Arc<dyn ConfigurationProvider> = self.runtime.Environment.Require();
291
292		let config = config_provider
293			.GetConfigurationValue(None, ConfigurationOverridesDTO::default())
294			.await
295			.map_err(|e| format!("Failed to get Mountain configuration: {}", e))?;
296
297		Ok(config)
298	}
299
300	/// Update Mountain's configuration
301	async fn update_mountain_configuration(&self, config:serde_json::Value) -> Result<(), String> {
302		dev_log!("config", "[ConfigurationBridge] Updating Mountain configuration");
303
304		// Validate configuration before updating
305		if !self.validate_configuration(&config) {
306			return Err("Invalid configuration data".to_string());
307		}
308
309		let config_provider:Arc<dyn ConfigurationProvider> = self.runtime.Environment.Require();
310
311		// Update configuration values
312		if let Some(obj) = config.as_object() {
313			for (key, value) in obj {
314				config_provider
315					.UpdateConfigurationValue(
316						key.clone(),
317						value.clone(),
318						ConfigurationTarget::User,
319						ConfigurationOverridesDTO::default(),
320						None,
321					)
322					.await
323					.map_err(|e| format!("Failed to update configuration key {}: {}", key, e))?;
324			}
325		}
326
327		Ok(())
328	}
329
330	/// Validate configuration data
331	fn validate_configuration(&self, config:&serde_json::Value) -> bool {
332		// Basic validation: config must be an object
333		if !config.is_object() {
334			return false;
335		}
336
337		// Validate individual configuration values
338		if let Some(obj) = config.as_object() {
339			for (key, value) in obj {
340				// Key validation
341				if key.trim().is_empty() {
342					return false;
343				}
344
345				// Value type validation
346				match key.as_str() {
347					"zoom_level" | "font_size" => {
348						if let Some(num) = value.as_f64() {
349							if key == "zoom_level" && (num < -8.0 || num > 9.0) {
350								return false;
351							}
352							if key == "font_size" && (num < 6.0 || num > 100.0) {
353								return false;
354							}
355						} else {
356							return false;
357						}
358					},
359					"is_packaged" | "enable_feature" => {
360						if !value.is_boolean() {
361							return false;
362						}
363					},
364					"theme" | "platform" | "arch" => {
365						if !value.is_string() || value.as_str().unwrap().trim().is_empty() {
366							return false;
367						}
368					},
369					_ => {
370						// Default validation: value must not be null
371						if value.is_null() {
372							return false;
373						}
374					},
375				}
376			}
377		}
378
379		true
380	}
381
382	/// Convert Wind configuration to Mountain format
383	async fn convert_to_mountain_configuration(
384		&self,
385		wind_config:WindDesktopConfiguration,
386	) -> Result<serde_json::Value, String> {
387		dev_log!("config", "[ConfigurationBridge] Converting Wind config to Mountain format");
388
389		let machine_id = self.generate_machine_id().await.unwrap_or_else(|e| {
390			dev_log!("config", "warn: [ConfigurationBridge] Failed to generate machine ID: {}", e);
391			"wind-machine-fallback".to_string()
392		});
393
394		let session_id = self.generate_session_id().await.unwrap_or_else(|e| {
395			dev_log!("config", "warn: [ConfigurationBridge] Failed to generate session ID: {}", e);
396			"wind-session-fallback".to_string()
397		});
398
399		let mountain_config = serde_json::json!({
400			"window_id": wind_config.window_id.to_string(),
401			"machine_id": machine_id,
402			"session_id": session_id,
403			"log_level": wind_config.log_level,
404			"app_root": wind_config.app_root,
405			"user_data_dir": wind_config.user_data_path,
406			"tmp_dir": wind_config.temp_path,
407			"platform": wind_config.platform,
408			"arch": wind_config.arch,
409			"zoom_level": wind_config.zoom_level.unwrap_or(0.0),
410			"backup_path": wind_config.backup_path.unwrap_or_default(),
411			"home_dir": wind_config.profiles.home,
412			"is_packaged": wind_config.is_packaged,
413		});
414
415		Ok(mountain_config)
416	}
417
418	/// Synchronize configuration between Mountain and Wind
419	pub async fn synchronize_configuration(&self) -> Result<(), String> {
420		dev_log!("config", "[ConfigurationBridge] Synchronizing configuration");
421
422		// Get Mountain's current configuration
423		let mountain_config = self.get_mountain_configuration().await?;
424
425		// Convert to Wind format
426		let service_adapter = WindServiceAdapter::new(self.runtime.clone());
427		let wind_config = service_adapter.convert_to_wind_configuration(mountain_config).await?;
428
429		// Send configuration to Wind via IPC
430		self.send_configuration_to_wind(wind_config).await?;
431
432		dev_log!("config", "[ConfigurationBridge] Configuration synchronized");
433		Ok(())
434	}
435
436	/// Send configuration to Wind frontend via IPC
437	async fn send_configuration_to_wind(&self, config:WindDesktopConfiguration) -> Result<(), String> {
438		dev_log!("config", "[ConfigurationBridge] Sending configuration to Wind");
439
440		// Get the IPC server
441		if let Some(ipc_server) = self
442			.runtime
443			.Environment
444			.ApplicationHandle
445			.try_state::<crate::IPC::TauriIPCServer_Old::TauriIPCServer>()
446		{
447			let config_json =
448				serde_json::to_value(config).map_err(|e| format!("Failed to serialize configuration: {}", e))?;
449
450			ipc_server
451				.send("configuration:update", config_json)
452				.await
453				.map_err(|e| format!("Failed to send configuration to Wind: {}", e))?;
454		} else {
455			return Err("IPC Server not found".to_string());
456		}
457
458		Ok(())
459	}
460
461	/// Handle configuration changes from Wind
462	pub async fn WindConfigurationChange(&self, new_config:serde_json::Value) -> Result<(), String> {
463		dev_log!("config", "[ConfigurationBridge] Handling Wind configuration change");
464
465		// Parse Wind configuration
466		let wind_config:WindDesktopConfiguration =
467			serde_json::from_value(new_config).map_err(|e| format!("Failed to parse Wind configuration: {}", e))?;
468
469		// Update Mountain configuration
470		self.update_configuration_from_wind(wind_config).await?;
471
472		dev_log!("config", "[ConfigurationBridge] Wind configuration change handled");
473		Ok(())
474	}
475
476	/// Get configuration status
477	pub async fn get_configuration_status(&self) -> Result<ConfigurationStatus, String> {
478		dev_log!("config", "[ConfigurationBridge] Getting configuration status");
479
480		let mountain_config = self.get_mountain_configuration().await?;
481		let is_valid = !mountain_config.is_null();
482
483		let status = ConfigurationStatus {
484			is_valid,
485			last_sync:std::time::SystemTime::now()
486				.duration_since(std::time::UNIX_EPOCH)
487				.unwrap_or_default()
488				.as_millis() as u64,
489			configuration_keys:if let Some(obj) = mountain_config.as_object() {
490				obj.keys().map(|k| k.clone()).collect()
491			} else {
492				Vec::new()
493			},
494		};
495
496		Ok(status)
497	}
498
499	/// Generate unique machine ID using advanced Microsoft-inspired patterns
500	async fn generate_machine_id(&self) -> Result<String, String> {
501		// IMPLEMENTATION: Multi-platform machine ID generation
502		#[cfg(target_os = "macos")]
503		{
504			use std::process::Command;
505
506			// Get macOS serial number using system_profiler
507			let result = Command::new("system_profiler")
508				.arg("SPHardwareDataType")
509				.arg("-json")
510				.output()
511				.map_err(|e| format!("Failed to execute system_profiler: {}", e))?;
512
513			if result.status.success() {
514				let output_str = String::from_utf8_lossy(&result.stdout);
515				if let Ok(json) = serde_json::from_str::<serde_json::Value>(&output_str) {
516					if let Some(serial) = json["SPHardwareDataType"][0]["serial_number"].as_str() {
517						return Ok(format!("mac-{}", serial));
518					}
519				}
520			}
521		}
522
523		#[cfg(target_os = "windows")]
524		{
525			use std::process::Command;
526
527			// Get Windows machine ID using wmic
528			let result = Command::new("wmic")
529				.arg("csproduct")
530				.arg("get")
531				.arg("UUID")
532				.output()
533				.map_err(|e| format!("Failed to execute wmic: {}", e))?;
534
535			if result.status.success() {
536				let output_str = String::from_utf8_lossy(&result.stdout);
537				let lines:Vec<&str> = output_str.lines().collect();
538				if lines.len() > 1 {
539					let uuid = lines[1].trim();
540					if !uuid.is_empty() {
541						return Ok(format!("win-{}", uuid));
542					}
543				}
544			}
545		}
546
547		#[cfg(target_os = "linux")]
548		{
549			use std::fs;
550
551			// Try to read machine-id from /etc/machine-id
552			if let Ok(content) = fs::read_to_string("/etc/machine-id") {
553				let machine_id = content.trim();
554				if !machine_id.is_empty() {
555					return Ok(format!("linux-{}", machine_id));
556				}
557			}
558
559			// Fallback to /var/lib/dbus/machine-id
560			if let Ok(content) = fs::read_to_string("/var/lib/dbus/machine-id") {
561				let machine_id = content.trim();
562				if !machine_id.is_empty() {
563					return Ok(format!("linux-{}", machine_id));
564				}
565			}
566		}
567
568		// Fallback: Generate a unique ID based on hostname and timestamp
569		let hostname = hostname::get()
570			.map_err(|e| format!("Failed to get hostname: {}", e))?
571			.to_string_lossy()
572			.to_string();
573
574		let timestamp = std::time::SystemTime::now()
575			.duration_since(std::time::UNIX_EPOCH)
576			.unwrap_or_default()
577			.as_millis();
578
579		Ok(format!("fallback-{}-{}", hostname, timestamp))
580	}
581
582	/// Generate unique session ID with Microsoft-inspired security patterns
583	async fn generate_session_id(&self) -> Result<String, String> {
584		use std::time::{SystemTime, UNIX_EPOCH};
585
586		// IMPLEMENTATION: Secure session ID generation
587		let random_part:u64 = rand::random();
588
589		let timestamp = SystemTime::now().duration_since(UNIX_EPOCH).unwrap_or_default().as_millis();
590
591		// Get process ID for additional uniqueness
592		let process_id = std::process::id();
593
594		// Create a hash-based session ID
595		let session_data = format!("{}:{}:{}", timestamp, random_part, process_id);
596		let mut hasher = sha2::Sha256::new();
597		hasher.update(session_data.as_bytes());
598		let result = hasher.finalize();
599
600		// Convert to hex string and take first 16 characters. sha2 0.11
601		// dropped the `LowerHex` impl from `Digest::finalize()`'s output
602		// (now `hybrid_array::Array`); `hex::encode` produces the same
603		// lowercase-hex string the old `format!("{:x}", …)` emitted.
604		let hex_string = hex::encode(result);
605		let session_id = hex_string.chars().take(16).collect::<String>();
606
607		dev_log!("config", "[ConfigurationBridge] Generated session ID: {}", session_id);
608		Ok(format!("session-{}", session_id))
609	}
610}
611
612/// Configuration status structure
613#[derive(Debug, Clone, Serialize, Deserialize)]
614pub struct ConfigurationStatus {
615	pub is_valid:bool,
616	pub last_sync:u64,
617	pub configuration_keys:Vec<String>,
618}
619
620/// Tauri command to get Wind desktop configuration
621#[tauri::command]
622pub async fn mountain_get_wind_desktop_configuration(
623	app_handle:tauri::AppHandle,
624) -> Result<WindDesktopConfiguration, String> {
625	dev_log!("config", "[ConfigurationBridge] Tauri command: get_wind_desktop_configuration");
626
627	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
628		let bridge = ConfigurationBridge::new(runtime.inner().clone());
629		bridge.get_wind_desktop_configuration().await
630	} else {
631		Err("ApplicationRunTime not found".to_string())
632	}
633}
634
635/// Tauri command to get configuration data for Wind frontend
636#[tauri::command]
637pub async fn get_configuration_data(app_handle:tauri::AppHandle) -> Result<serde_json::Value, String> {
638	dev_log!("config", "[ConfigurationBridge] Tauri command: get_configuration_data");
639
640	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
641		let bridge = ConfigurationBridge::new(runtime.inner().clone());
642
643		// Get Mountain's current configuration
644		let mountain_config = bridge.get_mountain_configuration().await?;
645
646		// Convert to Wind format
647		let config_data = serde_json::json!({
648			"application": mountain_config.clone(),
649			"workspace": mountain_config.clone(),
650			"profile": mountain_config.clone()
651		});
652
653		dev_log!("config", "[ConfigurationBridge] Configuration data retrieved successfully");
654		Ok(config_data)
655	} else {
656		Err("ApplicationRunTime not found".to_string())
657	}
658}
659
660/// Tauri command to save configuration data from Wind frontend
661#[tauri::command]
662pub async fn save_configuration_data(app_handle:tauri::AppHandle, config_data:serde_json::Value) -> Result<(), String> {
663	dev_log!("config", "[ConfigurationBridge] Tauri command: save_configuration_data");
664
665	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
666		let bridge = ConfigurationBridge::new(runtime.inner().clone());
667
668		// Update Mountain configuration with the new data
669		bridge.update_mountain_configuration(config_data).await?;
670
671		dev_log!("config", "[ConfigurationBridge] Configuration data saved successfully");
672		Ok(())
673	} else {
674		Err("ApplicationRunTime not found".to_string())
675	}
676}
677
678/// Tauri command to update configuration from Wind
679#[tauri::command]
680pub async fn mountain_update_configuration_from_wind(
681	app_handle:tauri::AppHandle,
682	config:serde_json::Value,
683) -> Result<(), String> {
684	dev_log!("config", "[ConfigurationBridge] Tauri command: update_configuration_from_wind");
685
686	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
687		let bridge = ConfigurationBridge::new(runtime.inner().clone());
688		bridge.WindConfigurationChange(config).await
689	} else {
690		Err("ApplicationRunTime not found".to_string())
691	}
692}
693
694/// Tauri command to synchronize configuration
695#[tauri::command]
696pub async fn mountain_synchronize_configuration(app_handle:tauri::AppHandle) -> Result<serde_json::Value, String> {
697	dev_log!("config", "[ConfigurationBridge] Tauri command: synchronize_configuration");
698
699	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
700		let bridge = ConfigurationBridge::new(runtime.inner().clone());
701		bridge
702			.synchronize_configuration()
703			.await
704			.map(|_| serde_json::json!({ "status": "success" }))
705	} else {
706		Err("ApplicationRunTime not found".to_string())
707	}
708}
709
710/// Tauri command to get configuration status
711#[tauri::command]
712pub async fn mountain_get_configuration_status(app_handle:tauri::AppHandle) -> Result<serde_json::Value, String> {
713	dev_log!("config", "[ConfigurationBridge] Tauri command: get_configuration_status");
714
715	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
716		let bridge = ConfigurationBridge::new(runtime.inner().clone());
717		bridge
718			.get_configuration_status()
719			.await
720			.map(|status| serde_json::to_value(status).unwrap_or(serde_json::Value::Null))
721	} else {
722		Err("ApplicationRunTime not found".to_string())
723	}
724}