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
use super::{Connect, ReadWrite};
use crate::error::{ClientErrorKind, Result};
use std::os::unix::net::UnixStream;
use std::path::PathBuf;
use std::time::Duration;
const DEFAULT_SOCKET_PATH: &str = "/tmp/security-daemon-socket";
const DEFAULT_TIMEOUT: Duration = Duration::from_secs(1);
#[derive(Debug, Clone)]
pub struct Handler {
path: PathBuf,
timeout: Option<Duration>,
}
impl Connect for Handler {
fn connect(&self) -> Result<Box<dyn ReadWrite>> {
let stream = UnixStream::connect(self.path.clone()).map_err(ClientErrorKind::Ipc)?;
stream
.set_read_timeout(self.timeout)
.map_err(ClientErrorKind::Ipc)?;
stream
.set_write_timeout(self.timeout)
.map_err(ClientErrorKind::Ipc)?;
Ok(Box::from(stream))
}
fn set_timeout(&mut self, timeout: Option<Duration>) {
self.timeout = timeout;
}
}
impl Handler {
pub fn new(path: PathBuf, timeout: Option<Duration>) -> Self {
Handler { path, timeout }
}
}
impl Default for Handler {
fn default() -> Self {
Handler {
path: DEFAULT_SOCKET_PATH.into(),
timeout: Some(DEFAULT_TIMEOUT),
}
}
}