crdb-core 0.0.1-alpha.0

Concurrently Replicated DataBase
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

use web_time::SystemTime;

pub trait SystemTimeExt {
    fn ms_since_posix(&self) -> crate::Result<i64>;

    fn from_ms_since_posix(ms: i64) -> crate::Result<SystemTime>;
}

impl SystemTimeExt for SystemTime {
    fn ms_since_posix(&self) -> crate::Result<i64> {
        self.duration_since(SystemTime::UNIX_EPOCH)
            .map_err(|_| crate::Error::InvalidTime(*self))?
            .as_millis()
            .try_into()
            .map_err(|_| crate::Error::InvalidTime(*self))
    }

    fn from_ms_since_posix(ms: i64) -> crate::Result<SystemTime> {
        use std::time::Duration;
        let ms = u64::try_from(ms).map_err(|_| {
            crate::Error::Other(anyhow::anyhow!(
                "Cannot convert negative milliseconds into SystemTime"
            ))
        })?;
        Ok(SystemTime::UNIX_EPOCH + Duration::from_millis(ms))
    }
}