use num_conv::prelude::*;
use serde_core::{Deserialize, Deserializer, Serialize, Serializer};
use crate::OffsetDateTime;
use crate::error::ComponentRange;
#[inline]
pub fn serialize<S>(datetime: &OffsetDateTime, serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
let timestamp = (datetime.unix_timestamp_nanos() / 1_000_000).truncate::<i64>();
timestamp.serialize(serializer)
}
#[inline]
pub fn deserialize<'a, D>(deserializer: D) -> Result<OffsetDateTime, D::Error>
where
D: Deserializer<'a>,
{
let value: i64 = <_>::deserialize(deserializer)?;
OffsetDateTime::from_unix_timestamp_nanos(value.extend::<i128>() * 1_000_000)
.map_err(ComponentRange::into_de_error)
}
pub mod option {
use super::*;
#[inline]
pub fn serialize<S>(option: &Option<OffsetDateTime>, serializer: S) -> Result<S::Ok, S::Error>
where
S: Serializer,
{
option
.map(|timestamp| (timestamp.unix_timestamp_nanos() / 1_000_000).truncate::<i64>())
.serialize(serializer)
}
#[inline]
pub fn deserialize<'a, D>(deserializer: D) -> Result<Option<OffsetDateTime>, D::Error>
where
D: Deserializer<'a>,
{
Option::deserialize(deserializer)?
.map(|value: i64| {
OffsetDateTime::from_unix_timestamp_nanos(value.extend::<i128>() * 1_000_000)
})
.transpose()
.map_err(ComponentRange::into_de_error)
}
}