Mountain/Environment/WebviewProvider/
Messaging.rs

1//! # WebviewProvider - Messaging Operations
2//!
3//! Implementation of webview message passing for
4//! [`MountainEnvironment`]
5//!
6//! Handles secure bidirectional communication between host and webview.
7
8use std::collections::HashMap;
9
10use CommonLibrary::{Error::CommonError::CommonError, IPC::SkyEvent::SkyEvent};
11use serde::{Deserialize, Serialize};
12use serde_json::Value;
13use tauri::{Emitter, Manager};
14use uuid::Uuid;
15
16use super::super::MountainEnvironment::MountainEnvironment;
17use crate::dev_log;
18
19/// Represents a Webview message
20#[derive(Debug, Clone, Serialize, Deserialize)]
21pub struct WebviewMessage {
22	pub MessageIdentifier:String,
23
24	pub MessageType:String,
25
26	pub Payload:Value,
27
28	pub Source:Option<String>,
29}
30
31/// Webview message handler context
32#[allow(dead_code)]
33struct WebviewMessageContext {
34	Handle:String,
35
36	SideCarIdentifier:Option<String>,
37
38	PendingResponses:HashMap<String, tokio::sync::oneshot::Sender<Value>>,
39}
40
41/// Messaging operations implementation for MountainEnvironment
42pub(super) async fn post_message_to_webview_impl(
43	env:&MountainEnvironment,
44
45	handle:String,
46
47	message:Value,
48) -> Result<bool, CommonError> {
49	dev_log!("extensions", "[WebviewProvider] Posting message to Webview: {}", handle);
50
51	if let Some(webview_window) = env.ApplicationHandle.get_webview_window(&handle) {
52		let webview_message = WebviewMessage {
53			MessageIdentifier:Uuid::new_v4().to_string(),
54
55			MessageType:"request".to_string(),
56
57			Payload:message,
58
59			Source:Some("host".to_string()),
60		};
61
62		webview_window
63			.emit::<WebviewMessage>(SkyEvent::WebviewPostMessage.AsStr(), webview_message)
64			.map_err(|error| {
65				CommonError::IPCError { Description:format!("Failed to post message to Webview: {}", error) }
66			})?;
67
68		dev_log!(
69			"extensions",
70			"[WebviewProvider] Message sent successfully to Webview: {}",
71			handle
72		);
73
74		Ok(true)
75	} else {
76		dev_log!(
77			"extensions",
78			"warn: [WebviewProvider] Webview not found for message: {}",
79			handle
80		);
81
82		Ok(false)
83	}
84}
85
86/// Sets up a message listener for a specific Webview.
87pub(super) async fn setup_webview_message_listener_impl(
88	env:&MountainEnvironment,
89
90	handle:String,
91) -> Result<(), CommonError> {
92	dev_log!(
93		"extensions",
94		"[WebviewProvider] Setting up message listener for Webview: {}",
95		handle
96	);
97
98	// In a full implementation, this would register an event listener
99	// that forwards Webview messages to the appropriate handler.
100	// For now, we'll just log a message.
101
102	Ok(())
103}
104
105/// Removes a message listener for a specific Webview.
106pub(super) async fn remove_webview_message_listener_impl(_env:&MountainEnvironment, _handle:&str) {
107
108	// In a full implementation, this would remove the event listener
109	// that forwards Webview messages.
110}
Mountain/Environment/WebviewProvider/Messaging.rs

Mountain/Environment/WebviewProvider/
Messaging.rs
