nightfury 0.3.0

(DRAFT) toothless is here to help you write code blazingly fast
Documentation 
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

use std::io::Read;
use std::os::unix::net::{UnixListener, UnixStream};
use std::thread;

use lib::protocol::Request;
use serde::Deserialize;

fn handle_client(mut stream: UnixStream) {
    let mut buf = String::new(); // bad
    stream.read_to_string(&mut buf).expect("buf read");
    let req: Request = serde_json::from_str(&buf).expect("Request deserialize");
}

fn main() -> std::io::Result<()> {
    let listener = UnixListener::bind("./nightfury.sock")?;

    // accept connections and process them, spawning a new thread for each one
    for stream in listener.incoming() {
        match stream {
            Ok(stream) => {
                /* connection succeeded */
                thread::spawn(|| handle_client(stream));
            }
            Err(err) => {
                /* connection failed */
                break;
            }
        }
    }
    Ok(())
}