feat: preview image over SSH

Cargo.lock

@@ -2623,6 +2623,7 @@ dependencies = [
  "arc-swap",
  "base64",
  "color_quant",
+ "crossterm",
  "image",
  "imagesize",
  "kamadak-exif",

yazi-adaptor/Cargo.toml

@@ -17,6 +17,7 @@ anyhow       = "^1"
 arc-swap     = "^1"
 base64       = "^0"
 color_quant  = "^1"
+crossterm    = "^0"
 image        = "^0"
 imagesize    = "^0"
 kamadak-exif = "0"

yazi-adaptor/src/adaptor.rs

@@ -1,6 +1,7 @@
-use std::{env, path::Path, sync::Arc};
+use std::{env, io::{Read, Write}, path::Path, sync::Arc};
 
-use anyhow::{anyhow, Result};
+use anyhow::{anyhow, bail, Result};
+use crossterm::terminal::{disable_raw_mode, enable_raw_mode};
 use ratatui::layout::Rect;
 use tracing::warn;
 use yazi_shared::{env_exists, term::Term};
@@ -58,7 +59,7 @@ impl Adaptor {
 			None => warn!("[Adaptor] No special environment variables detected"),
 		}
 
-		let (term, program) = Self::term_program();
+		let (term, program) = Self::via_env();
 		match program.as_str() {
 			"iTerm.app" => return Emulator::Iterm2,
 			"WezTerm" => return Emulator::WezTerm,
@@ -77,7 +78,8 @@ impl Adaptor {
 			"xterm-ghostty" => return Emulator::Ghostty,
 			_ => warn!("[Adaptor] Unknown TERM: {term}"),
 		}
-		Emulator::Unknown
+
+		Self::via_csi().unwrap_or(Emulator::Unknown)
 	}
 
 	pub(super) fn detect() -> Self {
@@ -128,13 +130,13 @@ impl Adaptor {
 		Self::Chafa
 	}
 
-	pub(super) fn term_program() -> (String, String) {
+	fn via_env() -> (String, String) {
 		fn tmux_env(name: &str) -> Result<String> {
 			let output = std::process::Command::new("tmux").args(["show-environment", name]).output()?;
 
 			String::from_utf8(output.stdout)?
 				.trim()
-				.strip_prefix(&format!("{}=", name))
+				.strip_prefix(&format!("{name}="))
 				.map_or_else(|| Err(anyhow!("")), |s| Ok(s.to_string()))
 		}
 
@@ -148,6 +150,42 @@ impl Adaptor {
 
 		(term, program)
 	}
+
+	fn via_csi() -> Result<Emulator> {
+		enable_raw_mode()?;
+		std::io::stdout().write_all(b"\x1b[>q\x1b[c")?;
+		std::io::stdout().flush()?;
+
+		let mut stdin = std::io::stdin().lock();
+		let mut buf = String::with_capacity(100);
+		loop {
+			let mut c = [0; 1];
+			if stdin.read(&mut c)? == 0 {
+				break;
+			}
+			if c[0] == b'c' && buf.contains("\x1b[?") {
+				break;
+			}
+			buf.push(c[0] as char);
+		}
+
+		disable_raw_mode().ok();
+		let names = [
+			("kitty", Emulator::Kitty),
+			("Konsole", Emulator::Konsole),
+			("iTerm2", Emulator::Iterm2),
+			("WezTerm", Emulator::WezTerm),
+			("foot", Emulator::Foot),
+			("ghostty", Emulator::Ghostty),
+		];
+
+		for (name, emulator) in names.iter() {
+			if buf.contains(name) {
+				return Ok(*emulator);
+			}
+		}
+		Ok(Emulator::Unknown)
+	}
 }
 
 impl ToString for Adaptor {