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
61
62
63
64
65
|
use crossbeam_channel::Receiver;
use karlcommon::{interfaces::unix_path, version, ClientboundPacket, ServerboundPacket};
use log::{debug, error};
use std::{
io::{BufRead, BufReader, Write},
os::unix::net::UnixStream,
process::exit,
thread,
};
pub struct Client {
socket: UnixStream,
pub busy: bool,
pub receiver: Receiver<ClientboundPacket>,
}
impl Client {
pub fn new() -> Self {
let socket = match UnixStream::connect(unix_path()) {
Ok(s) => s,
Err(e) => {
error!("failed to connect to socket: {}", e);
error!("make sure that karld is running");
exit(1)
}
};
let (sender, receiver) = crossbeam_channel::unbounded();
let mut reader = BufReader::new(socket.try_clone().unwrap());
thread::spawn(move || loop {
let mut buf = String::new();
reader.read_line(&mut buf).unwrap();
let p: ClientboundPacket = serde_json::from_str(buf.as_str()).unwrap();
debug!("<- {:?}", p);
if let ClientboundPacket::Error(e) = p {
error!("daemon reported error: {:?}", e);
} else {
sender.send(p).unwrap();
}
});
let mut c = Self {
receiver,
socket,
busy: true,
};
c.send(ServerboundPacket::Handshake {
version: version!(),
});
c.send(ServerboundPacket::Sync);
return c;
}
pub fn send(&mut self, p: ServerboundPacket) {
debug!("-> {:?}", p);
self.socket
.write_fmt(format_args!("{}\n", serde_json::to_string(&p).unwrap()))
.unwrap()
}
pub fn send_sync(&mut self, p: ServerboundPacket) {
self.busy = true;
self.send(p);
self.send(ServerboundPacket::Sync);
}
}
|
