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

use std::fmt::Display;

use anyhow::Result;
use serde::{Deserialize, Serialize};
use serde_with::chrono::{NaiveDateTime, Utc};
use uuid::Uuid;

use crate::{traits::UpdateStateFrom, SCMessage, Status};

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct Component {
    pub name: String,
    pub uuid: Option<Uuid>,
    pub status: Status,
    pub last_reading: Option<NaiveDateTime>,
}

impl Component {
    pub fn new(name: &str, uuid: Option<Uuid>) -> Component {
        Self {
            name: name.to_string(),
            uuid,
            status: Status::Uninitialized,
            last_reading: None,
        }
    }

    pub fn with_defaults(name: &str, uuid: Option<Uuid>) -> Self {
        let mut new_comp = Self::new(name, uuid);
        new_comp.status = Status::Coherent;
        new_comp.last_reading = Some(Utc::now().naive_local());

        new_comp
    }

    pub fn update_timeout_status(&mut self, _max_time: NaiveDateTime) {
        if let Some(_last) = self.last_reading {
            todo!()
        }
    }
}

impl UpdateStateFrom<&SCMessage> for Component {
    fn update_state_from(&mut self, message: &SCMessage) -> Result<()> {
        self.last_reading = Some(message.timestamp);
        self.status = Status::Coherent;

        Ok(())
    }
}

impl Display for Component {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        write!(f, "{}", serde_json::to_string_pretty(&self).unwrap())
    }
}