infrarust 1.1.0

A Rust adaptation of the Infrared Minecraft proxy
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 log::debug;
use std::{collections::HashMap, sync::Arc};
use tokio::sync::RwLock;
use wildmatch::WildMatch;

use crate::core::config::ServerConfig;

#[derive(Clone)]
pub struct ConfigurationService {
    configurations: Arc<RwLock<HashMap<String, Arc<ServerConfig>>>>,
}

impl Default for ConfigurationService {
    fn default() -> Self {
        Self::new()
    }
}

impl ConfigurationService {
    pub fn new() -> Self {
        Self {
            configurations: Arc::new(RwLock::new(HashMap::new())),
        }
    }

    pub async fn find_server_by_domain(&self, domain: &str) -> Option<Arc<ServerConfig>> {
        debug!("Finding server by domain: {}", domain);
        let domain = domain.to_lowercase();
        let configs = self.configurations.read().await;
        configs
            .values()
            .find(|server| {
                server
                    .domains
                    .iter()
                    .any(|pattern| WildMatch::new(pattern).matches(&domain))
            })
            .cloned()
    }

    pub async fn find_server_by_ip(&self, ip: &str) -> Option<Arc<ServerConfig>> {
        debug!("Finding server by ip: {}", ip);
        let configs = self.configurations.read().await;
        configs
            .iter()
            .find(|(_, server)| server.addresses.contains(&ip.to_string()))
            .map(|(_, server)| Arc::clone(server))
    }

    pub async fn update_configurations(&self, configs: Vec<ServerConfig>) {
        debug!("Updating configurations with length: {}", configs.len());
        let mut config_lock = self.configurations.write().await;
        for config in configs {
            config_lock.insert(config.config_id.clone(), Arc::new(config));
        }
    }

    pub async fn remove_configuration(&self, config_id: &str) {
        debug!("Removing configuration with id: {}", config_id);
        let mut config_lock = self.configurations.write().await;
        config_lock.remove(config_id);
    }
}