use serde::Serialize;
use std::io::Write;
const FALLBACK_TERMINAL_WIDTH: usize = 120;
pub fn terminal_width() -> usize {
if let Some(width) = terminal_width_from_env() {
return width;
}
terminal_width_from_stdout().unwrap_or(FALLBACK_TERMINAL_WIDTH)
}
fn terminal_width_from_env() -> Option<usize> {
std::env::var("COLUMNS")
.ok()
.and_then(|s| s.parse::<usize>().ok())
.filter(|w| *w > 0)
}
#[cfg(unix)]
fn terminal_width_from_stdout() -> Option<usize> {
let mut size = libc::winsize {
ws_row: 0,
ws_col: 0,
ws_xpixel: 0,
ws_ypixel: 0,
};
let rc = unsafe { libc::ioctl(libc::STDOUT_FILENO, libc::TIOCGWINSZ, &mut size) };
if rc == 0 && size.ws_col > 0 {
Some(size.ws_col as usize)
} else {
None
}
}
#[cfg(not(unix))]
fn terminal_width_from_stdout() -> Option<usize> {
None
}
pub fn print_table<W: Write>(
out: &mut W,
headers: &[&str],
rows: &[Vec<String>],
) -> std::io::Result<()> {
let ncols = headers.len();
let mut widths: Vec<usize> = headers.iter().map(|h| h.len()).collect();
for row in rows {
for (i, cell) in row.iter().enumerate().take(ncols) {
if cell.len() > widths[i] {
widths[i] = cell.len();
}
}
}
write_row(out, headers.iter().copied(), &widths)?;
let sep: Vec<String> = widths.iter().map(|w| "-".repeat(*w)).collect();
write_row(out, sep.iter().map(|s| s.as_str()), &widths)?;
for row in rows {
write_row(
out,
(0..ncols).map(|i| row.get(i).map(|s| s.as_str()).unwrap_or("")),
&widths,
)?;
}
Ok(())
}
fn write_row<'a, W: Write, I: Iterator<Item = &'a str>>(
out: &mut W,
cells: I,
widths: &[usize],
) -> std::io::Result<()> {
let cells: Vec<&str> = cells.collect();
let last = cells.len().saturating_sub(1);
for (i, cell) in cells.iter().enumerate() {
if i == last {
write!(out, "{}", cell)?;
} else {
write!(out, "{:<width$} ", cell, width = widths[i])?;
}
}
writeln!(out)
}
pub fn write_private_file(path: &std::path::Path, bytes: &[u8]) -> anyhow::Result<()> {
use anyhow::Context as _;
std::fs::write(path, bytes).with_context(|| format!("failed to write {}", path.display()))?;
#[cfg(unix)]
{
use std::os::unix::fs::PermissionsExt;
std::fs::set_permissions(path, std::fs::Permissions::from_mode(0o600))
.with_context(|| format!("failed to chmod 600 {}", path.display()))?;
}
Ok(())
}
pub fn image_dimensions(bytes: &[u8]) -> Option<(u32, u32)> {
if bytes.len() >= 24 && bytes.starts_with(b"\x89PNG\r\n\x1a\n") && &bytes[12..16] == b"IHDR" {
let w = u32::from_be_bytes([bytes[16], bytes[17], bytes[18], bytes[19]]);
let h = u32::from_be_bytes([bytes[20], bytes[21], bytes[22], bytes[23]]);
return Some((w, h));
}
if bytes.len() >= 4 && bytes[0] == 0xFF && bytes[1] == 0xD8 {
let mut i = 2;
while i + 9 < bytes.len() {
if bytes[i] != 0xFF {
i += 1;
continue;
}
let marker = bytes[i + 1];
if marker == 0xFF {
i += 1;
continue;
}
let is_sof = (0xC0..=0xCF).contains(&marker) && !matches!(marker, 0xC4 | 0xC8 | 0xCC);
if is_sof {
let h = u16::from_be_bytes([bytes[i + 5], bytes[i + 6]]) as u32;
let w = u16::from_be_bytes([bytes[i + 7], bytes[i + 8]]) as u32;
return Some((w, h));
}
let len = u16::from_be_bytes([bytes[i + 2], bytes[i + 3]]) as usize;
i += 2 + len;
}
}
None
}
pub fn print_json<W: Write, T: Serialize>(out: &mut W, value: &T) -> anyhow::Result<()> {
let s = serde_json::to_string_pretty(value)?;
out.write_all(s.as_bytes())?;
out.write_all(b"\n")?;
Ok(())
}
#[cfg(test)]
mod tests {
use super::*;
#[test]
fn empty_rows_produces_headers_and_separator() {
let mut buf: Vec<u8> = Vec::new();
print_table(&mut buf, &["A", "BB"], &[]).unwrap();
let s = String::from_utf8(buf).unwrap();
let lines: Vec<&str> = s.lines().collect();
assert_eq!(lines.len(), 2, "got: {:?}", lines);
assert!(lines[0].starts_with("A "));
assert!(lines[0].contains("BB"));
assert!(lines[1].starts_with("-"));
assert!(lines[1].contains("--"));
}
#[test]
fn column_widths_grow_to_longest_cell() {
let mut buf: Vec<u8> = Vec::new();
let rows = vec![
vec!["short".to_string(), "x".to_string()],
vec!["a-very-long-cell".to_string(), "y".to_string()],
];
print_table(&mut buf, &["K", "V"], &rows).unwrap();
let s = String::from_utf8(buf).unwrap();
let lines: Vec<&str> = s.lines().collect();
assert!(
lines[0].starts_with("K "),
"header pad wrong: {:?}",
lines[0]
);
assert!(
lines[1].starts_with(&"-".repeat(16)),
"sep wrong: {:?}",
lines[1]
);
assert!(lines[2].starts_with("short "));
assert!(lines[3].starts_with("a-very-long-cell y"));
}
#[test]
fn image_dimensions_parse_png_and_jpeg_headers() {
let mut png = b"\x89PNG\r\n\x1a\n".to_vec();
png.extend_from_slice(&[0, 0, 0, 13]);
png.extend_from_slice(b"IHDR");
png.extend_from_slice(&1280u32.to_be_bytes());
png.extend_from_slice(&720u32.to_be_bytes());
assert_eq!(image_dimensions(&png), Some((1280, 720)));
let mut jpg = vec![0xFF, 0xD8, 0xFF, 0xE0, 0x00, 0x04, 0x00, 0x00];
jpg.extend_from_slice(&[0xFF, 0xC0, 0x00, 0x11, 0x08, 0x00, 0x32, 0x00, 0x64, 0x03]);
assert_eq!(image_dimensions(&jpg), Some((100, 50)));
assert_eq!(image_dimensions(b"nope"), None);
}
#[test]
fn json_output_is_valid_json() {
#[derive(Serialize)]
struct X {
a: u32,
b: Vec<String>,
}
let mut buf: Vec<u8> = Vec::new();
let x = X {
a: 7,
b: vec!["hi".into(), "there".into()],
};
print_json(&mut buf, &x).unwrap();
let s = String::from_utf8(buf).unwrap();
let v: serde_json::Value = serde_json::from_str(&s).unwrap();
assert_eq!(v["a"], 7);
assert_eq!(v["b"][1], "there");
}
}