Struct TauriIPCServer 

pub struct TauriIPCServer {
    app_handle: AppHandle,
    listeners: Arc<Mutex<HashMap<String, Vec<Box<dyn Fn(Value) -> Result<(), String> + Send + Sync>>>>>,
    is_connected: Arc<Mutex<bool>>,
    message_queue: Arc<Mutex<Vec<TauriIPCMessage>>>,
}

Mountain’s IPC Server counterpart to Wind’s TauriIPCServer

Fields

app_handle: AppHandle

listeners: Arc<Mutex<HashMap<String, Vec<Box<dyn Fn(Value) -> Result<(), String> + Send + Sync>>>>>

is_connected: Arc<Mutex<bool>>

message_queue: Arc<Mutex<Vec<TauriIPCMessage>>>

Implementations

impl TauriIPCServer

pub fn new(app_handle: AppHandle) -> Self

Create a new Tauri IPC Server instance

pub async fn initialize(&self) -> Result<(), String>

Initialize the IPC server and set up event listeners

pub async fn send(&self, channel: &str, data: Value) -> Result<(), String>

Send a message to the Wind frontend

pub fn on( &self, channel: &str, callback: Box<dyn Fn(Value) -> Result<(), String> + Send + Sync>, ) -> Result<(), String>

Register a listener for incoming messages from Wind

pub fn off( &self, channel: &str, callback: &Box<dyn Fn(Value) -> Result<(), String> + Send + Sync>, ) -> Result<(), String>

Remove a listener

pub async fn handle_incoming_message( &self, message: TauriIPCMessage, ) -> Result<(), String>

Handle incoming messages from Wind

async fn send_connection_status(&self, connected: bool) -> Result<(), String>

Send connection status to Wind

async fn emit_message(&self, message: &TauriIPCMessage) -> Result<(), String>

Emit a message to Wind

async fn process_message_queue(&self)

Process queued messages

pub fn get_connection_status(&self) -> Result<bool, String>

Get connection status

pub fn get_queue_size(&self) -> Result<usize, String>

Get queued message count

pub fn dispose(&self) -> Result<(), String>

Cleanup resources

pub async fn validate_message_permissions( &self, message: &TauriIPCMessage, ) -> Result<(), String>

Advanced: Validate message permissions

fn create_security_context(&self, message: &TauriIPCMessage) -> SecurityContext

Advanced: Create security context from message

pub async fn log_security_event(&self, event: SecurityEvent)

Advanced: Log security event

pub async fn record_performance_metrics( &self, channel: String, duration: Duration, success: bool, )

Advanced: Record performance metrics

pub async fn get_security_audit_log( &self, limit: usize, ) -> Result<Vec<SecurityEvent>, String>

Advanced: Get security audit log

pub async fn send_compressed_batch( &self, channel: &str, messages: Vec<TauriIPCMessage>, ) -> Result<(), String>

Send compressed message batch

pub async fn handle_compressed_batch( &self, message: TauriIPCMessage, ) -> Result<(), String>

Handle compressed batch message

pub async fn send_with_pool( &self, channel: &str, data: Value, ) -> Result<(), String>

Send message using connection pool

pub async fn get_connection_stats(&self) -> Result<ConnectionStats, String>

Get connection pool statistics

pub async fn send_secure( &self, channel: &str, data: Value, ) -> Result<(), String>

Send encrypted message

pub async fn handle_secure_message( &self, encrypted_data: Value, ) -> Result<(), String>

Handle encrypted message

pub async fn handle_message_with_permissions( &self, message: TauriIPCMessage, ) -> Result<(), String>

Handle message with permission validation

Trait Implementations

impl Clone for TauriIPCServer

fn clone(&self) -> TauriIPCServer

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.