Function unix_socket_http_ping

crates/openshell-core/src/config.rs:249–283

(path: &Path, accepts_response: impl FnOnce(&[u8]) -> bool)

#[cfg(unix)]
fn unix_socket_http_ping(path: &Path, accepts_response: impl FnOnce(&[u8]) -> bool) -> bool {
    const PROBE_TIMEOUT: Duration = Duration::from_secs(1);
    const PING_REQUEST: &[u8] =
        b"GET /_ping HTTP/1.1\r\nHost: localhost\r\nConnection: close\r\n\r\n";

    if !is_unix_socket(path) {
        return false;
    }

    let Ok(mut stream) = std::os::unix::net::UnixStream::connect(path) else {
        return false;
    };
    if stream.set_read_timeout(Some(PROBE_TIMEOUT)).is_err()
        || stream.set_write_timeout(Some(PROBE_TIMEOUT)).is_err()
        || stream.write_all(PING_REQUEST).is_err()
    {
        return false;
    }

    let mut response = [0_u8; 512];
    let mut total = 0;
    while total < response.len() {
        let Ok(n) = stream.read(&mut response[total..]) else {
            return false;
        };
        if n == 0 {
            break;
        }
        total += n;
        if contains_ascii(&response[..total], b"\r\n\r\n") {
            break;
        }
    }
    total > 0 && accepts_response(&response[..total])
}

#[cfg(unix)]
fn http_response_is_success(response: &[u8]) -> bool {