#!/bin/sh
export RUN_DIR="/tmp/tmp.4y3mPdtiZB-tmpdir"
./target/release/histdb-rs server -c "${RUN_DIR}/cache" -d "${RUN_DIR}/datadir" -s "${RUN_DIR}/socket"

#[derive(Debug, Serialize, Deserialize)]

#[derive(Debug, Serialize, Deserialize, Clone)]

#[derive(Debug, Serialize, Deserialize)]

#[derive(Debug, Serialize, Deserialize, Clone)]

    /// Run benchmark against server
    #[structopt(name = "bench")]
    Bench(Socket),

                SubCommand::Bench(s) => run::bench(s.socket_path),

pub fn bench(socket_path: PathBuf) -> Result<(), Error> {
    let client = client::new(socket_path);
    let mut start = CommandStart {
        command: "test".to_string(),
        hostname: "test_hostname".to_string(),
        pwd: PathBuf::from("/tmp/test_pwd"),
        session_id: Uuid::new_v4(),
        time_stamp: Utc::now(),
        user: "test_user".to_string(),
    };

    let mut finished = CommandFinished {
        session_id: start.session_id.clone(),
        time_stamp: Utc::now(),
        result: 0,
    };
    loop {
        start.time_stamp = Utc::now();
        let message = Message::CommandStart(start.clone());
        client.send(&message).expect("ignore");
        finished.time_stamp = Utc::now();
        let message = Message::CommandFinished(finished.clone());
        client.send(&message).expect("ignore");
    }
}

        let (data_sender, data_receiver) = flume::unbounded();

        let (data_sender, data_receiver) = flume::bounded(10_000);