humphrey_server 0.6.1

A Performance-Focused, Dependency-Free Web Server.
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
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114

#![allow(unused_imports)]
#![allow(dead_code)]

use humphrey_server::config::tree::*;
use std::collections::{BTreeMap, HashMap};

pub const CONF: &str = include_str!("./testcases/valid.conf");

#[test]
fn test_build_tree() {
    #[rustfmt::skip]
    let expected_parsed_conf = ConfigNode::Section("server".into(), vec![
        ConfigNode::String("address".into(), "0.0.0.0".into()),
        ConfigNode::Number("port".into(), "80".into()),
        ConfigNode::Number("threads".into(), "32".into()),
        ConfigNode::String("websocket".into(), "localhost:1234".into()),
        ConfigNode::Number("timeout".into(), "5".into()),
        ConfigNode::Section("plugins".into(), vec![
            ConfigNode::Section("php".into(), vec![
                ConfigNode::String("library".into(), "plugins/php/target/release/php.dll".into()),
                ConfigNode::String("address".into(), "127.0.0.1".into()),
                ConfigNode::Number("port".into(), "9000".into()),
                ConfigNode::Number("threads".into(), "8".into())
            ])
        ]),
        ConfigNode::Section("blacklist".into(), vec![
            ConfigNode::String("mode".into(), "block".into()),
        ]),
        ConfigNode::Section("log".into(), vec![
            ConfigNode::String("level".into(), "info".into()),
            ConfigNode::Boolean("console".into(), "true".into()),
            ConfigNode::String("file".into(), "humphrey.log".into()),
        ]),
        ConfigNode::Section("cache".into(), vec![
            ConfigNode::Number("size".into(), "134217728".into()),
            ConfigNode::Number("time".into(), "60".into())
        ]),
        ConfigNode::Route("/static/*".into(), vec![
            ConfigNode::String("directory".into(), "/var/www".into()),
        ]),
        ConfigNode::Route("/*".into(), vec![
            ConfigNode::String("proxy".into(), "127.0.0.1:8000,127.0.0.1:8080".into()),
            ConfigNode::String("load_balancer_mode".into(), "round-robin".into())
        ])
    ]);

    let parsed_conf = parse_conf(CONF, "valid.conf").unwrap();

    assert_eq!(parsed_conf, expected_parsed_conf);
}

#[test]
#[rustfmt::skip]
fn test_flatten_config() {
    let parsed_conf = parse_conf(CONF, "valid.conf").unwrap();

    let mut expected_hashmap: HashMap<String, ConfigNode> = HashMap::new();
    expected_hashmap.insert("server.address".into(), ConfigNode::String("address".into(), "0.0.0.0".into()));
    expected_hashmap.insert("server.port".into(), ConfigNode::Number("port".into(), "80".into()));
    expected_hashmap.insert("server.threads".into(), ConfigNode::Number("threads".into(), "32".into()));
    expected_hashmap.insert("server.websocket".into(), ConfigNode::String("websocket".into(), "localhost:1234".into()));
    expected_hashmap.insert("server.timeout".into(), ConfigNode::Number("timeout".into(), "5".into()));
    expected_hashmap.insert("server.blacklist.mode".into(), ConfigNode::String("mode".into(), "block".into()));
    expected_hashmap.insert("server.log.level".into(), ConfigNode::String("level".into(), "info".into()));
    expected_hashmap.insert("server.log.console".into(), ConfigNode::Boolean("console".into(), "true".into()));
    expected_hashmap.insert("server.log.file".into(), ConfigNode::String("file".into(), "humphrey.log".into()));
    expected_hashmap.insert("server.cache.size".into(), ConfigNode::Number("size".into(), "134217728".into()));
    expected_hashmap.insert("server.cache.time".into(), ConfigNode::Number("time".into(), "60".into()));

    let mut actual_hashmap: HashMap<String, ConfigNode> = HashMap::new();
    parsed_conf.flatten(&mut actual_hashmap, &Vec::new());

    assert_eq!(actual_hashmap, expected_hashmap);
}

#[test]
#[rustfmt::skip]
fn test_get_routes() {
    let parsed_conf = parse_conf(CONF, "valid.conf").unwrap();

    let mut expected_map: Vec<(String, HashMap<String, ConfigNode>)> = Vec::new();

    let mut static_hashmap: HashMap<String, ConfigNode> = HashMap::new();
    static_hashmap.insert("directory".into(), ConfigNode::String("directory".into(), "/var/www".into()));
    expected_map.push(("/static/*".into(), static_hashmap));

    let mut proxy_hashmap: HashMap<String, ConfigNode> = HashMap::new();
    proxy_hashmap.insert("proxy".into(), ConfigNode::String("proxy".into(), "127.0.0.1:8000,127.0.0.1:8080".into()));
    proxy_hashmap.insert("load_balancer_mode".into(), ConfigNode::String("load_balancer_mode".into(), "round-robin".into()));
    expected_map.push(("/*".into(), proxy_hashmap));

    let routes = parsed_conf.get_routes();

    assert_eq!(routes, expected_map);
}

#[test]
#[rustfmt::skip]
fn test_get_plugins() {
    let parsed_conf = parse_conf(CONF, "valid.conf").unwrap();

    let mut expected_map: Vec<(String, HashMap<String, ConfigNode>)> = Vec::new();

    let mut php_hashmap: HashMap<String, ConfigNode> = HashMap::new();
    php_hashmap.insert("library".into(), ConfigNode::String("library".into(), "plugins/php/target/release/php.dll".into()));
    php_hashmap.insert("address".into(), ConfigNode::String("address".into(), "127.0.0.1".into()));
    php_hashmap.insert("port".into(), ConfigNode::Number("port".into(), "9000".into()));
    php_hashmap.insert("threads".into(), ConfigNode::Number("threads".into(), "8".into()));
    expected_map.push(("php".into(), php_hashmap));

    let plugins = parsed_conf.get_plugins();

    assert_eq!(plugins, expected_map);
}