romp 0.5.2

STOMP server and WebSockets platform
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

//! Contains global objects started during bootstrap, this is principally the `CONFIG` which provides
//! access to data in `romp.toml`, `SERVER` which contains the destinations (queues and topics)
//! and `USER` which contains configured users and functions to authenticate users.

use std::fs;

use crate::config;
use crate::config::config::CONFIG_FILE;
use crate::config::config::ServerConfig;
use crate::config::user::UserConfig;
use crate::workflow::console::ngin::Ngin;
use crate::workflow::destination::server::DestinationServer;

// Static initialization routines
// such statics are not native rust and IDE does not support this.
lazy_static! {

    pub static ref CONFIG: ServerConfig = {

        config::log::init_log4rs();

        let mut conf_path = String::from("./conf");
        if let Ok(var) = std::env::var("ROMP_CONF") {
            conf_path = String::from(var.as_str());
        }

        conf_path.push('/');
        conf_path.push_str(CONFIG_FILE);

        match fs::read_to_string(conf_path) {
            Ok(conf_data) => {
                let mut conf: ServerConfig = toml::from_str(&conf_data).unwrap();
                conf.init();
                return conf;
            }
            Err(e) => {
                eprintln!("loading config failed: {} {}", CONFIG_FILE, e);
                panic!();
            }
        }
    };

    pub static ref SERVER : DestinationServer = {
        let mut server = DestinationServer::new();
        server.init(&CONFIG);
        server
    };

    pub static ref USER: UserConfig = {
        let mut user = UserConfig::new();
        if let Some(user_file) = &CONFIG.user_file {
            let mut user_path: String;
            if user_file.starts_with("/") {
                user_path = user_file.to_string();
            } else {
                let mut conf_path = String::from("./conf");
                if let Ok(var) = std::env::var("ROMP_CONF") {
                    conf_path = var;
                }
                user_path = conf_path;
                user_path.push('/');
                user_path.push_str(user_file);
            }
            user.init(&user_path);
        }
        user
    };

    pub static ref NGIN: Ngin = {
        Ngin::new()
    };
}

// N.B. if code does not reference the refs they are never initialized.