exocore-core 0.1.26

Core of Exocore (Distributed applications framework)
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

mod atomic_instant;
mod clock;
mod consistent_timestamp;

pub use std::time::Duration;

pub use atomic_instant::AtomicInstant;
pub use chrono::prelude::*;
pub use clock::Clock;
pub use consistent_timestamp::ConsistentTimestamp;
pub use wasm_timer::{Instant, SystemTime, UNIX_EPOCH};

pub fn timestamp_parts_to_datetime(secs: i64, nanos: i32) -> chrono::DateTime<chrono::Utc> {
    chrono::DateTime::from_timestamp(secs, nanos as u32).unwrap_or_default()
}

pub fn timestamp_millis_to_datetime(millis: i64) -> chrono::DateTime<chrono::Utc> {
    let secs = millis / 1000;
    let nanos = (millis - secs * 1000) * 1_000_000;

    timestamp_parts_to_datetime(secs, nanos as i32)
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn timestamp_parts() {
        let date = timestamp_parts_to_datetime(1599492441, 123_000_000);
        assert_eq!("2020-09-07T15:27:21.123+00:00", date.to_rfc3339());
    }

    #[test]
    fn timestamp_millis() {
        let date = timestamp_millis_to_datetime(1599492441123);
        assert_eq!("2020-09-07T15:27:21.123+00:00", date.to_rfc3339());
    }
}