mirror of
https://github.com/chronotope/chrono.git
synced 2025-09-27 04:50:52 +00:00
1134 lines
35 KiB
Rust
1134 lines
35 KiB
Rust
#![cfg_attr(docsrs, doc(cfg(feature = "serde")))]
|
|
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::NaiveDateTime;
|
|
use crate::offset::LocalResult;
|
|
|
|
/// Serialize a `NaiveDateTime` as an RFC 3339 string
|
|
///
|
|
/// See [the `serde` module](./serde/index.html) for alternate
|
|
/// serialization formats.
|
|
impl ser::Serialize for NaiveDateTime {
|
|
fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
struct FormatWrapped<'a, D: 'a> {
|
|
inner: &'a D,
|
|
}
|
|
|
|
impl<'a, D: fmt::Debug> fmt::Display for FormatWrapped<'a, D> {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
self.inner.fmt(f)
|
|
}
|
|
}
|
|
|
|
serializer.collect_str(&FormatWrapped { inner: &self })
|
|
}
|
|
}
|
|
|
|
struct NaiveDateTimeVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for NaiveDateTimeVisitor {
|
|
type Value = NaiveDateTime;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a formatted date and time string")
|
|
}
|
|
|
|
fn visit_str<E>(self, value: &str) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
value.parse().map_err(E::custom)
|
|
}
|
|
}
|
|
|
|
impl<'de> de::Deserialize<'de> for NaiveDateTime {
|
|
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
deserializer.deserialize_str(NaiveDateTimeVisitor)
|
|
}
|
|
}
|
|
|
|
/// Used to serialize/deserialize from nanosecond-precision timestamps
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::{Deserialize, Serialize};
|
|
/// use chrono::naive::serde::ts_nanoseconds;
|
|
/// #[derive(Deserialize, Serialize)]
|
|
/// struct S {
|
|
/// #[serde(with = "ts_nanoseconds")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let time = NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_nano_opt(02, 04, 59, 918355733).unwrap();
|
|
/// let my_s = S {
|
|
/// time: time.clone(),
|
|
/// };
|
|
///
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918355733}"#);
|
|
/// let my_s: S = serde_json::from_str(&as_string)?;
|
|
/// assert_eq!(my_s.time, time);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub mod ts_nanoseconds {
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::ne_timestamp;
|
|
use crate::NaiveDateTime;
|
|
|
|
/// Serialize a datetime into an integer number of nanoseconds since the epoch
|
|
///
|
|
/// Intended for use with `serde`s `serialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Serialize;
|
|
/// use chrono::naive::serde::ts_nanoseconds::serialize as to_nano_ts;
|
|
/// #[derive(Serialize)]
|
|
/// struct S {
|
|
/// #[serde(serialize_with = "to_nano_ts")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let my_s = S {
|
|
/// time: NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_nano_opt(02, 04, 59, 918355733).unwrap(),
|
|
/// };
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918355733}"#);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn serialize<S>(dt: &NaiveDateTime, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
serializer.serialize_i64(dt.timestamp_nanos())
|
|
}
|
|
|
|
/// Deserialize a `NaiveDateTime` from a nanoseconds timestamp
|
|
///
|
|
/// Intended for use with `serde`s `deserialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::NaiveDateTime;
|
|
/// # use serde_derive::Deserialize;
|
|
/// use chrono::naive::serde::ts_nanoseconds::deserialize as from_nano_ts;
|
|
/// #[derive(Deserialize)]
|
|
/// struct S {
|
|
/// #[serde(deserialize_with = "from_nano_ts")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let my_s: S = serde_json::from_str(r#"{ "time": 1526522699918355733 }"#)?;
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn deserialize<'de, D>(d: D) -> Result<NaiveDateTime, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_i64(NanoSecondsTimestampVisitor)
|
|
}
|
|
|
|
pub(super) struct NanoSecondsTimestampVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for NanoSecondsTimestampVisitor {
|
|
type Value = NaiveDateTime;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a unix timestamp")
|
|
}
|
|
|
|
fn visit_i64<E>(self, value: i64) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
NaiveDateTime::from_timestamp_opt(value / 1_000_000_000, (value % 1_000_000_000) as u32)
|
|
.ok_or_else(|| E::custom(ne_timestamp(value)))
|
|
}
|
|
|
|
fn visit_u64<E>(self, value: u64) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
NaiveDateTime::from_timestamp_opt(
|
|
value as i64 / 1_000_000_000,
|
|
(value as i64 % 1_000_000_000) as u32,
|
|
)
|
|
.ok_or_else(|| E::custom(ne_timestamp(value)))
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Ser/de to/from optional timestamps in nanoseconds
|
|
///
|
|
/// Intended for use with `serde`'s `with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::{Deserialize, Serialize};
|
|
/// use chrono::naive::serde::ts_nanoseconds_option;
|
|
/// #[derive(Deserialize, Serialize)]
|
|
/// struct S {
|
|
/// #[serde(with = "ts_nanoseconds_option")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let time = Some(NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_nano_opt(02, 04, 59, 918355733).unwrap());
|
|
/// let my_s = S {
|
|
/// time: time.clone(),
|
|
/// };
|
|
///
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918355733}"#);
|
|
/// let my_s: S = serde_json::from_str(&as_string)?;
|
|
/// assert_eq!(my_s.time, time);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub mod ts_nanoseconds_option {
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::ts_nanoseconds::NanoSecondsTimestampVisitor;
|
|
use crate::NaiveDateTime;
|
|
|
|
/// Serialize a datetime into an integer number of nanoseconds since the epoch or none
|
|
///
|
|
/// Intended for use with `serde`s `serialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Serialize;
|
|
/// use chrono::naive::serde::ts_nanoseconds_option::serialize as to_nano_tsopt;
|
|
/// #[derive(Serialize)]
|
|
/// struct S {
|
|
/// #[serde(serialize_with = "to_nano_tsopt")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let my_s = S {
|
|
/// time: Some(NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_nano_opt(02, 04, 59, 918355733).unwrap()),
|
|
/// };
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918355733}"#);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn serialize<S>(opt: &Option<NaiveDateTime>, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
match *opt {
|
|
Some(ref dt) => serializer.serialize_some(&dt.timestamp_nanos()),
|
|
None => serializer.serialize_none(),
|
|
}
|
|
}
|
|
|
|
/// Deserialize a `NaiveDateTime` from a nanosecond timestamp or none
|
|
///
|
|
/// Intended for use with `serde`s `deserialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Deserialize;
|
|
/// use chrono::naive::serde::ts_nanoseconds_option::deserialize as from_nano_tsopt;
|
|
/// #[derive(Deserialize)]
|
|
/// struct S {
|
|
/// #[serde(deserialize_with = "from_nano_tsopt")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let my_s: S = serde_json::from_str(r#"{ "time": 1526522699918355733 }"#)?;
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn deserialize<'de, D>(d: D) -> Result<Option<NaiveDateTime>, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_option(OptionNanoSecondsTimestampVisitor)
|
|
}
|
|
|
|
struct OptionNanoSecondsTimestampVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for OptionNanoSecondsTimestampVisitor {
|
|
type Value = Option<NaiveDateTime>;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a unix timestamp in nanoseconds or none")
|
|
}
|
|
|
|
/// Deserialize a timestamp in nanoseconds since the epoch
|
|
fn visit_some<D>(self, d: D) -> Result<Self::Value, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_i64(NanoSecondsTimestampVisitor).map(Some)
|
|
}
|
|
|
|
/// Deserialize a timestamp in nanoseconds since the epoch
|
|
fn visit_none<E>(self) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
Ok(None)
|
|
}
|
|
|
|
/// Deserialize a timestamp in nanoseconds since the epoch
|
|
fn visit_unit<E>(self) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
Ok(None)
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Used to serialize/deserialize from microsecond-precision timestamps
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::{Deserialize, Serialize};
|
|
/// use chrono::naive::serde::ts_microseconds;
|
|
/// #[derive(Deserialize, Serialize)]
|
|
/// struct S {
|
|
/// #[serde(with = "ts_microseconds")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let time = NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_micro_opt(02, 04, 59, 918355).unwrap();
|
|
/// let my_s = S {
|
|
/// time: time.clone(),
|
|
/// };
|
|
///
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918355}"#);
|
|
/// let my_s: S = serde_json::from_str(&as_string)?;
|
|
/// assert_eq!(my_s.time, time);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub mod ts_microseconds {
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::ne_timestamp;
|
|
use crate::NaiveDateTime;
|
|
|
|
/// Serialize a datetime into an integer number of microseconds since the epoch
|
|
///
|
|
/// Intended for use with `serde`s `serialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Serialize;
|
|
/// use chrono::naive::serde::ts_microseconds::serialize as to_micro_ts;
|
|
/// #[derive(Serialize)]
|
|
/// struct S {
|
|
/// #[serde(serialize_with = "to_micro_ts")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let my_s = S {
|
|
/// time: NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_micro_opt(02, 04, 59, 918355).unwrap(),
|
|
/// };
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918355}"#);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn serialize<S>(dt: &NaiveDateTime, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
serializer.serialize_i64(dt.timestamp_micros())
|
|
}
|
|
|
|
/// Deserialize a `NaiveDateTime` from a microseconds timestamp
|
|
///
|
|
/// Intended for use with `serde`s `deserialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::NaiveDateTime;
|
|
/// # use serde_derive::Deserialize;
|
|
/// use chrono::naive::serde::ts_microseconds::deserialize as from_micro_ts;
|
|
/// #[derive(Deserialize)]
|
|
/// struct S {
|
|
/// #[serde(deserialize_with = "from_micro_ts")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let my_s: S = serde_json::from_str(r#"{ "time": 1526522699918355 }"#)?;
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn deserialize<'de, D>(d: D) -> Result<NaiveDateTime, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_i64(MicroSecondsTimestampVisitor)
|
|
}
|
|
|
|
pub(super) struct MicroSecondsTimestampVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for MicroSecondsTimestampVisitor {
|
|
type Value = NaiveDateTime;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a unix timestamp")
|
|
}
|
|
|
|
fn visit_i64<E>(self, value: i64) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
NaiveDateTime::from_timestamp_opt(
|
|
value / 1_000_000,
|
|
((value % 1_000_000) * 1000) as u32,
|
|
)
|
|
.ok_or_else(|| E::custom(ne_timestamp(value)))
|
|
}
|
|
|
|
fn visit_u64<E>(self, value: u64) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
NaiveDateTime::from_timestamp_opt(
|
|
(value / 1_000_000) as i64,
|
|
((value % 1_000_000) * 1_000) as u32,
|
|
)
|
|
.ok_or_else(|| E::custom(ne_timestamp(value)))
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Ser/de to/from optional timestamps in microseconds
|
|
///
|
|
/// Intended for use with `serde`'s `with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::{Deserialize, Serialize};
|
|
/// use chrono::naive::serde::ts_microseconds_option;
|
|
/// #[derive(Deserialize, Serialize)]
|
|
/// struct S {
|
|
/// #[serde(with = "ts_microseconds_option")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let time = Some(NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_micro_opt(02, 04, 59, 918355).unwrap());
|
|
/// let my_s = S {
|
|
/// time: time.clone(),
|
|
/// };
|
|
///
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918355}"#);
|
|
/// let my_s: S = serde_json::from_str(&as_string)?;
|
|
/// assert_eq!(my_s.time, time);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub mod ts_microseconds_option {
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::ts_microseconds::MicroSecondsTimestampVisitor;
|
|
use crate::NaiveDateTime;
|
|
|
|
/// Serialize a datetime into an integer number of microseconds since the epoch or none
|
|
///
|
|
/// Intended for use with `serde`s `serialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Serialize;
|
|
/// use chrono::naive::serde::ts_microseconds_option::serialize as to_micro_tsopt;
|
|
/// #[derive(Serialize)]
|
|
/// struct S {
|
|
/// #[serde(serialize_with = "to_micro_tsopt")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let my_s = S {
|
|
/// time: Some(NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_micro_opt(02, 04, 59, 918355).unwrap()),
|
|
/// };
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918355}"#);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn serialize<S>(opt: &Option<NaiveDateTime>, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
match *opt {
|
|
Some(ref dt) => serializer.serialize_some(&dt.timestamp_micros()),
|
|
None => serializer.serialize_none(),
|
|
}
|
|
}
|
|
|
|
/// Deserialize a `NaiveDateTime` from a nanosecond timestamp or none
|
|
///
|
|
/// Intended for use with `serde`s `deserialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Deserialize;
|
|
/// use chrono::naive::serde::ts_microseconds_option::deserialize as from_micro_tsopt;
|
|
/// #[derive(Deserialize)]
|
|
/// struct S {
|
|
/// #[serde(deserialize_with = "from_micro_tsopt")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let my_s: S = serde_json::from_str(r#"{ "time": 1526522699918355 }"#)?;
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn deserialize<'de, D>(d: D) -> Result<Option<NaiveDateTime>, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_option(OptionMicroSecondsTimestampVisitor)
|
|
}
|
|
|
|
struct OptionMicroSecondsTimestampVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for OptionMicroSecondsTimestampVisitor {
|
|
type Value = Option<NaiveDateTime>;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a unix timestamp in microseconds or none")
|
|
}
|
|
|
|
/// Deserialize a timestamp in microseconds since the epoch
|
|
fn visit_some<D>(self, d: D) -> Result<Self::Value, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_i64(MicroSecondsTimestampVisitor).map(Some)
|
|
}
|
|
|
|
/// Deserialize a timestamp in microseconds since the epoch
|
|
fn visit_none<E>(self) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
Ok(None)
|
|
}
|
|
|
|
/// Deserialize a timestamp in microseconds since the epoch
|
|
fn visit_unit<E>(self) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
Ok(None)
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Used to serialize/deserialize from millisecond-precision timestamps
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::{Deserialize, Serialize};
|
|
/// use chrono::naive::serde::ts_milliseconds;
|
|
/// #[derive(Deserialize, Serialize)]
|
|
/// struct S {
|
|
/// #[serde(with = "ts_milliseconds")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let time = NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_milli_opt(02, 04, 59, 918).unwrap();
|
|
/// let my_s = S {
|
|
/// time: time.clone(),
|
|
/// };
|
|
///
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918}"#);
|
|
/// let my_s: S = serde_json::from_str(&as_string)?;
|
|
/// assert_eq!(my_s.time, time);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub mod ts_milliseconds {
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::ne_timestamp;
|
|
use crate::NaiveDateTime;
|
|
|
|
/// Serialize a datetime into an integer number of milliseconds since the epoch
|
|
///
|
|
/// Intended for use with `serde`s `serialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Serialize;
|
|
/// use chrono::naive::serde::ts_milliseconds::serialize as to_milli_ts;
|
|
/// #[derive(Serialize)]
|
|
/// struct S {
|
|
/// #[serde(serialize_with = "to_milli_ts")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let my_s = S {
|
|
/// time: NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_milli_opt(02, 04, 59, 918).unwrap(),
|
|
/// };
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918}"#);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn serialize<S>(dt: &NaiveDateTime, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
serializer.serialize_i64(dt.timestamp_millis())
|
|
}
|
|
|
|
/// Deserialize a `NaiveDateTime` from a milliseconds timestamp
|
|
///
|
|
/// Intended for use with `serde`s `deserialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::NaiveDateTime;
|
|
/// # use serde_derive::Deserialize;
|
|
/// use chrono::naive::serde::ts_milliseconds::deserialize as from_milli_ts;
|
|
/// #[derive(Deserialize)]
|
|
/// struct S {
|
|
/// #[serde(deserialize_with = "from_milli_ts")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let my_s: S = serde_json::from_str(r#"{ "time": 1526522699918 }"#)?;
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn deserialize<'de, D>(d: D) -> Result<NaiveDateTime, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_i64(MilliSecondsTimestampVisitor)
|
|
}
|
|
|
|
pub(super) struct MilliSecondsTimestampVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for MilliSecondsTimestampVisitor {
|
|
type Value = NaiveDateTime;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a unix timestamp")
|
|
}
|
|
|
|
fn visit_i64<E>(self, value: i64) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
NaiveDateTime::from_timestamp_opt(value / 1000, ((value % 1000) * 1_000_000) as u32)
|
|
.ok_or_else(|| E::custom(ne_timestamp(value)))
|
|
}
|
|
|
|
fn visit_u64<E>(self, value: u64) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
NaiveDateTime::from_timestamp_opt(
|
|
(value / 1000) as i64,
|
|
((value % 1000) * 1_000_000) as u32,
|
|
)
|
|
.ok_or_else(|| E::custom(ne_timestamp(value)))
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Ser/de to/from optional timestamps in milliseconds
|
|
///
|
|
/// Intended for use with `serde`'s `with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::{Deserialize, Serialize};
|
|
/// use chrono::naive::serde::ts_milliseconds_option;
|
|
/// #[derive(Deserialize, Serialize)]
|
|
/// struct S {
|
|
/// #[serde(with = "ts_milliseconds_option")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let time = Some(NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_milli_opt(02, 04, 59, 918).unwrap());
|
|
/// let my_s = S {
|
|
/// time: time.clone(),
|
|
/// };
|
|
///
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918}"#);
|
|
/// let my_s: S = serde_json::from_str(&as_string)?;
|
|
/// assert_eq!(my_s.time, time);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub mod ts_milliseconds_option {
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::ts_milliseconds::MilliSecondsTimestampVisitor;
|
|
use crate::NaiveDateTime;
|
|
|
|
/// Serialize a datetime into an integer number of milliseconds since the epoch or none
|
|
///
|
|
/// Intended for use with `serde`s `serialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Serialize;
|
|
/// use chrono::naive::serde::ts_milliseconds_option::serialize as to_milli_tsopt;
|
|
/// #[derive(Serialize)]
|
|
/// struct S {
|
|
/// #[serde(serialize_with = "to_milli_tsopt")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let my_s = S {
|
|
/// time: Some(NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_milli_opt(02, 04, 59, 918).unwrap()),
|
|
/// };
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699918}"#);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn serialize<S>(opt: &Option<NaiveDateTime>, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
match *opt {
|
|
Some(ref dt) => serializer.serialize_some(&dt.timestamp_millis()),
|
|
None => serializer.serialize_none(),
|
|
}
|
|
}
|
|
|
|
/// Deserialize a `NaiveDateTime` from a nanosecond timestamp or none
|
|
///
|
|
/// Intended for use with `serde`s `deserialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Deserialize;
|
|
/// use chrono::naive::serde::ts_milliseconds_option::deserialize as from_milli_tsopt;
|
|
/// #[derive(Deserialize)]
|
|
/// struct S {
|
|
/// #[serde(deserialize_with = "from_milli_tsopt")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let my_s: S = serde_json::from_str(r#"{ "time": 1526522699918355 }"#)?;
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn deserialize<'de, D>(d: D) -> Result<Option<NaiveDateTime>, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_option(OptionMilliSecondsTimestampVisitor)
|
|
}
|
|
|
|
struct OptionMilliSecondsTimestampVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for OptionMilliSecondsTimestampVisitor {
|
|
type Value = Option<NaiveDateTime>;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a unix timestamp in milliseconds or none")
|
|
}
|
|
|
|
/// Deserialize a timestamp in milliseconds since the epoch
|
|
fn visit_some<D>(self, d: D) -> Result<Self::Value, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_i64(MilliSecondsTimestampVisitor).map(Some)
|
|
}
|
|
|
|
/// Deserialize a timestamp in milliseconds since the epoch
|
|
fn visit_none<E>(self) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
Ok(None)
|
|
}
|
|
|
|
/// Deserialize a timestamp in milliseconds since the epoch
|
|
fn visit_unit<E>(self) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
Ok(None)
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Used to serialize/deserialize from second-precision timestamps
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::{Deserialize, Serialize};
|
|
/// use chrono::naive::serde::ts_seconds;
|
|
/// #[derive(Deserialize, Serialize)]
|
|
/// struct S {
|
|
/// #[serde(with = "ts_seconds")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let time = NaiveDate::from_ymd_opt(2015, 5, 15).unwrap().and_hms_opt(10, 0, 0).unwrap();
|
|
/// let my_s = S {
|
|
/// time: time.clone(),
|
|
/// };
|
|
///
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1431684000}"#);
|
|
/// let my_s: S = serde_json::from_str(&as_string)?;
|
|
/// assert_eq!(my_s.time, time);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub mod ts_seconds {
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::ne_timestamp;
|
|
use crate::NaiveDateTime;
|
|
|
|
/// Serialize a datetime into an integer number of seconds since the epoch
|
|
///
|
|
/// Intended for use with `serde`s `serialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Serialize;
|
|
/// use chrono::naive::serde::ts_seconds::serialize as to_ts;
|
|
/// #[derive(Serialize)]
|
|
/// struct S {
|
|
/// #[serde(serialize_with = "to_ts")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let my_s = S {
|
|
/// time: NaiveDate::from_ymd_opt(2015, 5, 15).unwrap().and_hms_opt(10, 0, 0).unwrap(),
|
|
/// };
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1431684000}"#);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn serialize<S>(dt: &NaiveDateTime, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
serializer.serialize_i64(dt.timestamp())
|
|
}
|
|
|
|
/// Deserialize a `NaiveDateTime` from a seconds timestamp
|
|
///
|
|
/// Intended for use with `serde`s `deserialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::NaiveDateTime;
|
|
/// # use serde_derive::Deserialize;
|
|
/// use chrono::naive::serde::ts_seconds::deserialize as from_ts;
|
|
/// #[derive(Deserialize)]
|
|
/// struct S {
|
|
/// #[serde(deserialize_with = "from_ts")]
|
|
/// time: NaiveDateTime
|
|
/// }
|
|
///
|
|
/// let my_s: S = serde_json::from_str(r#"{ "time": 1431684000 }"#)?;
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn deserialize<'de, D>(d: D) -> Result<NaiveDateTime, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_i64(SecondsTimestampVisitor)
|
|
}
|
|
|
|
pub(super) struct SecondsTimestampVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for SecondsTimestampVisitor {
|
|
type Value = NaiveDateTime;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a unix timestamp")
|
|
}
|
|
|
|
fn visit_i64<E>(self, value: i64) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
NaiveDateTime::from_timestamp_opt(value, 0)
|
|
.ok_or_else(|| E::custom(ne_timestamp(value)))
|
|
}
|
|
|
|
fn visit_u64<E>(self, value: u64) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
NaiveDateTime::from_timestamp_opt(value as i64, 0)
|
|
.ok_or_else(|| E::custom(ne_timestamp(value)))
|
|
}
|
|
}
|
|
}
|
|
|
|
/// Ser/de to/from optional timestamps in seconds
|
|
///
|
|
/// Intended for use with `serde`'s `with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::{Deserialize, Serialize};
|
|
/// use chrono::naive::serde::ts_seconds_option;
|
|
/// #[derive(Deserialize, Serialize)]
|
|
/// struct S {
|
|
/// #[serde(with = "ts_seconds_option")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let time = Some(NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_opt(02, 04, 59).unwrap());
|
|
/// let my_s = S {
|
|
/// time: time.clone(),
|
|
/// };
|
|
///
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699}"#);
|
|
/// let my_s: S = serde_json::from_str(&as_string)?;
|
|
/// assert_eq!(my_s.time, time);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub mod ts_seconds_option {
|
|
use core::fmt;
|
|
use serde::{de, ser};
|
|
|
|
use super::ts_seconds::SecondsTimestampVisitor;
|
|
use crate::NaiveDateTime;
|
|
|
|
/// Serialize a datetime into an integer number of seconds since the epoch or none
|
|
///
|
|
/// Intended for use with `serde`s `serialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Serialize;
|
|
/// use chrono::naive::serde::ts_seconds_option::serialize as to_tsopt;
|
|
/// #[derive(Serialize)]
|
|
/// struct S {
|
|
/// #[serde(serialize_with = "to_tsopt")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let my_s = S {
|
|
/// time: Some(NaiveDate::from_ymd_opt(2018, 5, 17).unwrap().and_hms_opt(02, 04, 59).unwrap()),
|
|
/// };
|
|
/// let as_string = serde_json::to_string(&my_s)?;
|
|
/// assert_eq!(as_string, r#"{"time":1526522699}"#);
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn serialize<S>(opt: &Option<NaiveDateTime>, serializer: S) -> Result<S::Ok, S::Error>
|
|
where
|
|
S: ser::Serializer,
|
|
{
|
|
match *opt {
|
|
Some(ref dt) => serializer.serialize_some(&dt.timestamp()),
|
|
None => serializer.serialize_none(),
|
|
}
|
|
}
|
|
|
|
/// Deserialize a `NaiveDateTime` from a second timestamp or none
|
|
///
|
|
/// Intended for use with `serde`s `deserialize_with` attribute.
|
|
///
|
|
/// # Example:
|
|
///
|
|
/// ```rust
|
|
/// # use chrono::naive::{NaiveDate, NaiveDateTime};
|
|
/// # use serde_derive::Deserialize;
|
|
/// use chrono::naive::serde::ts_seconds_option::deserialize as from_tsopt;
|
|
/// #[derive(Deserialize)]
|
|
/// struct S {
|
|
/// #[serde(deserialize_with = "from_tsopt")]
|
|
/// time: Option<NaiveDateTime>
|
|
/// }
|
|
///
|
|
/// let my_s: S = serde_json::from_str(r#"{ "time": 1431684000 }"#)?;
|
|
/// # Ok::<(), serde_json::Error>(())
|
|
/// ```
|
|
pub fn deserialize<'de, D>(d: D) -> Result<Option<NaiveDateTime>, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_option(OptionSecondsTimestampVisitor)
|
|
}
|
|
|
|
struct OptionSecondsTimestampVisitor;
|
|
|
|
impl<'de> de::Visitor<'de> for OptionSecondsTimestampVisitor {
|
|
type Value = Option<NaiveDateTime>;
|
|
|
|
fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result {
|
|
formatter.write_str("a unix timestamp in seconds or none")
|
|
}
|
|
|
|
/// Deserialize a timestamp in seconds since the epoch
|
|
fn visit_some<D>(self, d: D) -> Result<Self::Value, D::Error>
|
|
where
|
|
D: de::Deserializer<'de>,
|
|
{
|
|
d.deserialize_i64(SecondsTimestampVisitor).map(Some)
|
|
}
|
|
|
|
/// Deserialize a timestamp in seconds since the epoch
|
|
fn visit_none<E>(self) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
Ok(None)
|
|
}
|
|
|
|
/// Deserialize a timestamp in seconds since the epoch
|
|
fn visit_unit<E>(self) -> Result<Self::Value, E>
|
|
where
|
|
E: de::Error,
|
|
{
|
|
Ok(None)
|
|
}
|
|
}
|
|
}
|
|
|
|
#[test]
|
|
fn test_serde_serialize() {
|
|
super::test_encodable_json(serde_json::to_string);
|
|
}
|
|
|
|
#[test]
|
|
fn test_serde_deserialize() {
|
|
super::test_decodable_json(|input| serde_json::from_str(input));
|
|
}
|
|
|
|
// Bincode is relevant to test separately from JSON because
|
|
// it is not self-describing.
|
|
#[test]
|
|
fn test_serde_bincode() {
|
|
use crate::NaiveDate;
|
|
use bincode::{deserialize, serialize};
|
|
|
|
let dt = NaiveDate::from_ymd_opt(2016, 7, 8).unwrap().and_hms_milli_opt(9, 10, 48, 90).unwrap();
|
|
let encoded = serialize(&dt).unwrap();
|
|
let decoded: NaiveDateTime = deserialize(&encoded).unwrap();
|
|
assert_eq!(dt, decoded);
|
|
}
|
|
|
|
#[test]
|
|
fn test_serde_bincode_optional() {
|
|
use crate::prelude::*;
|
|
use crate::serde::ts_nanoseconds_option;
|
|
use bincode::{deserialize, serialize};
|
|
use serde_derive::{Deserialize, Serialize};
|
|
|
|
#[derive(Debug, PartialEq, Eq, Serialize, Deserialize)]
|
|
struct Test {
|
|
one: Option<i64>,
|
|
#[serde(with = "ts_nanoseconds_option")]
|
|
two: Option<DateTime<Utc>>,
|
|
}
|
|
|
|
let expected =
|
|
Test { one: Some(1), two: Some(Utc.with_ymd_and_hms(1970, 1, 1, 0, 1, 1).unwrap()) };
|
|
let bytes: Vec<u8> = serialize(&expected).unwrap();
|
|
let actual = deserialize::<Test>(&(bytes)).unwrap();
|
|
|
|
assert_eq!(expected, actual);
|
|
}
|
|
|
|
// lik? function to convert a LocalResult into a serde-ish Result
|
|
pub(crate) fn serde_from<T, E, V>(me: LocalResult<T>, ts: &V) -> Result<T, E>
|
|
where
|
|
E: de::Error,
|
|
V: fmt::Display,
|
|
T: fmt::Display,
|
|
{
|
|
match me {
|
|
LocalResult::None => Err(E::custom(ne_timestamp(ts))),
|
|
LocalResult::Ambiguous(min, max) => {
|
|
Err(E::custom(SerdeError::Ambiguous { timestamp: ts, min, max }))
|
|
}
|
|
LocalResult::Single(val) => Ok(val),
|
|
}
|
|
}
|
|
|
|
enum SerdeError<V: fmt::Display, D: fmt::Display> {
|
|
NonExistent { timestamp: V },
|
|
Ambiguous { timestamp: V, min: D, max: D },
|
|
}
|
|
|
|
/// Construct a [`SerdeError::NonExistent`]
|
|
fn ne_timestamp<T: fmt::Display>(ts: T) -> SerdeError<T, u8> {
|
|
SerdeError::NonExistent::<T, u8> { timestamp: ts }
|
|
}
|
|
|
|
impl<V: fmt::Display, D: fmt::Display> fmt::Debug for SerdeError<V, D> {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
write!(f, "ChronoSerdeError({})", self)
|
|
}
|
|
}
|
|
|
|
// impl<V: fmt::Display, D: fmt::Debug> core::error::Error for SerdeError<V, D> {}
|
|
impl<V: fmt::Display, D: fmt::Display> fmt::Display for SerdeError<V, D> {
|
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
|
match self {
|
|
SerdeError::NonExistent { timestamp } => {
|
|
write!(f, "value is not a legal timestamp: {}", timestamp)
|
|
}
|
|
SerdeError::Ambiguous { timestamp, min, max } => write!(
|
|
f,
|
|
"value is an ambiguous timestamp: {}, could be either of {}, {}",
|
|
timestamp, min, max
|
|
),
|
|
}
|
|
}
|
|
}
|