hyperlocal-next 0.9.0

Hyper bindings for Unix domain sockets
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
32
33
34
35
36
37
38
39
40
41
42

use hyper::{service::service_fn, Response};
use hyper_util::rt::TokioIo;
use std::{error::Error, fs, path::Path};
use tokio::net::UnixListener;

const PHRASE: &str = "It's a Unix system. I know this.";

// Adapted from https://hyper.rs/guides/1/server/hello-world/
#[tokio::main]
async fn main() -> Result<(), Box<dyn Error + Send + Sync>> {
    let path = Path::new("/tmp/hyperlocal.sock");

    if path.exists() {
        fs::remove_file(path)?;
    }

    let listener = UnixListener::bind(path)?;

    loop {
        let (stream, _) = listener.accept().await?;
        let io = TokioIo::new(stream);

        tokio::task::spawn(async move {
            let svc_fn = service_fn(|_req| async {
                let body = PHRASE.to_string();
                Ok::<_, hyper::Error>(Response::new(body))
            });

            match hyper::server::conn::http1::Builder::new()
                .serve_connection(io, svc_fn)
                .await
            {
                Ok(()) => {
                    println!("Accepted connection.");
                }
                Err(err) => {
                    eprintln!("Failed to accept connection: {err:?}");
                }
            };
        });
    }
}