use super::term::TerminalState;
use crate::services::async_bridge::AsyncBridge;
use crate::services::authority::TerminalWrapper;
use portable_pty::{native_pty_system, CommandBuilder, PtySize};
use std::borrow::Cow;
use std::collections::HashMap;
use std::io::{Read, Write};
use std::sync::atomic::AtomicBool;
use std::sync::mpsc;
use std::sync::{Arc, Mutex};
use std::thread;
pub use fresh_core::TerminalId;
enum TerminalCommand {
Write(Vec<u8>),
Resize { cols: u16, rows: u16 },
Shutdown,
}
pub struct TerminalHandle {
pub state: Arc<Mutex<TerminalState>>,
command_tx: mpsc::Sender<TerminalCommand>,
alive: Arc<std::sync::atomic::AtomicBool>,
cols: u16,
rows: u16,
cwd: Option<std::path::PathBuf>,
shell: String,
}
impl TerminalHandle {
pub fn write(&self, data: &[u8]) {
#[allow(clippy::let_underscore_must_use)]
let _ = self.command_tx.send(TerminalCommand::Write(data.to_vec()));
}
pub fn resize(&mut self, cols: u16, rows: u16) {
if cols != self.cols || rows != self.rows {
self.cols = cols;
self.rows = rows;
#[allow(clippy::let_underscore_must_use)]
let _ = self.command_tx.send(TerminalCommand::Resize { cols, rows });
if let Ok(mut state) = self.state.lock() {
state.resize(cols, rows);
}
}
}
pub fn is_alive(&self) -> bool {
self.alive.load(std::sync::atomic::Ordering::Relaxed)
}
pub fn shutdown(&self) {
#[allow(clippy::let_underscore_must_use)]
let _ = self.command_tx.send(TerminalCommand::Shutdown);
}
pub fn size(&self) -> (u16, u16) {
(self.cols, self.rows)
}
pub fn cwd(&self) -> Option<std::path::PathBuf> {
self.cwd.clone()
}
pub fn shell(&self) -> &str {
&self.shell
}
}
pub struct TerminalManager {
terminals: HashMap<TerminalId, TerminalHandle>,
next_id: usize,
async_bridge: Option<AsyncBridge>,
}
impl TerminalManager {
pub fn new() -> Self {
Self {
terminals: HashMap::new(),
next_id: 0,
async_bridge: None,
}
}
pub fn set_async_bridge(&mut self, bridge: AsyncBridge) {
self.async_bridge = Some(bridge);
}
pub fn next_terminal_id(&self) -> TerminalId {
TerminalId(self.next_id)
}
pub fn spawn(
&mut self,
cols: u16,
rows: u16,
cwd: Option<std::path::PathBuf>,
log_path: Option<std::path::PathBuf>,
backing_path: Option<std::path::PathBuf>,
terminal_wrapper: crate::services::authority::TerminalWrapper,
) -> Result<TerminalId, String> {
let id = TerminalId(self.next_id);
self.next_id += 1;
let handle_result: Result<TerminalHandle, String> = (|| {
let pty_system = native_pty_system();
let pty_pair = pty_system
.openpty(PtySize {
rows,
cols,
pixel_width: 0,
pixel_height: 0,
})
.map_err(|e| {
#[cfg(windows)]
{
format!(
"Failed to open PTY: {}. Note: Terminal requires Windows 10 version 1809 or later with ConPTY support.",
e
)
}
#[cfg(not(windows))]
{
format!("Failed to open PTY: {}", e)
}
})?;
let TerminalWrapper {
command: shell,
args: cmd_args,
manages_cwd: skip_cwd,
} = terminal_wrapper;
tracing::info!("Spawning terminal with shell: {}", shell);
let mut cmd = CommandBuilder::new(&shell);
for arg in &cmd_args {
cmd.arg(arg);
}
if !skip_cwd {
if let Some(ref dir) = cwd {
cmd.cwd(strip_verbatim_prefix(dir).as_ref());
}
}
cmd.env("TERM", "xterm-256color");
#[cfg(windows)]
{
if shell.to_lowercase().contains("cmd") {
cmd.env("PROMPT", "$P$G");
}
}
let mut child = pty_pair
.slave
.spawn_command(cmd)
.map_err(|e| format!("Failed to spawn shell '{}': {}", shell, e))?;
tracing::debug!("Shell process spawned successfully");
let state = Arc::new(Mutex::new(TerminalState::new(cols, rows)));
if let Some(ref p) = backing_path {
if let Ok(metadata) = std::fs::metadata(p) {
if metadata.len() > 0 {
if let Ok(mut s) = state.lock() {
s.set_backing_file_history_end(metadata.len());
}
}
}
}
let (command_tx, command_rx) = mpsc::channel::<TerminalCommand>();
let alive = Arc::new(AtomicBool::new(true));
let alive_clone = alive.clone();
let mut master = pty_pair
.master
.take_writer()
.map_err(|e| format!("Failed to get PTY writer: {}", e))?;
let mut reader = pty_pair
.master
.try_clone_reader()
.map_err(|e| format!("Failed to get PTY reader: {}", e))?;
let state_clone = state.clone();
let async_bridge = self.async_bridge.clone();
let mut log_writer = log_path
.as_ref()
.and_then(|p| {
std::fs::OpenOptions::new()
.create(true)
.append(true)
.open(p)
.ok()
})
.map(std::io::BufWriter::new);
let mut backing_writer = backing_path
.as_ref()
.and_then(|p| {
let existing_has_content =
p.exists() && std::fs::metadata(p).map(|m| m.len() > 0).unwrap_or(false);
if existing_has_content {
std::fs::OpenOptions::new()
.create(true)
.append(true)
.open(p)
.ok()
} else {
std::fs::OpenOptions::new()
.create(true)
.write(true)
.truncate(true)
.open(p)
.ok()
}
})
.map(std::io::BufWriter::new);
let terminal_id = id;
let pty_response_tx = command_tx.clone();
thread::spawn(move || {
tracing::debug!("Terminal {:?} reader thread started", terminal_id);
let mut buf = [0u8; 4096];
let mut total_bytes = 0usize;
loop {
match reader.read(&mut buf) {
Ok(0) => {
tracing::info!(
"Terminal {:?} EOF after {} total bytes",
terminal_id,
total_bytes
);
break;
}
Ok(n) => {
total_bytes += n;
tracing::debug!(
"Terminal {:?} received {} bytes (total: {})",
terminal_id,
n,
total_bytes
);
if let Ok(mut state) = state_clone.lock() {
state.process_output(&buf[..n]);
for response in state.drain_pty_write_queue() {
tracing::debug!(
"Terminal {:?} sending PTY response: {:?}",
terminal_id,
response
);
#[allow(clippy::let_underscore_must_use)]
let _ = pty_response_tx
.send(TerminalCommand::Write(response.into_bytes()));
}
if let Some(ref mut writer) = backing_writer {
match state.flush_new_scrollback(writer) {
Ok(lines_written) => {
if lines_written > 0 {
if let Ok(pos) = writer.get_ref().metadata() {
state.set_backing_file_history_end(pos.len());
}
#[allow(clippy::let_underscore_must_use)]
let _ = writer.flush();
}
}
Err(e) => {
tracing::warn!(
"Terminal backing file write error: {}",
e
);
backing_writer = None;
}
}
}
}
if let Some(w) = log_writer.as_mut() {
if let Err(e) = w.write_all(&buf[..n]) {
tracing::warn!("Terminal log write error: {}", e);
log_writer = None; } else if let Err(e) = w.flush() {
tracing::warn!("Terminal log flush error: {}", e);
log_writer = None;
}
}
if let Some(ref bridge) = async_bridge {
#[allow(clippy::let_underscore_must_use)]
let _ = bridge.sender().send(
crate::services::async_bridge::AsyncMessage::TerminalOutput {
terminal_id,
},
);
}
}
Err(e) => {
tracing::error!("Terminal read error: {}", e);
break;
}
}
}
alive_clone.store(false, std::sync::atomic::Ordering::Relaxed);
if let Some(mut w) = log_writer {
#[allow(clippy::let_underscore_must_use)]
let _ = w.flush();
}
if let Some(mut w) = backing_writer {
#[allow(clippy::let_underscore_must_use)]
let _ = w.flush();
}
if let Some(ref bridge) = async_bridge {
#[allow(clippy::let_underscore_must_use)]
let _ = bridge.sender().send(
crate::services::async_bridge::AsyncMessage::TerminalExited { terminal_id },
);
}
});
let pty_size_ref = pty_pair.master;
thread::spawn(move || {
loop {
match command_rx.recv() {
Ok(TerminalCommand::Write(data)) => {
if let Err(e) = master.write_all(&data) {
tracing::error!("Terminal write error: {}", e);
break;
}
#[allow(clippy::let_underscore_must_use)]
let _ = master.flush();
}
Ok(TerminalCommand::Resize { cols, rows }) => {
if let Err(e) = pty_size_ref.resize(PtySize {
rows,
cols,
pixel_width: 0,
pixel_height: 0,
}) {
tracing::warn!("Failed to resize PTY: {}", e);
}
}
Ok(TerminalCommand::Shutdown) | Err(_) => {
break;
}
}
}
#[allow(clippy::let_underscore_must_use)]
let _ = child.kill();
#[allow(clippy::let_underscore_must_use)]
let _ = child.wait();
});
Ok(TerminalHandle {
state,
command_tx,
alive,
cols,
rows,
cwd: cwd.clone(),
shell,
})
})();
let handle = handle_result?;
self.terminals.insert(id, handle);
tracing::info!("Created terminal {:?} ({}x{})", id, cols, rows);
Ok(id)
}
pub fn get(&self, id: TerminalId) -> Option<&TerminalHandle> {
self.terminals.get(&id)
}
pub fn get_mut(&mut self, id: TerminalId) -> Option<&mut TerminalHandle> {
self.terminals.get_mut(&id)
}
pub fn close(&mut self, id: TerminalId) -> bool {
if let Some(handle) = self.terminals.remove(&id) {
handle.shutdown();
true
} else {
false
}
}
pub fn terminal_ids(&self) -> Vec<TerminalId> {
self.terminals.keys().copied().collect()
}
pub fn count(&self) -> usize {
self.terminals.len()
}
pub fn shutdown_all(&mut self) {
for (_, handle) in self.terminals.drain() {
handle.shutdown();
}
}
pub fn cleanup_dead(&mut self) -> Vec<TerminalId> {
let dead: Vec<TerminalId> = self
.terminals
.iter()
.filter(|(_, h)| !h.is_alive())
.map(|(id, _)| *id)
.collect();
for id in &dead {
self.terminals.remove(id);
}
dead
}
}
impl Default for TerminalManager {
fn default() -> Self {
Self::new()
}
}
impl Drop for TerminalManager {
fn drop(&mut self) {
self.shutdown_all();
}
}
pub(crate) fn strip_verbatim_prefix(path: &std::path::Path) -> Cow<'_, std::path::Path> {
#[cfg(windows)]
{
use std::path::{Component, Prefix};
let mut components = path.components();
let prefix = match components.next() {
Some(Component::Prefix(p)) => p,
_ => return Cow::Borrowed(path),
};
let mut rebuilt = std::path::PathBuf::new();
match prefix.kind() {
Prefix::VerbatimDisk(drive) => {
rebuilt.push(format!("{}:\\", drive as char));
}
Prefix::VerbatimUNC(server, share) => {
rebuilt.push(format!(
r"\\{}\{}\",
server.to_string_lossy(),
share.to_string_lossy()
));
}
_ => return Cow::Borrowed(path),
}
for component in components {
if matches!(component, Component::RootDir) {
continue;
}
rebuilt.push(component.as_os_str());
}
Cow::Owned(rebuilt)
}
#[cfg(not(windows))]
{
Cow::Borrowed(path)
}
}
pub fn detect_shell() -> String {
if let Ok(shell) = std::env::var("SHELL") {
if !shell.is_empty() {
return shell;
}
}
#[cfg(unix)]
{
"/bin/sh".to_string()
}
#[cfg(windows)]
{
let powershell_paths = [
"pwsh.exe",
"powershell.exe",
r"C:\Windows\System32\WindowsPowerShell\v1.0\powershell.exe",
];
for ps in &powershell_paths {
if std::path::Path::new(ps).exists() || which_exists(ps) {
return ps.to_string();
}
}
std::env::var("COMSPEC").unwrap_or_else(|_| "cmd.exe".to_string())
}
}
#[cfg(windows)]
fn which_exists(cmd: &str) -> bool {
if let Ok(path_var) = std::env::var("PATH") {
for path in path_var.split(';') {
let full_path = std::path::Path::new(path).join(cmd);
if full_path.exists() {
return true;
}
}
}
false
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn test_terminal_id_display() {
let id = TerminalId(42);
assert_eq!(format!("{}", id), "Terminal-42");
}
#[test]
fn test_detect_shell() {
let shell = detect_shell();
assert!(!shell.is_empty());
}
#[cfg(not(windows))]
#[test]
fn strip_verbatim_prefix_is_noop_on_unix() {
use std::path::Path;
let p = Path::new("/home/user/project");
assert_eq!(strip_verbatim_prefix(p).as_ref(), p);
}
#[cfg(windows)]
#[test]
fn strip_verbatim_prefix_removes_verbatim_disk() {
use std::path::{Path, PathBuf};
let verbatim = PathBuf::from(r"\\?\C:\Users\HP\OneDrive\Desktop\PY'PGMS");
let stripped = strip_verbatim_prefix(&verbatim);
assert_eq!(
stripped.as_ref(),
Path::new(r"C:\Users\HP\OneDrive\Desktop\PY'PGMS"),
"verbatim disk prefix should be replaced with plain drive form"
);
}
#[cfg(windows)]
#[test]
fn strip_verbatim_prefix_removes_verbatim_unc() {
use std::path::{Path, PathBuf};
let verbatim = PathBuf::from(r"\\?\UNC\server\share\dir\file");
let stripped = strip_verbatim_prefix(&verbatim);
assert_eq!(
stripped.as_ref(),
Path::new(r"\\server\share\dir\file"),
"verbatim UNC prefix should be replaced with plain UNC form"
);
}
#[cfg(windows)]
#[test]
fn strip_verbatim_prefix_passes_plain_paths_through() {
use std::path::{Path, PathBuf};
let plain = PathBuf::from(r"C:\Users\HP\project");
let result = strip_verbatim_prefix(&plain);
assert_eq!(result.as_ref(), Path::new(r"C:\Users\HP\project"));
}
}