use std::path::Path;

use anyhow::{Context, Result, bail};
use hive_sh4re::{HostRequest, HostResponse};
use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};
use tokio::net::UnixStream;

pub async fn request(socket: &Path, req: HostRequest) -> Result<HostResponse> {
    let stream = UnixStream::connect(socket)
        .await
        .with_context(|| format!("connect to {}", socket.display()))?;
    let (read, mut write) = stream.into_split();

    let mut payload = serde_json::to_string(&req)?;
    payload.push('\n');
    write.write_all(payload.as_bytes()).await?;
    write.flush().await?;

    let mut reader = BufReader::new(read);
    let mut line = String::new();
    reader.read_line(&mut line).await?;
    if line.is_empty() {
        bail!("server closed connection without responding");
    }
    let resp: HostResponse = serde_json::from_str(line.trim())?;
    Ok(resp)
}