fcoreutils 0.22.0

use std::cmp::Ordering;
use std::collections::HashMap;
use std::ffi::CString;
use std::fs::{self, DirEntry, Metadata};
use std::io::{self, BufWriter, Write};
use std::os::unix::fs::MetadataExt;
use std::path::{Path, PathBuf};
use std::sync::atomic::{AtomicBool, Ordering as AtomicOrdering};
use std::time::SystemTime;

/// Whether the current locale uses simple byte-order collation (C/POSIX).
/// When true, we skip the expensive `strcoll()` + CString allocation path.
static IS_C_LOCALE: AtomicBool = AtomicBool::new(false);

/// Detect whether the current locale is C/POSIX (byte-order collation).
/// Must be called after `setlocale(LC_ALL, "")`.
pub fn detect_c_locale() {
    let lc = unsafe { libc::setlocale(libc::LC_COLLATE, std::ptr::null()) };
    if lc.is_null() {
        IS_C_LOCALE.store(true, AtomicOrdering::Relaxed);
        return;
    }
    let s = unsafe { std::ffi::CStr::from_ptr(lc) }.to_bytes();
    let is_c = s == b"C" || s == b"POSIX";
    IS_C_LOCALE.store(is_c, AtomicOrdering::Relaxed);
}

// ---------------------------------------------------------------------------
// Configuration types
// ---------------------------------------------------------------------------

/// How to sort directory entries.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum SortBy {
    Name,
    Size,
    Time,
    Extension,
    Version,
    None,
    Width,
}

/// Output layout.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum OutputFormat {
    Long,
    SingleColumn,
    Columns,
    Comma,
    Across,
}

/// When to emit ANSI colour escapes.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum ColorMode {
    Always,
    Auto,
    Never,
}

/// Which timestamp to show / sort by.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum TimeField {
    Mtime,
    Atime,
    Ctime,
    Birth,
}

/// How to format timestamps in long listing.
#[derive(Debug, Clone, PartialEq, Eq)]
pub enum TimeStyle {
    FullIso,
    LongIso,
    Iso,
    Locale,
    Custom(String),
}

/// What indicators to append to names.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum IndicatorStyle {
    None,
    Slash,
    FileType,
    Classify,
}

/// File-type classify mode (for -F / --classify).
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum ClassifyMode {
    Always,
    Auto,
    Never,
}

/// Quoting style for file names.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum QuotingStyle {
    Literal,
    Locale,
    Shell,
    ShellAlways,
    ShellEscape,
    ShellEscapeAlways,
    C,
    Escape,
}

/// When to emit hyperlinks.
#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum HyperlinkMode {
    Always,
    Auto,
    Never,
}

/// Full configuration for ls.
#[derive(Debug, Clone)]
pub struct LsConfig {
    pub all: bool,
    pub almost_all: bool,
    pub long_format: bool,
    pub human_readable: bool,
    pub si: bool,
    pub reverse: bool,
    pub recursive: bool,
    pub sort_by: SortBy,
    pub format: OutputFormat,
    pub classify: ClassifyMode,
    pub color: ColorMode,
    pub group_directories_first: bool,
    pub show_inode: bool,
    pub show_size: bool,
    pub show_owner: bool,
    pub show_group: bool,
    pub numeric_ids: bool,
    pub dereference: bool,
    pub directory: bool,
    pub time_field: TimeField,
    pub time_style: TimeStyle,
    pub ignore_patterns: Vec<String>,
    pub ignore_backups: bool,
    pub width: usize,
    pub quoting_style: QuotingStyle,
    pub hide_control_chars: bool,
    pub kibibytes: bool,
    pub indicator_style: IndicatorStyle,
    pub tab_size: usize,
    pub hyperlink: HyperlinkMode,
    pub context: bool,
    pub literal: bool,
    /// --zero: use NUL as line terminator instead of newline.
    pub zero: bool,
    /// --block-size=SIZE: scale sizes by SIZE before printing.
    /// None means not set (use default behavior).
    pub block_size: Option<u64>,
    /// Suffix to append after block-size-scaled values (e.g. "K", "M", "kB").
    pub block_size_suffix: String,
}

impl Default for LsConfig {
    fn default() -> Self {
        LsConfig {
            all: false,
            almost_all: false,
            long_format: false,
            human_readable: false,
            si: false,
            reverse: false,
            recursive: false,
            sort_by: SortBy::Name,
            format: OutputFormat::Columns,
            classify: ClassifyMode::Never,
            color: ColorMode::Auto,
            group_directories_first: false,
            show_inode: false,
            show_size: false,
            show_owner: true,
            show_group: true,
            numeric_ids: false,
            dereference: false,
            directory: false,
            time_field: TimeField::Mtime,
            time_style: TimeStyle::Locale,
            ignore_patterns: Vec::new(),
            ignore_backups: false,
            width: 80,
            quoting_style: QuotingStyle::Literal,
            hide_control_chars: false,
            kibibytes: false,
            indicator_style: IndicatorStyle::None,
            tab_size: 8,
            hyperlink: HyperlinkMode::Never,
            context: false,
            literal: false,
            zero: false,
            block_size: None,
            block_size_suffix: String::new(),
        }
    }
}

// ---------------------------------------------------------------------------
// Default LS_COLORS
// ---------------------------------------------------------------------------

/// Parsed colour database.
#[derive(Debug, Clone)]
pub struct ColorDb {
    pub map: HashMap<String, String>,
    pub dir: String,
    pub link: String,
    pub exec: String,
    pub pipe: String,
    pub socket: String,
    pub block_dev: String,
    pub char_dev: String,
    pub orphan: String,
    pub setuid: String,
    pub setgid: String,
    pub sticky: String,
    pub other_writable: String,
    pub sticky_other_writable: String,
    pub reset: String,
}

impl Default for ColorDb {
    fn default() -> Self {
        ColorDb {
            map: HashMap::new(),
            dir: "\x1b[01;34m".to_string(),            // bold blue
            link: "\x1b[01;36m".to_string(),           // bold cyan
            exec: "\x1b[01;32m".to_string(),           // bold green
            pipe: "\x1b[33m".to_string(),              // yellow
            socket: "\x1b[01;35m".to_string(),         // bold magenta
            block_dev: "\x1b[01;33m".to_string(),      // bold yellow
            char_dev: "\x1b[01;33m".to_string(),       // bold yellow
            orphan: "\x1b[01;31m".to_string(),         // bold red
            setuid: "\x1b[37;41m".to_string(),         // white on red
            setgid: "\x1b[30;43m".to_string(),         // black on yellow
            sticky: "\x1b[37;44m".to_string(),         // white on blue
            other_writable: "\x1b[34;42m".to_string(), // blue on green
            sticky_other_writable: "\x1b[30;42m".to_string(), // black on green
            reset: "\x1b[0m".to_string(),
        }
    }
}

impl ColorDb {
    /// Parse from LS_COLORS environment variable.
    pub fn from_env() -> Self {
        let mut db = ColorDb::default();
        if let Ok(val) = std::env::var("LS_COLORS") {
            for item in val.split(':') {
                if let Some((key, code)) = item.split_once('=') {
                    let esc = format!("\x1b[{}m", code);
                    match key {
                        "di" => db.dir = esc,
                        "ln" => db.link = esc,
                        "ex" => db.exec = esc,
                        "pi" | "fi" if key == "pi" => db.pipe = esc,
                        "so" => db.socket = esc,
                        "bd" => db.block_dev = esc,
                        "cd" => db.char_dev = esc,
                        "or" => db.orphan = esc,
                        "su" => db.setuid = esc,
                        "sg" => db.setgid = esc,
                        "st" => db.sticky = esc,
                        "ow" => db.other_writable = esc,
                        "tw" => db.sticky_other_writable = esc,
                        "rs" => db.reset = esc,
                        _ => {
                            if key.starts_with('*') {
                                db.map.insert(key[1..].to_string(), esc);
                            }
                        }
                    }
                }
            }
        }
        db
    }

    /// Look up the colour escape for a file entry.
    fn color_for(&self, entry: &FileEntry) -> &str {
        let mode = entry.mode;
        let ft = mode & (libc::S_IFMT as u32);

        // Symlink
        if ft == libc::S_IFLNK as u32 {
            if entry.link_target_ok {
                return &self.link;
            } else {
                return &self.orphan;
            }
        }

        // Directory with special bits
        if ft == libc::S_IFDIR as u32 {
            let sticky = mode & (libc::S_ISVTX as u32) != 0;
            let ow = mode & (libc::S_IWOTH as u32) != 0;
            if sticky && ow {
                return &self.sticky_other_writable;
            }
            if ow {
                return &self.other_writable;
            }
            if sticky {
                return &self.sticky;
            }
            return &self.dir;
        }

        // Special files
        if ft == libc::S_IFIFO as u32 {
            return &self.pipe;
        }
        if ft == libc::S_IFSOCK as u32 {
            return &self.socket;
        }
        if ft == libc::S_IFBLK as u32 {
            return &self.block_dev;
        }
        if ft == libc::S_IFCHR as u32 {
            return &self.char_dev;
        }

        // Setuid / setgid
        if mode & (libc::S_ISUID as u32) != 0 {
            return &self.setuid;
        }
        if mode & (libc::S_ISGID as u32) != 0 {
            return &self.setgid;
        }

        // Extension match
        if let Some(ext_pos) = entry.name.rfind('.') {
            let ext = &entry.name[ext_pos..];
            if let Some(c) = self.map.get(ext) {
                return c;
            }
        }

        // Executable
        if ft == libc::S_IFREG as u32
            && mode & (libc::S_IXUSR as u32 | libc::S_IXGRP as u32 | libc::S_IXOTH as u32) != 0
        {
            return &self.exec;
        }

        ""
    }
}

// ---------------------------------------------------------------------------
// File entry
// ---------------------------------------------------------------------------

/// One entry to display.
#[derive(Debug, Clone)]
pub struct FileEntry {
    pub name: String,
    pub path: PathBuf,
    /// Pre-computed CString for locale-aware sorting (avoids allocation in comparator).
    pub sort_key: CString,
    pub ino: u64,
    pub nlink: u64,
    pub mode: u32,
    pub uid: u32,
    pub gid: u32,
    pub size: u64,
    pub blocks: u64,
    pub mtime: i64,
    pub mtime_nsec: i64,
    pub atime: i64,
    pub atime_nsec: i64,
    pub ctime: i64,
    pub ctime_nsec: i64,
    pub rdev_major: u32,
    pub rdev_minor: u32,
    pub is_dir: bool,
    pub link_target: Option<String>,
    pub link_target_ok: bool,
    /// Whether the symlink target is a directory (for --classify indicator on target).
    pub link_target_is_dir: bool,
    /// The mode of the symlink target (for full --classify indicator on target).
    pub link_target_mode: Option<u32>,
}

impl FileEntry {
    /// Create from a DirEntry.
    fn from_dir_entry(de: &DirEntry, config: &LsConfig) -> io::Result<Self> {
        let name = de.file_name().to_string_lossy().into_owned();
        let path = de.path();

        let meta = if config.dereference {
            match fs::metadata(&path) {
                Ok(m) => m,
                Err(e) => {
                    // Check if it's a broken symlink when dereferencing
                    if let Ok(lmeta) = fs::symlink_metadata(&path) {
                        if lmeta.file_type().is_symlink() {
                            // For long format, show placeholder with error.
                            // For non-long formats, just show the name from lstat.
                            if config.long_format {
                                eprintln!(
                                    "ls: cannot access '{}': {}",
                                    name,
                                    crate::common::io_error_msg(&e)
                                );
                                return Ok(Self::broken_deref(name, path));
                            }
                            // Non-long format: use lstat data, no error
                            return Self::from_metadata(name, path, &lmeta, config);
                        }
                    }
                    return Err(e);
                }
            }
        } else {
            fs::symlink_metadata(&path)?
        };

        Self::from_metadata(name, path, &meta, config)
    }

    /// Create from a path using the full path as the display name (for -d with
    /// arguments, or for the `.` and `..` virtual entries).
    pub fn from_path_with_name(name: String, path: &Path, config: &LsConfig) -> io::Result<Self> {
        let meta = if config.dereference {
            fs::metadata(path).or_else(|_| fs::symlink_metadata(path))?
        } else {
            fs::symlink_metadata(path)?
        };
        Self::from_metadata(name, path.to_path_buf(), &meta, config)
    }

    fn from_metadata(
        name: String,
        path: PathBuf,
        meta: &Metadata,
        _config: &LsConfig,
    ) -> io::Result<Self> {
        let file_type = meta.file_type();
        let is_symlink = file_type.is_symlink();

        let (link_target, link_target_ok, link_target_is_dir, link_target_mode) = if is_symlink {
            match fs::read_link(&path) {
                Ok(target) => match fs::metadata(&path) {
                    Ok(target_meta) => {
                        let tmode = target_meta.mode();
                        (
                            Some(target.to_string_lossy().into_owned()),
                            true,
                            target_meta.is_dir(),
                            Some(tmode),
                        )
                    }
                    Err(_) => (
                        Some(target.to_string_lossy().into_owned()),
                        false,
                        false,
                        None,
                    ),
                },
                Err(_) => (None, false, false, None),
            }
        } else {
            (None, true, false, None)
        };

        let rdev = meta.rdev();
        let sort_key = CString::new(name.as_str()).unwrap_or_default();

        Ok(FileEntry {
            name,
            path,
            sort_key,
            ino: meta.ino(),
            nlink: meta.nlink(),
            mode: meta.mode(),
            uid: meta.uid(),
            gid: meta.gid(),
            size: meta.size(),
            blocks: meta.blocks(),
            mtime: meta.mtime(),
            mtime_nsec: meta.mtime_nsec(),
            atime: meta.atime(),
            atime_nsec: meta.atime_nsec(),
            ctime: meta.ctime(),
            ctime_nsec: meta.ctime_nsec(),
            rdev_major: ((rdev >> 8) & 0xfff) as u32,
            rdev_minor: (rdev & 0xff) as u32,
            is_dir: meta.is_dir(),
            link_target,
            link_target_ok,
            link_target_is_dir,
            link_target_mode,
        })
    }

    /// Get the timestamp for the chosen time field.
    fn time_secs(&self, field: TimeField) -> i64 {
        match field {
            TimeField::Mtime => self.mtime,
            TimeField::Atime => self.atime,
            TimeField::Ctime | TimeField::Birth => self.ctime,
        }
    }

    fn time_nsec(&self, field: TimeField) -> i64 {
        match field {
            TimeField::Mtime => self.mtime_nsec,
            TimeField::Atime => self.atime_nsec,
            TimeField::Ctime | TimeField::Birth => self.ctime_nsec,
        }
    }

    /// Return the extension (lowercase) for sorting.
    fn extension(&self) -> &str {
        match self.name.rfind('.') {
            Some(pos) if pos > 0 => &self.name[pos + 1..],
            _ => "",
        }
    }

    /// Is this a directory (or symlink-to-directory when dereferencing)?
    fn is_directory(&self) -> bool {
        self.is_dir
    }

    /// Indicator character for classify.
    fn indicator(&self, style: IndicatorStyle) -> &'static str {
        let ft = self.mode & (libc::S_IFMT as u32);
        match style {
            IndicatorStyle::None => "",
            IndicatorStyle::Slash => {
                if ft == libc::S_IFDIR as u32 {
                    "/"
                } else {
                    ""
                }
            }
            IndicatorStyle::FileType => match ft {
                x if x == libc::S_IFDIR as u32 => "/",
                x if x == libc::S_IFLNK as u32 => "@",
                x if x == libc::S_IFIFO as u32 => "|",
                x if x == libc::S_IFSOCK as u32 => "=",
                _ => "",
            },
            IndicatorStyle::Classify => match ft {
                x if x == libc::S_IFDIR as u32 => "/",
                x if x == libc::S_IFLNK as u32 => "@",
                x if x == libc::S_IFIFO as u32 => "|",
                x if x == libc::S_IFSOCK as u32 => "=",
                _ => {
                    if ft == libc::S_IFREG as u32
                        && self.mode
                            & (libc::S_IXUSR as u32 | libc::S_IXGRP as u32 | libc::S_IXOTH as u32)
                            != 0
                    {
                        "*"
                    } else {
                        ""
                    }
                }
            },
        }
    }

    /// Create a placeholder entry for a broken symlink when -L (dereference) is used.
    /// GNU ls shows `l????????? ? ? ? ? ? name` for such entries with proper column padding.
    pub fn broken_deref(name: String, path: PathBuf) -> Self {
        let sort_key = CString::new(name.as_str()).unwrap_or_default();
        FileEntry {
            name,
            path,
            sort_key,
            ino: 0,
            nlink: 0, // marker: normal entries have nlink >= 1
            mode: libc::S_IFLNK as u32,
            uid: 0,
            gid: 0,
            size: 0,
            blocks: 0,
            mtime: 0,
            mtime_nsec: 0,
            atime: 0,
            atime_nsec: 0,
            ctime: 0,
            ctime_nsec: 0,
            rdev_major: 0,
            rdev_minor: 0,
            is_dir: false,
            link_target: None,
            link_target_ok: false,
            link_target_is_dir: false,
            link_target_mode: None,
        }
    }

    /// Whether this is a broken dereference placeholder.
    pub fn is_broken_deref(&self) -> bool {
        self.nlink == 0 && (self.mode & libc::S_IFMT as u32) == libc::S_IFLNK as u32
    }

    /// Display width of the name (accounting for quoting, indicator).
    fn display_width(&self, config: &LsConfig) -> usize {
        let quoted = quote_name(&self.name, config);
        let ind = self.indicator(config.indicator_style);
        quoted.len() + ind.len()
    }
}

// ---------------------------------------------------------------------------
// Name quoting
// ---------------------------------------------------------------------------

/// Quote a filename according to the configured quoting style.
pub fn quote_name(name: &str, config: &LsConfig) -> String {
    match config.quoting_style {
        QuotingStyle::Literal => {
            if config.hide_control_chars {
                hide_control(name)
            } else {
                name.to_string()
            }
        }
        QuotingStyle::Escape => escape_name(name),
        QuotingStyle::C => c_quote(name),
        QuotingStyle::Shell => shell_quote(name, false, false),
        QuotingStyle::ShellAlways => shell_quote(name, true, false),
        QuotingStyle::ShellEscape => shell_quote(name, false, true),
        QuotingStyle::ShellEscapeAlways => shell_quote(name, true, true),
        QuotingStyle::Locale => locale_quote(name),
    }
}

fn hide_control(name: &str) -> String {
    name.chars()
        .map(|c| if c.is_control() { '?' } else { c })
        .collect()
}

fn escape_name(name: &str) -> String {
    let mut out = String::with_capacity(name.len());
    for c in name.chars() {
        match c {
            '\\' => out.push_str("\\\\"),
            '\n' => out.push_str("\\n"),
            '\r' => out.push_str("\\r"),
            '\t' => out.push_str("\\t"),
            ' ' => out.push_str("\\ "),
            c if c.is_control() => {
                out.push_str(&format!("\\{:03o}", c as u32));
            }
            c => out.push(c),
        }
    }
    out
}

fn c_quote(name: &str) -> String {
    let mut out = String::with_capacity(name.len() + 2);
    out.push('"');
    for c in name.chars() {
        match c {
            '"' => out.push_str("\\\""),
            '\\' => out.push_str("\\\\"),
            '\n' => out.push_str("\\n"),
            '\r' => out.push_str("\\r"),
            '\t' => out.push_str("\\t"),
            '\x07' => out.push_str("\\a"),
            '\x08' => out.push_str("\\b"),
            '\x0C' => out.push_str("\\f"),
            '\x0B' => out.push_str("\\v"),
            c if c.is_control() => {
                out.push_str(&format!("\\{:03o}", c as u32));
            }
            c => out.push(c),
        }
    }
    out.push('"');
    out
}

fn shell_quote(name: &str, always: bool, escape: bool) -> String {
    let needs_quoting = name.is_empty()
        || name
            .chars()
            .any(|c| " \t\n'\"\\|&;()<>!$`#~{}[]?*".contains(c) || c.is_control());

    if !needs_quoting && !always {
        return name.to_string();
    }

    if escape {
        // Use $'...' form with escape sequences for control chars
        let has_control = name.chars().any(|c| c.is_control());
        if has_control {
            let mut out = String::with_capacity(name.len() + 4);
            out.push_str("$'");
            for c in name.chars() {
                match c {
                    '\'' => out.push_str("\\'"),
                    '\\' => out.push_str("\\\\"),
                    '\n' => out.push_str("\\n"),
                    '\r' => out.push_str("\\r"),
                    '\t' => out.push_str("\\t"),
                    c if c.is_control() => {
                        out.push_str(&format!("\\{:03o}", c as u32));
                    }
                    c => out.push(c),
                }
            }
            out.push('\'');
            return out;
        }
    }

    // Use single quotes
    let mut out = String::with_capacity(name.len() + 2);
    out.push('\'');
    for c in name.chars() {
        if c == '\'' {
            out.push_str("'\\''");
        } else {
            out.push(c);
        }
    }
    out.push('\'');
    out
}

fn locale_quote(name: &str) -> String {
    // Use \u{2018} and \u{2019} (left/right single quotation marks)
    let mut out = String::with_capacity(name.len() + 2);
    out.push('\u{2018}');
    for c in name.chars() {
        match c {
            '\\' => out.push_str("\\\\"),
            '\n' => out.push_str("\\n"),
            '\r' => out.push_str("\\r"),
            '\t' => out.push_str("\\t"),
            c if c.is_control() => {
                out.push_str(&format!("\\{:03o}", c as u32));
            }
            c => out.push(c),
        }
    }
    out.push('\u{2019}');
    out
}

// ---------------------------------------------------------------------------
// Sorting
// ---------------------------------------------------------------------------

/// Natural version sort comparison (like GNU `ls -v` / `sort -V`).
pub(crate) fn version_cmp(a: &str, b: &str) -> Ordering {
    let ab = a.as_bytes();
    let bb = b.as_bytes();
    let mut ai = 0;
    let mut bi = 0;
    while ai < ab.len() && bi < bb.len() {
        let ac = ab[ai];
        let bc = bb[bi];
        if ac.is_ascii_digit() && bc.is_ascii_digit() {
            // Skip leading zeros
            let a_start = ai;
            let b_start = bi;
            while ai < ab.len() && ab[ai] == b'0' {
                ai += 1;
            }
            while bi < bb.len() && bb[bi] == b'0' {
                bi += 1;
            }
            let a_num_start = ai;
            let b_num_start = bi;
            while ai < ab.len() && ab[ai].is_ascii_digit() {
                ai += 1;
            }
            while bi < bb.len() && bb[bi].is_ascii_digit() {
                bi += 1;
            }
            let a_len = ai - a_num_start;
            let b_len = bi - b_num_start;
            if a_len != b_len {
                return a_len.cmp(&b_len);
            }
            let ord = ab[a_num_start..ai].cmp(&bb[b_num_start..bi]);
            if ord != Ordering::Equal {
                return ord;
            }
            // If numeric parts are equal, fewer leading zeros comes first
            let a_zeros = a_num_start - a_start;
            let b_zeros = b_num_start - b_start;
            if a_zeros != b_zeros {
                return a_zeros.cmp(&b_zeros);
            }
        } else {
            let ord = ac.cmp(&bc);
            if ord != Ordering::Equal {
                return ord;
            }
            ai += 1;
            bi += 1;
        }
    }
    ab.len().cmp(&bb.len())
}

fn sort_entries(entries: &mut [FileEntry], config: &LsConfig) {
    if config.group_directories_first {
        // Stable sort: directories first, then sort within each group
        entries.sort_by(|a, b| {
            let a_dir = a.is_directory();
            let b_dir = b.is_directory();
            match (a_dir, b_dir) {
                (true, false) => Ordering::Less,
                (false, true) => Ordering::Greater,
                _ => compare_entries(a, b, config),
            }
        });
    } else {
        entries.sort_by(|a, b| compare_entries(a, b, config));
    }
}

/// Locale-aware string comparison matching GNU ls behavior.
/// Uses pre-computed CStrings with `strcoll()` for non-C locales,
/// or fast byte comparison for C/POSIX locale.
#[inline]
fn locale_cmp_cstr(a: &CString, b: &CString) -> Ordering {
    if IS_C_LOCALE.load(AtomicOrdering::Relaxed) {
        a.as_bytes().cmp(b.as_bytes())
    } else {
        let result = unsafe { libc::strcoll(a.as_ptr(), b.as_ptr()) };
        result.cmp(&0)
    }
}

/// Locale-aware comparison for ad-hoc strings (e.g. directory args).
fn locale_cmp(a: &str, b: &str) -> Ordering {
    if IS_C_LOCALE.load(AtomicOrdering::Relaxed) {
        a.cmp(b)
    } else {
        let ca = CString::new(a).unwrap_or_default();
        let cb = CString::new(b).unwrap_or_default();
        let result = unsafe { libc::strcoll(ca.as_ptr(), cb.as_ptr()) };
        result.cmp(&0)
    }
}

fn compare_entries(a: &FileEntry, b: &FileEntry, config: &LsConfig) -> Ordering {
    // Use pre-computed CString sort keys to avoid allocation during sorting.
    let ord = match config.sort_by {
        SortBy::Name => locale_cmp_cstr(&a.sort_key, &b.sort_key),
        SortBy::Size => {
            let size_ord = b.size.cmp(&a.size);
            if size_ord == Ordering::Equal {
                locale_cmp_cstr(&a.sort_key, &b.sort_key)
            } else {
                size_ord
            }
        }
        SortBy::Time => {
            let ta = a.time_secs(config.time_field);
            let tb = b.time_secs(config.time_field);
            let ord = tb.cmp(&ta);
            if ord == Ordering::Equal {
                let na = a.time_nsec(config.time_field);
                let nb = b.time_nsec(config.time_field);
                let nsec_ord = nb.cmp(&na);
                if nsec_ord == Ordering::Equal {
                    locale_cmp_cstr(&a.sort_key, &b.sort_key)
                } else {
                    nsec_ord
                }
            } else {
                ord
            }
        }
        SortBy::Extension => {
            let ea = a.extension();
            let eb = b.extension();
            let ord = locale_cmp(ea, eb);
            if ord == Ordering::Equal {
                locale_cmp_cstr(&a.sort_key, &b.sort_key)
            } else {
                ord
            }
        }
        SortBy::Version => version_cmp(&a.name, &b.name),
        SortBy::None => Ordering::Equal,
        SortBy::Width => {
            let wa = a.display_width(config);
            let wb = b.display_width(config);
            wa.cmp(&wb)
        }
    };

    if config.reverse { ord.reverse() } else { ord }
}

// ---------------------------------------------------------------------------
// Permission formatting
// ---------------------------------------------------------------------------

/// Format permission bits as `drwxr-xr-x` (10 chars).
pub fn format_permissions(mode: u32) -> String {
    let mut s = String::with_capacity(10);

    // File type character
    s.push(match mode & (libc::S_IFMT as u32) {
        x if x == libc::S_IFDIR as u32 => 'd',
        x if x == libc::S_IFLNK as u32 => 'l',
        x if x == libc::S_IFBLK as u32 => 'b',
        x if x == libc::S_IFCHR as u32 => 'c',
        x if x == libc::S_IFIFO as u32 => 'p',
        x if x == libc::S_IFSOCK as u32 => 's',
        _ => '-',
    });

    // User
    s.push(if mode & (libc::S_IRUSR as u32) != 0 {
        'r'
    } else {
        '-'
    });
    s.push(if mode & (libc::S_IWUSR as u32) != 0 {
        'w'
    } else {
        '-'
    });
    s.push(if mode & (libc::S_ISUID as u32) != 0 {
        if mode & (libc::S_IXUSR as u32) != 0 {
            's'
        } else {
            'S'
        }
    } else if mode & (libc::S_IXUSR as u32) != 0 {
        'x'
    } else {
        '-'
    });

    // Group
    s.push(if mode & (libc::S_IRGRP as u32) != 0 {
        'r'
    } else {
        '-'
    });
    s.push(if mode & (libc::S_IWGRP as u32) != 0 {
        'w'
    } else {
        '-'
    });
    s.push(if mode & (libc::S_ISGID as u32) != 0 {
        if mode & (libc::S_IXGRP as u32) != 0 {
            's'
        } else {
            'S'
        }
    } else if mode & (libc::S_IXGRP as u32) != 0 {
        'x'
    } else {
        '-'
    });

    // Other
    s.push(if mode & (libc::S_IROTH as u32) != 0 {
        'r'
    } else {
        '-'
    });
    s.push(if mode & (libc::S_IWOTH as u32) != 0 {
        'w'
    } else {
        '-'
    });
    s.push(if mode & (libc::S_ISVTX as u32) != 0 {
        if mode & (libc::S_IXOTH as u32) != 0 {
            't'
        } else {
            'T'
        }
    } else if mode & (libc::S_IXOTH as u32) != 0 {
        'x'
    } else {
        '-'
    });

    s
}

// ---------------------------------------------------------------------------
// Block size parsing (--block-size=SIZE)
// ---------------------------------------------------------------------------

/// Parse a GNU coreutils --block-size=SIZE value.
///
/// Supported formats:
///   - Plain number: `1024` → (1024, "")
///   - Suffix only: `K` → (1024, "K"), `M` → (1048576, "M")
///   - Number + suffix: `1K` → (1024, ""), `2M` → (2097152, "")
///   - SI suffix (trailing B): `KB` → (1000, "kB"), `MB` → (1000000, "MB")
///
/// Returns `(block_size_bytes, suffix_string)`.
pub fn parse_block_size(s: &str) -> Result<(u64, String), String> {
    let s = s.trim();
    if s.is_empty() {
        return Err("empty block size".to_string());
    }

    // Try to find where the numeric prefix ends and the suffix begins.
    // GNU: the SIZE may be an optional integer followed by one of:
    //   K, M, G, T, P, E, Z, Y (powers of 1024)
    //   KB, MB, GB, TB, PB, EB, ZB, YB (powers of 1000)
    let digit_end = s.find(|c: char| !c.is_ascii_digit()).unwrap_or(s.len());

    let (num_str, suffix_str) = s.split_at(digit_end);

    let suffix_upper = suffix_str.to_uppercase();

    // Determine base and multiplier from suffix
    let (multiplier, display_suffix) = match suffix_upper.as_str() {
        "" => (1u64, String::new()),
        "K" => (1024, "K".to_string()),
        "M" => (1024 * 1024, "M".to_string()),
        "G" => (1024 * 1024 * 1024, "G".to_string()),
        "T" => (1024u64 * 1024 * 1024 * 1024, "T".to_string()),
        "P" => (1024u64 * 1024 * 1024 * 1024 * 1024, "P".to_string()),
        "E" => (1024u64 * 1024 * 1024 * 1024 * 1024 * 1024, "E".to_string()),
        "KB" => (1000, "kB".to_string()),
        "MB" => (1000 * 1000, "MB".to_string()),
        "GB" => (1000 * 1000 * 1000, "GB".to_string()),
        "TB" => (1000u64 * 1000 * 1000 * 1000, "TB".to_string()),
        "PB" => (1000u64 * 1000 * 1000 * 1000 * 1000, "PB".to_string()),
        "EB" => (1000u64 * 1000 * 1000 * 1000 * 1000 * 1000, "EB".to_string()),
        _ => {
            return Err(format!("invalid suffix in block size '{}'", s));
        }
    };

    let numeric = if num_str.is_empty() {
        1u64
    } else {
        num_str
            .parse::<u64>()
            .map_err(|_| format!("invalid block size '{}'", s))?
    };

    let block_size = numeric
        .checked_mul(multiplier)
        .ok_or_else(|| format!("block size '{}' is too large", s))?;

    if block_size == 0 {
        return Err(format!("invalid block size '{}'", s));
    }

    // GNU behavior for suffix display:
    // - If a numeric prefix was given (e.g. "1K", "2M"), no suffix is shown.
    // - If no numeric prefix (e.g. "K", "M", "KB"), suffix is shown.
    let suffix = if num_str.is_empty() {
        display_suffix
    } else {
        String::new()
    };

    Ok((block_size, suffix))
}

// ---------------------------------------------------------------------------
// Size formatting
// ---------------------------------------------------------------------------

/// Format a file size for display.
pub fn format_size(size: u64, config: &LsConfig) -> String {
    // --block-size takes precedence over -h / --si / -k
    if let Some(bs) = config.block_size {
        let scaled = if bs == 0 { size } else { (size + bs - 1) / bs };
        return format!("{}{}", scaled, config.block_size_suffix);
    }
    if config.human_readable || config.si {
        let base: f64 = if config.si { 1000.0 } else { 1024.0 };
        let suffixes = ["", "K", "M", "G", "T", "P", "E"];

        if size == 0 {
            return "0".to_string();
        }

        let mut val = size as f64;
        let mut idx = 0;
        while val >= base && idx < suffixes.len() - 1 {
            val /= base;
            idx += 1;
        }

        if idx == 0 {
            format!("{}", size)
        } else if val >= 10.0 {
            format!("{:.0}{}", val, suffixes[idx])
        } else {
            format!("{:.1}{}", val, suffixes[idx])
        }
    } else if config.kibibytes {
        // Show blocks in 1K units
        let blocks_k = (size + 1023) / 1024;
        format!("{}", blocks_k)
    } else {
        format!("{}", size)
    }
}

/// Format blocks for the -s option (in 1K units by default, or --si / -h).
pub fn format_blocks(blocks_512: u64, config: &LsConfig) -> String {
    let bytes = blocks_512 * 512;
    if let Some(bs) = config.block_size {
        let scaled = if bs == 0 {
            bytes
        } else {
            (bytes + bs - 1) / bs
        };
        return format!("{}{}", scaled, config.block_size_suffix);
    }
    if config.human_readable || config.si {
        format_size(bytes, config)
    } else if config.kibibytes {
        let k = (bytes + 1023) / 1024;
        format!("{}", k)
    } else {
        // Default: 1K blocks
        let k = (bytes + 1023) / 1024;
        format!("{}", k)
    }
}

// ---------------------------------------------------------------------------
// Timestamp formatting
// ---------------------------------------------------------------------------

/// Format a unix timestamp for long listing.
pub fn format_time(secs: i64, nsec: i64, style: &TimeStyle) -> String {
    // Convert to SystemTime for the six-months-ago check
    let now_sys = SystemTime::now();
    let now_secs = now_sys
        .duration_since(SystemTime::UNIX_EPOCH)
        .map(|d| d.as_secs() as i64)
        .unwrap_or(0);
    let six_months_ago = now_secs - 6 * 30 * 24 * 3600;

    // Break down the timestamp
    let tm = time_from_epoch(secs);

    match style {
        TimeStyle::FullIso => {
            format!(
                "{:04}-{:02}-{:02} {:02}:{:02}:{:02}.{:09} {}",
                tm.year,
                tm.month,
                tm.day,
                tm.hour,
                tm.min,
                tm.sec,
                nsec,
                format_tz_offset(tm.utc_offset_secs)
            )
        }
        TimeStyle::LongIso => {
            format!(
                "{:04}-{:02}-{:02} {:02}:{:02}",
                tm.year, tm.month, tm.day, tm.hour, tm.min
            )
        }
        TimeStyle::Iso => {
            if secs > six_months_ago && secs <= now_secs {
                format!("{:02}-{:02} {:02}:{:02}", tm.month, tm.day, tm.hour, tm.min)
            } else {
                format!("{:02}-{:02}  {:04}", tm.month, tm.day, tm.year)
            }
        }
        TimeStyle::Locale | TimeStyle::Custom(_) => {
            let month_names = [
                "Jan", "Feb", "Mar", "Apr", "May", "Jun", "Jul", "Aug", "Sep", "Oct", "Nov", "Dec",
            ];
            let mon = if tm.month >= 1 && tm.month <= 12 {
                month_names[(tm.month - 1) as usize]
            } else {
                "???"
            };

            if secs > six_months_ago && secs <= now_secs {
                format!("{} {:>2} {:02}:{:02}", mon, tm.day, tm.hour, tm.min)
            } else {
                format!("{} {:>2}  {:04}", mon, tm.day, tm.year)
            }
        }
    }
}

fn format_tz_offset(offset_secs: i32) -> String {
    let sign = if offset_secs >= 0 { '+' } else { '-' };
    let abs = offset_secs.unsigned_abs();
    let hours = abs / 3600;
    let mins = (abs % 3600) / 60;
    format!("{}{:02}{:02}", sign, hours, mins)
}

struct BrokenDownTime {
    year: i32,
    month: u32,
    day: u32,
    hour: u32,
    min: u32,
    sec: u32,
    utc_offset_secs: i32,
}

/// Convert epoch seconds to broken-down local time using libc::localtime_r.
fn time_from_epoch(secs: i64) -> BrokenDownTime {
    let mut tm: libc::tm = unsafe { std::mem::zeroed() };
    let time_t = secs as libc::time_t;
    unsafe {
        libc::localtime_r(&time_t, &mut tm);
    }
    BrokenDownTime {
        year: tm.tm_year + 1900,
        month: (tm.tm_mon + 1) as u32,
        day: tm.tm_mday as u32,
        hour: tm.tm_hour as u32,
        min: tm.tm_min as u32,
        sec: tm.tm_sec as u32,
        utc_offset_secs: tm.tm_gmtoff as i32,
    }
}

// ---------------------------------------------------------------------------
// User/group name lookup
// ---------------------------------------------------------------------------

/// Look up a username by UID. Returns numeric string on failure.
/// Cached user name lookup to avoid repeated getpwuid_r syscalls.
fn lookup_user(uid: u32) -> String {
    use std::cell::RefCell;
    thread_local! {
        static CACHE: RefCell<HashMap<u32, String>> = RefCell::new(HashMap::new());
    }
    CACHE.with(|c| {
        let mut cache = c.borrow_mut();
        if let Some(name) = cache.get(&uid) {
            return name.clone();
        }
        let name = lookup_user_uncached(uid);
        cache.insert(uid, name.clone());
        name
    })
}

fn lookup_user_uncached(uid: u32) -> String {
    let mut buf = vec![0u8; 1024];
    let mut pwd: libc::passwd = unsafe { std::mem::zeroed() };
    let mut result: *mut libc::passwd = std::ptr::null_mut();
    let ret = unsafe {
        libc::getpwuid_r(
            uid,
            &mut pwd,
            buf.as_mut_ptr() as *mut libc::c_char,
            buf.len(),
            &mut result,
        )
    };
    if ret == 0 && !result.is_null() {
        let cstr = unsafe { std::ffi::CStr::from_ptr(pwd.pw_name) };
        cstr.to_string_lossy().into_owned()
    } else {
        uid.to_string()
    }
}

/// Cached group name lookup to avoid repeated getgrgid_r syscalls.
fn lookup_group(gid: u32) -> String {
    use std::cell::RefCell;
    thread_local! {
        static CACHE: RefCell<HashMap<u32, String>> = RefCell::new(HashMap::new());
    }
    CACHE.with(|c| {
        let mut cache = c.borrow_mut();
        if let Some(name) = cache.get(&gid) {
            return name.clone();
        }
        let name = lookup_group_uncached(gid);
        cache.insert(gid, name.clone());
        name
    })
}

fn lookup_group_uncached(gid: u32) -> String {
    let mut buf = vec![0u8; 1024];
    let mut grp: libc::group = unsafe { std::mem::zeroed() };
    let mut result: *mut libc::group = std::ptr::null_mut();
    let ret = unsafe {
        libc::getgrgid_r(
            gid,
            &mut grp,
            buf.as_mut_ptr() as *mut libc::c_char,
            buf.len(),
            &mut result,
        )
    };
    if ret == 0 && !result.is_null() {
        let cstr = unsafe { std::ffi::CStr::from_ptr(grp.gr_name) };
        cstr.to_string_lossy().into_owned()
    } else {
        gid.to_string()
    }
}

// ---------------------------------------------------------------------------
// Pattern matching (for --ignore)
// ---------------------------------------------------------------------------

/// Simple glob matching (supports * and ?).
pub fn glob_match(pattern: &str, name: &str) -> bool {
    let pat = pattern.as_bytes();
    let txt = name.as_bytes();
    let mut pi = 0;
    let mut ti = 0;
    let mut star_p = usize::MAX;
    let mut star_t = 0;

    while ti < txt.len() {
        if pi < pat.len() && (pat[pi] == b'?' || pat[pi] == txt[ti]) {
            pi += 1;
            ti += 1;
        } else if pi < pat.len() && pat[pi] == b'*' {
            star_p = pi;
            star_t = ti;
            pi += 1;
        } else if star_p != usize::MAX {
            pi = star_p + 1;
            star_t += 1;
            ti = star_t;
        } else {
            return false;
        }
    }
    while pi < pat.len() && pat[pi] == b'*' {
        pi += 1;
    }
    pi == pat.len()
}

fn should_ignore(name: &str, config: &LsConfig) -> bool {
    if config.ignore_backups && name.ends_with('~') {
        return true;
    }
    for pat in &config.ignore_patterns {
        if glob_match(pat, name) {
            return true;
        }
    }
    false
}

// ---------------------------------------------------------------------------
// Reading directory entries
// ---------------------------------------------------------------------------

/// Read entries from a directory path.
pub fn read_entries(path: &Path, config: &LsConfig) -> io::Result<Vec<FileEntry>> {
    let mut entries = Vec::new();

    // GNU behavior: -A overrides -a (when both are set, -aA means almost_all)
    let show_all = config.all && !config.almost_all;
    let show_hidden = config.all || config.almost_all;

    if show_all {
        // Add . and ..
        if let Ok(e) = FileEntry::from_path_with_name(".".to_string(), path, config) {
            entries.push(e);
        }
        let parent = path.parent().unwrap_or(path);
        if let Ok(e) = FileEntry::from_path_with_name("..".to_string(), parent, config) {
            entries.push(e);
        }
    }

    for entry in fs::read_dir(path)? {
        let entry = entry?;
        let name = entry.file_name().to_string_lossy().into_owned();

        // Filter hidden files
        if !show_hidden && name.starts_with('.') {
            continue;
        }

        // Filter ignored patterns
        if should_ignore(&name, config) {
            continue;
        }

        match FileEntry::from_dir_entry(&entry, config) {
            Ok(fe) => entries.push(fe),
            Err(e) => {
                eprintln!("ls: cannot access '{}': {}", entry.path().display(), e);
            }
        }
    }

    Ok(entries)
}

// ---------------------------------------------------------------------------
// Long format output
// ---------------------------------------------------------------------------

/// Print entries in long format to the writer.
fn print_long(
    out: &mut impl Write,
    entries: &[FileEntry],
    config: &LsConfig,
    color_db: Option<&ColorDb>,
) -> io::Result<()> {
    if entries.is_empty() {
        return Ok(());
    }

    // Calculate column widths for alignment
    let max_nlink = entries
        .iter()
        .map(|e| count_digits(e.nlink))
        .max()
        .unwrap_or(1);
    let max_owner = if config.show_owner {
        entries
            .iter()
            .map(|e| {
                if config.numeric_ids {
                    e.uid.to_string().len()
                } else {
                    lookup_user(e.uid).len()
                }
            })
            .max()
            .unwrap_or(0)
    } else {
        0
    };
    let max_group = if config.show_group {
        entries
            .iter()
            .map(|e| {
                if config.numeric_ids {
                    e.gid.to_string().len()
                } else {
                    lookup_group(e.gid).len()
                }
            })
            .max()
            .unwrap_or(0)
    } else {
        0
    };

    // Size width: use the formatted size for human-readable, else raw digits
    let has_device = entries.iter().any(|e| {
        let ft = e.mode & (libc::S_IFMT as u32);
        ft == libc::S_IFBLK as u32 || ft == libc::S_IFCHR as u32
    });
    let max_size = if has_device {
        // For device files, need room for "major, minor"
        entries
            .iter()
            .map(|e| {
                let ft = e.mode & (libc::S_IFMT as u32);
                if ft == libc::S_IFBLK as u32 || ft == libc::S_IFCHR as u32 {
                    format!("{}, {}", e.rdev_major, e.rdev_minor).len()
                } else {
                    format_size(e.size, config).len()
                }
            })
            .max()
            .unwrap_or(1)
    } else {
        entries
            .iter()
            .map(|e| format_size(e.size, config).len())
            .max()
            .unwrap_or(1)
    };

    let max_inode = if config.show_inode {
        entries
            .iter()
            .map(|e| count_digits(e.ino))
            .max()
            .unwrap_or(1)
    } else {
        0
    };

    let max_blocks = if config.show_size {
        entries
            .iter()
            .map(|e| format_blocks(e.blocks, config).len())
            .max()
            .unwrap_or(1)
    } else {
        0
    };

    // Compute timestamp width from non-broken entries so broken-deref "?" aligns.
    let ts_width = entries
        .iter()
        .filter(|e| !e.is_broken_deref())
        .map(|e| {
            format_time(
                e.time_secs(config.time_field),
                e.time_nsec(config.time_field),
                &config.time_style,
            )
            .len()
        })
        .max()
        .unwrap_or(12);

    for entry in entries {
        // Broken dereference placeholder: show l????????? ? ?<pad> ?<pad> ?<pad> ? name
        if entry.is_broken_deref() {
            let quoted = quote_name(&entry.name, config);
            if config.show_inode {
                write!(out, "{:>width$} ", "?", width = max_inode)?;
            }
            if config.show_size {
                write!(out, "{:>width$} ", "?", width = max_blocks)?;
            }
            write!(out, "l????????? ")?;
            write!(out, "{:>width$} ", "?", width = max_nlink)?;
            if config.show_owner {
                write!(out, "{:<width$} ", "?", width = max_owner)?;
            }
            if config.show_group {
                write!(out, "{:<width$} ", "?", width = max_group)?;
            }
            write!(out, "{:>width$} ", "?", width = max_size)?;
            write!(out, "{:>width$} ", "?", width = ts_width)?;
            writeln!(out, "{}", quoted)?;
            continue;
        }

        // Inode
        if config.show_inode {
            write!(out, "{:>width$} ", entry.ino, width = max_inode)?;
        }

        // Block size
        if config.show_size {
            let bs = format_blocks(entry.blocks, config);
            write!(out, "{:>width$} ", bs, width = max_blocks)?;
        }

        // Permissions
        write!(out, "{} ", format_permissions(entry.mode))?;

        // Hard link count
        write!(out, "{:>width$} ", entry.nlink, width = max_nlink)?;

        // Owner
        if config.show_owner {
            let owner = if config.numeric_ids {
                entry.uid.to_string()
            } else {
                lookup_user(entry.uid)
            };
            write!(out, "{:<width$} ", owner, width = max_owner)?;
        }

        // Group
        if config.show_group {
            let group = if config.numeric_ids {
                entry.gid.to_string()
            } else {
                lookup_group(entry.gid)
            };
            write!(out, "{:<width$} ", group, width = max_group)?;
        }

        // Size or device numbers
        let ft = entry.mode & (libc::S_IFMT as u32);
        if ft == libc::S_IFBLK as u32 || ft == libc::S_IFCHR as u32 {
            let dev = format!("{}, {}", entry.rdev_major, entry.rdev_minor);
            write!(out, "{:>width$} ", dev, width = max_size)?;
        } else {
            let sz = format_size(entry.size, config);
            write!(out, "{:>width$} ", sz, width = max_size)?;
        }

        // Timestamp
        let ts = format_time(
            entry.time_secs(config.time_field),
            entry.time_nsec(config.time_field),
            &config.time_style,
        );
        write!(out, "{} ", ts)?;

        // Name (with colour)
        let quoted = quote_name(&entry.name, config);
        if let Some(db) = color_db {
            let c = db.color_for(entry);
            if c.is_empty() {
                write!(out, "{}", quoted)?;
            } else {
                write!(out, "{}{}{}", c, quoted, db.reset)?;
            }
        } else {
            write!(out, "{}", quoted)?;
        }

        // Indicator — GNU ls does not append '@' to symlinks in long format;
        // the 'l' in the permission string already indicates a symlink.
        // Instead, the classify indicator goes on the TARGET filename.
        let is_symlink = (entry.mode & libc::S_IFMT as u32) == libc::S_IFLNK as u32;
        if !is_symlink {
            let ind = entry.indicator(config.indicator_style);
            if !ind.is_empty() {
                write!(out, "{}", ind)?;
            }
        }

        // Symlink target
        if let Some(ref target) = entry.link_target {
            let quoted_target = quote_name(target, config);
            write!(out, " -> {}", quoted_target)?;
            // Append classify indicator for the target based on target's mode
            if config.indicator_style == IndicatorStyle::Classify
                || config.indicator_style == IndicatorStyle::FileType
                || config.indicator_style == IndicatorStyle::Slash
            {
                if let Some(tmode) = entry.link_target_mode {
                    let tft = tmode & libc::S_IFMT as u32;
                    let target_ind = if tft == libc::S_IFDIR as u32 {
                        "/"
                    } else if config.indicator_style == IndicatorStyle::Classify
                        && tft == libc::S_IFREG as u32
                        && tmode
                            & (libc::S_IXUSR as u32 | libc::S_IXGRP as u32 | libc::S_IXOTH as u32)
                            != 0
                    {
                        "*"
                    } else if (config.indicator_style == IndicatorStyle::Classify
                        || config.indicator_style == IndicatorStyle::FileType)
                        && tft == libc::S_IFIFO as u32
                    {
                        "|"
                    } else if (config.indicator_style == IndicatorStyle::Classify
                        || config.indicator_style == IndicatorStyle::FileType)
                        && tft == libc::S_IFSOCK as u32
                    {
                        "="
                    } else {
                        ""
                    };
                    if !target_ind.is_empty() {
                        write!(out, "{}", target_ind)?;
                    }
                }
            }
        }

        if config.zero {
            out.write_all(&[0u8])?;
        } else {
            writeln!(out)?;
        }
    }

    Ok(())
}

fn count_digits(n: u64) -> usize {
    if n == 0 {
        return 1;
    }
    let mut count = 0;
    let mut v = n;
    while v > 0 {
        count += 1;
        v /= 10;
    }
    count
}

// ---------------------------------------------------------------------------
// Column format output
// ---------------------------------------------------------------------------

/// Write spaces (and optionally tabs) to advance from column `from` to `to`.
/// Matches GNU ls `indent()`.
fn indent(out: &mut impl Write, from: usize, to: usize, tab: usize) -> io::Result<()> {
    let mut pos = from;
    while pos < to {
        if tab != 0 && to / tab > (pos + 1) / tab {
            out.write_all(b"\t")?;
            pos += tab - pos % tab;
        } else {
            out.write_all(b" ")?;
            pos += 1;
        }
    }
    Ok(())
}

/// Write inode/blocks prefix for column output.
fn write_entry_prefix(
    out: &mut impl Write,
    entry: &FileEntry,
    config: &LsConfig,
    max_inode_w: usize,
    max_blocks_w: usize,
) -> io::Result<()> {
    if config.show_inode {
        write!(out, "{:>width$} ", entry.ino, width = max_inode_w)?;
    }
    if config.show_size {
        let bs = format_blocks(entry.blocks, config);
        write!(out, "{:>width$} ", bs, width = max_blocks_w)?;
    }
    Ok(())
}

/// Write a file name with optional colour.
fn write_entry_name(
    out: &mut impl Write,
    display: &str,
    entry: &FileEntry,
    config: &LsConfig,
    color_db: Option<&ColorDb>,
) -> io::Result<()> {
    if let Some(db) = color_db {
        let c = db.color_for(entry);
        let quoted = quote_name(&entry.name, config);
        let ind = entry.indicator(config.indicator_style);
        if c.is_empty() {
            write!(out, "{}{}", quoted, ind)?;
        } else {
            write!(out, "{}{}{}{}", c, quoted, db.reset, ind)?;
        }
    } else {
        write!(out, "{}", display)?;
    }
    Ok(())
}

/// GNU-compatible `print_with_separator`: entries separated by `sep` + space/newline.
/// Used for `-w0` (unlimited width, all on one line separated by two spaces)
/// and `-m` (comma mode, wrapping at line width).
fn print_with_separator(
    out: &mut impl Write,
    entries: &[FileEntry],
    config: &LsConfig,
    color_db: Option<&ColorDb>,
    sep: u8,
    eol: u8,
) -> io::Result<()> {
    let line_length = config.width;

    let max_inode_w = if config.show_inode {
        entries
            .iter()
            .map(|e| count_digits(e.ino))
            .max()
            .unwrap_or(1)
    } else {
        0
    };
    let max_blocks_w = if config.show_size {
        entries
            .iter()
            .map(|e| format_blocks(e.blocks, config).len())
            .max()
            .unwrap_or(1)
    } else {
        0
    };

    let prefix_width = if config.show_inode && config.show_size {
        max_inode_w + 1 + max_blocks_w + 1
    } else if config.show_inode {
        max_inode_w + 1
    } else if config.show_size {
        max_blocks_w + 1
    } else {
        0
    };

    let mut pos: usize = 0;

    for (i, entry) in entries.iter().enumerate() {
        let quoted = quote_name(&entry.name, config);
        let ind = entry.indicator(config.indicator_style);
        let len = if line_length > 0 {
            quoted.len() + ind.len() + prefix_width
        } else {
            0
        };

        if i > 0 {
            // GNU: if line_length == 0, never wrap.
            // Otherwise check if name + 2 (sep+space) fits on current line.
            let fits =
                line_length == 0 || (pos + len + 2 < line_length && pos <= usize::MAX - len - 2);
            let separator: u8 = if fits { b' ' } else { eol };

            out.write_all(&[sep, separator])?;
            if fits {
                pos += 2;
            } else {
                pos = 0;
            }
        }

        write_entry_prefix(out, entry, config, max_inode_w, max_blocks_w)?;
        if let Some(db) = color_db {
            let c = db.color_for(entry);
            if c.is_empty() {
                write!(out, "{}{}", quoted, ind)?;
            } else {
                write!(out, "{}{}{}{}", c, quoted, db.reset, ind)?;
            }
        } else {
            write!(out, "{}{}", quoted, ind)?;
        }
        pos += len;
    }
    if !entries.is_empty() {
        out.write_all(&[eol])?;
    }
    Ok(())
}

/// Print entries in multi-column format.
fn print_columns(
    out: &mut impl Write,
    entries: &[FileEntry],
    config: &LsConfig,
    color_db: Option<&ColorDb>,
) -> io::Result<()> {
    if entries.is_empty() {
        return Ok(());
    }

    let eol: u8 = if config.zero { 0 } else { b'\n' };

    // GNU: when line_length == 0 (-w0), use print_with_separator(' ')
    // instead of column layout.  This outputs all entries on one line
    // separated by two spaces (sep + separator) with no tab indentation.
    if config.width == 0 {
        return print_with_separator(out, entries, config, color_db, b' ', eol);
    }

    let by_columns = config.format == OutputFormat::Columns;
    let tab = config.tab_size;
    let term_width = config.width;

    let max_inode_w = if config.show_inode {
        entries
            .iter()
            .map(|e| count_digits(e.ino))
            .max()
            .unwrap_or(1)
    } else {
        0
    };
    let max_blocks_w = if config.show_size {
        entries
            .iter()
            .map(|e| format_blocks(e.blocks, config).len())
            .max()
            .unwrap_or(1)
    } else {
        0
    };

    let prefix_width = if config.show_inode && config.show_size {
        max_inode_w + 1 + max_blocks_w + 1
    } else if config.show_inode {
        max_inode_w + 1
    } else if config.show_size {
        max_blocks_w + 1
    } else {
        0
    };

    // Pre-compute name display widths (including prefix and indicator)
    let items: Vec<(String, usize, &FileEntry)> = entries
        .iter()
        .map(|e| {
            let quoted = quote_name(&e.name, config);
            let ind = e.indicator(config.indicator_style);
            let display = format!("{}{}", quoted, ind);
            let w = display.len() + prefix_width;
            (display, w, e)
        })
        .collect();

    let n = items.len();

    // GNU algorithm: try every possible number of columns from max down to 1.
    // MIN_COLUMN_WIDTH = 3 (1 char name + 2 char gap)
    let min_col_w: usize = 3;
    let max_possible_cols = if term_width < min_col_w {
        1
    } else {
        let base = term_width / min_col_w;
        let extra = if !term_width.is_multiple_of(min_col_w) {
            1
        } else {
            0
        };
        std::cmp::min(base + extra, n)
    };

    // For each column count, maintain per-column widths and total line length
    let mut col_arrs: Vec<Vec<usize>> = (0..max_possible_cols)
        .map(|i| vec![min_col_w; i + 1])
        .collect();
    let mut line_lens: Vec<usize> = (0..max_possible_cols)
        .map(|i| (i + 1) * min_col_w)
        .collect();
    let mut valid: Vec<bool> = vec![true; max_possible_cols];

    for filesno in 0..n {
        let name_length = items[filesno].1;

        for i in 0..max_possible_cols {
            if !valid[i] {
                continue;
            }
            let ncols = i + 1;
            let idx = if by_columns {
                filesno / ((n + i) / ncols)
            } else {
                filesno % ncols
            };
            // Non-last columns get +2 gap
            let real_length = name_length + if idx == i { 0 } else { 2 };

            if col_arrs[i][idx] < real_length {
                line_lens[i] += real_length - col_arrs[i][idx];
                col_arrs[i][idx] = real_length;
                valid[i] = line_lens[i] < term_width;
            }
        }
    }

    // Find the maximum valid column count
    let mut num_cols = 1;
    for cols in (1..=max_possible_cols).rev() {
        if valid[cols - 1] {
            num_cols = cols;
            break;
        }
    }

    if num_cols <= 1 {
        return print_single_column(out, entries, config, color_db);
    }

    let col_arr = &col_arrs[num_cols - 1];

    if by_columns {
        // Column-major (-C): entries fill down columns first
        let num_rows = (n + num_cols - 1) / num_cols;
        for row in 0..num_rows {
            let mut pos = 0;
            let mut col = 0;
            let mut filesno = row;

            loop {
                let (ref display, w, entry) = items[filesno];
                let max_w = col_arr[col];

                write_entry_prefix(out, entry, config, max_inode_w, max_blocks_w)?;
                write_entry_name(out, display, entry, config, color_db)?;

                if n.saturating_sub(num_rows) <= filesno {
                    break;
                }
                filesno += num_rows;

                indent(out, pos + w, pos + max_w, tab)?;
                pos += max_w;
                col += 1;
            }
            out.write_all(&[eol])?;
        }
    } else {
        // Row-major (-x): entries fill across rows first
        let (ref display0, w0, entry0) = items[0];
        write_entry_prefix(out, entry0, config, max_inode_w, max_blocks_w)?;
        write_entry_name(out, display0, entry0, config, color_db)?;

        let mut pos: usize = 0;
        let mut prev_w = w0;
        let mut prev_max_w = col_arr[0];

        for filesno in 1..n {
            let col_idx = filesno % num_cols;

            if col_idx == 0 {
                out.write_all(&[eol])?;
                pos = 0;
            } else {
                indent(out, pos + prev_w, pos + prev_max_w, tab)?;
                pos += prev_max_w;
            }

            let (ref display, w, entry) = items[filesno];
            write_entry_prefix(out, entry, config, max_inode_w, max_blocks_w)?;
            write_entry_name(out, display, entry, config, color_db)?;

            prev_w = w;
            prev_max_w = col_arr[col_idx];
        }
        out.write_all(&[eol])?;
    }

    Ok(())
}

// ---------------------------------------------------------------------------
// Single column output
// ---------------------------------------------------------------------------

fn print_single_column(
    out: &mut impl Write,
    entries: &[FileEntry],
    config: &LsConfig,
    color_db: Option<&ColorDb>,
) -> io::Result<()> {
    let max_inode_w = if config.show_inode {
        entries
            .iter()
            .map(|e| count_digits(e.ino))
            .max()
            .unwrap_or(1)
    } else {
        0
    };
    let max_blocks_w = if config.show_size {
        entries
            .iter()
            .map(|e| format_blocks(e.blocks, config).len())
            .max()
            .unwrap_or(1)
    } else {
        0
    };

    for entry in entries {
        if config.show_inode {
            write!(out, "{:>width$} ", entry.ino, width = max_inode_w)?;
        }
        if config.show_size {
            let bs = format_blocks(entry.blocks, config);
            write!(out, "{:>width$} ", bs, width = max_blocks_w)?;
        }

        let quoted = quote_name(&entry.name, config);
        if let Some(db) = color_db {
            let c = db.color_for(entry);
            if c.is_empty() {
                write!(out, "{}", quoted)?;
            } else {
                write!(out, "{}{}{}", c, quoted, db.reset)?;
            }
        } else {
            write!(out, "{}", quoted)?;
        }

        let ind = entry.indicator(config.indicator_style);
        if !ind.is_empty() {
            write!(out, "{}", ind)?;
        }

        if config.zero {
            out.write_all(&[0u8])?;
        } else {
            writeln!(out)?;
        }
    }
    Ok(())
}

// ---------------------------------------------------------------------------
// Comma-separated output
// ---------------------------------------------------------------------------

pub fn print_comma(
    out: &mut impl Write,
    entries: &[FileEntry],
    config: &LsConfig,
    color_db: Option<&ColorDb>,
) -> io::Result<()> {
    let eol: u8 = if config.zero { 0 } else { b'\n' };
    let line_length = config.width;
    let mut pos: usize = 0;

    for (i, entry) in entries.iter().enumerate() {
        let quoted = quote_name(&entry.name, config);
        let ind = entry.indicator(config.indicator_style);
        let name_len = if line_length > 0 {
            quoted.len() + ind.len()
        } else {
            0
        };

        if i > 0 {
            // GNU: if line_length == 0, never wrap (no limit).
            // Otherwise, check if name + ", " fits on current line.
            let fits = line_length == 0
                || (pos + name_len + 2 < line_length && pos <= usize::MAX - name_len - 2);
            if fits {
                write!(out, ", ")?;
                pos += 2;
            } else {
                write!(out, ",")?;
                out.write_all(&[eol])?;
                pos = 0;
            }
        }

        if let Some(db) = color_db {
            let c = db.color_for(entry);
            if c.is_empty() {
                write!(out, "{}{}", quoted, ind)?;
            } else {
                write!(out, "{}{}{}{}", c, quoted, db.reset, ind)?;
            }
        } else {
            write!(out, "{}{}", quoted, ind)?;
        }
        pos += name_len;
    }
    if !entries.is_empty() {
        out.write_all(&[eol])?;
    }
    Ok(())
}

// ---------------------------------------------------------------------------
// Total blocks line
// ---------------------------------------------------------------------------

fn print_total(out: &mut impl Write, entries: &[FileEntry], config: &LsConfig) -> io::Result<()> {
    let total_blocks: u64 = entries.iter().map(|e| e.blocks).sum();
    let formatted = format_blocks(total_blocks, config);
    write!(out, "total {}", formatted)?;
    if config.zero {
        out.write_all(&[0u8])
    } else {
        writeln!(out)
    }
}

// ---------------------------------------------------------------------------
// Main entry point
// ---------------------------------------------------------------------------

/// List a single directory to the provided writer.
pub fn ls_dir(
    out: &mut impl Write,
    path: &Path,
    config: &LsConfig,
    color_db: Option<&ColorDb>,
    show_header: bool,
) -> io::Result<bool> {
    if show_header {
        writeln!(out, "{}:", path.display())?;
    }

    let mut entries = read_entries(path, config)?;
    sort_entries(&mut entries, config);

    // Track if any entries have errors (e.g., broken symlink with -L)
    let has_broken_deref = entries.iter().any(|e| e.is_broken_deref());

    // Print total in long / show_size modes
    if config.long_format || config.show_size {
        print_total(out, &entries, config)?;
    }

    match config.format {
        OutputFormat::Long => print_long(out, &entries, config, color_db)?,
        OutputFormat::SingleColumn => print_single_column(out, &entries, config, color_db)?,
        OutputFormat::Columns | OutputFormat::Across => {
            print_columns(out, &entries, config, color_db)?
        }
        OutputFormat::Comma => print_comma(out, &entries, config, color_db)?,
    }

    // Recursive
    if config.recursive {
        let dirs: Vec<PathBuf> = entries
            .iter()
            .filter(|e| {
                e.is_directory()
                    && e.name != "."
                    && e.name != ".."
                    && (e.mode & (libc::S_IFMT as u32)) != libc::S_IFLNK as u32
            })
            .map(|e| e.path.clone())
            .collect();

        for dir in dirs {
            writeln!(out)?;
            ls_dir(out, &dir, config, color_db, true)?;
        }
    }

    Ok(!has_broken_deref)
}

/// Top-level entry: list the given paths.
///
/// Returns `true` if all operations succeeded.
pub fn ls_main(paths: &[String], config: &LsConfig) -> io::Result<bool> {
    let stdout = io::stdout();
    let is_tty = atty_stdout();
    // For pipes: shrink kernel pipe buffer to 4 KB so our writes block once the
    // buffer fills, allowing SIGPIPE to be delivered when the reader closes
    // early (e.g. `ls /big-dir | head -5` → exit 141 like GNU ls).
    // For TTYs: use a 64 KB BufWriter for performance.
    #[cfg(target_os = "linux")]
    if !is_tty {
        unsafe {
            libc::fcntl(1, 1031 /* F_SETPIPE_SZ */, 4096i32)
        };
    }
    let buf_cap = if is_tty { 64 * 1024 } else { 4 * 1024 };
    let mut out = BufWriter::with_capacity(buf_cap, stdout.lock());

    let color_db = match config.color {
        ColorMode::Always => Some(ColorDb::from_env()),
        ColorMode::Auto => {
            if atty_stdout() {
                Some(ColorDb::from_env())
            } else {
                None
            }
        }
        ColorMode::Never => None,
    };

    let mut had_error = false;

    // Separate files and directories
    let mut file_args: Vec<FileEntry> = Vec::new();
    let mut dir_args: Vec<PathBuf> = Vec::new();

    for p in paths {
        let path = PathBuf::from(p);
        let meta_result = if config.dereference {
            match fs::metadata(&path) {
                Ok(m) => Ok(m),
                Err(e) => {
                    // When -L and metadata fails, check if it's a broken symlink
                    if let Ok(lmeta) = fs::symlink_metadata(&path) {
                        if lmeta.file_type().is_symlink() {
                            // Broken symlink with -L: show error + placeholder entry
                            eprintln!(
                                "ls: cannot access '{}': {}",
                                p,
                                crate::common::io_error_msg(&e)
                            );
                            had_error = true;
                            file_args.push(FileEntry::broken_deref(p.to_string(), path));
                            continue;
                        }
                    }
                    Err(e)
                }
            }
        } else {
            fs::symlink_metadata(&path)
        };

        match meta_result {
            Ok(meta) => {
                if config.directory || !meta.is_dir() {
                    match FileEntry::from_path_with_name(p.to_string(), &path, config) {
                        Ok(fe) => file_args.push(fe),
                        Err(e) => {
                            eprintln!("ls: cannot access '{}': {}", p, e);
                            had_error = true;
                        }
                    }
                } else {
                    dir_args.push(path);
                }
            }
            Err(e) => {
                eprintln!(
                    "ls: cannot access '{}': {}",
                    p,
                    crate::common::io_error_msg(&e)
                );
                had_error = true;
            }
        }
    }

    // Sort file args
    sort_entries(&mut file_args, config);

    // Print file arguments
    if !file_args.is_empty() {
        match config.format {
            OutputFormat::Long => print_long(&mut out, &file_args, config, color_db.as_ref())?,
            OutputFormat::SingleColumn => {
                print_single_column(&mut out, &file_args, config, color_db.as_ref())?
            }
            OutputFormat::Columns | OutputFormat::Across => {
                print_columns(&mut out, &file_args, config, color_db.as_ref())?
            }
            OutputFormat::Comma => print_comma(&mut out, &file_args, config, color_db.as_ref())?,
        }
    }

    // Sort directory args by name using locale-aware comparison
    dir_args.sort_by(|a, b| {
        let an = a.to_string_lossy();
        let bn = b.to_string_lossy();
        let ord = locale_cmp(&an, &bn);
        if config.reverse { ord.reverse() } else { ord }
    });

    let show_header =
        dir_args.len() > 1 || (!file_args.is_empty() && !dir_args.is_empty()) || config.recursive;

    for (i, dir) in dir_args.iter().enumerate() {
        if i > 0 || !file_args.is_empty() {
            writeln!(out)?;
        }
        match ls_dir(&mut out, dir, config, color_db.as_ref(), show_header) {
            Ok(true) => {}
            Ok(false) => {
                had_error = true;
            }
            Err(e) if e.kind() == io::ErrorKind::BrokenPipe => return Err(e),
            Err(e) => {
                eprintln!(
                    "ls: cannot open directory '{}': {}",
                    dir.display(),
                    crate::common::io_error_msg(&e)
                );
                had_error = true;
            }
        }
    }

    out.flush()?;

    Ok(!had_error)
}

/// Check if stdout is a TTY.
pub fn atty_stdout() -> bool {
    unsafe { libc::isatty(1) != 0 }
}

// ---------------------------------------------------------------------------
// Testable helpers (exported for tests module)
// ---------------------------------------------------------------------------

/// Collect entries for a directory into a Vec (for testing).
pub fn collect_entries(path: &Path, config: &LsConfig) -> io::Result<Vec<FileEntry>> {
    let mut entries = read_entries(path, config)?;
    sort_entries(&mut entries, config);
    Ok(entries)
}

/// Render long format lines to a String (for testing).
pub fn render_long(entries: &[FileEntry], config: &LsConfig) -> io::Result<String> {
    let mut buf = Vec::new();
    print_long(&mut buf, entries, config, None)?;
    Ok(String::from_utf8_lossy(&buf).into_owned())
}

/// Render single-column output to a String (for testing).
pub fn render_single_column(entries: &[FileEntry], config: &LsConfig) -> io::Result<String> {
    let mut buf = Vec::new();
    print_single_column(&mut buf, entries, config, None)?;
    Ok(String::from_utf8_lossy(&buf).into_owned())
}

/// Render full ls_dir output to a String (for testing).
pub fn render_dir(path: &Path, config: &LsConfig) -> io::Result<String> {
    let mut buf = Vec::new();
    ls_dir(&mut buf, path, config, None, false)?;
    Ok(String::from_utf8_lossy(&buf).into_owned())
}