#[cfg(test)]
mod tests {
    use tokio::{
        io::{AsyncReadExt, AsyncWriteExt},
        net::TcpStream,
    };
    use watchmend::common::{
        config::Config,
        handle::{Command, Request, Response},
        task::Task,
    };

    #[tokio::test]
    async fn test_request() {
        let config: Config = Config::init(None).unwrap();
        let host = config.socket.host;
        let port = config.socket.port;
        let mut stream = TcpStream::connect((host, port)).await.unwrap();

        let request = Request {
            command: Command::Run(Task::default()),
        };
        let buf = serde_json::to_vec(&[request]).unwrap();
        stream.write_all(&buf).await.unwrap();

        let mut buf: [u8; 1024] = [0; 1024];
        let n = stream.read(&mut buf).await.unwrap();
        let res: Vec<Response> = serde_json::from_slice(&buf[..n]).unwrap();
        println!("{:#?}", res);
    }
}