awt 0.1.0

A simulation engine which can emulate a client/server with multiple requests.
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

use core::time::Duration;
use serde::Deserialize;
use std::convert::TryFrom;
use std::fs::File;
use std::io::Read;
use std::path::PathBuf;
use thiserror::Error;

mod client;
mod metric;
mod server;

use client::Client;
use metric::Metric;
use server::Server;

#[derive(Deserialize)]
pub struct Config {
    clients: Vec<Client>,
    servers: Vec<Server>,
    metrics: Vec<Metric>,
    #[serde(default)]
    pub simulations: usize,
    pub tick_size: Duration,
    pub tick_until: Duration,
}

#[allow(clippy::module_name_repetitions)]
#[derive(Debug, Error)]
pub enum ConfigError {
    #[error("IOError: Couldn't open file for reading - {0}")]
    IO(#[from] std::io::Error),
    #[error("DeserializationError: Invalid toml contents - {0}")]
    Deserialization(#[from] toml::de::Error),
    #[error("Metric: {0}")]
    Metric(metric::MetricError),
}

impl TryFrom<&PathBuf> for Config {
    type Error = ConfigError;

    fn try_from(path: &PathBuf) -> Result<Self, Self::Error> {
        let mut file = File::open(path)?;
        let mut toml = String::new();

        file.read_to_string(&mut toml)?;

        Ok(toml::from_str::<Config>(&toml)?)
    }
}

impl Config {
    pub fn clients(&self) -> Vec<crate::Client> {
        self.clients
            .iter()
            .flat_map(|client_config| {
                (0..client_config.quantity)
                    .map(|_| crate::Client::from(client_config))
                    .collect::<Vec<crate::Client>>()
            })
            .collect()
    }

    pub fn servers(&self) -> Vec<crate::Server> {
        self.servers
            .iter()
            .flat_map(|server_config| {
                (0..server_config.quantity)
                    .map(|_| crate::Server::from(server_config))
                    .collect::<Vec<crate::Server>>()
            })
            .collect()
    }

    pub fn metrics(&self) -> Result<Vec<crate::Metric>, ConfigError> {
        self.metrics
            .iter()
            .map(crate::Metric::try_from)
            .collect::<Result<Vec<crate::Metric>, metric::MetricError>>()
            .map_err(ConfigError::Metric)
    }
}