Mountain/Vine/Server/Notification/
WindowCreateTerminal.rs1#![allow(non_snake_case)]
2use std::sync::Arc;
10
11use serde_json::{Value, json};
12use tauri::Emitter;
13use CommonLibrary::{Environment::Requires::Requires, Terminal::TerminalProvider::TerminalProvider};
14
15use crate::{Vine::Server::MountainVinegRPCService::MountainVinegRPCService, dev_log};
16
17pub async fn WindowCreateTerminal(Service:&MountainVinegRPCService, Parameter:&Value) {
18 let Provider:Arc<dyn TerminalProvider> = Service.RunTime().Environment.Require();
19 let Name = Parameter.get("name").and_then(|V| V.as_str()).unwrap_or("terminal").to_string();
20 let Options = Parameter.get("options").cloned().unwrap_or_default();
21 let Handle = Parameter
22 .get("handle")
23 .and_then(|V| V.as_str())
24 .map(str::to_string)
25 .unwrap_or_default();
26
27 let AppHandleForTask = Service.ApplicationHandle().clone();
28 let NameForTask = Name.clone();
29 tokio::spawn(async move {
30 let OptionsPayload = if Options.is_object() {
31 let mut Map = Options.as_object().cloned().unwrap_or_default();
32 Map.entry("name".to_string()).or_insert_with(|| json!(NameForTask));
33 Value::Object(Map)
34 } else {
35 json!({ "name": NameForTask })
36 };
37 if let Ok(Created) = Provider.CreateTerminal(OptionsPayload).await {
38 if let Err(Error) = AppHandleForTask.emit(
39 "sky://terminal/create",
40 json!({
41 "handle": Handle,
42 "id": Created.get("id").cloned().unwrap_or(Value::Null),
43 "pid": Created.get("pid").cloned().unwrap_or(Value::Null),
44 "name": Created.get("name").cloned().unwrap_or(Value::Null),
45 }),
46 ) {
47 dev_log!(
48 "grpc",
49 "warn: [WindowCreateTerminal] sky://terminal/create emit failed: {}",
50 Error
51 );
52 }
53 }
54 });
55}