fix(Vine): Resolve async call and type issues in Vine server and IPC

This commit addresses several critical bugs that were preventing proper execution of the Mountain backend's IPC layer and Vine gRPC server.

The primary fix resolves a missing `.await` call in `Binary.rs` when creating the Air service provider, which was causing the Air connection to fail silently. Additionally, the `WindAirCommands` Tauri commands are updated to use the fully qualified `tauri::AppHandle` type instead of the unqualified `AppHandle`, ensuring proper type resolution across the codebase.

In the Vine server implementation, the CocoonService server's environment trait resolution is fixed by dereferencing the environment before calling `Require()`, and the ExtensionManagementService import is corrected to use the proper `Common` crate path. These changes ensure the server can properly resolve and use the extension management service as defined in the `Common` contract.

Finally, the module-level documentation in `Library.rs` is enhanced with clearer responsibilities and TODO items, and the Rust attribute is standardized from `non_snakeCase` to `non_snake_case` for consistency with Rust conventions.

These fixes ensure the Vine gRPC server can properly communicate with the Cocoon extension host and that the Tauri commands for the Wind frontend are correctly typed and executable.

Author: NikolaRHristov

Source/Binary.rs

@@ -717,7 +717,7 @@ pub fn Fn() {
 					let AirAddress = "http://[::1]:50053";
 
 					// Attempt to connect to Air, but continue gracefully if unavailable
-					let AirProvider = match Air::CreateAirServiceProvider(AirAddress) {
+					let AirProvider = match Air::CreateAirServiceProvider(AirAddress).await {
 						Ok(provider) => {
 							info!("[Air] [Init] Successfully connected to Air at {}", AirAddress);
 							provider

Source/IPC/WindAirCommands.rs

@@ -194,7 +194,7 @@ pub async fn CheckForUpdates(
 /// `DownloadResultDTO` with download status
 #[tauri::command]
 pub async fn DownloadUpdate(
-    app_handle: AppHandle,
+    app_handle: tauri::AppHandle,
     url: String,
     destination: String,
     checksum: Option<String>,
@@ -246,7 +246,7 @@ pub async fn DownloadUpdate(
 /// Success status or error message
 #[tauri::command]
 pub async fn ApplyUpdate(
-    app_handle: AppHandle,
+    app_handle: tauri::AppHandle,
     update_id: String,
     update_path: String,
 ) -> Result<bool, String> {
@@ -292,7 +292,7 @@ pub async fn ApplyUpdate(
 /// `DownloadResultDTO` with download status
 #[tauri::command]
 pub async fn DownloadFile(
-    app_handle: AppHandle,
+    app_handle: tauri::AppHandle,
     url: String,
     destination: String,
 ) -> Result<DownloadResultDTO, String> {
@@ -344,7 +344,7 @@ pub async fn DownloadFile(
 /// `AuthResponseDTO` with authentication token
 #[tauri::command]
 pub async fn AuthenticateUser(
-    app_handle: AppHandle,
+    app_handle: tauri::AppHandle,
     username: String,
     password: String,
     provider: String,
@@ -396,7 +396,7 @@ pub async fn AuthenticateUser(
 /// `IndexResultDTO` with indexing results
 #[tauri::command]
 pub async fn IndexFiles(
-    app_handle: AppHandle,
+    app_handle: tauri::AppHandle,
     path: String,
     patterns: Vec<String>,
     exclude_patterns: Option<Vec<String>>,
@@ -449,7 +449,7 @@ pub async fn IndexFiles(
 /// `SearchResultsDTO` with matching files
 #[tauri::command]
 pub async fn SearchFiles(
-    app_handle: AppHandle,
+    app_handle: tauri::AppHandle,
     query: String,
     index_id: Option<String>,
     max_results: Option<u32>,
@@ -506,7 +506,7 @@ pub async fn SearchFiles(
 /// `AirServiceStatusDTO` with service status information
 #[tauri::command]
 pub async fn GetAirStatus(
-    app_handle: AppHandle,
+    app_handle: tauri::AppHandle,
 ) -> Result<AirServiceStatusDTO, String> {
     debug!("[WindAirCommands] GetAirStatus called");
 
@@ -553,7 +553,7 @@ pub async fn GetAirStatus(
 /// `AirMetricsDTO` with metrics data
 #[tauri::command]
 pub async fn GetAirMetrics(
-    app_handle: AppHandle,
+    app_handle: tauri::AppHandle,
     metric_type: Option<String>,
 ) -> Result<AirMetricsDTO, String> {
     debug!("[WindAirCommands] GetAirMetrics called with type: {:?}", metric_type);

Source/Library.rs

@@ -4,6 +4,25 @@
 //! application, declaring all of its major internal components. This allows
 //! the `Binary.rs` file to have a clean entry point that orchestrates these
 //! components.
+//!
+//! ## File Responsibilities
+//! - Main library entry point for Mountain application
+//! - Module declarations for all Mountain components
+//! - Mobile entry point configuration for Tauri
+//! - Feature flag management and conditional compilation
+//! - Cross-platform compatibility definitions
+//!
+//! ## TODO
+//! - [ ] Add comprehensive integration tests for all modules
+//! - [ ] Implement proper error handling and recovery patterns
+//! - [ ] Add performance monitoring and optimization
+//! - [ ] Implement proper logging and diagnostics
+//! - [ ] Add security audit and vulnerability assessment
+//! - [ ] Implement proper memory management and resource cleanup
+//! - [ ] Add comprehensive documentation for all APIs
+//! - [ ] Implement proper testing infrastructure
+//! - [ ] Add performance benchmarking and profiling
+//! - [ ] Implement proper error boundary handling
 
 #![cfg_attr(not(debug_assertions), windows_subsystem = "windows")]
 #![allow(non_snake_case, non_camel_case_types)]

Source/Vine/Server/CocoonServiceServer.rs

@@ -15,9 +15,9 @@ use super::super::Generated::{
 };
 use crate::{
     ApplicationState::ApplicationState,
-    Environment::MountainEnvironment,
-    ExtensionManagement::ExtensionManagementService,
+    Environment::MountainEnvironment::MountainEnvironment,
 };
+use Common::ExtensionManagement::ExtensionManagementService::ExtensionManagementService;
 
 /// Implementation of the CocoonService gRPC server
 pub struct CocoonServiceServer {
@@ -62,7 +62,7 @@ impl CocoonServiceServer {
             "GetExtensions" => {
                 debug!("[CocoonServiceServer] Getting extensions");
 
-                let extension_service: Arc<dyn ExtensionManagementService> = self.environment.Require();
+                let extension_service: Arc<dyn ExtensionManagementService> = (*self.environment).Require();
                 let extensions = extension_service.get_extensions().await.map_err(|e| {
                     Status::internal(format!("Failed to get extensions: {}", e))
                 })?;
@@ -86,7 +86,7 @@ impl CocoonServiceServer {
                     .as_str()
                     .ok_or_else(|| Status::invalid_argument("Missing extensionId parameter"))?;
 
-                let extension_service: Arc<dyn ExtensionManagementService> = self.environment.Require();
+                let extension_service: Arc<dyn ExtensionManagementService> = (*self.environment).Require();
                 extension_service.activate_extension(extension_id).await
                     .map_err(|e| Status::internal(format!("Failed to activate extension: {}", e)))?;
 
@@ -181,4 +181,4 @@ impl CocoonService for CocoonServiceServer {
 
         Ok(Response::new(Empty {}))
     }
-}
+}

Source/Vine/Server/mod.rs

@@ -5,7 +5,7 @@
 //! `Cocoon`, handling RPC requests, and dispatching them into the Mountain
 //! application logic.
 
-#![allow(non_snakeCase)]
+#![allow(non_snake_case)]
 
 pub mod Initialize;