instrumentality 0.3.0

A data aggregation 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

use std::fs::File;
use std::io::Write;

use crate::config;
use crate::server;

pub const CONFIG_FILE_NAME: &str = "Instrumentality.toml";
pub const EXAMPLE_CONFIG_FILE_NAME: &str = "InstrumentalityExample.toml";

pub async fn instrumentality() {
    let config = config::open(CONFIG_FILE_NAME);
    if let Ok(config) = config {
        server::build_tracing(&config.settings.log_level);
        tracing::info!("Config file loaded.");

        let (app, tls_config, addr, handle) =
            server::build_server(&config.clone()).await;

        let server = axum_server::bind_rustls(addr, tls_config)
            .handle(handle)
            .serve(app.into_make_service());

        tracing::info!("READY: https://{:?}.", addr);
        server.await.unwrap();
    } else {
        server::build_tracing(&config::Settings::default_log_level());

        tracing::error!(
            "Couldn't load {CONFIG_FILE_NAME}, creating an example at \
            {EXAMPLE_CONFIG_FILE_NAME}."
        );

        let mut file = File::create(EXAMPLE_CONFIG_FILE_NAME).unwrap();
        file.write_all(EXAMPLE_CONFIG_FILE).unwrap();
    }
}

const EXAMPLE_CONFIG_FILE: &[u8] = b"[content_types]
instagram = [\"post\", \"story\", \"live\"]
twitter = [\"tweet\", \"like\", \"retweet\", \"story\"]
last_fm = [\"scrobble\"]
twitch_tv = [\"stream_start\", \"video\", \"stream_end\"]

[presence_types]
twitter = [\"follower_count_increase\"]
last_fm = [\"now_playing\"]
twitch_tv = [\"live\"]

[mongodb]
address = \"127.0.0.1\"
port = \"27017\"
database = \"instrumentality\"

[settings]
log_level = \"INFO\"
queue_timeout_secs = 30

[network]
address = \"127.0.0.1\"
port = \"12321\"

[tls]
# Can be taken directly from Let's Encrypt.
cert = \"tls/cert.pem\"
key = \"tls/privkey.pem\"";