histdb-rs 2.0.1

Better history management for zsh. Based on ideas from [https://github.com/larkery/zsh-histdb](https://github.com/larkery/zsh-histdb).
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

use super::{
    db,
    Server,
};
use crate::store;
use crossbeam_utils::sync::WaitGroup;
use std::{
    os::unix::net::UnixDatagram,
    path::PathBuf,
    sync::{
        atomic::AtomicBool,
        Arc,
    },
};
use thiserror::Error;

#[derive(Error, Debug)]
pub enum Error {
    #[error("no parent directory for socket path")]
    NoSocketPathParent,

    #[error("can not create socket parent directory: {0}")]
    CreateSocketPathParent(std::io::Error),

    #[error("can not bind to socket: {0}")]
    BindSocket(std::io::Error),

    #[error("{0}")]
    Db(#[from] db::Error),
}

pub struct Builder {
    pub(super) cache_dir: PathBuf,
    pub(super) data_dir: PathBuf,
    pub(super) socket: PathBuf,
}

impl Builder {
    pub fn build(self) -> Result<Server, Error> {
        let db = db::new(self.cache_dir)?;

        let socket_path_parent = self.socket.parent().ok_or(Error::NoSocketPathParent)?;
        std::fs::create_dir_all(socket_path_parent).map_err(Error::CreateSocketPathParent)?;
        let socket = UnixDatagram::bind(&self.socket).map_err(Error::BindSocket)?;

        let store = store::new(self.data_dir);

        let stopping = Arc::new(AtomicBool::new(false));
        let wait_group = WaitGroup::new();

        Ok(Server {
            db,
            socket,
            socket_path: self.socket,
            store,
            stopping,
            wait_group,
        })
    }
}