jast_lib 0.1.1

minimalist backend framework to practice
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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63


use std::net::TcpListener;
use crate::RouteResponse;
use crate::connection::handle_connection::handle_connection;
use crate::routes::types;
use crate::connection::threadpool::ThreadPool;
use std::sync::Arc;
pub struct Http;
use crate::Builder;

use num_cpus;

impl Http {

    /// Server execution.
    ///
    /// # Arguments
    ///
    /// * settings - Struct of Builder.
    ///
    /// # Returns
    ///
    /// server runtime.
    pub fn create_server(settings: Builder<'static>) {
        let listener = TcpListener::bind(settings.host).unwrap();

        let default_threads = num_cpus::get_physical();

        let pool = ThreadPool::new(default_threads);

        let routes_arc = Arc::new(settings.routes);

        for stream in listener.incoming() {
            let stream = stream.unwrap();
            let routes = routes_arc.clone();

            pool.execute(move || {
                handle_connection(stream, &routes);
            });
        }
    }


    /// Create new route.
    ///
    /// # Arguments
    ///
    /// * route_name - route location.
    /// * response - route response.
    ///
    /// # Returns
    ///
    /// Struct of Routes (method, route, response)
    pub fn route<'a>(route_name: &'static str, response: RouteResponse<'static>) -> types::Routes<'a> {
        let new_route = types::Routes {
            method: response.method,
            route: route_name,
            response: response.res
        };

        new_route
    }
}