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};
230
231type ConfigurationOverridesDTO = ConfigurationOverridesDTOModule::ConfigurationOverridesDTO;
232
233type ConfigurationTarget = ConfigurationTargetModule::ConfigurationTarget;
234
235use CommonLibrary::{Configuration::ConfigurationProvider::ConfigurationProvider, Environment::Requires::Requires};
236use sha2::Digest;
237
238use crate::{
239	IPC::WindServiceAdapters::{
240		WindDesktopConfiguration::Struct as WindDesktopConfiguration,
241		WindServiceAdapter::Struct as WindServiceAdapter,
242	},
243	RunTime::ApplicationRunTime::ApplicationRunTime,
244	dev_log,
245};
246
247/// Configuration bridge that handles Wind's desktop configuration needs
248pub struct ConfigurationBridge {
249	runtime:Arc<ApplicationRunTime>,
250}
251
252impl ConfigurationBridge {
253	/// Create a new configuration bridge
254	pub fn new(runtime:Arc<ApplicationRunTime>) -> Self {
255		dev_log!("config", "[ConfigurationBridge] Creating configuration bridge");
256
257		Self { runtime }
258	}
259
260	/// Get Wind-compatible desktop configuration
261	pub async fn get_wind_desktop_configuration(&self) -> Result<WindDesktopConfiguration, String> {
262		dev_log!("config", "[ConfigurationBridge] Getting Wind desktop configuration");
263
264		// Get the current Mountain configuration
265		let mountain_config = self.get_mountain_configuration().await?;
266
267		// Convert to Wind format using the service adapter
268		let service_adapter = WindServiceAdapter::new(self.runtime.clone());
269
270		let wind_config = service_adapter.convert_to_wind_configuration(mountain_config).await?;
271
272		dev_log!("config", "[ConfigurationBridge] Wind configuration ready");
273
274		Ok(wind_config)
275	}
276
277	/// Update configuration from Wind frontend
278	pub async fn update_configuration_from_wind(&self, wind_config:WindDesktopConfiguration) -> Result<(), String> {
279		dev_log!("config", "[ConfigurationBridge] Updating configuration from Wind");
280
281		// Convert Wind configuration to Mountain format
282		let mountain_config = self.convert_to_mountain_configuration(wind_config).await?;
283
284		// Update Mountain's configuration system
285		self.update_mountain_configuration(mountain_config).await?;
286
287		dev_log!("config", "[ConfigurationBridge] Configuration updated successfully");
288
289		Ok(())
290	}
291
292	/// Get Mountain's current configuration
293	async fn get_mountain_configuration(&self) -> Result<serde_json::Value, String> {
294		dev_log!("config", "[ConfigurationBridge] Getting Mountain configuration");
295
296		let config_provider:Arc<dyn ConfigurationProvider> = self.runtime.Environment.Require();
297
298		let config = config_provider
299			.GetConfigurationValue(None, ConfigurationOverridesDTO::default())
300			.await
301			.map_err(|e| format!("Failed to get Mountain configuration: {}", e))?;
302
303		Ok(config)
304	}
305
306	/// Update Mountain's configuration
307	async fn update_mountain_configuration(&self, config:serde_json::Value) -> Result<(), String> {
308		dev_log!("config", "[ConfigurationBridge] Updating Mountain configuration");
309
310		// Validate configuration before updating
311		if !self.validate_configuration(&config) {
312			return Err("Invalid configuration data".to_string());
313		}
314
315		let config_provider:Arc<dyn ConfigurationProvider> = self.runtime.Environment.Require();
316
317		// Update configuration values
318		if let Some(obj) = config.as_object() {
319			for (key, value) in obj {
320				config_provider
321					.UpdateConfigurationValue(
322						key.clone(),
323						value.clone(),
324						ConfigurationTarget::User,
325						ConfigurationOverridesDTO::default(),
326						None,
327					)
328					.await
329					.map_err(|e| format!("Failed to update configuration key {}: {}", key, e))?;
330			}
331		}
332
333		Ok(())
334	}
335
336	/// Validate configuration data
337	fn validate_configuration(&self, config:&serde_json::Value) -> bool {
338		// Basic validation: config must be an object
339		if !config.is_object() {
340			return false;
341		}
342
343		// Validate individual configuration values
344		if let Some(obj) = config.as_object() {
345			for (key, value) in obj {
346				// Key validation
347				if key.trim().is_empty() {
348					return false;
349				}
350
351				// Value type validation
352				match key.as_str() {
353					"zoom_level" | "font_size" => {
354						if let Some(num) = value.as_f64() {
355							if key == "zoom_level" && (num < -8.0 || num > 9.0) {
356								return false;
357							}
358
359							if key == "font_size" && (num < 6.0 || num > 100.0) {
360								return false;
361							}
362						} else {
363							return false;
364						}
365					},
366
367					"is_packaged" | "enable_feature" => {
368						if !value.is_boolean() {
369							return false;
370						}
371					},
372
373					"theme" | "platform" | "arch" => {
374						if !value.is_string() || value.as_str().unwrap().trim().is_empty() {
375							return false;
376						}
377					},
378
379					_ => {
380						// Default validation: value must not be null
381						if value.is_null() {
382							return false;
383						}
384					},
385				}
386			}
387		}
388
389		true
390	}
391
392	/// Convert Wind configuration to Mountain format
393	async fn convert_to_mountain_configuration(
394		&self,
395
396		wind_config:WindDesktopConfiguration,
397	) -> Result<serde_json::Value, String> {
398		dev_log!("config", "[ConfigurationBridge] Converting Wind config to Mountain format");
399
400		let machine_id = self.generate_machine_id().await.unwrap_or_else(|e| {
401			dev_log!("config", "warn: [ConfigurationBridge] Failed to generate machine ID: {}", e);
402			"wind-machine-fallback".to_string()
403		});
404
405		let session_id = self.generate_session_id().await.unwrap_or_else(|e| {
406			dev_log!("config", "warn: [ConfigurationBridge] Failed to generate session ID: {}", e);
407			"wind-session-fallback".to_string()
408		});
409
410		let mountain_config = serde_json::json!({
411			"window_id": wind_config.window_id.to_string(),
412			"machine_id": machine_id,
413			"session_id": session_id,
414			"log_level": wind_config.log_level,
415			"app_root": wind_config.app_root,
416			"user_data_dir": wind_config.user_data_path,
417			"tmp_dir": wind_config.temp_path,
418			"platform": wind_config.platform,
419			"arch": wind_config.arch,
420			"zoom_level": wind_config.zoom_level.unwrap_or(0.0),
421			"backup_path": wind_config.backup_path.unwrap_or_default(),
422			"home_dir": wind_config.profiles.home,
423			"is_packaged": wind_config.is_packaged,
424		});
425
426		Ok(mountain_config)
427	}
428
429	/// Synchronize configuration between Mountain and Wind
430	pub async fn synchronize_configuration(&self) -> Result<(), String> {
431		dev_log!("config", "[ConfigurationBridge] Synchronizing configuration");
432
433		// Get Mountain's current configuration
434		let mountain_config = self.get_mountain_configuration().await?;
435
436		// Convert to Wind format
437		let service_adapter = WindServiceAdapter::new(self.runtime.clone());
438
439		let wind_config = service_adapter.convert_to_wind_configuration(mountain_config).await?;
440
441		// Send configuration to Wind via IPC
442		self.send_configuration_to_wind(wind_config).await?;
443
444		dev_log!("config", "[ConfigurationBridge] Configuration synchronized");
445
446		Ok(())
447	}
448
449	/// Send configuration to Wind frontend via IPC
450	async fn send_configuration_to_wind(&self, config:WindDesktopConfiguration) -> Result<(), String> {
451		dev_log!("config", "[ConfigurationBridge] Sending configuration to Wind");
452
453		// Get the IPC server
454		if let Some(ipc_server) = self
455			.runtime
456			.Environment
457			.ApplicationHandle
458			.try_state::<crate::IPC::TauriIPCServer_Old::TauriIPCServer>()
459		{
460			let config_json =
461				serde_json::to_value(config).map_err(|e| format!("Failed to serialize configuration: {}", e))?;
462
463			ipc_server
464				.send("configuration:update", config_json)
465				.await
466				.map_err(|e| format!("Failed to send configuration to Wind: {}", e))?;
467		} else {
468			return Err("IPC Server not found".to_string());
469		}
470
471		Ok(())
472	}
473
474	/// Handle configuration changes from Wind
475	pub async fn WindConfigurationChange(&self, new_config:serde_json::Value) -> Result<(), String> {
476		dev_log!("config", "[ConfigurationBridge] Handling Wind configuration change");
477
478		// Parse Wind configuration
479		let wind_config:WindDesktopConfiguration =
480			serde_json::from_value(new_config).map_err(|e| format!("Failed to parse Wind configuration: {}", e))?;
481
482		// Update Mountain configuration
483		self.update_configuration_from_wind(wind_config).await?;
484
485		dev_log!("config", "[ConfigurationBridge] Wind configuration change handled");
486
487		Ok(())
488	}
489
490	/// Get configuration status
491	pub async fn get_configuration_status(&self) -> Result<ConfigurationStatus, String> {
492		dev_log!("config", "[ConfigurationBridge] Getting configuration status");
493
494		let mountain_config = self.get_mountain_configuration().await?;
495
496		let is_valid = !mountain_config.is_null();
497
498		let status = ConfigurationStatus {
499			is_valid,
500
501			last_sync:std::time::SystemTime::now()
502				.duration_since(std::time::UNIX_EPOCH)
503				.unwrap_or_default()
504				.as_millis() as u64,
505
506			configuration_keys:if let Some(obj) = mountain_config.as_object() {
507				obj.keys().map(|k| k.clone()).collect()
508			} else {
509				Vec::new()
510			},
511		};
512
513		Ok(status)
514	}
515
516	/// Generate unique machine ID using advanced Microsoft-inspired patterns
517	async fn generate_machine_id(&self) -> Result<String, String> {
518		// IMPLEMENTATION: Multi-platform machine ID generation
519		#[cfg(target_os = "macos")]
520		{
521			use std::process::Command;
522
523			// Get macOS serial number using system_profiler
524			let result = Command::new("system_profiler")
525				.arg("SPHardwareDataType")
526				.arg("-json")
527				.output()
528				.map_err(|e| format!("Failed to execute system_profiler: {}", e))?;
529
530			if result.status.success() {
531				let output_str = String::from_utf8_lossy(&result.stdout);
532
533				if let Ok(json) = serde_json::from_str::<serde_json::Value>(&output_str) {
534					if let Some(serial) = json["SPHardwareDataType"][0]["serial_number"].as_str() {
535						return Ok(format!("mac-{}", serial));
536					}
537				}
538			}
539		}
540
541		#[cfg(target_os = "windows")]
542		{
543			use std::process::Command;
544
545			// Get Windows machine ID using wmic
546			let result = Command::new("wmic")
547				.arg("csproduct")
548				.arg("get")
549				.arg("UUID")
550				.output()
551				.map_err(|e| format!("Failed to execute wmic: {}", e))?;
552
553			if result.status.success() {
554				let output_str = String::from_utf8_lossy(&result.stdout);
555
556				let lines:Vec<&str> = output_str.lines().collect();
557
558				if lines.len() > 1 {
559					let uuid = lines[1].trim();
560
561					if !uuid.is_empty() {
562						return Ok(format!("win-{}", uuid));
563					}
564				}
565			}
566		}
567
568		#[cfg(target_os = "linux")]
569		{
570			use std::fs;
571
572			// Try to read machine-id from /etc/machine-id
573			if let Ok(content) = fs::read_to_string("/etc/machine-id") {
574				let machine_id = content.trim();
575
576				if !machine_id.is_empty() {
577					return Ok(format!("linux-{}", machine_id));
578				}
579			}
580
581			// Fallback to /var/lib/dbus/machine-id
582			if let Ok(content) = fs::read_to_string("/var/lib/dbus/machine-id") {
583				let machine_id = content.trim();
584
585				if !machine_id.is_empty() {
586					return Ok(format!("linux-{}", machine_id));
587				}
588			}
589		}
590
591		// Fallback: Generate a unique ID based on hostname and timestamp
592		let hostname = hostname::get()
593			.map_err(|e| format!("Failed to get hostname: {}", e))?
594			.to_string_lossy()
595			.to_string();
596
597		let timestamp = std::time::SystemTime::now()
598			.duration_since(std::time::UNIX_EPOCH)
599			.unwrap_or_default()
600			.as_millis();
601
602		Ok(format!("fallback-{}-{}", hostname, timestamp))
603	}
604
605	/// Generate unique session ID with Microsoft-inspired security patterns
606	async fn generate_session_id(&self) -> Result<String, String> {
607		use std::time::{SystemTime, UNIX_EPOCH};
608
609		// IMPLEMENTATION: Secure session ID generation
610		let random_part:u64 = rand::random();
611
612		let timestamp = SystemTime::now().duration_since(UNIX_EPOCH).unwrap_or_default().as_millis();
613
614		// Get process ID for additional uniqueness
615		let process_id = std::process::id();
616
617		// Create a hash-based session ID
618		let session_data = format!("{}:{}:{}", timestamp, random_part, process_id);
619
620		let mut hasher = sha2::Sha256::new();
621
622		hasher.update(session_data.as_bytes());
623
624		let result = hasher.finalize();
625
626		// Convert to hex string and take first 16 characters. sha2 0.11
627		// dropped the `LowerHex` impl from `Digest::finalize()`'s output
628		// (now `hybrid_array::Array`); `hex::encode` produces the same
629		// lowercase-hex string the old `format!("{:x}", …)` emitted.
630		let hex_string = hex::encode(result);
631
632		let session_id = hex_string.chars().take(16).collect::<String>();
633
634		dev_log!("config", "[ConfigurationBridge] Generated session ID: {}", session_id);
635
636		Ok(format!("session-{}", session_id))
637	}
638}
639
640/// Configuration status structure
641#[derive(Debug, Clone, Serialize, Deserialize)]
642pub struct ConfigurationStatus {
643	pub is_valid:bool,
644
645	pub last_sync:u64,
646
647	pub configuration_keys:Vec<String>,
648}
649
650/// Tauri command to get Wind desktop configuration
651#[tauri::command]
652pub async fn mountain_get_wind_desktop_configuration(
653	app_handle:tauri::AppHandle,
654) -> Result<WindDesktopConfiguration, String> {
655	dev_log!("config", "[ConfigurationBridge] Tauri command: get_wind_desktop_configuration");
656
657	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
658		let bridge = ConfigurationBridge::new(runtime.inner().clone());
659
660		bridge.get_wind_desktop_configuration().await
661	} else {
662		Err("ApplicationRunTime not found".to_string())
663	}
664}
665
666/// Tauri command to get configuration data for Wind frontend
667#[tauri::command]
668pub async fn get_configuration_data(app_handle:tauri::AppHandle) -> Result<serde_json::Value, String> {
669	dev_log!("config", "[ConfigurationBridge] Tauri command: get_configuration_data");
670
671	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
672		let bridge = ConfigurationBridge::new(runtime.inner().clone());
673
674		// Get Mountain's current configuration
675		let mountain_config = bridge.get_mountain_configuration().await?;
676
677		// Convert to Wind format
678		let config_data = serde_json::json!({
679			"application": mountain_config.clone(),
680			"workspace": mountain_config.clone(),
681			"profile": mountain_config.clone()
682		});
683
684		dev_log!("config", "[ConfigurationBridge] Configuration data retrieved successfully");
685
686		Ok(config_data)
687	} else {
688		Err("ApplicationRunTime not found".to_string())
689	}
690}
691
692/// Tauri command to save configuration data from Wind frontend
693#[tauri::command]
694pub async fn save_configuration_data(app_handle:tauri::AppHandle, config_data:serde_json::Value) -> Result<(), String> {
695	dev_log!("config", "[ConfigurationBridge] Tauri command: save_configuration_data");
696
697	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
698		let bridge = ConfigurationBridge::new(runtime.inner().clone());
699
700		// Update Mountain configuration with the new data
701		bridge.update_mountain_configuration(config_data).await?;
702
703		dev_log!("config", "[ConfigurationBridge] Configuration data saved successfully");
704
705		Ok(())
706	} else {
707		Err("ApplicationRunTime not found".to_string())
708	}
709}
710
711/// Tauri command to update configuration from Wind
712#[tauri::command]
713pub async fn mountain_update_configuration_from_wind(
714	app_handle:tauri::AppHandle,
715
716	config:serde_json::Value,
717) -> Result<(), String> {
718	dev_log!("config", "[ConfigurationBridge] Tauri command: update_configuration_from_wind");
719
720	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
721		let bridge = ConfigurationBridge::new(runtime.inner().clone());
722
723		bridge.WindConfigurationChange(config).await
724	} else {
725		Err("ApplicationRunTime not found".to_string())
726	}
727}
728
729/// Tauri command to synchronize configuration
730#[tauri::command]
731pub async fn mountain_synchronize_configuration(app_handle:tauri::AppHandle) -> Result<serde_json::Value, String> {
732	dev_log!("config", "[ConfigurationBridge] Tauri command: synchronize_configuration");
733
734	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
735		let bridge = ConfigurationBridge::new(runtime.inner().clone());
736
737		bridge
738			.synchronize_configuration()
739			.await
740			.map(|_| serde_json::json!({ "status": "success" }))
741	} else {
742		Err("ApplicationRunTime not found".to_string())
743	}
744}
745
746/// Tauri command to get configuration status
747#[tauri::command]
748pub async fn mountain_get_configuration_status(app_handle:tauri::AppHandle) -> Result<serde_json::Value, String> {
749	dev_log!("config", "[ConfigurationBridge] Tauri command: get_configuration_status");
750
751	if let Some(runtime) = app_handle.try_state::<Arc<ApplicationRunTime>>() {
752		let bridge = ConfigurationBridge::new(runtime.inner().clone());
753
754		bridge
755			.get_configuration_status()
756			.await
757			.map(|status| serde_json::to_value(status).unwrap_or(serde_json::Value::Null))
758	} else {
759		Err("ApplicationRunTime not found".to_string())
760	}
761}