Skip to main content

Mountain/Vine/Server/Notification/
WindowCreateTerminal.rs

1#![allow(non_snake_case)]
2//! Cocoon → Mountain `window.createTerminal` notification.
3//! Fire-and-forget from Cocoon's `vscode.window.createTerminal(...)`
4//! shim. Spawns the PTY via the registered `TerminalProvider` so the
5//! xterm panel starts receiving data immediately, then emits
6//! `sky://terminal/create` with the provider-minted id/pid/name so Sky
7//! can correlate the panel with the extension-owned terminal instance.
8
9use 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}