oneiros-model 0.0.8

Shared domain types for oneiros
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

use serde::{Deserialize, Serialize};

use crate::*;

#[derive(Debug, thiserror::Error)]
pub enum PressureConstructionError {
    #[error("invalid pressure id: {0}")]
    InvalidId(IdParseError),
    #[error("invalid agent id: {0}")]
    InvalidAgentId(IdParseError),
    #[error("invalid gauge data: {0}")]
    InvalidGauge(#[from] serde_json::Error),
    #[error("invalid updated_at timestamp: {0}")]
    InvalidUpdatedAt(#[from] TimestampParseError),
}

#[derive(Clone, Debug, Serialize, Deserialize, PartialEq, schemars::JsonSchema)]
pub struct Pressure {
    pub id: PressureId,
    pub agent_id: AgentId,
    pub urge: UrgeName,
    pub data: Gauge,
    pub updated_at: Timestamp,
}

impl Pressure {
    pub fn urgency(&self) -> f64 {
        self.data.urgency()
    }

    pub fn construct_from_db(
        (id, agent_id, urge, data, updated_at): (
            impl AsRef<str>,
            impl AsRef<str>,
            impl AsRef<str>,
            impl AsRef<str>,
            impl AsRef<str>,
        ),
    ) -> Result<Self, PressureConstructionError> {
        Ok(Pressure {
            id: id
                .as_ref()
                .parse()
                .map_err(PressureConstructionError::InvalidId)?,
            agent_id: agent_id
                .as_ref()
                .parse()
                .map_err(PressureConstructionError::InvalidAgentId)?,
            urge: UrgeName::new(urge),
            data: serde_json::from_str(data.as_ref())?,
            updated_at: Timestamp::parse_str(updated_at)?,
        })
    }
}

impl core::fmt::Display for Pressure {
    fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
        write!(
            f,
            "{} {:>5.1}% {}",
            self.urge,
            self.urgency() * 100.0,
            self.updated_at
        )
    }
}

domain_id!(PressureId);