scraps 3.7.0

Scraps is a portable CLI knowledge hub for managing interconnected Markdown documentation with Wiki-link notation.
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

use std::{
    net::SocketAddr,
    path::{Path, PathBuf},
};

use crate::usecase::serve::service::ScrapsService;
use hyper::server::conn::http1;
use hyper_util::rt::TokioIo;
use tokio::net::TcpListener;

use crate::error::ScrapsResult;

pub struct ServeUsecase {
    output_dir_path: PathBuf,
}

impl ServeUsecase {
    pub fn new(output_dir_path: &Path) -> ServeUsecase {
        ServeUsecase {
            output_dir_path: output_dir_path.to_path_buf(),
        }
    }

    #[tokio::main]
    pub async fn execute(&self, addr: &SocketAddr) -> ScrapsResult<()> {
        let listener = TcpListener::bind(&addr).await?;

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

            let service = ScrapsService::new(&self.output_dir_path);
            tokio::task::spawn(async move {
                if let Err(err) = http1::Builder::new().serve_connection(io, service).await {
                    println!("Failed to serve connection: {err:?}");
                }
            });
        }
    }
}