nameless 0.15.2

use crate::path_to_name::path_to_name;
use anyhow::anyhow;
use char_device::CharDevice;
use clap::AmbientAuthority;
use io_streams::StreamDuplexer;
use std::ffi::OsStr;
use std::net::{TcpListener, TcpStream};
#[cfg(unix)]
use std::os::unix::net::{UnixListener, UnixStream};
use std::path::Path;
use url::Url;

pub(crate) struct Interactive {
    pub(crate) name: String,
    pub(crate) duplexer: StreamDuplexer,
}

pub(crate) fn open_interactive(
    os: &OsStr,
    _ambient_authority: AmbientAuthority,
) -> anyhow::Result<Interactive> {
    if let Some(s) = os.to_str() {
        // If we can parse it as a URL, treat it as such.
        if let Ok(url) = Url::parse(s) {
            return open_url(url);
        }

        // Special-case "-" to mean (stdin, stdout).
        if s == "-" {
            return acquire_stdin_stdout();
        }
    }

    #[cfg(not(windows))]
    {
        let lossy = os.to_string_lossy();

        // Strings beginning with "$(" are commands.
        if lossy.starts_with("$(") {
            return spawn_child(os, &lossy);
        }
    }

    // Otherwise try opening it as a path in the filesystem namespace.
    open_path(Path::new(os))
}

fn acquire_stdin_stdout() -> anyhow::Result<Interactive> {
    let duplexer = StreamDuplexer::stdin_stdout()?;
    Ok(Interactive {
        name: "-".to_owned(),
        duplexer,
    })
}

fn open_url(url: Url) -> anyhow::Result<Interactive> {
    match url.scheme() {
        "connect" => open_connect_url(url),
        "accept" => open_accept_url(url),
        scheme @ "http" | scheme @ "https" | scheme @ "file" | scheme @ "data" => {
            Err(anyhow!("non-interactive URL scheme \"{}\"", scheme))
        }
        other => Err(anyhow!("unsupported URL scheme \"{}\"", other)),
    }
}

fn open_connect_url(url: Url) -> anyhow::Result<Interactive> {
    if !url.username().is_empty()
        || url.password().is_some()
        || url.query().is_some()
        || url.fragment().is_some()
    {
        return Err(anyhow!("connect URL should only contain a socket address"));
    }

    if url.path().is_empty() {
        let port = match url.port() {
            Some(port) => port,
            None => return Err(anyhow!("TCP connect URL should have a port")),
        };
        let host_str = match url.host_str() {
            Some(host_str) => host_str,
            None => return Err(anyhow!("TCP connect URL should have a host")),
        };

        let duplexer = TcpStream::connect((host_str, port))?;
        let duplexer = StreamDuplexer::tcp_stream(duplexer);

        return Ok(Interactive {
            name: url.to_string(),
            duplexer,
        });
    }

    #[cfg(unix)]
    {
        if url.port().is_some() || url.host_str().is_some() {
            return Err(anyhow!(
                "Unix-domain connect URL should only contain a path"
            ));
        }

        let duplexer = UnixStream::connect(url.path())?;
        let duplexer = StreamDuplexer::unix_stream(duplexer);

        Ok(Interactive {
            name: url.to_string(),
            duplexer,
        })
    }

    #[cfg(windows)]
    {
        Err(anyhow!("Unsupported connect URL: {}", url))
    }
}

fn open_accept_url(url: Url) -> anyhow::Result<Interactive> {
    if !url.username().is_empty()
        || url.password().is_some()
        || url.query().is_some()
        || url.fragment().is_some()
    {
        return Err(anyhow!("accept URL should only contain a socket address"));
    }

    if url.path().is_empty() {
        let port = match url.port() {
            Some(port) => port,
            None => return Err(anyhow!("accept URL should have a port")),
        };
        let host_str = match url.host_str() {
            Some(host_str) => host_str,
            None => return Err(anyhow!("accept URL should have a host")),
        };

        let listener = TcpListener::bind((host_str, port))?;

        let (duplexer, addr) = listener.accept()?;
        let duplexer = StreamDuplexer::tcp_stream(duplexer);

        return Ok(Interactive {
            name: format!("accept://{}", addr),
            duplexer,
        });
    }

    #[cfg(unix)]
    {
        if url.port().is_some() || url.host_str().is_some() {
            return Err(anyhow!(
                "Unix-domain connect URL should only contain a path"
            ));
        }

        let listener = UnixListener::bind(url.path())?;

        let (duplexer, addr) = listener.accept()?;
        let duplexer = StreamDuplexer::unix_stream(duplexer);
        let name = path_to_name("accept", addr.as_pathname().unwrap())?;

        Ok(Interactive { name, duplexer })
    }

    #[cfg(windows)]
    {
        Err(anyhow!("Unsupported connect URL: {}", url))
    }
}

fn open_path(path: &Path) -> anyhow::Result<Interactive> {
    let name = path_to_name("file", path)?;
    let duplexer = CharDevice::open(path)?;
    let duplexer = StreamDuplexer::char_device(duplexer);
    Ok(Interactive { name, duplexer })
}

#[cfg(not(windows))]
fn spawn_child(os: &OsStr, lossy: &str) -> anyhow::Result<Interactive> {
    use std::process::Command;
    assert!(lossy.starts_with("$("));
    if !lossy.ends_with(')') {
        return Err(anyhow!("child string must end in ')'"));
    }
    let s = if let Some(s) = os.to_str() {
        s
    } else {
        return Err(anyhow!("Non-UTF-8 child strings not yet supported"));
    };
    let words = shell_words::split(&s[2..s.len() - 1])?;
    let (first, rest) = words
        .split_first()
        .ok_or_else(|| anyhow!("child stream specified with '(...)' must contain a command"))?;
    let mut command = Command::new(first);
    command.args(rest);
    let duplexer = StreamDuplexer::duplex_with_command(command)?;
    Ok(Interactive {
        name: lossy.to_owned(),
        duplexer,
    })
}